Method handle_catchup_request

nodedb/src/control/array_sync/inbound.rs:281–307

Handle a catch-up request from a Lite peer. Delegates to [`OriginCatchupServer`] which validates the array, selects the op-stream or snapshot delivery path, and enqueues outbound frames.

(
        &self,
        msg: &ArrayCatchupRequestMsg,
        session_id: &str,
    )

    /// Delegates to [`OriginCatchupServer`] which validates the array, selects
    /// the op-stream or snapshot delivery path, and enqueues outbound frames.
    pub fn handle_catchup_request(
        &self,
        msg: &ArrayCatchupRequestMsg,
        session_id: &str,
    ) -> Result<InboundOutcome, Option<ArrayRejectMsg>> {
        use super::catchup::OriginCatchupServer;

        let server = OriginCatchupServer::new(
            Arc::clone(&self.shared.array_sync_op_log),
            Arc::clone(&self.schemas),
            Arc::clone(&self.shared.array_snapshot_store),
            Arc::clone(&self.shared.array_delivery),
            Arc::clone(&self.shared.array_subscriber_cursors),
            Arc::clone(&self.shared.array_ack_registry),
        );

        if let Err(e) = server.serve(msg, session_id) {
            warn!(
                session = %session_id,
                array = %msg.array,
                error = %e,
                "array_inbound: catchup server error"
            );
        }

        Ok(InboundOutcome::CatchupRequested)
    }

    // ─── Internal helpers ─────────────────────────────────────────────────────