fix: corrected tests

Author: raphael-goetz

.env

@@ -1,5 +1,5 @@
 REDIS_URL='redis://localhost:6379'
 ENVIRONMENT='development'
-MODE='dynamic'
+MODE='static'
 RUNTIME_TOKEN="<token>"
-FLOW_FALLBACK_PATH='../flow/test_flow_one.json'
+FLOW_FALLBACK_PATH='./flow/test_flow_one.json'

Cargo.lock

@@ -5,7 +5,6 @@ edition = "2024"
 
 [dependencies]
 tokio = { version = "1.44.1", features = ["rt-multi-thread"] }
-dotenv = "0.15.0"
 futures = "0.3.31"
 log = "0.4.26"
 env_logger = "0.11.8"

Cargo.toml

@@ -112,7 +112,7 @@ mod test {
         };
 
         let id = get_flow_identifier(&rest);
-        assert_eq!(id, String::from("1::1::REST::abc.code0.tech::GET"))
+        assert_eq!(id, String::from("1.1.REST.abc.code0.tech.GET"))
     }
 
     #[test]

src/flow/mod.rs

@@ -5,8 +5,11 @@ use prost::Message;
 use sagittarius::flow_service_client_impl::SagittariusFlowClient;
 use serde_json::from_str;
 use server::AquilaGRPCServer;
-use std::{fs::File, io::Read, sync::Arc};
-use tucana::shared::Flows;
+use std::{collections::HashMap, fs::File, io::Read, sync::Arc};
+use tucana::shared::{
+    FlowSetting, Flows, NodeFunction, NodeParameter, NodeValue, Struct, ValidationFlow, Value,
+    node_value, value::Kind,
+};
 
 pub mod authorization;
 pub mod configuration;
@@ -17,6 +20,77 @@ pub mod stream;
 
 #[tokio::main]
 async fn main() {
+    let flow = ValidationFlow {
+        flow_id: 1,
+        project_id: 1,
+        r#type: String::from("REST"),
+        data_types: vec![],
+        input_type_identifier: Some(String::from("HTTP_REQUEST")),
+        return_type_identifier: Some(String::from("HTTP_RESPONSE")),
+        settings: vec![
+            FlowSetting {
+                database_id: 1,
+                flow_setting_id: String::from("HTTP_METHOD"),
+                object: Some(Struct {
+                    fields: HashMap::from([(
+                        String::from("method"),
+                        Value {
+                            kind: Some(Kind::StringValue(String::from("GET"))),
+                        },
+                    )]),
+                }),
+            },
+            FlowSetting {
+                database_id: 1,
+                flow_setting_id: String::from("HTTP_URL"),
+                object: Some(Struct {
+                    fields: HashMap::from([(
+                        String::from("url"),
+                        Value {
+                            kind: Some(Kind::StringValue(String::from("/hello-world"))),
+                        },
+                    )]),
+                }),
+            },
+            FlowSetting {
+                database_id: 1,
+                flow_setting_id: String::from("HTTP_HOST"),
+                object: Some(Struct {
+                    fields: HashMap::from([(
+                        String::from("host"),
+                        Value {
+                            kind: Some(Kind::StringValue(String::from("localhost"))),
+                        },
+                    )]),
+                }),
+            },
+        ],
+        starting_node: Some(NodeFunction {
+            database_id: 1,
+            runtime_function_id: String::from("std::control::break"),
+            next_node: None,
+            parameters: vec![NodeParameter {
+                database_id: 1,
+                runtime_parameter_id: String::from("value"),
+                value: Some(NodeValue {
+                    value: Some(node_value::Value::LiteralValue(Value {
+                        kind: Some(Kind::StructValue(Struct {
+                            fields: HashMap::from([(
+                                String::from("hallo"),
+                                Value {
+                                    kind: Some(Kind::StringValue(String::from("welt"))),
+                                },
+                            )]),
+                        })),
+                    })),
+                }),
+            }],
+        }),
+    };
+
+    let s = serde_json::to_string_pretty(&flow).unwrap();
+    println!("{}", s);
+
     log::info!("Starting Aquila...");
 
     // Configure Logging
@@ -106,6 +180,7 @@ async fn init_flows_from_json(
     for flow in flows.flows {
         let key = get_flow_identifier(&flow);
         let bytes = flow.encode_to_vec();
+        log::info!("Inserting flow with key {}", &key);
         match flow_store_client.put(key, bytes.into()).await {
             Ok(_) => log::info!("Flow updated successfully"),
             Err(err) => log::error!("Failed to update flow. Reason: {:?}", err),