feat: satisfied new tucana grpc interface

Author: raphael-goetz

crates/taurus/src/app/mod.rs

@@ -1,19 +1,17 @@
 mod worker;
 
-use std::sync::Arc;
-use std::time::Duration;
-
 use code0_flow::flow_config::load_env_file;
 use code0_flow::flow_config::mode::Mode::DYNAMIC;
 use code0_flow::flow_service::FlowUpdateService;
+use std::sync::Arc;
+use std::time::Duration;
 use taurus_core::runtime::engine::ExecutionEngine;
 use taurus_provider::providers::emitter::nats_emitter::NATSRespondEmitter;
 use taurus_provider::providers::remote::nats_remote_runtime::NATSRemoteRuntime;
 use tokio::signal;
 use tokio::task::JoinHandle;
 use tokio::time::sleep;
 use tonic_health::pb::health_server::HealthServer;
-use tucana::shared::{RuntimeFeature, Translation};
 
 use crate::client::runtime_status::TaurusRuntimeStatusService;
 use crate::client::runtime_usage::TaurusRuntimeUsageService;
@@ -124,7 +122,6 @@ async fn setup_dynamic_services_if_needed(
             config.aquila_url.clone(),
             config.aquila_token.clone(),
             "taurus".into(),
-            runtime_features(),
         )
         .await,
     ));
@@ -152,7 +149,9 @@ async fn setup_dynamic_services_if_needed(
             loop {
                 interval.tick().await;
                 status_service
-                    .update_runtime_status(tucana::shared::execution_runtime_status::Status::Running)
+                    .update_runtime_status(
+                        tucana::shared::execution_runtime_status::Status::Running,
+                    )
                     .await;
             }
         });
@@ -198,19 +197,6 @@ async fn push_definitions_until_success(config: &Config) {
     }
 }
 
-fn runtime_features() -> Vec<RuntimeFeature> {
-    vec![RuntimeFeature {
-        name: vec![Translation {
-            code: "en-US".to_string(),
-            content: "Runtime".to_string(),
-        }],
-        description: vec![Translation {
-            code: "en-US".to_string(),
-            content: "Will execute incoming flows.".to_string(),
-        }],
-    }]
-}
-
 async fn update_stopped_status(runtime_status_service: Option<&Arc<TaurusRuntimeStatusService>>) {
     if let Some(status_service) = runtime_status_service {
         status_service

crates/taurus/src/client/runtime_status.rs

@@ -9,37 +9,25 @@ use tucana::{
         RuntimeStatusUpdateRequest, runtime_status_service_client::RuntimeStatusServiceClient,
         runtime_status_update_request::Status,
     },
-    shared::{ExecutionRuntimeStatus, RuntimeFeature},
+    shared::ExecutionRuntimeStatus,
 };
 
 pub struct TaurusRuntimeStatusService {
     channel: Channel,
     identifier: String,
-    features: Vec<RuntimeFeature>,
     aquila_token: String,
 }
 
 impl TaurusRuntimeStatusService {
-    pub async fn from_url(
-        aquila_url: String,
-        aquila_token: String,
-        identifier: String,
-        features: Vec<RuntimeFeature>,
-    ) -> Self {
+    pub async fn from_url(aquila_url: String, aquila_token: String, identifier: String) -> Self {
         let channel = create_channel_with_retry("Aquila", aquila_url).await;
-        Self::new(channel, aquila_token, identifier, features)
+        Self::new(channel, aquila_token, identifier)
     }
 
-    pub fn new(
-        channel: Channel,
-        aquila_token: String,
-        identifier: String,
-        features: Vec<RuntimeFeature>,
-    ) -> Self {
+    pub fn new(channel: Channel, aquila_token: String, identifier: String) -> Self {
         TaurusRuntimeStatusService {
             channel,
             identifier,
-            features,
             aquila_token,
         }
     }
@@ -68,7 +56,6 @@ impl TaurusRuntimeStatusService {
                     status: status.into(),
                     timestamp: timestamp as i64,
                     identifier: self.identifier.clone(),
-                    features: self.features.clone(),
                 })),
             },
         );