async fn handle_connection( socket: WebSocket, database: String, schema: String, table: String, request_id: u32, headers: HeaderMap, headers_jsonb: JsonbVal, )