fix: face msg faceType

fix: quick reply friend msg
fix: ws 没有上报群文件上传事件
2024-11-22 01:56:33 +00:00 · 2024-04-11 18:57:58 +08:00 · 2024-04-11 18:17:02 +08:00 · 2024-04-08 00:21:24 +08:00 · 2024-04-07 18:51:26 +08:00 · 2024-04-07 17:37:52 +08:00
10 changed files with 771 additions and 594 deletions
--- a/manifest.json
+++ b/manifest.json
@@ -1,10 +1,10 @@
 {
  "manifest_version": 4,
  "type": "extension",
-  "name": "LLOneBot v3.21.0",
+  "name": "LLOneBot v3.22.1",
  "slug": "LLOneBot",
  "description": "使你的NTQQ支持OneBot11协议进行QQ机器人开发, 不支持商店在线更新",
-  "version": "3.21.0",
+  "version": "3.22.1",
  "icon": "./icon.jpg",
  "authors": [
    {
--- a/src/ntqqapi/constructor.ts
+++ b/src/ntqqapi/constructor.ts
@@ -1,15 +1,16 @@
 import {
-    AtType,
-    ElementType,
-    PicType,
-    SendArkElement,
-    SendFaceElement,
-    SendFileElement,
-    SendPicElement,
-    SendPttElement,
-    SendReplyElement,
-    SendTextElement,
-    SendVideoElement
+  AtType,
+  ElementType, FaceIndex,
+  FaceType,
+  PicType,
+  SendArkElement,
+  SendFaceElement,
+  SendFileElement,
+  SendPicElement,
+  SendPttElement,
+  SendReplyElement,
+  SendTextElement,
+  SendVideoElement
 } from "./types";
 import {promises as fs} from "node:fs";
 import ffmpeg from "fluent-ffmpeg"
@@ -18,239 +19,301 @@ import {calculateFileMD5, isGIF} from "../common/utils/file";
 import {log} from "../common/utils/log";
 import {defaultVideoThumb, getVideoInfo} from "../common/utils/video";
 import {encodeSilk} from "../common/utils/audio";
+import {isNull} from "../common/utils";


 export class SendMsgElementConstructor {

-    static poke(groupCode: string, uin: string){
-        return null
+  static poke(groupCode: string, uin: string) {
+    return null
+  }
+
+  static text(content: string): SendTextElement {
+    return {
+      elementType: ElementType.TEXT,
+      elementId: "",
+      textElement: {
+        content,
+        atType: AtType.notAt,
+        atUid: "",
+        atTinyId: "",
+        atNtUid: "",
+      },
+    };
+  }
+
+  static at(atUid: string, atNtUid: string, atType: AtType, atName: string): SendTextElement {
+    return {
+      elementType: ElementType.TEXT,
+      elementId: "",
+      textElement: {
+        content: `@${atName}`,
+        atType,
+        atUid,
+        atTinyId: "",
+        atNtUid,
+      },
+    };
+  }
+
+  static reply(msgSeq: string, msgId: string, senderUin: string, senderUinStr: string): SendReplyElement {
+    return {
+      elementType: ElementType.REPLY,
+      elementId: "",
+      replyElement: {
+        replayMsgSeq: msgSeq, // raw.msgSeq
+        replayMsgId: msgId,  // raw.msgId
+        senderUin: senderUin,
+        senderUinStr: senderUinStr,
+      }
    }
-    static text(content: string): SendTextElement {
-        return {
-            elementType: ElementType.TEXT,
-            elementId: "",
-            textElement: {
-                content,
-                atType: AtType.notAt,
-                atUid: "",
-                atTinyId: "",
-                atNtUid: "",
-            },
-        };
+  }
+
+  static async pic(picPath: string, summary: string = "", subType: 0 | 1 = 0): Promise<SendPicElement> {
+    const {md5, fileName, path, fileSize} = await NTQQFileApi.uploadFile(picPath, ElementType.PIC, subType);
+    if (fileSize === 0) {
+      throw "文件异常，大小为0";
+    }
+    const imageSize = await NTQQFileApi.getImageSize(picPath);
+    const picElement = {
+      md5HexStr: md5,
+      fileSize: fileSize.toString(),
+      picWidth: imageSize.width,
+      picHeight: imageSize.height,
+      fileName: fileName,
+      sourcePath: path,
+      original: true,
+      picType: isGIF(picPath) ? PicType.gif : PicType.jpg,
+      picSubType: subType,
+      fileUuid: "",
+      fileSubId: "",
+      thumbFileSize: 0,
+      summary
+    };
+    log("图片信息", picElement)
+    return {
+      elementType: ElementType.PIC,
+      elementId: "",
+      picElement,
+    };
+  }
+
+  static async file(filePath: string, fileName: string = ""): Promise<SendFileElement> {
+    const {md5, fileName: _fileName, path, fileSize} = await NTQQFileApi.uploadFile(filePath, ElementType.FILE);
+    if (fileSize === 0) {
+      throw "文件异常，大小为0";
+    }
+    let element: SendFileElement = {
+      elementType: ElementType.FILE,
+      elementId: "",
+      fileElement: {
+        fileName: fileName || _fileName,
+        "filePath": path,
+        "fileSize": (fileSize).toString(),
+      }
    }

-    static at(atUid: string, atNtUid: string, atType: AtType, atName: string): SendTextElement {
-        return {
-            elementType: ElementType.TEXT,
-            elementId: "",
-            textElement: {
-                content: `@${atName}`,
-                atType,
-                atUid,
-                atTinyId: "",
-                atNtUid,
-            },
-        };
+    return element;
+  }
+
+  static async video(filePath: string, fileName: string = "", diyThumbPath: string = ""): Promise<SendVideoElement> {
+    let {fileName: _fileName, path, fileSize, md5} = await NTQQFileApi.uploadFile(filePath, ElementType.VIDEO);
+    if (fileSize === 0) {
+      throw "文件异常，大小为0";
    }
-
-    static reply(msgSeq: string, msgId: string, senderUin: string, senderUinStr: string): SendReplyElement {
-        return {
-            elementType: ElementType.REPLY,
-            elementId: "",
-            replyElement: {
-                replayMsgSeq: msgSeq, // raw.msgSeq
-                replayMsgId: msgId,  // raw.msgId
-                senderUin: senderUin,
-                senderUinStr: senderUinStr,
-            }
-        }
+    const pathLib = require("path");
+    let thumbDir = path.replace(`${pathLib.sep}Ori${pathLib.sep}`, `${pathLib.sep}Thumb${pathLib.sep}`)
+    thumbDir = pathLib.dirname(thumbDir)
+    // log("thumb 目录", thumb)
+    let videoInfo = {
+      width: 1920, height: 1080,
+      time: 15,
+      format: "mp4",
+      size: fileSize,
+      filePath
+    };
+    try {
+      videoInfo = await getVideoInfo(path);
+      log("视频信息", videoInfo)
+    } catch (e) {
+      log("获取视频信息失败", e)
    }
+    const createThumb = new Promise<string>((resolve, reject) => {
+      const thumbFileName = `${md5}_0.png`
+      const thumbPath = pathLib.join(thumbDir, thumbFileName)
+      log("开始生成视频缩略图", filePath);
+      let completed = false;

-    static async pic(picPath: string, summary: string = "", subType: 0|1=0): Promise<SendPicElement> {
-        const {md5, fileName, path, fileSize} = await NTQQFileApi.uploadFile(picPath, ElementType.PIC, subType);
-        if (fileSize === 0) {
-            throw "文件异常，大小为0";
-        }
-        const imageSize = await NTQQFileApi.getImageSize(picPath);
-        const picElement = {
-            md5HexStr: md5,
-            fileSize: fileSize.toString(),
-            picWidth: imageSize.width,
-            picHeight: imageSize.height,
-            fileName: fileName,
-            sourcePath: path,
-            original: true,
-            picType: isGIF(picPath) ? PicType.gif : PicType.jpg,
-            picSubType: subType,
-            fileUuid: "",
-            fileSubId: "",
-            thumbFileSize: 0,
-            summary
-        };
-        log("图片信息", picElement)
-        return {
-            elementType: ElementType.PIC,
-            elementId: "",
-            picElement,
-        };
-    }
+      function useDefaultThumb() {
+        if (completed) return;
+        log("获取视频封面失败，使用默认封面");
+        fs.writeFile(thumbPath, defaultVideoThumb).then(() => {
+          resolve(thumbPath);
+        }).catch(reject)
+      }

-    static async file(filePath: string, fileName: string = ""): Promise<SendFileElement> {
-        const {md5, fileName: _fileName, path, fileSize} = await NTQQFileApi.uploadFile(filePath, ElementType.FILE);
-        if (fileSize === 0) {
-            throw "文件异常，大小为0";
-        }
-        let element: SendFileElement = {
-            elementType: ElementType.FILE,
-            elementId: "",
-            fileElement: {
-                fileName: fileName || _fileName,
-                "filePath": path,
-                "fileSize": (fileSize).toString(),
-            }
-        }
-
-        return element;
-    }
-
-    static async video(filePath: string, fileName: string = "", diyThumbPath: string = ""): Promise<SendVideoElement> {
-        let {fileName: _fileName, path, fileSize, md5} = await NTQQFileApi.uploadFile(filePath, ElementType.VIDEO);
-        if (fileSize === 0) {
-            throw "文件异常，大小为0";
-        }
-        const pathLib = require("path");
-        let thumb = path.replace(`${pathLib.sep}Ori${pathLib.sep}`, `${pathLib.sep}Thumb${pathLib.sep}`)
-        thumb = pathLib.dirname(thumb)
-        // log("thumb 目录", thumb)
-        let videoInfo = {
-            width: 1920, height: 1080,
-            time: 15,
-            format: "mp4",
-            size: fileSize,
-            filePath
-        };
-        try {
-            videoInfo = await getVideoInfo(path);
-            log("视频信息", videoInfo)
-        } catch (e) {
-            log("获取视频信息失败", e)
-        }
-        const createThumb = new Promise<string>((resolve, reject) => {
-            const thumbFileName = `${md5}_0.png`
-            const thumbPath = pathLib.join(thumb, thumbFileName)
-            ffmpeg(filePath)
-                .on("end", () => {
-                })
-                .on("error", (err) => {
-                    log("获取视频封面失败，使用默认封面", err)
-                    if (diyThumbPath) {
-                        fs.copyFile(diyThumbPath, thumbPath).then(() => {
-                            resolve(thumbPath);
-                        }).catch(reject)
-                    } else {
-                        fs.writeFile(thumbPath, defaultVideoThumb).then(() => {
-                            resolve(thumbPath);
-                        }).catch(reject)
-                    }
-                })
-                .screenshots({
-                    timestamps: [0],
-                    filename: thumbFileName,
-                    folder: thumb,
-                    size: videoInfo.width + "x" + videoInfo.height
-                }).on("end", () => {
-                resolve(thumbPath);
-            });
+      setTimeout(useDefaultThumb, 5000);
+      ffmpeg(filePath)
+        .on("end", () => {
        })
-        let thumbPath = new Map()
-        const _thumbPath = await createThumb;
-        const thumbSize = (await fs.stat(_thumbPath)).size;
-        // log("生成缩略图", _thumbPath)
-        thumbPath.set(0, _thumbPath)
-        const thumbMd5 = await calculateFileMD5(_thumbPath);
-        let element: SendVideoElement = {
-            elementType: ElementType.VIDEO,
-            elementId: "",
-            videoElement: {
-                fileName: fileName || _fileName,
-                filePath: path,
-                videoMd5: md5,
-                thumbMd5,
-                fileTime: videoInfo.time,
-                thumbPath: thumbPath,
-                thumbSize,
-                thumbWidth: videoInfo.width,
-                thumbHeight: videoInfo.height,
-                fileSize: "" + fileSize,
-                // fileUuid: "",
-                // transferStatus: 0,
-                // progress: 0,
-                // invalidState: 0,
-                // fileSubId: "",
-                // fileBizId: null,
-                // originVideoMd5: "",
-                // fileFormat: 2,
-                // import_rich_media_context: null,
-                // sourceVideoCodecFormat: 2
-            }
-        }
-        return element;
+        .on("error", (err) => {
+          if (diyThumbPath) {
+            fs.copyFile(diyThumbPath, thumbPath).then(() => {
+              completed = true;
+              resolve(thumbPath);
+            }).catch(reject)
+          } else {
+            useDefaultThumb()
+          }
+        })
+        .screenshots({
+          timestamps: [0],
+          filename: thumbFileName,
+          folder: thumbDir,
+          size: videoInfo.width + "x" + videoInfo.height
+        }).on("end", () => {
+          log("生成视频缩略图", thumbPath)
+          completed = true;
+          resolve(thumbPath);
+      })
+    })
+    let thumbPath = new Map()
+    const _thumbPath = await createThumb;
+    log("生成缩略图", _thumbPath)
+    const thumbSize = (await fs.stat(_thumbPath)).size;
+    // log("生成缩略图", _thumbPath)
+    thumbPath.set(0, _thumbPath)
+    const thumbMd5 = await calculateFileMD5(_thumbPath);
+    let element: SendVideoElement = {
+      elementType: ElementType.VIDEO,
+      elementId: "",
+      videoElement: {
+        fileName: fileName || _fileName,
+        filePath: path,
+        videoMd5: md5,
+        thumbMd5,
+        fileTime: videoInfo.time,
+        thumbPath: thumbPath,
+        thumbSize,
+        thumbWidth: videoInfo.width,
+        thumbHeight: videoInfo.height,
+        fileSize: "" + fileSize,
+        // fileUuid: "",
+        // transferStatus: 0,
+        // progress: 0,
+        // invalidState: 0,
+        // fileSubId: "",
+        // fileBizId: null,
+        // originVideoMd5: "",
+        // fileFormat: 2,
+        // import_rich_media_context: null,
+        // sourceVideoCodecFormat: 2
+      }
    }
+    log("videoElement", element)
+    return element;
+  }

-    static async ptt(pttPath: string): Promise<SendPttElement> {
-        const {converted, path: silkPath, duration} = await encodeSilk(pttPath);
-        // log("生成语音", silkPath, duration);
-        const {md5, fileName, path, fileSize} = await NTQQFileApi.uploadFile(silkPath, ElementType.PTT);
-        if (fileSize === 0) {
-            throw "文件异常，大小为0";
-        }
-        if (converted) {
-            fs.unlink(silkPath).then();
-        }
-        return {
-            elementType: ElementType.PTT,
-            elementId: "",
-            pttElement: {
-                fileName: fileName,
-                filePath: path,
-                md5HexStr: md5,
-                fileSize: fileSize,
-                // duration: Math.max(1, Math.round(fileSize / 1024 / 3)), // 一秒钟大概是3kb大小, 小于1秒的按1秒算
-                duration: duration,
-                formatType: 1,
-                voiceType: 1,
-                voiceChangeType: 0,
-                canConvert2Text: true,
-                waveAmplitudes: [
-                    0, 18, 9, 23, 16, 17, 16, 15, 44, 17, 24, 20, 14, 15, 17,
-                ],
-                fileSubId: "",
-                playState: 1,
-                autoConvertText: 0,
-            }
-        };
+  static async ptt(pttPath: string): Promise<SendPttElement> {
+    const {converted, path: silkPath, duration} = await encodeSilk(pttPath);
+    // log("生成语音", silkPath, duration);
+    const {md5, fileName, path, fileSize} = await NTQQFileApi.uploadFile(silkPath, ElementType.PTT);
+    if (fileSize === 0) {
+      throw "文件异常，大小为0";
    }
+    if (converted) {
+      fs.unlink(silkPath).then();
+    }
+    return {
+      elementType: ElementType.PTT,
+      elementId: "",
+      pttElement: {
+        fileName: fileName,
+        filePath: path,
+        md5HexStr: md5,
+        fileSize: fileSize,
+        // duration: Math.max(1, Math.round(fileSize / 1024 / 3)), // 一秒钟大概是3kb大小, 小于1秒的按1秒算
+        duration: duration,
+        formatType: 1,
+        voiceType: 1,
+        voiceChangeType: 0,
+        canConvert2Text: true,
+        waveAmplitudes: [
+          0, 18, 9, 23, 16, 17, 16, 15, 44, 17, 24, 20, 14, 15, 17,
+        ],
+        fileSubId: "",
+        playState: 1,
+        autoConvertText: 0,
+      }
+    };
+  }

-    static face(faceId: number): SendFaceElement {
-        return {
-            elementType: ElementType.FACE,
-            elementId: "",
-            faceElement: {
-                faceIndex: faceId,
-                faceType: 1
-            }
-        }
+  static face(faceId: number): SendFaceElement {
+    faceId = parseInt(faceId.toString());
+    return {
+      elementType: ElementType.FACE,
+      elementId: "",
+      faceElement: {
+        faceIndex: faceId,
+        faceType: faceId < 222 ? FaceType.normal : FaceType.normal2,
+      }
    }
+  }

-    static ark(data: any): SendArkElement {
-        return {
-            elementType: ElementType.ARK,
-            elementId: "",
-            arkElement: {
-                bytesData: data,
-                linkInfo: null,
-                subElementType: null
-            }
-        }
+  static dice(resultId: number | null): SendFaceElement {
+    // 实际测试并不能控制结果
+
+    // 随机1到6
+    if (isNull(resultId)) resultId = Math.floor(Math.random() * 6) + 1;
+    return {
+      elementType: ElementType.FACE,
+      elementId: "",
+      faceElement: {
+        faceIndex: FaceIndex.dice,
+        faceType: FaceType.dice,
+        "faceText": "[骰子]",
+        "packId": "1",
+        "stickerId": "33",
+        "sourceType": 1,
+        "stickerType": 2,
+        resultId: resultId.toString(),
+        "surpriseId": "",
+        // "randomType": 1,
+      }
    }
+  }
+
+  // 猜拳(石头剪刀布)表情
+  static rps(resultId: number | null): SendFaceElement {
+    // 实际测试并不能控制结果
+    if (isNull(resultId)) resultId = Math.floor(Math.random() * 3) + 1;
+    return {
+      elementType: ElementType.FACE,
+      elementId: "",
+      faceElement: {
+        "faceIndex": FaceIndex.RPS,
+        "faceText": "[包剪锤]",
+        "faceType": 3,
+        "packId": "1",
+        "stickerId": "34",
+        "sourceType": 1,
+        "stickerType": 2,
+        "resultId": resultId.toString(),
+        "surpriseId": "",
+        // "randomType": 1,
+      }
+    }
+  }
+
+  static ark(data: any): SendArkElement {
+    return {
+      elementType: ElementType.ARK,
+      elementId: "",
+      arkElement: {
+        bytesData: data,
+        linkInfo: null,
+        subElementType: null
+      }
+    }
+  }
 }
--- a/src/ntqqapi/hook.ts
+++ b/src/ntqqapi/hook.ts
@@ -1,8 +1,8 @@
 import {BrowserWindow} from 'electron';
-import {NTQQApiClass} from "./ntcall";
+import {NTQQApiClass, NTQQApiMethod} from "./ntcall";
 import {NTQQMsgApi, sendMessagePool} from "./api/msg"
 import {ChatType, Group, GroupMember, GroupMemberRole, RawMessage, User} from "./types";
-import {friends, getGroupMember, groups, selfInfo, tempGroupCodeMap, uidMaps} from "../common/data";
+import {friends, getFriend, getGroupMember, groups, selfInfo, tempGroupCodeMap, uidMaps} from "../common/data";
 import {OB11GroupDecreaseEvent} from "../onebot11/event/notice/OB11GroupDecreaseEvent";
 import {v4 as uuidv4} from "uuid"
 import {postOB11Event} from "../onebot11/server/postOB11Event";
@@ -11,446 +11,503 @@ import fs from "fs";
 import {dbUtil} from "../common/db";
 import {NTQQGroupApi} from "./api/group";
 import {log} from "../common/utils/log";
-import {sleep} from "../common/utils/helper";
+import {isNumeric, sleep} from "../common/utils/helper";
 import {OB11Constructor} from "../onebot11/constructor";

 export let hookApiCallbacks: Record<string, (apiReturn: any) => void> = {}

 export let ReceiveCmdS = {
-    RECENT_CONTACT: "nodeIKernelRecentContactListener/onRecentContactListChangedVer2",
-    UPDATE_MSG: "nodeIKernelMsgListener/onMsgInfoListUpdate",
-    UPDATE_ACTIVE_MSG: "nodeIKernelMsgListener/onActiveMsgInfoUpdate",
-    NEW_MSG: `nodeIKernelMsgListener/onRecvMsg`,
-    NEW_ACTIVE_MSG: `nodeIKernelMsgListener/onRecvActiveMsg`,
-    SELF_SEND_MSG: "nodeIKernelMsgListener/onAddSendMsg",
-    USER_INFO: "nodeIKernelProfileListener/onProfileSimpleChanged",
-    USER_DETAIL_INFO: "nodeIKernelProfileListener/onProfileDetailInfoChanged",
-    GROUPS: "nodeIKernelGroupListener/onGroupListUpdate",
-    GROUPS_STORE: "onGroupListUpdate",
-    GROUP_MEMBER_INFO_UPDATE: "nodeIKernelGroupListener/onMemberInfoChange",
-    FRIENDS: "onBuddyListChange",
-    MEDIA_DOWNLOAD_COMPLETE: "nodeIKernelMsgListener/onRichMediaDownloadComplete",
-    UNREAD_GROUP_NOTIFY: "nodeIKernelGroupListener/onGroupNotifiesUnreadCountUpdated",
-    GROUP_NOTIFY: "nodeIKernelGroupListener/onGroupSingleScreenNotifies",
-    FRIEND_REQUEST: "nodeIKernelBuddyListener/onBuddyReqChange",
-    SELF_STATUS: 'nodeIKernelProfileListener/onSelfStatusChanged',
-    CACHE_SCAN_FINISH: "nodeIKernelStorageCleanListener/onFinishScan",
-    MEDIA_UPLOAD_COMPLETE: "nodeIKernelMsgListener/onRichMediaUploadComplete",
-    SKEY_UPDATE: "onSkeyUpdate"
+  RECENT_CONTACT: "nodeIKernelRecentContactListener/onRecentContactListChangedVer2",
+  UPDATE_MSG: "nodeIKernelMsgListener/onMsgInfoListUpdate",
+  UPDATE_ACTIVE_MSG: "nodeIKernelMsgListener/onActiveMsgInfoUpdate",
+  NEW_MSG: `nodeIKernelMsgListener/onRecvMsg`,
+  NEW_ACTIVE_MSG: `nodeIKernelMsgListener/onRecvActiveMsg`,
+  SELF_SEND_MSG: "nodeIKernelMsgListener/onAddSendMsg",
+  USER_INFO: "nodeIKernelProfileListener/onProfileSimpleChanged",
+  USER_DETAIL_INFO: "nodeIKernelProfileListener/onProfileDetailInfoChanged",
+  GROUPS: "nodeIKernelGroupListener/onGroupListUpdate",
+  GROUPS_STORE: "onGroupListUpdate",
+  GROUP_MEMBER_INFO_UPDATE: "nodeIKernelGroupListener/onMemberInfoChange",
+  FRIENDS: "onBuddyListChange",
+  MEDIA_DOWNLOAD_COMPLETE: "nodeIKernelMsgListener/onRichMediaDownloadComplete",
+  UNREAD_GROUP_NOTIFY: "nodeIKernelGroupListener/onGroupNotifiesUnreadCountUpdated",
+  GROUP_NOTIFY: "nodeIKernelGroupListener/onGroupSingleScreenNotifies",
+  FRIEND_REQUEST: "nodeIKernelBuddyListener/onBuddyReqChange",
+  SELF_STATUS: 'nodeIKernelProfileListener/onSelfStatusChanged',
+  CACHE_SCAN_FINISH: "nodeIKernelStorageCleanListener/onFinishScan",
+  MEDIA_UPLOAD_COMPLETE: "nodeIKernelMsgListener/onRichMediaUploadComplete",
+  SKEY_UPDATE: "onSkeyUpdate"
 }

 export type ReceiveCmd = typeof ReceiveCmdS[keyof typeof ReceiveCmdS]

 interface NTQQApiReturnData<PayloadType = unknown> extends Array<any> {
-    0: {
-        "type": "request",
-        "eventName": NTQQApiClass,
-        "callbackId"?: string
-    },
-    1:
-        {
-            cmdName: ReceiveCmd,
-            cmdType: "event",
-            payload: PayloadType
-        }[]
+  0: {
+    "type": "request",
+    "eventName": NTQQApiClass,
+    "callbackId"?: string
+  },
+  1:
+    {
+      cmdName: ReceiveCmd,
+      cmdType: "event",
+      payload: PayloadType
+    }[]
 }

 let receiveHooks: Array<{
-    method: ReceiveCmd[],
-    hookFunc: ((payload: any) => void | Promise<void>)
-    id: string
+  method: ReceiveCmd[],
+  hookFunc: ((payload: any) => void | Promise<void>)
+  id: string
 }> = []

-export function hookNTQQApiReceive(window: BrowserWindow) {
-    const originalSend = window.webContents.send;
-    const patchSend = (channel: string, ...args: NTQQApiReturnData) => {
-        // console.log("hookNTQQApiReceive", channel, args)
-        let isLogger = false
-        try {
-            isLogger = args[0]?.eventName?.startsWith("ns-LoggerApi")
-        } catch (e) {
+let callHooks: Array<{
+  method: NTQQApiMethod[],
+  hookFunc: ((callParams: unknown[]) => void | Promise<void>)
+}> = []
+
+
+export function hookNTQQApiReceive(window: BrowserWindow) {
+  const originalSend = window.webContents.send;
+  const patchSend = (channel: string, ...args: NTQQApiReturnData) => {
+    // console.log("hookNTQQApiReceive", channel, args)
+    let isLogger = false
+    try {
+      isLogger = args[0]?.eventName?.startsWith("ns-LoggerApi")
+    } catch (e) {

-        }
-        if (!isLogger) {
-            try {
-                HOOK_LOG && log(`received ntqq api message: ${channel}`, args)
-            } catch (e) {
-                log("hook log error", e, args)
-            }
-        }
-        try {
-            if (args?.[1] instanceof Array) {
-                for (let receiveData of args?.[1]) {
-                    const ntQQApiMethodName = receiveData.cmdName;
-                    // log(`received ntqq api message: ${channel} ${ntQQApiMethodName}`, JSON.stringify(receiveData))
-                    for (let hook of receiveHooks) {
-                        if (hook.method.includes(ntQQApiMethodName)) {
-                            new Promise((resolve, reject) => {
-                                try {
-                                    let _ = hook.hookFunc(receiveData.payload)
-                                    if (hook.hookFunc.constructor.name === "AsyncFunction") {
-                                        (_ as Promise<void>).then()
-                                    }
-                                } catch (e) {
-                                    log("hook error", e, receiveData.payload)
-                                }
-                            }).then()
-                        }
-                    }
-                }
-            }
-            if (args[0]?.callbackId) {
-                // log("hookApiCallback", hookApiCallbacks, args)
-                const callbackId = args[0].callbackId;
-                if (hookApiCallbacks[callbackId]) {
-                    // log("callback found")
-                    new Promise((resolve, reject) => {
-                        hookApiCallbacks[callbackId](args[1]);
-                    }).then()
-                    delete hookApiCallbacks[callbackId];
-                }
-            }
-        } catch (e) {
-            log("hookNTQQApiReceive error", e.stack.toString(), args)
-        }
-        originalSend.call(window.webContents, channel, ...args);
    }
-    window.webContents.send = patchSend;
+    if (!isLogger) {
+      try {
+        HOOK_LOG && log(`received ntqq api message: ${channel}`, args)
+      } catch (e) {
+        log("hook log error", e, args)
+      }
+    }
+    try {
+      if (args?.[1] instanceof Array) {
+        for (let receiveData of args?.[1]) {
+          const ntQQApiMethodName = receiveData.cmdName;
+          // log(`received ntqq api message: ${channel} ${ntQQApiMethodName}`, JSON.stringify(receiveData))
+          for (let hook of receiveHooks) {
+            if (hook.method.includes(ntQQApiMethodName)) {
+              new Promise((resolve, reject) => {
+                try {
+                  let _ = hook.hookFunc(receiveData.payload)
+                  if (hook.hookFunc.constructor.name === "AsyncFunction") {
+                    (_ as Promise<void>).then()
+                  }
+                } catch (e) {
+                  log("hook error", e, receiveData.payload)
+                }
+              }).then()
+            }
+          }
+        }
+      }
+      if (args[0]?.callbackId) {
+        // log("hookApiCallback", hookApiCallbacks, args)
+        const callbackId = args[0].callbackId;
+        if (hookApiCallbacks[callbackId]) {
+          // log("callback found")
+          new Promise((resolve, reject) => {
+            hookApiCallbacks[callbackId](args[1]);
+          }).then()
+          delete hookApiCallbacks[callbackId];
+        }
+      }
+    } catch (e) {
+      log("hookNTQQApiReceive error", e.stack.toString(), args)
+    }
+    originalSend.call(window.webContents, channel, ...args);
+  }
+  window.webContents.send = patchSend;
 }

 export function hookNTQQApiCall(window: BrowserWindow) {
-    // 监听调用NTQQApi
-    let webContents = window.webContents as any;
-    const ipc_message_proxy = webContents._events["-ipc-message"]?.[0] || webContents._events["-ipc-message"];
+  // 监听调用NTQQApi
+  let webContents = window.webContents as any;
+  const ipc_message_proxy = webContents._events["-ipc-message"]?.[0] || webContents._events["-ipc-message"];

-    const proxyIpcMsg = new Proxy(ipc_message_proxy, {
-        apply(target, thisArg, args) {
-            // console.log(thisArg, args);
-            let isLogger = false
-            try {
-                isLogger = args[3][0].eventName.startsWith("ns-LoggerApi")
-            } catch (e) {
+  const proxyIpcMsg = new Proxy(ipc_message_proxy, {
+    apply(target, thisArg, args) {
+      // console.log(thisArg, args);
+      let isLogger = false
+      try {
+        isLogger = args[3][0].eventName.startsWith("ns-LoggerApi")
+      } catch (e) {

-            }
-            if (!isLogger) {
-                try {
-                    HOOK_LOG && log("call NTQQ api", thisArg, args);
-                } catch (e) {
+      }
+      if (!isLogger) {
+        try {
+          HOOK_LOG && log("call NTQQ api", thisArg, args);
+        } catch (e) {

-                }
-            }
-            return target.apply(thisArg, args);
-        },
-    });
-    if (webContents._events["-ipc-message"]?.[0]) {
-        webContents._events["-ipc-message"][0] = proxyIpcMsg;
-    } else {
-        webContents._events["-ipc-message"] = proxyIpcMsg;
-    }
-
-    const ipc_invoke_proxy = webContents._events["-ipc-invoke"]?.[0] || webContents._events["-ipc-invoke"];
-    const proxyIpcInvoke = new Proxy(ipc_invoke_proxy, {
-        apply(target, thisArg, args) {
-            // console.log(args);
-            HOOK_LOG && log("call NTQQ invoke api", thisArg, args)
-            args[0]["_replyChannel"]["sendReply"] = new Proxy(args[0]["_replyChannel"]["sendReply"], {
-                apply(sendtarget, sendthisArg, sendargs) {
-                    sendtarget.apply(sendthisArg, sendargs);
-                }
-            });
-            let ret = target.apply(thisArg, args);
-            try {
-                HOOK_LOG && log("call NTQQ invoke api return", ret)
-            } catch (e) {
-
-            }
-            return ret;
        }
-    });
-    if (webContents._events["-ipc-invoke"]?.[0]) {
-        webContents._events["-ipc-invoke"][0] = proxyIpcInvoke;
-    } else {
-        webContents._events["-ipc-invoke"] = proxyIpcInvoke;
+        try {
+          const _args: unknown[] = args[3][1];
+          const cmdName: NTQQApiMethod = _args[0] as NTQQApiMethod;
+          const callParams = _args.slice(1);
+          callHooks.forEach(hook => {
+            if (hook.method.includes(cmdName)) {
+              new Promise((resolve, reject) => {
+                try {
+                  let _ = hook.hookFunc(callParams)
+                  if (hook.hookFunc.constructor.name === "AsyncFunction") {
+                    (_ as Promise<void>).then()
+                  }
+                } catch (e) {
+                  log("hook call error", e, _args)
+                }
+              }).then()
+            }
+          })
+        } catch (e) {
+
+        }
+      }
+      return target.apply(thisArg, args);
+    },
+  });
+  if (webContents._events["-ipc-message"]?.[0]) {
+    webContents._events["-ipc-message"][0] = proxyIpcMsg;
+  } else {
+    webContents._events["-ipc-message"] = proxyIpcMsg;
+  }
+
+  const ipc_invoke_proxy = webContents._events["-ipc-invoke"]?.[0] || webContents._events["-ipc-invoke"];
+  const proxyIpcInvoke = new Proxy(ipc_invoke_proxy, {
+    apply(target, thisArg, args) {
+      // console.log(args);
+      HOOK_LOG && log("call NTQQ invoke api", thisArg, args)
+      args[0]["_replyChannel"]["sendReply"] = new Proxy(args[0]["_replyChannel"]["sendReply"], {
+        apply(sendtarget, sendthisArg, sendargs) {
+          sendtarget.apply(sendthisArg, sendargs);
+        }
+      });
+      let ret = target.apply(thisArg, args);
+      try {
+        HOOK_LOG && log("call NTQQ invoke api return", ret)
+      } catch (e) {
+
+      }
+      return ret;
    }
+  });
+  if (webContents._events["-ipc-invoke"]?.[0]) {
+    webContents._events["-ipc-invoke"][0] = proxyIpcInvoke;
+  } else {
+    webContents._events["-ipc-invoke"] = proxyIpcInvoke;
+  }
 }

 export function registerReceiveHook<PayloadType>(method: ReceiveCmd | ReceiveCmd[], hookFunc: (payload: PayloadType) => void): string {
-    const id = uuidv4()
-    if (!Array.isArray(method)) {
-        method = [method]
-    }
-    receiveHooks.push({
-        method,
-        hookFunc,
-        id
-    })
-    return id;
+  const id = uuidv4()
+  if (!Array.isArray(method)) {
+    method = [method]
+  }
+  receiveHooks.push({
+    method,
+    hookFunc,
+    id
+  })
+  return id;
+}
+
+export function registerCallHook(method: NTQQApiMethod | NTQQApiMethod[], hookFunc: (callParams: unknown[]) => void | Promise<void>): void {
+  if (!Array.isArray(method)) {
+    method = [method]
+  }
+  callHooks.push({
+    method,
+    hookFunc
+  })
 }

 export function removeReceiveHook(id: string) {
-    const index = receiveHooks.findIndex(h => h.id === id)
-    receiveHooks.splice(index, 1);
+  const index = receiveHooks.findIndex(h => h.id === id)
+  receiveHooks.splice(index, 1);
 }

 let activatedGroups: string[] = [];

 async function updateGroups(_groups: Group[], needUpdate: boolean = true) {
-    for (let group of _groups) {
-        log("update group", group)
-        // if (!activatedGroups.includes(group.groupCode)) {
-        NTQQMsgApi.activateChat({peerUid: group.groupCode, chatType: ChatType.group}).then((r) => {
-            // activatedGroups.push(group.groupCode);
-            // log(`激活群聊天窗口${group.groupName}(${group.groupCode})`, r)
-            // if (r.result !== 0) {
-            //     setTimeout(() => NTQQMsgApi.activateGroupChat(group.groupCode).then(r => log(`再次激活群聊天窗口${group.groupName}(${group.groupCode})`, r)), 500);
-            // }else {
-            // }
-        }).catch(log)
-        // }
-        let existGroup = groups.find(g => g.groupCode == group.groupCode);
-        if (existGroup) {
-            Object.assign(existGroup, group);
-        } else {
-            groups.push(group);
-            existGroup = group;
-        }
-
-        if (needUpdate) {
-            const members = await NTQQGroupApi.getGroupMembers(group.groupCode);
-
-            if (members) {
-                existGroup.members = members;
-            }
-        }
+  for (let group of _groups) {
+    log("update group", group)
+    // if (!activatedGroups.includes(group.groupCode)) {
+    NTQQMsgApi.activateChat({peerUid: group.groupCode, chatType: ChatType.group}).then((r) => {
+      // activatedGroups.push(group.groupCode);
+      // log(`激活群聊天窗口${group.groupName}(${group.groupCode})`, r)
+      // if (r.result !== 0) {
+      //     setTimeout(() => NTQQMsgApi.activateGroupChat(group.groupCode).then(r => log(`再次激活群聊天窗口${group.groupName}(${group.groupCode})`, r)), 500);
+      // }else {
+      // }
+    }).catch(log)
+    // }
+    let existGroup = groups.find(g => g.groupCode == group.groupCode);
+    if (existGroup) {
+      Object.assign(existGroup, group);
+    } else {
+      groups.push(group);
+      existGroup = group;
    }
+
+    if (needUpdate) {
+      const members = await NTQQGroupApi.getGroupMembers(group.groupCode);
+
+      if (members) {
+        existGroup.members = members;
+      }
+    }
+  }
 }

 async function processGroupEvent(payload: { groupList: Group[] }) {
-    try {
-        const newGroupList = payload.groupList;
-        for (const group of newGroupList) {
-            let existGroup = groups.find(g => g.groupCode == group.groupCode);
-            if (existGroup) {
-                if (existGroup.memberCount > group.memberCount) {
-                    log(`群(${group.groupCode})成员数量减少${existGroup.memberCount} -> ${group.memberCount}`);
-                    const oldMembers = existGroup.members;
+  try {
+    const newGroupList = payload.groupList;
+    for (const group of newGroupList) {
+      let existGroup = groups.find(g => g.groupCode == group.groupCode);
+      if (existGroup) {
+        if (existGroup.memberCount > group.memberCount) {
+          log(`群(${group.groupCode})成员数量减少${existGroup.memberCount} -> ${group.memberCount}`);
+          const oldMembers = existGroup.members;

-                    await sleep(200);  // 如果请求QQ API的速度过快，通常无法正确拉取到最新的群信息，因此这里人为引入一个延时
-                    const newMembers = await NTQQGroupApi.getGroupMembers(group.groupCode);
+          await sleep(200);  // 如果请求QQ API的速度过快，通常无法正确拉取到最新的群信息，因此这里人为引入一个延时
+          const newMembers = await NTQQGroupApi.getGroupMembers(group.groupCode);

-                    group.members = newMembers;
-                    const newMembersSet = new Set<string>();  // 建立索引降低时间复杂度
+          group.members = newMembers;
+          const newMembersSet = new Set<string>();  // 建立索引降低时间复杂度

-                    for (const member of newMembers) {
-                        newMembersSet.add(member.uin);
-                    }
-
-                    // 判断bot是否是管理员，如果是管理员不需要从这里得知有人退群，这里的退群无法得知是主动退群还是被踢
-                    let bot = await getGroupMember(group.groupCode, selfInfo.uin)
-                    if (bot.role == GroupMemberRole.admin || bot.role == GroupMemberRole.owner) {
-                        continue
-                    }
-                    for (const member of oldMembers) {
-                        if (!newMembersSet.has(member.uin) && member.uin != selfInfo.uin) {
-                            postOB11Event(new OB11GroupDecreaseEvent(parseInt(group.groupCode), parseInt(member.uin), parseInt(member.uin), "leave"));
-                            break;
-                        }
-                    }
-                }
+          for (const member of newMembers) {
+            newMembersSet.add(member.uin);
+          }

+          // 判断bot是否是管理员，如果是管理员不需要从这里得知有人退群，这里的退群无法得知是主动退群还是被踢
+          let bot = await getGroupMember(group.groupCode, selfInfo.uin)
+          if (bot.role == GroupMemberRole.admin || bot.role == GroupMemberRole.owner) {
+            continue
+          }
+          for (const member of oldMembers) {
+            if (!newMembersSet.has(member.uin) && member.uin != selfInfo.uin) {
+              postOB11Event(new OB11GroupDecreaseEvent(parseInt(group.groupCode), parseInt(member.uin), parseInt(member.uin), "leave"));
+              break;
            }
+          }
        }

-        updateGroups(newGroupList, false).then();
-    } catch (e) {
-        updateGroups(payload.groupList).then();
-        log("更新群信息错误", e.stack.toString());
+      }
    }
+
+    updateGroups(newGroupList, false).then();
+  } catch (e) {
+    updateGroups(payload.groupList).then();
+    log("更新群信息错误", e.stack.toString());
+  }
 }

 // 群列表变动
 registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS, (payload) => {
-    // updateType 3是群列表变动，2是群成员变动
-    // log("群列表变动", payload.updateType, payload.groupList)
-    if (payload.updateType != 2) {
-        updateGroups(payload.groupList).then();
-    } else {
-        if (process.platform == "win32") {
-            processGroupEvent(payload).then();
-        }
+  // updateType 3是群列表变动，2是群成员变动
+  // log("群列表变动", payload.updateType, payload.groupList)
+  if (payload.updateType != 2) {
+    updateGroups(payload.groupList).then();
+  } else {
+    if (process.platform == "win32") {
+      processGroupEvent(payload).then();
    }
+  }
 })
 registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS_STORE, (payload) => {
-    // updateType 3是群列表变动，2是群成员变动
-    // log("群列表变动", payload.updateType, payload.groupList)
-    if (payload.updateType != 2) {
-        updateGroups(payload.groupList).then();
-    } else {
-        if (process.platform != "win32") {
-            processGroupEvent(payload).then();
-        }
+  // updateType 3是群列表变动，2是群成员变动
+  // log("群列表变动", payload.updateType, payload.groupList)
+  if (payload.updateType != 2) {
+    updateGroups(payload.groupList).then();
+  } else {
+    if (process.platform != "win32") {
+      processGroupEvent(payload).then();
    }
+  }
 })

 registerReceiveHook<{
-    groupCode: string,
-    dataSource: number,
-    members: Set<GroupMember>
+  groupCode: string,
+  dataSource: number,
+  members: Set<GroupMember>
 }>(ReceiveCmdS.GROUP_MEMBER_INFO_UPDATE, async (payload) => {
-    const groupCode = payload.groupCode;
-    const members = Array.from(payload.members.values());
-    // log("群成员信息变动", groupCode, members)
-    for (const member of members) {
-        const existMember = await getGroupMember(groupCode, member.uin);
-        if (existMember) {
-            Object.assign(existMember, member);
-        }
+  const groupCode = payload.groupCode;
+  const members = Array.from(payload.members.values());
+  // log("群成员信息变动", groupCode, members)
+  for (const member of members) {
+    const existMember = await getGroupMember(groupCode, member.uin);
+    if (existMember) {
+      Object.assign(existMember, member);
    }
-    // const existGroup = groups.find(g => g.groupCode == groupCode);
-    // if (existGroup) {
-    //     log("对比群成员", existGroup.members, members)
-    //     for (const member of members) {
-    //         const existMember = existGroup.members.find(m => m.uin == member.uin);
-    //         if (existMember) {
-    //             log("对比群名片", existMember.cardName, member.cardName)
-    //             if (existMember.cardName != member.cardName) {
-    //                 postOB11Event(new OB11GroupCardEvent(parseInt(existGroup.groupCode), parseInt(member.uin), member.cardName, existMember.cardName));
-    //             }
-    //             Object.assign(existMember, member);
-    //         }
-    //     }
-    // }
+  }
+  // const existGroup = groups.find(g => g.groupCode == groupCode);
+  // if (existGroup) {
+  //     log("对比群成员", existGroup.members, members)
+  //     for (const member of members) {
+  //         const existMember = existGroup.members.find(m => m.uin == member.uin);
+  //         if (existMember) {
+  //             log("对比群名片", existMember.cardName, member.cardName)
+  //             if (existMember.cardName != member.cardName) {
+  //                 postOB11Event(new OB11GroupCardEvent(parseInt(existGroup.groupCode), parseInt(member.uin), member.cardName, existMember.cardName));
+  //             }
+  //             Object.assign(existMember, member);
+  //         }
+  //     }
+  // }
 })

 // 好友列表变动
 registerReceiveHook<{
-    data: { categoryId: number, categroyName: string, categroyMbCount: number, buddyList: User[] }[]
+  data: { categoryId: number, categroyName: string, categroyMbCount: number, buddyList: User[] }[]
 }>(ReceiveCmdS.FRIENDS, payload => {
-    for (const fData of payload.data) {
-        const _friends = fData.buddyList;
-        for (let friend of _friends) {
-            NTQQMsgApi.activateChat({peerUid: friend.uid, chatType: ChatType.friend}).then()
-            let existFriend = friends.find(f => f.uin == friend.uin)
-            if (!existFriend) {
-                friends.push(friend)
-            } else {
-                Object.assign(existFriend, friend)
-            }
-        }
+  for (const fData of payload.data) {
+    const _friends = fData.buddyList;
+    for (let friend of _friends) {
+      NTQQMsgApi.activateChat({peerUid: friend.uid, chatType: ChatType.friend}).then()
+      let existFriend = friends.find(f => f.uin == friend.uin)
+      if (!existFriend) {
+        friends.push(friend)
+      } else {
+        Object.assign(existFriend, friend)
+      }
    }
+  }
 })

 registerReceiveHook<{ msgList: Array<RawMessage> }>([ReceiveCmdS.NEW_MSG, ReceiveCmdS.NEW_ACTIVE_MSG], (payload) => {
-    // 保存一下uid
-    for (const message of payload.msgList) {
-        const uid = message.senderUid;
-        const uin = message.senderUin;
-        if (uid && uin) {
-            if (message.chatType === ChatType.temp) {
-                dbUtil.getReceivedTempUinMap().then(receivedTempUinMap => {
-                    if (!receivedTempUinMap[uin]) {
-                        receivedTempUinMap[uin] = uid;
-                        dbUtil.setReceivedTempUinMap(receivedTempUinMap)
-                    }
-                })
-            }
-            uidMaps[uid] = uin;
+  // 保存一下uid
+  for (const message of payload.msgList) {
+    const uid = message.senderUid;
+    const uin = message.senderUin;
+    if (uid && uin) {
+      if (message.chatType === ChatType.temp) {
+        dbUtil.getReceivedTempUinMap().then(receivedTempUinMap => {
+          if (!receivedTempUinMap[uin]) {
+            receivedTempUinMap[uin] = uid;
+            dbUtil.setReceivedTempUinMap(receivedTempUinMap)
+          }
+        })
+      }
+      uidMaps[uid] = uin;
+    }
+  }
+
+
+  // 自动清理新消息文件
+  const {autoDeleteFile} = getConfigUtil().getConfig();
+  if (!autoDeleteFile) {
+    return
+  }
+  for (const message of payload.msgList) {
+    // log("收到新消息，push到历史记录", message.msgId)
+    // dbUtil.addMsg(message).then()
+    // 清理文件
+
+    for (const msgElement of message.elements) {
+      setTimeout(() => {
+        const picPath = msgElement.picElement?.sourcePath
+        const picThumbPath = [...msgElement.picElement?.thumbPath.values()]
+        const pttPath = msgElement.pttElement?.filePath
+        const filePath = msgElement.fileElement?.filePath
+        const videoPath = msgElement.videoElement?.filePath
+        const videoThumbPath: string[] = [...msgElement.videoElement?.thumbPath.values()]
+        const pathList = [picPath, ...picThumbPath, pttPath, filePath, videoPath, ...videoThumbPath]
+        if (msgElement.picElement) {
+          pathList.push(...Object.values(msgElement.picElement.thumbPath))
        }
-    }
-
-
-    // 自动清理新消息文件
-    const {autoDeleteFile} = getConfigUtil().getConfig();
-    if (!autoDeleteFile) {
-        return
-    }
-    for (const message of payload.msgList) {
-        // log("收到新消息，push到历史记录", message.msgId)
-        // dbUtil.addMsg(message).then()
-        // 清理文件
-
-        for (const msgElement of message.elements) {
-            setTimeout(() => {
-                const picPath = msgElement.picElement?.sourcePath
-                const picThumbPath = [...msgElement.picElement?.thumbPath.values()]
-                const pttPath = msgElement.pttElement?.filePath
-                const filePath = msgElement.fileElement?.filePath
-                const videoPath = msgElement.videoElement?.filePath
-                const videoThumbPath: string[] = [...msgElement.videoElement?.thumbPath.values()]
-                const pathList = [picPath, ...picThumbPath, pttPath, filePath, videoPath, ...videoThumbPath]
-                if (msgElement.picElement) {
-                    pathList.push(...Object.values(msgElement.picElement.thumbPath))
-                }
-                const aioOpGrayTipElement = msgElement.grayTipElement?.aioOpGrayTipElement
-                if (aioOpGrayTipElement) {
-                    tempGroupCodeMap[aioOpGrayTipElement.peerUid] = aioOpGrayTipElement.fromGrpCodeOfTmpChat;
-                }
-
-                // log("需要清理的文件", pathList);
-                for (const path of pathList) {
-                    if (path) {
-                        fs.unlink(picPath, () => {
-                            log("删除文件成功", path)
-                        });
-                    }
-                }
-            }, getConfigUtil().getConfig().autoDeleteFileSecond * 1000)
+        const aioOpGrayTipElement = msgElement.grayTipElement?.aioOpGrayTipElement
+        if (aioOpGrayTipElement) {
+          tempGroupCodeMap[aioOpGrayTipElement.peerUid] = aioOpGrayTipElement.fromGrpCodeOfTmpChat;
        }
+
+        // log("需要清理的文件", pathList);
+        for (const path of pathList) {
+          if (path) {
+            fs.unlink(picPath, () => {
+              log("删除文件成功", path)
+            });
+          }
+        }
+      }, getConfigUtil().getConfig().autoDeleteFileSecond * 1000)
    }
+  }
 })

 registerReceiveHook<{ msgRecord: RawMessage }>(ReceiveCmdS.SELF_SEND_MSG, ({msgRecord}) => {
-    const message = msgRecord;
-    const peerUid = message.peerUid;
-    // log("收到自己发送成功的消息", Object.keys(sendMessagePool), message);
-    // log("收到自己发送成功的消息", message.msgId, message.msgSeq);
-    dbUtil.addMsg(message).then()
-    const sendCallback = sendMessagePool[peerUid]
-    if (sendCallback) {
-        try {
-            sendCallback(message);
-        } catch (e) {
-            log("receive self msg error", e.stack)
-        }
+  const message = msgRecord;
+  const peerUid = message.peerUid;
+  // log("收到自己发送成功的消息", Object.keys(sendMessagePool), message);
+  // log("收到自己发送成功的消息", message.msgId, message.msgSeq);
+  dbUtil.addMsg(message).then()
+  const sendCallback = sendMessagePool[peerUid]
+  if (sendCallback) {
+    try {
+      sendCallback(message);
+    } catch (e) {
+      log("receive self msg error", e.stack)
    }
+  }
 })

 registerReceiveHook<{ info: { status: number } }>(ReceiveCmdS.SELF_STATUS, (info) => {
-    selfInfo.online = info.info.status !== 20
+  selfInfo.online = info.info.status !== 20
 })


 let activatedPeerUids: string[] = []
 registerReceiveHook<{
-    changedRecentContactLists: {
-        listType: number, sortedContactList: string[],
-        changedList: {
-            id: string,  // peerUid
-            chatType: ChatType
-        }[]
+  changedRecentContactLists: {
+    listType: number, sortedContactList: string[],
+    changedList: {
+      id: string,  // peerUid
+      chatType: ChatType
    }[]
+  }[]
 }>(ReceiveCmdS.RECENT_CONTACT, async (payload) => {
-    for (const recentContact of payload.changedRecentContactLists) {
-        for (const changedContact of recentContact.changedList) {
-            if (activatedPeerUids.includes(changedContact.id)) continue;
-            activatedPeerUids.push(changedContact.id)
-            const peer = {peerUid: changedContact.id, chatType: changedContact.chatType}
-            if (changedContact.chatType === ChatType.temp) {
-                log("收到临时会话消息", peer)
-                NTQQMsgApi.activateChatAndGetHistory(peer).then(
-                    () => {
-                        NTQQMsgApi.getMsgHistory(peer, "", 20).then(({msgList}) => {
-                            let lastTempMsg =  msgList.pop()
-                            log("激活窗口之前的第一条临时会话消息:", lastTempMsg)
-                            if ((Date.now() / 1000) - parseInt(lastTempMsg.msgTime) < 5) {
-                                OB11Constructor.message(lastTempMsg).then(r => postOB11Event(r))
-                            }
-                        })
-                    }
-                )
-            } else {
-                NTQQMsgApi.activateChat(peer).then()
-            }
-        }
+  for (const recentContact of payload.changedRecentContactLists) {
+    for (const changedContact of recentContact.changedList) {
+      if (activatedPeerUids.includes(changedContact.id)) continue;
+      activatedPeerUids.push(changedContact.id)
+      const peer = {peerUid: changedContact.id, chatType: changedContact.chatType}
+      if (changedContact.chatType === ChatType.temp) {
+        log("收到临时会话消息", peer)
+        NTQQMsgApi.activateChatAndGetHistory(peer).then(
+          () => {
+            NTQQMsgApi.getMsgHistory(peer, "", 20).then(({msgList}) => {
+              let lastTempMsg = msgList.pop()
+              log("激活窗口之前的第一条临时会话消息:", lastTempMsg)
+              if ((Date.now() / 1000) - parseInt(lastTempMsg.msgTime) < 5) {
+                OB11Constructor.message(lastTempMsg).then(r => postOB11Event(r))
+              }
+            })
+          }
+        )
+      } else {
+        NTQQMsgApi.activateChat(peer).then()
+      }
    }
+  }
+})
+
+registerCallHook(NTQQApiMethod.DELETE_ACTIVE_CHAT, async (payload) => {
+  const peerUid = payload[0] as string;
+  log("激活的聊天窗口被删除，准备重新激活", peerUid);
+  let chatType = ChatType.friend;
+  if (isNumeric(peerUid)) {
+    chatType = ChatType.group;
+  }
+  else{
+    // 检查是否好友
+    if (!(await getFriend(peerUid))){
+      chatType = ChatType.temp;
+    }
+  }
+  const peer = {peerUid, chatType}
+  await sleep(1000);
+  NTQQMsgApi.activateChat(peer).then((r) => {
+    log("重新激活聊天窗口", peer, {result: r.result, errMsg: r.errMsg})
+  });
 })
--- a/src/ntqqapi/ntcall.ts
+++ b/src/ntqqapi/ntcall.ts
@@ -26,6 +26,7 @@ export enum NTQQApiMethod {
    ACTIVE_CHAT_HISTORY = "nodeIKernelMsgService/getMsgsIncludeSelfAndAddActiveChat", // 激活聊天窗口，有时候必须这样才能收到消息, 并返回历史消息
    HISTORY_MSG = "nodeIKernelMsgService/getMsgsIncludeSelf",
    GET_MULTI_MSG = "nodeIKernelMsgService/getMultiMsg",
+    DELETE_ACTIVE_CHAT = "nodeIKernelMsgService/deleteActiveChatByUid",

    LIKE_FRIEND = "nodeIKernelProfileLikeService/setBuddyProfileLike",
    SELF_INFO = "fetchAuthData",
--- a/src/ntqqapi/types/msg.ts
+++ b/src/ntqqapi/types/msg.ts
@@ -212,9 +212,28 @@ export interface GrayTipElement {
    }
 }

+export enum FaceType {
+    normal=1, // 小黄脸
+    normal2=2, // 新小黄脸, 从faceIndex 222开始？
+    dice=3  // 骰子
+}
+
+export enum FaceIndex {
+    dice = 358,
+    RPS = 359  // 石头剪刀布
+}
+
 export interface FaceElement {
    faceIndex: number,
-    faceType: 1
+    faceType: FaceType,
+    faceText?: string,
+    packId?: string,
+    stickerId?: string,
+    sourceType?: number,
+    stickerType?: number,
+    resultId?: string,
+    surpriseId?: string,
+    randomType?: number
 }

 export interface MarketFaceElement {
--- a/src/onebot11/action/msg/SendMsg.ts
+++ b/src/onebot11/action/msg/SendMsg.ts
@@ -224,6 +224,14 @@ export async function createSendElements(messageData: OB11MessageData[], target:
                }
            }
                break;
+            case OB11MessageDataType.dice:{
+                const resultId = sendMsg.data?.result
+                sendElements.push(SendMsgElementConstructor.dice(resultId));
+            }break;
+            case OB11MessageDataType.RPS:{
+                const resultId = sendMsg.data?.result
+                sendElements.push(SendMsgElementConstructor.rps(resultId));
+            }break;
        }

    }
--- a/src/onebot11/constructor.ts
+++ b/src/onebot11/constructor.ts
@@ -10,7 +10,7 @@ import {
 } from "./types";
 import {
    AtType,
-    ChatType,
+    ChatType, FaceIndex,
    GrayTipElementSubType,
    Group,
    GroupMember,
@@ -227,8 +227,19 @@ export class OB11Constructor {
                message_data["type"] = OB11MessageDataType.json;
                message_data["data"]["data"] = element.arkElement.bytesData;
            } else if (element.faceElement) {
-                message_data["type"] = OB11MessageDataType.face;
-                message_data["data"]["id"] = element.faceElement.faceIndex.toString();
+                const faceId = element.faceElement.faceIndex;
+                if (faceId === FaceIndex.dice){
+                    message_data["type"] = OB11MessageDataType.dice
+                    message_data["data"]["result"] = element.faceElement.resultId;
+                }
+                else if (faceId === FaceIndex.RPS){
+                    message_data["type"] = OB11MessageDataType.RPS
+                    message_data["data"]["result"] = element.faceElement.resultId;
+                }
+                else{
+                    message_data["type"] = OB11MessageDataType.face;
+                    message_data["data"]["id"] = element.faceElement.faceIndex.toString();
+                }
            } else if (element.marketFaceElement) {
                message_data["type"] = OB11MessageDataType.mface;
                message_data["data"]["text"] = element.marketFaceElement.faceName;
--- a/src/onebot11/server/postOB11Event.ts
+++ b/src/onebot11/server/postOB11Event.ts
@@ -1,5 +1,5 @@
 import {OB11Message, OB11MessageAt, OB11MessageData} from "../types";
-import {getGroup, selfInfo} from "../../common/data";
+import {getFriend, getGroup, getUidByUin, selfInfo} from "../../common/data";
 import {OB11BaseMetaEvent} from "../event/meta/OB11BaseMetaEvent";
 import {OB11BaseNoticeEvent} from "../event/notice/OB11BaseNoticeEvent";
 import {WebSocket as WebSocketClass} from "ws";
@@ -63,7 +63,6 @@ export function unregisterWsEventSender(ws: WebSocketClass) {

 export function postWsEvent(event: PostEventType) {
    for (const ws of eventWSList) {
-        log(ws)
        new Promise(() => {
            wsReply(ws, event);
        }).then()
@@ -116,6 +115,7 @@ export function postOB11Event(msg: PostEventType, reportSelf = false) {
                        peerUid: msg.user_id.toString()
                    }
                    if (msg.message_type == "private") {
+                        peer.peerUid = getUidByUin(msg.user_id.toString())
                        if (msg.sub_type === "group") {
                            peer.chatType = ChatType.temp
                        }
@@ -140,6 +140,7 @@ export function postOB11Event(msg: PostEventType, reportSelf = false) {
                        }
                        replyMessage = replyMessage.concat(convertMessage2List(reply, resJson.auto_escape))
                        const {sendElements, deleteAfterSentFiles} = await createSendElements(replyMessage, group)
+                        log(`发送消息给`, peer, sendElements)
                        sendMsg(peer, sendElements, deleteAfterSentFiles, false).then()
                    } else if (resJson.delete) {
                        NTQQMsgApi.recallMsg(peer, [rawMessage.msgId]).then()
--- a/src/onebot11/types.ts
+++ b/src/onebot11/types.ts
@@ -117,7 +117,9 @@ export enum OB11MessageDataType {
    node = "node",  // 合并转发消息节点
    forward = "forward",  // 合并转发消息，用于上报
    xml = "xml",
-    poke = "poke"
+    poke = "poke",
+    dice = "dice",
+    RPS = "rps"
 }

 export interface OB11MessageMFace{
@@ -126,6 +128,20 @@ export interface OB11MessageMFace{
        text: string
    }
 }
+
+export interface OB11MessageDice{
+    type: OB11MessageDataType.dice,
+    data: {
+        result: number
+    }
+}
+export interface OB11MessageRPS{
+    type: OB11MessageDataType.RPS,
+    data: {
+        result: number
+    }
+}
+
 export interface OB11MessageText {
    type: OB11MessageDataType.text,
    data: {
@@ -226,7 +242,8 @@ export type OB11MessageData =
    OB11MessageFace | OB11MessageMFace |
    OB11MessageAt | OB11MessageReply |
    OB11MessageImage | OB11MessageRecord | OB11MessageFile | OB11MessageVideo |
-    OB11MessageNode | OB11MessageCustomMusic | OB11MessageJson | OB11MessagePoke
+    OB11MessageNode | OB11MessageCustomMusic | OB11MessageJson | OB11MessagePoke |
+    OB11MessageDice | OB11MessageRPS

 export interface OB11PostSendMsg {
    message_type?: "private" | "group"
--- a/src/version.ts
+++ b/src/version.ts
@@ -1 +1 @@
-export const version = "3.21.0"
+export const version = "3.22.1"
Author	SHA1	Message	Date
linyuchen	f8890b309b	fix: face msg faceType	2024-04-11 18:57:58 +08:00
linyuchen	b5e578733f	fix: quick reply friend msg	2024-04-11 18:17:02 +08:00
linyuchen	51602b987e	fix: ws 没有上报群文件上传事件	2024-04-08 00:21:24 +08:00
linyuchen	b501af6e0e	feat: 骰子魔法表情 & 猜拳魔法表情	2024-04-07 18:51:26 +08:00
linyuchen	81821e74d8	fix: 手动频繁切换聊天窗口时导致旧的窗口接收不到消息	2024-04-07 17:37:52 +08:00