class
Matter::Controller::Client
- Matter::Controller::Client
- Reference
- Object
Defined in:
matter/controller/client.crConstant Summary
-
Log =
::Log.for("matter.controller.client") -
MSG_STANDALONE_ACK =
16_u8 -
PROTOCOL_INTERACTION_MODEL =
1_u16 -
PROTOCOL_SECURE_CHANNEL =
0_u16
Constructors
Instance Method Summary
- #close : Nil
- #crypto : Crypto::CryptoBase
- #next_exchange_id : UInt16
- #register_session(session : Session::SecureContext) : Nil
-
#send_encrypted_request(session : Session::SecureContext, peer : Socket::IPAddress, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), exchange_id : UInt16 = next_exchange_id, initiator_message : Bool = true, requires_ack : Bool = true, acknowledged_message_id : UInt32 | Nil = nil) : UInt16
Send an encrypted request on an existing secure session.
-
#send_unsecured_on_exchange(peer : Socket::IPAddress, exchange_id : UInt16, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), initiator_message : Bool = true, requires_ack : Bool = true, acknowledged_message_id : UInt32 | Nil = nil) : Nil
Send an unsecured (session_id=0) message on an existing exchange.
-
#send_unsecured_request(peer : Socket::IPAddress, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), requires_ack : Bool = true) : UInt16
Send an unsecured (session_id=0) request and return the exchange id.
- #session?(session_id : UInt16) : Session::SecureContext | Nil
- #transport : Transport::UDPTransport
-
#wait_for(exchange_id : UInt16, protocol_id : UInt16, message_type : UInt8, timeout : Time::Span) : ReceivedMessage | Nil
Wait for the next message matching exchange/protocol/type.
Constructor Detail
def self.new(port : Int32 = 0, interface_ipv4 : String = "0.0.0.0", interface_ipv6 : String = "::", crypto : Crypto::CryptoBase = Crypto::StandardCrypto.new, unsecured_source_node_id : UInt64 | Nil = nil, initial_unsecured_message_counter : UInt32 | Nil = nil)
#
Instance Method Detail
def send_encrypted_request(session : Session::SecureContext, peer : Socket::IPAddress, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), exchange_id : UInt16 = next_exchange_id, initiator_message : Bool = true, requires_ack : Bool = true, acknowledged_message_id : UInt32 | Nil = nil) : UInt16
#
Send an encrypted request on an existing secure session.
def send_unsecured_on_exchange(peer : Socket::IPAddress, exchange_id : UInt16, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), initiator_message : Bool = true, requires_ack : Bool = true, acknowledged_message_id : UInt32 | Nil = nil) : Nil
#
Send an unsecured (session_id=0) message on an existing exchange.
def send_unsecured_request(peer : Socket::IPAddress, protocol_id : UInt16, message_type : UInt8, payload : Bytes | Slice(UInt8), requires_ack : Bool = true) : UInt16
#
Send an unsecured (session_id=0) request and return the exchange id.
def wait_for(exchange_id : UInt16, protocol_id : UInt16, message_type : UInt8, timeout : Time::Span) : ReceivedMessage | Nil
#
Wait for the next message matching exchange/protocol/type.