Function push_write_event

nodedb/src/control/trigger/batch/collector.rs:326–351

Convert a [`WriteEvent`] into a [`TriggerBatchRow`] and push to the collector. Returns `Some(TriggerBatch)` if the push completes or flushes a batch. Returns `None` for non-triggerable events or if the batch isn't full yet. Stores raw bytes from the WriteEvent — no deserialization at ingestion time. The row decodes lazily when a trigger body or WHEN clause accesses the fields.

(
    collector: &mut TriggerBatchCollector,
    event: &crate::event::types::WriteEvent,
)

/// Stores raw bytes from the WriteEvent — no deserialization at ingestion time.
/// The row decodes lazily when a trigger body or WHEN clause accesses the fields.
pub fn push_write_event(
    collector: &mut TriggerBatchCollector,
    event: &crate::event::types::WriteEvent,
) -> Option<TriggerBatch> {
    use crate::event::types::{EventSource, WriteOp};

    // Only User-originated events fire triggers.
    if !matches!(event.source, EventSource::User) {
        return None;
    }

    let op_str = match event.op {
        WriteOp::Insert => "INSERT",
        WriteOp::Update => "UPDATE",
        WriteOp::Delete => "DELETE",
        _ => return None,
    };

    let row = TriggerBatchRow::from_raw(
        event.new_value.clone(),
        event.old_value.clone(),
        event.row_id.as_str().to_string(),
    );

    collector.push(&event.collection, op_str, event.tenant_id.as_u64(), row)
}

#[cfg(test)]
mod tests {