diff options
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)?; |