feat: added flow queue

Author: raphael-goetz

code0-flow/src/flow_queue/connection.rs

@@ -0,0 +1,41 @@
+use rabbitmq_stream_client::Environment;
+use std::sync::Arc;
+use tokio::sync::Mutex;
+
+pub type FlowQueue = Arc<Mutex<Box<Environment>>>;
+
+pub struct RedisConfiguration {
+    host: String,
+    port: u16,
+    username: String,
+    password: String,
+}
+
+impl RedisConfiguration {
+    pub fn new(host: String, port: u16, username: String, password: String) -> Self {
+        Self {
+            host,
+            port,
+            username,
+            password,
+        }
+    }
+}
+
+pub async fn init_rabbitmq(redis_configuration: RedisConfiguration) -> FlowQueue {
+    Arc::new(Mutex::new(Box::new(connect(redis_configuration).await)))
+}
+
+async fn connect(redis_configuration: RedisConfiguration) -> Environment {
+    match Environment::builder()
+        .host(&*redis_configuration.host)
+        .port(redis_configuration.port)
+        .username(&*redis_configuration.username)
+        .password(&*redis_configuration.password)
+        .build()
+        .await
+    {
+        Ok(env) => env,
+        Err(error) => panic!("Cannot connect to redis instance! Reason: {:?}", error),
+    }
+}

code0-flow/src/flow_queue/mod.rs

@@ -0,0 +1,2 @@
+pub mod connection;
+pub mod service;

code0-flow/src/flow_queue/service.rs

@@ -0,0 +1,58 @@
+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 code0_flow::flow_queue::service::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 code0_flow::flow_queue::service::{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(),
+        }
+    }
+}