feat: added connection and connection buildup tests

Author: raphael-goetz

src/flow_queue/connection.rs

@@ -21,3 +21,21 @@ pub async fn get_flow_channel(uri: &str) -> FlowChannel {
         Err(error) => panic!("Cannot create channel {:?}", error),
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use crate::flow_queue::connection::connect;
+    use testcontainers::core::{IntoContainerPort, WaitFor};
+    use testcontainers::runners::AsyncRunner;
+    use testcontainers::GenericImage;
+    use crate::rabbitmq_container_test;
+
+    rabbitmq_container_test!(test_rabbitmq_startup, (|url: String| async move {
+        println!("RabbitMQ started with the url: {}", url);
+    }));  
+    
+    rabbitmq_container_test!(test_rabbitmq_connection, (|url: String| async move {
+        connect(&*url).await;
+    }));
+
+}

src/flow_store/connection.rs

@@ -1,7 +1,27 @@
 use redis::Client;
 
 pub fn build_connection(redis_url: String) -> Client {
-    Client::open(redis_url).unwrap_or_else(|err| {
-        panic!("Cannot connect to redis instance! Reason: {err}")
-    })
-}
+    match Client::open(redis_url) {
+        Ok(client) => client,
+        Err(con_error) => panic!("{}", con_error),
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use testcontainers::core::IntoContainerPort;
+    use testcontainers::runners::AsyncRunner;
+    use testcontainers::GenericImage;
+    use testcontainers::core::WaitFor;
+    use crate::flow_store::connection::build_connection;
+    use crate::redis_container_test;
+    
+    redis_container_test!(test_redis_startup, (|url: String| async move {
+        println!("Redis server started correctly on: {}", url);
+    }));
+    
+    redis_container_test!(test_redis_connection, (|url: String| async move {
+        let result = build_connection(url).get_connection();
+        assert!(result.is_ok());
+    }));
+}

src/lib.rs

@@ -2,4 +2,6 @@
 pub mod flow_store;
 
 #[cfg(feature = "flow_queue")]
-pub mod flow_queue;
+pub mod flow_queue;
+
+pub mod container;