matter-clusters 0.3.0

//! GeneralDiagnostics cluster (0x0033).
//! @generated by `cargo xtask codegen` — do not edit.

#![allow(
    clippy::all,
    clippy::pedantic,
    dead_code,
    unreachable_pub,
    unused_imports
)]

use crate::datatypes::SemanticTagStruct;
use crate::error::ClusterError;
use crate::types::Nullable;
use matter_codec::{ContainerKind, Element, Tag, TlvReader, TlvWriter, Value};

/// Cluster ID.
pub const CLUSTER_ID: u32 = 0x0033;
/// Cluster revision.
pub const CLUSTER_REVISION: u16 = 2;

/// Command IDs (requests and responses).
pub mod command_id {
    /// `TestEventTrigger` (request).
    pub const TEST_EVENT_TRIGGER: u32 = 0x00;
    /// `TimeSnapshot` (request).
    pub const TIME_SNAPSHOT: u32 = 0x01;
    /// `TimeSnapshotResponse` (response).
    pub const TIME_SNAPSHOT_RESPONSE: u32 = 0x02;
    /// `PayloadTestRequest` (request).
    pub const PAYLOAD_TEST_REQUEST: u32 = 0x03;
    /// `PayloadTestResponse` (response).
    pub const PAYLOAD_TEST_RESPONSE: u32 = 0x04;
}

/// Attribute IDs (cluster-specific).
pub mod attribute_id {
    /// `NetworkInterfaces`.
    pub const NETWORK_INTERFACES: u32 = 0x0000;
    /// `RebootCount`.
    pub const REBOOT_COUNT: u32 = 0x0001;
    /// `UpTime`.
    pub const UP_TIME: u32 = 0x0002;
    /// `TotalOperationalHours`.
    pub const TOTAL_OPERATIONAL_HOURS: u32 = 0x0003;
    /// `BootReason`.
    pub const BOOT_REASON: u32 = 0x0004;
    /// `ActiveHardwareFaults`.
    pub const ACTIVE_HARDWARE_FAULTS: u32 = 0x0005;
    /// `ActiveRadioFaults`.
    pub const ACTIVE_RADIO_FAULTS: u32 = 0x0006;
    /// `ActiveNetworkFaults`.
    pub const ACTIVE_NETWORK_FAULTS: u32 = 0x0007;
    /// `TestEventTriggersEnabled`.
    pub const TEST_EVENT_TRIGGERS_ENABLED: u32 = 0x0008;
}

bitflags::bitflags! {
    /// `GeneralDiagnostics` feature bits (FeatureMap).
    #[derive(Copy, Clone, Debug, PartialEq, Eq, Hash)]
    pub struct Feature: u32 {
        /// DataModelTest (DMTEST).
        const DMTEST = 1 << 0;
    }
}

/// `BootReasonEnum` (enum8).
#[derive(Copy, Clone, Debug, PartialEq, Eq)]
pub enum BootReasonEnum {
    /// Unspecified = 0.
    Unspecified,
    /// PowerOnReboot = 1.
    PowerOnReboot,
    /// BrownOutReset = 2.
    BrownOutReset,
    /// SoftwareWatchdogReset = 3.
    SoftwareWatchdogReset,
    /// HardwareWatchdogReset = 4.
    HardwareWatchdogReset,
    /// SoftwareUpdateCompleted = 5.
    SoftwareUpdateCompleted,
    /// SoftwareReset = 6.
    SoftwareReset,
    /// A value not known to this codegen revision.
    Unknown(u8),
}

impl BootReasonEnum {
    /// Decode from its raw discriminant (unknown → `Unknown`).
    #[must_use]
    pub fn from_raw(v: u8) -> Self {
        match v {
            0 => Self::Unspecified,
            1 => Self::PowerOnReboot,
            2 => Self::BrownOutReset,
            3 => Self::SoftwareWatchdogReset,
            4 => Self::HardwareWatchdogReset,
            5 => Self::SoftwareUpdateCompleted,
            6 => Self::SoftwareReset,
            other => Self::Unknown(other),
        }
    }
    /// The raw discriminant.
    #[must_use]
    pub fn to_raw(self) -> u8 {
        match self {
            Self::Unspecified => 0,
            Self::PowerOnReboot => 1,
            Self::BrownOutReset => 2,
            Self::SoftwareWatchdogReset => 3,
            Self::HardwareWatchdogReset => 4,
            Self::SoftwareUpdateCompleted => 5,
            Self::SoftwareReset => 6,
            Self::Unknown(v) => v,
        }
    }
}

