authorization: Bearer <keycloak-issued-jwt>

rpc DeployAgent(DeployAgentRequest) returns (DeployAgentResponse);

message DeployAgentRequest {
  string manifest_yaml = 1;  // Complete Agent manifest YAML
}

message DeployAgentResponse {
  string agent_id = 1;       // UUID of the created/updated agent
  string name = 2;
  string status = 3;         // "deployed"
}

rpc GetAgent(GetAgentRequest) returns (GetAgentResponse);

message GetAgentRequest {
  string agent_id = 1;      // UUID or name
}

message GetAgentResponse {
  string agent_id = 1;
  string name = 2;
  string status = 3;        // deployed | paused | archived
  string manifest_yaml = 4;
  google.protobuf.Timestamp created_at = 5;
  google.protobuf.Timestamp updated_at = 6;
  map<string, string> labels = 7;
}

rpc ListAgents(ListAgentsRequest) returns (ListAgentsResponse);

message ListAgentsRequest {
  string status_filter = 1;           // optional; "deployed" | "paused" | "archived"
  map<string, string> label_filter = 2;  // optional; filter by labels
}

message ListAgentsResponse {
  repeated AgentSummary agents = 1;
}

rpc StartExecution(StartExecutionRequest) returns (StartExecutionResponse);

message StartExecutionRequest {
  string agent_id = 1;              // UUID or agent name
  string input_json = 2;            // JSON input for bootstrap.py
  optional uint32 max_iterations = 3; // override manifest default
}

message StartExecutionResponse {
  string execution_id = 1;
  string status = 2;                // "pending"
}

rpc GetExecution(GetExecutionRequest) returns (GetExecutionResponse);

message GetExecutionResponse {
  string execution_id = 1;
  string agent_id = 2;
  string status = 3;                // pending | running | completed | failed | cancelled
  uint32 total_iterations = 4;
  optional string final_output = 5;
  google.protobuf.Timestamp started_at = 6;
  optional google.protobuf.Timestamp ended_at = 7;
  repeated IterationSummary iterations = 8;
}

message IterationSummary {
  uint32 number = 1;
  string status = 2;               // running | failed | refining | success
  optional float validation_score = 3;
  google.protobuf.Timestamp started_at = 4;
  optional google.protobuf.Timestamp ended_at = 5;
}

rpc StreamExecution(StreamExecutionRequest) returns (stream ExecutionEvent);

message StreamExecutionRequest {
  string execution_id = 1;
}

message ExecutionEvent {
  string event_type = 1;  // ExecutionStarted | IterationStarted | IterationCompleted | ...
  string payload_json = 2; // JSON-encoded event payload
  google.protobuf.Timestamp timestamp = 3;
}

rpc CancelExecution(CancelExecutionRequest) returns (CancelExecutionResponse);

rpc DeployWorkflow(DeployWorkflowRequest) returns (DeployWorkflowResponse);

rpc StartWorkflow(StartWorkflowRequest) returns (StartWorkflowResponse);

message StartWorkflowRequest {
  string workflow_id = 1;    // UUID or workflow name
  string input_json = 2;     // JSON input available as {{input.*}} templates
}

message StartWorkflowResponse {
  string workflow_execution_id = 1;
}

rpc SignalWorkflowExecution(SignalWorkflowRequest) returns (SignalWorkflowResponse);

message SignalWorkflowRequest {
  string workflow_execution_id = 1;
  string state_name = 2;
  string payload_json = 3;   // Written directly to Blackboard[state_name]
}

rpc StreamWorkflow(StreamWorkflowRequest) returns (stream WorkflowEvent);