Struct ChatMeshService 

pub struct ChatMeshService { /* private fields */ }

A handle to the running chat-over-mesh service.

Implementations

impl ChatMeshService

pub fn spawn(mesh: MeshService) -> ChatMeshService

Spawn the chat loop over mesh, forwarding received envelopes to try_recv / recv_timeout. Used by tests and callers that want to handle delivery themselves.

pub fn spawn_applying( mesh: MeshService, storage_root: PathBuf, ) -> ChatMeshService

Spawn the chat loop over mesh, applying received envelopes directly to the session store under storage_root via crate::chat_relay::apply_incoming_envelope (dedup + agent-message validation + UI notify). This is the desktop path: publish with publish, and inbound chat lands in the local sessions automatically.

pub fn add_peer( &self, peer_id: &str, peer_pubkey_hex: &str, endpoint: Option<SocketAddr>, ) -> Result<SocketAddr, String>

Add a peer to the underlying mesh; returns the local bound address.

pub fn set_peer_endpoint( &self, peer_id: &str, addr: SocketAddr, ) -> Result<(), String>

Point a peer’s tunnel at addr.

pub fn initiate_handshake(&self, peer_id: &str) -> Result<(), String>

Initiate the handshake with a peer.

pub fn peers(&self) -> Result<Vec<String>, String>

Peers currently in the mesh.

pub fn has_session(&self, peer_id: &str) -> Result<bool, String>

Whether a live session exists with a peer.

pub fn wait_for_session(&self, peer_id: &str, timeout: Duration) -> bool

Poll until a session with peer_id is established or timeout elapses.

pub fn publish( &self, peers: Vec<String>, env: RelayEnvelope, ) -> Result<(), String>

Reliably send env to each peer in peers over the mesh.

pub fn try_recv(&self) -> Option<IncomingChat>

Non-blocking receive of the next inbound chat message (channel mode only; None in apply mode).

pub fn recv_timeout(&self, timeout: Duration) -> Option<IncomingChat>

Block up to timeout for the next inbound chat message (channel mode only).

pub fn shutdown(&mut self)

Stop the chat loop and join the thread (also runs on drop).

Trait Implementations

impl Drop for ChatMeshService

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.