GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-21 09:36:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: 部分离谱情况

Browse Source
This commit is contained in:
手瓜一十雪 2024-10-16 20:49:12 +08:00
parent 3f20733e7e
commit 659aa005b0
1 changed files with 26 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/core/apis/group.ts
View File

@ -318,23 +318,33 @@ export class NTQQGroupApi {
async getGroupMembersV2(groupQQ: string, num = 3000): Promise<Map<string, GroupMember>> {
const sceneId = this.context.session.getGroupService().createMemberListScene(groupQQ, 'groupMemberList_MainWindow');
try {
const [callback, listener] = await this.core.eventWrapper.callNormalEventV2(
'NodeIKernelGroupService/getNextMemberList',
'NodeIKernelGroupListener/onMemberListChange',
[sceneId, undefined, num],
(ret) => ret.errCode === 0,
(params) => params.sceneId === sceneId,
1,
2000
);
if(callback.result.infos.size === 0) {
return listener.infos;
}
return callback.result.infos;
} finally {
this.context.session.getGroupService().destroyMemberListScene(sceneId);
let once = this.core.eventWrapper.registerListen('NodeIKernelGroupListener/onMemberListChange', 1, 2000, (params) => params.sceneId === sceneId)
.catch();
const result = await this.context.session.getGroupService().getNextMemberList(sceneId!, undefined, num);
if (result.errCode !== 0) {
throw new Error('获取群成员列表出错,' + result.errMsg);
}
if (result.result.infos.size === 0) {
return (await once)[0].infos;
}
return result.result.infos;
// try {
// const [callback, listener] = await this.core.eventWrapper.callNormalEventV2(
// 'NodeIKernelGroupService/getNextMemberList',
// 'NodeIKernelGroupListener/onMemberListChange',
// [sceneId, undefined, num],
// (ret) => ret.errCode === 0,
// (params) => params.sceneId === sceneId,
// 1,
// 2000
// );
// if (callback.result.infos.size === 0) {
// return listener.infos;
// }
// return callback.result.infos;
// } finally {
// this.context.session.getGroupService().destroyMemberListScene(sceneId);
// }
}
async getGroupMembers(groupQQ: string, num = 3000): Promise<Map<string, GroupMember>> {