chore: sqlx prepare workspace json

This commit is contained in:
Bartosz Sypytkowski 2024-06-27 09:01:07 +02:00
parent cce52a5185
commit b6f301b3ad
3 changed files with 41 additions and 6 deletions

View File

@ -0,0 +1,14 @@
{
"db_name": "PostgreSQL",
"query": "\n UPDATE auth.users\n SET role = 'supabase_admin', email_confirmed_at = NOW()\n WHERE id = $1\n ",
"describe": {
"columns": [],
"parameters": {
"Left": [
"Uuid"
]
},
"nullable": []
},
"hash": "884c44d3a87ca4e520f9e8cec6ba673ea4e196920636e4a4db9d42fad3ef4d73"
}

View File

@ -0,0 +1,22 @@
{
"db_name": "PostgreSQL",
"query": "SELECT pg_advisory_xact_lock($1)",
"describe": {
"columns": [
{
"ordinal": 0,
"name": "pg_advisory_xact_lock",
"type_info": "Void"
}
],
"parameters": {
"Left": [
"Int8"
]
},
"nullable": [
null
]
},
"hash": "a06e1d9f6f95e4c4c2b98310ebddcc9d963cc033582bf2e945e8bf3a301b4247"
}

View File

@ -244,16 +244,15 @@ where
);
let mut indexer = self.indexer_provider.indexer_for(collab_type.clone());
if indexer.is_some() {
if !self
if indexer.is_some()
&& !self
.indexer_provider
.can_index_workspace(workspace_id)
.await
.map_err(|e| RealtimeError::Internal(e.into()))?
{
tracing::trace!("workspace {} indexing is disabled", workspace_id);
indexer = None;
}
{
tracing::trace!("workspace {} indexing is disabled", workspace_id);
indexer = None;
}
let group = Arc::new(
CollabGroup::new(