Function execute_before_batch

nodedb/src/control/trigger/batch/before.rs:45–132

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    event: DmlEvent,
    mut rows: Vec<TriggerBatchRow>,
    cascade_depth: u32,
)

/// Returns the mutated batch + error accumulator.
#[allow(clippy::too_many_arguments)]
pub async fn execute_before_batch(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    event: DmlEvent,
    mut rows: Vec<TriggerBatchRow>,
    cascade_depth: u32,
) -> crate::Result<BeforeBatchResult> {
    let triggers = state
        .trigger_registry
        .get_matching(tenant_id.as_u64(), collection, event);

    let before_triggers: Vec<_> = triggers
        .into_iter()
        .filter(|t| t.timing == TriggerTiming::Before)
        .collect();

    if before_triggers.is_empty() {
        return Ok(BeforeBatchResult {
            rows,
            errors: ErrorAccumulator::new(),
        });
    }

    crate::control::trigger::fire_common::check_cascade_depth(cascade_depth, collection)?;

    let mut errors = ErrorAccumulator::new();

    for trigger in &before_triggers {
        let op_str = event.as_str();

        // Pre-filter by WHEN clause.
        let mask = when_filter::filter_batch_by_when(
            &rows,
            collection,
            op_str,
            trigger.when_condition.as_deref(),
        );

        let effective_identity = resolve_trigger_identity(trigger, identity, tenant_id);

        let block = match state.block_cache.get_or_parse(&trigger.body_sql) {
            Ok(b) => b,
            Err(e) => {
                tracing::warn!(trigger = %trigger.name, error = %e, "failed to parse BEFORE trigger body");
                continue;
            }
        };

        // Process each passing row.
        for (idx, (row, &passes)) in rows.iter_mut().zip(mask.iter()).enumerate() {
            if !passes {
                continue;
            }

            let bindings = build_before_bindings(row, collection, op_str);