feat: integrate MemoryDriver and update plugin initialization for ObjectQL compatibility

Author: hotlong

objectstack.config.ts

@@ -25,8 +25,8 @@ import { JSONRPCPlugin } from '@objectql/protocol-json-rpc';
 import { HonoServerPlugin } from '@objectstack/plugin-hono-server';
 import { ObjectQLPlugin } from '@objectql/core';
 import { createApiRegistryPlugin } from '@objectstack/core';
+import { MemoryDriver } from '@objectql/driver-memory';
 import * as fs from 'fs';
-import * as path from 'path';
 import * as yaml from 'js-yaml';
 
 function loadObjects(dir: string) {
@@ -70,7 +70,10 @@ export default {
             enableQueryService: true,
             // Validator and Formula plugins are included by default
             enableValidator: true,
-            enableFormulas: true
+            enableFormulas: true,
+            datasources: {
+                default: new MemoryDriver()
+            }
         }),
         new ObjectQLSecurityPlugin({
             enableAudit: false

package.json

@@ -26,6 +26,7 @@
     "@eslint/js": "^9.39.2",
     "@objectql/cli": "workspace:*",
     "@objectql/core": "workspace:*",
+    "@objectql/driver-memory": "^4.2.0",
     "@objectql/example-enterprise-erp": "workspace:*",
     "@objectql/example-project-tracker": "workspace:*",
     "@objectql/plugin-security": "workspace:*",

packages/foundation/core/src/plugin.ts

@@ -16,6 +16,7 @@ import { QueryAnalyzer } from './query/query-analyzer';
 import { ObjectStackProtocolImplementation } from './protocol';
 import type { Driver } from '@objectql/types';
 import { createDefaultAiRegistry } from './ai';
+import { SchemaRegistry } from '@objectstack/objectql';
 
 /**
  * Extended kernel with ObjectQL services
@@ -304,33 +305,74 @@ export class ObjectQLPlugin implements RuntimePlugin {
   }
 
     // --- Adapter for @objectstack/core compatibility ---
-    init = async (kernel: any): Promise<void> => {
-        // The new core passes the kernel instance directly
-        // We wrap it to match the old RuntimeContext interface
+    init = async (pluginCtx: any): Promise<void> => {
+        // The @objectstack/core kernel passes a PluginContext (with registerService, getKernel, etc.)
+        // We extract the actual kernel and build a RuntimeContext wrapper that proxies registerService.
+        const actualKernel = typeof pluginCtx.getKernel === 'function'
+            ? pluginCtx.getKernel()
+            : pluginCtx;
+
+        // Create metadata facade on the kernel if not already present.
+        // The raw ObjectKernel from @objectstack/core has no .metadata property;
+        // it's normally created by the ObjectQL wrapper (app.ts).
+        // When running via `objectstack serve`, we must create it here.
+        if (!actualKernel.metadata) {
+            const unwrapContent = (item: any) => (item && item.content) ? item.content : item;
+            actualKernel.metadata = {
+                register: (type: string, item: any) => SchemaRegistry.registerItem(type, item, item.id ? 'id' : 'name'),
+                get: (type: string, name: string) => {
+                    const item = SchemaRegistry.getItem(type, name) as any;
+                    return unwrapContent(item);
+                },
+                getEntry: (type: string, name: string) => SchemaRegistry.getItem(type, name),
+                list: (type: string) => {
+                    const items = SchemaRegistry.listItems(type);
+                    return items.map(unwrapContent);
+                },
+                unregister: (type: string, name: string) => {
+                    if (typeof SchemaRegistry.unregisterItem === 'function') {
+                        SchemaRegistry.unregisterItem(type, name);
+                    }
+                },
+                unregisterPackage: (packageName: string) => {
+                    if (typeof (SchemaRegistry as any).unregisterObjectsByPackage === 'function') {
+                        (SchemaRegistry as any).unregisterObjectsByPackage(packageName);
+                    }
+                },
+            };
+            this.logger.info('Created metadata facade on kernel');
+        }
+
         const ctx: any = {
-            engine: kernel,
-            getKernel: () => kernel
+            engine: actualKernel,
+            getKernel: () => actualKernel,
+            // Proxy registerService from PluginContext so install() can register metadata/data/analytics
+            registerService: typeof pluginCtx.registerService === 'function'
+                ? pluginCtx.registerService.bind(pluginCtx)
+                : undefined,
         };
 
         // Register Protocol Service
-        // If kernel supports service registration (PluginContext or ExtendedKernel with custom registry)
-        if (kernel && typeof kernel.registerService === 'function') {
+        if (typeof pluginCtx.registerService === 'function') {
             this.logger.info('Registering protocol service...');
-            const protocolShim = new ObjectStackProtocolImplementation(kernel);
-             kernel.registerService('protocol', protocolShim);
-             
-             // Register 'objectql' service for AppPlugin compatibility
-             kernel.registerService('objectql', this);
-             this.logger.debug('Registered objectql service');
+            const protocolShim = new ObjectStackProtocolImplementation(actualKernel);
+            pluginCtx.registerService('protocol', protocolShim);
+
+            // Register 'objectql' service for AppPlugin compatibility
+            pluginCtx.registerService('objectql', this);
+            this.logger.debug('Registered objectql service');
         }
 
         return this.install(ctx);
     }
 
-    start = async (kernel: any): Promise<void> => {
+    start = async (pluginCtx: any): Promise<void> => {
+        const actualKernel = typeof pluginCtx.getKernel === 'function'
+            ? pluginCtx.getKernel()
+            : pluginCtx;
         const ctx: any = {
-            engine: kernel,
-            getKernel: () => kernel
+            engine: actualKernel,
+            getKernel: () => actualKernel,
         };
         return this.onStart(ctx);
     }

packages/foundation/plugin-security/src/plugin.ts

@@ -74,15 +74,28 @@ export class ObjectQLSecurityPlugin implements RuntimePlugin {
   }
 
   // --- Adapter for @objectstack/core compatibility ---
-  init = async (kernel: any): Promise<void> => {
+  init = async (pluginCtx: any): Promise<void> => {
+      // Extract actual kernel from PluginContext and proxy registerService
+      const actualKernel = typeof pluginCtx.getKernel === 'function'
+          ? pluginCtx.getKernel()
+          : pluginCtx;
       const ctx: any = {
-          engine: kernel,
-          getKernel: () => kernel
+          engine: actualKernel,
+          getKernel: () => actualKernel,
+          registerService: typeof pluginCtx.registerService === 'function'
+              ? pluginCtx.registerService.bind(pluginCtx)
+              : undefined,
+          hook: typeof pluginCtx.hook === 'function'
+              ? pluginCtx.hook.bind(pluginCtx)
+              : undefined,
+          trigger: typeof pluginCtx.trigger === 'function'
+              ? pluginCtx.trigger.bind(pluginCtx)
+              : undefined,
       };
       return this.install(ctx);
   }
 
-  start = async (_kernel: any): Promise<void> => {
+  start = async (_pluginCtx: any): Promise<void> => {
       // Security plugin doesn't have specific start logic yet
       return;
   }
@@ -161,10 +174,10 @@ export class ObjectQLSecurityPlugin implements RuntimePlugin {
     const registerHook = (name: string, handler: any) => {
         if (typeof ctx.hook === 'function') {
             ctx.hook(name, handler);
-        } else if (typeof (kernel as any).use === 'function') {
-            (kernel as any).use(name, handler);
         } else if (typeof (kernel as any).hooks?.register === 'function') {
            (kernel as any).hooks.register(name, handler);
+        } else {
+           this.logger.warn(`Cannot register hook '${name}': no hook registration mechanism available`);
         }
     };