feat: Added monorepos + Docker support

Cargo.toml

@@ -1,19 +1,3 @@
-[package]
-name = "distributed-id-indexer"
-version = "0.1.0"
-edition = "2021"
-
-[dependencies]
-dotenv = "0.15.0"
-redis = { version = "0.26.1", features = ["tokio-comp","cluster-async"] }
-tokio = { version = "1.40.0", features = ["full"] }
-actix-web = "4.3.1"
-actix-http = "3.4.0"
-serde = { version = "1.0.167", features = ["derive"] }
-serde_json = "1.0.100"
-actix = "0.13.0"
-env_logger = "0.11.0"
-lazy_static = "1.4"
-listenfd = "1.0.1"
-tracing-actix-web = "0.7"
-tracing = "0.1"
+[workspace]
+resolver = "2"
+members = ["crates/http", "crates/pubsub"]

README.md

@@ -19,10 +19,22 @@ NUM_WORKERS=
 LOG_LEVEL=
 ```
 
+### 🎁 Crates
+
+| Name | Description | Visit |
+|------|-------------|-------|
+| http | REST API Server for Retriving IDs from Redis | [Open](./crates/http/) |
+| pubsub | Redis Pub/Sub Server which saves IDs to Redis | [Open](./crates/pubsub/) |
+
 ### 🚀 Usage
 
 ```bash
