fix: transaction is async

Author: farfromrefug

src/sqlite.common.ts

@@ -29,7 +29,7 @@ export interface SQLiteDatabase {
 
     execute(query: string, params?: SqliteParams): Promise<void>;
 
-    transaction<T = any>(action: (cancel?: () => void) => T): T;
+    transaction<T = any>(action: (cancel?: () => void) => Promise<T>): Promise<T>;
 
     each(
         query: string,

src/sqlite.ios.ts

@@ -415,11 +415,11 @@ function execRaw(db: FMDatabase, query: string, params?: SqliteParams) {
     }
 }
 
-function transactionRaw<T = any>(
+async function transactionRaw<T = any>(
     db: FMDatabase,
-    action: (cancel?: () => void) => T,
+    action: (cancel?: () => void) => Promise<T>,
     isFirstTransaction: boolean
-): T {
+) {
     try {
         if (isFirstTransaction) {
             execRaw(db, 'BEGIN EXCLUSIVE TRANSACTION');
@@ -428,7 +428,7 @@ function transactionRaw<T = any>(
         const cancel = () => {
             cancelled.value = true;
         };
-        const result = action(cancel);
+        const result = await action(cancel);
         if (!cancelled.value && isFirstTransaction) {
             execRaw(db, 'COMMIT TRANSACTION');
         } else if (cancelled.value && isFirstTransaction) {
@@ -509,7 +509,7 @@ export class SQLiteDatabase {
         return selectRaw(this.db, query, params, false) as SqliteParam[][];
     }
     _isInTransaction = false;
-    transaction<T = any>(action: (cancel?: () => void) => T): T {
+    async transaction<T = any>(action: (cancel?: () => void) => Promise<T>): Promise<T> {
         let res;
         if (!this._isInTransaction) {
             this._isInTransaction = true;

src/sqlitedatabase.android.ts

@@ -117,14 +117,14 @@ const eachRaw = <T>(onCursor: FromCursor<T>) => (db: Db) => (
         });
 };
 
-const transactionRaw = <T = any>(db: Db, action: (cancel?: () => void) => T) => {
+const transactionRaw = async <T = any>(db: Db, action: ( (cancel?: () => void) => Promise<T>)) => {
     db.beginTransaction();
     try {
         const cancelled = { value: false };
         const cancel = () => {
             cancelled.value = true;
         };
-        const result = action(cancel);
+        const result = await action(cancel);
         if (!cancelled.value) {
             db.setTransactionSuccessful();
         }
@@ -318,7 +318,7 @@ export class SQLiteDatabaseBase {
     ) {
         return eachRaw(dataFromCursor)(this.db)(query, params, callback, complete);
     }
-    transaction<T = any>(action: (cancel?: () => void) => T): T {
+    async transaction<T = any>(action: (cancel?: () => void) => Promise<T>): Promise<T> {
         return transactionRaw(this.db, action);
     }
 }