Function start_bootnode_discovery_task

gateway/src/main_service.rs:637–676

Periodically retry bootnode peer discovery if no peers are available

(proxy: Proxy)

/// Periodically retry bootnode peer discovery if no peers are available
fn start_bootnode_discovery_task(proxy: Proxy) {
    if !proxy.config.sync.enabled || proxy.config.sync.bootnode.is_empty() {
        return;
    }

    let bootnode = proxy.config.sync.bootnode.clone();
    let node_id = proxy.config.sync.node_id;
    let kv_store = proxy.kv_store.clone();
    let https_config = match &proxy.https_config {
        Some(config) => config.clone(),
        None => return,
    };

    tokio::spawn(async move {
        let mut interval = tokio::time::interval(Duration::from_secs(10));
        loop {
            interval.tick().await;
            // Check if we already have peers
            let n_peers = kv_store
                .load_all_node_statuses()
                .keys()
                .filter(|&id| *id != node_id)
                .count();
            if n_peers > 0 {
                info!("bootnode peer discovery finished, {n_peers} peers found");
                break;
            }
            // Try to fetch peers from bootnode
            debug!("retrying bootnode peer discovery...");
            if let Err(err) =
                fetch_peers_from_bootnode(&bootnode, &kv_store, node_id, &https_config).await
            {
                warn!("bootnode discovery retry failed: {err:?}");
            } else {
                info!("bootnode peer discovery succeeded");
            }
        }
    });
    info!("Bootnode discovery task started (will retry every 10s if no peers)");
}

async fn start_wavekv_sync_task(proxy: Proxy, wavekv_sync: Arc<WaveKvSyncService>) {
    if !proxy.config.sync.enabled {