Struct PeerSessionManager 

pub struct PeerSessionManager { /* private fields */ }

Manager for all per-peer E2EE sessions

Implementations

impl PeerSessionManager

pub fn new(our_node_id: NodeId) -> Self

Create a new session manager with a generated identity key

pub fn with_identity_key( our_node_id: NodeId, identity_key: PeerIdentityKey, ) -> Self

Create with a specific identity key

pub fn with_max_sessions(self, max: usize) -> Self

Configure maximum sessions

pub fn with_session_timeout(self, timeout_ms: u64) -> Self

Configure session timeout

pub fn our_public_key(&self) -> [u8; 32]

Get our public key bytes (for sharing with peers)

pub fn our_node_id(&self) -> NodeId

Get our node ID

pub fn initiate_session( &mut self, peer_node_id: NodeId, now_ms: u64, ) -> KeyExchangeMessage

Initiate an E2EE session with a peer

Returns a key exchange message to send to the peer.

pub fn handle_key_exchange( &mut self, msg: &KeyExchangeMessage, now_ms: u64, ) -> Option<(KeyExchangeMessage, bool)>

Handle incoming key exchange message from peer

Returns:

• Some((response, established)) if we should respond (response is our key exchange message)
• None if the message is invalid or session limit reached

pub fn has_session(&self, peer_node_id: NodeId) -> bool

Check if we have an established session with a peer

pub fn session_state(&self, peer_node_id: NodeId) -> Option<SessionState>

Get session state for a peer

pub fn encrypt_for_peer( &mut self, peer_node_id: NodeId, plaintext: &[u8], now_ms: u64, ) -> Result<PeerEncryptedMessage, EncryptionError>

Encrypt a message for a specific peer

Returns the encrypted message, or an error if no established session exists.

pub fn decrypt_from_peer( &mut self, msg: &PeerEncryptedMessage, now_ms: u64, ) -> Result<Vec<u8>, EncryptionError>

Decrypt a message from a peer

Returns the plaintext, or an error if decryption fails.

pub fn close_session(&mut self, peer_node_id: NodeId)

Close a session with a peer

pub fn remove_session(&mut self, peer_node_id: NodeId) -> Option<PeerSession>

Remove a session entirely

pub fn cleanup_expired(&mut self, now_ms: u64) -> Vec<NodeId>

Cleanup expired sessions

pub fn session_count(&self) -> usize

Get number of active sessions

pub fn established_count(&self) -> usize

Get number of established sessions

Trait Implementations

impl Debug for PeerSessionManager

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

Formats the value using the given formatter.