feat: add wxpusher message push

server/models/chat/inbox.ts

@@ -28,6 +28,11 @@ interface InboxMessage {
    * 消息片段，用于消息的预览/发送通知
    */
   messageSnippet: string;
+
+  /**
+   * 消息去除富文本标记的原始内容，用于推送
+   */
+  messagePlainContent: string;
 }
 
 /**

server/packages/sdk/src/structs/chat.ts

@@ -80,6 +80,7 @@ export interface MessageInboxItem extends BasicInboxItem {
     converseId: string;
     messageId: string;
     messageSnippet: string;
+    messagePlainContent?: string;
   };
 }
 

server/plugins/com.msgbyte.wxpusher/services/wxpusher.service.ts

@@ -1,4 +1,4 @@
-import { TcService, TcDbService } from 'tailchat-server-sdk';
+import { TcService, TcDbService, InboxStruct, call } from 'tailchat-server-sdk';
 import type {
   WXPusherUserDocument,
   WXPusherUserModel,
@@ -41,6 +41,29 @@ class WxpusherService extends TcService {
       return;
     }
 
+    this.registerEventListener(
+      'chat.inbox.append',
+      async (inboxItem: InboxStruct, ctx) => {
+        if (inboxItem.type === 'message') {
+          const userId = inboxItem.userId;
+          const message = inboxItem.payload;
+
+          let title = 'new';
+          if (message.groupId) {
+            const groupInfo = await call(ctx).getGroupInfo(message.groupId);
+            title = groupInfo.name;
+          }
+          const content = message.messagePlainContent ?? message.messageSnippet; // 优先使用去节点的内容
+
+          try {
+            await this.sendMessage(userId, [title, content].join('\n'));
+          } catch (err) {
+            console.error(err);
+          }
+        }
+      }
+    );
+
     this.registerAction('getWXPusherUserId', this.getWXPusherUserId);
     this.registerAction('createQRCode', this.createQRCode);
     this.registerAction('callback', this.callback, {

server/services/core/chat/inbox.service.ts

@@ -40,6 +40,7 @@ class InboxService extends TcService {
                     converseId: payload.converseId,
                     messageId: payload.messageId,
                     messageSnippet: payload.content,
+                    messagePlainContent: payload.plain,
                   },
                 });
               })