Merge pull request #108 from code0-tech/41-test-execution-endpoint

Test Execution Endpoint

Author: raphael-goetz

README.md

@@ -58,14 +58,14 @@ services that Sagittarius must implement as a server.
 │   ├── flow - Flow service (handles flow updates)
 │   ├── flow_definition - FlowType service (handles flow_type updates)
 │   ├── ping - Ping service (performs life checks)
-│   └── runtime_function - Service for updating the runtime functions
+│   ├── runtime_function - Service for updating the runtime functions
+│   └── test_execution - Service and Types for the test execution
 └── shared
     ├── data_type - Defines types for data types
     ├── event - Defines types for events
     ├── flow - Defines types for flows
     ├── flow_definition - Defines a definition for a Flow
     ├── runtime_function_definition - Defines types for runtime functions
     ├── struct - Defines types for json representations
-    ├── test_execution - Defines types test execution
     └── translation - Contains translations with country codes and translated messages
 ```

proto/sagittarius/sagittarius.text_execution.proto

@@ -0,0 +1,46 @@
+syntax = "proto3";
+
+option ruby_package = "Tucana::Sagittarius";
+
+package sagittarius;
+
+import "shared.struct.proto";
+
+message Logon {}
+
+message TestExecutionRequest {
+    int64 flow_id = 1;
+    string execution_uuid = 2;
+    shared.Value body = 3;
+}
+
+message TestExecutionResponse {
+    int64 flow_id = 1;
+    string execution_uuid = 2;
+    shared.Value result = 3;
+    repeated Log logs = 4;
+}
+
+message Log {
+    string message = 1;
+    string level = 2;
+    string timestamp = 3;
+}
+
+// Aquila sends a logon request to Sagittarius that initiates a stream
+// If the stream is initialized it will return the result after it received a request
+message ExecutionLogonRequest {
+    oneof data {
+        Logon logon = 1;
+        TestExecutionResponse response = 2;
+    }
+}
+
+// Sagittarius sends execution requests
+message ExecutionLogonResponse {
+  TestExecutionRequest request = 1;
+}
+
+service ExecutionService {
+  rpc Test (stream ExecutionLogonRequest) returns (stream ExecutionLogonResponse) {}
+}