Merge pull request #349 from code0-tech/revert-341-#269-action-flow

Revert "action flow"

Author: raphael-goetz

proto/aquila/aquila.action.proto

@@ -7,21 +7,6 @@ package aquila;
 import "shared.module.proto";
 import "shared.execution_result.proto";
 import "shared.struct.proto";
-import "shared.flow.proto";
-import "shared.translation.proto";
-import "shared.errors.proto";
-
-message ActionFlow {
-  int64 flow_id = 1;
-  int64 project_id = 2;
-
-  repeated shared.FlowSetting settings = 3;
-  shared.Struct input_schema = 4;
-  shared.Struct output_schema = 5;
-  string project_slug = 6;
-
-  string name = 7;
-}
 
 // Event that gets admitted by an action
 message ActionEvent {
@@ -51,36 +36,13 @@ message ActionExecutionRequest {
   int64 project_id = 4;
 }
 
-message ActionFlowExecutioRequest {
-  string execution_identifier = 1;
-  string flow_id = 2;
-  shared.Value payload = 3;
-}
-
 message ActionExecutionResponse {
-  // Execution identifier of execution
+   // Execution identifier of execution
   string execution_identifier = 1;
   // Result of execution
   shared.NodeExecutionResult node_result = 2;
 }
 
-message ActionFlowExecutionResponse {
-  // Execution identifier of execution
-  string execution_identifier = 1;
-   oneof result {
-    shared.Value success = 2;
-    shared.Error failure = 3;
-   }
-}
-
-message ActionFlowUpdate {
-  oneof data {
-    ActionFlow updated_flow = 1;
-    int64 deleted_flow = 2;
-  }
-}
-
-// Messages sent by the Action
 message ActionTransferRequest {
   oneof data {
     // Identification of the action
@@ -92,20 +54,15 @@ message ActionTransferRequest {
     ActionEvent event = 2;
     // Result of execution that was triggered by a execution request
     ActionExecutionResponse result = 3;
-    // Result of an flow execution
-    ActionFlowExecutionResponse flow_execution_response = 4;
   }
 }
 
-// Messages sent by Aquila
 message ActionTransferResponse {
   oneof data {
     // Execution request
     ActionExecutionRequest execution = 1;
     // ModuleConfigurations that have been configured by the user
     shared.ModuleConfigurations module_configurations = 2;
-    // An Action Flow update
-    ActionFlowUpdate flow_update = 3;
   }
 }
 

proto/shared/shared.flow.proto

@@ -6,7 +6,6 @@ package shared;
 
 import "shared.struct.proto";
 import "shared.data_type.proto";
-import "shared.translation.proto";
 
 message ValidationFlow {
   // Database ID -> req. for Aquila to identify in FlowStore
@@ -22,12 +21,6 @@ message ValidationFlow {
   string project_slug = 8;
   optional string disable_reason = 9;
   string signature = 10;
-
-  optional string definition_source = 11;
-  shared.Struct input_schema = 12;
-  shared.Struct output_schema = 13;
- 
-  string name = 14;
 }
 
 message ExecutionFlow {

proto/velorum/velorum.info.proto

@@ -4,6 +4,10 @@ option ruby_package = "Tucana::Velorum";
 
 package velorum;
 
+import "shared.function.proto";
+import "shared.data_type.proto";
+import "shared.flow.proto";
+
 message ModelsRequest {}
 
 message Model {