external-resource-lock.spec.ts

import { expect } from "chai";
import { ONE_MINUTE_IN_MILLIS } from "../util/time-constants";
import { ExternalResourceLock } from "./external-resource-lock";


describe("External Resource Lock", () => {
  it("should work", async () => {

    const g = new ExternalResourceLock("externalDatabases", "database01");

    await g.deleteDoc();

    await g.acquireLock();

    await g.releaseLock();

    // try to get the lock in parallel (should fail, only one can get the lock)
    const pr = [];
    for (let i = 0; i < 10; i++) {
      pr.push(g.acquireLock());
    }
    const r = await Promise.all(pr);

    const locks = r.filter(v => v !== null);

    expect(locks.length).to.equal(1);

    expect(locks[0]?.isLocked).to.equal(true);
    const nv = await g.isLocked();
    expect(nv).to.equal(true);


    // release the lock
    await g.releaseLock();

    const currentStatus = await g.isLocked();

    expect(currentStatus).to.equal(false);

  }).timeout(4 * ONE_MINUTE_IN_MILLIS);
});