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

chore: onRecv

Browse Source
This commit is contained in:
手瓜一十雪
2024-08-08 21:19:42 +08:00
parent 828307fc52
commit 30975f7360
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/core/core.ts
View File

@@ -3,6 +3,8 @@ import path from "node:path";
import fs from "node:fs"; import fs from "node:fs";
import { InstanceContext } from "./wrapper"; import { InstanceContext } from "./wrapper";
import { NTEventChannel } from "@/common/framework/event"; import { NTEventChannel } from "@/common/framework/event";
import { proxiedListenerOf } from "@/common/utils/proxy-handler";
import { MsgListener } from "./listeners";
export enum NapCatCoreWorkingEnv { export enum NapCatCoreWorkingEnv {
Unknown = 0, Unknown = 0,
@@ -27,10 +29,17 @@ export class NapCatCore {
constructor(context: InstanceContext) { constructor(context: InstanceContext) {
this.context = context; this.context = context;
this.eventChannel = new NTEventChannel(context.wrapper, context.session); this.eventChannel = new NTEventChannel(context.wrapper, context.session);
this.initNapCatCoreListeners();
} }
// Renamed from 'InitDataListener' // Renamed from 'InitDataListener'
initNapCatCoreListeners() { initNapCatCoreListeners() {
let msg = new MsgListener();
msg.onRecvMsg = (msg) => {
console.log("RecvMsg", msg);
}
this.context.session.getMsgService().addKernelMsgListener(
new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msg, this.context.logger))
);
} }
} }