Function execute_then_action

nodedb/src/control/event_trigger.rs:124–179

Execute a THEN action string as SQL. Template variables are substituted before execution: - `$document_id` → the affected document ID - `$collection` → the collection name - `$operation` → "insert", "update", or "delete"

(
    shared: &SharedState,
    event: &ChangeEvent,
    action: &str,
    trigger_name: &str,
)

/// - `$collection` → the collection name
/// - `$operation` → "insert", "update", or "delete"
async fn execute_then_action(
    shared: &SharedState,
    event: &ChangeEvent,
    action: &str,
    trigger_name: &str,
) {
    let sql = action
        .replace("$document_id", &event.document_id)
        .replace("$collection", &event.collection)
        .replace("$operation", event.operation.as_str());

    let query_ctx = QueryContext::for_state(shared);

    match query_ctx
        .plan_sql(&sql, event.tenant_id, crate::types::DatabaseId::DEFAULT)
        .await
    {
        Ok(tasks) => {
            for task in tasks {
                match crate::control::server::dispatch_utils::dispatch_to_data_plane(
                    shared,
                    task.tenant_id,
                    task.vshard_id,
                    task.plan,
                    TraceId::ZERO,
                )
                .await
                {
                    Ok(_) => {
                        info!(
                            trigger = trigger_name,
                            sql = sql,
                            "event trigger action executed"
                        );
                    }
                    Err(e) => {
                        warn!(
                            trigger = trigger_name,
                            sql = sql,
                            error = %e,
                            "event trigger action dispatch failed"
                        );
                    }
                }
            }
        }
        Err(e) => {
            warn!(
                trigger = trigger_name,
                sql = sql,
                error = %e,
                "event trigger action plan failed"
            );
        }
    }
}