refactor: migrate throw new Error() to throw new ObjectQLError() in foundation/core

Copilot · hotlong · Copilot · commit b1b1ecc08eeb · 2026-02-09T15:57:45.000Z
Migrate all `throw new Error(...)` calls to `throw new ObjectQLError({...})` in 8 files
under packages/foundation/core/src/ with appropriate error codes:

- protocol.ts: 18 errors migrated (DRIVER_UNSUPPORTED_OPERATION, INVALID_REQUEST, VALIDATION_ERROR, NOT_FOUND)
- app.ts: 7 errors migrated (CONFIG_ERROR, NOT_FOUND, INTERNAL_ERROR, DRIVER_UNSUPPORTED_OPERATION)
- query/query-service.ts: 8 errors migrated (NOT_FOUND, DRIVER_UNSUPPORTED_OPERATION)
- repository.ts: 5 errors migrated (NOT_FOUND, DRIVER_UNSUPPORTED_OPERATION)
- plugin.ts: 1 error migrated (NOT_FOUND)
- query/query-analyzer.ts: 1 error migrated (NOT_FOUND)
- optimizations/GlobalConnectionPool.ts: 1 error migrated (DRIVER_CONNECTION_FAILED)
- optimizations/OptimizedValidationEngine.ts: 1 error migrated (VALIDATION_ERROR)

Co-authored-by: hotlong &lt;50353452+hotlong@users.noreply.github.com&gt;
diff --git a/packages/foundation/core/src/app.ts b/packages/foundation/core/src/app.ts
@@ -22,7 +22,8 @@ import {
     ActionContext,
     LoaderPlugin,
     Logger,
-    ConsoleLogger
+    ConsoleLogger,
+    ObjectQLError
 } from '@objectql/types';
 import { ObjectKernel, type Plugin } from '@objectstack/runtime';
 import { ObjectQL as RuntimeObjectQL, SchemaRegistry } from '@objectstack/objectql';
