add isFree

src/aragami.ts

@@ -206,6 +206,17 @@ export class Aragami {
     return this.driver.lock(actualKeys, async () => await cb());
   }
 
+  async isFree(keys: MayBeArray<string | any>) {
+    const keyMeta = makeArray(keys);
+    const actualKeys = (
+      await Promise.all(keyMeta.map((o) => this.getLockKeys(o)))
+    ).flat();
+    if (!keys.length) {
+      return true;
+    }
+    return this.driver.isFree(actualKeys);
+  }
+
   useLock<A extends any[], R>(
     cb: (...args: A) => R,
     keySource: (...args: A) => Awaitable<MayBeArray<string | any>>,

src/base-driver.ts

@@ -47,6 +47,10 @@ export class BaseDriver {
     return cb();
   }
 
+  async isFree(keys: string[]): Promise<boolean> {
+    return true;
+  }
+
   async destroy(): Promise<void> {}
 
   async isQueueEmpty(key: string): Promise<boolean> {

src/drivers/memory.ts

@@ -79,6 +79,10 @@ export class MemoryDriver extends BaseDriver {
     return this.betterLock.acquire(keys, cb);
   }
 
+  override async isFree(keys: string[]): Promise<boolean> {
+    return keys.every((key) => this.betterLock.canAcquire(key));
+  }
+
   private queues = new Map<string, Buffer[]>();
   private blockingGathers = new Map<string, ((buf: Buffer) => void)[]>();
 

src/drivers/redis.ts

@@ -95,6 +95,13 @@ export class RedisDriver extends BaseDriver {
     );
   }
 
+  override async isFree(keys: string[]): Promise<boolean> {
+    const lockKeys = keys.map(
+      (key) => `${this.options.lock?.prefix || '_lock'}:${key}`,
+    );
+    return (await this.pool.use((r) => r.redis.exists(...lockKeys))) === 0;
+  }
+
   quitted = false;
 
   async destroy() {