feat(raiko): init redis impl

Cargo.toml

@@ -14,7 +14,7 @@ members = [
     "provers/sgx/setup",
     "pipeline",
     "core",
-    "tasks",
+    "taskdb",
 ]
 
 # Always optimize; building and running the guest takes much longer without optimization.
@@ -36,7 +36,7 @@ opt-level = 3
 # raiko
 raiko-lib = { path = "./lib", features = ["std"] }
 raiko-core = { path = "./core" }
-raiko-tasks = { path = "./tasks" }
+raiko-tasks = { path = "./taskdb" }
 
 # reth
 reth-primitives = { git = "https://github.com/taikoxyz/taiko-reth.git", branch = "v1.0.0-rc.2-taiko", default-features = false, features = [
@@ -165,6 +165,9 @@ thiserror-no-std = "2.0.2"
 # SQLite
 rusqlite = { version = "0.31.0", features = ["bundled"] }
 
+# redis
+redis = { version = "0.27.0" }
+
 # misc
 hashbrown = { version = "0.14", features = ["inline-more"] }
 tempfile = "3.8"

tasks/Cargo.toml → taskdb/Cargo.toml

@@ -2,12 +2,12 @@
 name = "raiko-tasks"
 version = "0.1.0"
 authors = ["Taiko Labs"]
-edition = "2021" 
+edition = "2021"
 
 [dependencies]
 raiko-lib = { workspace = true }
 raiko-core = { workspace = true }
-rusqlite = { workspace = true, features = ["chrono"] }
+rusqlite = { workspace = true, features = ["chrono"], optional = true }
 num_enum = { workspace = true }
 chrono = { workspace = true, features = ["serde"] }
 thiserror = { workspace = true }
@@ -19,6 +19,7 @@ anyhow = { workspace = true }
 tokio = { workspace = true }
 async-trait = { workspace = true }
 utoipa = { workspace = true }
+redis = { workspace = true, optional = true }
 
 [dev-dependencies]
 rand = "0.9.0-alpha.1"                                            # This is an alpha version, that has rng.gen_iter::<T>()
@@ -29,8 +30,10 @@ rusqlite = { workspace = true, features = ["trace"] }
 
 [features]
 default = ["in-memory"]
-sqlite = []
+sqlite = ["rusqlite"]
 in-memory = []
+redis-db = ["redis"]
+
 
 [[test]]
 name = "tasks_tests"

tasks/src/lib.rs → taskdb/src/lib.rs

@@ -17,15 +17,18 @@ use crate::{adv_sqlite::SqliteTaskManager, mem_db::InMemoryTaskManager};
 
 mod adv_sqlite;
 mod mem_db;
+mod redis;
 
 // Types
 // ----------------------------------------------------------------
-#[derive(PartialEq, Debug, thiserror::Error)]
+#[derive(Debug, thiserror::Error)]
 pub enum TaskManagerError {
     #[error("IO Error {0}")]
     IOError(IOErrorKind),
     #[error("SQL Error {0}")]
     SqlError(String),
+    #[error("Redis Error {0}")]
+    RedisError(#[from] crate::redis::RedisDbError),
     #[error("No data for query")]
     NoData,
     #[error("Anyhow error: {0}")]
@@ -183,6 +186,7 @@ pub type TaskReport = (TaskDescriptor, TaskStatus);
 pub struct TaskManagerOpts {
     pub sqlite_file: PathBuf,
     pub max_db_size: usize,
+    pub redis_url: String,
 }
 
 #[async_trait::async_trait]
@@ -465,6 +469,7 @@ mod test {
         let opts = TaskManagerOpts {
             sqlite_file: sqlite_file.to_path_buf(),
             max_db_size: 1024 * 1024,
+            redis_url: "redis://localhost:6379".to_string(),
         };
         let mut task_manager = get_task_manager(&opts);