worker/jobs/typosquat: Replace r2d2 with deadpool

Author: Turbo87

src/worker/jobs/typosquat.rs

@@ -1,11 +1,11 @@
+use anyhow::anyhow;
 use std::sync::Arc;
 
 use crates_io_worker::BackgroundJob;
 use diesel::PgConnection;
 use typomania::Package;
 
 use crate::email::Email;
-use crate::tasks::spawn_blocking;
 use crate::{
     typosquat::{Cache, Crate},
     worker::Environment,
@@ -34,12 +34,13 @@ impl BackgroundJob for CheckTyposquat {
     async fn run(&self, env: Self::Context) -> anyhow::Result<()> {
         let crate_name = self.name.clone();
 
-        spawn_blocking(move || {
-            let mut conn = env.connection_pool.get()?;
-            let cache = env.typosquat_cache(&mut conn)?;
-            check(&env.emails, cache, &mut conn, &crate_name)
+        let conn = env.deadpool.get().await?;
+        conn.interact(move |conn| {
+            let cache = env.typosquat_cache(conn)?;
+            check(&env.emails, cache, conn, &crate_name)
         })
         .await
+        .map_err(|err| anyhow!(err.to_string()))?
     }
 }