Struct PeerSession 

pub struct PeerSession {
    pub peer_node_id: NodeId,
    pub state: SessionState,
    pub created_at_ms: u64,
    pub last_activity_ms: u64,
    pub outbound_counter: u64,
    pub inbound_counter: u64,
    /* private fields */
}

A per-peer E2EE session

Fields

peer_node_id: NodeId

Peer’s node ID

state: SessionState

Session state

created_at_ms: u64

Timestamp when session was created

last_activity_ms: u64

Timestamp of last activity

outbound_counter: u64

Outbound message counter (for replay protection)

inbound_counter: u64

Highest inbound message counter seen (for replay protection)

Implementations

impl PeerSession

pub fn new_initiator(peer_node_id: NodeId, now_ms: u64) -> Self

Create a new session in awaiting state (we initiated)

pub fn new_responder( peer_node_id: NodeId, session_key: PeerSessionKey, peer_public_key: [u8; 32], now_ms: u64, ) -> Self

Create a new established session (peer initiated, we’re responding)

pub fn complete_handshake( &mut self, session_key: PeerSessionKey, peer_public_key: [u8; 32], now_ms: u64, )

Complete the handshake (transition from AwaitingPeerKey to Established)

pub fn is_established(&self) -> bool

Check if session is established

pub fn is_expired(&self, now_ms: u64, timeout_ms: u64) -> bool

Check if session is expired

pub fn next_outbound_counter(&mut self) -> u64

Get next outbound message counter and increment

pub fn validate_inbound_counter(&mut self, counter: u64) -> bool

Validate and update inbound message counter (replay protection)

Returns true if the counter is valid (not previously seen). Uses >= check with next-counter storage to accept counter 0 initially.

pub fn session_key(&self) -> Option<&PeerSessionKey>

Get the session key (if established)

pub fn touch(&mut self, now_ms: u64)

Update last activity timestamp

pub fn close(&mut self)

Close the session

Trait Implementations

impl Debug for PeerSession

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

Formats the value using the given formatter.