feat(pubsub): promote BulkPublishEvent from alpha1 to stable

dapr/proto/runtime/v1/dapr.proto

@@ -57,8 +57,13 @@ service Dapr {
   // Publishes events to the specific topic.
   rpc PublishEvent(PublishEventRequest) returns (google.protobuf.Empty) {}
 
+  // Deprecated: Use BulkPublishEvent instead.
+  rpc BulkPublishEventAlpha1(BulkPublishRequest) returns (BulkPublishResponse) {
+    option deprecated = true;
+  }
+
   // Bulk Publishes multiple events to the specified topic.
-  rpc BulkPublishEventAlpha1(BulkPublishRequest) returns (BulkPublishResponse) {}
+  rpc BulkPublishEvent(BulkPublishRequest) returns (BulkPublishResponse) {}
 
   // SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
   // events from it.

src/implementation/Client/GRPCClient/pubsub.ts

@@ -87,7 +87,7 @@ export default class GRPCClientPubSub implements IClientPubSub {
     const client = await this.client.getClient();
 
     try {
-      const res = await client.bulkPublishEventAlpha1(create(BulkPublishRequestSchema, {
+      const res = await client.bulkPublishEvent(create(BulkPublishRequestSchema, {
         pubsubName: pubSubName,
         topic,
         entries: serializedEntries,

src/implementation/Client/HTTPClient/pubsub.ts

@@ -81,7 +81,7 @@ export default class HTTPClientPubSub implements IClientPubSub {
 
     try {
       await this.client.executeWithApiVersion(
-        "v1.0-alpha1",
+        "v1.0",
         `/publish/bulk/${pubSubName}/${topic}?${queryParams}`,
         params,
       );

src/proto/dapr/proto/runtime/v1/dapr_connect.d.ts

@@ -10,13 +10,13 @@
 //See the License for the specific language governing permissions and
 //limitations under the License.
 
-// @generated by protoc-gen-connect-es v1.6.1 with parameter "target=js+dts,import_extension=none"
+// @generated by protoc-gen-connect-es v1.6.1 with parameter "target=js+dts,import_extension=.js"
 // @generated from file dapr/proto/runtime/v1/dapr.proto (package dapr.proto.runtime.v1, syntax proto3)
 /* eslint-disable */
 // @ts-nocheck
 
-import { BulkPublishRequest, BulkPublishResponse, ConversationRequest, ConversationRequestAlpha2, ConversationResponse, ConversationResponseAlpha2, DecryptRequest, DecryptResponse, DeleteBulkStateRequest, DeleteJobRequest, DeleteJobResponse, DeleteStateRequest, EncryptRequest, EncryptResponse, ExecuteActorStateTransactionRequest, ExecuteStateTransactionRequest, GetActorStateRequest, GetActorStateResponse, GetBulkSecretRequest, GetBulkSecretResponse, GetBulkStateRequest, GetBulkStateResponse, GetConfigurationRequest, GetConfigurationResponse, GetJobRequest, GetJobResponse, GetMetadataRequest, GetMetadataResponse, GetSecretRequest, GetSecretResponse, GetStateRequest, GetStateResponse, GetWorkflowRequest, GetWorkflowResponse, InvokeActorRequest, InvokeActorResponse, InvokeBindingRequest, InvokeBindingResponse, InvokeServiceRequest, PauseWorkflowRequest, PublishEventRequest, PurgeWorkflowRequest, QueryStateRequest, QueryStateResponse, RaiseEventWorkflowRequest, RegisterActorReminderRequest, RegisterActorTimerRequest, ResumeWorkflowRequest, SaveStateRequest, ScheduleJobRequest, ScheduleJobResponse, SetMetadataRequest, ShutdownRequest, StartWorkflowRequest, StartWorkflowResponse, SubscribeConfigurationRequest, SubscribeConfigurationResponse, SubscribeTopicEventsRequestAlpha1, SubscribeTopicEventsResponseAlpha1, SubtleDecryptRequest, SubtleDecryptResponse, SubtleEncryptRequest, SubtleEncryptResponse, SubtleGetKeyRequest, SubtleGetKeyResponse, SubtleSignRequest, SubtleSignResponse, SubtleUnwrapKeyRequest, SubtleUnwrapKeyResponse, SubtleVerifyRequest, SubtleVerifyResponse, SubtleWrapKeyRequest, SubtleWrapKeyResponse, TerminateWorkflowRequest, TryLockRequest, TryLockResponse, UnlockRequest, UnlockResponse, UnregisterActorReminderRequest, UnregisterActorTimerRequest, UnsubscribeConfigurationRequest, UnsubscribeConfigurationResponse } from "./dapr_pb";
-import { InvokeResponse } from "../../common/v1/common_pb";
+import { BulkPublishRequest, BulkPublishResponse, ConversationRequest, ConversationRequestAlpha2, ConversationResponse, ConversationResponseAlpha2, DecryptRequest, DecryptResponse, DeleteBulkStateRequest, DeleteJobRequest, DeleteJobResponse, DeleteStateRequest, EncryptRequest, EncryptResponse, ExecuteActorStateTransactionRequest, ExecuteStateTransactionRequest, GetActorStateRequest, GetActorStateResponse, GetBulkSecretRequest, GetBulkSecretResponse, GetBulkStateRequest, GetBulkStateResponse, GetConfigurationRequest, GetConfigurationResponse, GetJobRequest, GetJobResponse, GetMetadataRequest, GetMetadataResponse, GetSecretRequest, GetSecretResponse, GetStateRequest, GetStateResponse, GetWorkflowRequest, GetWorkflowResponse, InvokeActorRequest, InvokeActorResponse, InvokeBindingRequest, InvokeBindingResponse, InvokeServiceRequest, PauseWorkflowRequest, PublishEventRequest, PurgeWorkflowRequest, QueryStateRequest, QueryStateResponse, RaiseEventWorkflowRequest, RegisterActorReminderRequest, RegisterActorTimerRequest, ResumeWorkflowRequest, SaveStateRequest, ScheduleJobRequest, ScheduleJobResponse, SetMetadataRequest, ShutdownRequest, StartWorkflowRequest, StartWorkflowResponse, SubscribeConfigurationRequest, SubscribeConfigurationResponse, SubscribeTopicEventsRequestAlpha1, SubscribeTopicEventsResponseAlpha1, SubtleDecryptRequest, SubtleDecryptResponse, SubtleEncryptRequest, SubtleEncryptResponse, SubtleGetKeyRequest, SubtleGetKeyResponse, SubtleSignRequest, SubtleSignResponse, SubtleUnwrapKeyRequest, SubtleUnwrapKeyResponse, SubtleVerifyRequest, SubtleVerifyResponse, SubtleWrapKeyRequest, SubtleWrapKeyResponse, TerminateWorkflowRequest, TryLockRequest, TryLockResponse, UnlockRequest, UnlockResponse, UnregisterActorReminderRequest, UnregisterActorTimerRequest, UnsubscribeConfigurationRequest, UnsubscribeConfigurationResponse } from "./dapr_pb.js";
+import { InvokeResponse } from "../../common/v1/common_pb.js";
 import { Empty, MethodKind } from "@bufbuild/protobuf";
 
 /**
@@ -128,16 +128,28 @@ export declare const Dapr: {
       readonly kind: MethodKind.Unary,
     },
     /**
-     * Bulk Publishes multiple events to the specified topic.
+     * Deprecated: Use BulkPublishEvent instead.
      *
      * @generated from rpc dapr.proto.runtime.v1.Dapr.BulkPublishEventAlpha1
+     * @deprecated
      */
     readonly bulkPublishEventAlpha1: {
       readonly name: "BulkPublishEventAlpha1",
       readonly I: typeof BulkPublishRequest,
       readonly O: typeof BulkPublishResponse,
       readonly kind: MethodKind.Unary,
     },
+    /**
+     * Bulk Publishes multiple events to the specified topic.
+     *
+     * @generated from rpc dapr.proto.runtime.v1.Dapr.BulkPublishEvent
+     */
+    readonly bulkPublishEvent: {
+      readonly name: "BulkPublishEvent",
+      readonly I: typeof BulkPublishRequest,
+      readonly O: typeof BulkPublishResponse,
+      readonly kind: MethodKind.Unary,
+    },
     /**
      * SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
      * events from it.

src/proto/dapr/proto/runtime/v1/dapr_connect.js

@@ -10,7 +10,7 @@
 //See the License for the specific language governing permissions and
 //limitations under the License.
 
-// @generated by protoc-gen-connect-es v1.6.1 with parameter "target=js+dts,import_extension=none"
+// @generated by protoc-gen-connect-es v1.6.1 with parameter "target=js+dts,import_extension=.js"
 // @generated from file dapr/proto/runtime/v1/dapr.proto (package dapr.proto.runtime.v1, syntax proto3)
 /* eslint-disable */
 // @ts-nocheck
@@ -128,16 +128,28 @@ export const Dapr = {
       kind: MethodKind.Unary,
     },
     /**
-     * Bulk Publishes multiple events to the specified topic.
+     * Deprecated: Use BulkPublishEvent instead.
      *
      * @generated from rpc dapr.proto.runtime.v1.Dapr.BulkPublishEventAlpha1
+     * @deprecated
      */
     bulkPublishEventAlpha1: {
       name: "BulkPublishEventAlpha1",
       I: BulkPublishRequest,
       O: BulkPublishResponse,
       kind: MethodKind.Unary,
     },
+    /**
+     * Bulk Publishes multiple events to the specified topic.
+     *
+     * @generated from rpc dapr.proto.runtime.v1.Dapr.BulkPublishEvent
+     */
+    bulkPublishEvent: {
+      name: "BulkPublishEvent",
+      I: BulkPublishRequest,
+      O: BulkPublishResponse,
+      kind: MethodKind.Unary,
+    },
     /**
      * SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
      * events from it.