Method resolve_event_payload

nodedb/src/data/executor/core_loop/event_emit.rs:14–29

Convert stored bytes to msgpack for Event Plane consumption. For strict collections, the stored format is Binary Tuple which the Event Plane cannot decode (it lacks the schema). This method converts Binary Tuple → msgpack so triggers can deserialize the payload. Returns `None` for schemaless collections (already msgpack).

(
        &self,
        tid: u64,
        collection: &str,
        stored_bytes: &[u8],
    )

    /// Binary Tuple → msgpack so triggers can deserialize the payload.
    /// Returns `None` for schemaless collections (already msgpack).
    pub(in crate::data::executor) fn resolve_event_payload(
        &self,
        tid: u64,
        collection: &str,
        stored_bytes: &[u8],
    ) -> Option<Vec<u8>> {
        let config_key = (crate::types::TenantId::new(tid), collection.to_string());
        let config = self.doc_configs.get(&config_key)?;
        if let nodedb_physical::physical_plan::StorageMode::Strict { ref schema } =
            config.storage_mode
        {
            crate::data::executor::strict_format::binary_tuple_to_msgpack(stored_bytes, schema)
        } else {
            None
        }
    }

    /// Emit a point write/overwrite/update event derived from the new bytes
    /// produced by the handler and the prior bytes returned from storage.