Merge pull request #68 from code0-tech/59-drop-redis-and-rabbitmq

Drop Redis and RabbitMQ

Author: raphael-goetz

Cargo.lock

@@ -12,31 +12,17 @@ tucana = { version = "0.0.32", features = ["aquila"] }
 tokio = "1.43.0"
 async-trait = "0.1.85"
 log = "0.4.24"
-redis = { version = "0.32.0", features = [
-    "aio",
-    "tokio-comp",
-    "async-std-comp",
-    "json",
-] }
 serde_json = "1.0.138"
 serde = "1.0.138"
-lapin = "3.0.0"
-futures-lite = "2.6.0"
 tonic = "0.13.0"
 dotenv = "0.15.0"
-
-
-[dev-dependencies]
-testcontainers = "0.25.0"
-serial_test = "3.2.0"
+code0-definition-reader = "0.0.8"
 
 [lib]
 doctest = true
 
 [features]
 default = ["all"]
-flow_queue = []
-flow_store = []
 flow_definition = []
 flow_config = []
-all = ["flow_queue", "flow_store", "flow_definition", "flow_config"]
+all = ["flow_definition", "flow_config"]

Cargo.toml

@@ -32,11 +32,9 @@ pub fn load_env_file() {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use serial_test::serial;
     use std::env;
 
     #[test]
-    #[serial]
     fn test_env_with_default_string_exists() {
         let key = "TEST_STRING_VAR";
         let expected = "test_value";
@@ -54,7 +52,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_string_missing() {
         let key = "TEST_MISSING_STRING_VAR";
         unsafe {
@@ -67,7 +64,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_integer_exists() {
         let key = "TEST_INT_VAR";
         let expected = 42;
@@ -84,7 +80,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_integer_missing() {
         let key = "TEST_MISSING_INT_VAR";
         unsafe {
@@ -97,7 +92,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_boolean_exists_true() {
         let key = "TEST_BOOL_TRUE_VAR";
         unsafe {
@@ -113,7 +107,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_boolean_exists_false() {
         let key = "TEST_BOOL_FALSE_VAR";
         unsafe {
@@ -129,7 +122,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_boolean_missing() {
         let key = "TEST_MISSING_BOOL_VAR";
         unsafe {
@@ -142,7 +134,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_boolean_invalid() {
         let key = "TEST_INVALID_BOOL_VAR";
         unsafe {
@@ -158,7 +149,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_u32_exists() {
         let key = "TEST_U32_VAR";
         let expected = 42u32;
@@ -175,7 +165,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_u32_negative_invalid() {
         let key = "TEST_U32_NEGATIVE_VAR";
         unsafe {
@@ -191,7 +180,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_empty_string() {
         let key = "TEST_EMPTY_STRING_VAR";
         unsafe {
@@ -207,7 +195,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_default_whitespace_string() {
         let key = "TEST_WHITESPACE_VAR";
         unsafe {
@@ -223,7 +210,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_environment() {
         let key = "TEST_ENVIRONMENT";
         unsafe {
@@ -239,7 +225,6 @@ mod tests {
     }
 
     #[test]
-    #[serial]
     fn test_env_with_mode() {
         let key = "TEST_MODE";
         unsafe {

src/flow_config/mod.rs

@@ -16,12 +16,39 @@ pub struct FlowUpdateService {
 }
 
 impl FlowUpdateService {
-    pub fn from_url(aquila_url: String) -> Self {
+    /// Create a new FlowUpdateService instance from an Aquila URL and a definition path.
+    ///
+    /// This will read the definition files from the given path and initialize the service with the data types, runtime definitions, and flow types.
+    pub fn from_url(aquila_url: String, definition_path: &str) -> Self {
+        let mut data_types = Vec::new();
+        let mut runtime_definitions = Vec::new();
+        let mut flow_types = Vec::new();
+
+        let definitions = match code0_definition_reader::parser::Parser::from_path(definition_path)
+        {
+            Some(reader) => reader,
+            None => {
+                log::error!("No definition folder found at path: {}", definition_path);
+                return Self {
+                    aquila_url,
+                    data_types,
+                    runtime_definitions,
+                    flow_types,
+                };
+            }
+        };
+
+        for feature in definitions.features {
+            data_types.append(&mut feature.data_types.clone());
+            flow_types.append(&mut feature.flow_types.clone());
+            runtime_definitions.append(&mut feature.runtime_functions.clone());
+        }
+
         Self {
             aquila_url,
-            data_types: Vec::new(),
-            runtime_definitions: Vec::new(),
-            flow_types: Vec::new(),
+            data_types,
+            runtime_definitions,
+            flow_types,
         }
     }