feat: added flow_definition as new definition reader and moved the definitions service into its own feature

Author: raphael-goetz

Cargo.lock

@@ -8,25 +8,27 @@ homepage = "https://code0.tech"
 license = "Apache-2.0"
 
 [dependencies]
-tucana = { version = "0.0.39", features = ["aquila"] }
+tucana = { version = "0.0.41", features = ["aquila"] }
 async-trait = "0.1.85"
 log = "0.4.24"
 tonic = "0.14.1"
 dotenv = "0.15.0"
-code0-definition-reader = "0.0.18"
 tonic-health = "0.14.1"
 async-nats = "0.45.0"
 futures-core = "0.3.31"
 regex = "1.11.2"
 serde_json = "1.0.143"
+walkdir = "2.5.0"
+serde = "1.0.228"
 
 [lib]
 doctest = true
 
 [features]
 default = ["all"]
 flow_definition = []
+flow_service = ["flow_definition"]
 flow_config = []
 flow_health = []
 flow_validator = []
-all = ["flow_definition", "flow_config", "flow_health", "flow_validator"]
+all = ["flow_definition", "flow_config", "flow_health", "flow_validator", "flow_service"]

Cargo.toml

@@ -0,0 +1,23 @@
+use std::io;
+use std::path::PathBuf;
+
+#[derive(Debug)]
+pub enum ReaderError {
+    JsonError {
+        path: PathBuf,
+        error: serde_json::Error,
+    },
+    ReadFeatureError {
+        path: String,
+        source: Box<ReaderError>,
+    },
+    ReadDirectoryError {
+        path: PathBuf,
+        error: io::Error,
+    },
+    ReadFileError {
+        path: PathBuf,
+        error: io::Error,
+    },
+    DirectoryEntryError(io::Error),
+}

src/flow_definition/error/mod.rs

@@ -0,0 +1,10 @@
+use serde::Deserialize;
+use tucana::shared::{DefinitionDataType, FlowType, RuntimeFunctionDefinition};
+
+#[derive(Deserialize, Debug, Clone)]
+pub struct Feature {
+    pub name: String,
+    pub data_types: Vec<DefinitionDataType>,
+    pub flow_types: Vec<FlowType>,
+    pub functions: Vec<RuntimeFunctionDefinition>,
+}