Update redis version to 0.27

Author: DavidBM

Cargo.toml

@@ -1,9 +1,7 @@
 [package]
 name = "rsmq_async"
-version = "12.0.0"
-authors = [
-    "David Bonet <webbonet@gmail.com>"
-]
+version = "13.0.0"
+authors = ["David Bonet <webbonet@gmail.com>"]
 edition = "2021"
 license = "MIT"
 description = "Async RSMQ port to rust. RSMQ is a simple redis queue system that works in any redis v2.4+. It contains the same methods as the original one in https://github.com/smrchy/rsmq"
@@ -18,13 +16,17 @@ rand = "^0.8"
 radix_fmt = "^1"
 bb8 = "^0.8"
 thiserror = "^1"
-redis = { version = "^0.25", default-features = false, features = ["acl", "keep-alive", "script"] }
+redis = { version = "^0.27", default-features = false, features = [
+    "acl",
+    "keep-alive",
+    "script",
+] }
 async-trait = "^0.1"
-tokio = { version = "^1", optional = true}
+tokio = { version = "^1", optional = true }
 
 [dev-dependencies]
 net2 = "^0.2"
-tokio = { version = "^1", features = ["rt-multi-thread"]}
+tokio = { version = "^1", features = ["rt-multi-thread"] }
 
 [features]
 default = ["tokio-comp", "sync"]

src/functions.rs

@@ -117,7 +117,7 @@ impl<T: ConnectionLike> RsmqFunctions<T> {
         number_in_range(hidden, 0, JS_COMPAT_MAX_TIME_MILLIS)?;
 
         cached_script
-            .invoke_change_message_visibility::<_, T>(
+            .invoke_change_message_visibility::<(), T>(
                 conn,
                 format!("{}:{}", self.ns, qname),
                 message_id.to_string(),
@@ -205,7 +205,7 @@ impl<T: ConnectionLike> RsmqFunctions<T> {
         redis::cmd("SADD")
             .arg(format!("{}:QUEUES", self.ns))
             .arg(qname)
-            .query_async::<_, ()>(conn)
+            .query_async::<()>(conn)
             .await?;
 
         Ok(())
@@ -463,7 +463,7 @@ impl<T: ConnectionLike> RsmqFunctions<T> {
             redis::cmd("PUBLISH")
                 .arg(format!("{}:rt:{}", self.ns, qname))
                 .arg(result[3])
-                .query_async::<_, ()>(conn)
+                .query_async::<()>(conn)
                 .await?;
         }
 
@@ -534,7 +534,7 @@ impl<T: ConnectionLike> RsmqFunctions<T> {
                 .arg(maxsize);
         }
 
-        commands.query_async::<_, ()>(conn).await?;
+        commands.query_async::<()>(conn).await?;
 
         self.get_queue_attributes(conn, qname).await
     }

src/multiplexed_facade.rs

@@ -31,6 +31,7 @@ impl Rsmq {
                 db: options.db.into(),
                 username: options.username,
                 password: options.password,
+                protocol: options.protocol,
             },
         };
 

src/pooled_facade.rs

@@ -75,6 +75,7 @@ impl PooledRsmq {
                 db: options.db.into(),
                 username: options.username,
                 password: options.password,
+                protocol: options.protocol,
             },
         };
 

src/redis-scripts/changeMessageVisibility.lua

@@ -1,6 +1,19 @@
-local msg = redis.call("ZSCORE", KEYS[1], KEYS[2])
-if not msg then
+-- changeMessageVisibility.lua
+-- This script changes the visibility timestamp of a message in a Redis sorted set.
+-- KEYS[1]: The Redis key for the sorted set representing the message queue.
+-- KEYS[2]: The message ID whose visibility is to be updated.
+-- KEYS[3]: The new visibility timestamp to be set for the message.
+
+-- Retrieve the current score (visibility timestamp) of the message
+local currentScore = redis.call("ZSCORE", KEYS[1], KEYS[2])
+
+-- If the message does not exist in the sorted set, return false
+if not currentScore then
     return false
 end
+
+-- Update the message's visibility timestamp (score) to the new value provided
 redis.call("ZADD", KEYS[1], KEYS[3], KEYS[2])
+
+-- Return true indicating that the visibility has been successfully updated
 return true

src/sync_facade.rs

@@ -39,6 +39,7 @@ impl RsmqSync {
                 db: options.db.into(),
                 username: options.username,
                 password: options.password,
+                protocol: options.protocol,
             },
         };
 

src/types.rs

@@ -1,3 +1,4 @@
+use redis::ProtocolVersion;
 use std::{convert::TryFrom, time::Duration};
 
 #[derive(Debug)]
@@ -27,6 +28,8 @@ pub struct RsmqOptions {
     pub password: Option<String>,
     /// RSMQ namespace (you can have several. "rsmq" by default)
     pub ns: String,
+    /// Redisa protocol. Defaults to RESP2
+    pub protocol: ProtocolVersion,
 }
 
 impl Default for RsmqOptions {
@@ -39,6 +42,7 @@ impl Default for RsmqOptions {
             username: None,
             password: None,
             ns: "rsmq".to_string(),
+            protocol: ProtocolVersion::RESP2,
         }
     }
 }
@@ -99,7 +103,7 @@ pub struct RsmqQueueAttributes {
 /// ```rust,ignore
 /// use std::convert::TryFrom;
 /// use rsmq_async::RedisBytes;
-///  
+///
 /// impl TryFrom<RedisBytes> for String {
 ///     type Error = Vec<u8>;
 ///

tests/support/mod.rs

@@ -91,6 +91,7 @@ impl TestContext {
                 db: 0,
                 username: None,
                 password: None,
+                ..Default::default()
             },
         })
         .unwrap();