/// `HardwareFaultEnum` (enum8).
#[derive(Copy, Clone, Debug, PartialEq, Eq)]
pub enum HardwareFaultEnum {
    /// Unspecified = 0.
    Unspecified,
    /// Radio = 1.
    Radio,
    /// Sensor = 2.
    Sensor,
    /// ResettableOverTemp = 3.
    ResettableOverTemp,
    /// NonResettableOverTemp = 4.
    NonResettableOverTemp,
    /// PowerSource = 5.
    PowerSource,
    /// VisualDisplayFault = 6.
    VisualDisplayFault,
    /// AudioOutputFault = 7.
    AudioOutputFault,
    /// UserInterfaceFault = 8.
    UserInterfaceFault,
    /// NonVolatileMemoryError = 9.
    NonVolatileMemoryError,
    /// TamperDetected = 10.
    TamperDetected,
    /// A value not known to this codegen revision.
    Unknown(u8),
}

impl HardwareFaultEnum {
    /// Decode from its raw discriminant (unknown → `Unknown`).
    #[must_use]
    pub fn from_raw(v: u8) -> Self {
        match v {
            0 => Self::Unspecified,
            1 => Self::Radio,
            2 => Self::Sensor,
            3 => Self::ResettableOverTemp,
            4 => Self::NonResettableOverTemp,
            5 => Self::PowerSource,
            6 => Self::VisualDisplayFault,
            7 => Self::AudioOutputFault,
            8 => Self::UserInterfaceFault,
            9 => Self::NonVolatileMemoryError,
            10 => Self::TamperDetected,
            other => Self::Unknown(other),
        }
    }
    /// The raw discriminant.
    #[must_use]
    pub fn to_raw(self) -> u8 {
        match self {
            Self::Unspecified => 0,
            Self::Radio => 1,
            Self::Sensor => 2,
            Self::ResettableOverTemp => 3,
            Self::NonResettableOverTemp => 4,
            Self::PowerSource => 5,
            Self::VisualDisplayFault => 6,
            Self::AudioOutputFault => 7,
            Self::UserInterfaceFault => 8,
            Self::NonVolatileMemoryError => 9,
            Self::TamperDetected => 10,
            Self::Unknown(v) => v,
        }
    }
}

/// `InterfaceTypeEnum` (enum8).
#[derive(Copy, Clone, Debug, PartialEq, Eq)]
pub enum InterfaceTypeEnum {
    /// Unspecified = 0.
    Unspecified,
    /// WiFi = 1.
    WiFi,
    /// Ethernet = 2.
    Ethernet,
    /// Cellular = 3.
    Cellular,
    /// Thread = 4.
    Thread,
    /// A value not known to this codegen revision.
    Unknown(u8),
}

impl InterfaceTypeEnum {
    /// Decode from its raw discriminant (unknown → `Unknown`).
    #[must_use]
    pub fn from_raw(v: u8) -> Self {
        match v {
            0 => Self::Unspecified,
            1 => Self::WiFi,
            2 => Self::Ethernet,
            3 => Self::Cellular,
            4 => Self::Thread,
            other => Self::Unknown(other),
        }
    }
    /// The raw discriminant.
    #[must_use]
    pub fn to_raw(self) -> u8 {
        match self {
            Self::Unspecified => 0,
            Self::WiFi => 1,
            Self::Ethernet => 2,
            Self::Cellular => 3,
            Self::Thread => 4,
            Self::Unknown(v) => v,
        }
    }
}

/// `NetworkFaultEnum` (enum8).
#[derive(Copy, Clone, Debug, PartialEq, Eq)]
pub enum NetworkFaultEnum {
    /// Unspecified = 0.
    Unspecified,
    /// HardwareFailure = 1.
    HardwareFailure,
    /// NetworkJammed = 2.
    NetworkJammed,
    /// ConnectionFailed = 3.
    ConnectionFailed,
    /// A value not known to this codegen revision.
    Unknown(u8),
}

