release: 2.2.26

build(deps-dev): bump eslint from 8.57.0 to 9.9.1

manifest.json

@@ -4,7 +4,7 @@
   "name": "NapCatQQ",
   "slug": "NapCat.Framework",
   "description": "高性能的 OneBot 11 协议实现",
-  "version": "2.2.21",
+  "version": "2.2.26",
   "icon": "./logo.png",
   "authors": [
     {

package.json

@@ -2,7 +2,7 @@
   "name": "napcat",
   "private": true,
   "type": "module",
-  "version": "2.2.21",
+  "version": "2.2.26",
   "scripts": {
     "build:framework": "vite build --mode framework",
     "build:shell": "vite build --mode shell",

src/common/helper.ts

@@ -1,7 +1,7 @@
 import path from 'node:path';
 import fs from 'fs';
 import os from 'node:os';
-import { QQLevel } from '@/core';
+import { Peer, QQLevel } from '@/core';
 
 export async function solveProblem<T extends (...arg: any[]) => any>(func: T, ...args: Parameters<T>): Promise<ReturnType<T> | undefined> {
     return new Promise<ReturnType<T> | undefined>((resolve) => {
@@ -23,29 +23,48 @@ export async function solveAsyncProblem<T extends (...args: any[]) => Promise<an
         });
     });
 }
-
+export class FileNapCatOneBotUUID {
-//下面这个类是用于将uid+msgid合并的类
+    static encodeModelId(peer: Peer, modelId: string): string {
-export class UUIDConverter {
+        return `NapCatOneBot-ModeldFile-${peer.chatType}-${peer.peerUid}-${modelId}`;
-    static encode(highStr: string, lowStr: string): string {
-        const high = BigInt(highStr);
-        const low = BigInt(lowStr);
-        const highHex = high.toString(16).padStart(16, '0');
-        const lowHex = low.toString(16).padStart(16, '0');
-        const combinedHex = highHex + lowHex;
-        return `${combinedHex.substring(0, 8)}-${combinedHex.substring(8, 12)}-${combinedHex.substring(
-            12,
-            16,
-        )}-${combinedHex.substring(16, 20)}-${combinedHex.substring(20)}`;
     }
-
+    static decodeModelId(uuid: string): undefined | {
-    static decode(uuid: string): { high: string; low: string } {
+        peer: Peer,
-        const hex = uuid.replace(/-/g, '');
+        modelId: string
-        const high = BigInt('0x' + hex.substring(0, 16));
+    } {
-        const low = BigInt('0x' + hex.substring(16));
+        if (!uuid.startsWith('NapCatOneBot-ModeldFile-')) return undefined;
-        return { high: high.toString(), low: low.toString() };
+        const data = uuid.split('-');
+        if (data.length !== 5) return undefined;
+        const [, , chatType, peerUid, modelId] = data;
+        return {
+            peer: {
+                chatType: chatType as any,
+                peerUid: peerUid
+            },
+            modelId,
+        };
+    }
+    static encode(peer: Peer, msgId: string, elementId: string): string {
+        return `NapCatOneBot-MsgFile-${peer.chatType}-${peer.peerUid}-${msgId}-${elementId}`;
+    }
+    static decode(uuid: string): undefined | {
+        peer: Peer,
+        msgId: string,
+        elementId: string
+    } {
+        if (!uuid.startsWith('NapCatOneBot-MsgFile-')) return undefined;
+        const data = uuid.split('-');
+        if (data.length !== 6) return undefined;
+        const [, , chatType, peerUid, msgId, elementId] = data;
+        return {
+            peer: {
+                chatType: chatType as any,
+                peerUid: peerUid
+            },
+            msgId,
+            elementId,
+        };
     }
 }
-
 export function sleep(ms: number): Promise<void> {
     return new Promise((resolve) => setTimeout(resolve, ms));
 }

src/common/version.ts

@@ -1 +1 @@
-export const napCatVersion = '2.2.21';
+export const napCatVersion = '2.2.26';

src/core/apis/file.ts

@@ -17,7 +17,7 @@ import {
 import path from 'path';
 import fs from 'fs';
 import fsPromises from 'fs/promises';
-import { InstanceContext, NapCatCore } from '@/core';
+import { InstanceContext, NapCatCore, SearchResultItem } from '@/core';
 import * as fileType from 'file-type';
 import imageSize from 'image-size';
 import { ISizeCalculationResult } from 'image-size/dist/types/interface';
@@ -302,7 +302,18 @@ export class NTQQFileApi {
     async downloadMediaByUuid() {
         //napCatCore.session.getRichMediaService().downloadFileForFileUuid();
     }
-
+    async downloadFileForModelId(peer: Peer, modelId: string, timeout = 1000 * 60 * 2) {
+        const [, fileTransNotifyInfo] = await this.core.eventWrapper.callNormalEventV2(
+            'NodeIKernelRichMediaService/downloadFileForModelId',
+            'NodeIKernelMsgListener/onRichMediaDownloadComplete',
+            [peer, [modelId]],
+            () => true,
+            (arg) => arg?.commonFileInfo?.fileModelId === modelId,
+            1,
+            timeout,
+        );
+        return fileTransNotifyInfo.filePath;
+    }
     async downloadMedia(msgId: string, chatType: ChatType, peerUid: string, elementId: string, thumbPath: string, sourcePath: string, timeout = 1000 * 60 * 2, force: boolean = false) {
         //logDebug('receive downloadMedia task', msgId, chatType, peerUid, elementId, thumbPath, sourcePath, timeout, force);
         // 用于下载收到的消息中的图片等
@@ -342,20 +353,15 @@ export class NTQQFileApi {
             chatType: chatType,
             peerUid: peerUid,
         }, [msgId]);
-        if (msg.msgList.length === 0) {
+        const mixElement = msg.msgList.find((msg) => msg.msgId === msgId)?.elements.find((e) => e.elementId === elementId);
-            return fileTransNotifyInfo.filePath;
+        const mixElementInner = mixElement?.videoElement ?? mixElement?.fileElement ?? mixElement?.pttElement ?? mixElement?.picElement;
+        let realPath = mixElementInner?.filePath;
+        if (!realPath) {
+            const picThumbPath: Map<number, string> = (mixElementInner as any)?.picThumbPath;
+            const picThumbPathList = Array.from(picThumbPath.values());
+            if (picThumbPathList.length > 0) realPath = picThumbPathList[0];
         }
-        //获取原始消息
+        return realPath;
-        const FileElements = msg?.msgList[0]?.elements?.find(e => e.elementId === elementId);
-        if (!FileElements) {
-            //失败则就乱来 Todo
-            return fileTransNotifyInfo.filePath;
-        }
-        //从原始消息获取文件路径
-        return FileElements?.fileElement?.filePath ??
-            FileElements?.pttElement?.filePath ??
-            FileElements?.videoElement?.filePath ??
-            FileElements?.picElement?.sourcePath;
     }
 
     async getImageSize(filePath: string): Promise<ISizeCalculationResult | undefined> {
@@ -429,17 +435,36 @@ export class NTQQFileApi {
         });
     }
 
-    async searchfile(keys: string[]) {
+    async searchForFile(keys: string[]): Promise<SearchResultItem | undefined> {
-        const Event = this.core.eventWrapper.createEventFunction('NodeIKernelSearchService/searchFileWithKeywords');
+        const [, searchResult] = await this.core.eventWrapper.callNormalEventV2(
-        const id = await Event!(keys, 12);
+            'NodeIKernelFileAssistantService/searchFile',
-        const Listener = this.core.eventWrapper.registerListen(
+            'NodeIKernelFileAssistantListener/onFileSearch',
-            'NodeIKernelSearchListener/onSearchFileKeywordsResult',
+            [
-            1,
+                keys,
-            20000,
+                {
-            (params) => id !== '' && params.searchId == id,
+                    resultType: 2,
+                    pageLimit: 1,
+                }
+            ]
         );
-        const [ret] = (await Listener);
+        return searchResult.resultItems[0];
-        return ret;
+    }
+
+    async downloadFileById(
+        fileId: string,
+        fileSize: number = 1024576,
+        estimatedTime: number = (fileSize * 1000 / 1024576) + 5000,
+    ) {
+        const [, ret] = await this.core.eventWrapper.callNormalEventV2(
+            'NodeIKernelFileAssistantService/downloadFile',
+            'NodeIKernelFileAssistantListener/onFileStatusChanged',
+            [[fileId]],
+            ret => ret.result === 0,
+            status => status.fileStatus === 2 && status.fileProgress === '0',
+            1,
+            estimatedTime, // estimate 1MB/s
+        );
+        return ret.filePath!;
     }
 
     async getImageUrl(element: PicElement) {

src/core/apis/group.ts

@@ -309,12 +309,12 @@ export class NTQQGroupApi {
         return this.context.session.getGroupService().removeGroupEssence(param);
     }
 
-    async getSingleScreenNotifies(num: number) {
+    async getSingleScreenNotifies(doubt: boolean, num: number) {
         const [, , , notifies] = await this.core.eventWrapper.callNormalEventV2(
             'NodeIKernelGroupService/getSingleScreenNotifies',
             'NodeIKernelGroupListener/onGroupSingleScreenNotifies',
             [
-                false,
+                doubt,
                 '',
                 num,
             ],

src/core/apis/webapi.ts

@@ -34,11 +34,26 @@ export class NTQQWebApi {
             return undefined;
         }
     }
+    async getGroupEssenceMsgAll(GroupCode: string) {
+        let ret: GroupEssenceMsgRet[] = [];
+        for (let i = 0; i < 4; i++) {
+            let data = await this.getGroupEssenceMsg(GroupCode, i, 50);
+            if (!data) break;
+            if (data.data.is_end) {
+                ret.push(data);
+                break;
+            }
+            ret.push(data);
 
-    async getGroupEssenceMsg(GroupCode: string) {
+        }
+        return ret;
+    }
+    async getGroupEssenceMsg(GroupCode: string, page_start: number = 0, page_limit: number = 50) {
         const cookieObject = await this.core.apis.UserApi.getCookies('qun.qq.com');
         const url = `https://qun.qq.com/cgi-bin/group_digest/digest_list?${new URLSearchParams({
             bkn: this.getBknFromCookie(cookieObject),
+            page_start: page_start.toString(),
+            page_limit: page_limit.toString(),
             group_code: GroupCode,
         }).toString()
             }`;

src/core/entities/msg.ts

@@ -593,6 +593,7 @@ export const IMAGE_HTTP_HOST_NT = 'https://multimedia.nt.qq.com.cn';
 
 export interface PicElement {
     md5HexStr?: string;
+    filePath?: string;
     fileSize: number | string;//number
     picWidth: number;
     picHeight: number;

src/core/listeners/NodeIKernelFileAssistantListener.ts

@@ -1,5 +1,13 @@
 export class NodeIKernelFileAssistantListener {
-    onFileStatusChanged(...args: unknown[]) {
+    onFileStatusChanged(fileStatus: {
+        id: string,
+        fileStatus: number,
+        fileProgress: `${number}`,
+        fileSize: `${number}`,
+        fileSpeed: number,
+        thumbPath: string | null,
+        filePath: string | null,
+    }) {
     }
 
     onSessionListChanged(...args: unknown[]) {
@@ -11,6 +19,42 @@ export class NodeIKernelFileAssistantListener {
     onFileListChanged(...args: unknown[]) {
     }
 
-    onFileSearch(...args: unknown[]) {
+    onFileSearch(searchResult: SearchResultWrapper) {
     }
 }
+
+export type SearchResultWrapper = {
+    searchId: number,
+    resultType: number,
+    hasMore: boolean,
+    resultItems: SearchResultItem[],
+};
+
+export type SearchResultItem = {
+    id: string,
+    fileName: string,
+    fileNameHits: string[],
+    fileStatus: number,
+    fileSize: string,
+    isSend: boolean,
+    source: number,
+    fileTime: string,
+    expTime: string,
+    session: {
+        context: null,
+        uid: string,
+        nick: string,
+        remark: string,
+        memberCard: string,
+        groupCode: string,
+        groupName: string,
+        groupRemark: string,
+        count: number,
+    },
+    thumbPath: string,
+    filePath: string,
+    msgId: string,
+    chatType: number,
+    peerUid: string,
+    fileType: number,
+};

src/core/listeners/NodeIKernelMsgListener.ts

@@ -1,4 +1,5 @@
 import { ChatType, RawMessage } from '@/core/entities';
+import { CommonFileInfo } from '@/core';
 
 export interface OnRichMediaDownloadCompleteParams {
     fileModelId: string,
@@ -15,7 +16,7 @@ export interface OnRichMediaDownloadCompleteParams {
     totalSize: string,
     trasferStatus: number,
     step: number,
-    commonFileInfo: unknown | null,
+    commonFileInfo?: CommonFileInfo,
     fileSrvErrCode: string,
     clientMsg: string,
     businessId: number,

src/core/proto/EmojiLikeToOthers.proto

@@ -19,6 +19,13 @@ message EmojiLikeToOthersMsgSpec {
 }
 
 message EmojiLikeToOthersAttributes {
+  enum Operation {
+    FALLBACK = 0;
+    LIKE = 1;
+    UNLIKE = 2;
+  }
+
   string emojiId = 1;
   string senderUid = 4;
+  Operation operation = 5;
 }

src/core/proto/EmojiLikeToOthers.ts

@@ -62,6 +62,27 @@ export interface EmojiLikeToOthersAttributes {
      * @generated from protobuf field: string senderUid = 4;
      */
     senderUid: string;
+    /**
+     * @generated from protobuf field: SysMessage.EmojiLikeToOthersAttributes.Operation operation = 5;
+     */
+    operation: EmojiLikeToOthersAttributes_Operation;
+}
+/**
+ * @generated from protobuf enum SysMessage.EmojiLikeToOthersAttributes.Operation
+ */
+export enum EmojiLikeToOthersAttributes_Operation {
+    /**
+     * @generated from protobuf enum value: FALLBACK = 0;
+     */
+    FALLBACK = 0,
+    /**
+     * @generated from protobuf enum value: LIKE = 1;
+     */
+    LIKE = 1,
+    /**
+     * @generated from protobuf enum value: UNLIKE = 2;
+     */
+    UNLIKE = 2
 }
 // @generated message type with reflection information, may provide speed optimized methods
 class EmojiLikeToOthersWrapper1$Type extends MessageType<EmojiLikeToOthersWrapper1> {
@@ -260,13 +281,15 @@ class EmojiLikeToOthersAttributes$Type extends MessageType<EmojiLikeToOthersAttr
     constructor() {
         super("SysMessage.EmojiLikeToOthersAttributes", [
             { no: 1, name: "emojiId", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
-            { no: 4, name: "senderUid", kind: "scalar", T: 9 /*ScalarType.STRING*/ }
+            { no: 4, name: "senderUid", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
+            { no: 5, name: "operation", kind: "enum", T: () => ["SysMessage.EmojiLikeToOthersAttributes.Operation", EmojiLikeToOthersAttributes_Operation] }
         ]);
     }
     create(value?: PartialMessage<EmojiLikeToOthersAttributes>): EmojiLikeToOthersAttributes {
         const message = globalThis.Object.create((this.messagePrototype!));
         message.emojiId = "";
         message.senderUid = "";
+        message.operation = 0;
         if (value !== undefined)
             reflectionMergePartial<EmojiLikeToOthersAttributes>(this, message, value);
         return message;
@@ -282,6 +305,9 @@ class EmojiLikeToOthersAttributes$Type extends MessageType<EmojiLikeToOthersAttr
                 case /* string senderUid */ 4:
                     message.senderUid = reader.string();
                     break;
+                case /* SysMessage.EmojiLikeToOthersAttributes.Operation operation */ 5:
+                    message.operation = reader.int32();
+                    break;
                 default:
                     let u = options.readUnknownField;
                     if (u === "throw")
@@ -300,6 +326,9 @@ class EmojiLikeToOthersAttributes$Type extends MessageType<EmojiLikeToOthersAttr
         /* string senderUid = 4; */
         if (message.senderUid !== "")
             writer.tag(4, WireType.LengthDelimited).string(message.senderUid);
+        /* SysMessage.EmojiLikeToOthersAttributes.Operation operation = 5; */
+        if (message.operation !== 0)
+            writer.tag(5, WireType.Varint).int32(message.operation);
         let u = options.writeUnknownFields;
         if (u !== false)
             (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);

src/core/services/NodeIKernelFileAssistantService.ts

@@ -1,5 +1,7 @@
+import { NodeIKernelFileAssistantListener } from '@/core';
+
 export interface NodeIKernelFileAssistantService {
-    addKernelFileAssistantListener(arg1: unknown[]): unknown;
+    addKernelFileAssistantListener(listener: NodeIKernelFileAssistantListener): unknown;
 
     removeKernelFileAssistantListener(arg1: unknown[]): unknown;
 
@@ -9,7 +11,7 @@ export interface NodeIKernelFileAssistantService {
 
     getFileSessionList(): unknown;
 
-    searchFile(arg1: unknown, arg2: unknown, arg3: unknown): unknown;
+    searchFile(keywords: string[], params: { resultType: number, pageLimit: number }): unknown;
 
     resetSearchFileSortType(arg1: unknown, arg2: unknown, arg3: unknown): unknown;
 
@@ -17,7 +19,7 @@ export interface NodeIKernelFileAssistantService {
 
     cancelSearchFile(arg1: unknown, arg2: unknown, arg3: unknown): unknown;
 
-    downloadFile(arg1: unknown[]): unknown;
+    downloadFile(fileIds: string[]): { result: number, errMsg: string };
 
     forwardFile(arg1: unknown, arg2: unknown, arg3: unknown): unknown;
 

src/core/services/NodeIKernelGroupService.ts

@@ -182,8 +182,7 @@ export interface NodeIKernelGroupService {
 
     destroyGroup(groupCode: string): void;
 
-    //获取单屏群通知列表
+    getSingleScreenNotifies(doubted: boolean, start_seq: string, num: number): Promise<GeneralCallResult>;
-    getSingleScreenNotifies(force: boolean, start_seq: string, num: number): Promise<GeneralCallResult>;
 
     clearGroupNotifies(groupCode: string): void;
 

src/core/services/NodeIKernelRichMediaService.ts

@@ -155,7 +155,7 @@ export interface NodeIKernelRichMediaService {
     }): unknown;
 
     //arg3为“”
-    downloadFileForModelId(peer: Peer, ModelId: string[], arg3: string): unknown;
+    downloadFileForModelId(peer: Peer, ModelId: string[]): Promise<unknown>;
 
     //第三个参数 Array<Type>
     // this.fileId = "";

src/onebot/action/file/GetFile.ts

@@ -1,8 +1,8 @@
 import BaseAction from '../BaseAction';
 import fs from 'fs/promises';
-import { UUIDConverter } from '@/common/helper';
+import { FileNapCatOneBotUUID } from '@/common/helper';
 import { ActionName } from '../types';
-import { ChatType, ElementType, Peer, RawMessage } from '@/core/entities';
+import { ChatType, Peer, RawMessage } from '@/core/entities';
 import { FromSchema, JSONSchema } from 'json-schema-to-ts';
 
 export interface GetFilePayload {
@@ -29,100 +29,80 @@ export class GetFileBase extends BaseAction<GetFilePayload, GetFileResponse> {
     payloadSchema: any = GetFileBase_PayloadSchema;
 
     async _handle(payload: GetFilePayload): Promise<GetFileResponse> {
-        const NTQQFriendApi = this.core.apis.FriendApi;
-        const NTQQUserApi = this.core.apis.UserApi;
         const NTQQMsgApi = this.core.apis.MsgApi;
-        const NTQQGroupApi = this.core.apis.GroupApi;
         const NTQQFileApi = this.core.apis.FileApi;
-        try {
+
-            const uuidData = UUIDConverter.decode(payload.file);
+        const contextMsgFile = FileNapCatOneBotUUID.decode(payload.file);
-            const peerUin = uuidData.high;
+        //接收消息标记模式
-            const msgId = uuidData.low;
+        if (contextMsgFile) {
-            const isGroup: boolean = !!(await NTQQGroupApi.getGroups(false)).find(e => e.groupCode == peerUin);
+            const { peer, msgId, elementId } = contextMsgFile;
-            let peer: Peer | undefined;
+            const downloadPath = await NTQQFileApi.downloadMedia(msgId, peer.chatType, peer.peerUid, elementId, '', '');
-            //识别Peer
+            const mixElement = (await NTQQMsgApi.getMsgsByMsgId(peer, [msgId]))?.msgList
-            if (isGroup) {
+                .find(msg => msg.msgId === msgId)?.elements.find(e => e.elementId === elementId);
-                peer = { chatType: ChatType.KCHATTYPEGROUP, peerUid: peerUin };
+            const mixElementInner = mixElement?.videoElement ?? mixElement?.fileElement ?? mixElement?.pttElement ?? mixElement?.picElement;
-            }
+            if (!mixElementInner) throw new Error('element not found');
-            const PeerUid = await NTQQUserApi.getUidByUinV2(peerUin);
+            const fileSize = mixElementInner.fileSize?.toString() ?? '';
-            if (PeerUid) {
+            const fileName = mixElementInner.fileName ?? '';
-                const isBuddy = await NTQQFriendApi.isBuddy(PeerUid);
+
-                if (isBuddy) {
-                    peer = { chatType: ChatType.KCHATTYPEC2C, peerUid: PeerUid };
-                } else {
-                    peer = { chatType: ChatType.KCHATTYPETEMPC2CFROMGROUP, peerUid: PeerUid };
-                }
-            }
-            if (!peer) {
-                throw new Error('chattype not support');
-            }
-            const msgList = await NTQQMsgApi.getMsgsByMsgId(peer, [msgId]);
-            if (msgList.msgList.length == 0) {
-                throw new Error('msg not found');
-            }
-            const msg = msgList.msgList[0];
-            const findEle = msg.elements.find(e => e.elementType == ElementType.VIDEO || e.elementType == ElementType.FILE || e.elementType == ElementType.PTT);
-            if (!findEle) {
-                throw new Error('element not found');
-            }
-            const downloadPath = await NTQQFileApi.downloadMedia(msgId, msg.chatType, msg.peerUid, findEle.elementId, '', '');
-            const fileSize = findEle?.videoElement?.fileSize || findEle?.fileElement?.fileSize || findEle?.pttElement?.fileSize || '0';
-            const fileName = findEle?.videoElement?.fileName || findEle?.fileElement?.fileName || findEle?.pttElement?.fileName || '';
             const res: GetFileResponse = {
                 file: downloadPath,
                 url: downloadPath,
                 file_size: fileSize,
                 file_name: fileName,
             };
-            if (/* enableLocalFile2Url && */ downloadPath) {
+
+            if (this.obContext.configLoader.configData.enableLocalFile2Url && downloadPath) {
                 try {
                     res.base64 = await fs.readFile(downloadPath, 'base64');
                 } catch (e) {
                     throw new Error('文件下载失败. ' + e);
                 }
             }
-            //不手动删除？文件持久化了
             return res;
-        } catch {
-            this.core.context.logger.logDebug('GetFileBase Mode - 1 Error');
         }
 
-        const NTSearchNameResult = (await NTQQFileApi.searchfile([payload.file])).resultItems;
+        //群文件模式
-        if (NTSearchNameResult.length !== 0) {
+        const contextModelIdFile = FileNapCatOneBotUUID.decodeModelId(payload.file);
-            const MsgId = NTSearchNameResult[0].msgId;
+        if (contextModelIdFile) {
-            let peer: Peer | undefined = undefined;
+            const { peer, modelId } = contextModelIdFile;
-            if (NTSearchNameResult[0].chatType == ChatType.KCHATTYPEGROUP) {
+            const downloadPath = await NTQQFileApi.downloadFileForModelId(peer, modelId);
-                peer = { chatType: ChatType.KCHATTYPEGROUP, peerUid: NTSearchNameResult[0].groupChatInfo[0].groupCode };
-            }
-            if (!peer) {
-                throw new Error('chattype not support');
-            }
-            const msgList: RawMessage[] = (await NTQQMsgApi.getMsgsByMsgId(peer, [MsgId]))?.msgList;
-            if (!msgList || msgList.length == 0) {
-                throw new Error('msg not found');
-            }
-            const msg = msgList[0];
-            const file = msg.elements.filter(e => e.elementType == NTSearchNameResult[0].elemType);
-            if (file.length == 0) {
-                throw new Error('file not found');
-            }
-            const downloadPath = await NTQQFileApi.downloadMedia(msg.msgId, msg.chatType, msg.peerUid, file[0].elementId, '', '');
             const res: GetFileResponse = {
                 file: downloadPath,
                 url: downloadPath,
-                file_size: NTSearchNameResult[0].fileSize.toString(),
+                file_size: '',
-                file_name: NTSearchNameResult[0].fileName,
+                file_name: '',
             };
-            if (/* enableLocalFile2Url && */ downloadPath) {
+
+            if (this.obContext.configLoader.configData.enableLocalFile2Url && downloadPath) {
                 try {
                     res.base64 = await fs.readFile(downloadPath, 'base64');
                 } catch (e) {
                     throw new Error('文件下载失败. ' + e);
                 }
             }
-            //不手动删除？文件持久化了
             return res;
         }
+
+        //搜索名字模式
+        const searchResult = (await NTQQFileApi.searchForFile([payload.file]));
+        if (searchResult) {
+            const downloadPath = await NTQQFileApi.downloadFileById(searchResult.id, parseInt(searchResult.fileSize));
+            const res: GetFileResponse = {
+                file: downloadPath,
+                url: downloadPath,
+                file_size: searchResult.fileSize.toString(),
+                file_name: searchResult.fileName,
+            };
+            if (this.obContext.configLoader.configData.enableLocalFile2Url && downloadPath) {
+                try {
+                    res.base64 = await fs.readFile(downloadPath, 'base64');
+                } catch (e) {
+                    throw new Error('文件下载失败. ' + e);
+                }
+            }
+            return res;
+        }
+
         throw new Error('file not found');
     }
 }

src/onebot/action/file/GetGroupFileList.ts

@@ -1,13 +1,15 @@
 import { FromSchema, JSONSchema } from 'json-schema-to-ts';
 import BaseAction from '../BaseAction';
 import { ActionName } from '../types';
+import { FileNapCatOneBotUUID } from '@/common/helper';
 
 const SchemaData = {
     type: 'object',
     properties: {
         group_id: { type: ['string', 'number'] },
-        start_index: { type: 'number' },
+        start_index: { type: ['string', 'number'] },
-        file_count: { type: 'number' },
+        file_count: { type: ['string', 'number'] },
+        folder_id: { type: ['string', 'number'] },
     },
     required: ['group_id', 'start_index', 'file_count'],
 } as const satisfies JSONSchema;
@@ -20,15 +22,29 @@ export class GetGroupFileList extends BaseAction<Payload, { FileList: Array<any>
 
     async _handle(payload: Payload) {
         const NTQQMsgApi = this.core.apis.MsgApi;
+        let param = {};
+        if (payload.folder_id) {
+            param = {
+                folderId: payload.folder_id.toString(),
+            };
+        }
         const ret = await NTQQMsgApi.getGroupFileList(payload.group_id.toString(), {
             sortType: 1,
-            fileCount: payload.file_count,
+            fileCount: +payload.file_count,
-            startIndex: payload.start_index,
+            startIndex: +payload.start_index,
             sortOrder: 2,
             showOnlinedocFolder: 0,
+            ...param
         }).catch((e) => {
             return [];
         });
+        ret.forEach((e) => {
+            let fileModelId = e?.fileInfo?.fileModelId;
+            if (fileModelId) {
+                e.fileModelId = fileModelId;
+            }
+            e.fileId = FileNapCatOneBotUUID.encodeModelId({ chatType: 2, peerUid: payload.group_id.toString() }, fileModelId);
+        });
         return { FileList: ret };
     }
 }

src/onebot/action/group/GetGroupEssence.ts

@@ -1,4 +1,4 @@
-import { ChatType, GroupEssenceMsgRet, Peer } from '@/core';
+import { ChatType, Peer } from '@/core';
 import BaseAction from '../BaseAction';
 import { ActionName } from '../types';
 import { FromSchema, JSONSchema } from 'json-schema-to-ts';
@@ -18,42 +18,32 @@ type Payload = FromSchema<typeof SchemaData>;
 export class GetGroupEssence extends BaseAction<Payload, any> {
     actionName = ActionName.GoCQHTTP_GetEssenceMsg;
     payloadSchema = SchemaData;
-    async msgSeqToMsgId(peer: Peer, msgSeq: string, msgRandom: string) {
+
-        const NTQQMsgApi = this.core.apis.MsgApi;
+    private async msgSeqToMsgId(peer: Peer, msgSeq: string, msgRandom: string) {
-        const replyMsgList = (await NTQQMsgApi.getMsgsBySeqAndCount(peer, msgSeq, 1, true, true)).msgList.find((msg) => msg.msgSeq === msgSeq && msg.msgRandom === msgRandom);
+        const replyMsgList = (await this.core.apis.MsgApi.getMsgsBySeqAndCount(peer, msgSeq, 1, true, true)).msgList.find((msg) => msg.msgSeq === msgSeq && msg.msgRandom === msgRandom);
         if (!replyMsgList) {
-            return 0;
+            return undefined;
         }
-        return MessageUnique.createUniqueMsgId(peer, replyMsgList.msgId);
+        return {
+            id: MessageUnique.createUniqueMsgId(peer, replyMsgList.msgId),
+            msg: replyMsgList
+        };
     }
+
     async _handle(payload: Payload) {
         const NTQQWebApi = this.core.apis.WebApi;
         const NTQQGroupApi = this.core.apis.GroupApi;
-        //await NTQQGroupApi.fetchGroupEssenceList(payload.group_id.toString());
+        const msglist = (await NTQQWebApi.getGroupEssenceMsgAll(payload.group_id.toString())).flatMap((e) => e.data.msg_list);
-        let peer = {
+        if (!msglist) {
-            chatType: ChatType.KCHATTYPEGROUP,
-            peerUid: payload.group_id.toString(),
-        };
-
-        const ret = await NTQQWebApi.getGroupEssenceMsg(payload.group_id.toString());
-        if (!ret) {
             throw new Error('获取失败');
         }
-        const Ob11Ret = await Promise.all(ret.data.msg_list.map(async (msg) => {
+        return await Promise.all(msglist.map(async (msg) => {
-            let message_id = await this.msgSeqToMsgId(peer, msg.msg_seq.toString(), msg.msg_random.toString());
+            const msgOriginData = await this.msgSeqToMsgId({
-            if (message_id === 0) {
+                chatType: ChatType.KCHATTYPEGROUP,
-                const data = JSON.stringify({
+                peerUid: payload.group_id.toString(),
-                    msg_seq: msg.msg_seq.toString(),
+            }, msg.msg_seq.toString(), msg.msg_random.toString());
-                    msg_random: msg.msg_random.toString(),
+            if (msgOriginData) {
-                    group_id: payload.group_id.toString(),
+                const { id: message_id, msg: rawMessage } = msgOriginData;
-                });
-                const hash = crypto.createHash('md5').update(data).digest();
-                //设置第一个bit为0 保证shortId为正数
-                hash[0] &= 0x7f;
-                const shortId = hash.readInt32BE(0);
-                NTQQGroupApi.essenceLRU.set(shortId, data);
-                message_id = shortId;
-            }
                 return {
                     msg_seq: msg.msg_seq,
                     msg_random: msg.msg_random,
@@ -63,8 +53,47 @@ export class GetGroupEssence extends BaseAction<Payload, any> {
                     operator_nick: msg.add_digest_nick,
                     message_id: message_id,
                     operator_time: msg.add_digest_time,
+                    content: (await this.obContext.apis.MsgApi.parseMessage(rawMessage, 'array'))?.message
+                };
+            }
+            const msgTempData = JSON.stringify({
+                msg_seq: msg.msg_seq.toString(),
+                msg_random: msg.msg_random.toString(),
+                group_id: payload.group_id.toString(),
+            });
+            const hash = crypto.createHash('md5').update(msgTempData).digest();
+            //设置第一个bit为0 保证shortId为正数
+            hash[0] &= 0x7f;
+            const shortId = hash.readInt32BE(0);
+            NTQQGroupApi.essenceLRU.set(shortId, msgTempData);
+            return {
+                msg_seq: msg.msg_seq,
+                msg_random: msg.msg_random,
+                sender_id: +msg.sender_uin,
+                sender_nick: msg.sender_nick,
+                operator_id: +msg.add_digest_uin,
+                operator_nick: msg.add_digest_nick,
+                message_id: shortId,
+                operator_time: msg.add_digest_time,
+                content: msg.msg_content.map((msg) => {
+                    if (msg.msg_type === 1) {
+                        return {
+                            type: 'text',
+                            data: {
+                                text: msg?.text
+                            }
+                        };
+                    } else if (msg.msg_type === 3) {
+                        return {
+                            type: 'image',
+                            data: {
+                                url: msg?.image_url,
+                            }
+                        };
+                    }
+                    return undefined;
+                }).filter(e => e !== undefined),
             };
         }));
-        return Ob11Ret;
     }
 }

src/onebot/action/group/GetGroupIgnoredNotifies.ts

@@ -0,0 +1,39 @@
+import { GroupNotifyMsgStatus } from '@/core';
+import BaseAction from '../BaseAction';
+import { ActionName } from '../types';
+import { FromSchema, JSONSchema } from 'json-schema-to-ts';
+
+const SchemaData = {
+    type: 'object',
+    properties: {
+        group_id: { type: ['number', 'string'] },
+    },
+} as const satisfies JSONSchema;
+
+type Payload = FromSchema<typeof SchemaData>;
+
+export class GetGroupIgnoredNotifies extends BaseAction<void, any> {
+    actionName = ActionName.GetGroupIgnoredNotifies;
+
+    async _handle(payload: void) {
+        const NTQQUserApi = this.core.apis.UserApi;
+        const NTQQGroupApi = this.core.apis.GroupApi;
+        const ignoredNotifies = await NTQQGroupApi.getSingleScreenNotifies(true, 10);
+        const retData: any = {
+            join_requests: await Promise.all(
+                ignoredNotifies
+                    .filter(notify => notify.type === 7)
+                    .map(async SSNotify => ({
+                        request_id: SSNotify.seq,
+                        requester_uin: await NTQQUserApi.getUinByUidV2(SSNotify.user1?.uid),
+                        requester_nick: SSNotify.user1?.nickName,
+                        group_id: SSNotify.group?.groupCode,
+                        group_name: SSNotify.group?.groupName,
+                        checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
+                        actor: await NTQQUserApi.getUinByUidV2(SSNotify.user2?.uid) || 0,
+                    }))),
+        };
+
+        return retData;
+    }
+}

src/onebot/action/group/GetGroupSystemMsg.ts

@@ -1,50 +0,0 @@
-import { GroupNotifyMsgStatus } from '@/core';
-import BaseAction from '../BaseAction';
-import { ActionName } from '../types';
-import { FromSchema, JSONSchema } from 'json-schema-to-ts';
-
-const SchemaData = {
-    type: 'object',
-    properties: {
-        group_id: { type: ['number', 'string'] },
-    },
-} as const satisfies JSONSchema;
-
-type Payload = FromSchema<typeof SchemaData>;
-
-export class GetGroupSystemMsg extends BaseAction<void, any> {
-    actionName = ActionName.GetGroupSystemMsg;
-
-    async _handle(payload: void) {
-        const NTQQUserApi = this.core.apis.UserApi;
-        const NTQQGroupApi = this.core.apis.GroupApi;
-        // 默认10条 该api未完整实现 包括响应数据规范化 类型规范化 
-        const SingleScreenNotifies = await NTQQGroupApi.getSingleScreenNotifies(10);
-        const retData: any = { InvitedRequest: [], join_requests: [] };
-        for (const SSNotify of SingleScreenNotifies) {
-            if (SSNotify.type == 1) {
-                retData.InvitedRequest.push({
-                    request_id: SSNotify.seq,
-                    invitor_uin: await NTQQUserApi.getUinByUidV2(SSNotify.user1?.uid),
-                    invitor_nick: SSNotify.user1?.nickName,
-                    group_id: SSNotify.group?.groupCode,
-                    group_name: SSNotify.group?.groupName,
-                    checked: SSNotify.status === GroupNotifyMsgStatus.KUNHANDLE ? false : true,
-                    actor: await NTQQUserApi.getUinByUidV2(SSNotify.user2?.uid) || 0,
-                });
-            } else if (SSNotify.type == 7) {
-                retData.join_requests.push({
-                    request_id: SSNotify.seq,
-                    requester_uin: await NTQQUserApi.getUinByUidV2(SSNotify.user1?.uid),
-                    requester_nick: SSNotify.user1?.nickName,
-                    group_id: SSNotify.group?.groupCode,
-                    group_name: SSNotify.group?.groupName,
-                    checked: SSNotify.status === GroupNotifyMsgStatus.KUNHANDLE ? false : true,
-                    actor: await NTQQUserApi.getUinByUidV2(SSNotify.user2?.uid) || 0,
-                });
-            }
-        }
-
-        return retData;
-    }
-}

src/onebot/action/index.ts

@@ -52,7 +52,7 @@ import { GetFriendWithCategory } from './extends/GetFriendWithCategory';
 import { SendGroupNotice } from './go-cqhttp/SendGroupNotice';
 import { GetGroupHonorInfo } from './go-cqhttp/GetGroupHonorInfo';
 import { GoCQHTTPHandleQuickAction } from './go-cqhttp/QuickAction';
-import { GetGroupSystemMsg } from './group/GetGroupSystemMsg';
+import { GetGroupIgnoredNotifies } from './group/GetGroupIgnoredNotifies';
 import { GetOnlineClient } from './go-cqhttp/GetOnlineClient';
 import { IOCRImage, OCRImage } from './extends/OCRImage';
 import { GetGroupFileCount } from './file/GetGroupFileCount';
@@ -159,7 +159,7 @@ export function createActionMap(obContext: NapCatOneBot11Adapter, core: NapCatCo
         new GoCQHTTPGetForwardMsgAction(obContext, core),
         new GetFriendMsgHistory(obContext, core),
         new GoCQHTTPHandleQuickAction(obContext, core),
-        new GetGroupSystemMsg(obContext, core),
+        new GetGroupIgnoredNotifies(obContext, core),
         new DelEssenceMsg(obContext, core),
         new SetEssenceMsg(obContext, core),
         new GetRecentContact(obContext, core),

src/onebot/action/types.ts

@@ -87,7 +87,7 @@ export enum ActionName {
     GoCQHTTP_GetGroupMsgHistory = 'get_group_msg_history',
     GoCQHTTP_GetForwardMsg = 'get_forward_msg',
     GetFriendMsgHistory = 'get_friend_msg_history',
-    GetGroupSystemMsg = 'get_group_system_msg',
+    GetGroupIgnoredNotifies = 'get_group_ignored_notifies',
     GetOnlineClient = 'get_online_clients',
     OCRImage = 'ocr_image',
     IOCRImage = '.ocr_image',

src/onebot/api/group.ts

@@ -116,18 +116,22 @@ export class OneBotGroupApi {
                         const searchParams = new URL(json.items[0].jp).searchParams;
                         const msgSeq = searchParams.get('msgSeq')!;
                         const Group = searchParams.get('groupCode');
+                        if (!Group) return;
                         // const businessId = searchParams.get('businessid');
                         const Peer = {
                             guildId: '',
                             chatType: ChatType.KCHATTYPEGROUP,
-                            peerUid: Group!,
+                            peerUid: Group,
                         };
                         const msgData = await NTQQMsgApi.getMsgsBySeqAndCount(Peer, msgSeq.toString(), 1, true, true);
+                        let msgList = (await this.core.apis.WebApi.getGroupEssenceMsgAll(Group)).flatMap((e) => e.data.msg_list);
+                        let realMsg = msgList.find((e) => e.msg_seq.toString() == msgSeq);
                         return new OB11GroupEssenceEvent(
                             this.core,
                             parseInt(msg.peerUid),
                             MessageUnique.getShortIdByMsgId(msgData.msgList[0].msgId)!,
                             parseInt(msgData.msgList[0].senderUin),
+                            parseInt(realMsg?.add_digest_uin ?? '0'),
                         );
                         // 获取MsgSeq+Peer可获取具体消息
                     }

src/onebot/api/msg.ts

@@ -1,4 +1,4 @@
-import { UUIDConverter } from '@/common/helper';
+import { FileNapCatOneBotUUID } from '@/common/helper';
 import { MessageUnique } from '@/common/message-unique';
 import {
     AtType,
@@ -98,14 +98,19 @@ export class OneBotMsgApi {
             }
         },
 
-        picElement: async (element, msg) => {
+        picElement: async (element, msg, elementWrapper) => {
             try {
+                const peer = {
+                    chatType: msg.chatType,
+                    peerUid: msg.peerUid,
+                    guildId: '',
+                };
                 return {
                     type: OB11MessageDataType.image,
                     data: {
                         file: element.fileName,
                         sub_type: element.picSubType,
-                        file_id: UUIDConverter.encode(msg.peerUin, msg.msgId),
+                        file_id: FileNapCatOneBotUUID.encode(peer, msg.msgId, elementWrapper.elementId),
                         url: await this.core.apis.FileApi.getImageUrl(element),
                         file_size: element.fileSize,
                     },
@@ -117,6 +122,11 @@ export class OneBotMsgApi {
         },
 
         fileElement: async (element, msg, elementWrapper) => {
+            const peer = {
+                chatType: msg.chatType,
+                peerUid: msg.peerUid,
+                guildId: '',
+            };
             await this.core.apis.FileApi.addFileCache(
                 {
                     peerUid: msg.peerUid,
@@ -137,7 +147,7 @@ export class OneBotMsgApi {
                     file: element.fileName,
                     path: element.filePath,
                     url: element.filePath,
-                    file_id: UUIDConverter.encode(msg.peerUin, msg.msgId),
+                    file_id: FileNapCatOneBotUUID.encode(peer, msg.msgId, elementWrapper.elementId),
                     file_size: element.fileSize,
                 },
             };
@@ -184,11 +194,16 @@ export class OneBotMsgApi {
                 '0',
                 'marketface',
             );
+            const peer = {
+                chatType: msg.chatType,
+                peerUid: msg.peerUid,
+                guildId: '',
+            };
             return {
                 type: OB11MessageDataType.image,
                 data: {
                     file: 'marketface',
-                    file_id: UUIDConverter.encode(msg.peerUin, msg.msgId),
+                    file_id: FileNapCatOneBotUUID.encode(peer, msg.msgId, elementWrapper.elementId),
                     path: elementWrapper.elementId,
                     url: elementWrapper.elementId,
                 },
@@ -207,13 +222,21 @@ export class OneBotMsgApi {
                 this.core.context.logger.logError('获取不到引用的消息', element.replayMsgSeq);
                 return null;
             }
+
+            const createReplyData = (msgId: string): OB11MessageData => ({
+                type: OB11MessageDataType.reply,
+                data: {
+                    id: MessageUnique.createUniqueMsgId(peer, msgId).toString(),
+                },
+            });
+
+            if (records.peerUin === '284840486') {
+                return createReplyData(records.msgId);
+            }
+
             let replyMsg: RawMessage | undefined;
             // Attempt 1
-            replyMsg = (await NTQQMsgApi.getMsgsBySeqAndCount({
+            replyMsg = (await NTQQMsgApi.getMsgsBySeqAndCount(peer,element.replayMsgSeq, 1, true, true))
-                peerUid: msg.peerUid,
-                guildId: '',
-                chatType: msg.chatType,
-            }, element.replayMsgSeq, 1, true, true))
                 .msgList
                 .find(msg => msg.msgRandom === records.msgRandom);
 
@@ -221,7 +244,7 @@ export class OneBotMsgApi {
                 // Attempt 2
                 replyMsg = (await NTQQMsgApi.getSingleMsg(peer, element.replayMsgSeq)).msgList[0];
 
-                if ((!replyMsg || records.msgRandom !== replyMsg.msgRandom) && msg.peerUin !== '284840486') {
+                if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
                     // Attempt 3
                     const replyMsgList = (await NTQQMsgApi.getMsgExBySeq(peer, records.msgSeq)).msgList;
                     if (replyMsgList.length < 1) {
@@ -233,21 +256,16 @@ export class OneBotMsgApi {
                 }
             }
 
-            return {
+            return createReplyData(replyMsg.msgId);
-                type: OB11MessageDataType.reply,
-                data: {
-                    id: MessageUnique.createUniqueMsgId({
-                        peerUid: msg.peerUid,
-                        guildId: '',
-                        chatType: msg.chatType,
-                    }, replyMsg.msgId).toString(),
-                },
-            };
         },
 
         videoElement: async (element, msg, elementWrapper) => {
             const NTQQFileApi = this.core.apis.FileApi;
-
+            const peer = {
+                chatType: msg.chatType,
+                peerUid: msg.peerUid,
+                guildId: '',
+            };
             //读取视频链接并兜底
             let videoUrlWrappers: Awaited<ReturnType<typeof NTQQFileApi.getVideoUrl>> | undefined;
 
@@ -302,13 +320,18 @@ export class OneBotMsgApi {
                     file: element.fileName,
                     path: videoDownUrl,
                     url: videoDownUrl,
-                    file_id: UUIDConverter.encode(msg.peerUin, msg.msgId),
+                    file_id: FileNapCatOneBotUUID.encode(peer, msg.msgId, elementWrapper.elementId),
                     file_size: element.fileSize,
                 },
             };
         },
 
         pttElement: async (element, msg, elementWrapper) => {
+            const peer = {
+                chatType: msg.chatType,
+                peerUid: msg.peerUid,
+                guildId: '',
+            };
             await this.core.apis.FileApi.addFileCache(
                 {
                     peerUid: msg.peerUid,
@@ -328,7 +351,7 @@ export class OneBotMsgApi {
                 data: {
                     file: element.fileName,
                     path: element.filePath,
-                    file_id: UUIDConverter.encode(msg.peerUin, msg.msgId),
+                    file_id: FileNapCatOneBotUUID.encode(peer, msg.msgId, elementWrapper.elementId),
                     file_size: element.fileSize,
                 },
             };

src/onebot/api/quick-action.ts

@@ -78,7 +78,7 @@ export class OneBotQuickActionApi {
                 sendElements,
                 deleteAfterSentFiles,
             } = await this.obContext.apis.MsgApi.createSendElements(replyMessage, peer);
-            this.obContext.apis.MsgApi.sendMsgWithOb11UniqueId(peer, sendElements, deleteAfterSentFiles, false).then().catch(this.core.context.logger.logError);
+            this.obContext.apis.MsgApi.sendMsgWithOb11UniqueId(peer, sendElements, deleteAfterSentFiles, false).then().catch(this.core.context.logger.logError.bind(this.core.context.logger));
         }
     }
 
@@ -88,13 +88,13 @@ export class OneBotQuickActionApi {
                 request.flag,
                 quickAction.approve ? GroupRequestOperateTypes.approve : GroupRequestOperateTypes.reject,
                 quickAction.reason,
-            ).catch(this.core.context.logger.logError);
+            ).catch(this.core.context.logger.logError.bind(this.core.context.logger));
         }
     }
 
     async handleFriendRequest(request: OB11FriendRequestEvent, quickAction: QuickActionFriendRequest) {
         if (!isNull(quickAction.approve)) {
-            this.core.apis.FriendApi.handleFriendRequest(request.flag, !!quickAction.approve).then().catch(this.core.context.logger.logError);
+            this.core.apis.FriendApi.handleFriendRequest(request.flag, !!quickAction.approve).then().catch(this.core.context.logger.logError.bind(this.core.context.logger));
         }
     }
 }

src/onebot/event/notice/OB11GroupEssenceEvent.ts

@@ -5,11 +5,14 @@ export class OB11GroupEssenceEvent extends OB11GroupNoticeEvent {
     notice_type = 'essence';
     message_id: number;
     sender_id: number;
+    operator_id: number;
     sub_type: 'add' | 'delete' = 'add';
 
-    constructor(core: NapCatCore, groupId: number, message_id: number, sender_id: number) {
+
+    constructor(core: NapCatCore, groupId: number, message_id: number, sender_id: number, operator_id: number) {
         super(core, groupId, sender_id);
         this.group_id = groupId;
+        this.operator_id = operator_id;
         this.message_id = message_id;
         this.sender_id = sender_id;
     }

src/onebot/index.ts

@@ -139,7 +139,7 @@ export class NapCatOneBot11Adapter {
 
     initRecentContactListener() {
         const recentContactListener = new NodeIKernelRecentContactListener();
-        recentContactListener.onRecentContactNotification = function(msgList: any[] /* arg0: { msgListUnreadCnt: string }, arg1: number */) {
+        recentContactListener.onRecentContactNotification = function (msgList: any[] /* arg0: { msgListUnreadCnt: string }, arg1: number */) {
             msgList.forEach((msg) => {
                 if (msg.chatType == ChatType.KCHATTYPEGROUP) {
                     // log("recent contact", msgList, arg0, arg1);
@@ -248,13 +248,16 @@ export class NapCatOneBot11Adapter {
                 return;
             }
             const { msgType, subType, subSubType } = sysMsg.msgSpec[0];
-            if (msgType === 732 && subType === 16 && subSubType === 16 ) {
+            if (msgType === 732 && subType === 16 && subSubType === 16) {
                 const greyTip = GreyTipWrapper.fromBinary(Uint8Array.from(sysMsg.bodyWrapper!.wrappedBody.slice(7)));
                 if (greyTip.subTypeId === 36) {
                     const emojiLikeToOthers = EmojiLikeToOthersWrapper1
                         .fromBinary(greyTip.rest)
                         .wrapper!
                         .body!;
+                    if (emojiLikeToOthers.attributes?.operation !== 1) { // Un-like
+                        return;
+                    }
                     const eventOrEmpty = await this.apis.GroupApi.createGroupEmojiLikeEvent(
                         greyTip.groupCode.toString(),
                         await this.core.apis.UserApi.getUinByUidV2(emojiLikeToOthers.attributes!.senderUid),
@@ -470,6 +473,18 @@ export class NapCatOneBot11Adapter {
                         );
                         this.networkManager.emitEvent(groupInviteEvent)
                             .catch(e => this.context.logger.logError('处理邀请本人加群失败', e));
+                    } else if (notify.type == GroupNotifyMsgType.INVITED_NEED_ADMINI_STRATOR_PASS && notify.status == GroupNotifyMsgStatus.KUNHANDLE) {
+                        this.context.logger.logDebug(`收到群员邀请加群通知:${notify}`);
+                        const groupInviteEvent = new OB11GroupRequestEvent(
+                            this.core,
+                            parseInt(notify.group.groupCode),
+                            parseInt(await this.core.apis.UserApi.getUinByUidV2(notify.user2.uid)),
+                            'invite',
+                            notify.postscript,
+                            flag,
+                        );
+                        this.networkManager.emitEvent(groupInviteEvent)
+                            .catch(e => this.context.logger.logError('处理邀请本人加群失败', e));
                     }
                 }
             }

src/webui/ui/NapCat.ts

@@ -30,7 +30,7 @@ async function onSettingWindowCreated(view: Element) {
                 SettingItem(
                     '<span id="napcat-update-title">Napcat</span>',
                     undefined,
-                    SettingButton('V2.2.21', 'napcat-update-button', 'secondary'),
+                    SettingButton('V2.2.26', 'napcat-update-button', 'secondary'),
                 ),
             ]),
             SettingList([

static/assets/renderer.js

@@ -164,7 +164,7 @@ async function onSettingWindowCreated(view) {
         SettingItem(
           '<span id="napcat-update-title">Napcat</span>',
           void 0,
-          SettingButton("V2.2.21", "napcat-update-button", "secondary")
+          SettingButton("V2.2.26", "napcat-update-button", "secondary")
         )
       ]),
       SettingList([