rename WatchStage to WatchStages

Signed-off-by: Alexander Matyushentsev <AMatyushentsev@gmail.com>

api/service/v1alpha1/service.proto

@@ -19,7 +19,7 @@ service KargoService {
   rpc CreateStage(CreateStageRequest) returns (CreateStageResponse);
   rpc ListStages(ListStagesRequest) returns (ListStagesResponse);
   rpc GetStage(GetStageRequest) returns (GetStageResponse);
-  rpc WatchStage(WatchStageRequest) returns (stream WatchStageResponse);
+  rpc WatchStages(WatchStagesRequest) returns (stream WatchStagesResponse);
   rpc UpdateStage(UpdateStageRequest) returns (UpdateStageResponse);
   rpc DeleteStage(DeleteStageRequest) returns (DeleteStageResponse);
   rpc PromoteStage(PromoteStageRequest) returns (PromoteStageResponse);
@@ -116,12 +116,12 @@ message GetStageResponse {
   github.com.akuity.kargo.pkg.api.v1alpha1.Stage stage = 1;
 }
 
-message WatchStageRequest {
+message WatchStagesRequest {
   string project = 1;
   string name = 2;
 }
 
-message WatchStageResponse {
+message WatchStagesResponse {
   github.com.akuity.kargo.pkg.api.v1alpha1.Stage stage = 1;
   string type = 2;
 }

internal/api/handler/watch_stage_v1alpha1.go → internal/api/handler/watch_stages_v1alpha1.go

@@ -20,8 +20,8 @@ import (
 
 type WatchStageV1Alpha1Func func(
 	context.Context,
-	*connect.Request[svcv1alpha1.WatchStageRequest],
-	*connect.ServerStream[svcv1alpha1.WatchStageResponse],
+	*connect.Request[svcv1alpha1.WatchStagesRequest],
+	*connect.ServerStream[svcv1alpha1.WatchStagesResponse],
 ) error
 
 func WatchStageV1Alpha1(
@@ -32,8 +32,8 @@ func WatchStageV1Alpha1(
 	stageCli := dynamicCli.Resource(kargov1alpha1.GroupVersion.WithResource("stages"))
 	return func(
 		ctx context.Context,
-		req *connect.Request[svcv1alpha1.WatchStageRequest],
-		stream *connect.ServerStream[svcv1alpha1.WatchStageResponse],
+		req *connect.Request[svcv1alpha1.WatchStagesRequest],
+		stream *connect.ServerStream[svcv1alpha1.WatchStagesResponse],
 	) error {
 		if req.Msg.GetProject() == "" {
 			return connect.NewError(connect.CodeInvalidArgument, errors.New("project should not be empty"))
@@ -79,7 +79,7 @@ func WatchStageV1Alpha1(
 				if err := runtime.DefaultUnstructuredConverter.FromUnstructured(u.Object, &stage); err != nil {
 					return errors.Wrap(err, "from unstructured")
 				}
-				if err := stream.Send(&svcv1alpha1.WatchStageResponse{
+				if err := stream.Send(&svcv1alpha1.WatchStagesResponse{
 					Stage: typesv1alpha1.ToStageProto(*stage),
 					Type:  string(e.Type),
 				}); err != nil {

internal/api/server.go

@@ -155,10 +155,10 @@ func (s *server) GetStage(
 	return handler.GetStageV1Alpha1(s.kubeCli)(ctx, req)
 }
 
-func (s *server) WatchStage(
+func (s *server) WatchStages(
 	ctx context.Context,
-	req *connect.Request[svcv1alpha1.WatchStageRequest],
-	stream *connect.ServerStream[svcv1alpha1.WatchStageResponse],
+	req *connect.Request[svcv1alpha1.WatchStagesRequest],
+	stream *connect.ServerStream[svcv1alpha1.WatchStagesResponse],
 ) error {
 	return handler.WatchStageV1Alpha1(s.kubeCli, s.dynamicCli)(ctx, req, stream)
 }

ui/src/features/project/project-details/project-details.tsx

@@ -35,7 +35,7 @@ export const ProjectDetails = () => {
     const watchStages = async () => {
       const transport = createConnectTransport({ baseUrl: '' });
       const promiseClient = createPromiseClient(KargoService, transport);
-      const stream = promiseClient.watchStage(
+      const stream = promiseClient.watchStages(
         { project: 'kargo-demo', name: 'test' },
         { signal: cancel.signal }
       );

ui/src/gen/service/v1alpha1/service_connect.ts

@@ -3,7 +3,7 @@
 /* eslint-disable */
 // @ts-nocheck
 
-import { AdminLoginRequest, AdminLoginResponse, CreateProjectRequest, CreateProjectResponse, CreatePromotionPolicyRequest, CreatePromotionPolicyResponse, CreateStageRequest, CreateStageResponse, DeleteProjectRequest, DeleteProjectResponse, DeletePromotionPolicyRequest, DeletePromotionPolicyResponse, DeleteStageRequest, DeleteStageResponse, GetPromotionPolicyRequest, GetPromotionPolicyResponse, GetPublicConfigRequest, GetPublicConfigResponse, GetStageRequest, GetStageResponse, GetVersionInfoRequest, GetVersionInfoResponse, ListProjectsRequest, ListProjectsResponse, ListPromotionPoliciesRequest, ListPromotionPoliciesResponse, ListStagesRequest, ListStagesResponse, PromoteStageRequest, PromoteStageResponse, SetAutoPromotionForStageRequest, SetAutoPromotionForStageResponse, UpdatePromotionPolicyRequest, UpdatePromotionPolicyResponse, UpdateStageRequest, UpdateStageResponse, WatchStageRequest, WatchStageResponse } from "./service_pb.js";
+import { AdminLoginRequest, AdminLoginResponse, CreateProjectRequest, CreateProjectResponse, CreatePromotionPolicyRequest, CreatePromotionPolicyResponse, CreateStageRequest, CreateStageResponse, DeleteProjectRequest, DeleteProjectResponse, DeletePromotionPolicyRequest, DeletePromotionPolicyResponse, DeleteStageRequest, DeleteStageResponse, GetPromotionPolicyRequest, GetPromotionPolicyResponse, GetPublicConfigRequest, GetPublicConfigResponse, GetStageRequest, GetStageResponse, GetVersionInfoRequest, GetVersionInfoResponse, ListProjectsRequest, ListProjectsResponse, ListPromotionPoliciesRequest, ListPromotionPoliciesResponse, ListStagesRequest, ListStagesResponse, PromoteStageRequest, PromoteStageResponse, SetAutoPromotionForStageRequest, SetAutoPromotionForStageResponse, UpdatePromotionPolicyRequest, UpdatePromotionPolicyResponse, UpdateStageRequest, UpdateStageResponse, WatchStagesRequest, WatchStagesResponse } from "./service_pb.js";
 import { MethodKind } from "@bufbuild/protobuf";
 
 /**
@@ -67,12 +67,12 @@ export const KargoService = {
       kind: MethodKind.Unary,
     },
     /**
-     * @generated from rpc akuity.io.kargo.service.v1alpha1.KargoService.WatchStage
+     * @generated from rpc akuity.io.kargo.service.v1alpha1.KargoService.WatchStages
      */
-    watchStage: {
-      name: "WatchStage",
-      I: WatchStageRequest,
-      O: WatchStageResponse,
+    watchStages: {
+      name: "WatchStages",
+      I: WatchStagesRequest,
+      O: WatchStagesResponse,
       kind: MethodKind.ServerStreaming,
     },
     /**

ui/src/gen/service/v1alpha1/service_pb.ts

@@ -679,9 +679,9 @@ export class GetStageResponse extends Message<GetStageResponse> {
 }
 
 /**
- * @generated from message akuity.io.kargo.service.v1alpha1.WatchStageRequest
+ * @generated from message akuity.io.kargo.service.v1alpha1.WatchStagesRequest
  */
-export class WatchStageRequest extends Message<WatchStageRequest> {
+export class WatchStagesRequest extends Message<WatchStagesRequest> {
   /**
    * @generated from field: string project = 1;
    */
@@ -692,39 +692,39 @@ export class WatchStageRequest extends Message<WatchStageRequest> {
    */
   name = "";
 
-  constructor(data?: PartialMessage<WatchStageRequest>) {
+  constructor(data?: PartialMessage<WatchStagesRequest>) {
     super();
     proto3.util.initPartial(data, this);
   }
 
   static readonly runtime: typeof proto3 = proto3;
-  static readonly typeName = "akuity.io.kargo.service.v1alpha1.WatchStageRequest";
+  static readonly typeName = "akuity.io.kargo.service.v1alpha1.WatchStagesRequest";
   static readonly fields: FieldList = proto3.util.newFieldList(() => [
     { no: 1, name: "project", kind: "scalar", T: 9 /* ScalarType.STRING */ },
     { no: 2, name: "name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
   ]);
 
-  static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): WatchStageRequest {
-    return new WatchStageRequest().fromBinary(bytes, options);
+  static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): WatchStagesRequest {
+    return new WatchStagesRequest().fromBinary(bytes, options);
   }
 
-  static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): WatchStageRequest {
-    return new WatchStageRequest().fromJson(jsonValue, options);
+  static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): WatchStagesRequest {
+    return new WatchStagesRequest().fromJson(jsonValue, options);
   }
 
-  static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): WatchStageRequest {
-    return new WatchStageRequest().fromJsonString(jsonString, options);
+  static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): WatchStagesRequest {
+    return new WatchStagesRequest().fromJsonString(jsonString, options);
   }
 
-  static equals(a: WatchStageRequest | PlainMessage<WatchStageRequest> | undefined, b: WatchStageRequest | PlainMessage<WatchStageRequest> | undefined): boolean {
-    return proto3.util.equals(WatchStageRequest, a, b);
+  static equals(a: WatchStagesRequest | PlainMessage<WatchStagesRequest> | undefined, b: WatchStagesRequest | PlainMessage<WatchStagesRequest> | undefined): boolean {
+    return proto3.util.equals(WatchStagesRequest, a, b);
   }
 }
 
 /**
- * @generated from message akuity.io.kargo.service.v1alpha1.WatchStageResponse
+ * @generated from message akuity.io.kargo.service.v1alpha1.WatchStagesResponse
  */
-export class WatchStageResponse extends Message<WatchStageResponse> {
+export class WatchStagesResponse extends Message<WatchStagesResponse> {
   /**
    * @generated from field: github.com.akuity.kargo.pkg.api.v1alpha1.Stage stage = 1;
    */
@@ -735,32 +735,32 @@ export class WatchStageResponse extends Message<WatchStageResponse> {
    */
   type = "";
 
-  constructor(data?: PartialMessage<WatchStageResponse>) {
+  constructor(data?: PartialMessage<WatchStagesResponse>) {
     super();
     proto3.util.initPartial(data, this);
   }
 
   static readonly runtime: typeof proto3 = proto3;
-  static readonly typeName = "akuity.io.kargo.service.v1alpha1.WatchStageResponse";
+  static readonly typeName = "akuity.io.kargo.service.v1alpha1.WatchStagesResponse";
   static readonly fields: FieldList = proto3.util.newFieldList(() => [
     { no: 1, name: "stage", kind: "message", T: Stage },
     { no: 2, name: "type", kind: "scalar", T: 9 /* ScalarType.STRING */ },
   ]);
 
-  static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): WatchStageResponse {
-    return new WatchStageResponse().fromBinary(bytes, options);
+  static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): WatchStagesResponse {
+    return new WatchStagesResponse().fromBinary(bytes, options);
   }
 
-  static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): WatchStageResponse {
-    return new WatchStageResponse().fromJson(jsonValue, options);
+  static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): WatchStagesResponse {
+    return new WatchStagesResponse().fromJson(jsonValue, options);
   }
 
-  static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): WatchStageResponse {
-    return new WatchStageResponse().fromJsonString(jsonString, options);
+  static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): WatchStagesResponse {
+    return new WatchStagesResponse().fromJsonString(jsonString, options);
   }
 
-  static equals(a: WatchStageResponse | PlainMessage<WatchStageResponse> | undefined, b: WatchStageResponse | PlainMessage<WatchStageResponse> | undefined): boolean {
-    return proto3.util.equals(WatchStageResponse, a, b);
+  static equals(a: WatchStagesResponse | PlainMessage<WatchStagesResponse> | undefined, b: WatchStagesResponse | PlainMessage<WatchStagesResponse> | undefined): boolean {
+    return proto3.util.equals(WatchStagesResponse, a, b);
   }
 }