Move to deadpool-redis for managing redis connections (#77)

* Move to deadpool-redis for managing redis connections

* Update versions

Author: CCXLV

Cargo.lock

@@ -3,7 +3,7 @@ members = ["crates/fluxqueue-common", "crates/fluxqueue-worker"]
 
 [package]
 name = "fluxqueue_core"
-version = "0.1.0-beta.4"
+version = "0.2.0-beta.1"
 edition = "2024"
 
 [lib]
@@ -14,7 +14,7 @@ crate-type = ["cdylib"]
 pyo3 = { version = "0.27.2", features = ["experimental-async"] }
 pyo3-async-runtimes = { version = "0.27.0", features = ["tokio-runtime"] }
 tokio = { version = "1.49.0", features = ["rt-multi-thread", "sync"] }
-redis = "1.0.3"
+deadpool-redis = { version = "0.22.1", features = ["rt_tokio_1"] }
 fluxqueue-common = { path = "./crates/fluxqueue-common" }
 
 [workspace.dependencies]

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "fluxqueue-common"
-version = "0.1.0"
+version = "0.2.0-beta.1"
 edition = "2024"
 
 [lib]
@@ -10,7 +10,7 @@ path = "src/lib.rs"
 [dependencies]
 anyhow = "1.0.100"
 pyo3 = "0.27.2"
-redis = { version = "1.0.3", features = ["connection-manager", "tokio-comp"] }
+deadpool-redis = { version = "0.22.1", features = ["rt_tokio_1"] }
 rmp-serde = "1.3.1"
 rmpv = { version = "1.3.1", features = ["with-serde"] }
 serde = { version = "1.0.228", features = ["derive"] }

crates/fluxqueue-common/Cargo.toml

@@ -1,15 +1,21 @@
 use anyhow::{Context, Result};
-use redis::Client;
-use redis::aio::ConnectionManager;
+use deadpool_redis::{Connection, redis};
 
 use crate::get_queue_key;
 
-pub fn get_redis_client(redis_url: &str) -> Result<Client> {
-    let client = redis::Client::open(redis_url).context("Failed to connect to Redis")?;
-    Ok(client)
+pub fn get_redis_connection(redis_url: &str) -> Result<redis::Connection> {
+    let client = redis::Client::open(redis_url).context("Failed to create Redis client")?;
+    let conn = client
+        .get_connection()
+        .context("Failed to connect to Redis")?;
+    Ok(conn)
 }
 
-pub fn push_task(conn: &mut Client, queue_name: String, task_blob: Vec<u8>) -> Result<()> {
+pub fn push_task(
+    conn: &mut redis::Connection,
+    queue_name: String,
+    task_blob: Vec<u8>,
+) -> Result<()> {
     let queue_key = get_queue_key(&queue_name);
 
     let _: () = redis::cmd("LPUSH")
@@ -22,7 +28,7 @@ pub fn push_task(conn: &mut Client, queue_name: String, task_blob: Vec<u8>) -> R
 }
 
 pub async fn push_task_async(
-    conn: &mut ConnectionManager,
+    conn: &mut Connection,
     queue_name: String,
     task_blob: Vec<u8>,
 ) -> Result<()> {

crates/fluxqueue-common/src/redis/client.rs

@@ -1,6 +1,6 @@
 [package]
 name = "fluxqueue-worker"
-version = "0.1.0-beta.2"
+version = "0.2.0-beta.1"
 edition = "2024"
 
 [lib]
@@ -14,7 +14,7 @@ path = "src/main.rs"
 [dependencies]
 pyo3-async-runtimes = { version = "0.27.0", features = ["tokio-runtime"] }
 uuid = { version = "1.20.0", features = ["v4"] }
-redis = { version = "1.0.3", features = ["connection-manager", "tokio-comp"] }
+redis = "0.32.7"
 tokio = { version = "1.49.0", features = [
   "macros",
   "rt-multi-thread",
@@ -33,3 +33,4 @@ pythonize = "0.27.0"
 chrono = "0.4.43"
 
 fluxqueue-common.workspace = true
+deadpool-redis = { version = "0.22.1", features = ["rt_tokio_1"] }