toil: update plumber internal api (#953)

## 📝 Description

Update services to reflect the plumber's internal API changes.

## ✅ Checklist
- [x] I have tested this change
- [ ] This change requires documentation update

Author: skipi

badge/lib/internal_api/plumber.pipeline.pb.ex

@@ -1604,6 +1604,36 @@ defmodule InternalApi.Plumber.AfterPipelineEvent do
   field(:timestamp, 3, type: Google.Protobuf.Timestamp)
 end
 
+defmodule InternalApi.Plumber.PipelineDeleted do
+  @moduledoc false
+  use Protobuf, syntax: :proto3
+
+  @type t :: %__MODULE__{
+          pipeline_id: String.t(),
+          workflow_id: String.t(),
+          organization_id: String.t(),
+          project_id: String.t(),
+          artifact_store_id: String.t(),
+          deleted_at: Google.Protobuf.Timestamp.t() | nil
+        }
+
+  defstruct [
+    :pipeline_id,
+    :workflow_id,
+    :organization_id,
+    :project_id,
+    :artifact_store_id,
+    :deleted_at
+  ]
+
+  field(:pipeline_id, 1, type: :string)
+  field(:workflow_id, 2, type: :string)
+  field(:organization_id, 3, type: :string)
+  field(:project_id, 4, type: :string)
+  field(:artifact_store_id, 5, type: :string)
+  field(:deleted_at, 6, type: Google.Protobuf.Timestamp)
+end
+
 defmodule InternalApi.Plumber.PipelineService.Service do
   @moduledoc false
   use GRPC.Service, name: "InternalApi.Plumber.PipelineService"

badge/lib/internal_api/plumber_w_f.workflow.pb.ex

@@ -162,7 +162,9 @@ defmodule InternalApi.PlumberWF.ScheduleRequest do
           label: String.t(),
           triggered_by: InternalApi.PlumberWF.TriggeredBy.t(),
           scheduler_task_id: String.t(),
-          env_vars: [InternalApi.PlumberWF.ScheduleRequest.EnvVar.t()]
+          env_vars: [InternalApi.PlumberWF.ScheduleRequest.EnvVar.t()],
+          start_in_conceived_state: boolean,
+          git_reference: String.t()
         }
 
   defstruct [
@@ -179,7 +181,9 @@ defmodule InternalApi.PlumberWF.ScheduleRequest do
     :label,
     :triggered_by,
     :scheduler_task_id,
-    :env_vars
+    :env_vars,
+    :start_in_conceived_state,
+    :git_reference
   ]
 
   field(:service, 2, type: InternalApi.PlumberWF.ScheduleRequest.ServiceType, enum: true)
@@ -196,6 +200,8 @@ defmodule InternalApi.PlumberWF.ScheduleRequest do
   field(:triggered_by, 15, type: InternalApi.PlumberWF.TriggeredBy, enum: true)
   field(:scheduler_task_id, 16, type: :string)
   field(:env_vars, 17, repeated: true, type: InternalApi.PlumberWF.ScheduleRequest.EnvVar)
+  field(:start_in_conceived_state, 18, type: :bool)
+  field(:git_reference, 19, type: :string)
 end
 
 defmodule InternalApi.PlumberWF.ScheduleResponse do
@@ -781,44 +787,25 @@ defmodule InternalApi.PlumberWF.GetProjectIdResponse do
   field(:project_id, 2, type: :string)
 end
 
-defmodule InternalApi.PlumberWF.CreateRequest do
+defmodule InternalApi.PlumberWF.WorkflowDeleted do
   @moduledoc false
   use Protobuf, syntax: :proto3
 
   @type t :: %__MODULE__{
+          workflow_id: String.t(),
+          organization_id: String.t(),
           project_id: String.t(),
-          label: String.t(),
-          hook_id: String.t(),
-          request_token: String.t(),
-          definition_file: String.t(),
-          requester_id: String.t()
+          artifact_store_id: String.t(),
+          deleted_at: Google.Protobuf.Timestamp.t() | nil
         }
 
-  defstruct [:project_id, :label, :hook_id, :request_token, :definition_file, :requester_id]
-
-  field(:project_id, 1, type: :string)
-  field(:label, 2, type: :string)
-  field(:hook_id, 3, type: :string)
-  field(:request_token, 4, type: :string)
-  field(:definition_file, 5, type: :string)
-  field(:requester_id, 6, type: :string)
-end
-
-defmodule InternalApi.PlumberWF.CreateResponse do
-  @moduledoc false
-  use Protobuf, syntax: :proto3
+  defstruct [:workflow_id, :organization_id, :project_id, :artifact_store_id, :deleted_at]
 