-$ cargo run
+$ cargo run --bin http
+$ cargo run --bin pubsub
+
+// or
+
+$ docker-compose up
 ```
 
 ### 📝 License

crates/http/.env.example

@@ -0,0 +1,4 @@
+REDIS_URL=
+WEB_SERVER_PORT=
+NUM_WORKERS=
+LOG_LEVEL=

crates/http/Cargo.toml

@@ -0,0 +1,19 @@
+[package]
+name = "distributed-id-indexer-http"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+dotenv = "0.15.0"
+redis = { version = "0.26.1", features = ["tokio-comp","cluster-async"] }
+tokio = { version = "1.40.0", features = ["full"] }
+actix-web = "4.3.1"
+actix-http = "3.4.0"
+serde = { version = "1.0.167", features = ["derive"] }
+serde_json = "1.0.100"
+actix = "0.13.0"
+env_logger = "0.11.0"
+lazy_static = "1.4"
+listenfd = "1.0.1"
+tracing-actix-web = "0.7"
+tracing = "0.1"

crates/http/Dockerfile

@@ -0,0 +1,14 @@
+FROM rust:1.80.1-slim-bullseye
+
+# View app name in Cargo.toml
+ARG APP_NAME=distributed-id-indexer-http
+
+WORKDIR /app
+
+COPY . .
+RUN cargo build --release
+RUN cp ./target/release/$APP_NAME /distributed-id-indexer-http
+
+EXPOSE 8000
+
+CMD ["/distributed-id-indexer-http"]

crates/http/README.md

@@ -0,0 +1,3 @@
+### http - crate
+
+REST API Server for Retriving IDs from Redis

crates/http/src/libs/redis.rs

@@ -0,0 +1,17 @@
+use redis::AsyncCommands;
+
+pub async fn connection_to_redis(
+    redis_url: &str,
+) -> redis::Client {
+    let client: redis::Client = redis::Client::open(redis_url).unwrap();
+    client
+}
+
+pub async fn get_value(connection: &mut redis::aio::MultiplexedConnection, key: &str) -> String {
+    let value = connection.get(key).await;
+
+    match value {
+        Ok(value) => value,
+        Err(_) => "".to_string(),
+    }
+}

src/main.rs → crates/http/src/main.rs

@@ -5,12 +5,6 @@ mod controller;
 
 #[tokio::main]
 async fn main() {
-    tokio::task::spawn_blocking(|| {
-        let _ = libs::redis::start_pub_sub();
-
-        println!("PubSub started");
-    });
-
     tokio::task::spawn_blocking(|| {
         let _ = libs::http::start_web_server();
 

crates/pubsub/.env.example

@@ -0,0 +1 @@
+REDIS_URL=

crates/pubsub/Cargo.toml

@@ -0,0 +1,19 @@
+[package]
+name = "distributed-id-indexer-pubsub"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+dotenv = "0.15.0"
+redis = { version = "0.26.1", features = ["tokio-comp","cluster-async"] }
+tokio = { version = "1.40.0", features = ["full"] }
+actix-web = "4.3.1"
+actix-http = "3.4.0"
+serde = { version = "1.0.167", features = ["derive"] }
+serde_json = "1.0.100"
+actix = "0.13.0"
+env_logger = "0.11.0"
+lazy_static = "1.4"
+listenfd = "1.0.1"
+tracing-actix-web = "0.7"
+tracing = "0.1"

crates/pubsub/Dockerfile

@@ -0,0 +1,12 @@
+FROM rust:1.80.1-slim-bullseye
+
+# View app name in Cargo.toml
+ARG APP_NAME=distributed-id-indexer-pubsub
+
+WORKDIR /app
+
+COPY . .
+RUN cargo build --release
+RUN cp ./target/release/$APP_NAME /distributed-id-indexer-pubsub
+
+CMD ["/distributed-id-indexer-pubsub"]

crates/pubsub/README.md

@@ -0,0 +1,3 @@
+### pubsub - crate
+
+Redis Pub/Sub Server which saves IDs to Redis

crates/pubsub/src/config/env.rs

@@ -0,0 +1,20 @@
+use std::env;
+use dotenv::dotenv;
+
+pub struct Env {
+    pub redis_url: String,
+}
+
+impl Env {
+    pub fn new() -> Self {
+        dotenv().ok();
+
+        Self {
+            redis_url: env::var("REDIS_URL").expect("REDIS_URL must be set"),
+        }
+    }
+}
+
+pub fn get_env() -> Env {
+    Env::new()
+}

crates/pubsub/src/config/mod.rs

@@ -0,0 +1 @@
+pub mod env;

crates/pubsub/src/libs/mod.rs

@@ -0,0 +1 @@
+pub mod redis;

src/libs/redis.rs → crates/pubsub/src/libs/redis.rs

@@ -3,7 +3,6 @@ use redis::AsyncCommands;
 pub async fn connection_to_redis(
     redis_url: &str,
 ) -> redis::Client {
-    // read the redis connection string from the environment
     let client: redis::Client = redis::Client::open(redis_url).unwrap();
     client
 }
@@ -33,11 +32,12 @@ pub async fn start_pub_sub() {
 
     pubsub.psubscribe("snowflake:id:set:*").unwrap();
 
+    println!("Subscribed to snowflake:id:set:*");
+
     loop {
         let msg = pubsub.get_message().unwrap();
         let payload: String = msg.get_payload().unwrap();
 
-        // Payload is in the format of "a-z:a-z:0-9"
         let payload_parts: Vec<&str> = payload.split(":").collect();
 
         if payload_parts.len() != 3 {

crates/pubsub/src/main.rs

@@ -0,0 +1,9 @@
+mod config;
+mod libs;
+
+#[tokio::main]
+async fn main() {
+    let _ = libs::redis::start_pub_sub().await;
+
+    println!("PubSub started");
+}

docker-compose.yaml

@@ -0,0 +1,41 @@
+version: '3.7'
+
+services:
+  http:
+    build:
+      context: ./crates/http
+      dockerfile: Dockerfile
+    ports:
+      - "8181:4000"
+    depends_on:
+      - redis
+    environment:
+      - REDIS_URL=redis://redis:6379
+      - WEB_SERVER_PORT=4000
+      - NUM_WORKERS=1
+      - LOG_LEVEL="info"
+    networks:
+      - dii
+
+  pubsub:
+    build:
+      context: ./crates/pubsub
+      dockerfile: Dockerfile
+    depends_on:
+      - redis
+    environment:
+      - REDIS_URL=redis://redis:6379
+    networks:
+      - dii
+
+  redis:
+    image: "redis:alpine"
+    networks:
+      - dii
+    ports:
+      - "6380:6379"
+
+networks:
+  dii:
+
+