Exposes flushPendingReactiveQueries (#344)

Author: ospfranco

src/functions.ts

@@ -94,6 +94,18 @@ function enhanceDB(db: _InternalDB, options: DBParams): DB {
     delete: db.delete,
     attach: db.attach,
     detach: db.detach,
+    loadFile: db.loadFile,
+    updateHook: db.updateHook,
+    commitHook: db.commitHook,
+    rollbackHook: db.rollbackHook,
+    loadExtension: db.loadExtension,
+    getDbPath: db.getDbPath,
+    reactiveExecute: db.reactiveExecute,
+    sync: db.sync,
+    setReservedBytes: db.setReservedBytes,
+    getReservedBytes: db.getReservedBytes,
+    close: db.close,
+    flushPendingReactiveQueries: db.flushPendingReactiveQueries,
     executeBatch: async (
       commands: SQLBatchTuple[]
     ): Promise<BatchQueryResult> => {
@@ -141,17 +153,6 @@ function enhanceDB(db: _InternalDB, options: DBParams): DB {
         startNextTransaction();
       });
     },
-    loadFile: db.loadFile,
-    updateHook: db.updateHook,
-    commitHook: db.commitHook,
-    rollbackHook: db.rollbackHook,
-    loadExtension: db.loadExtension,
-    getDbPath: db.getDbPath,
-    reactiveExecute: db.reactiveExecute,
-    sync: db.sync,
-    setReservedBytes: db.setReservedBytes,
-    getReservedBytes: db.getReservedBytes,
-    close: db.close,
     executeWithHostObjects: async (
       query: string,
       params?: Scalar[]

src/types.ts

@@ -294,6 +294,13 @@ export type DB = {
   sync: () => void;
   setReservedBytes: (reservedBytes: number) => void;
   getReservedBytes: () => number;
+  /**
+   * If you have changed any of the tables outside of a transaction then the reactive queries will not fire on their own
+   * This method allows to flush the pending queue of changes. Useful when using Drizzle or other ORM that do not
+   * use the db.transaction method internally
+   * @returns void
+   */
+  flushPendingReactiveQueries: () => Promise<void>;
 };
 
 export type DBParams = {
@@ -310,10 +317,7 @@ export type OPSQLiteProxy = {
     location?: string;
     encryptionKey?: string;
   }) => _InternalDB;
-  openV2: (options: {
-    path: string;
-    encryptionKey?: string
-  }) => _InternalDB,
+  openV2: (options: { path: string; encryptionKey?: string }) => _InternalDB;
   openRemote: (options: { url: string; authToken: string }) => _InternalDB;
   openSync: (options: DBParams) => _InternalDB;
   isSQLCipher: () => boolean;