小改

pnpm-workspace.yaml

@@ -0,0 +1,2 @@
+packages:
+  - 'src/plugins/*'

src/core/app/core.ts

@@ -0,0 +1,60 @@
+class Core {
+  private static _instance: Core;
+  private _services: Map<string, any> = new Map();
+  [key: string]: any;
+  private constructor() {}
+
+  public static get logger() {
+    return Core.getInstance()._services.get('logger');
+  }
+
+  public static get redis() {
+    return Core.getInstance()._services.get('redis');
+  }
+
+  public static get ws() {
+    return Core.getInstance()._services.get('ws');
+  }
+
+  public static get tools() {
+    return Core.getInstance()._services.get('tools');
+  }
+
+  public static get system() {
+    return Core.getInstance()._services.get('system');
+  }
+
+  public static get response() {
+    return Core.getInstance()._services.get('response');
+  }
+
+  public static get file() {
+    return Core.getInstance()._services.get('file');
+  }
+
+  /**
+   * 注册服务
+   * @param name 服务名称
+   * @param service 服务
+   */
+  public static registerService(name: string, service: any): void {
+    Core.getInstance()._services.set(name, service);
+  }
+
+  private static getInstance(): Core {
+    if (!Core._instance) {
+      Core._instance = new Core();
+    }
+    return Core._instance;
+  }
+
+  /**
+   * 是否有某个依赖
+   * @param name 依赖名
+   */
+  public static hasService(name: string): boolean {
+    return Core.getInstance()._services.has(name);
+  }
+}
+
+export default Core;

src/core/app/loader.ts

@@ -3,9 +3,10 @@ import fs from 'fs/promises';
 import simpleGit, { SimpleGit } from 'simple-git';
 import { Application } from 'express';
 import { Server } from 'http';
-import Plugin from '../types/plugin';
+import Plugin from './../types/plugin';
 import logger from '../utils/system/logger';
 import paths from '../utils/system/path';
+import Core from './core';
 
 class PluginLoader {
   private readonly pluginsDir: string;
@@ -21,11 +22,13 @@ class PluginLoader {
 
   public async loadPlugins(): Promise<void> {
     try {
+      logger.info('正在加载插件..');
       const pluginFolders = await fs.readdir(this.pluginsDir);
 
       await Promise.all(
         pluginFolders.map(async (folder) => {
           const pluginPath = path.join(this.pluginsDir, folder);
+          logger.debug(`加载${folder}插件..`);
           const stat = await fs.stat(pluginPath);
 
           if (stat.isDirectory()) {
@@ -40,6 +43,11 @@ class PluginLoader {
     }
   }
 
+  /**
+   * 加载插件
+   * @param pluginPath
+   * @private
+   */
   private async loadPlugin(pluginPath: string): Promise<void> {
     try {
       const pluginName = path.basename(pluginPath);
@@ -63,6 +71,13 @@ class PluginLoader {
         return;
       }
 
+      try {
+        await this.checkDependencies(plugin);
+      } catch (err) {
+        logger.error(`插件依赖检查失败: ${plugin.name}`, err);
+        return;
+      }
+
       if (plugin.initialize) {
         await plugin.initialize(this.app, this.server);
       }
@@ -78,6 +93,11 @@ class PluginLoader {
     }
   }
 
+  /**
+   * 检查更新
+   * @param pluginPath
+   * @private
+   */
   private async checkPluginUpdates(pluginPath: string): Promise<boolean> {
     try {
       const git = simpleGit(pluginPath);
@@ -99,6 +119,11 @@ class PluginLoader {
     }
   }
 
+  /**
+   * 更新插件
+   * @param pluginPath
+   * @private
+   */
   private async updatePlugin(pluginPath: string): Promise<void> {
     try {
       const git = this.gitInstances.get(pluginPath);
@@ -116,6 +141,25 @@ class PluginLoader {
     }
   }
 
+  /**
+   * 检查依赖
+   * @param plugin
+   * @private
+   */
+  private async checkDependencies(plugin: Plugin): Promise<boolean> {
+    if (!plugin.dependencies) return true;
+
+    for (const dep of plugin.dependencies) {
+      if (!Core.hasService(dep)) {
+        throw new Error(`插件 ${plugin.name} 缺少依赖服务: ${dep}`);
+      }
+    }
+    return true;
+  }
+
+  /**
+   * 关闭插件
+   */
   public async closePlugins(): Promise<void> {
     await this.invokePluginHooks('onClose');
     this.loadedPlugins.clear();

src/core/types/plugin.ts

@@ -1,22 +1,33 @@
 import { Application } from 'express';
 import { Server } from 'http';
 
-interface Plugin {
+export default interface Plugin {
+  // 必须字段
   name: string;
   version: string;
+
+  // 可选描述
   description?: string;
-  // 初始化插件
+
+  // 依赖的核心服务 (如 ['logger', 'redis'])
+  dependencies?: string[];
+
+  // 初始化方法
   initialize?: (app: Application, server?: Server) => void | Promise<void>;
-  // 路由挂载点
+
+  // 路由注册方法
   routes?: (app: Application) => void;
+
   // 生命周期钩子
   onReady?: () => void | Promise<void>;
   onClose?: () => void | Promise<void>;
   onError?: (error: Error) => void;
-  // 自动更新相关
+
+  // 自动更新配置
   autoUpdateEnabled?: boolean;
   checkForUpdates?: () => Promise<boolean>;
   applyUpdate?: () => Promise<void>;
-}
 
-export default Plugin;
+  // 其他配置
+  [key: string]: any;
+}

src/plugins/example/index.ts

@@ -0,0 +1,26 @@
+import Plugin from '../../core/types/plugin';
+import MainService from './main.service';
+import Core from './../../core/app/core';
+
+const plugin: Plugin = {
+  name: 'example',
+  version: '1.0.0',
+  dependencies: ['logger'],
+
+  initialize() {
+    this.service = new MainService();
+    Core.registerService('example', this.service);
+  },
+
+  routes(app) {
+    app.get('/api/example', (req, res) => {
+      Core.response.success(res, { message: 'Hello from plugin' });
+    });
+  },
+
+  onClose() {
+    this.service.cleanup();
+  },
+};
+
+export default plugin;

src/plugins/example/main.service.ts

@@ -0,0 +1,7 @@
+import logger from '../../core/utils/system/logger';
+
+export default class MainService {
+  constructor() {
+    logger.info('示例插件初始化..');
+  }
+}

src/plugins/example/package.json

@@ -0,0 +1,10 @@
+{
+  "name": "plugin-name",
+  "version": "1.0.0",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "crystelf": {
+    "type": "plugin",
+    "dependencies": []
+  }
+}

tsconfig.json

@@ -6,7 +6,9 @@
     "forceConsistentCasingInFileNames": true,
     "strict": true,
     "skipLibCheck": true,
-    "outDir": "dist"
+    "outDir": "dist",
+    "rootDir": ".",
   },
-  "include": ["src"]
+  "include": ["src/**/*", "src/plugins/**/*"],
+  "exclude": ["node_modules"]
 }