feat(objectql): add service status report and enhance schema validation in registry

Author: hotlong

packages/objectql/src/engine.ts

@@ -8,6 +8,7 @@ import {
   DataEngineCountOptions 
 } from '@objectstack/spec/data';
 import { DriverInterface, IDataEngine, Logger, createLogger } from '@objectstack/core';
+import { CoreServiceName } from '@objectstack/spec/system';
 import { SchemaRegistry } from './registry.js';
 
 export type HookHandler = (context: HookContext) => Promise<void> | void;
@@ -26,6 +27,9 @@ export interface ObjectQLHostContext {
  * ObjectQL Engine
  * 
  * Implements the IDataEngine interface for data persistence.
+ * Acts as the reference implementation for:
+ * - CoreServiceName.data (CRUD)
+ * - CoreServiceName.metadata (Schema Registry)
  */
 export class ObjectQL implements IDataEngine {
   private drivers = new Map<string, DriverInterface>();
@@ -50,6 +54,19 @@ export class ObjectQL implements IDataEngine {
     this.logger.info('ObjectQL Engine Instance Created');
   }
 
+  /**
+   * Service Status Report
+   * Used by Kernel to verify health and capabilities.
+   */
+  getStatus() {
+      return {
+          name: CoreServiceName.enum.data,
+          status: 'running',
+          version: '0.9.0',
+          features: ['crud', 'query', 'aggregate', 'transactions', 'metadata']
+      };
+  }
+
   /**
    * Expose the SchemaRegistry for plugins to register metadata
    */

packages/objectql/src/registry.ts

@@ -1,5 +1,6 @@
-import { ServiceObject } from '@objectstack/spec/data';
-import { ObjectStackManifest } from '@objectstack/spec/system';
+import { ServiceObject, ObjectSchema } from '@objectstack/spec/data';
+import { ObjectStackManifest, ManifestSchema } from '@objectstack/spec/system';
+import { AppSchema } from '@objectstack/spec/ui';
 
 /**
  * Global Schema Registry
@@ -22,13 +23,40 @@ export class SchemaRegistry {
     const collection = this.metadata.get(type)!;
     const key = String(item[keyField]);
 
+    // Validation Hook
+    try {
+        this.validate(type, item);
+    } catch (e: any) {
+        console.error(`[Registry] Validation failed for ${type} ${key}: ${e.message}`);
+        // For now, warn but don't crash, allowing partial/legacy loads
+        // throw e; 
+    }
+
     if (collection.has(key)) {
       console.warn(`[Registry] Overwriting ${type}: ${key}`);
     }
     collection.set(key, item);
     console.log(`[Registry] Registered ${type}: ${key}`);
   }
 
+  /**
+   * Validate Metadata against Spec Zod Schemas
+   */
+  static validate(type: string, item: any) {
+      if (type === 'object') {
+          return ObjectSchema.parse(item);
+      }
+      if (type === 'app') {
+          // AppSchema might rely on Zod, imported via UI protocol
+          return AppSchema.parse(item);
+      }
+      if (type === 'plugin') {
+          return ManifestSchema.parse(item);
+      }
+      // Add more validations as needed
+      return true;
+  }
+
   /**
    * Universal Unregister Method
    */