Function try_handle_connection 

async fn try_handle_connection(
    ws_tx: &mut SplitSink<WebSocket, Message>,
    ws_rx: SplitStream<WebSocket>,
    database: String,
    schema: String,
    table: String,
    request_id: u32,
    headers: HeaderMap,
    headers_jsonb: JsonbVal,
) -> Result<(), String>