impl NetworkFaultEnum {
    /// Decode from its raw discriminant (unknown → `Unknown`).
    #[must_use]
    pub fn from_raw(v: u8) -> Self {
        match v {
            0 => Self::Unspecified,
            1 => Self::HardwareFailure,
            2 => Self::NetworkJammed,
            3 => Self::ConnectionFailed,
            other => Self::Unknown(other),
        }
    }
    /// The raw discriminant.
    #[must_use]
    pub fn to_raw(self) -> u8 {
        match self {
            Self::Unspecified => 0,
            Self::HardwareFailure => 1,
            Self::NetworkJammed => 2,
            Self::ConnectionFailed => 3,
            Self::Unknown(v) => v,
        }
    }
}

/// `NetworkInterface` struct.
#[derive(Clone, Debug, PartialEq)]
#[non_exhaustive]
pub struct NetworkInterface {
    /// Field Name (tag 0).
    pub name: String,
    /// Field IsOperational (tag 1).
    pub is_operational: bool,
    /// Field OffPremiseServicesReachableIPv4 (tag 2).
    pub off_premise_services_reachable_i_pv4: Nullable<bool>,
    /// Field OffPremiseServicesReachableIPv6 (tag 3).
    pub off_premise_services_reachable_i_pv6: Nullable<bool>,
    /// Field HardwareAddress (tag 4).
    pub hardware_address: Vec<u8>,
    /// Field IPv4Addresses (tag 5).
    pub i_pv4_addresses: Vec<Vec<u8>>,
    /// Field IPv6Addresses (tag 6).
    pub i_pv6_addresses: Vec<Vec<u8>>,
    /// Field Type (tag 7).
    pub r#type: InterfaceTypeEnum,
}

/// `RadioFaultEnum` (enum8).
#[derive(Copy, Clone, Debug, PartialEq, Eq)]
pub enum RadioFaultEnum {
    /// Unspecified = 0.
    Unspecified,
    /// WiFiFault = 1.
    WiFiFault,
    /// CellularFault = 2.
    CellularFault,
    /// ThreadFault = 3.
    ThreadFault,
    /// NfcFault = 4.
    NfcFault,
    /// BleFault = 5.
    BleFault,
    /// EthernetFault = 6.
    EthernetFault,
    /// A value not known to this codegen revision.
    Unknown(u8),
}

impl RadioFaultEnum {
    /// Decode from its raw discriminant (unknown → `Unknown`).
    #[must_use]
    pub fn from_raw(v: u8) -> Self {
        match v {
            0 => Self::Unspecified,
            1 => Self::WiFiFault,
            2 => Self::CellularFault,
            3 => Self::ThreadFault,
            4 => Self::NfcFault,
            5 => Self::BleFault,
            6 => Self::EthernetFault,
            other => Self::Unknown(other),
        }
    }
    /// The raw discriminant.
    #[must_use]
    pub fn to_raw(self) -> u8 {
        match self {
            Self::Unspecified => 0,
            Self::WiFiFault => 1,
            Self::CellularFault => 2,
            Self::ThreadFault => 3,
            Self::NfcFault => 4,
            Self::BleFault => 5,
            Self::EthernetFault => 6,
            Self::Unknown(v) => v,
        }
    }
}

