diff options
Diffstat (limited to 'kittybox-rs/src/webmentions/queue.rs')
| -rw-r--r-- | kittybox-rs/src/webmentions/queue.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/kittybox-rs/src/webmentions/queue.rs b/kittybox-rs/src/webmentions/queue.rs index 0b11a4e..3ced831 100644 --- a/kittybox-rs/src/webmentions/queue.rs +++ b/kittybox-rs/src/webmentions/queue.rs @@ -54,13 +54,13 @@ impl<T: PostgresJobItem> Drop for PostgresJob<T> { .push(" WHERE id = ") .push_bind(id) .build() - .execute(&mut txn) + .execute(&mut *txn) .await .unwrap(); sqlx::query_builder::QueryBuilder::new("NOTIFY ") .push(T::NOTIFICATION_CHANNEL) .build() - .execute(&mut txn) + .execute(&mut *txn) .await .unwrap(); txn.commit().await.unwrap(); @@ -79,7 +79,7 @@ impl<T: PostgresJobItem> PostgresJob<T> { .build_query_as::<(i32,)>() // It's safe to unwrap here, because we "take" the txn only on drop or commit, // where it's passed by value, not by reference. - .fetch_one(self.txn.as_mut().unwrap()) + .fetch_one(self.txn.as_deref_mut().unwrap()) .await .map(|(i,)| i as usize) } @@ -94,7 +94,7 @@ impl Job<Webmention, PostgresJobQueue<Webmention>> for PostgresJob<Webmention> { tracing::debug!("Deleting {} from the job queue", self.id); sqlx::query("DELETE FROM kittybox.incoming_webmention_queue WHERE id = $1") .bind(self.id) - .execute(self.txn.as_mut().unwrap()) + .execute(self.txn.as_deref_mut().unwrap()) .await?; self.txn.take().unwrap().commit().await @@ -149,7 +149,7 @@ impl JobQueue<Webmention> for PostgresJobQueue<Webmention> { match sqlx::query_as::<_, PostgresJobRow<Webmention>>( "SELECT id, source, target FROM kittybox.incoming_webmention_queue WHERE attempts < 5 FOR UPDATE SKIP LOCKED LIMIT 1" ) - .fetch_optional(&mut txn) + .fetch_optional(&mut *txn) .await? { Some(job_row) => { |