feat: implemented new config system

Author: raphael-goetz

.env-example

@@ -0,0 +1,4 @@
+ENVIRONMENT='development'
+MODE='dynamic'
+RABBITMQ_URL='amqp://localhost:5672'
+AQUILA_URL='http://localhost:8080'

.gitignore

@@ -4,3 +4,5 @@ target
 .DS_Store
 ./out
 out
+
+.env

src/configuration.rs

@@ -0,0 +1,38 @@
+use code0_flow::flow_config::{env_with_default, environment::Environment, mode::Mode};
+
+/// Struct for all relevant `Taurus` startup configurations
+pub struct Config {
+    /// Options:
+    /// `development` (default)
+    /// `staging`
+    /// `production`
+    pub environment: Environment,
+
+    /// Aquila mode
+    ///
+    /// Options:
+    /// `static` (default)
+    /// `hybrid`
+    pub mode: Mode,
+
+    /// Verification Token required for internal communication
+    pub rabbitmq_url: String,
+
+    /// URL to the `Sagittarius` Server.
+    pub aquila_url: String,
+}
+
+/// Implementation for all relevant `Aquila` startup configurations
+///
+/// Behavior:
+/// Searches for the env. file at root level. Filename: `.env`
+impl Config {
+    pub fn new() -> Self {
+        Config {
+            environment: env_with_default("ENVIRONMENT", Environment::Development),
+            mode: env_with_default("MODE", Mode::STATIC),
+            rabbitmq_url: env_with_default("RABBITMQ_URL", String::from("amqp://localhost:5672")),
+            aquila_url: env_with_default("AQUILA_URL", String::from("http://localhost:8080")),
+        }
+    }
+}

src/main.rs

@@ -1,12 +1,15 @@
+mod configuration;
 pub mod context;
 pub mod error;
 pub mod implementation;
 pub mod locale;
 pub mod registry;
-
 use std::sync::Arc;
 
-use code0_flow::flow_queue::service::{Message, RabbitmqClient};
+use code0_flow::{
+    flow_config::load_env_file,
+    flow_queue::service::{Message, RabbitmqClient},
+};
 use context::{Context, ContextEntry, ContextResult};
 use error::RuntimeError;
 use futures_lite::StreamExt;
@@ -15,6 +18,8 @@ use locale::locale::Locale;
 use registry::FunctionStore;
 use tucana::shared::{Flow, NodeFunction, Value};
 
+use crate::configuration::Config;
+
 fn handle_node_function(
     function: NodeFunction,
     store: &FunctionStore,
@@ -165,10 +170,18 @@ fn handle_message(message: Message, store: &FunctionStore) -> Result<Message, la
 
 #[tokio::main]
 async fn main() {
+    env_logger::Builder::from_default_env()
+        .filter_level(log::LevelFilter::Debug)
+        .init();
+
+    load_env_file();
+
+    let config = Config::new();
+
     let _locale = Locale::default();
     let store = FunctionStore::new();
 
-    let rabbitmq_client = Arc::new(RabbitmqClient::new("amqp://localhost:5672").await);
+    let rabbitmq_client = Arc::new(RabbitmqClient::new(config.rabbitmq_url.as_str()).await);
 
     let mut consumer = {
         let channel = rabbitmq_client.channel.lock().await;