-  @type t :: %__MODULE__{
-          wf_id: String.t(),
-          status: InternalApi.Status.t() | nil,
-          ppl_id: String.t()
-        }
-
-  defstruct [:wf_id, :status, :ppl_id]
-
-  field(:wf_id, 1, type: :string)
-  field(:status, 2, type: InternalApi.Status)
-  field(:ppl_id, 3, type: :string)
+  field(:workflow_id, 1, type: :string)
+  field(:organization_id, 2, type: :string)
+  field(:project_id, 3, type: :string)
+  field(:artifact_store_id, 4, type: :string)
+  field(:deleted_at, 5, type: Google.Protobuf.Timestamp)
 end
 
 defmodule InternalApi.PlumberWF.WorkflowService.Service do
@@ -882,8 +869,6 @@ defmodule InternalApi.PlumberWF.WorkflowService.Service do
     InternalApi.PlumberWF.GetProjectIdRequest,
     InternalApi.PlumberWF.GetProjectIdResponse
   )
-
-  rpc(:Create, InternalApi.PlumberWF.CreateRequest, InternalApi.PlumberWF.CreateResponse)
 end
 
 defmodule InternalApi.PlumberWF.WorkflowService.Stub do

badge/lib/internal_api/repository_integrator.pb.ex

@@ -34,15 +34,17 @@ defmodule InternalApi.RepositoryIntegrator.GetTokenRequest do
           user_id: String.t(),
           repository_slug: String.t(),
           integration_type: InternalApi.RepositoryIntegrator.IntegrationType.t(),
-          project_id: String.t()
+          project_id: String.t(),
+          repository_remote_id: String.t()
         }
 
-  defstruct [:user_id, :repository_slug, :integration_type, :project_id]
+  defstruct [:user_id, :repository_slug, :integration_type, :project_id, :repository_remote_id]
 
   field(:user_id, 1, type: :string)
   field(:repository_slug, 2, type: :string)
   field(:integration_type, 3, type: InternalApi.RepositoryIntegrator.IntegrationType, enum: true)
   field(:project_id, 4, type: :string)
+  field(:repository_remote_id, 5, type: :string)
 end
 
 defmodule InternalApi.RepositoryIntegrator.GetTokenResponse do

ee/gofer/lib/internal_api/plumber.pipeline.pb.ex

@@ -863,6 +863,18 @@ defmodule InternalApi.Plumber.AfterPipelineEvent do
   field :timestamp, 3, type: Google.Protobuf.Timestamp
 end
 
+defmodule InternalApi.Plumber.PipelineDeleted do
+  @moduledoc false
+  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
+
+  field :pipeline_id, 1, type: :string, json_name: "pipelineId"
+  field :workflow_id, 2, type: :string, json_name: "workflowId"
+  field :organization_id, 3, type: :string, json_name: "organizationId"
+  field :project_id, 4, type: :string, json_name: "projectId"
+  field :artifact_store_id, 5, type: :string, json_name: "artifactStoreId"
+  field :deleted_at, 6, type: Google.Protobuf.Timestamp, json_name: "deletedAt"
+end
+
 defmodule InternalApi.Plumber.PipelineService.Service do
   @moduledoc false
   use GRPC.Service,

ee/gofer/lib/internal_api/plumber_w_f.workflow.pb.ex

@@ -129,6 +129,9 @@ defmodule InternalApi.PlumberWF.ScheduleRequest do
     repeated: true,
     type: InternalApi.PlumberWF.ScheduleRequest.EnvVar,
     json_name: "envVars"
+
+  field :start_in_conceived_state, 18, type: :bool, json_name: "startInConceivedState"
+  field :git_reference, 19, type: :string, json_name: "gitReference"
 end
 
 defmodule InternalApi.PlumberWF.ScheduleResponse do
@@ -443,25 +446,15 @@ defmodule InternalApi.PlumberWF.GetProjectIdResponse do
   field :project_id, 2, type: :string, json_name: "projectId"
 end
 
-defmodule InternalApi.PlumberWF.CreateRequest do
+defmodule InternalApi.PlumberWF.WorkflowDeleted do
   @moduledoc false
   use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
 
