nodedb-lite 0.1.0

Embedded edge client for NodeDB — offline vector search, graph traversal, and CRDT sync
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

//! The reconnecting sync loop: connect, handshake, push and receive, then
//! back off and reconnect.

use std::sync::Arc;

use crate::sync::client::{SyncClient, SyncState};
use crate::sync::delegate::SyncDelegate;

/// Run the sync loop — connects, handshakes, pushes/receives, reconnects.
///
/// Runs forever (until the task is cancelled). On disconnect it sleeps for
/// [`SyncClient::backoff_duration`] and retries; on a clean close the
/// backoff resets to zero.
pub async fn run_sync_loop(client: Arc<SyncClient>, delegate: Arc<dyn SyncDelegate>) {
    let mut attempt: u32 = 0;

    loop {
        client.set_state(SyncState::Connecting).await;
        tracing::info!(url = %client.config().url, attempt, "connecting to Origin");

        match super::connect::connect_and_run(&client, &delegate).await {
            Ok(()) => {
                tracing::info!("sync connection closed cleanly");
                attempt = 0;
            }
            Err(e) => {
                tracing::warn!(error = %e, attempt, "sync connection failed");
            }
        }

        client.set_state(SyncState::Reconnecting).await;
        let backoff = client.backoff_duration(attempt);
        tracing::info!(
            backoff_ms = backoff.as_millis(),
            "reconnecting after backoff"
        );
        tokio::time::sleep(backoff).await;
        attempt = attempt.saturating_add(1);
    }
}