Method deliver_op

nodedb/src/control/array_sync/outbound/merge.rs:193–228

Deliver one op to the session's delivery channel.

(&self, op: &ArrayOp, delivery: &ArrayDeliveryRegistry)

    /// Deliver one op to the session's delivery channel.
    fn deliver_op(&self, op: &ArrayOp, delivery: &ArrayDeliveryRegistry) {
        let op_payload = match op_codec::encode_op(op) {
            Ok(b) => b,
            Err(e) => {
                warn!(
                    session = %self.session_id,
                    array = %self.array,
                    error = %e,
                    "multi_shard_merger: encode_op failed — skipping op"
                );
                return;
            }
        };

        let msg = ArrayDeltaMsg {
            array: op.header.array.clone(),
            op_payload,
        };

        let frame = match nodedb_types::sync::wire::SyncFrame::try_encode(
            SyncMessageType::ArrayDelta,
            &msg,
        ) {
            Some(f) => f.to_bytes(),
            None => {
                warn!(
                    session = %self.session_id,
                    array = %self.array,
                    "multi_shard_merger: SyncFrame encode failed — skipping op"
                );
                return;
            }
        };

        delivery.enqueue(&self.session_id, frame);
    }
}

// ─── Registry ────────────────────────────────────────────────────────────────