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

chore: remove debug

Browse Source
This commit is contained in:
手瓜一十雪 2024-07-23 10:12:20 +08:00
parent efb2be2f94
commit 8bf1a545d9
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -37,7 +37,7 @@ setTimeout(() => {
// const sendMessagePool: Record<string, ((sendSuccessMsg: RawMessage) => void | Promise<void>) | null> = {};// peerUid: callbackFunc
const sendSuccessCBMap: Record<string, ((sendSuccessMsg: RawMessage) => boolean | Promise<boolean>) | null> = {};// uuid: callbackFunc
// const sendSuccessCBMap: Record<string, ((sendSuccessMsg: RawMessage) => boolean | Promise<boolean>) | null> = {};// uuid: callbackFunc
const GroupFileInfoUpdateTasks: Map<string, ((groupFileListResult: onGroupFileInfoUpdateParamType) => void)> = new Map();
@ -66,26 +66,26 @@ msgListener.onGroupFileInfoUpdate = (groupFileListResult: onGroupFileInfoUpdateP
// }
// };
msgListener.onMsgInfoListUpdate = (msgInfoList: RawMessage[]) => {
msgInfoList.forEach(msg => {
new Promise((resolve, reject) => {
for (const cbId in sendSuccessCBMap) {
const cb = sendSuccessCBMap[cbId]!;
const cbResult = cb(msg);
const checkResult = (result: boolean) => {
if (result) {
delete sendSuccessCBMap[cbId];
}
};
if (cbResult instanceof Promise) {
cbResult.then(checkResult);
} else {
checkResult(cbResult);
}
}
}).then().catch(log);
});
};
// msgListener.onMsgInfoListUpdate = (msgInfoList: RawMessage[]) => {
// msgInfoList.forEach(msg => {
// new Promise((resolve, reject) => {
// for (const cbId in sendSuccessCBMap) {
// const cb = sendSuccessCBMap[cbId]!;
// const cbResult = cb(msg);
// const checkResult = (result: boolean) => {
// if (result) {
// delete sendSuccessCBMap[cbId];
// }
// };
// if (cbResult instanceof Promise) {
// cbResult.then(checkResult);
// } else {
// checkResult(cbResult);
// }
// }
// }).then().catch(log);
// });
// };