From dc7dfc61ec839175ebb51fcbaef1156fea5fdcf4 Mon Sep 17 00:00:00 2001
From: Vika <vika@fireburn.ru>
Date: Sun, 9 Jul 2023 22:21:12 +0300
Subject: cargo update, part 1

---
 kittybox-rs/src/database/postgres/mod.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

(limited to 'kittybox-rs/src/database/postgres/mod.rs')

diff --git a/kittybox-rs/src/database/postgres/mod.rs b/kittybox-rs/src/database/postgres/mod.rs
index 4ac2abe..286a965 100644
--- a/kittybox-rs/src/database/postgres/mod.rs
+++ b/kittybox-rs/src/database/postgres/mod.rs
@@ -134,7 +134,7 @@ impl Storage for PostgresStorage {
         let mut txn = self.db.begin().await?;
         let (uid, mut post) = sqlx::query_as::<_, (String, serde_json::Value)>("SELECT uid, mf2 FROM kittybox.mf2_json WHERE uid = $1 OR mf2['properties']['url'] ? $1 FOR UPDATE")
             .bind(url)
-            .fetch_optional(&mut txn)
+            .fetch_optional(&mut *txn)
             .await?
             .ok_or(StorageError::from_static(
                 ErrorKind::NotFound,
@@ -178,7 +178,7 @@ impl Storage for PostgresStorage {
         sqlx::query("UPDATE kittybox.mf2_json SET mf2 = $2 WHERE uid = $1")
             .bind(uid)
             .bind(post)
-            .execute(&mut txn)
+            .execute(&mut *txn)
             .await?;
             
         txn.commit().await.map_err(Into::into)
@@ -273,14 +273,14 @@ ORDER BY mf2 #>> '{properties,published,0}' DESC
     ) -> Result<Option<(serde_json::Value, Option<String>)>> {
         let mut txn = self.db.begin().await?;
         sqlx::query("SET TRANSACTION ISOLATION LEVEL REPEATABLE READ, READ ONLY")
-			.execute(&mut txn)
+			.execute(&mut *txn)
 			.await?;
         tracing::debug!("Started txn: {:?}", txn);
         let mut feed = match sqlx::query_scalar::<_, serde_json::Value>("
 SELECT kittybox.hydrate_author(mf2) FROM kittybox.mf2_json WHERE uid = $1
 ")
             .bind(url)
-            .fetch_optional(&mut txn)
+            .fetch_optional(&mut *txn)
             .await?
         {
             Some(feed) => feed,
@@ -315,7 +315,7 @@ LIMIT $2"
             .bind(limit as i64)
             .bind(user)
             .bind(cursor)
-            .fetch_all(&mut txn)
+            .fetch_all(&mut *txn)
             .await
             .map(serde_json::Value::Array)?;
 
-- 
cgit 1.4.1