syntax = "proto3";

package astro_run_server;

import "astro_run.proto";

message Event {
  string event_name = 1;
  oneof payload {
    astro_run.Context run = 2;
    astro_run.RunWorkflowEvent run_workflow_event = 3;
    astro_run.RunJobEvent run_job_event = 4;
    astro_run.RunStepEvent run_step_event = 5;
    astro_run.WorkflowRunResult workflow_completed_event = 6;
    astro_run.JobRunResult job_completed_event = 7;
    astro_run.StepRunResult step_completed_event = 8;
    astro_run.WorkflowStateEvent workflow_state_event = 9;
    astro_run.WorkflowLog log_event = 10;
    astro_run.Signal signal_event = 11;
    string error = 12;
  }
}

message ReportLogResponse {}

message ReportRunCompletedRequest {
  string id = 1;
  astro_run.RunResult result = 2;
}

message ReportRunCompletedResponse {}

service AstroRunService {
  rpc SubscribeEvents(astro_run.RunnerMetadata) returns (stream Event) {}
  rpc ReportLog(astro_run.WorkflowLog) returns (ReportLogResponse) {}
  rpc ReportRunCompleted(ReportRunCompletedRequest) returns (ReportRunCompletedResponse) {}
}