Function parse_create_trigger

nodedb-sql/src/ddl_ast/parse/trigger.rs:70–118

Structural extraction for `CREATE [OR REPLACE] [SYNC|DEFERRED] TRIGGER`. Extracts all fields as primitive types. The handler converts timing/events/ granularity strings to their respective enums.

(upper: &str, trimmed: &str)

/// Extracts all fields as primitive types. The handler converts timing/events/
/// granularity strings to their respective enums.
fn parse_create_trigger(upper: &str, trimmed: &str) -> NodedbStatement {
    let (or_replace, execution_mode, rest_original) = strip_create_trigger_prefix(upper, trimmed);

    let (header_original, header_upper, body_sql) = split_header_and_body(rest_original);

    let tokens_orig: Vec<&str> = header_original.split_whitespace().collect();
    let tokens_upper: Vec<String> = tokens_orig.iter().map(|t| t.to_uppercase()).collect();

    let name = tokens_orig
        .first()
        .map(|s| s.to_lowercase())
        .unwrap_or_default();

    let mut i = 1usize;

    let timing = parse_timing_token(&tokens_upper, &mut i);
    let (events_insert, events_update, events_delete) = parse_event_tokens(&tokens_upper, &mut i);

    if i < tokens_upper.len() && tokens_upper[i] == "ON" {
        i += 1;
    }
    let collection = tokens_orig
        .get(i)
        .map(|s| s.to_lowercase())
        .unwrap_or_default();
    i += 1;

    let granularity = parse_granularity_tokens(&tokens_upper, &mut i);
    let when_condition =
        extract_when_condition(&header_upper, &header_original, &tokens_upper, &mut i);
    let priority = parse_priority_token(&tokens_orig, &tokens_upper, &mut i);
    let security = parse_security_token(&tokens_upper, &mut i);

    NodedbStatement::Automation(AutomationStmt::CreateTrigger {
        or_replace,
        execution_mode,
        name,
        timing,
        events_insert,
        events_update,
        events_delete,
        collection,
        granularity,
        when_condition,
        priority,
        security,
        body_sql,
    })
}

/// Strip `CREATE [OR REPLACE] [SYNC|DEFERRED] TRIGGER ` prefix.
/// Returns `(or_replace, execution_mode, original_rest)`.