fix nightly warnings

kitsune-soc · Aug 28, 2024 · 6d15f9b · 6d15f9b
1 parent 59f8a7d
commit 6d15f9b
Show file tree

Hide file tree

Showing 6 changed files with 20 additions and 17 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/kitsune-cache/src/redis.rs b/crates/kitsune-cache/src/redis.rs
@@ -54,7 +54,7 @@ where
         let key = self.compute_key(key);
 
         debug!(%key, "Deleting cache entry");
-        self.redis_conn.del(key).await?;
+        let () = self.redis_conn.del(key).await?;
 
         Ok(())
     }
@@ -78,7 +78,8 @@ where
         let serialised = sonic_rs::to_string(value)?;
 
         debug!(%key, ttl = ?self.ttl, "Setting cache entry");
-        self.redis_conn
+        let () = self
+            .redis_conn
             .set(
                 key,
                 serialised,

diff --git a/crates/kitsune-oidc/src/state/store/redis.rs b/crates/kitsune-oidc/src/state/store/redis.rs
@@ -29,7 +29,8 @@ impl Store for Redis {
 
     async fn set(&self, key: &str, value: LoginState) -> Result<()> {
         let raw_value = sonic_rs::to_string(&value)?;
-        self.pool
+        let () = self
+            .pool
             .set(Self::format_key(key), raw_value, None, None, false)
             .await?;
 

diff --git a/lib/athena/src/redis/mod.rs b/lib/athena/src/redis/mod.rs
@@ -105,7 +105,7 @@ where
                 .duration_since(Timestamp::UNIX_EPOCH)
                 .as_seconds_f64();
 
-            client
+            let () = client
                 .zadd(
                     self.scheduled_queue_name.as_str(),
                     None,
@@ -116,7 +116,7 @@ where
                 )
                 .await?;
         } else {
-            client
+            let () = client
                 .xadd(
                     self.queue_name.as_str(),
                     false,
@@ -241,14 +241,14 @@ where
         let client = self.redis_pool.next();
         let pipeline = client.pipeline();
 
-        pipeline
+        let () = pipeline
             .xack(
                 self.queue_name.as_str(),
                 self.consumer_group.as_str(),
                 stream_id.as_str(),
             )
             .await?;
-        pipeline
+        let () = pipeline
             .xdel(self.queue_name.as_str(), &[stream_id])
             .await?;
 
@@ -279,7 +279,7 @@ where
             Outcome::Success => true, // Execution succeeded, we don't need the context anymore
         };
 
-        pipeline.last().await?;
+        let () = pipeline.last().await?;
 
         if remove_context {
             self.context_repository
@@ -297,7 +297,8 @@ where
             .get::<String>()
             .expect("[Bug] Not a string in the context");
 
-        self.redis_pool
+        let () = self
+            .redis_pool
             .xclaim(
                 self.queue_name.as_str(),
                 self.consumer_group.as_str(),

diff --git a/lib/athena/src/redis/scheduled.rs b/lib/athena/src/redis/scheduled.rs
@@ -22,7 +22,7 @@ pub struct ScheduledJobActor {
 impl ScheduledJobActor {
     async fn run(&mut self) -> Result<()> {
         let client = self.redis_pool.next();
-        SCHEDULE_SCRIPT
+        let () = SCHEDULE_SCRIPT
             .evalsha_with_reload(
                 client,
                 (self.queue_name.as_str(), self.scheduled_queue_name.as_str()),

diff --git a/lib/tower-stop-using-brave/Cargo.toml b/lib/tower-stop-using-brave/Cargo.toml
@@ -7,13 +7,13 @@ license = "MIT OR Apache-2.0"
 
 [dependencies]
 either = "1.13.0"
-futures-test = "0.3.30"
 http = "1.1.0"
 regex = "1.10.6"
 tower-layer = "0.3.3"
 tower-service = "0.3.3"
 
 [dev-dependencies]
+futures-test = "0.3.30"
 tower = { version = "0.5.0", default-features = false, features = ["util"] }
 
 [lints]