release: 2.1.0

Support: 9.9.15-27254

.github/workflows/release.yml

@@ -30,34 +30,34 @@ jobs:
               ls
               node ./script/checkVersion.cjs
               sh ./checkVersion.sh
-  Build-LiteLoader:
+  # Build-LiteLoader:
-    needs: [check-version]
+  #   needs: [check-version]
-    runs-on: ubuntu-latest
+  #   runs-on: ubuntu-latest
-    steps:
+  #   steps:
-    - name: Clone Main Repository
+  #   - name: Clone Main Repository
-      uses: actions/checkout@v4
+  #     uses: actions/checkout@v4
-      with:
+  #     with:
-          repository: 'NapNeko/NapCatQQ'
+  #         repository: 'NapNeko/NapCatQQ'
-          submodules: true
+  #         submodules: true
-          ref: main
+  #         ref: main
-          token: ${{ secrets.NAPCAT_BUILD }}
+  #         token: ${{ secrets.NAPCAT_BUILD }}
-    - name: Use Node.js 20.X
+  #   - name: Use Node.js 20.X
-      uses: actions/setup-node@v4
+  #     uses: actions/setup-node@v4
-      with:
+  #     with:
-          node-version: 20.x
+  #         node-version: 20.x
 
-    - name: Build NuCat Framework
+  #   - name: Build NuCat Framework
-      run: |
+  #     run: |
-          npm i
+  #         npm i
-          npm run build:framework
+  #         npm run build:framework
-          cd dist
+  #         cd dist
-          npm i --omit=dev
+  #         npm i --omit=dev
-          cd ..
+  #         cd ..
-    - name: Upload Artifact
+  #   - name: Upload Artifact
-      uses: actions/upload-artifact@v4
+  #     uses: actions/upload-artifact@v4
-      with:
+  #     with:
-        name: NapCat.Framework
+  #       name: NapCat.Framework
-        path: dist
+  #       path: dist
   Build-Shell:
     runs-on: ubuntu-latest
     needs: [check-version]
@@ -90,24 +90,31 @@ jobs:
               path: dist
 
   release-napcat:
-    needs: [Build-LiteLoader,Build-Shell]
+    needs: [Build-Shell]
+    # needs: [Build-LiteLoader,Build-Shell]
     runs-on: ubuntu-latest
     steps:
     - name: Download All Artifact
       uses: actions/download-artifact@v4
-    
     - name: Compress subdirectories
       run: |
         cd ./NapCat.Shell/
         zip -q -r NapCat.Shell.zip *
         cd ..
-        cd ./NapCat.Framework/
-        zip -q -r NapCat.Framework.zip *
-        cd ..
         rm ./NapCat.Shell.zip -rf
-        rm ./NapCat.Framework.zip -rf
         mv ./NapCat.Shell/NapCat.Shell.zip ./
-        mv ./NapCat.Framework/NapCat.Framework.zip ./
+    # - name: Compress subdirectories
+    #   run: |
+    #     cd ./NapCat.Shell/
+    #     zip -q -r NapCat.Shell.zip *
+    #     cd ..
+    #     cd ./NapCat.Framework/
+    #     zip -q -r NapCat.Framework.zip *
+    #     cd ..
+    #     rm ./NapCat.Shell.zip -rf
+    #     rm ./NapCat.Framework.zip -rf
+    #     mv ./NapCat.Shell/NapCat.Shell.zip ./
+    #     mv ./NapCat.Framework/NapCat.Framework.zip ./
     - name: Extract version from tag
       run: echo "VERSION=${GITHUB_REF#refs/tags/v}" >> $GITHUB_ENV
       
@@ -121,6 +128,5 @@ jobs:
         token: ${{ secrets.GITHUB_TOKEN }}
         body_path: CHANGELOG.md
         files: |
-          NapCat.Framework.zip
           NapCat.Shell.zip
         draft: true

README.md

@@ -4,7 +4,9 @@
 
 ---
 ## To Be Continued
-当前版本请使用低于27187 (不包含) 高于26702 (包含) 的QQ版本运行
+当前版本请使用内核构建版本（版本号最后的五位数）为 26702 至 26909 的 PC NTQQ 运行。
+
+高版本QQ NapCat已完成兼容 暂时不发布 直至版本2.0.x结束。
 
 ## 项目介绍
 NapCatQQ 是现代化的基于 NTQQ 的 Bot 协议端实现。
@@ -12,6 +14,7 @@ NapCatQQ 是现代化的基于 NTQQ 的 Bot 协议端实现。
 ## 项目优势
 - [x] **多种启动方式**：支持以无头、LiteLoader 插件、仅 QQ GUI 三种方式启动
 - [x] **低占用**：无头模式占用资源极低，适合在服务器上运行
+- [x] **超多接口**：在实现大部分Onebot接口上扩展了一套私有API
 - [x] **WebUI**：自带 WebUI 支持，远程管理更加便捷
 
 ## 如何使用

manifest.json

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

package.json

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

src/common/framework/event-legacy.ts

