Merge pull request #92 from code0-tech/91-add-definition-reader

Definition Reader

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.42", 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,12 @@
+pub mod version;
+
+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>,
+}

src/flow_definition/feature/mod.rs

@@ -0,0 +1,50 @@
+use tucana::shared::{DefinitionDataType, FlowType, RuntimeFunctionDefinition, Version};
+
+pub trait HasVersion {
+    fn version(&self) -> &Option<Version>;
+    fn version_mut(&mut self) -> &mut Option<Version>;
+
+    fn normalize_version(&mut self) {
+        self.version_mut().get_or_insert(Version {
+            major: 0,
+            minor: 0,
+            patch: 0,
+        });
+    }
+
+    fn is_accepted(&self, filter: &Option<Version>) -> bool {
+        filter
+            .as_ref()
+            .is_none_or(|v| self.version().as_ref() == Some(v))
+    }
+}
+
+impl HasVersion for DefinitionDataType {
+    fn version(&self) -> &Option<Version> {
+        &self.version
+    }
+
+    fn version_mut(&mut self) -> &mut Option<Version> {
+        &mut self.version
+    }
+}
+
+impl HasVersion for FlowType {
+    fn version(&self) -> &Option<Version> {
+        &self.version
+    }
+
+    fn version_mut(&mut self) -> &mut Option<Version> {
+        &mut self.version
+    }
+}
+
+impl HasVersion for RuntimeFunctionDefinition {
+    fn version(&self) -> &Option<Version> {
+        &self.version
+    }
+
+    fn version_mut(&mut self) -> &mut Option<Version> {
+        &mut self.version
+    }
+}