Add debugMode

Author: stevensJourney

packages/capacitor/src/PowerSyncDatabase.ts

@@ -36,7 +36,7 @@ export class PowerSyncDatabase extends WebPowerSyncDatabase {
       }
       options.logger?.debug(`Using CapacitorSQLiteAdapter for platform: ${platform}`);
       return new CapacitorSQLiteAdapter({
-        dbFilename: options.database.dbFilename
+        ...options.database
       });
     } else {
       options.logger?.debug(`Using default web adapter for web platform`);

packages/capacitor/src/adapter/CapacitorSQLiteAdapter.ts

@@ -15,6 +15,20 @@ import { PowerSyncCore } from '../plugin/PowerSyncCore';
 import { messageForErrorCode } from '../plugin/PowerSyncPlugin';
 import { CapacitorSQLiteOpenFactoryOptions, DEFAULT_SQLITE_OPTIONS } from './CapacitorSQLiteOpenFactory';
 
+/**
+ * Monitors the execution time of a query and logs it to the performance timeline.
+ */
+async function monitorQuery(sql: string, executor: () => Promise<QueryResult>): Promise<QueryResult> {
+  const start = performance.now();
+  try {
+    const r = await executor();
+    performance.measure(`[SQL] ${sql}`, { start });
+    return r;
+  } catch (e: any) {
+    performance.measure(`[SQL] [ERROR: ${e.message}] ${sql}`, { start });
+    throw e;
+  }
+}
 /**
  * An implementation of {@link DBAdapter} using the Capacitor Community SQLite [plugin](https://github.com/capacitor-community/sqlite).
  *
@@ -92,7 +106,7 @@ export class CapacitorSQLiteAdapter extends BaseObserver<DBAdapterListener> impl
   }
 
   protected generateLockContext(db: SQLiteDBConnection): LockContext {
-    const execute = async (query: string, params: any[] = []): Promise<QueryResult> => {
+    const _execute = async (query: string, params: any[] = []): Promise<QueryResult> => {
       // This driver does not support returning results for execute methods
       if (query.toLowerCase().trim().startsWith('select')) {
         let result = await db.query(query, params);
@@ -119,7 +133,11 @@ export class CapacitorSQLiteAdapter extends BaseObserver<DBAdapterListener> impl
       }
     };
 
-    const executeQuery = async (query: string, params?: any[]): Promise<QueryResult> => {
+    const execute = this.options.debugMode
+      ? (sql: string, params?: any[]) => monitorQuery(sql, () => _execute(sql, params))
+      : _execute;
+
+    const _executeQuery = async (query: string, params?: any[]): Promise<QueryResult> => {
       let result = await db.query(query, params);
 
       let arrayResult = result.values ?? [];
@@ -134,6 +152,10 @@ export class CapacitorSQLiteAdapter extends BaseObserver<DBAdapterListener> impl
       };
     };
 
+    const executeQuery = this.options.debugMode
+      ? (sql: string, params?: any[]) => monitorQuery(sql, () => _executeQuery(sql, params))
+      : _executeQuery;
+
     const getAll = async <T>(query: string, params?: any[]): Promise<T[]> => {
       const result = await executeQuery(query, params);
       return result.rows?._array ?? ([] as T[]);