Function fire_after_statement

nodedb/src/control/trigger/fire_statement.rs:36–75

Fire AFTER STATEMENT triggers for the given operation. Called once after all rows of a DML statement have been dispatched. `mode_filter` controls which execution mode triggers are fired (same semantics as the ROW-level fire functions). Statement-level triggers receive: - `TG_OP`: the operation name ("INSERT", "UPDATE", "DELETE") - `TG_TABLE_NAME`: the collection name - `TG_WHEN`: "AFTER" - NO `N

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    event: DmlEvent,
    cascade_depth: u32,
    mode_filter: Option<TriggerExecutionMod

/// - `TG_WHEN`: "AFTER"
/// - NO `NEW` or `OLD` row references
pub async fn fire_after_statement(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    event: DmlEvent,
    cascade_depth: u32,
    mode_filter: Option<TriggerExecutionMode>,
) -> crate::Result<()> {
    let triggers = state
        .trigger_registry
        .get_matching(tenant_id.as_u64(), collection, event);

    let statement_triggers: Vec<_> = triggers
        .into_iter()
        .filter(|t| t.timing == TriggerTiming::After)
        .filter(|t| t.granularity == TriggerGranularity::Statement)
        .filter(|t| mode_filter.is_none() || Some(t.execution_mode) == mode_filter)
        .collect();

    if statement_triggers.is_empty() {
        return Ok(());
    }

    check_cascade_depth(cascade_depth, collection)?;

    // Statement-level bindings: TG_OP + TG_TABLE_NAME, no NEW/OLD.
    let bindings = RowBindings::statement(collection, event.as_str());

    fire_triggers(
        state,
        identity,
        tenant_id,
        collection,
        &statement_triggers,
        &bindings,
        cascade_depth,
    )
    .await
}