impl NetworkInterface {
    /// Decode the fields of an already-opened anonymous structure
    /// (reader positioned after the struct start; consumes to its end).
    ///
    /// # Errors
    /// Returns [`ClusterError`] on a malformed structure or missing required field.
    pub fn decode_from(r: &mut TlvReader<'_>) -> Result<Self, ClusterError> {
        let mut f_name: Option<String> = None;
        let mut f_is_operational: Option<bool> = None;
        let mut f_off_premise_services_reachable_i_pv4: Option<Nullable<bool>> = None;
        let mut f_off_premise_services_reachable_i_pv6: Option<Nullable<bool>> = None;
        let mut f_hardware_address: Option<Vec<u8>> = None;
        let mut f_i_pv4_addresses: Option<Vec<Vec<u8>>> = None;
        let mut f_i_pv6_addresses: Option<Vec<Vec<u8>>> = None;
        let mut f_type: Option<InterfaceTypeEnum> = None;
        loop {
            match r.next()? {
                Some(Element::ContainerEnd) => break,
                Some(Element::Scalar {
                    tag: Tag::Context(0),
                    value: Value::Utf8(v),
                }) => f_name = Some(v),
                Some(Element::Scalar {
                    tag: Tag::Context(1),
                    value: Value::Bool(v),
                }) => f_is_operational = Some(v),
                Some(Element::Scalar {
                    tag: Tag::Context(2),
                    value: Value::Null,
                }) => f_off_premise_services_reachable_i_pv4 = Some(Nullable::Null),
                Some(Element::Scalar {
                    tag: Tag::Context(2),
                    value: Value::Bool(v),
                }) => f_off_premise_services_reachable_i_pv4 = Some(Nullable::Value(v)),
                Some(Element::Scalar {
                    tag: Tag::Context(3),
                    value: Value::Null,
                }) => f_off_premise_services_reachable_i_pv6 = Some(Nullable::Null),
                Some(Element::Scalar {
                    tag: Tag::Context(3),
                    value: Value::Bool(v),
                }) => f_off_premise_services_reachable_i_pv6 = Some(Nullable::Value(v)),
                Some(Element::Scalar {
                    tag: Tag::Context(4),
                    value: Value::Bytes(v),
                }) => f_hardware_address = Some(v),
                Some(Element::ContainerStart {
                    tag: Tag::Context(5),
                    kind: ContainerKind::Array,
                }) => {
                    let mut out = Vec::new();
                    loop {
                        match r.next()? {
                            Some(Element::ContainerEnd) => break,
                            Some(Element::Scalar {
                                value: Value::Bytes(v),
                                ..
                            }) => out.push(v),
                            None => {
                                return Err(ClusterError::Tlv(
                                    matter_codec::Error::UnclosedContainer,
                                ))
                            }
                            Some(Element::ContainerStart { .. }) => r.skip_container()?,
                            Some(_) => {} // skip unknown scalar
                        }
                    }
                    f_i_pv4_addresses = Some(out);
                }
                Some(Element::ContainerStart {
                    tag: Tag::Context(6),
                    kind: ContainerKind::Array,
                }) => {
                    let mut out = Vec::new();
                    loop {
                        match r.next()? {
                            Some(Element::ContainerEnd) => break,
                            Some(Element::Scalar {
                                value: Value::Bytes(v),
                                ..
                            }) => out.push(v),
                            None => {
                                return Err(ClusterError::Tlv(
                                    matter_codec::Error::UnclosedContainer,
                                ))
                            }
                            Some(Element::ContainerStart { .. }) => r.skip_container()?,
                            Some(_) => {} // skip unknown scalar
                        }
                    }
                    f_i_pv6_addresses = Some(out);
                }
                Some(Element::Scalar {
                    tag: Tag::Context(7),
                    value: Value::Uint(v),
                }) => {
                    f_type = Some(InterfaceTypeEnum::from_raw(
                        u8::try_from(v).map_err(|_| ClusterError::InvalidLength("Type"))?,
                    ))
                }
                None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
                Some(Element::ContainerStart { .. }) => r.skip_container()?,
                Some(_) => {} // unknown/future scalar — skip
            }
        }
        Ok(Self {
            name: f_name.ok_or(ClusterError::MissingField("Name"))?,
            is_operational: f_is_operational.ok_or(ClusterError::MissingField("IsOperational"))?,
            off_premise_services_reachable_i_pv4: f_off_premise_services_reachable_i_pv4.ok_or(
                ClusterError::MissingField("OffPremiseServicesReachableIPv4"),
            )?,
            off_premise_services_reachable_i_pv6: f_off_premise_services_reachable_i_pv6.ok_or(
                ClusterError::MissingField("OffPremiseServicesReachableIPv6"),
            )?,
            hardware_address: f_hardware_address
                .ok_or(ClusterError::MissingField("HardwareAddress"))?,
            i_pv4_addresses: f_i_pv4_addresses
                .ok_or(ClusterError::MissingField("IPv4Addresses"))?,
            i_pv6_addresses: f_i_pv6_addresses
                .ok_or(ClusterError::MissingField("IPv6Addresses"))?,
            r#type: f_type.ok_or(ClusterError::MissingField("Type"))?,
        })
    }
    /// Decode from a standalone anonymous TLV structure.
    ///
    /// # Errors
    /// Returns [`ClusterError`] if the bytes are not an anonymous structure or a field is malformed.
    pub fn decode(tlv: &[u8]) -> Result<Self, ClusterError> {
        let mut r = TlvReader::new(tlv);
        match r.next()? {
            Some(Element::ContainerStart {
                kind: ContainerKind::Structure,
                ..
            }) => {}
            _ => {
                return Err(ClusterError::UnexpectedType {
                    context: "NetworkInterface",
                })
            }
        }
        Self::decode_from(&mut r)
    }
}

