start pubsub

Cargo.lock

@@ -195,6 +195,15 @@ dependencies = [
  "twoway",
 ]
 
+[[package]]
+name = "actix-pubsub"
+version = "0.1.0"
+dependencies = [
+ "actix 0.13.0",
+ "actix-rt",
+ "crossbeam-channel",
+]
+
 [[package]]
 name = "actix-redis"
 version = "0.11.0"

Cargo.toml

@@ -1,2 +1,2 @@
 [workspace]
-members = ["api"]
+members = ["api", "actix-pubsub"]

actix-pubsub/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "actix-pubsub"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+actix = { version = "0.13", features = [] }
+actix-rt = { version = "2.7", features = [] }
+
+crossbeam-channel = { version = "0.5" }

actix-pubsub/src/lib.rs

@@ -0,0 +1,34 @@
+use std::sync::Arc;
+
+use crossbeam_channel::{Receiver, Sender};
+
+struct Message<Topic, Payload> {
+    topic: Topic,
+    payload: Payload,
+}
+
+pub trait PubSubBus<Topic, Payload> {
+    fn publisher(&self) -> Publisher<Topic, Payload>;
+
+    fn subscribe(&self, topic: Topic) -> Subscriber<Topic, Payload>;
+}
+
+pub struct PubSub<Topic, Payload> {
+    tx: Sender<Message<Topic, Payload>>,
+    rx: Receiver<Message<Topic, Payload>>,
+}
+
+pub struct Publisher<Topic, Payload> {}
+
+pub struct Subscriber<Topic, Payload> {}
+
+impl<Topic, Payload> PubSub<Topic, Payload> {
+    pub fn new() -> Self {
+        let (tx, rx) = crossbeam_channel::unbounded::<Message<Topic, Payload>>();
+        Self { rx, tx }
+    }
+}
+
+impl<Topic, Payload> actix::Actor for PubSub<Topic, Payload> {
+    type Context = actix::Context<Self>;
+}