Fix: Extend Driver interface to be compatible with DriverInterface from @objectstack/spec

Co-authored-by: hotlong <50353452+hotlong@users.noreply.github.com>

Author: Copilot

packages/foundation/core/src/app.ts

@@ -8,6 +8,7 @@
 
 import { 
     MetadataRegistry, 
+    Driver,
     ObjectConfig, 
     ObjectQLContext, 
     ObjectQLContextOptions, 
@@ -28,13 +29,12 @@ import { registerHookHelper, triggerHookHelper, HookEntry } from './hook';
 import { registerObjectHelper, getConfigsHelper } from './object';
 import { convertIntrospectedSchemaToObjects } from './util';
 
-// Import ObjectStack engine and standard driver interface
+// Import ObjectStack engine for driver management
 import { ObjectQL as ObjectStackEngine } from '@objectstack/objectql';
-import { DriverInterface } from '@objectstack/spec';
 
 export class ObjectQL implements IObjectQL {
     public metadata: MetadataRegistry;
-    private datasources: Record<string, DriverInterface> = {};
+    private datasources: Record<string, Driver> = {};
     private remotes: string[] = [];
     private hooks: Record<string, HookEntry[]> = {};
     private actions: Record<string, ActionEntry> = {};
@@ -54,9 +54,9 @@ export class ObjectQL implements IObjectQL {
         // Initialize ObjectStack engine for driver management
         this.stackEngine = new ObjectStackEngine({});
 
-        // Register drivers with ObjectStack engine (no wrapping needed)
+        // Register drivers with ObjectStack engine
         for (const [name, driver] of Object.entries(this.datasources)) {
-            this.stackEngine.registerDriver(driver, name === 'default');
+            this.stackEngine.registerDriver(driver as any, name === 'default');
         }
         }
 
@@ -90,12 +90,12 @@ export class ObjectQL implements IObjectQL {
     /**
      * Register a new driver with ObjectStack engine
      */
-    registerDriver(name: string, driver: DriverInterface, isDefault: boolean = false) {
+    registerDriver(name: string, driver: Driver, isDefault: boolean = false) {
         if (this.datasources[name]) {
             console.warn(`[ObjectQL] Driver '${name}' already exists. Overwriting...`);
         }
         this.datasources[name] = driver;
-        this.stackEngine.registerDriver(driver, isDefault);
+        this.stackEngine.registerDriver(driver as any, isDefault);
     }
 
     removePackage(name: string) {
@@ -190,7 +190,7 @@ export class ObjectQL implements IObjectQL {
         return getConfigsHelper(this.metadata);
     }
 
-    datasource(name: string): DriverInterface {
+    datasource(name: string): Driver {
         const driver = this.datasources[name];
         if (!driver) {
             throw new Error(`Datasource '${name}' not found`);

packages/foundation/core/src/repository.ts

@@ -6,8 +6,7 @@
  * LICENSE file in the root directory of this source tree.
  */
 
-import { ObjectQLContext, IObjectQL, ObjectConfig, UnifiedQuery, ActionContext, HookAPI, RetrievalHookContext, MutationHookContext, UpdateHookContext, ValidationContext, ValidationError, ValidationRuleResult, FormulaContext } from '@objectql/types';
-import { DriverInterface } from '@objectstack/spec';
+import { ObjectQLContext, IObjectQL, ObjectConfig, Driver, UnifiedQuery, ActionContext, HookAPI, RetrievalHookContext, MutationHookContext, UpdateHookContext, ValidationContext, ValidationError, ValidationRuleResult, FormulaContext } from '@objectql/types';
 import { Validator } from './validator';
 import { FormulaEngine } from './formula-engine';
 
@@ -24,7 +23,7 @@ export class ObjectRepository {
         this.formulaEngine = new FormulaEngine();
     }
 
-    private getDriver(): DriverInterface {
+    private getDriver(): Driver {
         const obj = this.getSchema();
         const datasourceName = obj.datasource || 'default';
         return this.app.datasource(datasourceName);

packages/foundation/types/src/app.ts

@@ -7,17 +7,16 @@
  */
 
 import { ObjectConfig } from "./object";
+import { Driver } from "./driver";
 import { MetadataRegistry } from "./registry";
 import { HookName, HookHandler, HookContext } from "./hook";
 import { ActionHandler, ActionContext } from "./action";
 import { LoaderPlugin } from "./loader";
-// Import DriverInterface from @objectstack/spec
-import type { DriverInterface } from "@objectstack/spec";
 
 export interface IObjectQL {
     getObject(name: string): ObjectConfig | undefined;
     getConfigs(): Record<string, ObjectConfig>;
-    datasource(name: string): DriverInterface;
+    datasource(name: string): Driver;
     init(): Promise<void>;
     close?(): Promise<void>;
     removePackage(name: string): void;

packages/foundation/types/src/config.ts

@@ -7,14 +7,13 @@
  */
 
 import { MetadataRegistry } from "./registry";
+import { Driver } from "./driver";
 import { ObjectConfig } from "./object";
 import { ObjectQLPlugin } from "./plugin";
-// Import DriverInterface from @objectstack/spec
-import type { DriverInterface } from "@objectstack/spec";
 
 export interface ObjectQLConfig {
     registry?: MetadataRegistry;
-    datasources?: Record<string, DriverInterface>;
+    datasources?: Record<string, Driver>;
     /**
      * Optional connection string for auto-configuration.
      * e.g. "sqlite://dev.db", "postgres://localhost/db", "mongodb://localhost/db"

packages/foundation/types/src/driver.ts

@@ -63,14 +63,45 @@ export interface IntrospectedSchema {
 }
 
 export interface Driver {
+    // Required for DriverInterface compatibility
+    name?: string;
+    version?: string;
+    supports?: {
+        transactions?: boolean;
+        joins?: boolean;
+        fullTextSearch?: boolean;
+        jsonFields?: boolean;
+        arrayFields?: boolean;
+    };
+    
+    // Core CRUD methods (existing)
     find(objectName: string, query: any, options?: any): Promise<any[]>;
     findOne(objectName: string, id: string | number, query?: any, options?: any): Promise<any>;
     create(objectName: string, data: any, options?: any): Promise<any>;
     update(objectName: string, id: string | number, data: any, options?: any): Promise<any>;
     delete(objectName: string, id: string | number, options?: any): Promise<any>;
     count(objectName: string, filters: any, options?: any): Promise<number>;
 
-    // Schema / Lifecycle
+    // Lifecycle methods
+    connect?(): Promise<void>;
+    disconnect?(): Promise<void>;
+    checkHealth?(): Promise<boolean>;
+    
+    // Additional methods for DriverInterface compatibility
+    execute?(command: any, parameters?: any[], options?: any): Promise<any>;
+    findOne?(objectName: string, id: string | number, query?: any, options?: any): Promise<any>;
+    bulkCreate?(objectName: string, data: any[], options?: any): Promise<any>;
+    bulkUpdate?(objectName: string, updates: Array<{id: string | number, data: any}>, options?: any): Promise<any>;
+    bulkDelete?(objectName: string, ids: Array<string | number>, options?: any): Promise<any>;
+    distinct?(objectName: string, field: string, filters?: any, options?: any): Promise<any[]>;
+    aggregate?(objectName: string, aggregations: any[], filters?: any, options?: any): Promise<any[]>;
+    
+    // Transaction support
+    beginTransaction?(): Promise<any>;
+    commitTransaction?(transaction: any): Promise<void>;
+    rollbackTransaction?(transaction: any): Promise<void>;
+    
+    // Schema / Lifecycle (existing)
     init?(objects: any[]): Promise<void>;
 
     /**