refactor(redis): replace throw new Error with throw new ObjectQLError

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

Author: Copilot

packages/drivers/pg-wasm/src/wasm-loader.ts

@@ -11,6 +11,8 @@
  * Handles lazy loading and initialization of the PostgreSQL WASM module
  */
 
+import { ObjectQLError } from '@objectql/types';
+
 let pgliteModule: any = null;
 
 /**
@@ -34,7 +36,7 @@ export async function loadWasmModule(): Promise<any> {
  */
 export function getPGlite(): any {
     if (!pgliteModule) {
-        throw new Error('PGlite WASM module not loaded. Call loadWasmModule() first.');
+        throw new ObjectQLError({ code: 'DRIVER_ERROR', message: 'PGlite WASM module not loaded. Call loadWasmModule() first.' });
     }
     return pgliteModule;
 }

packages/drivers/redis/src/index.ts

@@ -39,7 +39,7 @@ type DriverInterface = z.infer<typeof Data.DriverInterface>;
  * @version 4.1.0 - Production-ready with distinct() and aggregate()
  */
 
-import { Driver } from '@objectql/types';
+import { Driver, ObjectQLError } from '@objectql/types';
 import { createClient, RedisClientType } from 'redis';
 
 /**
@@ -264,7 +264,7 @@ export class RedisDriver implements Driver {
             }
         }
 
-        throw new Error(`[RedisDriver] Failed to connect after ${maxAttempts} attempts: ${lastError?.message}`);
+        throw new ObjectQLError({ code: 'DRIVER_CONNECTION_FAILED', message: `[RedisDriver] Failed to connect after ${maxAttempts} attempts: ${lastError?.message}` });
     }
 
     /**
@@ -399,7 +399,7 @@ export class RedisDriver implements Driver {
         const result = await this.client.set(key, JSON.stringify(doc), { NX: true });
 
         if (!result) {
-            throw new Error(`Record with ID ${id} already exists in ${objectName}`);
+            throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: `Record with ID ${id} already exists in ${objectName}` });
         }
 
         return doc;
@@ -415,7 +415,7 @@ export class RedisDriver implements Driver {
         const existing = await this.client.get(key);
 
         if (!existing) {
-            throw new Error(`Record not found: ${objectName}:${id}`);
+            throw new ObjectQLError({ code: 'NOT_FOUND', message: `Record not found: ${objectName}:${id}` });
         }
 
         const existingDoc = JSON.parse(existing);
@@ -806,7 +806,7 @@ export class RedisDriver implements Driver {
             switch (command.type) {
                 case 'create':
                     if (!command.data) {
-                        throw new Error('Create command requires data');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'Create command requires data' });
                     }
                     const created = await this.create(command.object, command.data, cmdOptions);
                     return {
@@ -817,7 +817,7 @@ export class RedisDriver implements Driver {
 
                 case 'update':
                     if (!command.id || !command.data) {
-                        throw new Error('Update command requires id and data');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'Update command requires id and data' });
                     }
                     const updated = await this.update(command.object, command.id, command.data, cmdOptions);
                     return {
@@ -828,7 +828,7 @@ export class RedisDriver implements Driver {
 
                 case 'delete':
                     if (!command.id) {
-                        throw new Error('Delete command requires id');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'Delete command requires id' });
                     }
                     await this.delete(command.object, command.id, cmdOptions);
                     return {
@@ -838,7 +838,7 @@ export class RedisDriver implements Driver {
 
                 case 'bulkCreate':
                     if (!command.records || !Array.isArray(command.records)) {
-                        throw new Error('BulkCreate command requires records array');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'BulkCreate command requires records array' });
                     }
                     // Use Redis PIPELINE for batch operations
                     const pipeline = this.client.multi();
@@ -868,7 +868,7 @@ export class RedisDriver implements Driver {
 
                 case 'bulkUpdate':
                     if (!command.updates || !Array.isArray(command.updates)) {
-                        throw new Error('BulkUpdate command requires updates array');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'BulkUpdate command requires updates array' });
                     }
 
                     // First, batch GET all existing records using PIPELINE
@@ -917,7 +917,7 @@ export class RedisDriver implements Driver {
 
                 case 'bulkDelete':
                     if (!command.ids || !Array.isArray(command.ids)) {
-                        throw new Error('BulkDelete command requires ids array');
+                        throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: 'BulkDelete command requires ids array' });
                     }
                     // Use Redis PIPELINE for batch operations
                     const deletePipeline = this.client.multi();
@@ -938,7 +938,7 @@ export class RedisDriver implements Driver {
                     };
 
                 default:
-                    throw new Error(`Unknown command type: ${(command as any).type}`);
+                    throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: `Unknown command type: ${(command as any).type}` });
             }
         } catch (error: any) {
             return {

packages/drivers/sdk/src/index.ts

@@ -336,7 +336,7 @@ export class RemoteDriver implements Driver {
         try {
             await this.checkHealth();
         } catch (error) {
-            throw new Error(`Failed to connect to remote server: ${(error as Error).message}`);
+            throw new ObjectQLError({ code: 'DRIVER_CONNECTION_FAILED', message: `Failed to connect to remote server: ${(error as Error).message}` });
         }
     }
 
@@ -617,7 +617,7 @@ export class RemoteDriver implements Driver {
         const json = await res.json();
 
         if (json.error) {
-            throw new Error(json.error.message);
+            throw new ObjectQLError({ code: 'DRIVER_QUERY_FAILED', message: json.error.message });
         }
 
         return json.data;

packages/drivers/sqlite-wasm/src/knex-adapter.ts

@@ -7,6 +7,7 @@
  */
 
 import { Knex } from 'knex';
+import { ObjectQLError } from '@objectql/types';
 
 /**
  * Custom Knex client adapter for wa-sqlite
@@ -135,7 +136,7 @@ export class KnexWaSqliteClient {
     }
 
     _stream(connection: any, obj: any, stream: any, options: any): any {
-        throw new Error('Streaming is not supported in wa-sqlite adapter');
+        throw new ObjectQLError({ code: 'DRIVER_UNSUPPORTED_OPERATION', message: 'Streaming is not supported in wa-sqlite adapter' });
     }
 
     canCancelQuery = false;

packages/drivers/sqlite-wasm/src/wasm-loader.ts

@@ -11,6 +11,8 @@
  * Handles lazy loading and initialization of the SQLite WASM module
  */
 
+import { ObjectQLError } from '@objectql/types';
+
 let wasmModule: any = null;
 let sqlite3: any = null;
 
@@ -38,7 +40,7 @@ export async function loadWasmModule(): Promise<any> {
  */
 export function getSqlite3(): any {
     if (!sqlite3) {
-        throw new Error('SQLite WASM module not loaded. Call loadWasmModule() first.');
+        throw new ObjectQLError({ code: 'DRIVER_ERROR', message: 'SQLite WASM module not loaded. Call loadWasmModule() first.' });
     }
     return sqlite3;
 }