/// Decode the `NetworkInterfaces` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_network_interfaces(tlv: &[u8]) -> Result<Vec<NetworkInterface>, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::ContainerStart {
            kind: ContainerKind::Array,
            ..
        }) => {}
        _ => {
            return Err(ClusterError::UnexpectedType {
                context: "NetworkInterfaces",
            })
        }
    }
    let r = &mut r;
    let mut out = Vec::new();
    loop {
        match r.next()? {
            Some(Element::ContainerEnd) => break,
            Some(Element::ContainerStart {
                kind: ContainerKind::Structure,
                ..
            }) => {
                out.push(NetworkInterface::decode_from(r)?);
            }
            None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
            Some(Element::ContainerStart { .. }) => r.skip_container()?,
            Some(_) => {} // skip unknown scalar
        }
    }
    Ok(out)
}

/// Decode the `RebootCount` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_reboot_count(tlv: &[u8]) -> Result<u16, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::Scalar {
            value: Value::Uint(v),
            ..
        }) => Ok(u16::try_from(v).map_err(|_| ClusterError::InvalidLength("RebootCount"))?),
        _ => Err(ClusterError::UnexpectedType {
            context: "RebootCount",
        }),
    }
}

/// Decode the `UpTime` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_up_time(tlv: &[u8]) -> Result<u64, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::Scalar {
            value: Value::Uint(v),
            ..
        }) => Ok(u64::try_from(v).map_err(|_| ClusterError::InvalidLength("UpTime"))?),
        _ => Err(ClusterError::UnexpectedType { context: "UpTime" }),
    }
}

/// Decode the `TotalOperationalHours` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_total_operational_hours(tlv: &[u8]) -> Result<u32, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::Scalar {
            value: Value::Uint(v),
            ..
        }) => {
            Ok(u32::try_from(v)
                .map_err(|_| ClusterError::InvalidLength("TotalOperationalHours"))?)
        }
        _ => Err(ClusterError::UnexpectedType {
            context: "TotalOperationalHours",
        }),
    }
}

/// Decode the `BootReason` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_boot_reason(tlv: &[u8]) -> Result<BootReasonEnum, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::Scalar {
            value: Value::Uint(v),
            ..
        }) => Ok(BootReasonEnum::from_raw(
            u8::try_from(v).map_err(|_| ClusterError::InvalidLength("BootReason"))?,
        )),
        _ => Err(ClusterError::UnexpectedType {
            context: "BootReason",
        }),
    }
}

/// Decode the `ActiveHardwareFaults` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_active_hardware_faults(tlv: &[u8]) -> Result<Vec<HardwareFaultEnum>, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::ContainerStart {
            kind: ContainerKind::Array,
            ..
        }) => {}
        _ => {
            return Err(ClusterError::UnexpectedType {
                context: "ActiveHardwareFaults",
            })
        }
    }
    let r = &mut r;
    let mut out = Vec::new();
    loop {
        match r.next()? {
            Some(Element::ContainerEnd) => break,
            Some(Element::Scalar {
                value: Value::Uint(v),
                ..
            }) => out.push(HardwareFaultEnum::from_raw(
                u8::try_from(v).map_err(|_| ClusterError::InvalidLength("ActiveHardwareFaults"))?,
            )),
            None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
            Some(Element::ContainerStart { .. }) => r.skip_container()?,
            Some(_) => {} // skip unknown scalar
        }
    }
    Ok(out)
}

/// Decode the `ActiveRadioFaults` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_active_radio_faults(tlv: &[u8]) -> Result<Vec<RadioFaultEnum>, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::ContainerStart {
            kind: ContainerKind::Array,
            ..
        }) => {}
        _ => {
            return Err(ClusterError::UnexpectedType {
                context: "ActiveRadioFaults",
            })
        }
    }
    let r = &mut r;
    let mut out = Vec::new();
    loop {
        match r.next()? {
            Some(Element::ContainerEnd) => break,
            Some(Element::Scalar {
                value: Value::Uint(v),
                ..
            }) => out.push(RadioFaultEnum::from_raw(
                u8::try_from(v).map_err(|_| ClusterError::InvalidLength("ActiveRadioFaults"))?,
            )),
            None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
            Some(Element::ContainerStart { .. }) => r.skip_container()?,
            Some(_) => {} // skip unknown scalar
        }
    }
    Ok(out)
}

