jasper.proto

syntax = "proto3";

package jasper;
option go_package = "internal";

import "google/protobuf/empty.proto";
import "google/protobuf/timestamp.proto";
import "google/protobuf/duration.proto";

message LoggerConfig {
  oneof producer {
    DefaultLoggerOptions default = 1;
    FileLoggerOptions file = 2;
    InheritedLoggerOptions inherited = 3;
    InMemoryLoggerOptions in_memory = 4;
    RawLoggerConfig raw = 5;
    SplunkLoggerOptions splunk = 6;
  }
}

message LogLevel {
  int32 threshold = 1;
  int32 default = 2;
}

message BufferOptions {
  bool buffered = 1;
  int64 duration = 2;
  int64 max_size = 3;
}

enum LogFormat {
  LOGFORMATUNKNOWN = 0;
  LOGFORMATDEFAULT = 1;
  LOGFORMATJSON = 2;
  LOGFORMATPLAIN = 3;
}

message BaseOptions {
  LogLevel level = 1;
  BufferOptions buffer = 2;
  LogFormat format = 3;
}

message DefaultLoggerOptions {
  string prefix = 1;
  BaseOptions base = 2;
}

message FileLoggerOptions {
  string filename = 1;
  BaseOptions base = 2;
}

message InheritedLoggerOptions {
  BaseOptions base = 1;
}

message InMemoryLoggerOptions {
  int64 in_memory_cap = 1;
  BaseOptions base = 2;
}

message SplunkInfo {
  string url = 1;
  string token = 2;
  string channel = 3;
}

message SplunkLoggerOptions {
  SplunkInfo splunk = 1;
  BaseOptions base = 2;
}

enum RawLoggerConfigFormat {
  RAWLOGGERCONFIGFORMATJSON = 0;
  RAWLOGGERCONFIGFORMATBSON = 1;
  RAWLOGGERCONFIGFORMATUNKNOWN = 2;
}

message RawLoggerConfig {
  RawLoggerConfigFormat format = 1;
  bytes config_data = 2;
}

message OutputOptions {
  repeated LoggerConfig loggers = 1;
  bool suppress_output = 2;
  bool suppress_error = 3;
  bool redirect_output_to_error = 4;
  bool redirect_error_to_output = 5;
}

message CreateOptions {
  repeated string args = 1;
  string working_directory = 2;
  map<string, string> environment = 3;
  bool override_environ = 4;
  int64 timeout_seconds = 5;
  repeated string tags = 6;
  repeated CreateOptions on_success = 7;
  repeated CreateOptions on_failure = 8;
  repeated CreateOptions on_timeout = 9;
  OutputOptions output = 10;
  bytes standard_input_bytes = 11;
}

message IDResponse {
  string value = 1;
}

message ProcessInfo {
  string id = 1;
  int64 pid = 2;
  string host_id = 3;
  bool running = 4;
  bool successful = 5;
  bool complete = 6;
  bool timedout = 7;
  CreateOptions options = 8;
  int32 exit_code = 9;
  google.protobuf.Timestamp start_at = 10;
  google.protobuf.Timestamp end_at = 11;
}

message StatusResponse {
  string host_id = 1;
  bool active = 2;
}

message Filter {
  FilterSpecifications name = 1;
}

enum  FilterSpecifications {
  ALL = 0;
  RUNNING = 1;
  TERMINATED = 2;
  FAILED = 3;
  SUCCESSFUL = 4;
}

message SignalProcess {
  JasperProcessID ProcessID = 1;
  Signals signal = 2;
}

enum Signals {
  UNKNOWN = 0;
  TERMINATE = 1;
  KILL = 2;
  HANGUP = 3;
  INIT = 4;
  USER1 = 5;
  USER2 = 6;
  ABRT= 7;
}

message TagName {
  string value = 1;
}

message ProcessTags {
  string processID = 1;
  repeated string tags = 2;
}

message JasperProcessID {
  string value = 1;
}

message OperationOutcome {
  bool success = 1;
  string text = 2;
  int32 exit_code = 3;
}

enum ArchiveFormat {
  ARCHIVEUNKNOWN = 0;
  ARCHIVEAUTO = 1;
  ARCHIVETARGZ = 2;
  ARCHIVEZIP = 3;
}

message ArchiveOptions {
  bool should_extract = 1;
  ArchiveFormat format = 2;
  string target_path = 3;
}

message DownloadInfo {
  string url = 1;
  string path = 2;
  ArchiveOptions archive_opts = 3;
}

message WriteFileInfo {
  string path = 1;
  bytes content = 2;
  bool append = 4;
  uint32 perm = 3;
}

message BuildloggerURLs {
  repeated string urls = 1;
}

message LogRequest {
  JasperProcessID id = 1;
  int64 count = 2;
}
message LogStream {
  repeated string logs = 1;
  bool done = 2;
}

enum SignalTriggerID {
  NONE = 0;
  CLEANTERMINATION = 1;
}

message SignalTriggerParams {
  JasperProcessID processID = 1;
  SignalTriggerID signalTriggerID = 2;
}

message EventName {
  string value = 1;
}

message ScriptingHarnessID {
  string id = 1;
  bool setup = 2;
}

message ScriptingOptionsGolang {
  string gopath = 1;
  string goroot = 2;
  repeated string packages = 3;
  string directory = 4;
  bool update_packages = 5;
}

message ScriptingOptionsPython {
  string virtual_env_path = 1;
  string requirements_path = 2;
  string interpreter_binary = 3;
  repeated string packages = 4;
  bool legacy_python = 5;
  bool add_test_reqs = 6;
}

message ScriptingOptionsRoswell {
  string path = 1;
  repeated string systems = 2;
  string lisp = 3;
}

