Introducing PCC locking for DBTransaction

Author: CMCDragonkai

package-lock.json

@@ -28,9 +28,9 @@
   },
   "dependencies": {
     "@matrixai/async-init": "^1.8.1",
-    "@matrixai/async-locks": "^2.3.1",
+    "@matrixai/async-locks": "^3.0.0",
     "@matrixai/errors": "^1.1.2",
-    "@matrixai/logger": "^2.2.2",
+    "@matrixai/logger": "^2.3.0",
     "@matrixai/resources": "^1.1.3",
     "@matrixai/workers": "^1.3.3",
     "node-gyp-build": "4.4.0",

package.json

@@ -1,4 +1,5 @@
 import type { ResourceAcquire } from '@matrixai/resources';
+import type { RWLockWriter } from '@matrixai/async-locks';
 import type {
   KeyPath,
   LevelPath,
@@ -20,6 +21,7 @@ import {
   CreateDestroyStartStop,
   ready,
 } from '@matrixai/async-init/dist/CreateDestroyStartStop';
+import { LockBox } from '@matrixai/async-locks';
 import DBIterator from './DBIterator';
 import DBTransaction from './DBTransaction';
 import { rocksdbP } from './rocksdb';
@@ -69,6 +71,7 @@ class DB {
   protected fs: FileSystem;
   protected logger: Logger;
   protected workerManager?: DBWorkerManagerInterface;
+  protected _lockBox: LockBox<RWLockWriter> = new LockBox();
   protected _db: RocksDBDatabase;
   /**
    * References to iterators
@@ -97,6 +100,10 @@ class DB {
     return this._transactionRefs;
   }
 
+  get lockBox(): Readonly<LockBox<RWLockWriter>> {
+    return this._lockBox;
+  }
+
   constructor({
     dbPath,
     crypto,
@@ -193,6 +200,7 @@ class DB {
     return async () => {
       const tran = new DBTransaction({
         db: this,
+        lockBox: this._lockBox,
         logger: this.logger,
       });
       return [