Function from_replicated_entry

nodedb/src/control/wal_replication/decode.rs:21–44

Returns `None` if the data is not a valid ReplicatedEntry (e.g., ConfChange or no-op). `assigner`, when `Some`, drives follower-local surrogate binding for the variants that carry one: each insert/upsert/put re-derives its stable identity by calling `assigner.assign(collection, pk_bytes)`, which writes the binding to the local catalog and emits a `SurrogateBind` WAL record. When `None`, all surro

(
    data: &[u8],
    assigner: Option<&SurrogateAssigner>,
)

/// back to `Surrogate::ZERO` (used by tests that exercise the decoder
/// in isolation without spinning up `SharedState`).
pub fn from_replicated_entry(
    data: &[u8],
    assigner: Option<&SurrogateAssigner>,
) -> crate::Result<Option<(TenantId, VShardId, PhysicalPlan)>> {
    let entry = match ReplicatedEntry::from_bytes(data) {
        Some(e) => e,
        None => return Ok(None),
    };
    // Array CRDT variants are handled by the distributed applier before this
    // function is called. Return None so the applier skips the generic dispatch
    // path for them.
    match &entry.write {
        ReplicatedWrite::ArrayOp { .. } | ReplicatedWrite::ArraySchema { .. } => {
            return Ok(None);
        }
        _ => {}
    }
    let plan = to_physical_plan(&entry.write, assigner)?;
    Ok(Some((
        TenantId::new(entry.tenant_id),
        VShardId::new(entry.vshard_id),
        plan,
    )))
}

fn assign_or_zero(
    assigner: Option<&SurrogateAssigner>,