samod_core/network/
connection_info.rs

1use std::collections::HashMap;
2
3use crate::{ConnectionId, DocumentId, PeerId, UnixTimestamp};
4
5/// Information about each live connection
6#[derive(Debug, Clone, PartialEq, Eq)]
7pub struct ConnectionInfo {
8    pub id: ConnectionId,
9    pub last_received: Option<UnixTimestamp>,
10    pub last_sent: Option<UnixTimestamp>,
11    /// The state of each document we are synchronizing with this peer
12    pub docs: HashMap<DocumentId, PeerDocState>,
13    /// Whether we are handshaking or connected with this peer
14    pub state: ConnectionState,
15}
16
17#[derive(Debug, Clone, PartialEq, Eq)]
18pub enum ConnectionState {
19    /// We're still exchanging peer IDs
20    Handshaking,
21    /// We have exchanged peer IDs and we're now synchronizing documents
22    Connected { their_peer_id: PeerId },
23}
24
25/// The state of synchronization for one (peer, document) pair
26#[derive(Debug, Clone, PartialEq, Eq, PartialOrd)]
27pub struct PeerDocState {
28    /// When we last received a message from this peer
29    pub last_received: Option<UnixTimestamp>,
30    /// When we last sent a message to this peer
31    pub last_sent: Option<UnixTimestamp>,
32    /// The heads of the document when we last sent a message
33    pub last_sent_heads: Option<Vec<automerge::ChangeHash>>,
34    /// The last heads of the document that the peer said they had
35    pub last_acked_heads: Option<Vec<automerge::ChangeHash>>,
36}
37
38impl PeerDocState {
39    pub(crate) fn empty() -> Self {
40        Self {
41            last_received: None,
42            last_sent: None,
43            last_sent_heads: None,
44            last_acked_heads: None,
45        }
46    }
47}
samod_core/network/connection_info.rs

samod_core/network/
connection_info.rs
