Northern_Lights/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2025-12-20 13:40:10 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
手瓜一十雪 2025-08-25 19:05:13 +08:00
parent c213cd6c3a
commit c4f9c4f630
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/onebot/index.ts
View File

@ -49,6 +49,7 @@ import {
import { OB11Message } from './types'; import { OB11Message } from './types';
import { IOB11NetworkAdapter } from '@/onebot/network/adapter'; import { IOB11NetworkAdapter } from '@/onebot/network/adapter';
import { OB11HttpSSEServerAdapter } from './network/http-server-sse'; import { OB11HttpSSEServerAdapter } from './network/http-server-sse';
import { OB11PluginAdapter } from './network/plugin';
//OneBot实现类 //OneBot实现类
export class NapCatOneBot11Adapter { export class NapCatOneBot11Adapter {
@ -61,7 +62,7 @@ export class NapCatOneBot11Adapter {
actions: ActionMap; actions: ActionMap;
private readonly bootTime = Date.now() / 1000; private readonly bootTime = Date.now() / 1000;
//recallMsgCache = new LRUCache<string, boolean>(100); //recallMsgCache = new LRUCache<string, boolean>(100);
recallEventCache = new Map<string, any>();
constructor(core: NapCatCore, context: InstanceContext, pathWrapper: NapCatPathWrapper) { constructor(core: NapCatCore, context: InstanceContext, pathWrapper: NapCatPathWrapper) {
this.core = core; this.core = core;
this.context = context; this.context = context;
@ -306,14 +307,17 @@ export class NapCatOneBot11Adapter {
let msg = (await this.core.apis.MsgApi.queryMsgsWithFilterExWithSeq(peer, msgSeq)).msgList.find(e => e.msgType == NTMsgType.KMSGTYPEGRAYTIPS); let msg = (await this.core.apis.MsgApi.queryMsgsWithFilterExWithSeq(peer, msgSeq)).msgList.find(e => e.msgType == NTMsgType.KMSGTYPEGRAYTIPS);
const element = msg?.elements.find(e => !!e.grayTipElement?.revokeElement); const element = msg?.elements.find(e => !!e.grayTipElement?.revokeElement);
if (msg && element?.grayTipElement?.revokeElement.isSelfOperate) { if (msg && element?.grayTipElement?.revokeElement.isSelfOperate) {
await this.core.eventWrapper.registerListen('NodeIKernelMsgListener/onMsgRecall', const isSelfDevice = this.recallEventCache.has(msg.msgId);
(chatType: ChatType, uid: string, msgSeq: string) => { if (isSelfDevice) {
return chatType === msg?.chatType && uid === msg?.peerUid && msgSeq === msg?.msgSeq; await this.core.eventWrapper.registerListen('NodeIKernelMsgListener/onMsgRecall',
} (chatType: ChatType, uid: string, msgSeq: string) => {
).catch(() => { return chatType === msg?.chatType && uid === msg?.peerUid && msgSeq === msg?.msgSeq;
msg = undefined; }
this.context.logger.logDebug('自操作消息撤回事件'); ).catch(() => {
}); msg = undefined;
this.context.logger.logDebug('自操作消息撤回事件');
});
}
} }
if (msg && element) { if (msg && element) {
const recallEvent = await this.emitRecallMsg(msg, element); const recallEvent = await this.emitRecallMsg(msg, element);