GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2025-07-19 12:03:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: report self

Browse Source
This commit is contained in:
手瓜一十雪
2024-10-31 20:27:17 +08:00
parent 85b4966ba8
commit 63bcee01a1
1 changed files with 24 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
src/onebot/index.ts
View File

@@ -311,51 +311,37 @@ export class NapCatOneBot11Adapter {
} }
}; };
//const msgIdSend = new LRUCache<string, boolean>(100); const msgIdSend = new LRUCache<string, boolean>(100);
const recallMsgs = new LRUCache<string, boolean>(100); const recallMsgs = new LRUCache<string, boolean>(100);
msgListener.onAddSendMsg = async msg => { msgListener.onAddSendMsg = async msg => {
if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS) { if (msg.sendStatus == SendStatusType.KSEND_STATUS_SENDING) {
this.apis.MsgApi.parseMessage(msg) msgIdSend.put(msg.msgId, true)
.then((ob11Msg) => {
if (!ob11Msg) return;
ob11Msg.target_id = parseInt(msg.peerUin);
if (this.configLoader.configData.reportSelfMessage) {
msg.id = MessageUnique.createUniqueMsgId({
chatType: msg.chatType,
peerUid: msg.peerUid,
guildId: '',
}, msg.msgId);
this.emitMsg(msg);
} else {
// logOB11Message(this.core, ob11Msg);
}
});
} }
}; };
msgListener.onMsgInfoListUpdate = async msgList => { msgListener.onMsgInfoListUpdate = async msgList => {
this.emitRecallMsg(msgList, recallMsgs) this.emitRecallMsg(msgList, recallMsgs)
.catch(e => this.context.logger.logError.bind(this.context.logger)('处理消息失败', e)); .catch(e => this.context.logger.logError.bind(this.context.logger)('处理消息失败', e));
// for (const msg of msgList.filter(e => e.senderUin == this.core.selfInfo.uin)) { for (const msg of msgList.filter(e => e.senderUin == this.core.selfInfo.uin)) {
// if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS && !msgIdSend.get(msg.msgId)) { if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS && msgIdSend.get(msg.msgId)) {
// msgIdSend.put(msg.msgId, true); msgIdSend.put(msg.msgId, true);
// // 完成后再post // 完成后再post
// this.apis.MsgApi.parseMessage(msg) this.apis.MsgApi.parseMessage(msg)
// .then((ob11Msg) => { .then((ob11Msg) => {
// if (!ob11Msg) return; if (!ob11Msg) return;
// ob11Msg.target_id = parseInt(msg.peerUin); ob11Msg.target_id = parseInt(msg.peerUin);
// if (this.configLoader.configData.reportSelfMessage) { if (this.configLoader.configData.reportSelfMessage) {
// msg.id = MessageUnique.createUniqueMsgId({ msg.id = MessageUnique.createUniqueMsgId({
// chatType: msg.chatType, chatType: msg.chatType,
// peerUid: msg.peerUid, peerUid: msg.peerUid,
// guildId: '', guildId: '',
// }, msg.msgId); }, msg.msgId);
// this.emitMsg(msg); this.emitMsg(msg);
// } else { } else {
// // logOB11Message(this.core, ob11Msg); // logOB11Message(this.core, ob11Msg);
// } }
// }); });
// } }
// } }
}; };
this.context.session.getMsgService().addKernelMsgListener( this.context.session.getMsgService().addKernelMsgListener(