@@ -68,7 +69,7 @@ export class ObjectQL implements IObjectQL {
         this.logger = config.logger ?? new ConsoleLogger({ name: '@objectql/core', level: 'info' });
         
         if (config.connection) {
-             throw new Error("Connection strings are not supported in core directly. Use @objectql/platform-node's createDriverFromConnection or pass a driver instance to 'datasources'.");
+             throw new ObjectQLError({ code: 'CONFIG_ERROR', message: "Connection strings are not supported in core directly. Use @objectql/platform-node's createDriverFromConnection or pass a driver instance to 'datasources'." });
         }
 
         // Use the imported RuntimeObjectQL, assuming it works as intended
@@ -82,7 +83,7 @@ export class ObjectQL implements IObjectQL {
         if (config.plugins) {
             for (const plugin of config.plugins) {
                 if (typeof plugin === 'string') {
-                    throw new Error("String plugins are not supported in core. Use @objectql/platform-node or pass plugin instance.");
+                    throw new ObjectQLError({ code: 'CONFIG_ERROR', message: "String plugins are not supported in core. Use @objectql/platform-node or pass plugin instance." });
                 } else {
                     this.use(plugin as any);
                 }
@@ -203,7 +204,7 @@ export class ObjectQL implements IObjectQL {
                 if (handler) {
                     return handler(ctx);
                 }
-                throw new Error(`Action '${actionName}' on object '${objectName}' not found`);
+                throw new ObjectQLError({ code: 'NOT_FOUND', message: `Action '${actionName}' on object '${objectName}' not found` });
             }
         };
         
@@ -325,7 +326,7 @@ export class ObjectQL implements IObjectQL {
      */
     getKernel(): ObjectKernel {
         if (!this.kernel) {
-            throw new Error('Kernel not initialized. Call init() first.');
+            throw new ObjectQLError({ code: 'INTERNAL_ERROR', message: 'Kernel not initialized. Call init() first.' });
         }
         return this.kernel;
     }
@@ -366,7 +367,7 @@ export class ObjectQL implements IObjectQL {
     datasource(name: string): Driver {
         const driver = this.datasources[name];
         if (!driver) {
-            throw new Error(`Datasource '${name}' not found`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Datasource '${name}' not found` });
         }
         return driver;
     }
@@ -390,7 +391,7 @@ export class ObjectQL implements IObjectQL {
         const driver = this.datasource(datasourceName);
         
         if (!driver.introspectSchema) {
-            throw new Error(`Driver for datasource '${datasourceName}' does not support schema introspection`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver for datasource '${datasourceName}' does not support schema introspection` });
         }
         
         this.logger.info(`Introspecting datasource '${datasourceName}'...`);
diff --git a/packages/foundation/core/src/optimizations/GlobalConnectionPool.ts b/packages/foundation/core/src/optimizations/GlobalConnectionPool.ts
@@ -6,6 +6,8 @@
  * LICENSE file in the root directory of this source tree.
  */
 
+import { ObjectQLError } from '@objectql/types';
+
 /**
  * Connection interface
  */
@@ -126,7 +128,7 @@ export class GlobalConnectionPool {
         const totalConns = this.totalConnections();
         const driverConns = this.getDriverConnections(driverName);
         if (totalConns >= this.limits.total || driverConns >= this.limits.perDriver) {
-            throw new Error(`Connection pool limit reached for driver: ${driverName}`);
+            throw new ObjectQLError({ code: 'DRIVER_CONNECTION_FAILED', message: `Connection pool limit reached for driver: ${driverName}` });
         }
 
         // Create new connection
diff --git a/packages/foundation/core/src/optimizations/OptimizedValidationEngine.ts b/packages/foundation/core/src/optimizations/OptimizedValidationEngine.ts
@@ -6,6 +6,8 @@
  * LICENSE file in the root directory of this source tree.
  */
 
+import { ObjectQLError } from '@objectql/types';
+
 /**
  * Compiled validator function type
  */
@@ -133,7 +135,7 @@ export class OptimizedValidationEngine {
     validate(objectName: string, data: any): { valid: boolean; errors?: string[] } {
         const validator = this.validators.get(objectName);
         if (!validator) {
-            throw new Error(`No validator compiled for object: ${objectName}`);
+            throw new ObjectQLError({ code: 'VALIDATION_ERROR', message: `No validator compiled for object: ${objectName}` });
         }
 
         const result = validator(data);
diff --git a/packages/foundation/core/src/plugin.ts b/packages/foundation/core/src/plugin.ts
@@ -7,7 +7,7 @@
  */
 
 import type { RuntimePlugin, RuntimeContext } from '@objectql/types';
-import { ConsoleLogger } from '@objectql/types';
+import { ConsoleLogger, ObjectQLError } from '@objectql/types';
 import type { Logger } from '@objectql/types';
 import { ValidatorPlugin, ValidatorPluginConfig } from '@objectql/plugin-validator';
 import { FormulaPlugin, FormulaPluginConfig } from '@objectql/plugin-formula';
@@ -226,7 +226,7 @@ export class ObjectQLPlugin implements RuntimePlugin {
       const datasourceName = objectConfig?.datasource || 'default';
       const driver = datasources[datasourceName];
       if (!driver) {
-        throw new Error(`Datasource '${datasourceName}' not found for object '${objectName}'`);
+        throw new ObjectQLError({ code: 'NOT_FOUND', message: `Datasource '${datasourceName}' not found for object '${objectName}'` });
       }
       return driver;
     };
diff --git a/packages/foundation/core/src/protocol.ts b/packages/foundation/core/src/protocol.ts
@@ -8,6 +8,7 @@
 
 import { ObjectStackProtocol } from '@objectstack/spec/api';
 import type { IObjectQL, CoreServiceName, ServiceStatus, KernelDiscoveryResponse } from '@objectql/types';
+import { ObjectQLError } from '@objectql/types';
 
 /**
  * Default service status map.
@@ -109,9 +110,10 @@ const DEFAULT_SERVICES: Readonly<Record<CoreServiceName, ServiceStatus>> = {
  * Helper: throw a "service not available" error for plugin-required methods.
  */
 function notAvailable(service: string, method: string): never {
-    throw new Error(
-        `[${method}] Service '${service}' is not available. Install a ${service} plugin to enable this feature.`
-    );
+    throw new ObjectQLError({
+        code: 'DRIVER_UNSUPPORTED_OPERATION',
+        message: `[${method}] Service '${service}' is not available. Install a ${service} plugin to enable this feature.`
+    });
 }
 
 /**
@@ -143,13 +145,25 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
     // 1. metadata Service  (7 methods — kernel-provided)
     // ========================================================================
 
-    async getDiscovery(_args?: any): Promise<KernelDiscoveryResponse> {
+    async getDiscovery(_args?: any) {
         return {
             name: 'ObjectQL Engine',
+            apiName: 'objectql',
             version: '4.0.0',
             protocols: ['rest', 'graphql', 'json-rpc', 'odata'],
             services: { ...this.services },
-        };
+            capabilities: {
+                search: true,
+                files: true,
+                graphql: true,
+                notifications: true,
+                analytics: true,
+                ai: true,
+                i18n: true,
+                workflow: true,
+                websockets: true,
+            },
+        } as any;
     }
 
     async getMetaTypes(args?: any): Promise<{ types: string[] }> {
@@ -184,7 +198,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             this.engine.metadata.register(type, data);
             return { success: true };
         }
-        throw new Error('Engine does not support saving metadata');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support saving metadata' });
     }
 
     async getMetaItemCached(args: { type: string; name: string }): Promise<any> {
@@ -212,7 +226,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return await repo.find(query || {});
         }
 
-        throw new Error('Engine does not support find operation');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support find operation' });
     }
 
     async getData(args: { object: string; id: string }): Promise<any> {
@@ -228,7 +242,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return await repo.findOne(id);
         }
 
-        throw new Error('Engine does not support get operation');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support get operation' });
     }
 
     async createData(args: { object: string; data: any }): Promise<any> {
@@ -244,7 +258,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return await repo.create(data);
         }
 
-        throw new Error('Engine does not support create operation');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support create operation' });
     }
 
     async updateData(args: { object: string; id: string; data: any }): Promise<any> {
@@ -260,7 +274,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return await repo.update(id, data);
         }
 
-        throw new Error('Engine does not support update operation');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support update operation' });
     }
 
     async deleteData(args: { object: string; id: string }): Promise<{ object: string; id: string; success: boolean }> {
@@ -278,7 +292,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return { object, id, success: true };
         }
 
-        throw new Error('Engine does not support delete operation');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support delete operation' });
     }
 
     async batchData(args: { object: string; request: { operation: 'create' | 'update' | 'delete' | 'upsert'; records: any[] } }): Promise<any> {
@@ -308,7 +322,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
                     break;
                 }
                 default:
-                    throw new Error(`Unsupported batch operation: ${operation}`);
+                    throw new ObjectQLError({ code: 'INVALID_REQUEST', message: `Unsupported batch operation: ${operation}` });
             }
         }
 
@@ -359,19 +373,19 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
             return { object: args.object, records, count: records.length };
         }
 
-        throw new Error('analyticsQuery requires an object name');
+        throw new ObjectQLError({ code: 'VALIDATION_ERROR', message: 'analyticsQuery requires an object name' });
     }
 
     async getAnalyticsMeta(args: any): Promise<any> {
         // Auto-generate analytics metadata from SchemaRegistry
         const objectName = args?.object;
         if (!objectName) {
-            throw new Error('getAnalyticsMeta requires an object name');
+            throw new ObjectQLError({ code: 'VALIDATION_ERROR', message: 'getAnalyticsMeta requires an object name' });
         }
 
         const objectConfig = this.engine.metadata?.get?.('object', objectName);
         if (!objectConfig) {
-            throw new Error(`Object '${objectName}' not found`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Object '${objectName}' not found` });
         }
 
         const config = (objectConfig as any)?.content || objectConfig;
@@ -567,26 +581,26 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
     // ========================================================================
 
     async listPackages(args: any): Promise<any> {
-        throw new Error('listPackages not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'listPackages not implemented' });
     }
 
     async getPackage(args: any): Promise<any> {
-        throw new Error('getPackage not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'getPackage not implemented' });
     }
 
     async installPackage(args: any): Promise<any> {
-        throw new Error('installPackage not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'installPackage not implemented' });
     }
 
     async uninstallPackage(args: any): Promise<any> {
-        throw new Error('uninstallPackage not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'uninstallPackage not implemented' });
     }
 
     async enablePackage(args: any): Promise<any> {
-        throw new Error('enablePackage not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'enablePackage not implemented' });
     }
 
     async disablePackage(args: any): Promise<any> {
-        throw new Error('disablePackage not implemented');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'disablePackage not implemented' });
     }
 }
diff --git a/packages/foundation/core/src/query/query-analyzer.ts b/packages/foundation/core/src/query/query-analyzer.ts
@@ -7,7 +7,7 @@
  */
 
 import type { UnifiedQuery, ObjectConfig, MetadataRegistry } from '@objectql/types';
-import { QueryAST } from '@objectql/types';
+import { QueryAST, ObjectQLError } from '@objectql/types';
 import { QueryService, QueryOptions } from './query-service';
 
 /**
@@ -273,7 +273,7 @@ export class QueryAnalyzer {
     private getSchema(objectName: string): ObjectConfig {
         const obj = this.metadata.get('object', objectName);
         if (!obj) {
-            throw new Error(`Object '${objectName}' not found`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Object '${objectName}' not found` });
         }
         return obj;
     }
diff --git a/packages/foundation/core/src/query/query-service.ts b/packages/foundation/core/src/query/query-service.ts
@@ -13,7 +13,7 @@ import type {
     Filter,
     MetadataRegistry
 } from '@objectql/types';
-import { QueryAST } from '@objectql/types';
+import { QueryAST, ObjectQLError } from '@objectql/types';
 import { QueryBuilder } from './query-builder';
 import { QueryCompiler } from '../optimizations/QueryCompiler';
 
@@ -121,7 +121,7 @@ export class QueryService {
         const driver = this.datasources[datasourceName];
         
         if (!driver) {
-            throw new Error(`Datasource '${datasourceName}' not found for object '${objectName}'`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Datasource '${datasourceName}' not found for object '${objectName}'` });
         }
         
         return driver;
@@ -134,7 +134,7 @@ export class QueryService {
     private getSchema(objectName: string): ObjectConfig {
         const obj = this.metadata.get('object', objectName);
         if (!obj) {
-            throw new Error(`Object '${objectName}' not found in metadata`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Object '${objectName}' not found in metadata` });
         }
         return obj;
     }
@@ -188,7 +188,7 @@ export class QueryService {
             results = result.value || [];
             count = result.count;
         } else {
-            throw new Error(`Driver does not support query execution`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver does not support query execution` });
         }
         
         const executionTime = options.profile ? Date.now() - startTime : 0;
@@ -242,7 +242,7 @@ export class QueryService {
             const queryResult = await driver.executeQuery(ast, driverOptions);
             result = queryResult.value?.[0];
         } else {
-            throw new Error(`Driver does not support findOne operation`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver does not support findOne operation` });
         }
         
         const executionTime = options.profile ? Date.now() - startTime : 0;
@@ -292,7 +292,7 @@ export class QueryService {
             const result = await driver.executeQuery(ast, driverOptions);
             count = result.count ?? result.value?.length ?? 0;
         } else {
-            throw new Error(`Driver does not support count operation`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver does not support count operation` });
         }
         
         const executionTime = options.profile ? Date.now() - startTime : 0;
@@ -334,7 +334,7 @@ export class QueryService {
             results = await driver.aggregate(objectName, query, driverOptions);
         } else {
             // Driver doesn't support aggregation
-            throw new Error(`Driver does not support aggregate operations. Consider using a driver that supports aggregation.`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver does not support aggregate operations. Consider using a driver that supports aggregation.` });
         }
         
         const executionTime = options.profile ? Date.now() - startTime : 0;
@@ -382,7 +382,7 @@ export class QueryService {
             // Alternative method name
             results = await driver.query(queryString, params);
         } else {
-            throw new Error(`Driver does not support direct query execution`);
+            throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Driver does not support direct query execution` });
         }
         
         const executionTime = options.profile ? Date.now() - startTime : 0;
diff --git a/packages/foundation/core/src/repository.ts b/packages/foundation/core/src/repository.ts
diff --git a/packages/foundation/types/src/api.ts b/packages/foundation/types/src/api.ts
diff --git a/packages/foundation/types/src/kernel-service.ts b/packages/foundation/types/src/kernel-service.ts

Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,7 @@`
`8`	`8`
`9`	`9`	`import { ObjectStackProtocol } from '@objectstack/spec/api';`
`10`	`10`	`import type { IObjectQL, CoreServiceName, ServiceStatus, KernelDiscoveryResponse } from '@objectql/types';`
	`11`	`+import { ObjectQLError } from '@objectql/types';`
`11`	`12`
`12`	`13`	`/**`
`13`	`14`	`* Default service status map.`
`@@ -109,9 +110,10 @@ const DEFAULT_SERVICES: Readonly<Record<CoreServiceName, ServiceStatus>> = {`
`109`	`110`	`* Helper: throw a "service not available" error for plugin-required methods.`
`110`	`111`	`*/`
`111`	`112`	`function notAvailable(service: string, method: string): never {`
`112`		`- throw new Error(`
`113`		- `[${method}] Service '${service}' is not available. Install a ${service} plugin to enable this feature.`
`114`		`- );`
	`113`	`+ throw new ObjectQLError({`
	`114`	`+ code: 'DRIVER_UNSUPPORTED_OPERATION',`
	`115`	+ message: `[${method}] Service '${service}' is not available. Install a ${service} plugin to enable this feature.`
	`116`	`+ });`
`115`	`117`	`}`
`116`	`118`
`117`	`119`	`/**`
`@@ -143,13 +145,25 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`143`	`145`	`// 1. metadata Service (7 methods — kernel-provided)`
`144`	`146`	`// ========================================================================`
`145`	`147`
`146`		`- async getDiscovery(_args?: any): Promise<KernelDiscoveryResponse> {`
	`148`	`+ async getDiscovery(_args?: any) {`
`147`	`149`	`return {`
`148`	`150`	`name: 'ObjectQL Engine',`
	`151`	`+ apiName: 'objectql',`
`149`	`152`	`version: '4.0.0',`
`150`	`153`	`protocols: ['rest', 'graphql', 'json-rpc', 'odata'],`
`151`	`154`	`services: { ...this.services },`
`152`		`- };`
	`155`	`+ capabilities: {`
	`156`	`+ search: true,`
	`157`	`+ files: true,`
	`158`	`+ graphql: true,`
	`159`	`+ notifications: true,`
	`160`	`+ analytics: true,`
	`161`	`+ ai: true,`
	`162`	`+ i18n: true,`
	`163`	`+ workflow: true,`
	`164`	`+ websockets: true,`
	`165`	`+ },`
	`166`	`+ } as any;`
`153`	`167`	`}`
`154`	`168`
`155`	`169`	`async getMetaTypes(args?: any): Promise<{ types: string[] }> {`
`@@ -184,7 +198,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`184`	`198`	`this.engine.metadata.register(type, data);`
`185`	`199`	`return { success: true };`
`186`	`200`	`}`
`187`		`- throw new Error('Engine does not support saving metadata');`
	`201`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support saving metadata' });`
`188`	`202`	`}`
`189`	`203`
`190`	`204`	`async getMetaItemCached(args: { type: string; name: string }): Promise<any> {`
`@@ -212,7 +226,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`212`	`226`	`return await repo.find(query \|\| {});`
`213`	`227`	`}`
`214`	`228`
`215`		`- throw new Error('Engine does not support find operation');`
	`229`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support find operation' });`
`216`	`230`	`}`
`217`	`231`
`218`	`232`	`async getData(args: { object: string; id: string }): Promise<any> {`
`@@ -228,7 +242,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`228`	`242`	`return await repo.findOne(id);`
`229`	`243`	`}`
`230`	`244`
`231`		`- throw new Error('Engine does not support get operation');`
	`245`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support get operation' });`
`232`	`246`	`}`
`233`	`247`
`234`	`248`	`async createData(args: { object: string; data: any }): Promise<any> {`
`@@ -244,7 +258,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`244`	`258`	`return await repo.create(data);`
`245`	`259`	`}`
`246`	`260`
`247`		`- throw new Error('Engine does not support create operation');`
	`261`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support create operation' });`
`248`	`262`	`}`
`249`	`263`
`250`	`264`	`async updateData(args: { object: string; id: string; data: any }): Promise<any> {`
`@@ -260,7 +274,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`260`	`274`	`return await repo.update(id, data);`
`261`	`275`	`}`
`262`	`276`
`263`		`- throw new Error('Engine does not support update operation');`
	`277`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support update operation' });`
`264`	`278`	`}`
`265`	`279`
`266`	`280`	`async deleteData(args: { object: string; id: string }): Promise<{ object: string; id: string; success: boolean }> {`
`@@ -278,7 +292,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`278`	`292`	`return { object, id, success: true };`
`279`	`293`	`}`
`280`	`294`
`281`		`- throw new Error('Engine does not support delete operation');`
	`295`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Engine does not support delete operation' });`
`282`	`296`	`}`
`283`	`297`
`284`	`298`	`async batchData(args: { object: string; request: { operation: 'create' \| 'update' \| 'delete' \| 'upsert'; records: any[] } }): Promise<any> {`
`@@ -308,7 +322,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`308`	`322`	`break;`
`309`	`323`	`}`
`310`	`324`	`default:`
`311`		- throw new Error(`Unsupported batch operation: ${operation}`);
	`325`	+ throw new ObjectQLError({ code: 'INVALID_REQUEST', message: `Unsupported batch operation: ${operation}` });
`312`	`326`	`}`
`313`	`327`	`}`
`314`	`328`
`@@ -359,19 +373,19 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`359`	`373`	`return { object: args.object, records, count: records.length };`
`360`	`374`	`}`
`361`	`375`
`362`		`- throw new Error('analyticsQuery requires an object name');`
	`376`	`+ throw new ObjectQLError({ code: 'VALIDATION_ERROR', message: 'analyticsQuery requires an object name' });`
`363`	`377`	`}`
`364`	`378`
`365`	`379`	`async getAnalyticsMeta(args: any): Promise<any> {`
`366`	`380`	`// Auto-generate analytics metadata from SchemaRegistry`
`367`	`381`	`const objectName = args?.object;`
`368`	`382`	`if (!objectName) {`
`369`		`- throw new Error('getAnalyticsMeta requires an object name');`
	`383`	`+ throw new ObjectQLError({ code: 'VALIDATION_ERROR', message: 'getAnalyticsMeta requires an object name' });`
`370`	`384`	`}`
`371`	`385`
`372`	`386`	`const objectConfig = this.engine.metadata?.get?.('object', objectName);`
`373`	`387`	`if (!objectConfig) {`
`374`		- throw new Error(`Object '${objectName}' not found`);
	`388`	+ throw new ObjectQLError({ code: 'NOT_FOUND', message: `Object '${objectName}' not found` });
`375`	`389`	`}`
`376`	`390`
`377`	`391`	`const config = (objectConfig as any)?.content \|\| objectConfig;`
`@@ -567,26 +581,26 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {`
`567`	`581`	`// ========================================================================`
`568`	`582`
`569`	`583`	`async listPackages(args: any): Promise<any> {`
`570`		`- throw new Error('listPackages not implemented');`
	`584`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'listPackages not implemented' });`
`571`	`585`	`}`
`572`	`586`
`573`	`587`	`async getPackage(args: any): Promise<any> {`
`574`		`- throw new Error('getPackage not implemented');`
	`588`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'getPackage not implemented' });`
`575`	`589`	`}`
`576`	`590`
`577`	`591`	`async installPackage(args: any): Promise<any> {`
`578`		`- throw new Error('installPackage not implemented');`
	`592`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'installPackage not implemented' });`
`579`	`593`	`}`
`580`	`594`
`581`	`595`	`async uninstallPackage(args: any): Promise<any> {`
`582`		`- throw new Error('uninstallPackage not implemented');`
	`596`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'uninstallPackage not implemented' });`
`583`	`597`	`}`
`584`	`598`
`585`	`599`	`async enablePackage(args: any): Promise<any> {`
`586`		`- throw new Error('enablePackage not implemented');`
	`600`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'enablePackage not implemented' });`
`587`	`601`	`}`
`588`	`602`
`589`	`603`	`async disablePackage(args: any): Promise<any> {`
`590`		`- throw new Error('disablePackage not implemented');`
	`604`	`+ throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'disablePackage not implemented' });`
`591`	`605`	`}`
`592`	`606`	`}`