feat(cache): add getLock

README.md

@@ -255,6 +255,11 @@ const isLocked = await Cache.lock("key", 10).get(async () => {
   console.log("do something");
 });
 
+// or
+const isAcquired = await Cache.getLock("key", 10, async () => {
+  console.log("do something");
+});
+
 // or
 const lock = Cache.lock("key", 10);
 

src/cache/index.ts

@@ -1,8 +1,8 @@
 import { memoryCacheDriver } from './drivers'
 
 export interface ICacheLock {
-  acquire: () => Promise<boolean>|boolean
-  release: () => Promise<void>|void
+  acquire: () => Promise<boolean> | boolean
+  release: () => Promise<void> | void
 }
 
 export interface ICacheDriver {
@@ -126,4 +126,8 @@ export class Cache {
       }
     }
   }
+
+  static async getLock (key: string, seconds: number, cb: () => Promise<void> | void) {
+    return await this.lock(key, seconds).get(cb)
+  }
 }

test/cache.test.ts

@@ -125,4 +125,12 @@ describe('cache', () => {
     expect(acquired).toBe(true)
     expect(notAcquired).toBe(false)
   })
+
+  test('atomic lock - getLock', async () => {
+    const acquired = await Cache.getLock('get-lock', 10, async () => {
+      await wait(1000)
+    })
+
+    expect(acquired).toBe(true)
+  })
 })