DistributedLockFactory.mts

import { DistributedLock } from "./DistributedLock.mjs";
import { DistributedLockDb } from "./DistributedLockDb.mjs";
import { logger, TMMLogger } from "@tmm/tools/logger";
import type { Metrics } from "@aws-lambda-powertools/metrics";
import type { DistributedLockDependencies, DistributedLockParams } from "./DistributedLock.mjs";

export class DistributedLockFactory {
    readonly #lockDb: DistributedLockDb;
    readonly #logger: TMMLogger;
    readonly #metrics?: Metrics;
    constructor({ lockDb = new DistributedLockDb(), loggerInstance = logger, metricsInstance }: DistributedLockDependencies = {}) {
        this.#lockDb = lockDb;
        this.#logger = loggerInstance;
        this.#metrics = metricsInstance;
        //mocks may not have setlogger method
        if (typeof this.#lockDb.setlogger === "function") {
            this.#lockDb.setlogger(this.#logger);
        }
    }

    createLock(params: DistributedLockParams): DistributedLock {
        return new DistributedLock(params, { lockDb: this.#lockDb, loggerInstance: this.#logger, metricsInstance: this.#metrics });
    }
}

export type { DistributedLockDependencies, DistributedLockParams };