Update proto from Dapr 1.0.0-RC.2 (#68)

* Update proto from Dapr 1.0.0-RC.2

* Update example to use new proto fields from Dapr 1.0.0-RC.2

Author: tcnghia

examples/typescript/app.ts

@@ -14,6 +14,8 @@ var client = new dapr_grpc.DaprClient(
 var event = new dapr_pb.PublishEventRequest();
 event.setTopic('sith');
 event.setPubsubName('pubsub');
+event.setDataContentType('text/plain');
+event.getMetadataMap().set('key', 'value');
 
 const data = Buffer.from('lala');
 event.setData(data);
@@ -108,5 +110,3 @@ client.saveState(stateReq, (err, res) => {
         });
     }
 });
-
-

package-lock.json

@@ -30,7 +30,7 @@
   },
   "devDependencies": {
     "eslint": "^7.9.0",
-    "grpc-tools": "^1.9.1",
+    "grpc-tools": "^1.10.0",
     "grpc_tools_node_protoc_ts": "^4.1.5"
   }
 }

package.json

@@ -7,6 +7,8 @@
  * @public
  */
 // GENERATED CODE -- DO NOT EDIT!
+/* eslint-disable */
+// @ts-nocheck
 
 var jspb = require('google-protobuf');
 var goog = jspb;

src/dapr/proto/common/v1/common_pb.js

@@ -7,6 +7,8 @@
  * @public
  */
 // GENERATED CODE -- DO NOT EDIT!
+/* eslint-disable */
+// @ts-nocheck
 
 var jspb = require('google-protobuf');
 var goog = jspb;

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

@@ -9,6 +9,7 @@
 'use strict';
 var grpc = require('grpc');
 var dapr_proto_runtime_v1_dapr_pb = require('../../../../dapr/proto/runtime/v1/dapr_pb.js');
+var google_protobuf_any_pb = require('google-protobuf/google/protobuf/any_pb.js');
 var google_protobuf_empty_pb = require('google-protobuf/google/protobuf/empty_pb.js');
 var dapr_proto_common_v1_common_pb = require('../../../../dapr/proto/common/v1/common_pb.js');
 
@@ -34,6 +35,17 @@ function deserialize_dapr_proto_runtime_v1_DeleteStateRequest(buffer_arg) {
   return dapr_proto_runtime_v1_dapr_pb.DeleteStateRequest.deserializeBinary(new Uint8Array(buffer_arg));
 }
 
