Method handle_delta

nodedb/src/control/array_sync/inbound.rs:162–180

Handle a single delta message from a Lite peer.

(
        &self,
        msg: &ArrayDeltaMsg,
    )

    /// Handle a single delta message from a Lite peer.
    pub async fn handle_delta(
        &self,
        msg: &ArrayDeltaMsg,
    ) -> Result<InboundOutcome, Option<ArrayRejectMsg>> {
        let op = match op_codec::decode_op(&msg.op_payload) {
            Ok(op) => op,
            Err(e) => {
                warn!(array = %msg.array, error = %e, "array_inbound: delta decode failed");
                return Err(Some(build_reject(
                    &msg.array,
                    Hlc::ZERO,
                    ArrayRejectReason::ShapeInvalid,
                    format!("decode error: {e}"),
                )));
            }
        };

        self.apply_op(op, &msg.op_payload).await
    }

    /// Handle a batch of delta messages from a Lite peer.
    ///