Skip to content

Commit

Permalink
feat: updated proto files to latest communication-planing
Browse files Browse the repository at this point in the history
raphael-goetz committed Aug 27, 2024
1 parent d1b6817 commit 4d59650
Showing 9 changed files with 19 additions and 89 deletions.
23 changes: 9 additions & 14 deletions internal/flow.proto
Original file line number Diff line number Diff line change
@@ -5,28 +5,26 @@ option ruby_package = "Tucana::Internal";
package internal;

import "node.proto";
import "flow_type.proto";
import "flow_definition.proto";

message Flow {
int64 flow_id = 1;
Node starting_node = 2;
FlowType type = 3;
FlowDefinition definition = 3;
}

enum FlowCommandType {
INSERT = 0;
DELETE = 1;
}

//Sagittarius sends flow to be updated
message FlowRequest {
Flow updated_flow = 1;
FlowCommandType type = 2;
//Aquila sends a request to initialise stream to Sagittarius
message FlowLogonRequest {
}

//Aquila response with success or failure
//Sagittarius sends flow to be updated
message FlowResponse {
bool success = 1;
Flow updated_flow = 1;
FlowCommandType type = 2;
}

//All ids of flows that Aquila holds
@@ -42,10 +40,7 @@ message FlowGetResponse {
repeated int64 deleted_flow_ids = 2;
}

service FlowAquilaService {
rpc Update (stream FlowRequest) returns (stream FlowResponse) {}
}

service FlowSagittariusService {
service FlowService {
rpc Get (FlowGetRequest) returns (FlowGetResponse) {}
rpc Update (FlowLogonRequest) returns (stream FlowResponse) {}
}
1 change: 0 additions & 1 deletion internal/flow_definition.proto
Original file line number Diff line number Diff line change
@@ -5,5 +5,4 @@ option ruby_package = "Tucana::Internal";
package internal;

message FlowDefinition {
int32 id = 1;
}
13 changes: 0 additions & 13 deletions internal/flow_type.proto

This file was deleted.

14 changes: 0 additions & 14 deletions internal/function_definition.proto

This file was deleted.

18 changes: 8 additions & 10 deletions internal/node.proto
Original file line number Diff line number Diff line change
@@ -4,19 +4,17 @@ option ruby_package = "Tucana::Internal";

package internal;

import "function_definition.proto";
import "parameter_definition.proto";
import "runtime_function_definition.proto";
import "runtime_parameter_definition.proto";

message Node {
int64 node_id = 1;
FunctionDefinition function_definition = 2;
optional Node next_node = 3;
RuntimeFunctionDefinition definition = 1;
optional Node next_node = 2;
repeated Parameter parameters = 3;
}

message Parameter {
int64 id = 1;
Node parent = 2;
ParameterDefinition parameter_definition = 3;
string name = 4;
optional Node sub_node = 5;
RuntimeParameterDefinition definition = 1;
optional string value = 2;
optional Node sub_node = 3;
}
15 changes: 0 additions & 15 deletions internal/parameter_definition.proto

This file was deleted.

16 changes: 0 additions & 16 deletions internal/rule.proto

This file was deleted.

5 changes: 1 addition & 4 deletions internal/runtime_function_definition.proto
Original file line number Diff line number Diff line change
@@ -2,11 +2,8 @@ syntax = "proto3";

option ruby_package = "Tucana::Internal";

import "definitions.proto";

package internal;

message RuntimeFunctionDefinition {
int32 id = 1;
shared.DataType return_type = 2;
string id = 1;
}
Original file line number Diff line number Diff line change
@@ -4,7 +4,6 @@ option ruby_package = "Tucana::Internal";

package internal;

message Variable {
message RuntimeParameterDefinition {
string name = 1;
string type = 2;
}

0 comments on commit 4d59650

Please sign in to comment.