Function dispatch_sql

nodedb/src/control/sql_dispatch/dispatch.rs:25–40

Attempt to dispatch `sql` as a NodeDB SQL extension. Returns `Some(result)` if the statement was handled (e.g. `PUBLISH TO`), or `None` if the SQL should be handled by the caller via `plan_sql`. The caller is responsible for handling `None`.

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    sql: &str,
)

///
/// The caller is responsible for handling `None`.
pub async fn dispatch_sql(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    sql: &str,
) -> Option<crate::Result<DispatchOutcome>> {
    let trimmed = sql.trim().trim_end_matches(';').trim();
    let upper = trimmed.to_uppercase();

    // ── PUBLISH TO <topic> <payload> ─────────────────────────────────────────
    if upper.starts_with("PUBLISH TO ") {
        return Some(handle_publish(state, identity, trimmed).await);
    }

    // Not a handled NodeDB extension — caller should use plan_sql.
    None
}

/// Handle `PUBLISH TO <topic> <payload>` without pgwire coupling.
async fn handle_publish(