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

update: move to recallMsg(V2)

Browse Source
This commit is contained in:
Wesley F. Young 2024-09-07 23:28:35 +08:00
parent 264cb6bbd2
commit 4672930037
2 changed files with 2 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -157,14 +157,7 @@ export class NTQQMsgApi {
return this.context.session.getMsgService().getMsgsIncludeSelf(peer, msgId, count, isReverseOrder); return this.context.session.getMsgService().getMsgsIncludeSelf(peer, msgId, count, isReverseOrder);
} }
async recallMsg(peer: Peer, msgIds: string[]) { async recallMsg(peer: Peer, msgId: string) {
await this.context.session.getMsgService().recallMsg({
chatType: peer.chatType,
peerUid: peer.peerUid,
}, msgIds);
}
async recallMsgV2(peer: Peer, msgId: string) {
await this.core.eventWrapper.callNormalEventV2( await this.core.eventWrapper.callNormalEventV2(
'NodeIKernelMsgService/recallMsg', 'NodeIKernelMsgService/recallMsg',
'NodeIKernelMsgListener/onMsgInfoListUpdate', 'NodeIKernelMsgListener/onMsgInfoListUpdate',

10
src/onebot/action/msg/DeleteMsg.ts
View File

@ -25,15 +25,7 @@ class DeleteMsg extends BaseAction<Payload, void> {
async _handle(payload: Payload) { async _handle(payload: Payload) {
const msg = MessageUnique.getMsgIdAndPeerByShortId(Number(payload.message_id)); const msg = MessageUnique.getMsgIdAndPeerByShortId(Number(payload.message_id));
if (msg) { if (msg) {
const ret = this.core.eventWrapper.registerListen( await this.core.apis.MsgApi.recallMsg(msg.Peer, msg.MsgId);
'NodeIKernelMsgListener/onMsgInfoListUpdate',
1,
1000,
(msgs) => !!msgs.find(m => m.msgId === msg.MsgId && m.recallTime !== '0'),
).catch(() => undefined);
await this.core.apis.MsgApi.recallMsg(msg.Peer, [msg.MsgId]);
const data = await ret;
if (!data) throw new Error('Recall failed');
} else { } else {
throw new Error('Recall failed'); throw new Error('Recall failed');
} }