Merge pull request #8 from code0-tech/2-add-flow-queue

2 add flow queue

Author: raphael-goetz

Cargo.lock

@@ -1,5 +1,5 @@
 [workspace]
 
 members = [
-    "taurus_poc"
+    "taurus_poc", "taurus_queue",
 ]

Cargo.toml

@@ -0,0 +1,6 @@
+[package]
+name = "taurus_queue"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]

taurus_queue/Cargo.toml

@@ -0,0 +1,61 @@
+pub mod queue {
+
+    use std::ops::Add;
+
+    /// # Queue Prefix
+    /// - Every incoming message will have the `Send` prefix
+    /// - Every processed message (answer) from taurus will have the `Receive` prefix
+    pub enum QueuePrefix {
+        Send,
+        Receive,
+    }
+
+    /// Supported Protocols
+    pub enum QueueProtocol {
+        Rest,
+        WebSocket,
+    }
+
+    /// Implementation to turn a protocol into a str
+    impl QueueProtocol {
+
+        /// Function to turn a protocol into a str
+        ///
+        /// # Example:
+        /// ```
+        /// use taurus_queue::queue::QueueProtocol;
+        /// let proto_str = QueueProtocol::Rest.as_str().to_string();
+        /// let result = "REST".to_string();
+        ///
+        /// assert_eq!(result, proto_str);
+        /// ```
+        pub fn as_str(&self) -> &'static str {
+            match self {
+                QueueProtocol::Rest => "REST",
+                QueueProtocol::WebSocket => "WS",
+            }
+        }
+    }
+
+    /// Implementation to add a prefix and a protocol to a queue name
+    impl Add<QueueProtocol> for QueuePrefix {
+        type Output = String;
+
+        /// Function to add a prefix and a protocol to a queue name
+        ///
+        /// # Example:
+        /// ```
+        /// use taurus_queue::queue::{QueuePrefix, QueueProtocol};
+        /// let send_rest_queue_name = QueuePrefix::Send + QueueProtocol::Rest;
+        /// let result = "S_REST".to_string();
+        ///
+        /// assert_eq!(result, send_rest_queue_name);
+        /// ```
+        fn add(self, rhs: QueueProtocol) -> Self::Output {
+            match self {
+                QueuePrefix::Send => "S_".to_string() + rhs.as_str(),
+                QueuePrefix::Receive => "R_".to_string() + rhs.as_str(),
+            }
+        }
+    }
+}