WIP

Author: CMCDragonkai

src/DB.ts

@@ -146,37 +146,37 @@ class DB {
     delete this.workerManager;
   }
 
-  // @ready(new errors.ErrorDBNotRunning())
-  // public transaction(): ResourceAcquire<DBTransaction> {
-  //   return async () => {
-  //     const transactionId = this.transactionCounter++;
-  //     const tran = await DBTransaction.createTransaction({
-  //       db: this,
-  //       transactionId,
-  //       logger: this.logger,
-  //     });
-  //     return [
-  //       async (e?: Error) => {
-  //         try {
-  //           if (e == null) {
-  //             try {
-  //               await tran.commit();
-  //             } catch (e) {
-  //               await tran.rollback();
-  //               throw e;
-  //             }
-  //             await tran.finalize();
-  //           } else {
-  //             await tran.rollback();
-  //           }
-  //         } finally {
-  //           await tran.destroy();
-  //         }
-  //       },
-  //       tran,
-  //     ];
-  //   };
-  // }
+  @ready(new errors.ErrorDBNotRunning())
+  public transaction(): ResourceAcquire<DBTransaction> {
+    return async () => {
+      const transactionId = this.transactionCounter++;
+      const tran = await DBTransaction.createTransaction({
+        db: this,
+        transactionId,
+        logger: this.logger,
+      });
+      return [
+        async (e?: Error) => {
+          try {
+            if (e == null) {
+              try {
+                await tran.commit();
+              } catch (e) {
+                await tran.rollback();
+                throw e;
+              }
+              await tran.finalize();
+            } else {
+              await tran.rollback();
+            }
+          } finally {
+            await tran.destroy();
+          }
+        },
+        tran,
+      ];
+    };
+  }
 
   /**
    * Gets a value from the DB