diff options
author | Vika <vika@fireburn.ru> | 2023-07-09 22:21:12 +0300 |
---|---|---|
committer | Vika <vika@fireburn.ru> | 2023-07-17 01:53:42 +0300 |
commit | dc7dfc61ec839175ebb51fcbaef1156fea5fdcf4 (patch) | |
tree | 83c935c793481864b79a6bd482f09b1622cba104 /kittybox-rs/src/database/postgres | |
parent | b38b508366a80a2f1c163ae3623c79e883323201 (diff) | |
download | kittybox-dc7dfc61ec839175ebb51fcbaef1156fea5fdcf4.tar.zst |
cargo update, part 1
Diffstat (limited to 'kittybox-rs/src/database/postgres')
-rw-r--r-- | kittybox-rs/src/database/postgres/mod.rs | 10 |
1 files changed, 5 insertions, 5 deletions
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)?; |