Function mz_environmentd::http::sql::run_ws

async fn run_ws(
    state: &WsState,
    user: Option<AuthedUser>,
    peer_addr: IpAddr,
    ws: WebSocket,
)