bacnet-server 0.8.1

BACnet server: APDU dispatch and service handlers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! Schedule execution engine.
//!
//! Periodically evaluates Schedule objects and writes the effective value
//! to all controlled object-property references.

use std::sync::Arc;
use std::time::{SystemTime, UNIX_EPOCH};

use bacnet_objects::database::ObjectDatabase;
use bacnet_types::enums::{ObjectType, PropertyIdentifier};
use tokio::sync::RwLock;
use tracing::{debug, warn};

/// Compute (day_of_week, hour, minute) from the current time with UTC offset.
///
/// day_of_week: 0=Monday .. 6=Sunday (matching BACnet weekly_schedule index).
/// `utc_offset_minutes`: offset from UTC in minutes (e.g. -300 for US Eastern).
fn current_time_components(utc_offset_minutes: i16) -> (u8, u8, u8) {
    let secs = SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap_or_default()
        .as_secs();
    let local_secs = (secs as i64 + (utc_offset_minutes as i64) * 60) as u64;
    let day_of_week = ((local_secs / 86400 + 3) % 7) as u8;
    let time_of_day = local_secs % 86400;
    let hour = (time_of_day / 3600) as u8;
    let minute = ((time_of_day % 3600) / 60) as u8;
    (day_of_week, hour, minute)
}

/// Evaluate all Schedule objects and write to their controlled properties.
///
/// Called periodically by the server (every 60 seconds). Uses the current
/// system time (with UTC offset) to determine the active schedule value.
/// `utc_offset_minutes`: device's UTC offset (from Device object UTC_Offset property).
pub async fn tick_schedules(db: &Arc<RwLock<ObjectDatabase>>, utc_offset_minutes: i16) {
    let (day_of_week, hour, minute) = current_time_components(utc_offset_minutes);

    let mut writes = Vec::new();
    {
        let mut db_w = db.write().await;
        let schedule_oids = db_w.find_by_type(ObjectType::SCHEDULE);
        for oid in schedule_oids {
            if let Some(obj) = db_w.get_mut(&oid) {
                if let Some((value, refs)) = obj.tick_schedule(day_of_week, hour, minute) {
                    debug!(
                        schedule = %oid,
                        refs = refs.len(),
                        "Schedule value changed, writing to controlled properties"
                    );
                    for (target_oid, prop_id) in refs {
                        writes.push((target_oid, prop_id, value.clone()));
                    }
                }
            }
        }

        for (target_oid, prop_id, value) in writes {
            if let Some(target_obj) = db_w.get_mut(&target_oid) {
                let prop = PropertyIdentifier::from_raw(prop_id);
                if let Err(e) = target_obj.write_property(prop, None, value, None) {
                    warn!(
                        target = %target_oid,
                        property = prop_id,
                        error = %e,
                        "Schedule failed to write to controlled property"
                    );
                }
            }
        }
    }
}