ezsp 5.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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

//! Parameters for the [`Configuration::add_endpoint`](crate::Configuration::add_endpoint) command.

use std::iter::{Chain, FlatMap};

use le_stream::{FromLeStream, ToLeStream};
use num_traits::FromPrimitive;

use crate::Error;
use crate::ezsp::Status;
use crate::frame::Parameter;
use crate::frame::responds_with::RespondsWith;
use crate::types::ByteSizedVec;

const ID: u16 = 0x0002;

#[derive(Clone, Debug, Eq, PartialEq, ToLeStream)]
pub(crate) struct Command {
    endpoint: u8,
    profile_id: u16,
    device_id: u16,
    app_flags: u8,
    clusters: Clusters,
}

impl Command {
    #[must_use]
    pub fn new(
        endpoint: u8,
        profile_id: u16,
        device_id: u16,
        app_flags: u8,
        input_cluster_list: ByteSizedVec<u16>,
        output_cluster_list: ByteSizedVec<u16>,
    ) -> Self {
        Self {
            endpoint,
            profile_id,
            device_id,
            app_flags,
            clusters: Clusters::new(input_cluster_list, output_cluster_list),
        }
    }
}

/// Helper struct to deal with special serialization of the cluster lists.
#[derive(Clone, Debug, Eq, PartialEq)]
pub(crate) struct Clusters {
    input_cluster_counts: u8,
    output_cluster_counts: u8,
    #[expect(clippy::struct_field_names)]
    input_clusters: ByteSizedVec<u16>,
    #[expect(clippy::struct_field_names)]
    output_clusters: ByteSizedVec<u16>,
}

impl Clusters {
    #[must_use]
    pub fn new(input_clusters: ByteSizedVec<u16>, output_clusters: ByteSizedVec<u16>) -> Self {
        Self {
            #[expect(clippy::cast_possible_truncation)]
            input_cluster_counts: input_clusters.len() as u8,
            #[expect(clippy::cast_possible_truncation)]
            output_cluster_counts: output_clusters.len() as u8,
            input_clusters,
            output_clusters,
        }
    }
}

impl ToLeStream for Clusters {
    type Iter = Chain<
        Chain<
            Chain<<u8 as ToLeStream>::Iter, <u8 as ToLeStream>::Iter>,
            FlatMap<
                <ByteSizedVec<u16> as IntoIterator>::IntoIter,
                <u16 as ToLeStream>::Iter,
                fn(u16) -> <u16 as ToLeStream>::Iter,
            >,
        >,
        FlatMap<
            <ByteSizedVec<u16> as IntoIterator>::IntoIter,
            <u16 as ToLeStream>::Iter,
            fn(u16) -> <u16 as ToLeStream>::Iter,
        >,
    >;

    fn to_le_stream(self) -> Self::Iter {
        #[expect(trivial_casts)]
        self.input_cluster_counts
            .to_le_stream()
            .chain(self.output_cluster_counts.to_le_stream())
            .chain(
                self.input_clusters
                    .into_iter()
                    .flat_map(ToLeStream::to_le_stream as _),
            )
            .chain(
                self.output_clusters
                    .into_iter()
                    .flat_map(ToLeStream::to_le_stream as _),
            )
    }
}

impl Parameter for Command {
    const ID: u16 = ID;
}

impl RespondsWith for Command {
    type Response = Response;
}

/// Response parameters.
#[derive(Clone, Debug, Eq, PartialEq, FromLeStream)]
pub struct Response {
    status: u8,
}

impl Parameter for Response {
    const ID: u16 = ID;
}

/// Converts the response into `()` or an appropriate [`Error`] depending on its status.
impl TryFrom<Response> for () {
    type Error = Error;

    fn try_from(response: Response) -> Result<Self, Self::Error> {
        match Status::from_u8(response.status).ok_or(response.status) {
            Ok(Status::Success) => Ok(()),
            other => Err(other.into()),
        }
    }
}