Merge pull request #26 from fabian4/fix_talkerId_and_listenerId

replace fromId by talkerId, toId by listenerId

package.json

@@ -1,6 +1,6 @@
 {
   "name": "wechaty-puppet-walnut",
-  "version": "1.11.8",
+  "version": "1.18.1",
   "description": "Puppet Walnut for Wechaty",
   "type": "module",
   "exports": {
@@ -59,7 +59,7 @@
     "@types/uuid": "^8.3.3"
   },
   "peerDependencies": {
-    "wechaty-puppet": "^1.11.12"
+    "wechaty-puppet": "^1.18.3"
   },
   "dependencies": {
     "axios": "^0.24.0",

src/puppet-walnut.spec.ts

@@ -53,9 +53,9 @@ test('message parser for text message', async t => {
   }
   const messagePayload = await puppet.messageRawPayloadParser(walnutMessagePayload as WalnutMessagePayload)
   t.ok(
-    messagePayload.toId === 'sip:[email protected]'
+    messagePayload.listenerId === 'sip:[email protected]'
     && messagePayload.roomId === undefined
-    && messagePayload.fromId === '17928222350'
+    && messagePayload.talkerId === '17928222350'
     && messagePayload.text === 'hello world'
     && messagePayload.type === PUPPET.types.Message.Text,
   )
@@ -95,9 +95,9 @@ test('message parser for image message', async t => {
   }
   const messagePayload = await puppet.messageRawPayloadParser(walnutMessagePayload as WalnutMessagePayload)
   t.ok(
-    messagePayload.toId === 'sip:[email protected]'
+    messagePayload.listenerId === 'sip:[email protected]'
     && messagePayload.roomId === undefined
-    && messagePayload.fromId === '17928222350'
+    && messagePayload.talkerId === '17928222350'
     && messagePayload.text === 'image'
     && messagePayload.type === PUPPET.types.Message.Image,
   )
@@ -137,9 +137,9 @@ test('message parser for file message', async t => {
   }
   const messagePayload = await puppet.messageRawPayloadParser(walnutMessagePayload as WalnutMessagePayload)
   t.ok(
-    messagePayload.toId === 'sip:[email protected]'
+    messagePayload.listenerId === 'sip:[email protected]'
     && messagePayload.roomId === undefined
-    && messagePayload.fromId === '17928222350'
+    && messagePayload.talkerId === '17928222350'
     && messagePayload.text === 'file'
     && messagePayload.type === PUPPET.types.Message.Attachment,
   )

src/puppet-walnut.ts

@@ -181,11 +181,11 @@ class PuppetWalnut extends PUPPET.Puppet {
    */
   override async messageRawPayloadParser (rawPayload: WalnutMessagePayload): Promise<PUPPET.payloads.Message> {
     const res = {
-      fromId: rawPayload.senderAddress.replace('tel:+86', ''),
       id: rawPayload.messageId,
+      listenerId: rawPayload.destinationAddress,
+      talkerId: rawPayload.senderAddress.replace('tel:+86', ''),
       text: rawPayload.messageList[0]!.contentText.toString(),
       timestamp: Date.parse(rawPayload.dateTime),
-      toId: rawPayload.destinationAddress,
       type: PUPPET.types.Message.Text,
     }
     const file = rawPayload.messageList[0]?.contentText[0] as FileItem
@@ -280,6 +280,43 @@ class PuppetWalnut extends PUPPET.Puppet {
     }
   }
 
+  /**
+   *
+   * Post
+   *
+   */
+  override async postRawPayload (postId: string): Promise<any> {
+    log.verbose('PuppetWalnut', 'postRawPayload(%s)', postId)
+    return { postId } as any
+  }
+
+  override async postRawPayloadParser (rawPayload: any): Promise<PUPPET.payloads.Post> {
+    log.verbose('PuppetWalnut', 'postRawPayloadParser(%s)', rawPayload.id)
+    return rawPayload
+  }
+
+  override async postPublish (payload: PUPPET.payloads.Post): Promise<void | string> {
+    log.verbose('PuppetWalnut', 'postPublish({type: %s})',
+      PUPPET.types.Post[
+        payload.type || PUPPET.types.Post.Unspecified
+      ],
+    )
+  }
+
+  override async postSearch (
+    filter      : PUPPET.filters.Post,
+    pagination? : PUPPET.filters.PaginationRequest,
+  ): Promise<PUPPET.filters.PaginationResponse<string[]>> {
+    log.verbose('PuppetWalnut', 'postSearch(%s, %s)',
+      JSON.stringify(filter),
+      JSON.stringify(pagination),
+    )
+    return {
+      nextPageToken: undefined,
+      response: [],
+    }
+  }
+
 }
 
 export default PuppetWalnut