Function fire_instead_of_insert

nodedb/src/control/trigger/fire_instead.rs:38–76

Check for and fire INSTEAD OF triggers for an INSERT operation. Returns `InsteadOfResult::Handled` if an INSTEAD OF trigger fired (caller must skip normal dispatch). Returns `NoTrigger` otherwise.

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

/// Returns `InsteadOfResult::Handled` if an INSTEAD OF trigger fired
/// (caller must skip normal dispatch). Returns `NoTrigger` otherwise.
pub async fn fire_instead_of_insert(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    tenant_id: TenantId,
    collection: &str,
    new_fields: &HashMap<String, nodedb_types::Value>,
    cascade_depth: u32,
) -> crate::Result<InsteadOfResult> {
    let triggers =
        state
            .trigger_registry
            .get_matching(tenant_id.as_u64(), collection, DmlEvent::Insert);

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

    if instead_triggers.is_empty() {
        return Ok(InsteadOfResult::NoTrigger);
    }

    check_cascade_depth(cascade_depth, collection)?;

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

    fire_triggers(
        state,
        identity,
        tenant_id,
        collection,
        &instead_triggers,
        &bindings,
        cascade_depth,
    )
    .await?;

    Ok(InsteadOfResult::Handled)
}

/// Check for and fire INSTEAD OF triggers for an UPDATE operation.
#[allow(clippy::too_many_arguments)]