chore: Re-architecture v0.2.0

.changeset/little-rivers-bow.md

@@ -0,0 +1,2 @@
+---
+---

.changeset/pink-stingrays-learn.md

@@ -0,0 +1,2 @@
+---
+---

.changeset/yellow-berries-march.md

@@ -0,0 +1,2 @@
+---
+---

Cargo.toml

@@ -10,3 +10,7 @@ authors = ["AsPulse <contact@aspulse.dev>"]
 license = "MIT/Apache-2.0"
 edition = "2021"
 repository = "https://github.com/pulsuite/servify"
+
+[profile.size-optimized]
+inherits = "release"
+opt-level = "s"

servify/src/lib.rs

@@ -1,6 +1,2 @@
-pub use servify_macro::{export, service};
-
-pub trait ServifyExport {
-    type Request;
-    type Response;
-}
+pub mod processor;
+pub mod serial;

servify/src/processor/mod.rs

@@ -0,0 +1,56 @@
+use tokio::sync::oneshot;
+
+use crate::serial::ServifyMiddle;
+use std::any::Any;
+
+pub type ServifyMessage<T> = (
+    ServifyMiddle<<T as ServifyProcessor>::Kind, <T as ServifyProcessor>::Context>,
+    oneshot::Sender<Box<dyn Any + Send>>,
+);
+
+pub trait ServifyProcessor: Sized {
+    type Kind;
+    type Context;
+
+    fn serve(
+        &mut self,
+        middle: ServifyMiddle<Self::Kind, Self::Context>,
+    ) -> impl std::future::Future<Output = Box<dyn Any + Send>>;
+
+    fn channel(self, buffer_size: usize) -> (ServifyService<Self>, ServifyAccess<Self>) {
+        let (tx, rx) = tokio::sync::mpsc::channel(buffer_size);
+        (
+            ServifyService {
+                processor: self,
+                rx,
+            },
+            ServifyAccess { tx },
+        )
+    }
+}
+
+pub struct ServifyService<T: ServifyProcessor + Sized> {
+    processor: T,
+    rx: tokio::sync::mpsc::Receiver<ServifyMessage<T>>,
+}
+
+impl<T: ServifyProcessor + Sized> ServifyService<T> {
+    pub async fn listen(mut self) {
+        while let Some((middle, tx)) = self.rx.recv().await {
+            let response = self.processor.serve(middle).await;
+            tx.send(response).unwrap();
+        }
+    }
+}
+
+pub struct ServifyAccess<T: ServifyProcessor + Sized> {
+    pub tx: tokio::sync::mpsc::Sender<ServifyMessage<T>>,
+}
+
+impl<T: ServifyProcessor + Sized> Clone for ServifyAccess<T> {
+    fn clone(&self) -> Self {
+        Self {
+            tx: self.tx.clone(),
+        }
+    }
+}

servify/src/serial/mod.rs

@@ -0,0 +1,17 @@
+use std::any::Any;
+
+pub struct ServifyMiddle<Kind, Context> {
+    pub ctx: Context,
+    pub request: ServifyRequest<Kind>,
+}
+
+pub struct ServifyRequest<Kind> {
+    pub payload: Box<dyn Any + Send>,
+    pub kind: Kind,
+}
+
+impl<Kind> ServifyRequest<Kind> {
+    pub fn with_ctx<Context>(self, ctx: Context) -> ServifyMiddle<Kind, Context> {
+        ServifyMiddle { ctx, request: self }
+    }
+}