Function fire_after_insert

nodedb/src/control/trigger/fire_after.rs:36–74

Fire AFTER ROW triggers for an INSERT operation. Called after a successful INSERT dispatch. `new_fields` contains the inserted row's field values. The trigger body's DML is dispatched through the normal plan+SPSC path, executing in the same logical transaction context. `mode_filter` selects which execution mode to fire: - `Some(Sync)`: only fire SYNC triggers (called from write path) - `Some(Asy

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    new_fields: &HashMap<String, nodedb_types::Value>,
    cascade_depth: u32,
    mode_

/// - `Some(Async)`: only fire ASYNC triggers (called from Event Plane)
/// - `None`: fire all AFTER triggers regardless of mode (legacy behavior)
pub async fn fire_after_insert(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    new_fields: &HashMap<String, nodedb_types::Value>,
    cascade_depth: u32,
    mode_filter: Option<TriggerExecutionMode>,
) -> crate::Result<()> {
    let triggers =
        state
            .trigger_registry
            .get_matching(tenant_id.as_u64(), collection, DmlEvent::Insert);

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

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

    check_cascade_depth(cascade_depth, collection)?;

    let bindings = RowBindings::after_insert(collection, new_fields.clone());

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

/// Fire AFTER ROW triggers for an UPDATE operation.
///