new module endpoint

Cargo.toml

@@ -10,7 +10,7 @@ log = "0.4.26"
 env_logger = "0.11.8"
 prost = "0.14.1"
 tonic = "0.14.1"
-tucana = { version = "0.0.68", features = ["all"] }
+tucana = { version = "0.0.70", features = ["all"] }
 code0-flow = { version = "0.0.32", features = ["flow_health"] }
 serde_json = "1.0.140"
 async-nats = "0.47.0"

src/configuration/service.rs

@@ -1,27 +1,27 @@
 use serde::{Deserialize, Serialize};
 use serde_json::from_str;
 use std::{fs::File, io::Read};
-use tucana::shared::{ActionConfigurations, helper::value::from_json_value};
+use tucana::shared::{ModuleConfigurations, helper::value::from_json_value};
 
 #[derive(Serialize, Deserialize, Clone)]
-struct SerializableActionConfiguration {
+struct SerializableModuleConfiguration {
     identifier: String,
     value: serde_json::Value,
 }
 
 #[derive(Serialize, Deserialize, Clone)]
-struct SerializableActionProjectConfiguration {
+struct SerializableModuleProjectConfiguration {
     project_id: i64,
     #[serde(default)]
-    configs: Vec<SerializableActionConfiguration>,
+    configs: Vec<SerializableModuleConfiguration>,
 }
 
 #[derive(Serialize, Deserialize, Clone)]
 pub struct SerializableActionServiceConfiguration {
     token: String,
     identifier: String,
     #[serde(default)]
-    configs: Vec<SerializableActionProjectConfiguration>,
+    configs: Vec<SerializableModuleProjectConfiguration>,
 }
 
 #[derive(Serialize, Deserialize, Clone, Default)]
@@ -36,7 +36,7 @@ pub struct SerializableServiceConfiguration {
 pub struct ActionServiceConfiguration {
     token: String,
     service_name: String,
-    config: Vec<ActionConfigurations>,
+    config: Vec<ModuleConfigurations>,
 }
 
 #[derive(Serialize, Deserialize, Clone)]
@@ -51,34 +51,34 @@ pub struct ServiceConfiguration {
     runtimes: Vec<RuntimeServiceConfiguration>,
 }
 
-impl From<SerializableActionConfiguration> for tucana::shared::ActionConfiguration {
-    fn from(value: SerializableActionConfiguration) -> Self {
+impl From<SerializableModuleConfiguration> for tucana::shared::ModuleConfiguration {
+    fn from(value: SerializableModuleConfiguration) -> Self {
         Self {
             identifier: value.identifier,
             value: Some(from_json_value(value.value)),
         }
     }
 }
 
-impl From<SerializableActionProjectConfiguration> for tucana::shared::ActionProjectConfiguration {
-    fn from(value: SerializableActionProjectConfiguration) -> Self {
+impl From<SerializableModuleProjectConfiguration> for tucana::shared::ModuleProjectConfigurations {
+    fn from(value: SerializableModuleProjectConfiguration) -> Self {
         Self {
             project_id: value.project_id,
-            action_configurations: value.configs.into_iter().map(Into::into).collect(),
+            module_configurations: value.configs.into_iter().map(Into::into).collect(),
         }
     }
 }
 
 impl From<SerializableActionServiceConfiguration> for ActionServiceConfiguration {
     fn from(value: SerializableActionServiceConfiguration) -> Self {
-        let action_identifier = value.identifier.clone();
+        let module_identifier = value.identifier.clone();
 
         Self {
             token: value.token,
             service_name: value.identifier,
-            config: vec![ActionConfigurations {
-                action_identifier,
-                action_configurations: value.configs.into_iter().map(Into::into).collect(),
+            config: vec![ModuleConfigurations {
+                module_identifier,
+                module_configurations: value.configs.into_iter().map(Into::into).collect(),
             }],
         }
     }
@@ -114,7 +114,7 @@ impl ServiceConfiguration {
     pub fn get_action_configuration(
         &self,
         action_identifier: &String,
-    ) -> Vec<ActionConfigurations> {
+    ) -> Vec<ModuleConfigurations> {
         match self
             .actions
             .iter()

src/sagittarius/flow_service_client_impl.rs

@@ -21,7 +21,7 @@ pub struct SagittariusFlowClient {
     env: String,
     token: String,
     sagittarius_ready: Arc<AtomicBool>,
-    action_config_tx: broadcast::Sender<tucana::shared::ActionConfigurations>,
+    action_config_tx: broadcast::Sender<tucana::shared::ModuleConfigurations>,
 }
 
 impl SagittariusFlowClient {
@@ -31,7 +31,7 @@ impl SagittariusFlowClient {
         token: String,
         channel: Channel,
         sagittarius_ready: Arc<AtomicBool>,
-        action_config_tx: broadcast::Sender<tucana::shared::ActionConfigurations>,
+        action_config_tx: broadcast::Sender<tucana::shared::ModuleConfigurations>,
     ) -> SagittariusFlowClient {
         let client = FlowServiceClient::new(channel);
 
@@ -151,7 +151,7 @@ impl SagittariusFlowClient {
                     };
                 }
             }
-            Data::ActionConfigurations(action_configurations) => {
+            Data::ModuleConfigurations(action_configurations) => {
                 if let Err(err) = self.action_config_tx.send(action_configurations) {
                     log::warn!("No action configuration receivers available: {:?}", err);
                 }