diff --git a/crates/collab/src/db/queries/channels.rs b/crates/collab/src/db/queries/channels.rs index e26da783b7611b1fe106063180859d6ba4902952..f517256f55d407ade22923b1924bd21cd4ace615 100644 --- a/crates/collab/src/db/queries/channels.rs +++ b/crates/collab/src/db/queries/channels.rs @@ -501,8 +501,10 @@ impl Database { /// Returns all channels for the user with the given ID. pub async fn get_channels_for_user(&self, user_id: UserId) -> Result { - self.transaction(|tx| async move { self.get_user_channels(user_id, None, true, &tx).await }) - .await + self.weak_transaction( + |tx| async move { self.get_user_channels(user_id, None, true, &tx).await }, + ) + .await } /// Returns all channels for the user with the given ID that are descendants diff --git a/crates/collab/src/db/queries/contacts.rs b/crates/collab/src/db/queries/contacts.rs index 8521814bdb6b5264d4270259ac6828b82b77859b..e1e063ce23ecd14912e7985f656bd9f2cf2132ed 100644 --- a/crates/collab/src/db/queries/contacts.rs +++ b/crates/collab/src/db/queries/contacts.rs @@ -15,7 +15,7 @@ impl Database { user_b_busy: bool, } - self.transaction(|tx| async move { + self.weak_transaction(|tx| async move { let user_a_participant = Alias::new("user_a_participant"); let user_b_participant = Alias::new("user_b_participant"); let mut db_contacts = contact::Entity::find() @@ -91,7 +91,7 @@ impl Database { /// Returns whether the given user is a busy (on a call). pub async fn is_user_busy(&self, user_id: UserId) -> Result { - self.transaction(|tx| async move { + self.weak_transaction(|tx| async move { let participant = room_participant::Entity::find() .filter(room_participant::Column::UserId.eq(user_id)) .one(&*tx) diff --git a/crates/collab/src/db/queries/rooms.rs b/crates/collab/src/db/queries/rooms.rs index 2eb1d0efa0b12ff8e3928bb8c75359e6a9ea39c0..0ffc46b185e17934cbacd94746589ee2f3af33c5 100644 --- a/crates/collab/src/db/queries/rooms.rs +++ b/crates/collab/src/db/queries/rooms.rs @@ -80,7 +80,7 @@ impl Database { &self, user_id: UserId, ) -> Result> { - self.transaction(|tx| async move { + self.weak_transaction(|tx| async move { let pending_participant = room_participant::Entity::find() .filter( room_participant::Column::UserId