rustbac_client/
lib.rs

1//! High-level async BACnet client.
2//!
3//! [`BacnetClient`] wraps any [`DataLink`](rustbac_datalink::DataLink)
4//! transport and exposes ergonomic methods for common BACnet operations
5//! such as reading properties, discovering devices, and subscribing to
6//! change-of-value (COV) notifications.
7
8/// Alarm and event services (GetAlarmSummary, GetEventInformation, etc.).
9pub mod alarm;
10/// Core [`BacnetClient`] type and transport setup.
11pub mod client;
12/// Change-of-value (COV) notification types.
13pub mod cov;
14/// COV subscriptions with renewal and polling failover.
15pub mod cov_manager;
16/// Device and object discovery (Who-Is / I-Am / Who-Has).
17pub mod discovery;
18/// Client-level error type.
19pub mod error;
20/// Atomic file read/write operations.
21pub mod file;
22/// Long-running async notification listener.
23pub mod listener;
24/// Point type inference for BACnet objects.
25pub mod point;
26/// ReadRange results and related types.
27pub mod range;
28/// Schedule and Calendar convenience helpers.
29pub mod schedule;
30/// BACnet server/responder implementation.
31pub mod server;
32/// Lightweight simulated BACnet device.
33pub mod simulator;
34/// Per-device request throttling utility.
35pub mod throttle;
36/// Owned application-data values for client-side use.
37pub mod value;
38/// Device discovery walk — reads all objects and their properties.
39pub mod walk;
40
41pub use alarm::{
42    AlarmSummaryItem, EnrollmentSummaryItem, EventInformationItem, EventInformationResult,
43    EventNotification,
44};
45pub use client::{BacnetClient, ForeignDeviceRenewal};
46pub use cov::{CovNotification, CovPropertyValue};
47pub use cov_manager::{
48    CovManager, CovManagerBuilder, CovSubscriptionSpec, CovUpdate, UpdateSource,
49};
50pub use discovery::{DiscoveredDevice, DiscoveredObject};
51pub use error::ClientError;
52pub use file::{AtomicReadFileResult, AtomicWriteFileResult};
53pub use listener::{create_notification_listener, Notification, NotificationListener};
54pub use point::{PointClassification, PointDirection, PointKind};
55pub use range::{ClientBitString, ReadRangeResult};
56pub use rustbac_bacnet_sc::BacnetScTransport;
57pub use rustbac_core::services::acknowledge_alarm::{EventState, TimeStamp};
58pub use rustbac_core::services::device_management::{DeviceCommunicationState, ReinitializeState};
59pub use rustbac_datalink::bip::transport::{BroadcastDistributionEntry, ForeignDeviceTableEntry};
60pub use schedule::{CalendarEntry, DateRange, TimeValue};
61pub use server::{
62    BacnetServer, BacnetServiceError, ObjectStore, ObjectStoreHandler, ServiceHandler,
63};
64pub use simulator::SimulatedDevice;
65pub use throttle::DeviceThrottle;
66pub use value::ClientDataValue;
67pub use walk::{DeviceInfo, DeviceWalkResult, ObjectSummary};
68
69// Internal helpers used by simulator module.
70use rustbac_core::encoding::{primitives::decode_unsigned, reader::Reader, tag::Tag};
71use rustbac_core::types::ObjectId;
72
73fn decode_ctx_unsigned(r: &mut Reader<'_>) -> Result<u32, ClientError> {
74    match Tag::decode(r)? {
75        Tag::Context { len, .. } => Ok(decode_unsigned(r, len as usize)?),
76        _ => Err(ClientError::UnsupportedResponse),
77    }
78}
79
80fn decode_ctx_object_id(r: &mut Reader<'_>) -> Result<ObjectId, ClientError> {
81    Ok(ObjectId::from_raw(decode_ctx_unsigned(r)?))
82}
83
84fn data_value_to_client(value: rustbac_core::types::DataValue<'_>) -> ClientDataValue {
85    match value {
86        rustbac_core::types::DataValue::Null => ClientDataValue::Null,
87        rustbac_core::types::DataValue::Boolean(v) => ClientDataValue::Boolean(v),
88        rustbac_core::types::DataValue::Unsigned(v) => ClientDataValue::Unsigned(v),
89        rustbac_core::types::DataValue::Signed(v) => ClientDataValue::Signed(v),
90        rustbac_core::types::DataValue::Real(v) => ClientDataValue::Real(v),
91        rustbac_core::types::DataValue::Double(v) => ClientDataValue::Double(v),
92        rustbac_core::types::DataValue::OctetString(v) => ClientDataValue::OctetString(v.to_vec()),
93        rustbac_core::types::DataValue::CharacterString(v) => {
94            ClientDataValue::CharacterString(v.to_string())
95        }
96        rustbac_core::types::DataValue::BitString(v) => ClientDataValue::BitString {
97            unused_bits: v.unused_bits,
98            data: v.data.to_vec(),
99        },
100        rustbac_core::types::DataValue::Enumerated(v) => ClientDataValue::Enumerated(v),
101        rustbac_core::types::DataValue::Date(v) => ClientDataValue::Date(v),
102        rustbac_core::types::DataValue::Time(v) => ClientDataValue::Time(v),
103        rustbac_core::types::DataValue::ObjectId(v) => ClientDataValue::ObjectId(v),
104        rustbac_core::types::DataValue::Constructed { tag_num, values } => {
105            ClientDataValue::Constructed {
106                tag_num,
107                values: values.into_iter().map(data_value_to_client).collect(),
108            }
109        }
110    }
111}
rustbac_client/lib.rs

rustbac_client/
lib.rs
