feat: ✨ add send post message

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@juzi/wechaty-puppet-service",
-  "version": "1.0.96",
+  "version": "1.0.97",
   "description": "Puppet Service for Wechaty",
   "type": "module",
   "exports": {
@@ -73,7 +73,7 @@
     "@juzi/wechaty-puppet": "^1.0.84"
   },
   "dependencies": {
-    "@juzi/wechaty-grpc": "^1.0.84",
+    "@juzi/wechaty-grpc": "^1.0.86",
     "clone-class": "^1.1.1",
     "ducks": "^1.0.2",
     "file-box": "^1.5.5",

src/client/puppet-service.ts

@@ -1509,6 +1509,31 @@ class PuppetService extends PUPPET.Puppet {
     }
   }
 
+  override async messageSendPost (
+    conversationId: string,
+    postPayload: PUPPET.payloads.PostClient,
+  ): Promise<void | string> {
+    log.verbose('PuppetService', 'messageSendPost("%s", %s)', conversationId, JSON.stringify(postPayload))
+
+    const request = new grpcPuppet.MessageSendPostRequest()
+    const post = await postPayloadToPb(grpcPuppet, postPayload, this.serializeFileBox.bind(this))
+    request.setContent(post)
+    request.setConversationId(conversationId)
+
+    log.info('PuppetService', `messageSendPost(${conversationId}, ${postPayload}) about to call grpc`)
+    const response = await util.promisify(
+      this.grpcManager.client.messageSendPost
+        .bind(this.grpcManager.client),
+    )(request)
+
+    const messageId = response.getId()
+    log.info('PuppetService', `messageSendPost(${conversationId}, ${postPayload}) grpc called, messageId: ${messageId}`)
+
+    if (messageId) {
+      return messageId
+    }
+  }
+
   override async messageUrl (messageId: string): Promise<PUPPET.payloads.UrlLink> {
     log.verbose('PuppetService', 'messageUrl(%s)', messageId)
 

src/server/puppet-implementation.ts

@@ -1250,6 +1250,40 @@ function puppetImplementation (
       }
     },
 
+    messageSendPost: async (call, callback) => {
+      log.verbose('PuppetServiceImpl', 'messageSendPost()')
+
+      try {
+        const conversationId = call.request.getConversationId()
+        const post = call.request.getContent()
+
+        if (!post) {
+          throw new Error('no post found')
+        }
+        if (
+          post.getType() === grpcPuppet.PostType.POST_TYPE_CHANNEL
+          || post.getType() === grpcPuppet.PostType.POST_TYPE_BROADCAST
+          || post.getType() === grpcPuppet.PostType.POST_TYPE_UNSPECIFIED
+        ) {
+          throw new Error('cannot send post with non-message post type')
+        }
+
+        const payload = postPbToPayload(post, FileBoxUuid)
+
+        const id = await puppet.messageSendPost(conversationId, payload)
+
+        const response = new grpcPuppet.MessageSendPostResponse()
+        if (id) {
+          response.setId(id)
+        }
+
+        return callback(null, response)
+
+      } catch (e) {
+        return grpcError('messageSendPost', e, callback)
+      }
+    },
+
     messageUrl: async (call, callback) => {
       log.verbose('PuppetServiceImpl', 'messageUrl()')