重构 ObjectQL 引擎以支持插件系统，添加插件加载和注册逻辑，更新 SchemaRegistry，移除不再使用的注册器

Author: hotlong

examples/objectql/src/engine.ts

@@ -1,23 +1,74 @@
-import { DriverInterface, DriverOptions, QueryAST } from '@objectstack/spec';
+import { DriverInterface, DriverOptions, QueryAST, ObjectStackManifest, ManifestSchema } from '@objectstack/spec';
+import { SchemaRegistry } from './registry';
+
+/**
+ * Host Context provided to plugins
+ */
+export interface PluginContext {
+  ql: ObjectQL;
+  logger: Console;
+  // Extensible map for host-specific globals (like HTTP Router, etc.)
+  [key: string]: any;
+}
 
 /**
  * ObjectQL Engine
- * 
- * The core orchestration layer that sits between the API/UI and the Data Driver.
- * It handles:
- * 1. Request Validation (using Schemas)
- * 2. Security Enforcement (ACLs, Sharing Rules)
- * 3. Workflow Triggers
- * 4. Driver Delegation
  */
 export class ObjectQL {
   private drivers = new Map<string, DriverInterface>();
   private defaultDriver: string | null = null;
+  private plugins = new Map<string, any>();
+  
+  // Host provided context additions (e.g. Server router)
+  private hostContext: Record<string, any> = {};
 
-  constructor() {
+  constructor(hostContext: Record<string, any> = {}) {
+    this.hostContext = hostContext;
     console.log(`[ObjectQL] Engine Instance Created`);
   }
 
+  /**
+   * Load and Register a Plugin
+   */
+  async use(manifestPart: any, runtimePart?: any) {
+    // 1. Validate / Register Manifest
+    if (manifestPart) {
+      // In a real scenario, we might strictly parse this using Zod
+      // For now, simple ID check
+      const id = manifestPart.id;
+      if (!id) {
+        console.warn('[ObjectQL] Plugin manifest missing ID', manifestPart);
+        return;
+      }
+      
+      console.log(`[ObjectQL] Loading Plugin: ${id}`);
+      SchemaRegistry.registerPlugin(manifestPart as ObjectStackManifest);
+
+      // Register contributions
+       if (manifestPart.contributes?.kinds) {
+          for (const kind of manifestPart.contributes.kinds) {
+            SchemaRegistry.registerKind(kind);
+          }
+       }
+    }
+
+    // 2. Execute Runtime
+    if (runtimePart) {
+       const pluginDef = (runtimePart as any).default || runtimePart;
+       if (pluginDef.onEnable) {
+          const context: PluginContext = {
+            ql: this,
+            logger: console,
+            // Expose the driver registry helper explicitly if needed
+            drivers: this, // Since `registerDriver` is on `this`, we can alias it or expose `this`
+            ...this.hostContext
+          };
+          
+          await pluginDef.onEnable(context);
+       }
+    }
+  }
+
   /**
    * Register a new storage driver
    */

examples/objectql/src/index.ts

@@ -1,5 +1,6 @@
 // Export core engine
 export { ObjectQL } from './engine';
+export { SchemaRegistry } from './registry';
 
 // Re-export common types from spec for convenience
 export type { DriverInterface, DriverOptions, QueryAST } from '@objectstack/spec';

examples/server/src/kernel/registry.ts examples/objectql/src/registry.tsexamples/server/src/kernel/registry.ts renamed to examples/objectql/src/registry.ts

@@ -8,17 +8,11 @@ import { DataEngine } from './kernel/engine';
 
 // 1. Initialize Kernel
 const app = new Hono();
-const dataEngine = new DataEngine();
+const dataEngine = new DataEngine(); // Engine loads plugins internally now
 
 app.use('*', logger());
 app.use('*', cors());
 
-// 2. Load Plugins (CRM, Todo)
-// Initialization moved to async startup below
-loadPlugins(dataEngine).then(() => {
-  console.log('[Server] Kernel Ready');
-}).catch(console.error);
-
 // 3. Define Unified Routes
 
 /**

examples/server/src/index.ts

@@ -1,6 +1,18 @@
 import { ServiceObject } from '@objectstack/spec';
-import { SchemaRegistry } from './registry';
-import { ObjectQL } from '@objectstack/objectql';
+import { SchemaRegistry, ObjectQL } from '@objectstack/objectql';
+
+// Import Packages/Plugins
+// @ts-ignore
+import CrmApp from '@objectstack/example-crm/objectstack.config';
+// @ts-ignore
+import TodoApp from '@objectstack/example-todo/objectstack.config';
+// @ts-ignore
+import BiPluginManifest from '@objectstack/plugin-bi/objectstack.config';
+import BiPluginRuntime from '@objectstack/plugin-bi';
+// @ts-ignore
+import DriverMemoryManifest from '@objectstack/plugin-driver-memory/objectstack.config';
+import DriverMemoryRuntime from '@objectstack/plugin-driver-memory';
+
 
 /**
  * Server Data Engine Wrapper
@@ -14,16 +26,34 @@ export class DataEngine {
   public ql: ObjectQL;
 
   constructor() {
-    this.ql = new ObjectQL();
+    // 1. Initialize Engine with Host Context (Simulated OS services)
+    this.ql = new ObjectQL({
+        os: { registerService: () => console.log('OS Service Registered') },
+        app: { router: { get: () => {} } }, 
+        storage: { set: () => {} },
+        services: { register: () => {} },
+        i18n: {}
+    });
+
+    // 2. Load Plugins (Declarative)
+    this.loadPlugins();
+
+    // 3. Start Engine
+    this.ql.init().then(() => {
+        this.seed();
+    }).catch(console.error);
+  }
 
-    // Driver is now registered via Plugin System (see context.drivers.register) in loader.ts
-    // We just wait for init
+  async loadPlugins() {
+    // Apps
+    await this.ql.use(CrmApp);
+    await this.ql.use(TodoApp);
 
-    // 2. Start Engine
-    this.ql.init().catch(console.error);
+    // Plugins (Manifest + Runtime)
+    await this.ql.use(BiPluginManifest, BiPluginRuntime);
 
-    // Seed after a short delay (mocking async startup)
-    setTimeout(() => this.seed(), 500);
+    // Drivers
+    await this.ql.use(DriverMemoryManifest, DriverMemoryRuntime);
   }
 
   async seed() {