+function serialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.ExecuteActorStateTransactionRequest)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.ExecuteActorStateTransactionRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.ExecuteActorStateTransactionRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 function serialize_dapr_proto_runtime_v1_ExecuteStateTransactionRequest(arg) {
   if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest)) {
     throw new Error('Expected argument of type dapr.proto.runtime.v1.ExecuteStateTransactionRequest');
@@ -45,6 +57,50 @@ function deserialize_dapr_proto_runtime_v1_ExecuteStateTransactionRequest(buffer
   return dapr_proto_runtime_v1_dapr_pb.ExecuteStateTransactionRequest.deserializeBinary(new Uint8Array(buffer_arg));
 }
 
+function serialize_dapr_proto_runtime_v1_GetActorStateRequest(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetActorStateRequest)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.GetActorStateRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_GetActorStateRequest(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.GetActorStateRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_dapr_proto_runtime_v1_GetActorStateResponse(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetActorStateResponse)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.GetActorStateResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_GetActorStateResponse(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.GetActorStateResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_dapr_proto_runtime_v1_GetBulkSecretRequest(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetBulkSecretRequest)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.GetBulkSecretRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_GetBulkSecretRequest(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.GetBulkSecretRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_dapr_proto_runtime_v1_GetBulkSecretResponse(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetBulkSecretResponse)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.GetBulkSecretResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_GetBulkSecretResponse(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.GetBulkSecretResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 function serialize_dapr_proto_runtime_v1_GetBulkStateRequest(arg) {
   if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.GetBulkStateRequest)) {
     throw new Error('Expected argument of type dapr.proto.runtime.v1.GetBulkStateRequest');
@@ -177,6 +233,17 @@ function deserialize_dapr_proto_runtime_v1_PublishEventRequest(buffer_arg) {
   return dapr_proto_runtime_v1_dapr_pb.PublishEventRequest.deserializeBinary(new Uint8Array(buffer_arg));
 }
 
+function serialize_dapr_proto_runtime_v1_RegisterActorReminderRequest(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.RegisterActorReminderRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_RegisterActorReminderRequest(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 function serialize_dapr_proto_runtime_v1_RegisterActorTimerRequest(arg) {
   if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.RegisterActorTimerRequest)) {
     throw new Error('Expected argument of type dapr.proto.runtime.v1.RegisterActorTimerRequest');
@@ -199,6 +266,17 @@ function deserialize_dapr_proto_runtime_v1_SaveStateRequest(buffer_arg) {
   return dapr_proto_runtime_v1_dapr_pb.SaveStateRequest.deserializeBinary(new Uint8Array(buffer_arg));
 }
 
+function serialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest(arg) {
+  if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest)) {
+    throw new Error('Expected argument of type dapr.proto.runtime.v1.UnregisterActorReminderRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest(buffer_arg) {
+  return dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 function serialize_dapr_proto_runtime_v1_UnregisterActorTimerRequest(arg) {
   if (!(arg instanceof dapr_proto_runtime_v1_dapr_pb.UnregisterActorTimerRequest)) {
     throw new Error('Expected argument of type dapr.proto.runtime.v1.UnregisterActorTimerRequest');
@@ -332,6 +410,18 @@ getSecret: {
     responseSerialize: serialize_dapr_proto_runtime_v1_GetSecretResponse,
     responseDeserialize: deserialize_dapr_proto_runtime_v1_GetSecretResponse,
   },
+  // Gets a bulk of secrets
+getBulkSecret: {
+    path: '/dapr.proto.runtime.v1.Dapr/GetBulkSecret',
+    requestStream: false,
+    responseStream: false,
+    requestType: dapr_proto_runtime_v1_dapr_pb.GetBulkSecretRequest,
+    responseType: dapr_proto_runtime_v1_dapr_pb.GetBulkSecretResponse,
+    requestSerialize: serialize_dapr_proto_runtime_v1_GetBulkSecretRequest,
+    requestDeserialize: deserialize_dapr_proto_runtime_v1_GetBulkSecretRequest,
+    responseSerialize: serialize_dapr_proto_runtime_v1_GetBulkSecretResponse,
+    responseDeserialize: deserialize_dapr_proto_runtime_v1_GetBulkSecretResponse,
+  },
   // Register an actor timer.
 registerActorTimer: {
     path: '/dapr.proto.runtime.v1.Dapr/RegisterActorTimer',
@@ -356,6 +446,54 @@ unregisterActorTimer: {
     responseSerialize: serialize_google_protobuf_Empty,
     responseDeserialize: deserialize_google_protobuf_Empty,
   },
+  // Register an actor reminder.
+registerActorReminder: {
+    path: '/dapr.proto.runtime.v1.Dapr/RegisterActorReminder',
+    requestStream: false,
+    responseStream: false,
+    requestType: dapr_proto_runtime_v1_dapr_pb.RegisterActorReminderRequest,
+    responseType: google_protobuf_empty_pb.Empty,
+    requestSerialize: serialize_dapr_proto_runtime_v1_RegisterActorReminderRequest,
+    requestDeserialize: deserialize_dapr_proto_runtime_v1_RegisterActorReminderRequest,
+    responseSerialize: serialize_google_protobuf_Empty,
+    responseDeserialize: deserialize_google_protobuf_Empty,
+  },
+  // Unregister an actor reminder.
+unregisterActorReminder: {
+    path: '/dapr.proto.runtime.v1.Dapr/UnregisterActorReminder',
+    requestStream: false,
+    responseStream: false,
+    requestType: dapr_proto_runtime_v1_dapr_pb.UnregisterActorReminderRequest,
+    responseType: google_protobuf_empty_pb.Empty,
+    requestSerialize: serialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest,
+    requestDeserialize: deserialize_dapr_proto_runtime_v1_UnregisterActorReminderRequest,
+    responseSerialize: serialize_google_protobuf_Empty,
+    responseDeserialize: deserialize_google_protobuf_Empty,
+  },
+  // Gets the state for a specific actor.
+getActorState: {
+    path: '/dapr.proto.runtime.v1.Dapr/GetActorState',
+    requestStream: false,
+    responseStream: false,
+    requestType: dapr_proto_runtime_v1_dapr_pb.GetActorStateRequest,
+    responseType: dapr_proto_runtime_v1_dapr_pb.GetActorStateResponse,
+    requestSerialize: serialize_dapr_proto_runtime_v1_GetActorStateRequest,
+    requestDeserialize: deserialize_dapr_proto_runtime_v1_GetActorStateRequest,
+    responseSerialize: serialize_dapr_proto_runtime_v1_GetActorStateResponse,
+    responseDeserialize: deserialize_dapr_proto_runtime_v1_GetActorStateResponse,
+  },
+  // Executes state transactions for a specified actor
+executeActorStateTransaction: {
+    path: '/dapr.proto.runtime.v1.Dapr/ExecuteActorStateTransaction',
+    requestStream: false,
+    responseStream: false,
+    requestType: dapr_proto_runtime_v1_dapr_pb.ExecuteActorStateTransactionRequest,
+    responseType: google_protobuf_empty_pb.Empty,
+    requestSerialize: serialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest,
+    requestDeserialize: deserialize_dapr_proto_runtime_v1_ExecuteActorStateTransactionRequest,
+    responseSerialize: serialize_google_protobuf_Empty,
+    responseDeserialize: deserialize_google_protobuf_Empty,
+  },
   // InvokeActor calls a method on an actor.
 invokeActor: {
     path: '/dapr.proto.runtime.v1.Dapr/InvokeActor',