message ScriptingOptions {
  oneof value {
    ScriptingOptionsGolang golang = 1;
    ScriptingOptionsPython python = 2;
    ScriptingOptionsRoswell roswell = 3;
  }
  map<string, string> environment = 4;
  OutputOptions output = 5;
  int64 duration = 6;
}

message ScriptingHarnessRunArgs {
  string id = 1;
  repeated string args = 2;
}

message ScriptingHarnessBuildArgs {
  string id = 1;
  string directory = 2;
  repeated string args = 3;
}

message ScriptingHarnessBuildResponse {
  OperationOutcome outcome = 1;
  string path = 2;
}

message ScriptingHarnessRunScriptArgs {
  string id = 1;
  string script = 2;
}

message ScriptingHarnessTestArgs {
  string id = 1;
  string directory = 2;
  repeated ScriptingHarnessTestOptions options = 3;
}

message ScriptingHarnessTestOptions {
  string name = 1;
  repeated string args = 2;
  string pattern = 3;
  google.protobuf.Duration timeout = 4;
  int32 count = 5;
}

message ScriptingHarnessTestResult {
  string name = 1;
  google.protobuf.Timestamp start_at = 2;
  google.protobuf.Duration duration = 3;
  string outcome = 4;
}

message ScriptingHarnessTestResponse {
  OperationOutcome outcome = 1;
  repeated ScriptingHarnessTestResult results = 2;
}

message LoggingCacheCreateArgs {
  string name = 1;
  OutputOptions options = 2;
}

message LoggingCacheArgs {
  string name = 1;
}

message LoggingCacheInstance {
  OperationOutcome outcome = 1 ;
  string id = 2;
  string manager = 3;
  google.protobuf.Timestamp accessed = 4;
}

message LoggingCacheSize {
  OperationOutcome outcome = 1 ;
  string id = 2;
  int64 size = 3;
}

enum LoggingPayloadFormat {
  FORMATUNKNONW = 0;
  FORMATBSON = 1;
  FORMATJSON = 2;
  FORMATSTRING = 3;
}

message LoggingPayloadData {
  oneof data {
    string msg = 1;
    bytes raw = 2;
  }
}

message LoggingPayload {
  string LoggerID = 1;
  int32 priority = 2;
  LoggingPayloadFormat format = 3;
  bool is_multi = 4;
  bool prefer_send_to_error = 5;
  bool add_metadata = 6;
  repeated LoggingPayloadData data = 7;
}

service JasperProcessManager {
  // Manager functions
  rpc ID(google.protobuf.Empty) returns (IDResponse);
  rpc Create(CreateOptions) returns (ProcessInfo);
  rpc List(Filter) returns (stream ProcessInfo);
  rpc Group(TagName) returns (stream ProcessInfo);
  rpc Get(JasperProcessID) returns (ProcessInfo);
  rpc Signal(SignalProcess) returns (OperationOutcome);
  rpc Clear(google.protobuf.Empty) returns (OperationOutcome);
  rpc Close(google.protobuf.Empty) returns (OperationOutcome);

  // Process functions
  rpc TagProcess(ProcessTags) returns (OperationOutcome);
  rpc ResetTags(JasperProcessID) returns (OperationOutcome);
  rpc GetTags(JasperProcessID) returns (ProcessTags);
  rpc RegisterSignalTriggerID(SignalTriggerParams) returns (OperationOutcome);
  rpc Wait(JasperProcessID) returns (OperationOutcome);
  rpc Respawn(JasperProcessID) returns (ProcessInfo);

  // ScriptingHarness functions
  rpc ScriptingHarnessCreate(ScriptingOptions) returns (ScriptingHarnessID);
  rpc ScriptingHarnessCheck(ScriptingHarnessID) returns (OperationOutcome);
  rpc ScriptingHarnessSetup(ScriptingHarnessID) returns (OperationOutcome);
  rpc ScriptingHarnessCleanup(ScriptingHarnessID) returns (OperationOutcome);
  rpc ScriptingHarnessRun(ScriptingHarnessRunArgs) returns (OperationOutcome);
  rpc ScriptingHarnessBuild(ScriptingHarnessBuildArgs) returns (ScriptingHarnessBuildResponse);
  rpc ScriptingHarnessRunScript(ScriptingHarnessRunScriptArgs) returns (OperationOutcome);
  rpc ScriptingHarnessTest(ScriptingHarnessTestArgs) returns (ScriptingHarnessTestResponse);

  // Logging functions
  rpc LoggingCacheCreate(LoggingCacheCreateArgs) returns (LoggingCacheInstance);
  rpc LoggingCacheGet(LoggingCacheArgs) returns (LoggingCacheInstance);
  rpc LoggingCacheRemove(LoggingCacheArgs) returns (OperationOutcome);
  rpc LoggingCacheCloseAndRemove(LoggingCacheArgs) returns (OperationOutcome);
  rpc LoggingCacheClear(google.protobuf.Empty) returns (OperationOutcome);
  rpc LoggingCacheLen(google.protobuf.Empty) returns (LoggingCacheSize);
  rpc LoggingCachePrune(google.protobuf.Timestamp) returns (OperationOutcome);

  // Remote specific functions
  rpc Status(google.protobuf.Empty) returns (StatusResponse);
  rpc DownloadFile(DownloadInfo) returns (OperationOutcome);
  rpc GetLogStream(LogRequest) returns (LogStream);
  rpc SignalEvent(EventName) returns (OperationOutcome);
  rpc WriteFile(stream WriteFileInfo) returns (OperationOutcome);
  rpc SendMessages(LoggingPayload) returns (OperationOutcome);
}