Merge pull request #90 from code0-tech/89-shutdown-on-ctrl_c

raphael-goetz · web-flow · commit 141d10f33577 · 2025-11-27T17:01:17.000+01:00
Shutdown on ctrl_c
diff --git a/.env-example b/.env-example
@@ -4,4 +4,5 @@ NATS_URL='nats://localhost:4222'
 AQUILA_URL='http://localhost:8080'
 WITH_HEALTH_SERVICE=false
 GRPC_HOST='127.0.0.1'
-GRPC_PORT=50051
+GRPC_PORT=50051
+DEFINITIONS='./definitions'
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -7,15 +7,15 @@ version = "0.1.0"
 edition = "2024"
 
 [workspace.dependencies]
-code0-flow = { version = "0.0.18" }
-tucana = { version = "0.0.40" }
-tokio = { version = "1.44.1", features = ["rt-multi-thread"] }
+code0-flow = { version = "0.0.19" }
+tucana = { version = "0.0.42" }
+tokio = { version = "1.44.1", features = ["rt-multi-thread", "signal"] }
 log = "0.4.27"
 futures-lite = "2.6.0"
 rand = "0.9.1"
 base64 = "0.22.1"
 env_logger = "0.11.8"
-async-nats = "0.44.2"
+async-nats = "0.45.0"
 prost = "0.14.1"
 tonic-health = "0.14.1"
 tonic = "0.14.1"
diff --git a/taurus/Cargo.toml b/taurus/Cargo.toml
@@ -4,7 +4,7 @@ version = "0.1.0"
 edition = "2024"
 
 [dependencies]
-code0-flow = { workspace = true }
+code0-flow = { workspace = true, features = ["flow_service"] }
 tucana = { workspace = true }
 tokio = { workspace = true }
 log = { workspace = true }
diff --git a/taurus/src/config/mod.rs b/taurus/src/config/mod.rs
@@ -26,6 +26,8 @@ pub struct Config {
     pub grpc_host: String,
 
     pub grpc_port: u16,
+
+    pub definitions: String,
 }
 
 /// Implementation for all relevant `Aquila` startup configurations
@@ -36,12 +38,13 @@ impl Config {
     pub fn new() -> Self {
         Config {
             environment: env_with_default("ENVIRONMENT", Environment::Development),
-            mode: env_with_default("MODE", Mode::STATIC),
+            mode: env_with_default("MODE", Mode::DYNAMIC),
             nats_url: env_with_default("NATS_URL", String::from("nats://localhost:4222")),
             aquila_url: env_with_default("AQUILA_URL", String::from("http://localhost:50051")),
             with_health_service: env_with_default("WITH_HEALTH_SERVICE", false),
             grpc_host: env_with_default("GRPC_HOST", "127.0.0.1".to_string()),
             grpc_port: env_with_default("GRPC_PORT", 50051),
+            definitions: env_with_default("DEFINITIONS", String::from("./definitions")),
         }
     }
 }
diff --git a/taurus/src/main.rs b/taurus/src/main.rs

Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,8 @@ pub struct Config {`
`26`	`26`	`pub grpc_host: String,`
`27`	`27`
`28`	`28`	`pub grpc_port: u16,`
	`29`	`+`
	`30`	`+ pub definitions: String,`
`29`	`31`	`}`
`30`	`32`
`31`	`33`	/// Implementation for all relevant `Aquila` startup configurations
`@@ -36,12 +38,13 @@ impl Config {`
`36`	`38`	`pub fn new() -> Self {`
`37`	`39`	`Config {`
`38`	`40`	`environment: env_with_default("ENVIRONMENT", Environment::Development),`
`39`		`- mode: env_with_default("MODE", Mode::STATIC),`
	`41`	`+ mode: env_with_default("MODE", Mode::DYNAMIC),`
`40`	`42`	`nats_url: env_with_default("NATS_URL", String::from("nats://localhost:4222")),`
`41`	`43`	`aquila_url: env_with_default("AQUILA_URL", String::from("http://localhost:50051")),`
`42`	`44`	`with_health_service: env_with_default("WITH_HEALTH_SERVICE", false),`
`43`	`45`	`grpc_host: env_with_default("GRPC_HOST", "127.0.0.1".to_string()),`
`44`	`46`	`grpc_port: env_with_default("GRPC_PORT", 50051),`
	`47`	`+ definitions: env_with_default("DEFINITIONS", String::from("./definitions")),`
`45`	`48`	`}`
`46`	`49`	`}`
`47`	`50`	`}`