Function notify_insert

nodedb/src/event/alert/notify.rs:179–239

INSERT alert event into a history table via StatementExecutor.

(
    state: &SharedState,
    tenant_id: u64,
    owner: &str,
    table: &str,
    columns: &[String],
    event: &AlertEvent,
)

/// INSERT alert event into a history table via StatementExecutor.
async fn notify_insert(
    state: &SharedState,
    tenant_id: u64,
    owner: &str,
    table: &str,
    columns: &[String],
    event: &AlertEvent,
) {
    // Build INSERT statement.
    let col_list = if columns.is_empty() {
        "alert_name, group_key, severity, status, value, threshold, timestamp_ms".to_string()
    } else {
        columns.join(", ")
    };

    let values = format!(
        "'{}', '{}', '{}', '{}', {}, {}, {}",
        escape_sql(&event.alert_name),
        escape_sql(&event.group_key),
        escape_sql(&event.severity),
        escape_sql(&event.status),
        event.value,
        event.threshold,
        event.timestamp_ms,
    );

    let sql = format!("BEGIN INSERT INTO {table} ({col_list}) VALUES ({values}); END");

    let identity = alert_identity(TenantId::new(tenant_id), owner);
    let block = match crate::control::planner::procedural::parse_block(&sql) {
        Ok(b) => b,
        Err(e) => {
            warn!(
                alert = event.alert_name,
                table,
                error = %e,
                "failed to parse INSERT statement for alert history"
            );
            return;
        }
    };

    let executor = StatementExecutor::new(state, identity, TenantId::new(tenant_id), 0);
    let bindings = RowBindings::empty();

    if let Err(e) = executor.execute_block(&block, &bindings).await {
        warn!(
            alert = event.alert_name,
            table,
            error = %e,
            "failed to INSERT alert event into history table"
        );
    } else {
        info!(
            alert = event.alert_name,
            table,
            status = event.status,
            "alert event inserted into history table"