WIP feat: services comm using redis

chain/Cargo.toml

@@ -33,6 +33,10 @@ diesel.workspace = true
 orm.workspace = true
 clap-verbosity-flag.workspace = true
 futures.workspace = true
+futures-util.workspace = true
+serde.workspace = true
+deadpool-redis = "0.15.1"
+redis =  {version = "0.25.0", features = ["streams"]}
 
 [build-dependencies]
 vergen = { version = "8.0.0", features = ["build", "git", "gitcl"] }

chain/run.sh

@@ -1,4 +1,5 @@
 . ../.env
 export TENDERMINT_URL
 export DATABASE_URL
+export QUEUE_URL
 cargo run -- --initial-query-retry-time 5

chain/src/app_state.rs

@@ -2,14 +2,16 @@ use std::env;
 
 use anyhow::Context;
 use deadpool_diesel::postgres::{Object, Pool as DbPool};
+use deadpool_redis::{Config, Pool as RedisPool, Runtime};
 
 #[derive(Clone)]
 pub struct AppState {
     db: DbPool,
+    redis: RedisPool,
 }
 
 impl AppState {
-    pub fn new(db_url: String) -> anyhow::Result<Self> {
+    pub fn new(db_url: String, redis_url: String) -> anyhow::Result<Self> {
         let max_pool_size = env::var("DATABASE_POOL_SIZE")
             .unwrap_or_else(|_| 8.to_string())
             .parse::<usize>()
@@ -23,7 +25,13 @@ impl AppState {
             .build()
             .context("Failed to build Postgres db pool")?;
 
-        Ok(Self { db: pool })
+        let cfg = Config::from_url(redis_url);
+        let redis_pool = cfg.create_pool(Some(Runtime::Tokio1)).unwrap();
+
+        Ok(Self {
+            db: pool,
+            redis: redis_pool,
+        })
     }
 
     pub async fn get_db_connection(&self) -> anyhow::Result<Object> {
@@ -32,4 +40,13 @@ impl AppState {
             .await
             .context("Failed to get db connection handle from deadpool")
     }
+
+    pub async fn get_redis_connection(
+        &self,
+    ) -> anyhow::Result<deadpool_redis::Connection> {
+        self.redis
+            .get()
+            .await
+            .context("Failed to get redis connection handle from deadpool")
+    }
 }

chain/src/config.rs

@@ -15,14 +15,17 @@ impl Display for CargoEnv {
     }
 }
 
-#[derive(clap::Parser)]
+#[derive(clap::Parser, Clone)]
 pub struct AppConfig {
     #[clap(long, env)]
     pub tendermint_url: String,
 
     #[clap(long, env)]
     pub database_url: String,
 
+    #[clap(long, env)]
+    pub queue_url: String,
+
     #[clap(long, env)]
     pub initial_query_retry_time: u64,