fix: 修复编辑器保存问题

Author: lrhh123

src/main/backend/backend.ts

@@ -13,6 +13,7 @@ import { MessageService } from './services/messageService';
 import { DispatchService } from './services/dispatchService';
 import { PluginService } from './services/pluginService';
 import { AppService } from './services/appService';
+import { LoggerService } from './services/loggerService';
 
 class BKServer {
   private app: express.Application;
@@ -35,6 +36,8 @@ class BKServer {
 
   private dispatchService: DispatchService;
 
+  private loggerService: LoggerService;
+
   private appService: AppService;
 
   constructor(port: number, mainWindow: BrowserWindow) {
@@ -60,16 +63,22 @@ class BKServer {
     this.configController = new ConfigController();
     this.messageController = new MessageController();
     this.keywordReplyController = new KeywordReplyController(port);
+    this.loggerService = new LoggerService(mainWindow);
 
-    this.messageService = new MessageService(this.keywordReplyController);
+    this.messageService = new MessageService(
+      this.loggerService,
+      this.keywordReplyController,
+    );
 
     this.pluginService = new PluginService(
+      this.loggerService,
       this.configController,
       this.messageService,
     );
 
     this.dispatchService = new DispatchService(
       mainWindow,
+      this.loggerService,
       this.io,
       this.configController,
       this.messageService,

src/main/backend/controllers/configController.ts

@@ -23,12 +23,12 @@ export class ConfigController {
     let config;
 
     config = await Config.findOne({
-      where: { instance_id: instanceId },
+      where: { instance_id: instanceId, active: true },
     });
 
     if (!config && appId) {
       config = await Config.findOne({
-        where: { platform_id: appId },
+        where: { platform_id: appId, active: true },
       });
     }
 
@@ -101,7 +101,7 @@ export class ConfigController {
     let config = null;
     if (instanceId) {
       config = await Config.findOne({
-        where: { instance_id: instanceId },
+        where: { instance_id: instanceId, active: true },
       });
       if (!config) {
         config = await Config.create({
@@ -113,7 +113,7 @@ export class ConfigController {
 
     if (!config && appId) {
       config = await Config.findOne({
-        where: { platform_id: appId },
+        where: { platform_id: appId, active: true },
       });
       if (!config) {
         config = await Config.create({

src/main/backend/services/dispatchService.ts

@@ -8,29 +8,20 @@ import { ConfigController } from '../controllers/configController';
 import { MessageController } from '../controllers/messageController';
 import { Instance } from '../entities/instance';
 import { PluginDefaultRunCode } from '../constants';
+import { LoggerService } from './loggerService';
 
 export class DispatchService {
-  private mainWindow: BrowserWindow;
-
-  private messageService: MessageService;
-
-  private messageController: MessageController;
-
-  private io: socketIo.Server;
-
-  private configController: ConfigController;
-
-  private pluginService: PluginService;
-
   constructor(
-    mainWindow: BrowserWindow,
-    io: socketIo.Server,
-    configController: ConfigController,
-    messageService: MessageService,
-    messageController: MessageController,
-    pluginService: PluginService,
+    private mainWindow: BrowserWindow,
+    private log: LoggerService,
+    private io: socketIo.Server,
+    private configController: ConfigController,
+    private messageService: MessageService,
+    private messageController: MessageController,
+    private pluginService: PluginService,
   ) {
     this.io = io;
+    this.log = log;
     this.mainWindow = mainWindow;
     this.messageService = messageService;
     this.messageController = messageController;
@@ -87,6 +78,8 @@ export class DispatchService {
             ctxMap,
             msgs,
           );
+
+          this.log.info(`使用自定义插件回复: ${reply.content}`);
         } else {
           const reply_data = await this.pluginService.executePluginCode(
             PluginDefaultRunCode,
@@ -98,6 +91,12 @@ export class DispatchService {
         }
       } catch (error) {
         console.error('Failed to execute plugin', error);
+        this.log.error(
+          `回复失败: ${
+            error instanceof Error ? error.message : String(error)
+          }，使用默认回复`,
+        );
+
         reply = {
           content: cfg.default_reply || 'Failed to execute plugin',
           type: 'TEXT',

src/main/backend/services/loggerService.ts

@@ -0,0 +1,62 @@
+import { BrowserWindow } from 'electron';
+
+export class LoggerService {
+  constructor(private mainWindow: BrowserWindow) {
+    this.mainWindow = mainWindow;
+  }
+
+  public log(msg: string) {
+    console.log(msg);
+    this.mainWindow.webContents.send('broadcast', {
+      event: 'log_show',
+      data: {
+        time: new Date().toLocaleTimeString(),
+        content: msg,
+      },
+    });
+  }
+
+  public error(msg: string) {
+    console.error('[ERROR]', msg);
+    this.mainWindow.webContents.send('broadcast', {
+      event: 'log_show',
+      data: {
+        time: new Date().toLocaleTimeString(),
+        content: `[ERROR] ${msg}`,
+      },
+    });
+  }
+
+  public info(msg: string) {
+    console.info('[INFO]', msg);
+    this.mainWindow.webContents.send('broadcast', {
+      event: 'log_show',
+      data: {
+        time: new Date().toLocaleTimeString(),
+        content: `[INFO] ${msg}`,
+      },
+    });
+  }
+
+  public warn(msg: string) {
+    console.warn('[WARN]', msg);
+    this.mainWindow.webContents.send('broadcast', {
+      event: 'log_show',
+      data: {
+        time: new Date().toLocaleTimeString(),
+        content: `[WARN] ${msg}`,
+      },
+    });
+  }
+
+  public success(msg: string) {
+    console.log('[SUCCESS]', msg);
+    this.mainWindow.webContents.send('broadcast', {
+      event: 'log_show',
+      data: {
+        time: new Date().toLocaleTimeString(),
+        content: `[SUCCESS] ${msg}`,
+      },
+    });
+  }
+}

src/main/backend/services/messageService.ts

@@ -1,4 +1,5 @@
 import fs from 'fs/promises';
+import { BrowserWindow } from 'electron';
 import { KeywordReplyController } from '../controllers/keywordReplyController';
 import {
   MessageDTO,
@@ -29,10 +30,9 @@ import {
   VYroAI,
   DifyAI,
 } from '../../gptproxy';
+import { LoggerService } from './loggerService';
 
 export class MessageService {
-  private autoReplyController: KeywordReplyController;
-
   private llmClientMap: Map<
     string,
     | ErnieAI
@@ -46,8 +46,12 @@ export class MessageService {
     | DifyAI
   >;
 
-  constructor(keywordReplyController: KeywordReplyController) {
-    this.autoReplyController = keywordReplyController;
+  constructor(
+    private log: LoggerService,
+    private autoReplyController: KeywordReplyController,
+  ) {
+    this.log = log;
+    this.autoReplyController = autoReplyController;
 
     this.llmClientMap = new Map();
   }
@@ -69,6 +73,7 @@ export class MessageService {
     };
 
     if (!lastUserMsg) {
+      this.log.warn(`未匹配到用户消息，所以使用默认回复: ${reply.content}`);
       return reply;
     }
 
@@ -84,18 +89,27 @@ export class MessageService {
     if (cfg.has_keyword_match) {
       const data = await this.matchKeyword(ctx, lastUserMsg);
       if (data && data.content) {
+        this.log.success(`匹配关键词: ${data.content}`);
         return data;
       }
+      this.log.warn(`未匹配到关键词`);
     }
 
     // 最后检查是否使用 GPT 生成回复
     if (cfg.has_use_gpt) {
+      this.log.info(`开始使用 GPT 生成回复`);
+
       const data = await this.getLLMResponse(cfg, ctx, messages);
+
       if (data && data.content) {
+        this.log.success(`GPT 生成回复: ${data.content}`);
         return data;
       }
+
+      this.log.warn(`AI 回复生成失败`);
     }
 
+    this.log.info('使用默认回复');
     return reply;
   }
 

src/main/backend/services/pluginService.ts

@@ -8,6 +8,7 @@ import axios from 'axios';
 import { ConfigController } from '../controllers/configController';
 import { MessageDTO, ReplyDTO, Context } from '../types';
 import { MessageService } from './messageService';
+import { LoggerService } from './loggerService';
 
 interface PreloadedModules {
   [key: string]: any;
@@ -38,15 +39,17 @@ const createSandbox = (contextOverrides: Record<string, any> = {}) => {
 };
 
 export class PluginService {
-  private configController: ConfigController;
-
   constructor(
-    configController: ConfigController,
-    messageService: MessageService,
+    private log: LoggerService,
+    private configController: ConfigController,
+    private messageService: MessageService,
   ) {
+    this.log = log;
     this.configController = configController;
-    preloadedModules.config_srv = configController;
-    preloadedModules.reply_srv = messageService;
+    this.messageService = messageService;
+
+    preloadedModules.config_srv = this.configController;
+    preloadedModules.reply_srv = this.messageService;
   }
 
   async checkPlugin(
@@ -162,6 +165,7 @@ export class PluginService {
         console: customConsole,
         messages,
         require: (module: string) => {
+          console.log('Require:', module);
           if (preloadedModules[module]) {
             return preloadedModules[module];
           }
@@ -178,10 +182,12 @@ export class PluginService {
       vm.runInContext(pluginCode, sandbox);
 
       if (typeof sandbox.module.exports !== 'function') {
+        this.log.error('插件格式错误，请检查是否导出函数');
         throw new Error('Plugin does not export a function');
       }
 
       if (!messages || messages.length === 0) {
+        this.log.error('未提供消息给插件');
         throw new Error('No messages provided to the plugin');
       }
 
@@ -204,9 +210,15 @@ export class PluginService {
         return { data: data as ReplyDTO, consoleOutput };
       }
 
+      this.log.error('未返回有效响应');
+
       throw new Error('Plugin function did not return a valid response');
     } catch (error: any) {
       console.error('Plugin execution error:', error);
+
+      this.log.error(
+        `回复失败: ${error instanceof Error ? error.message : String(error)}`,
+      );
       error.consoleOutput = consoleOutput;
       throw error;
     }

src/main/preload.ts

@@ -50,6 +50,9 @@ const electronHandler = {
     remove(channel: Channels) {
       ipcRenderer.removeAllListeners(channel);
     },
+    removeListener(channel: Channels, func: (...args: unknown[]) => void) {
+      ipcRenderer.removeListener(channel, func);
+    },
   },
   store: {
     get(key: string) {

src/renderer/main-window/components/LogBox/index.tsx

@@ -64,7 +64,7 @@ const LogBox = () => {
           </Button>
         </HStack>
 
-        <TableContainer overflowY="scroll" width="full">
+        <TableContainer overflowY="scroll" width="full" maxH={'40vh'}>
           <Table size="sm">
             <Thead>
               <Tr>