From 18c9c493a8e7050dc2d6b4ba57f09834391c366c Mon Sep 17 00:00:00 2001
From: Roger Qiu <roger.qiu@polyhack.io>
Date: Thu, 30 Jun 2022 16:42:04 +1000
Subject: [PATCH] WIP

---
 src/LockBox.ts | 28 +++++++++++++++++++++-------
 src/types.ts   |  9 ++++++++-
 2 files changed, 29 insertions(+), 8 deletions(-)

diff --git a/src/LockBox.ts b/src/LockBox.ts
index e001d19..ace9726 100644
--- a/src/LockBox.ts
+++ b/src/LockBox.ts
@@ -4,7 +4,7 @@ import type {
   Lockable,
   MultiLockRequest,
   MultiLockAcquire,
-  MultiLockAcquired
+  MultiLockAcquired,
 } from './types';
 import { withF, withG } from '@matrixai/resources';
 import { ErrorAsyncLocksLockBoxConflict } from './errors';
@@ -12,7 +12,9 @@ import { ErrorAsyncLocksLockBoxConflict } from './errors';
 class LockBox<L extends Lockable = Lockable> implements Lockable {
   protected _locks: Map<string, L> = new Map();
 
-  public lock(...requests: Array<MultiLockRequest<L>>): ResourceAcquire<LockBox<L>> {
+  public lock(
+    ...requests: Array<MultiLockRequest<L>>
+  ): ResourceAcquire<LockBox<L>> {
     return async () => {
       // Convert to strings
       // This creates a copy of the requests
@@ -215,8 +217,12 @@ class LockBox<L extends Lockable = Lockable> implements Lockable {
       f: (multiLocks: Array<MultiLockAcquired<L>>) => Promise<T>,
     ]
   ): Promise<T> {
-    const f = params.pop() as (multiLocks: Array<MultiLockAcquired<L>>) => Promise<T>;
-    const lockAcquires = this.lockMulti(...(params as Array<MultiLockRequest<L>>));
+    const f = params.pop() as (
+      multiLocks: Array<MultiLockAcquired<L>>,
+    ) => Promise<T>;
+    const lockAcquires = this.lockMulti(
+      ...(params as Array<MultiLockRequest<L>>),
+    );
 
     const lockAcquires_: Array<ResourceAcquire<MultiLockAcquired<L>>> =
       lockAcquires.map(
@@ -224,7 +230,10 @@ class LockBox<L extends Lockable = Lockable> implements Lockable {
           (...r) =>
             lockAcquire(...r).then(
               ([lockRelease, lock]) =>
-                [lockRelease, [key, lock, ...lockingParams]] as [ResourceRelease, MultiLockAcquired<L>],
+                [lockRelease, [key, lock, ...lockingParams]] as [
+                  ResourceRelease,
+                  MultiLockAcquired<L>,
+                ],
             ),
       );
     return withF(lockAcquires_, f);
@@ -256,14 +265,19 @@ class LockBox<L extends Lockable = Lockable> implements Lockable {
     const g = params.pop() as (
       multiLocks: Array<MultiLockAcquired<L>>,
     ) => AsyncGenerator<T, TReturn, TNext>;
-    const lockAcquires = this.lockMulti(...(params as Array<MultiLockRequest<L>>));
+    const lockAcquires = this.lockMulti(
+      ...(params as Array<MultiLockRequest<L>>),
+    );
     const lockAcquires_: Array<ResourceAcquire<MultiLockAcquired<L>>> =
       lockAcquires.map(
         ([key, lockAcquire, ...lockingParams]) =>
           (...r) =>
             lockAcquire(...r).then(
               ([lockRelease, lock]) =>
-                [lockRelease, [key, lock, ...lockingParams]] as [ResourceRelease, MultiLockAcquired<L>],
+                [lockRelease, [key, lock, ...lockingParams]] as [
+                  ResourceRelease,
+                  MultiLockAcquired<L>,
+                ],
             ),
       );
     return withG(lockAcquires_, g);
diff --git a/src/types.ts b/src/types.ts
index 8bab0f7..15a4f09 100644
--- a/src/types.ts
+++ b/src/types.ts
@@ -41,4 +41,11 @@ type MultiLockAcquired<L extends Lockable = Lockable> = [
   ...lockingParams: Parameters<L['lock']>,
 ];
 
-export type { POJO, ToString, Lockable, MultiLockRequest, MultiLockAcquire, MultiLockAcquired };
+export type {
+  POJO,
+  ToString,
+  Lockable,
+  MultiLockRequest,
+  MultiLockAcquire,
+  MultiLockAcquired,
+};