WIP

Author: CMCDragonkai

src/LockBox.ts

@@ -4,15 +4,17 @@ import type {
   Lockable,
   MultiLockRequest,
   MultiLockAcquire,
-  MultiLockAcquired
+  MultiLockAcquired,
 } from './types';
 import { withF, withG } from '@matrixai/resources';
 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,16 +217,23 @@ 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(
         ([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 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);

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,
+};