refactor: flag handle&onebot标准化

README.md

@@ -36,6 +36,13 @@ NapCatQQ 是现代化的基于 NTQQ 的 Bot 协议端实现
 ## 回家旅途
 [QQ Group](https://qm.qq.com/q/I6LU87a0Yq)
 
+## 性能设计/协议标准
+NapCat 已实现90％+的OneBot/GoCQ标准接口,并提供兼容性保留接口，其设计理念遵守 无数据库/异步优先/后台刷新 的性能思想。
+
+由此设计带来一系列好处,在开发中,获取群员列表通常小于50Ms,单条文本消息发送在320Ms以内,在1k+的群聊流程运行,同时带来一些副作用，上报数据中大量使用Magic生成字段, 消息Id无法持久，无法上报撤回消息原始内容。
+
+NapCat在设计理念下遵守OneBot规范大多数要求并且积极改进,任何合理的标准化issue与pr将被接收。
+
 ## 感谢他们
 感谢 [Lagrange](https://github.com/LagrangeDev/Lagrange.Core) 对本项目的大力支持 参考部分代码 已获授权
 

manifest.json

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

package.json

@@ -2,7 +2,7 @@
   "name": "napcat",
   "private": true,
   "type": "module",
-  "version": "4.2.22",
+  "version": "4.2.23",
   "scripts": {
     "build:universal": "npm run build:webui && vite build --mode universal || exit 1",
     "build:framework": "npm run build:webui && vite build --mode framework || exit 1",

src/common/version.ts

@@ -1 +1 @@
-export const napCatVersion = '4.2.22';
+export const napCatVersion = '4.2.23';

src/core/apis/friend.ts

@@ -1,4 +1,4 @@
-import { FriendV2 } from '@/core/types';
+import { FriendRequest, FriendV2 } from '@/core/types';
 import { BuddyListReqType, InstanceContext, NapCatCore } from '@/core';
 import { LimitedHashTable } from '@/common/message-unique';
 
@@ -79,16 +79,10 @@ export class NTQQFriendApi {
         return ret;
     }
 
-    async handleFriendRequest(flag: string, accept: boolean) {
-        const data = flag.split('|');
-        if (data.length < 2) {
-            return;
-        }
-        const friendUid = data[0];
-        const reqTime = data[1];
+    async handleFriendRequest(notify: FriendRequest, accept: boolean) {
         this.context.session.getBuddyService()?.approvalFriendRequest({
-            friendUid: friendUid,
-            reqTime: reqTime,
+            friendUid: notify.friendUid,
+            reqTime: notify.reqTime,
             accept,
         });
     }

src/core/apis/group.ts

@@ -7,6 +7,7 @@ import {
     KickMemberV2Req,
     MemberExtSourceType,
     NapCatCore,
+    GroupNotify,
 } from '@/core';
 import { isNumeric, solveAsyncProblem } from '@/common/helper';
 import { LimitedHashTable } from '@/common/message-unique';
@@ -120,7 +121,7 @@ export class NTQQGroupApi {
         }
         return this.groupMemberCache;
     }
-    
+
     async getGroupMember(groupCode: string | number, memberUinOrUid: string | number) {
         const groupCodeStr = groupCode.toString();
         const memberUinOrUidStr = memberUinOrUid.toString();
@@ -288,20 +289,15 @@ export class NTQQGroupApi {
         return this.context.session.getGroupService().uploadGroupBulletinPic(groupCode, _Pskey, imageurl);
     }
 
-    async handleGroupRequest(flag: string, operateType: NTGroupRequestOperateTypes, reason?: string) {
-        const flagitem = flag.split('|');
-        const groupCode = flagitem[0];
-        const seq = flagitem[1];
-        const type = parseInt(flagitem[2]);
-
+    async handleGroupRequest(notify: GroupNotify, operateType: NTGroupRequestOperateTypes, reason?: string) {
         return this.context.session.getGroupService().operateSysNotify(
             false,
             {
                 operateType: operateType,
                 targetMsg: {
-                    seq: seq,  // 通知序列号
-                    type: type,
-                    groupCode: groupCode,
+                    seq: notify.seq,  // 通知序列号
+                    type: notify.type,
+                    groupCode: notify.group.groupCode,
                     postscript: reason ?? ' ', // 仅传空值可能导致处理失败，故默认给个空格
                 },
             });

src/core/external/appid.json

@@ -102,5 +102,13 @@
     "9.9.17-30366": {
         "appid": 537258389,
         "qua": "V1_WIN_NQ_9.9.17_30366_GW_B"
+    },
+    "3.2.15-30366": {
+        "appid": 537258413,
+        "qua": "V1_LNX_NQ_3.2.15_30366_GW_B"
+    },
+    "6.9.62-30366": {
+        "appid": 537258401,
+        "qua": "V1_MAC_NQ_6.9.62_30366_GW_B"
     }
 }

src/core/external/offset.json

@@ -106,5 +106,21 @@
     "9.9.17-30366-x64": {
         "send": "39AB0B0",
         "recv": "39AF4E4"
+    },
+    "3.2.15-30366-x64": {
+        "send": "A402380",
+        "recv": "A405C80"
+    },
+    "3.2.15-30366-arm64": {
+        "send": "70C3FA8",
+        "recv": "70C77E0"
+    },
+    "6.9.62-30366-x64": {
+        "send": "4669760",
+        "recv": "466BFCC"
+    },
+    "6.9.62-30366-arm64": {
+        "send": "4189770",
+        "recv": "418BF88"
     }
 }

src/onebot/action/extends/GetGroupAddRequest.ts

@@ -1,17 +1,7 @@
 import { GroupNotifyMsgStatus } from '@/core';
 import { OneBotAction } from '@/onebot/action/OneBotAction';
 import { ActionName } from '@/onebot/action/router';
-
-interface Notify {
-    request_id: string;
-    invitor_uin: number;
-    invitor_nick?: string;
-    group_id?: number;
-    group_name?: string;
-    checked: boolean;
-    requester_nick?: string;
-    actor: number;
-}
+import { Notify } from '@/onebot/types';
 
 export default class GetGroupAddRequest extends OneBotAction<null, Notify[] | null> {
     actionName = ActionName.GetGroupIgnoreAddRequest;
@@ -28,13 +18,15 @@ export default class GetGroupAddRequest extends OneBotAction<null, Notify[] | nu
                 const invitorUin = SSNotify.user1?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user1.uid) : 0;
                 const actorUin = SSNotify.user2?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user2.uid) : 0;
                 retData.push({
-                    request_id: `${SSNotify.group.groupCode}|${SSNotify.seq}|${SSNotify.type}`,
+                    request_id: +SSNotify.seq,
                     invitor_uin: invitorUin,
-                    requester_nick: SSNotify.user1?.nickName,
+                    invitor_nick: SSNotify.user1?.nickName,
                     group_id: +SSNotify.group?.groupCode,
+                    message: SSNotify?.postscript,
                     group_name: SSNotify.group?.groupName,
                     checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
                     actor: actorUin,
+                    requester_nick: SSNotify.user1?.nickName,
                 });
             });
 

src/onebot/action/group/GetGroupIgnoredNotifies.ts

@@ -1,40 +1,29 @@
 import { GroupNotifyMsgStatus } from '@/core';
 import { OneBotAction } from '@/onebot/action/OneBotAction';
 import { ActionName } from '@/onebot/action/router';
+import { Notify } from '@/onebot/types';
 
-interface Notify {
-    request_id: string;
-    invitor_uin: number;
-    invitor_nick?: string;
-    group_id?: number;
-    group_name?: string;
-    checked: boolean;
-    requester_nick?: string;
-    actor: number;
-}
 interface RetData {
     InvitedRequest: Notify[];
     join_requests: Notify[];
 }
 
 export class GetGroupIgnoredNotifies extends OneBotAction<void, RetData> {
-    actionName = ActionName.GetGroupSystemMsg;
+    actionName = ActionName.GetGroupIgnoredNotifies;
 
     async _handle(): Promise<RetData> {
-        const NTQQUserApi = this.core.apis.UserApi;
-        const NTQQGroupApi = this.core.apis.GroupApi;
-        const SingleScreenNotifies = await NTQQGroupApi.getSingleScreenNotifies(false, 50);
+        const SingleScreenNotifies = await this.core.apis.GroupApi.getSingleScreenNotifies(false, 50);
         const retData: RetData = { InvitedRequest: [], join_requests: [] };
 
         const notifyPromises = SingleScreenNotifies.map(async (SSNotify) => {
-            const invitorUin = SSNotify.user1?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user1.uid) : 0;
-            const actorUin = SSNotify.user2?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user2.uid) : 0;
-
+            const invitorUin = SSNotify.user1?.uid ? +await this.core.apis.UserApi.getUinByUidV2(SSNotify.user1.uid) : 0;
+            const actorUin = SSNotify.user2?.uid ? +await this.core.apis.UserApi.getUinByUidV2(SSNotify.user2.uid) : 0;
             const commonData = {
-                request_id: `${SSNotify.group.groupCode}|${SSNotify.seq}|${SSNotify.type}`,
+                request_id: +SSNotify.seq,
                 invitor_uin: invitorUin,
                 invitor_nick: SSNotify.user1?.nickName,
                 group_id: +SSNotify.group?.groupCode,
+                message: SSNotify?.postscript,
                 group_name: SSNotify.group?.groupName,
                 checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
                 actor: actorUin,

src/onebot/action/group/SetGroupAddRequest.ts

@@ -4,9 +4,9 @@ import { ActionName } from '@/onebot/action/router';
 import { Static, Type } from '@sinclair/typebox';
 
 const SchemaData = Type.Object({
-    flag: Type.String(),
+    flag: Type.Union([Type.String(), Type.Number()]),
     approve: Type.Optional(Type.Union([Type.Boolean(), Type.String()])),
-    reason: Type.Union([Type.String({ default: ' ' }), Type.Null()]),
+    reason: Type.Optional(Type.Union([Type.String({ default: ' ' }), Type.Null()])),
 });
 
 type Payload = Static<typeof SchemaData>;
@@ -18,10 +18,26 @@ export default class SetGroupAddRequest extends OneBotAction<Payload, null> {
     async _handle(payload: Payload): Promise<null> {
         const flag = payload.flag.toString();
         const approve = payload.approve?.toString() !== 'false';
-        await this.core.apis.GroupApi.handleGroupRequest(flag,
+        const reason = payload.reason ?? ' ';
+
+        let notify = await this.findNotify(flag);
+        if (!notify) {
+            throw new Error('No such request');
+        }
+
+        await this.core.apis.GroupApi.handleGroupRequest(
+            notify,
             approve ? NTGroupRequestOperateTypes.KAGREE : NTGroupRequestOperateTypes.KREFUSE,
-            payload.reason ?? ' ',
+            reason,
         );
         return null;
     }
-}
+
+    private async findNotify(flag: string) {
+        let notify = (await this.core.apis.GroupApi.getSingleScreenNotifies(false, 100)).find(e => e.seq == flag);
+        if (!notify) {
+            notify = (await this.core.apis.GroupApi.getSingleScreenNotifies(true, 100)).find(e => e.seq == flag);
+        }
+        return notify;
+    }
+}

src/onebot/action/system/GetSystemMsg.ts

@@ -1,59 +1,39 @@
 import { GroupNotifyMsgStatus } from '@/core';
 import { OneBotAction } from '@/onebot/action/OneBotAction';
 import { ActionName } from '@/onebot/action/router';
-
-interface Notify {
-    request_id: string;
-    invitor_uin: number;
-    invitor_nick?: string;
-    group_id?: number;
-    group_name?: string;
-    checked: boolean;
-    actor: number;
-}
-
-interface JoinRequest extends Notify {
-    requester_nick?: string;
-}
+import { Notify } from '@/onebot/types';
 
 interface RetData {
     InvitedRequest: Notify[];
-    join_requests: JoinRequest[];
+    join_requests: Notify[];
 }
 
 export class GetGroupSystemMsg extends OneBotAction<void, RetData> {
     actionName = ActionName.GetGroupSystemMsg;
 
     async _handle(): Promise<RetData> {
-        const NTQQUserApi = this.core.apis.UserApi;
-        const NTQQGroupApi = this.core.apis.GroupApi;
-        const SingleScreenNotifies = await NTQQGroupApi.getSingleScreenNotifies(false, 50);
+        const SingleScreenNotifies = await this.core.apis.GroupApi.getSingleScreenNotifies(false, 50);
         const retData: RetData = { InvitedRequest: [], join_requests: [] };
 
         const notifyPromises = SingleScreenNotifies.map(async (SSNotify) => {
-            const invitorUin = SSNotify.user1?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user1.uid) : 0;
-            const actorUin = SSNotify.user2?.uid ? +await NTQQUserApi.getUinByUidV2(SSNotify.user2.uid) : 0;
+            const invitorUin = SSNotify.user1?.uid ? +await this.core.apis.UserApi.getUinByUidV2(SSNotify.user1.uid) : 0;
+            const actorUin = SSNotify.user2?.uid ? +await this.core.apis.UserApi.getUinByUidV2(SSNotify.user2.uid) : 0;
+            const commonData = {
+                request_id: +SSNotify.seq,
+                invitor_uin: invitorUin,
+                invitor_nick: SSNotify.user1?.nickName,
+                group_id: +SSNotify.group?.groupCode,
+                message: SSNotify?.postscript,
+                group_name: SSNotify.group?.groupName,
+                checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
+                actor: actorUin,
+                requester_nick: SSNotify.user1?.nickName,
+            };
 
             if (SSNotify.type === 1) {
-                retData.InvitedRequest.push({
-                    request_id: `${SSNotify.group.groupCode}|${SSNotify.seq}|${SSNotify.type}`,
-                    invitor_uin: invitorUin,
-                    invitor_nick: SSNotify.user1?.nickName,
-                    group_id: +SSNotify.group?.groupCode,
-                    group_name: SSNotify.group?.groupName,
-                    checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
-                    actor: actorUin,
-                });
+                retData.InvitedRequest.push(commonData);
             } else if (SSNotify.type === 7) {
-                retData.join_requests.push({
-                    request_id: `${SSNotify.group.groupCode}|${SSNotify.seq}|${SSNotify.type}`,
-                    invitor_uin: invitorUin,
-                    requester_nick: SSNotify.user1?.nickName,
-                    group_id: +SSNotify.group?.groupCode,
-                    group_name: SSNotify.group?.groupName,
-                    checked: SSNotify.status !== GroupNotifyMsgStatus.KUNHANDLE,
-                    actor: actorUin,
-                });
+                retData.join_requests.push(commonData);
             }
         });
 

src/onebot/action/user/SetFriendAddRequest.ts

@@ -3,7 +3,7 @@ import { ActionName } from '@/onebot/action/router';
 import { Static, Type } from '@sinclair/typebox';
 
 const SchemaData = Type.Object({
-    flag: Type.String(),
+    flag: Type.Union([Type.String(), Type.Number()]),
     approve: Type.Optional(Type.Union([Type.String(), Type.Boolean()])),
     remark: Type.Optional(Type.String())
 });
@@ -16,14 +16,13 @@ export default class SetFriendAddRequest extends OneBotAction<Payload, null> {
 
     async _handle(payload: Payload): Promise<null> {
         const approve = payload.approve?.toString() !== 'false';
-        await this.core.apis.FriendApi.handleFriendRequest(payload.flag, approve);
+        let notify = (await this.core.apis.FriendApi.getBuddyReq()).buddyReqs.find(e => e.reqTime == payload.flag.toString());
+        if (!notify) {
+            throw new Error('No such request');
+        }
+        await this.core.apis.FriendApi.handleFriendRequest(notify, approve);
         if (payload.remark) {
-            const data = payload.flag.split('|');
-            if (data.length < 2) {
-                throw new Error('Invalid flag');
-            }
-            const friendUid = data[0];
-            await this.core.apis.FriendApi.setBuddyRemark(friendUid, payload.remark);
+            await this.core.apis.FriendApi.setBuddyRemark(notify.friendUid, payload.remark);
         }
         return null;
     }

src/onebot/api/group.ts

@@ -51,9 +51,9 @@ export class OneBotGroupApi {
         if (memberUin && adminUin) {
             return new OB11GroupBanEvent(
                 this.core,
-                parseInt(GroupCode),
-                parseInt(memberUin),
-                parseInt(adminUin),
+                +GroupCode,
+                +memberUin,
+                +adminUin,
                 duration,
                 subType,
             );
@@ -98,8 +98,8 @@ export class OneBotGroupApi {
         }
         return new OB11GroupMsgEmojiLikeEvent(
             this.core,
-            parseInt(groupCode),
-            parseInt(senderUin),
+            +groupCode,
+            +senderUin,
             MessageUnique.getShortIdByMsgId(replyMsg.msgId)!,
             [{
                 emoji_id: emojiId,
@@ -111,9 +111,10 @@ export class OneBotGroupApi {
     async parseCardChangedEvent(msg: RawMessage) {
         if (msg.senderUin && msg.senderUin !== '0') {
             const member = await this.core.apis.GroupApi.getGroupMember(msg.peerUid, msg.senderUin);
-            if (member && member.cardName !== msg.sendMemberName) {
+            const oldName = member?.cardName || member?.nick || '';
+            if (member && oldName !== msg.sendMemberName) {
                 const newCardName = msg.sendMemberName ?? '';
-                const event = new OB11GroupCardEvent(this.core, parseInt(msg.peerUid), parseInt(msg.senderUin), newCardName, member.cardName);
+                const event = new OB11GroupCardEvent(this.core, parseInt(msg.peerUid), parseInt(msg.senderUin), newCardName, oldName);
                 member.cardName = newCardName;
                 return event;
             }

src/onebot/index.ts

@@ -333,7 +333,7 @@ export class NapCatOneBot11Adapter {
                             this.core,
                             +requesterUin,
                             req.extWords,
-                            req.friendUid + '|' + req.reqTime
+                            req.reqTime
                         )
                     );
                 } catch (e) {
@@ -365,8 +365,7 @@ export class NapCatOneBot11Adapter {
                     if (notifyTime < this.bootTime) {
                         continue;
                     }
-
-                    const flag = notify.group.groupCode + '|' + notify.seq + '|' + notify.type;
+                    const flag = notify.seq;
                     this.context.logger.logDebug('收到群通知', notify);
                     if (
                         [GroupNotifyMsgType.REQUEST_JOIN_NEED_ADMINI_STRATOR_PASS].includes(notify.type) &&

src/onebot/types/data.ts

@@ -11,6 +11,17 @@ export interface OB11User {
     categoryName?: string; // 分组名称
     categoryId?: number; // 分组ID 999为特别关心
 }
+export interface Notify {
+    request_id: number;
+    invitor_uin: number;
+    invitor_nick?: string;
+    group_id?: number;
+    group_name?: string;
+    message?: string;
+    checked: boolean;
+    actor: number;
+    requester_nick?: string;
+}
 
 export enum OB11UserSex {
     male = 'male', // 男性