Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Manages node identity and tracks local changes for network sync.

Records document/chunk/embedding mutations as CognitiveDiffs. The identity seed is stored in the platform keychain (macOS Keychain, Linux secret-service) with a plaintext file fallback for environments where no keychain is available.

Implementations

impl SyncManager

pub fn new(key_path: &Path) -> Result<Self>

Create a new sync manager with a persistent node identity.

Tries to load the identity seed from the file path first, then falls back to the platform keychain. On first run, generates a new identity and stores it in both locations. The file is always written as a backup even when keychain succeeds, ensuring reliable persistence.

pub fn new_file_only(key_path: &Path) -> Result<Self>

Create a sync manager using file-based storage only.

Skips all keychain access. Useful for headless environments (CI, containers, tests) where no platform keychain is available.

pub fn record_add_doc(&self, doc: Document)

Record a document addition (deduplicates by ID)

pub fn record_add_chunk(&self, chunk: Chunk)

Record a chunk addition (deduplicates by ID)

pub fn record_add_embedding(&self, emb: Embedding)

Record an embedding addition (deduplicates by ID)

pub fn record_remove_doc( &self, doc_id: Uuid, chunk_ids: Vec<Uuid>, embedding_ids: Vec<Uuid>, )

Record a document removal (deduplicates by ID)

pub fn take_pending_diff(&self) -> CognitiveDiff

Take the pending diff and reset it. Used by the network layer to retrieve accumulated changes for gossip.

pub fn update_state_root(&self, root: [u8; 32])

Update the last known state root. Call this after computing the Merkle root from the graph store so that the next diff’s prev_root reflects the current state.

pub fn has_pending_changes(&self) -> bool

Check whether there are pending changes to sync.

pub fn get_identity(&self) -> &DeviceIdentity

Get device identity for network operations

pub fn get_device_id_hex(&self) -> String

Get device ID as hex string

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

Get the X25519 public key for key agreement with remote nodes.

pub fn pair_with_remote( &self, remote_public_key: &[u8; 32], remote_x25519_public: &[u8; 32], ) -> Result<()>

Pair with a remote device using X25519 key agreement.

Performs Diffie-Hellman key exchange to derive a shared encryption key, then stores the paired device for future encrypted diff exchange.

pub fn encrypt_diff_for_peer( &self, diff: &CognitiveDiff, peer_device_id: &[u8; 16], ) -> Result<Option<EncryptedPayload>>

Encrypt a diff for a specific paired device using their shared key.

pub fn paired_device_ids(&self) -> Vec<[u8; 16]>

Get the list of paired device IDs.