feat: satisfied new tucana interface

Author: raphael-goetz

crates/taurus-core/src/runtime/engine.rs

@@ -181,6 +181,7 @@ mod tests {
             value: Some(NodeValue {
                 value: Some(node_value::Value::LiteralValue(value)),
             }),
+            cast: None,
         }
     }
 
@@ -189,8 +190,11 @@ mod tests {
             database_id,
             runtime_parameter_id: runtime_parameter_id.to_string(),
             value: Some(NodeValue {
-                value: Some(node_value::Value::NodeFunctionId(node_id)),
+                value: Some(node_value::Value::SubFlow(unimplemented!(
+                    "Taurus needs to handle SubFlows (issue nr #184)"
+                ))),
             }),
+            cast: None,
         }
     }
 
@@ -208,6 +212,7 @@ mod tests {
                     paths: Vec::new(),
                 })),
             }),
+            cast: None,
         }
     }
 
@@ -276,6 +281,7 @@ mod tests {
                     paths: Vec::new(),
                 })),
             }),
+            cast: None,
         }
     }
 

crates/taurus-core/src/runtime/engine/compiler.rs

@@ -125,7 +125,7 @@ pub fn compile_flow(
             let arg = match value {
                 node_value::Value::LiteralValue(v) => CompiledArg::Literal(v.clone()),
                 node_value::Value::ReferenceValue(r) => CompiledArg::Reference(r.clone()),
-                node_value::Value::NodeFunctionId(id) => CompiledArg::DeferredNode(*id),
+                node_value::Value::SubFlow(_sub_flow) => unimplemented!("Taurus needs to handle SubFlows (issue nr #184)"),
             };
 
             parameters.push(CompiledParameter {

crates/taurus-core/src/runtime/engine/executor.rs

@@ -4,7 +4,7 @@ use std::cell::RefCell;
 use std::collections::HashMap;
 
 use futures_lite::future::block_on;
-use tucana::aquila::ExecutionRequest;
+use tucana::aquila::ActionExecutionRequest;
 use tucana::shared::reference_value::Target;
 use tucana::shared::value::Kind;
 use tucana::shared::{Struct, Value};
@@ -485,7 +485,7 @@ impl<'a> EngineExecutor<'a> {
         &self,
         node: &CompiledNode,
         values: Vec<Value>,
-    ) -> Result<ExecutionRequest, RuntimeError> {
+    ) -> Result<ActionExecutionRequest, RuntimeError> {
         if node.parameters.len() != values.len() {
             return Err(RuntimeError::new(
                 "T-CORE-000005",
@@ -499,7 +499,7 @@ impl<'a> EngineExecutor<'a> {
             fields.insert(parameter.runtime_parameter_id.clone(), value);
         }
 
-        Ok(ExecutionRequest {
+        Ok(ActionExecutionRequest {
             execution_identifier: Uuid::new_v4().to_string(),
             function_identifier: node.handler_id.clone(),
             parameters: Some(Struct { fields }),

crates/taurus-core/src/runtime/remote/mod.rs

@@ -4,15 +4,16 @@
 //! trait without coupling the core engine to a specific transport.
 
 use async_trait::async_trait;
-use tucana::{aquila::ExecutionRequest, shared::Value};
+use tucana::{aquila::ActionExecutionRequest, shared::Value};
 
 use crate::types::errors::runtime_error::RuntimeError;
 
 pub struct RemoteExecution {
     /// Remote service identifier to route the call.
     pub target_service: String,
     /// Execution request payload expected by the remote runtime.
-    pub request: ExecutionRequest,
+    pub request: ActionExecutionRequest,
+
 }
 
 #[async_trait]

crates/taurus-provider/src/providers/remote/nats_remote_runtime.rs

@@ -3,7 +3,7 @@ use prost::Message;
 use taurus_core::runtime::remote::{RemoteExecution, RemoteRuntime};
 use taurus_core::types::errors::runtime_error::RuntimeError;
 use tonic::async_trait;
-use tucana::aquila::ExecutionResult;
+use tucana::aquila::ActionExecutionResponse;
 use tucana::shared::Value;
 
 pub struct NATSRemoteRuntime {
@@ -42,8 +42,8 @@ impl RemoteRuntime for NATSRemoteRuntime {
             }
         };
 
-        let decode_result = ExecutionResult::decode(message.payload);
-        let execution_result = match decode_result {
+        let decode_result = ActionExecutionResponse::decode(message.payload);
+        let _execution_result = match decode_result {
             Ok(r) => r,
             Err(err) => {
                 log::error!(
@@ -58,24 +58,6 @@ impl RemoteRuntime for NATSRemoteRuntime {
             }
         };
 
-        match execution_result.result {
-            Some(result) => match result {
-                tucana::aquila::execution_result::Result::Success(value) => Ok(value),
-                tucana::aquila::execution_result::Result::Error(err) => {
-                    let code = err.code.to_string();
-                    let description = match err.description {
-                        Some(string) => string,
-                        None => "Unknown Error".to_string(),
-                    };
-                    let error = RuntimeError::new(code, "RemoteExecutionError", description);
-                    Err(error)
-                }
-            },
-            None => Err(RuntimeError::new(
-                "T-PROV-000003",
-                "RemoteRuntimeExeption",
-                "Result of Remote Response was empty.",
-            )),
-        }
+        unimplemented!("Taurus needs to handle text executions (issue nr #185)")
     }
 }