ezsp 11.0.0

Ember ZNet Serial Protocol
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

//! Conversion implementations between EZSP callback data and `apis-saltans` types.
//!
//! These conversions are used by the feature-gated NCP driver adapter and event
//! handler. They translate incoming APS frames, endpoint descriptors, scan
//! results, join/leave callbacks, and stack status callbacks into the types
//! expected by `apis_saltans_hw` and the EZSP endpoint registration command.

use apis_saltans_hw::aps::data::Header;
use apis_saltans_hw::aps::{Data, Destination};
use apis_saltans_hw::core::{Endpoint, GroupId};
use bytes::Bytes;

pub use self::error::ParseApsFrameError;
use crate::DefragmentedMessage;
use crate::ember::message::Incoming;

mod address;
mod clusters;
mod envelope;
mod error;
mod event;
mod found_network;
mod metadata;
mod scanned_channel;

impl TryFrom<DefragmentedMessage> for Data<Bytes> {
    type Error = ParseApsFrameError;

    fn try_from(message: DefragmentedMessage) -> Result<Self, Self::Error> {
        let aps_frame = message.aps_frame();
        let typ = message.typ().map_err(ParseApsFrameError::MessageType)?;

        let destination_endpoint = aps_frame.destination_endpoint();
        let destination = match typ {
            Incoming::Broadcast | Incoming::BroadcastLoopback => Destination::Broadcast(
                Endpoint::try_from(destination_endpoint)
                    .map_err(ParseApsFrameError::InvalidEndpoint)?,
            ),
            Incoming::Unicast | Incoming::UnicastReply => Destination::Unicast(
                Endpoint::try_from(destination_endpoint)
                    .map_err(ParseApsFrameError::InvalidEndpoint)?,
            ),
            Incoming::Multicast | Incoming::MulticastLoopback => Destination::Group(
                GroupId::try_from(aps_frame.group_id()).map_err(ParseApsFrameError::GroupId)?,
            ),
            Incoming::ManyToOneRouteRequest => unreachable!("EZSP does not allow this."),
        };

        let source_endpoint = Endpoint::try_from(aps_frame.source_endpoint())
            .map_err(|endpoint| ParseApsFrameError::SourceEndpoint(endpoint.into()))?;

        let header = Header::new(
            destination,
            aps_frame.cluster_id(),
            aps_frame.profile_id(),
            source_endpoint,
            aps_frame.sequence(),
            None,
        );
        Ok(Self::raw(
            header,
            message.into_message().into_iter().collect(),
        ))
    }
}