-  field :project_id, 1, type: :string, json_name: "projectId"
-  field :label, 2, type: :string
-  field :hook_id, 3, type: :string, json_name: "hookId"
-  field :request_token, 4, type: :string, json_name: "requestToken"
-  field :definition_file, 5, type: :string, json_name: "definitionFile"
-  field :requester_id, 6, type: :string, json_name: "requesterId"
-end
-
-defmodule InternalApi.PlumberWF.CreateResponse do
-  @moduledoc false
-  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
-
-  field :wf_id, 1, type: :string, json_name: "wfId"
-  field :status, 2, type: InternalApi.Status
-  field :ppl_id, 3, type: :string, json_name: "pplId"
+  field :workflow_id, 1, type: :string, json_name: "workflowId"
+  field :organization_id, 2, type: :string, json_name: "organizationId"
+  field :project_id, 3, type: :string, json_name: "projectId"
+  field :artifact_store_id, 4, type: :string, json_name: "artifactStoreId"
+  field :deleted_at, 5, type: Google.Protobuf.Timestamp, json_name: "deletedAt"
 end
 
 defmodule InternalApi.PlumberWF.WorkflowService.Service do
@@ -509,8 +502,6 @@ defmodule InternalApi.PlumberWF.WorkflowService.Service do
   rpc :GetProjectId,
       InternalApi.PlumberWF.GetProjectIdRequest,
       InternalApi.PlumberWF.GetProjectIdResponse
-
-  rpc :Create, InternalApi.PlumberWF.CreateRequest, InternalApi.PlumberWF.CreateResponse
 end
 
 defmodule InternalApi.PlumberWF.WorkflowService.Stub do

ee/gofer/lib/internal_api/rbac.pb.ex

@@ -4,6 +4,7 @@ defmodule InternalApi.RBAC.SubjectType do
 
   field :USER, 0
   field :GROUP, 1
+  field :SERVICE_ACCOUNT, 2
 end
 
 defmodule InternalApi.RBAC.Scope do
@@ -331,6 +332,21 @@ defmodule InternalApi.RBAC.Permission do
   field :scope, 4, type: InternalApi.RBAC.Scope, enum: true
 end
 
+defmodule InternalApi.RBAC.ListSubjectsRequest do
+  @moduledoc false
+  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
+
+  field :org_id, 1, type: :string, json_name: "orgId"
+  field :subject_ids, 2, repeated: true, type: :string, json_name: "subjectIds"
+end
+
+defmodule InternalApi.RBAC.ListSubjectsResponse do
+  @moduledoc false
+  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
+
+  field :subjects, 1, repeated: true, type: InternalApi.RBAC.Subject
+end
+
 defmodule InternalApi.RBAC.RBAC.Service do
   @moduledoc false
   use GRPC.Service, name: "InternalApi.RBAC.RBAC", protoc_gen_elixir_version: "0.10.0"
@@ -374,6 +390,8 @@ defmodule InternalApi.RBAC.RBAC.Service do
   rpc :RefreshCollaborators,
       InternalApi.RBAC.RefreshCollaboratorsRequest,
       InternalApi.RBAC.RefreshCollaboratorsResponse
+
+  rpc :ListSubjects, InternalApi.RBAC.ListSubjectsRequest, InternalApi.RBAC.ListSubjectsResponse
 end
 
 defmodule InternalApi.RBAC.RBAC.Stub do

ee/gofer/lib/internal_api/repository.pb.ex

@@ -540,6 +540,7 @@ defmodule InternalApi.Repository.RemoteRepositoryChanged do
   use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.10.0"
 
   field :remote_id, 1, type: :string, json_name: "remoteId"
+  field :repository_id, 2, type: :string, json_name: "repositoryId"
   field :timestamp, 3, type: Google.Protobuf.Timestamp
 end
 

ee/gofer/lib/internal_api/repository_integrator.pb.ex

@@ -31,6 +31,7 @@ defmodule InternalApi.RepositoryIntegrator.GetTokenRequest do
     enum: true
 
   field :project_id, 4, type: :string, json_name: "projectId"
+  field :repository_remote_id, 5, type: :string, json_name: "repositoryRemoteId"
 end
 
 defmodule InternalApi.RepositoryIntegrator.GetTokenResponse do

ee/gofer/lib/internal_api/user.pb.ex

@@ -50,6 +50,7 @@ defmodule InternalApi.User.User.CreationSource do
 
   field :NOT_SET, 0
   field :OKTA, 1
+  field :SERVICE_ACCOUNT, 2
 end
 
 defmodule InternalApi.User.ListFavoritesRequest do