@@ -16,16 +16,13 @@ export interface ListenerIBase {
 }
 
 export class LegacyNTEventWrapper {
-    private listenerMapping: Record<string, ListenerIBase>; //ListenerName-Unique -> Listener构造函数
     private WrapperSession: NodeIQQNTWrapperSession | undefined; //WrapperSession
     private listenerManager: Map<string, ListenerClassBase> = new Map<string, ListenerClassBase>(); //ListenerName-Unique -> Listener实例
     private EventTask = new Map<string, Map<string, Map<string, Internal_MapKey>>>(); //tasks ListenerMainName -> ListenerSubName-> uuid -> {timeout,createtime,func}
 
     constructor(
-        listenerMapping: Record<string, ListenerIBase>,
+        wrapperSession: NodeIQQNTWrapperSession
-        wrapperSession: NodeIQQNTWrapperSession,
     ) {
-        this.listenerMapping = listenerMapping;
         this.WrapperSession = wrapperSession;
     }
 
@@ -72,18 +69,17 @@ export class LegacyNTEventWrapper {
     }
 
     createListenerFunction<T>(listenerMainName: string, uniqueCode: string = ''): T {
-        const ListenerType = this.listenerMapping![listenerMainName];
+        let existListener = this.listenerManager.get(listenerMainName + uniqueCode);
-        let Listener = this.listenerManager.get(listenerMainName + uniqueCode);
+        if (!existListener) {
-        if (!Listener && ListenerType) {
+            let Listener = this.createProxyDispatch(listenerMainName);
-            Listener = new ListenerType(this.createProxyDispatch(listenerMainName));
             const ServiceSubName = listenerMainName.match(/^NodeIKernel(.*?)Listener$/)![1];
             const Service = 'NodeIKernel' + ServiceSubName + 'Service/addKernel' + ServiceSubName + 'Listener';
             const addfunc = this.createEventFunction<(listener: T) => number>(Service);
             addfunc!(Listener as T);
-            //console.log(addfunc!(Listener as T));
             this.listenerManager.set(listenerMainName + uniqueCode, Listener);
+            return Listener as T;
         }
-        return Listener as T;
+        return existListener as T;
     }
 
     //统一回调清理事件

src/common/framework/napcat.ts

@@ -2,7 +2,7 @@ import path, { dirname } from 'path';
 import { fileURLToPath } from 'url';
 import fs from 'fs';
 
-export const napcat_version = '2.0.32';
+export const napcat_version = '2.1.0';
 
 export class NapCatPathWrapper {
     binaryPath: string;

src/common/utils/QQBasicInfo.ts

@@ -74,7 +74,7 @@ export class QQBasicInfoWrapper {
         this.context.logger.log(
             `[QQ版本兼容性检测] ${this.getFullQQVesion()} 版本兼容性不佳，可能会导致一些功能无法正常使用`,
         );
-        return { appid: systemPlatform === 'linux' ? '537237950' : '537237765', qua: this.getQUAInternal() };
+        return { appid: systemPlatform === 'linux' ? '537240645' : '537240610', qua: this.getQUAInternal() };
     }
 }
 

src/common/utils/file.ts

@@ -259,7 +259,7 @@ export async function uri2local(dir: string, uri: string, filename: string | und
         if (success) {
             filePath = fileTypePath;
             fileExt = ext;
-            filename = path.basename(filePath, fileExt);
+            filename = filename + '.' + ext;
         }
         return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: filePath, isLocal: true };
     }

src/common/utils/helper.ts

@@ -97,19 +97,19 @@ export function isEqual(obj1: any, obj2: any) {
 export function getDefaultQQVersionConfigInfo(): QQVersionConfigType {
     if (os.platform() === 'linux') {
         return {
-            baseVersion: '3.2.12-26702',
+            baseVersion: '3.2.12-27206',
-            curVersion: '3.2.12-26702',
+            curVersion: '3.2.12-27206',
             prevVersion: '',
             onErrorVersions: [],
-            buildId: '26702',
+            buildId: '27206',
         };
     }
     return {
-        baseVersion: '9.9.15-26702',
+        baseVersion: '9.9.15-27206',
-        curVersion: '9.9.15-26702',
+        curVersion: '9.9.15-27206',
         prevVersion: '',
         onErrorVersions: [],
-        buildId: '26702',
+        buildId: '27206',
     };
 }
 

src/core/apis/group.ts

@@ -261,7 +261,7 @@ export class NTQQGroupApi {
         (
             'NodeIKernelGroupListener/onMemberInfoChange',
             1,
-            forced ? 5000 : 500,
+            forced ? 5000 : 250,
             (params) => {
                 return params === GroupCode;
             },
@@ -269,7 +269,7 @@ export class NTQQGroupApi {
         const EventFunc = this.core.eventWrapper.createEventFunction<EventType>('NodeIKernelGroupService/getMemberInfo');
         const retData = await EventFunc!(GroupCode, [uid], forced);
         if (retData.result !== 0) {
-            throw new Error(`获取群成员信息失败: ${retData.errMsg}`);
+            throw new Error(`${retData.errMsg}`);
         }
         const result = await Listener as unknown;
         let member: GroupMember | undefined;

src/core/apis/user.ts

@@ -120,20 +120,23 @@ export class NTQQUserApi {
             ...profile.simpleInfo.vasInfo,
             ...profile.commonExt,
             ...profile.simpleInfo.baseInfo,
-            qqLevel: profile.commonExt.qqLevel,
+            qqLevel: profile.commonExt?.qqLevel,
             age: profile.simpleInfo.baseInfo.age,
             pendantId: '',
         };
         return RetUser;
     }
 
-    async getUserDetailInfo(uid: string) {
+    async getUserDetailInfo(uid: string): Promise<User> {
-        const ret = await this.fetchUserDetailInfo(uid, UserDetailSource.KDB);
+        try {
-        if (ret.uin === '0') {
+            let retUser = await this.fetchUserDetailInfo(uid, UserDetailSource.KDB);
-            console.log('[NapCat] [Mark] getUserDetailInfo Mode1 Failed.')
+            if (retUser.uin !== '0') {
-            return await this.fetchUserDetailInfo(uid, UserDetailSource.KSERVER);
+                return retUser;
+            }
+        } catch (e) {
         }
-        return ret;
+        this.context.logger.logDebug('[NapCat] [Mark] getUserDetailInfo Mode1 Failed.');
+        return this.fetchUserDetailInfo(uid, UserDetailSource.KSERVER);
     }
 
     async modifySelfProfile(param: ModifyProfileParams) {
@@ -207,9 +210,9 @@ export class NTQQUserApi {
 
     //后期改成流水线处理
     async getUinByUidV2(Uid: string) {
-        let uin = (await this.context.session.getProfileService().getUinByUid('FriendsServiceImpl', [Uid])).get(Uid);
+        let uin = (await this.context.session.getGroupService().getUinByUids([Uid])).uins.get(Uid);
         if (uin) return uin;
-        uin = (await this.context.session.getGroupService().getUinByUids([Uid])).uins.get(Uid);
+        uin = (await this.context.session.getProfileService().getUinByUid('FriendsServiceImpl', [Uid])).get(Uid);
         if (uin) return uin;
         uin = (await this.context.session.getUixConvertService().getUin([Uid])).uinInfo.get(Uid);
         if (uin) return uin;

src/core/core.ts

@@ -44,8 +44,8 @@ export class NapCatCore {
     constructor(context: InstanceContext, selfInfo: SelfInfo) {
         this.selfInfo = selfInfo;
         this.context = context;
-        this.util = new this.context.wrapper.NodeQQNTWrapperUtil();
+        this.util = this.context.wrapper.NodeQQNTWrapperUtil;
-        this.eventWrapper = new LegacyNTEventWrapper(context.wrapper, context.session);
+        this.eventWrapper = new LegacyNTEventWrapper(context.session);
         this.apis = {
             FileApi: new NTQQFileApi(this.context, this),
             SystemApi: new NTQQSystemApi(this.context, this),
@@ -79,7 +79,7 @@ export class NapCatCore {
     }
 
     get dataPath(): string {
-        let result = this.util.getNTUserDataInfoConfig();
+        let result = this.context.wrapper.NodeQQNTWrapperUtil.getNTUserDataInfoConfig();
         if (!result) {
             result = path.resolve(os.homedir(), './.config/QQ');
             fs.mkdirSync(result, { recursive: true });
@@ -98,7 +98,7 @@ export class NapCatCore {
         };
         //await sleep(2500);
         this.context.session.getMsgService().addKernelMsgListener(
-            new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msgListener, this.context.logger)),
+            proxiedListenerOf(msgListener, this.context.logger) as any
         );
 
         const profileListener = new ProfileListener();
@@ -113,7 +113,7 @@ export class NapCatCore {
             // }
         };
         this.context.session.getProfileService().addKernelProfileListener(
-            new this.context.wrapper.NodeIKernelProfileListener(proxiedListenerOf(profileListener, this.context.logger)),
+            proxiedListenerOf(profileListener, this.context.logger),
         );
 
         // 群相关
@@ -196,6 +196,9 @@ export class NapCatCore {
                 this.apis.GroupApi.groupMemberCache.set(groupCode, members);
             }
         };
+        this.context.session.getGroupService().addKernelGroupListener(
+            proxiedListenerOf(profileListener, this.context.logger) as any
+        );
     }
     checkAdminEvent(groupCode: string, memberNew: GroupMember, memberOld: GroupMember | undefined): boolean {
         if (memberNew.role !== memberOld?.role) {

src/core/external/appid.json

@@ -1,58 +1,26 @@
 {
-    "3.1.2-13107": {
+    "3.2.12-27187": {
-        "appid": 537146866,
+        "appid": 537240645,
-        "qua": "V1_LNX_NQ_3.1.2-13107_RDM_B"
+        "qua": "V1_LNX_NQ_3.2.12_27187_GW_B"
     },
-    "3.2.10-25765": {
+    "3.2.12-27206": {
-        "appid": 537234773,
+        "appid": 537240645,
-        "qua": "V1_LNX_NQ_3.2.10_25765_GW_B"
+        "qua": "V1_LNX_NQ_3.2.12_27206_GW_B"
     },
-    "3.2.12-26702": {
+    "3.2.12-27254":{
-        "appid": 537237950,
+        "appid": 537240795,
-        "qua": "V1_LNX_NQ_3.2.12_26702_GW_B"
+        "qua": "V1_LNX_NQ_3.2.12_27254_GW_B"
     },
-    "3.2.12-26740": {
+    "9.9.15-27187":{
-        "appid": 537237950,
+        "appid": 537240610,
-        "qua": "V1_WIN_NQ_9.9.15_26740_GW_B"
+        "qua": "V1_WIN_NQ_9.9.15_27187_GW_B"
     },
-    "3.2.12-26909": {
+    "9.9.15-27206":{
-        "appid": 537237923,
+        "appid": 537240610,
-        "qua": "V1_LNX_NQ_3.2.12_26909_GW_B"
+        "qua": "V1_WIN_NQ_9.9.15_27206_GW_B"
     },
-    "9.9.11-24815": {
+    "9.9.15-27254":{
-        "appid": 537226656,
+        "appid": 537240709,
-        "qua": "V1_WIN_NQ_9.9.11_24815_GW_B"
+        "qua": "V1_WIN_NQ_9.9.15_27254_GW_B"
-    },
-    "9.9.12-25493": {
-        "appid": 537231759,
-        "qua": "V1_WIN_NQ_9.9.12_25493_GW_B"
-    },
-    "9.9.12-25765": {
-        "appid": 537234702,
-        "qua": "V1_WIN_NQ_9.9.12_25765_GW_B"
-    },
-    "9.9.12-26299": {
-        "appid": 537234826,
-        "qua": "V1_WIN_NQ_9.9.12_26299_GW_B"
-    },
-    "9.9.12-26339": {
-        "appid": 537234826,
-        "qua": "V1_WIN_NQ_9.9.12_26339_GW_B"
-    },
-    "9.9.12-26466": {
-        "appid": 537234826,
-        "qua": "V1_WIN_NQ_9.9.12_26466_GW_B"
-    },
-    "9.9.15-26702": {
-        "appid": 537237765,
-        "qua": "V1_WIN_NQ_9.9.15_26702_GW_B"
-    },
-    "9.9.15-26740": {
-        "appid": 537237765,
-        "qua": "V1_WIN_NQ_9.9.15_26702_GW_B"
-    },
-    "9.9.15-26909": {
-        "appid": 537237802,
-        "qua": "V1_WIN_NQ_9.9.15_26909_GW_B"
     }
 }

src/core/listeners/NodeIKernelGroupListener.ts

@@ -1,6 +1,6 @@
 import { Group, GroupListUpdateType, GroupMember, GroupNotify } from '@/core/entities';
 
-interface IGroupListener {
+export interface IGroupListener {
     onGroupListUpdate(updateType: GroupListUpdateType, groupList: Group[]): void;
 
     onGroupExtListUpdate(...args: unknown[]): void;

src/core/services/NodeIKernelGroupService.ts

@@ -1,4 +1,4 @@
-import { NodeIKernelGroupListener } from '@/core/listeners/NodeIKernelGroupListener';
+import { IGroupListener, NodeIKernelGroupListener } from '@/core/listeners/NodeIKernelGroupListener';
 import {
     GroupExtParam,
     GroupMember,
@@ -104,7 +104,7 @@ export interface NodeIKernelGroupService {
 
     setHeader(uid: string, path: string): unknown;
 
-    addKernelGroupListener(listener: NodeIKernelGroupListener): number;
+    addKernelGroupListener(listener: IGroupListener): number;
 
     removeKernelGroupListener(listenerId: unknown): void;
 

src/core/services/NodeIKernelProfileService.ts

@@ -1,6 +1,6 @@
 import { AnyCnameRecord } from 'node:dns';
 import { BizKey, ModifyProfileParams, SimpleInfo, UserDetailInfoByUin } from '../entities';
-import { NodeIKernelProfileListener } from '../listeners';
+import { NodeIKernelProfileListener, ProfileListener } from '../listeners';
 import { GeneralCallResult } from '@/core/services/common';
 
 export enum UserDetailSource {
@@ -35,7 +35,7 @@ export interface NodeIKernelProfileService {
 
     fetchUserDetailInfo(trace: string, uids: string[], arg2: number, arg3: number[]): Promise<unknown>;
 
-    addKernelProfileListener(listener: NodeIKernelProfileListener): number;
+    addKernelProfileListener(listener: ProfileListener): number;
 
     removeKernelProfileListener(listenerId: number): void;
 

src/core/wrapper/wrapper.ts

@@ -35,6 +35,7 @@ import { NodeIkernelTestPerformanceService } from '../services/NodeIkernelTestPe
 import { NodeIKernelECDHService } from '../services/NodeIKernelECDHService';
 
 export interface NodeQQNTWrapperUtil {
+    get(): unknown;
     // eslint-disable-next-line @typescript-eslint/no-misused-new
     new(): NodeQQNTWrapperUtil;
 

src/framework/napcat.ts

@@ -41,8 +41,7 @@ export async function NCoreInitFramework(
                 online: true,
             });
         };
-        loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
+        loginService.addKernelLoginListener(proxiedListenerOf(loginListener, logger) as any);
-            proxiedListenerOf(loginListener, logger)));
     });
     // 过早进入会导致addKernelMsgListener等Listener添加失败
     // await sleep(2500);

src/onebot/action/extends/SetSelfProfile.ts

@@ -1,32 +0,0 @@
-import BaseAction from '../BaseAction';
-import { ActionName } from '../types';
-import { FromSchema, JSONSchema } from 'json-schema-to-ts';
-
-const SchemaData = {
-    type: 'object',
-    properties: {
-        nick: { type: 'string' },
-        longNick: { type: 'string' },
-        sex: { type: ['number', 'string'] },//传Sex值？建议传0
-    },
-    required: ['nick', 'longNick', 'sex'],
-} as const satisfies JSONSchema;
-
-type Payload = FromSchema<typeof SchemaData>;
-
-export class SetSelfProfile extends BaseAction<Payload, any | null> {
-    actionName = ActionName.SetSelfProfile;
-    PayloadSchema = SchemaData;
-
-    async _handle(payload: Payload) {
-        const NTQQUserApi = this.CoreContext.apis.UserApi;
-        const ret = await NTQQUserApi.modifySelfProfile({
-            nick: payload.nick,
-            longNick: payload.longNick,
-            sex: parseInt(payload.sex.toString()),
-            birthday: { birthday_year: '', birthday_month: '', birthday_day: '' },
-            location: undefined,
-        });
-        return ret;
-    }
-}

src/onebot/action/go-cqhttp/SetGroupPortrait.ts

@@ -7,18 +7,18 @@ import { checkFileReceived, uri2local } from '@/common/utils/file';
 
 interface Payload {
     file: string,
-    groupCode: string
+    group_id: number
 }
 
-export default class SetGroupHeader extends BaseAction<Payload, any> {
+export default class SetGroupPortrait extends BaseAction<Payload, any> {
-    actionName = ActionName.SetGroupHeader;
+    actionName = ActionName.SetGroupPortrait;
 
     // 用不着复杂检测
     protected async check(payload: Payload): Promise<BaseCheckResult> {
-        if (!payload.file || typeof payload.file != 'string' || !payload.groupCode || typeof payload.groupCode != 'string') {
+        if (!payload.file || typeof payload.file != 'string' || !payload.group_id || typeof payload.group_id != 'number') {
             return {
                 valid: false,
-                message: 'file和groupCode字段不能为空或者类型错误',
+                message: 'file和group_id字段不能为空或者类型错误',
             };
         }
         return {
@@ -34,7 +34,7 @@ export default class SetGroupHeader extends BaseAction<Payload, any> {
         }
         if (path) {
             await checkFileReceived(path, 5000); // 文件不存在QQ会崩溃，需要提前判断
-            const ret = await NTQQGroupApi.setGroupAvatar(payload.groupCode, path);
+            const ret = await NTQQGroupApi.setGroupAvatar(payload.group_id.toString(), path) as any;
             if (!isLocal) {
                 fs.unlink(path, () => {
                 });
@@ -43,11 +43,11 @@ export default class SetGroupHeader extends BaseAction<Payload, any> {
                 throw `头像${payload.file}设置失败,api无返回`;
             }
             // log(`头像设置返回：${JSON.stringify(ret)}`)
-            // if (ret['result'] == 1004022) {
+            if (ret['result'] == 1004022) {
-            //   throw `头像${payload.file}设置失败，文件可能不是图片格式`;
+              throw `头像${payload.file}设置失败，文件可能不是图片格式或权限不足`;
-            // } else if (ret['result'] != 0) {
+            } else if (ret['result'] != 0) {
-            //   throw `头像${payload.file}设置失败,未知的错误,${ret['result']}:${ret['errMsg']}`;
+              throw `头像${payload.file}设置失败,未知的错误,${ret['result']}:${ret['errMsg']}`;
-            // }
+            }
             return ret;
         } else {
             if (!isLocal) {

src/onebot/action/go-cqhttp/SetQQProfile.ts

@@ -0,0 +1,34 @@
+import BaseAction from '../BaseAction';
+import { ActionName } from '../types';
+import { FromSchema, JSONSchema } from 'json-schema-to-ts';
+
+const SchemaData = {
+    type: 'object',
+    properties: {
+        nickname: { type: 'string' },
+        personal_note: { type: 'string' },
+        sex: { type: ['number', 'string'] },//传Sex值？建议传0
+    },
+    required: ['nickname'],
+} as const satisfies JSONSchema;
+
+type Payload = FromSchema<typeof SchemaData>;
+
+export class SetQQProfile extends BaseAction<Payload, any | null> {
+    actionName = ActionName.SetQQProfile;
+    PayloadSchema = SchemaData;
+
+    async _handle(payload: Payload) {
+        const NTQQUserApi = this.CoreContext.apis.UserApi;
+        const self = this.CoreContext.selfInfo;
+        const OldProfile = await NTQQUserApi.getUserDetailInfo(self.uid);
+        const ret = await NTQQUserApi.modifySelfProfile({
+            nick: payload.nickname,
+            longNick: payload?.personal_note ?? OldProfile?.longNick!,
+            sex: parseInt(payload?.sex ? payload?.sex.toString() : OldProfile?.sex!.toString()),
+            birthday: { birthday_year: OldProfile?.birthday_year!.toString(), birthday_month: OldProfile?.birthday_month!.toString(), birthday_day: OldProfile?.birthday_day!.toString() },
+            location: undefined,
+        });
+        return ret;
+    }
+}

src/onebot/action/group/GetGroupMemberInfo.ts

@@ -3,6 +3,7 @@ import { OB11Constructor } from '../../helper/data';
 import BaseAction from '../BaseAction';
 import { ActionName } from '../types';
 import { FromSchema, JSONSchema } from 'json-schema-to-ts';
+import { GroupMember } from '@/core';
 
 const SchemaData = {
     type: 'object',
@@ -23,23 +24,25 @@ class GetGroupMemberInfo extends BaseAction<Payload, OB11GroupMember> {
     async _handle(payload: Payload) {
         const NTQQUserApi = this.CoreContext.apis.UserApi;
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
-        const NTQQWebApi = this.CoreContext.apis.WebApi;
         const isNocache = typeof payload.no_cache === 'string' ? payload.no_cache === 'true' : !!payload.no_cache;
         const uid = await NTQQUserApi.getUidByUinV2(payload.user_id.toString());
         if (!uid) throw (`Uin2Uid Error ${payload.user_id}不存在`);
-        const member = await NTQQGroupApi.getGroupMemberV2(payload.group_id.toString(), uid, isNocache);
+        const [member, info] = await Promise.allSettled([
-        if (!member) throw (`群(${payload.group_id})成员${payload.user_id}不存在`);
+            NTQQGroupApi.getGroupMemberV2(payload.group_id.toString(), uid, isNocache),
-        try {
+            NTQQUserApi.getUserDetailInfo(uid),
-            const info = (await NTQQUserApi.getUserDetailInfo(member.uid));
+        ]);
-            this.CoreContext.context.logger.logDebug('群成员详细信息结果', info);
+        if (member.status !== 'fulfilled') throw (`群(${payload.group_id})成员${payload.user_id}不存在 ${member.reason}`);
-            Object.assign(member, info);
+        if (info.status === 'fulfilled') {
-        } catch (e) {
+            this.CoreContext.context.logger.logDebug("群成员详细信息结果", info.value);
-            this.CoreContext.context.logger.logDebug('获取群成员详细信息失败, 只能返回基础信息', e);
+            Object.assign(member, info.value);
+        } else {
+            this.CoreContext.context.logger.logDebug(`获取群成员详细信息失败, 只能返回基础信息 ${info.reason}`);
         }
         const date = Math.round(Date.now() / 1000);
-        const retMember = OB11Constructor.groupMember(payload.group_id.toString(), member);
+        const retMember = OB11Constructor.groupMember(payload.group_id.toString(), member.value as GroupMember);
-        retMember.last_sent_time = parseInt((await this.CoreContext.apis.GroupApi.getGroupMember(payload.group_id.toString(), retMember.user_id))?.lastSpeakTime || date.toString());
+        const Member = await this.CoreContext.apis.GroupApi.getGroupMember(payload.group_id.toString(), retMember.user_id);
-        retMember.join_time = parseInt((await this.CoreContext.apis.GroupApi.getGroupMember(payload.group_id.toString(), retMember.user_id))?.joinTime || date.toString());
+        retMember.last_sent_time = parseInt(Member?.lastSpeakTime || date.toString());
+        retMember.join_time = parseInt(Member?.joinTime || date.toString());
         return retMember;
     }
 }

src/onebot/action/index.ts

@@ -61,7 +61,7 @@ import { TranslateEnWordToZn } from './extends/TranslateEnWordToZn';
 import { SetGroupFileFolder } from './file/SetGroupFileFolder';
 import { DelGroupFile } from './file/DelGroupFile';
 import { DelGroupFileFolder } from './file/DelGroupFileFolder';
-import { SetSelfProfile } from './extends/SetSelfProfile';
+import { SetQQProfile } from './go-cqhttp/SetQQProfile'
 import { ShareGroupEx, SharePeer } from './extends/ShareContact';
 import { CreateCollection } from './extends/CreateCollection';
 import { SetLongNick } from './extends/SetLongNick';
@@ -69,7 +69,7 @@ import DelEssenceMsg from './group/DelEssenceMsg';
 import SetEssenceMsg from './group/SetEssenceMsg';
 import GetRecentContact from './user/GetRecentContact';
 import { GetProfileLike } from './extends/GetProfileLike';
-import SetGroupHeader from './extends/SetGroupHeader';
+import SetGroupPortrait from './go-cqhttp/SetGroupPortrait';
 import { FetchCustomFace } from './extends/FetchCustomFace';
 import GoCQHTTPUploadPrivateFile from './go-cqhttp/UploadPrivareFile';
 import { FetchEmojiLike } from './extends/FetchEmojiLike';
@@ -79,6 +79,7 @@ import { NapCatOneBot11Adapter } from '@/onebot';
 import GetGuildProfile from './guild/GetGuildProfile';
 import SetModelShow from './go-cqhttp/SetModelShow';
 import { SetInputStatus } from './extends/SetInputStatus';
+import { GetCSRF } from './system/GetCSRF';
 
 export type ActionMap = Map<string, BaseAction<any, any>>;
 
@@ -86,7 +87,7 @@ export function createActionMap(onebotContext: NapCatOneBot11Adapter, coreContex
     const actionHandlers = [
         new FetchEmojiLike(onebotContext, coreContext),
         new GetFile(onebotContext, coreContext),
-        new SetSelfProfile(onebotContext, coreContext),
+        new SetQQProfile(onebotContext, coreContext),
         new ShareGroupEx(onebotContext, coreContext),
         new SharePeer(onebotContext, coreContext),
         new CreateCollection(onebotContext, coreContext),
@@ -161,12 +162,13 @@ export function createActionMap(onebotContext: NapCatOneBot11Adapter, coreContex
         new GetRecentContact(onebotContext, coreContext),
         new MarkAllMsgAsRead(onebotContext, coreContext),
         new GetProfileLike(onebotContext, coreContext),
-        new SetGroupHeader(onebotContext, coreContext),
+        new SetGroupPortrait(onebotContext, coreContext),
         new FetchCustomFace(onebotContext, coreContext),
         new GoCQHTTPUploadPrivateFile(onebotContext, coreContext),
         new GetGuildProfile(onebotContext, coreContext),
         new SetModelShow(onebotContext, coreContext),
         new SetInputStatus(onebotContext, coreContext),
+        new GetCSRF(onebotContext, coreContext),
     ];
     const actionMap = new Map();
     for (const action of actionHandlers) {

src/onebot/action/msg/SendMsg/create-send-elements.ts

@@ -56,7 +56,7 @@ const _handlers: {
         if (atQQ === 'all') return SendMsgElementConstructor.at(coreContext, atQQ, atQQ, AtType.atAll, '全体成员');
 
         // then the qq is a group member
-        // Mlikiowa V2.0.32 Refactor Todo
+        // Mlikiowa V2.1.0 Refactor Todo
         const uid = await coreContext.apis.UserApi.getUidByUinV2(`${atQQ}`);
         if (!uid) throw new Error('Get Uid Error');
         return SendMsgElementConstructor.at(coreContext, atQQ, uid, AtType.atUser, '');
@@ -161,7 +161,7 @@ const _handlers: {
         } else {
             postData = data;
         }
-        // Mlikiowa V2.0.32 Refactor Todo
+        // Mlikiowa V2.1.0 Refactor Todo
         const signUrl = obContext.configLoader.configData.musicSignUrl;
         if (!signUrl) {
             if (data.type === 'qq') {

src/onebot/action/system/GetCSRF.ts

@@ -0,0 +1,12 @@
+import BaseAction from '../BaseAction';
+import { ActionName } from '../types';
+
+export class GetCSRF extends BaseAction<any, any> {
+    actionName = ActionName.GetCSRF;
+
+    async _handle(payload: any) {
+        return {
+            token: "",
+        };
+    }
+}

src/onebot/action/types.ts

@@ -91,7 +91,7 @@ export enum ActionName {
     GetOnlineClient = 'get_online_clients',
     OCRImage = 'ocr_image',
     IOCRImage = '.ocr_image',
-    SetSelfProfile = 'set_self_profile',
+    SetQQProfile = 'set_qq_profile',
     CreateCollection = 'create_collection',
     GetCollectionList = 'get_collection_list',
     SetLongNick = 'set_self_longnick',
@@ -100,12 +100,13 @@ export enum ActionName {
     GetRecentContact = 'get_recent_contact',
     _MarkAllMsgAsRead = '_mark_all_as_read',
     GetProfileLike = 'get_profile_like',
-    SetGroupHeader = 'set_group_head',
+    SetGroupPortrait = 'set_group_portrait',
     FetchCustomFace = 'fetch_custom_face',
     GOCQHTTP_UploadPrivateFile = 'upload_private_file',
     TestApi01 = 'test_api_01',
     FetchEmojiLike = 'fetch_emoji_like',
     GetGuildProfile = "get_guild_service_profile",
     SetModelShow = "_set_model_show",
-    SetInputStatus = "set_input_status"
+    SetInputStatus = "set_input_status",
+    GetCSRF = "get_csrf_token",
 }

src/onebot/helper/data.ts

@@ -30,6 +30,7 @@ import { EventType } from '../event/OB11BaseEvent';
 import { encodeCQCode } from './cqcode';
 import { OB11GroupIncreaseEvent } from '../event/notice/OB11GroupIncreaseEvent';
 import { OB11GroupBanEvent } from '../event/notice/OB11GroupBanEvent';
+import { OB11GroupCardEvent } from '../event/notice/OB11GroupCardEvent';
 import { OB11GroupUploadNoticeEvent } from '../event/notice/OB11GroupUploadNoticeEvent';
 import { OB11GroupNoticeEvent } from '../event/notice/OB11GroupNoticeEvent';
 import { calcQQLevel, sleep, UUIDConverter } from '@/common/utils/helper';
@@ -149,7 +150,6 @@ export class OB11Constructor {
                 message_data['type'] = OB11MessageDataType.reply;
                 //log("收到回复消息", element.replyElement);
                 try {
-                    let oldMsgFlag = false;
                     const records = msg.records.find(msgRecord => msgRecord.msgId === element?.replyElement?.sourceMsgIdInRecords);
                     const peer = {
                         chatType: msg.chatType,
@@ -164,14 +164,17 @@ export class OB11Constructor {
                         chatType: msg.chatType,
                     }, element.replyElement.replayMsgSeq, 1, true, true)).msgList.find(msg => msg.msgRandom === records.msgRandom);
                     if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
-                        if (!replyMsg && records.msgRandom === '0') oldMsgFlag = true;
                         replyMsg = (await NTQQMsgApi.getSingleMsg(peer, element.replyElement.replayMsgSeq)).msgList[0];
                     }
                     if (msg.peerUin == '284840486') {
                         //合并消息内侧 消息具体定位不到
                     }
-                    if ((!replyMsg || (records.msgRandom !== replyMsg.msgRandom && !oldMsgFlag || (oldMsgFlag && records.msgSeq !== replyMsg.msgSeq))) && msg.peerUin !== '284840486') {
+                    if ((!replyMsg || records.msgRandom !== replyMsg.msgRandom) && msg.peerUin !== '284840486') {
-                        throw new Error('回复消息消息验证失败');
+                        const replyMsgList = (await NTQQMsgApi.getMsgExBySeq(peer, records.msgSeq)).msgList;
+                        if (replyMsgList.length < 1) {
+                            throw new Error('回复消息消息验证失败');
+                        }
+                        replyMsg = replyMsgList.filter(e => e.msgSeq == records.msgSeq).sort((a, b) => parseInt(a.msgTime) - parseInt(b.msgTime))[0];
                     }
                     message_data['data']['id'] = MessageUnique.createMsg({
                         peerUid: msg.peerUid,
@@ -419,16 +422,15 @@ export class OB11Constructor {
             return;
         }
         //log("group msg", msg);
-        // Mlikiowa V2.0.32 Refactor Todo
+        if (msg.senderUin && msg.senderUin !== '0') {
-        // if (msg.senderUin && msg.senderUin !== '0') {
+          const member = await NTQQGroupApi.getGroupMember(msg.peerUid, msg.senderUin);
-        //   const member = await getGroupMember(msg.peerUid, msg.senderUin);
+          if (member && member.cardName !== msg.sendMemberName) {
-        //   if (member && member.cardName !== msg.sendMemberName) {
+            const newCardName = msg.sendMemberName || '';
-        //     const newCardName = msg.sendMemberName || '';
+            const event = new OB11GroupCardEvent(core, parseInt(msg.peerUid), parseInt(msg.senderUin), newCardName, member.cardName);
-        //     const event = new OB11GroupCardEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), newCardName, member.cardName);
+            member.cardName = newCardName;
-        //     member.cardName = newCardName;
+            return event;
-        //     return event;
+          }
-        //   }
+        }
-        // }
 
         for (const element of msg.elements) {
             const grayTipElement = element.grayTipElement;

src/onebot/index.ts

@@ -9,6 +9,7 @@ import {
     NapCatCore,
     RawMessage,
     SendStatusType,
+    GroupMemberRole,
 } from '@/core';
 import { OB11Config, OB11ConfigLoader } from '@/onebot/helper/config';
 import { OneBotApiContextType } from '@/onebot/types';
@@ -274,7 +275,7 @@ export class NapCatOneBot11Adapter {
         };
 
         this.context.session.getMsgService().addKernelMsgListener(
-            new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msgListener, this.context.logger)),
+            proxiedListenerOf(msgListener, this.context.logger) as any
         );
     }
 
@@ -301,7 +302,7 @@ export class NapCatOneBot11Adapter {
         };
 
         this.context.session.getBuddyService().addKernelBuddyListener(
-            new this.context.wrapper.NodeIKernelBuddyListener(proxiedListenerOf(buddyListener, this.context.logger)),
+            proxiedListenerOf(buddyListener, this.context.logger) as any
         );
     }
 
@@ -413,8 +414,31 @@ export class NapCatOneBot11Adapter {
             }
         };
 
+        groupListener.onMemberInfoChange = async (groupCode, changeType, members) => {
+            //this.context.logger.logDebug('收到群成员信息变动通知', groupCode, changeType);
+            if (changeType === 0) {
+                const existMembers = this.core.apis.GroupApi.groupMemberCache.get(groupCode);
+                if (!existMembers) return;
+                members.forEach((member) => {
+                    const existMember = existMembers.get(member.uid);
+                    if (!existMember?.isChangeRole) return;
+                    this.context.logger.logDebug('变动管理员获取成功');
+                    const groupAdminNoticeEvent = new OB11GroupAdminNoticeEvent(
+                        this.core,
+                        parseInt(groupCode),
+                        parseInt(member.uin),
+                        member.role === GroupMemberRole.admin ? 'set' : 'unset',
+                    );
+                    this.networkManager.emitEvent(groupAdminNoticeEvent)
+                    .catch(e => this.context.logger.logError('处理群管理员变动失败', e));
+                    existMember.isChangeRole = false;
+                    this.context.logger.logDebug('群管理员变动处理完毕');
+                });
+            }
+        };
+
         this.context.session.getGroupService().addKernelGroupListener(
-            new this.context.wrapper.NodeIKernelGroupListener(proxiedListenerOf(groupListener, this.context.logger)),
+            proxiedListenerOf(groupListener, this.context.logger)
         );
     }
 

src/onebot/network/active-websocket.ts

@@ -71,6 +71,8 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
 
             this.connection = new WebSocket(this.url, {
                 maxPayload: 1024 * 1024 * 1024,
+                handshakeTimeout: 2000,
+                perMessageDeflate: false,
                 headers: {
                     'X-Self-ID': this.coreContext.selfInfo.uin,
                     'Authorization': `Bearer ${this.token}`,
@@ -79,6 +81,12 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
                 },
 
             });
+            this.connection.on('ping', () => {
+                this.connection?.pong();
+            });
+            this.connection.on('pong', () => {
+                //this.logger.logDebug('[OneBot] [WebSocket Client] 收到pong');
+            });
             this.connection.on('open', () => {
                 try {
                     this.connectEvent(this.coreContext);
@@ -128,6 +136,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
                 this.logger.logDebug('[OneBot] [WebSocket Client] 收到正向Websocket消息', receiveData);
             } catch (e) {
                 this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo));
+                return;
             }
             receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
             const retdata = await this.actions.get(receiveData.action)

src/onebot/network/passive-websocket.ts

@@ -36,7 +36,11 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
         this.logger = coreContext.context.logger;
 
         this.heartbeatInterval = heartbeatInterval;
-        this.wsServer = new WebSocketServer({ port: port, host: ip, maxPayload: 1024 * 1024 * 1024, });
+        this.wsServer = new WebSocketServer({
+            port: port,
+            host: ip,
+            maxPayload: 1024 * 1024 * 1024,
+        });
         const core = coreContext;
         this.wsServer.on('connection', async (wsClient, wsReq) => {
             if (!this.isOpen) {
@@ -50,6 +54,12 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
             wsClient.on('message', (message) => {
                 this.handleMessage(wsClient, message).then().catch(this.logger.logError);
             });
+            wsClient.on('ping', () => {
+                wsClient.pong();
+            });
+            wsClient.on('pong', () => {
+                //this.logger.logDebug('[OneBot] [WebSocket Server] Pong received');
+            });
             wsClient.once('close', () => {
                 this.wsClientsMutex.runExclusive(async () => {
                     const index = this.wsClients.indexOf(wsClient);
@@ -145,6 +155,7 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
                 //this.logger.logDebug('收到正向Websocket消息', receiveData);
             } catch (e) {
                 this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo), wsClient);
+                return;
             }
             receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
             const retdata = await this.actions.get(receiveData.action)?.websocketHandle(receiveData.params, echo || '');

src/shell/napcat.ts

@@ -43,12 +43,12 @@ export async function NCoreInitShell() {
 
     // from constructor
     const engine = new wrapper.NodeIQQNTWrapperEngine();
-    const util = new wrapper.NodeQQNTWrapperUtil();
+    //const util = wrapper.NodeQQNTWrapperUtil.get();
     const loginService = new wrapper.NodeIKernelLoginService();
     const session = new wrapper.NodeIQQNTWrapperSession();
 
     // from get dataPath
-    let dataPath = util.getNTUserDataInfoConfig();
+    let dataPath = wrapper.NodeQQNTWrapperUtil.getNTUserDataInfoConfig();
     if (!dataPath) {
         dataPath = path.resolve(os.homedir(), './.config/QQ');
         fs.mkdirSync(dataPath, { recursive: true });
@@ -70,7 +70,7 @@ export async function NCoreInitShell() {
             },
             thumb_config: { maxSide: 324, minSide: 48, longLimit: 6, density: 2 },
         },
-        new wrapper.NodeIGlobalAdapter(new GlobalAdapter()),
+        new GlobalAdapter() as any,
     );
     loginService.initConfig({
         machineId: '',
@@ -140,8 +140,7 @@ export async function NCoreInitShell() {
             logger.logError('[Core] [Login] Login Error , ErrInfo: ', args);
         };
 
-        loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
+        loginService.addKernelLoginListener(proxiedListenerOf(loginListener, logger) as any);
-            proxiedListenerOf(loginListener, logger)));
 
         // 实现WebUi快速登录
         loginService.getLoginList().then((res) => {
@@ -188,11 +187,10 @@ export async function NCoreInitShell() {
         } else {
             logger.log('没有 -q 指令指定快速登录，将使用二维码登录方式');
             if (historyLoginList.length > 0) {
-                logger.log(`可用于快速登录的 QQ：\n${
+                logger.log(`可用于快速登录的 QQ：\n${historyLoginList
-                    historyLoginList
+                    .map((u, index) => `${index + 1}. ${u.uin} ${u.nickName}`)
-                        .map((u, index) => `${index + 1}. ${u.uin} ${u.nickName}`)
+                    .join('\n')
-                        .join('\n')
+                    }`);
-                }`);
             }
             loginService.getQRCodePicture();
         }
@@ -220,9 +218,9 @@ export async function NCoreInitShell() {
         };
         session.init(
             sessionConfig,
-            new wrapper.NodeIDependsAdapter(new DependsAdapter()),
+            new DependsAdapter() as any,
-            new wrapper.NodeIDispatcherAdapter(new DispatcherAdapter()),
+            new DispatcherAdapter() as any,
-            new wrapper.NodeIKernelSessionListener(sessionListener),
+            sessionListener as any,
         );
         try {
             session.startNT(0);

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.0.32', 'napcat-update-button', 'secondary'),
+                    SettingButton('V2.1.0', '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.0.32", "napcat-update-button", "secondary")
+          SettingButton("V2.1.0", "napcat-update-button", "secondary")
         )
       ]),
       SettingList([