Send message stream (#89)

* add sendFileStream rpc call

* add sendFileStream into puppet server impl

* add readme

* 0.18.1

* change filebox to data with bytes type

* add name attribute into stream request and response

Author: windmemory

README.md

@@ -223,6 +223,7 @@ TCP hole punching
 
 ### 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)
+- Add new `MessageSendFileStream` to replace the `MessageSendFile` method to avoid blocking nodejs event loop when sending large files ([#89](https://github.com/Chatie/grpc/pull/89)) by [@windmemory](https://github.com/windmemory)
 
 ### v0.17 (Aug 5, 2020)
 

package.json

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

proto/wechaty/puppet.proto

@@ -102,7 +102,9 @@ service Puppet {
   rpc MessageUrl (puppet.MessageUrlRequest) returns (puppet.MessageUrlResponse) {}
 
   rpc MessageSendContact (puppet.MessageSendContactRequest) returns (puppet.MessageSendContactResponse) {}
+  // @deprecated: using MesageSendFileStream to transfer file message to server
   rpc MessageSendFile (puppet.MessageSendFileRequest) returns (puppet.MessageSendFileResponse) {}
+  rpc MessageSendFileStream (stream puppet.MessageSendFileStreamRequest) returns (puppet.MessageSendFileStreamResponse) {}
   rpc MessageSendText (puppet.MessageSendTextRequest) returns (puppet.MessageSendTextResponse) {}
   rpc MessageSendMiniProgram (puppet.MessageSendMiniProgramRequest) returns (puppet.MessageSendMiniProgramResponse) {}
   rpc MessageSendUrl (puppet.MessageSendUrlRequest) returns (puppet.MessageSendUrlResponse) {}

proto/wechaty/puppet/message.proto

@@ -62,6 +62,7 @@ message MessageImageStreamRequest {
 }
 message MessageImageStreamResponse {
   bytes data = 1;
+  string name = 2;
 }
 
 message MessageContactRequest {
@@ -83,6 +84,7 @@ message MessageFileStreamRequest {
 }
 message MessageFileStreamResponse {
   bytes data = 1;
+  string name = 2;
 }
 
 message MessageMiniProgramRequest {
@@ -116,6 +118,15 @@ message MessageSendFileResponse {
   google.protobuf.StringValue id = 1;
 }
 
+message MessageSendFileStreamRequest {
+  string conversation_id = 1;
+  bytes data = 2;
+  string name = 3;
+}
+message MessageSendFileStreamResponse {
+  google.protobuf.StringValue id = 1;
+}
+
 message MessageSendTextRequest {
   string conversation_id = 1;
   string text = 2;

tests/puppet-server-impl.ts

@@ -179,6 +179,12 @@ export const puppetServerImpl: IPuppetServer = {
     throw new Error('not implemented.')
   },
 
+  messageSendFileStream: (call, callback) => {
+    void call
+    void callback
+    throw new Error('not implemented.')
+  },
+
   messageSendMiniProgram: (call, callback) => {
     void call
     void callback