Struct DirectMessaging 

pub struct DirectMessaging { /* private fields */ }

Tracks connections and mappings for direct messaging.

This maintains the MachineId → AgentId reverse lookup needed to identify message senders, since ant-quic only knows about MachineIds.

Implementations

impl DirectMessaging

pub fn new() -> Self

Create a new DirectMessaging instance.

pub async fn register_agent(&self, agent_id: AgentId, machine_id: MachineId)

Register a mapping from MachineId to AgentId.

Called when an agent is discovered or connected.

pub async fn lookup_agent(&self, machine_id: &MachineId) -> Option<AgentId>

Look up AgentId from MachineId.

pub async fn mark_connected(&self, agent_id: AgentId, machine_id: MachineId)

Mark an agent as connected.

pub async fn mark_disconnected(&self, agent_id: &AgentId)

Mark an agent as disconnected.

pub async fn is_connected(&self, agent_id: &AgentId) -> bool

Check if an agent is currently connected.

pub async fn get_machine_id(&self, agent_id: &AgentId) -> Option<MachineId>

Get the MachineId for a connected agent.

pub async fn connected_agents(&self) -> Vec<AgentId>

Get all currently connected agents.

pub fn subscribe(&self) -> DirectMessageReceiver

Get a receiver for direct messages.

pub fn subscriber_count(&self) -> usize

Current number of live broadcast subscribers.

Used by diagnostics to distinguish “message dispatched to N SSE/WS consumers” from “message silently dropped because no one is listening”.

pub async fn handle_incoming( &self, machine_id: MachineId, sender_agent_id: AgentId, payload: Vec<u8>, verified: bool, trust_decision: Option<TrustDecision>, )

Process an incoming direct message from the network.

Called by the network layer when a direct message is received. The verified and trust_decision fields are populated by the caller based on the identity discovery cache and contact store.

pub async fn recv(&self) -> Option<DirectMessage>

Receive the next direct message (blocking).

pub fn encode_message( sender_agent_id: &AgentId, payload: &[u8], ) -> NetworkResult<Vec<u8>>

Encode a direct message for transmission.

Format: [0x10][sender_agent_id: 32 bytes][payload]

pub fn decode_message(data: &[u8]) -> NetworkResult<(AgentId, Vec<u8>)>

Decode a direct message from the wire.

Returns (sender_agent_id, payload) on success.

Trait Implementations

impl Debug for DirectMessaging

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DirectMessaging

fn default() -> Self

Returns the “default value” for a type.