/// Decode the `ActiveNetworkFaults` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_active_network_faults(tlv: &[u8]) -> Result<Vec<NetworkFaultEnum>, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::ContainerStart {
            kind: ContainerKind::Array,
            ..
        }) => {}
        _ => {
            return Err(ClusterError::UnexpectedType {
                context: "ActiveNetworkFaults",
            })
        }
    }
    let r = &mut r;
    let mut out = Vec::new();
    loop {
        match r.next()? {
            Some(Element::ContainerEnd) => break,
            Some(Element::Scalar {
                value: Value::Uint(v),
                ..
            }) => out.push(NetworkFaultEnum::from_raw(
                u8::try_from(v).map_err(|_| ClusterError::InvalidLength("ActiveNetworkFaults"))?,
            )),
            None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
            Some(Element::ContainerStart { .. }) => r.skip_container()?,
            Some(_) => {} // skip unknown scalar
        }
    }
    Ok(out)
}

/// Decode the `TestEventTriggersEnabled` attribute value.
///
/// # Errors
/// Returns [`ClusterError`] on a type mismatch or out-of-range value.
pub fn decode_test_event_triggers_enabled(tlv: &[u8]) -> Result<bool, ClusterError> {
    let mut r = TlvReader::new(tlv);
    match r.next()? {
        Some(Element::Scalar {
            value: Value::Bool(v),
            ..
        }) => Ok(v),
        _ => Err(ClusterError::UnexpectedType {
            context: "TestEventTriggersEnabled",
        }),
    }
}

/// Encode the `TestEventTrigger` command request payload.
#[must_use]
#[allow(clippy::expect_used, clippy::missing_panics_doc)] // Vec-backed TlvWriter is infallible.
pub fn encode_test_event_trigger(enable_key: &Vec<u8>, event_trigger: u64) -> Vec<u8> {
    let mut buf = Vec::new();
    let mut w = TlvWriter::new(&mut buf);
    w.start_structure(Tag::Anonymous)
        .expect("infallible: vec writer");
    w.put_bytes(Tag::Context(0), &enable_key)
        .expect("infallible: vec writer");
    w.put_uint(Tag::Context(1), u64::from(event_trigger))
        .expect("infallible: vec writer");
    w.end_container().expect("infallible: vec writer");
    buf
}

/// Encode the `TimeSnapshot` command request payload.
#[must_use]
#[allow(clippy::expect_used, clippy::missing_panics_doc)] // Vec-backed TlvWriter is infallible.
pub fn encode_time_snapshot() -> Vec<u8> {
    let mut buf = Vec::new();
    let mut w = TlvWriter::new(&mut buf);
    w.start_structure(Tag::Anonymous)
        .expect("infallible: vec writer");
    w.end_container().expect("infallible: vec writer");
    buf
}

/// Decoded `TimeSnapshotResponse` payload.
#[derive(Clone, Debug, PartialEq)]
#[non_exhaustive]
pub struct TimeSnapshotResponse {
    /// Field SystemTimeMs (tag 0).
    pub system_time_ms: u64,
    /// Field PosixTimeMs (tag 1).
    pub posix_time_ms: Nullable<u64>,
}

