chore: onRecvSysMsg

This commit is contained in:
手瓜一十雪
2024-08-26 11:33:17 +08:00
parent a71eddbed2
commit 19097388d0
3 changed files with 19 additions and 4 deletions

View File

@@ -259,7 +259,7 @@ export class NodeIKernelMsgListener {
} }
onRecvSysMsg(arrayList: unknown) { onRecvSysMsg(arrayList: Array<number>) {
} }

View File

@@ -3,7 +3,7 @@ export class NodeIKernelRecentContactListener {
} }
onRecentContactNotification(...args: unknown[]) { onRecentContactNotification(msgList: any, arg0: { msgListUnreadCnt: string }, arg1: number) {
} }

View File

@@ -37,6 +37,7 @@ import { OB11FriendRecallNoticeEvent } from '@/onebot/event/notice/OB11FriendRec
import { OB11GroupRecallNoticeEvent } from '@/onebot/event/notice/OB11GroupRecallNoticeEvent'; import { OB11GroupRecallNoticeEvent } from '@/onebot/event/notice/OB11GroupRecallNoticeEvent';
import { LRUCache } from '@/common/utils/LRU'; import { LRUCache } from '@/common/utils/LRU';
import { NT2GroupEvent, NT2PrivateEvent } from './helper'; import { NT2GroupEvent, NT2PrivateEvent } from './helper';
import { NodeIKernelRecentContactListener } from '@/core/listeners/NodeIKernelRecentContactListener';
//OneBot实现类 //OneBot实现类
export class NapCatOneBot11Adapter { export class NapCatOneBot11Adapter {
@@ -115,6 +116,7 @@ export class NapCatOneBot11Adapter {
this.initMsgListener(); this.initMsgListener();
this.initBuddyListener(); this.initBuddyListener();
this.initGroupListener(); this.initGroupListener();
//this.initRecentContactListener();
await WebUiDataRuntime.setQQLoginUin(selfInfo.uin.toString()); await WebUiDataRuntime.setQQLoginUin(selfInfo.uin.toString());
await WebUiDataRuntime.setQQLoginStatus(true); await WebUiDataRuntime.setQQLoginStatus(true);
@@ -125,6 +127,16 @@ export class NapCatOneBot11Adapter {
await this.reloadNetwork(prev, newConfig); await this.reloadNetwork(prev, newConfig);
}); });
} }
initRecentContactListener() {
const recentContactListener = new NodeIKernelRecentContactListener();
recentContactListener.onRecentContactNotification = function (msgList: any[], arg0: { msgListUnreadCnt: string }, arg1: number) {
msgList.forEach((msg) => {
if (msg.chatType == ChatType.KCHATTYPEGROUP) {
// log("recent contact", msgList, arg0, arg1);
}
});
}
}
private async reloadNetwork(prev: OB11Config, now: OB11Config) { private async reloadNetwork(prev: OB11Config, now: OB11Config) {
const serviceInfo = ` const serviceInfo = `
@@ -220,6 +232,9 @@ export class NapCatOneBot11Adapter {
private initMsgListener() { private initMsgListener() {
const msgListener = new NodeIKernelMsgListener(); const msgListener = new NodeIKernelMsgListener();
msgListener.onRecvSysMsg = msg => {
//console.log('onRecvSysMsg', Buffer.from(msg).toString('hex'));
}
msgListener.onInputStatusPush = async data => { msgListener.onInputStatusPush = async data => {
const uin = await this.core.apis.UserApi.getUinByUidV2(data.fromUin); const uin = await this.core.apis.UserApi.getUinByUidV2(data.fromUin);
this.context.logger.log(`[Notice] [输入状态] ${uin} ${data.statusText}`); this.context.logger.log(`[Notice] [输入状态] ${uin} ${data.statusText}`);