From b6f301b3ad689df20b065b07ca36b0f8324f4c61 Mon Sep 17 00:00:00 2001
From: Bartosz Sypytkowski <b.sypytkowski@gmail.com>
Date: Thu, 27 Jun 2024 09:01:07 +0200
Subject: [PATCH] chore: sqlx prepare workspace json

---
 ...a673ea4e196920636e4a4db9d42fad3ef4d73.json | 14 ++++++++++++
 ...dcc9d963cc033582bf2e945e8bf3a301b4247.json | 22 +++++++++++++++++++
 .../appflowy-collaborate/src/group/manager.rs | 11 +++++-----
 3 files changed, 41 insertions(+), 6 deletions(-)
 create mode 100644 .sqlx/query-884c44d3a87ca4e520f9e8cec6ba673ea4e196920636e4a4db9d42fad3ef4d73.json
 create mode 100644 .sqlx/query-a06e1d9f6f95e4c4c2b98310ebddcc9d963cc033582bf2e945e8bf3a301b4247.json

diff --git a/.sqlx/query-884c44d3a87ca4e520f9e8cec6ba673ea4e196920636e4a4db9d42fad3ef4d73.json b/.sqlx/query-884c44d3a87ca4e520f9e8cec6ba673ea4e196920636e4a4db9d42fad3ef4d73.json
new file mode 100644
index 00000000..aafc6f23
--- /dev/null
+++ b/.sqlx/query-884c44d3a87ca4e520f9e8cec6ba673ea4e196920636e4a4db9d42fad3ef4d73.json
@@ -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"
+}
diff --git a/.sqlx/query-a06e1d9f6f95e4c4c2b98310ebddcc9d963cc033582bf2e945e8bf3a301b4247.json b/.sqlx/query-a06e1d9f6f95e4c4c2b98310ebddcc9d963cc033582bf2e945e8bf3a301b4247.json
new file mode 100644
index 00000000..909e6ad4
--- /dev/null
+++ b/.sqlx/query-a06e1d9f6f95e4c4c2b98310ebddcc9d963cc033582bf2e945e8bf3a301b4247.json
@@ -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"
+}
diff --git a/services/appflowy-collaborate/src/group/manager.rs b/services/appflowy-collaborate/src/group/manager.rs
index 44ff8ea3..56ddfe87 100644
--- a/services/appflowy-collaborate/src/group/manager.rs
+++ b/services/appflowy-collaborate/src/group/manager.rs
@@ -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(