syntax = "proto3";

option go_package = "git.dragse.it/anthrove/orchestrator/pkg/api/gRPC";

service PlugConnector {
  rpc TaskStart(PlugTaskCreation) returns (PlugTaskStatus);
  rpc TaskStatus(PlugTask) returns (PlugTaskStatus);
  rpc TaskCancel(PlugTask) returns (PlugTaskStatus);
}

message PlugTaskStatus {
  string task_id = 1;
  PlugTaskState task_state = 2;
}

enum PlugTaskState {
  UNKNOWN = 0;
  STARTED = 1;
  RUNNING = 2;
  STOPPED = 3;
}

message PlugTask {
  string task_id = 1;
}

message PlugTaskCreation {
  string user_id = 1;
  string user_source_name = 2;
  bool deep_scrape = 3;
}