From 30975f7360db690e6c64746ebda46caa90f2cdea Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?=
 <nanaeonn@outlook.com>
Date: Thu, 8 Aug 2024 21:19:42 +0800
Subject: [PATCH] chore: onRecv

---
 src/core/core.ts | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/core/core.ts b/src/core/core.ts
index c8ed1c52..56afb9f6 100644
--- a/src/core/core.ts
+++ b/src/core/core.ts
@@ -3,6 +3,8 @@ import path from "node:path";
 import fs from "node:fs";
 import { InstanceContext } from "./wrapper";
 import { NTEventChannel } from "@/common/framework/event";
+import { proxiedListenerOf } from "@/common/utils/proxy-handler";
+import { MsgListener } from "./listeners";
 
 export enum NapCatCoreWorkingEnv {
     Unknown = 0,
@@ -27,10 +29,17 @@ export class NapCatCore {
     constructor(context: InstanceContext) {
         this.context = context;
         this.eventChannel = new NTEventChannel(context.wrapper, context.session);
+        this.initNapCatCoreListeners();
     }
 
     // Renamed from 'InitDataListener'
     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))
+        );
     }
 }