feat(streamer): implementing protobuf for NotifBrokerActor

Cargo.toml

@@ -12,7 +12,6 @@ members = [
 [dependencies]
 migration = { path = "migration", name = "migration" }
 crypter = { path = "crypter", name = "crypter" }
-capnp-rpc = "0.19.4"
 salvo = { version = "0.71.1", features = ["full"] }
 actix = "0.13.5"
 actix-web = "4"
@@ -30,7 +29,6 @@ is_type = "0.2.1"
 rayon = "1.10.0"
 rand = "0.8"
 rslock = "0.4.0"
-tonic = "0.12"
 futures = "0.3"
 deadpool-lapin = { version = "0.12.1", features = ["serde", "rt_tokio_1"] }
 deadpool-redis = "0.16.0"
@@ -68,11 +66,6 @@ rand_chacha = "0.3"
 chacha20 = "0.9"
 indexmap = "2.4"
 
-
-[[bin]]
-name = "playground"
-path = "playground/main.rs"
-
 [[bin]]
 path = "src/app.rs"
 name = "hoopoe"
@@ -84,11 +77,5 @@ lto = true
 codegen-units = 1
 overflow-checks = true # panic on any overflow
 
-[build-dependencies]
-tonic-build = "0.10.2"
-
-[dependencies.capnp]
-version = "0.19.0"
-
 [profile.dev.package.sqlx-macros]
 opt-level = 3

docs/Rmq.md

@@ -115,8 +115,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     channel
         .basic_publish(
-            "",
-            request_queue,
+            "", // "" means direct exchange
+            request_queue, // in direct exchange routing key is the same as the queue name
             BasicPublishOptions::default(),
             request_payload.to_vec(),
             BasicProperties::default()
@@ -207,8 +207,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             let response_payload = b"Response Payload";
             channel
                 .basic_publish(
-                    "",
-                    reply_to.as_str(),
+                    "", // "" means direct exchange
+                    reply_to.as_str(), // in direct exchange routing key is the same as the queue name 
                     BasicPublishOptions::default(),
                     response_payload.to_vec(),
                     BasicProperties::default()

src/app.rs

@@ -82,7 +82,6 @@ use indexmap::IndexMap;
 use models::event::NotifData;
 use salvo::http::response;
 use serde_json::Value;
-use tests::{actor, orex};
 use workers::notif::{self, NotifBrokerActor};
 use std::io::BufWriter;
 use std::str::FromStr;

src/middlewares/check_token.rs

@@ -1,7 +1,6 @@
 
 
 
-use capnp::data;
 use context::AppContext;
 use interfaces::passport::Passport;
 use models::user::UserData;

src/storage.rs

@@ -1,4 +1,5 @@
 
 
 
-pub mod engine;
+pub mod engine;
+pub mod cruft;