impl TimeSnapshotResponse {
    /// Decode the fields of an already-opened anonymous structure
    /// (reader positioned after the struct start; consumes to its end).
    ///
    /// # Errors
    /// Returns [`ClusterError`] on a malformed structure or missing required field.
    pub fn decode_from(r: &mut TlvReader<'_>) -> Result<Self, ClusterError> {
        let mut f_system_time_ms: Option<u64> = None;
        let mut f_posix_time_ms: Option<Nullable<u64>> = None;
        loop {
            match r.next()? {
                Some(Element::ContainerEnd) => break,
                Some(Element::Scalar {
                    tag: Tag::Context(0),
                    value: Value::Uint(v),
                }) => {
                    f_system_time_ms = Some(
                        u64::try_from(v)
                            .map_err(|_| ClusterError::InvalidLength("SystemTimeMs"))?,
                    )
                }
                Some(Element::Scalar {
                    tag: Tag::Context(1),
                    value: Value::Null,
                }) => f_posix_time_ms = Some(Nullable::Null),
                Some(Element::Scalar {
                    tag: Tag::Context(1),
                    value: Value::Uint(v),
                }) => {
                    f_posix_time_ms = Some(Nullable::Value(
                        u64::try_from(v).map_err(|_| ClusterError::InvalidLength("PosixTimeMs"))?,
                    ))
                }
                None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
                Some(Element::ContainerStart { .. }) => r.skip_container()?,
                Some(_) => {} // unknown/future scalar — skip
            }
        }
        Ok(Self {
            system_time_ms: f_system_time_ms.ok_or(ClusterError::MissingField("SystemTimeMs"))?,
            posix_time_ms: f_posix_time_ms.ok_or(ClusterError::MissingField("PosixTimeMs"))?,
        })
    }
    /// Decode from a standalone anonymous TLV structure.
    ///
    /// # Errors
    /// Returns [`ClusterError`] if the bytes are not an anonymous structure or a field is malformed.
    pub fn decode(tlv: &[u8]) -> Result<Self, ClusterError> {
        let mut r = TlvReader::new(tlv);
        match r.next()? {
            Some(Element::ContainerStart {
                kind: ContainerKind::Structure,
                ..
            }) => {}
            _ => {
                return Err(ClusterError::UnexpectedType {
                    context: "TimeSnapshotResponse",
                })
            }
        }
        Self::decode_from(&mut r)
    }
}

/// Encode the `PayloadTestRequest` command request payload.
#[must_use]
#[allow(clippy::expect_used, clippy::missing_panics_doc)] // Vec-backed TlvWriter is infallible.
pub fn encode_payload_test_request(enable_key: &Vec<u8>, value: u8, count: u16) -> Vec<u8> {
    let mut buf = Vec::new();
    let mut w = TlvWriter::new(&mut buf);
    w.start_structure(Tag::Anonymous)
        .expect("infallible: vec writer");
    w.put_bytes(Tag::Context(0), &enable_key)
        .expect("infallible: vec writer");
    w.put_uint(Tag::Context(1), u64::from(value))
        .expect("infallible: vec writer");
    w.put_uint(Tag::Context(2), u64::from(count))
        .expect("infallible: vec writer");
    w.end_container().expect("infallible: vec writer");
    buf
}

/// Decoded `PayloadTestResponse` payload.
#[derive(Clone, Debug, PartialEq)]
#[non_exhaustive]
pub struct PayloadTestResponse {
    /// Field Payload (tag 0).
    pub payload: Vec<u8>,
}

impl PayloadTestResponse {
    /// Decode the fields of an already-opened anonymous structure
    /// (reader positioned after the struct start; consumes to its end).
    ///
    /// # Errors
    /// Returns [`ClusterError`] on a malformed structure or missing required field.
    pub fn decode_from(r: &mut TlvReader<'_>) -> Result<Self, ClusterError> {
        let mut f_payload: Option<Vec<u8>> = None;
        loop {
            match r.next()? {
                Some(Element::ContainerEnd) => break,
                Some(Element::Scalar {
                    tag: Tag::Context(0),
                    value: Value::Bytes(v),
                }) => f_payload = Some(v),
                None => return Err(ClusterError::Tlv(matter_codec::Error::UnclosedContainer)),
                Some(Element::ContainerStart { .. }) => r.skip_container()?,
                Some(_) => {} // unknown/future scalar — skip
            }
        }
        Ok(Self {
            payload: f_payload.ok_or(ClusterError::MissingField("Payload"))?,
        })
    }
    /// Decode from a standalone anonymous TLV structure.
    ///
    /// # Errors
    /// Returns [`ClusterError`] if the bytes are not an anonymous structure or a field is malformed.
    pub fn decode(tlv: &[u8]) -> Result<Self, ClusterError> {
        let mut r = TlvReader::new(tlv);
        match r.next()? {
            Some(Element::ContainerStart {
                kind: ContainerKind::Structure,
                ..
            }) => {}
            _ => {
                return Err(ClusterError::UnexpectedType {
                    context: "PayloadTestResponse",
                })
            }
        }
        Self::decode_from(&mut r)
    }
}