Function kill_user_sessions

nodedb/src/control/server/pgwire/ddl/session_ddl.rs:176–216

KILL USER SESSIONS ' '

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    parts: &[&str],
)

/// KILL USER SESSIONS '<auth_user_id>'
pub fn kill_user_sessions(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    parts: &[&str],
) -> PgWireResult<Vec<Response>> {
    if !identity.is_superuser {
        return Err(sqlstate_error(
            "42501",
            "permission denied: requires superuser",
        ));
    }
    if parts.len() < 4 {
        return Err(sqlstate_error(
            "42601",
            "syntax: KILL USER SESSIONS '<auth_user_id>'",
        ));
    }
    let user_id_str = parts[3].trim_matches('\'');
    let user_id: u64 = user_id_str.parse().map_err(|_| {
        sqlstate_error(
            "22003",
            &format!("invalid user_id '{user_id_str}': must be numeric"),
        )
    })?;

    let killed = state.session_registry.kill_sessions_for_user(
        user_id,
        crate::control::security::sessions::KillReason::AdminKill,
    );

    state.audit_record(
        crate::control::security::audit::AuditEvent::AdminAction,
        Some(identity.tenant_id),
        &identity.username,
        &format!("killed {killed} sessions for user_id={user_id}"),
    );

    Ok(vec![Response::Execution(Tag::new(&format!(
        "KILL {killed}"
    )))])
}

/// VERIFY AUDIT CHAIN
pub fn verify_audit_chain(