add file stream and image stream rpc call (#88)

* add file stream and image stream rpc call

* fix test

* 0.17.5

* add imageType to MessageImageStreamRequest

* add @deprecated to MessageFile and MessageImage rpc

* add change history in readme

* 0.18.0

Author: windmemory

README.md

@@ -221,6 +221,9 @@ TCP hole punching
 
 ## HISTORY
 
+### v0.18 (Oct 15, 2020)
+- Add new `MessageFileStream` and `MessageImageStream` to replace the `MessageFile` and `MessageImage` method to avoid blocking nodejs event loop when sending large files ([#88](https://github.com/Chatie/grpc/pull/88)) by [@windmemory](https://github.com/windmemory)
+
 ### v0.17 (Aug 5, 2020)
 
 - Add PHPH Support ([#76](https://github.com/Chatie/grpc/pull/76) [#78](https://github.com/Chatie/grpc/pull/78)) by [@zhangchunsheng](https://github.com/zhangchunsheng)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@chatie/grpc",
-  "version": "0.17.4",
+  "version": "0.18.0",
   "description": "gRPC for Chatie",
   "main": "dist/src/index.js",
   "typings": "dist/src/index.d.js",

proto/wechaty/puppet.proto

@@ -92,8 +92,12 @@ service Puppet {
   rpc MessagePayload (puppet.MessagePayloadRequest)  returns (puppet.MessagePayloadResponse) {}
 
   rpc MessageContact (puppet.MessageContactRequest) returns (puppet.MessageContactResponse) {}
+  // @deprecated: using MessageFileStream to transfer files
   rpc MessageFile (puppet.MessageFileRequest) returns (puppet.MessageFileResponse) {}
+  rpc MessageFileStream (puppet.MessageFileStreamRequest) returns (stream puppet.MessageFileStreamResponse) {}
+  // @deprecated: using MessageImageStream to transfer images
   rpc MessageImage (puppet.MessageImageRequest) returns (puppet.MessageImageResponse) {}
+  rpc MessageImageStream (puppet.MessageImageStreamRequest) returns (stream puppet.MessageImageStreamResponse) {}
   rpc MessageMiniProgram (puppet.MessageMiniProgramRequest) returns (puppet.MessageMiniProgramResponse) {}
   rpc MessageUrl (puppet.MessageUrlRequest) returns (puppet.MessageUrlResponse) {}
 

proto/wechaty/puppet/message.proto

@@ -56,6 +56,14 @@ message MessageImageResponse {
   string filebox = 1;
 }
 
+message MessageImageStreamRequest {
+  string id = 1;
+  ImageType type = 2;
+}
+message MessageImageStreamResponse {
+  bytes data = 1;
+}
+
 message MessageContactRequest {
   string id = 1;
 }
@@ -70,6 +78,13 @@ message MessageFileResponse {
   string filebox = 1;
 }
 
+message MessageFileStreamRequest {
+  string id = 1;
+}
+message MessageFileStreamResponse {
+  bytes data = 1;
+}
+
 message MessageMiniProgramRequest {
   string id = 1;
 }

tests/puppet-server-impl.ts

@@ -133,12 +133,22 @@ export const puppetServerImpl: IPuppetServer = {
     throw new Error('not implemented.')
   },
 
+  messageFileStream: (call) => {
+    void call
+    throw new Error('not implemented.')
+  },
+
   messageImage: (call, callback) => {
     void call
     void callback
     throw new Error('not implemented.')
   },
 
+  messageImageStream: (call) => {
+    void call
+    throw new Error('not implemented.')
+  },
+
   messageMiniProgram: (call, callback) => {
     void call
     void callback