import { createDedupeCache, resolveDedupeNonNegativeInteger } from "../infra/dedupe.js";

import { createDedupeCache } from "../infra/dedupe.js";

import { resolveNonNegativeIntegerOption } from "../infra/numeric-options.js";

import type { FileLockOptions } from "./file-lock.js";

import { withFileLock } from "./file-lock.js";

import { readJsonFileWithFallback, writeJsonFileAtomically } from "./json-store.js";

/** Create a dedupe helper that combines in-memory fast checks with a lock-protected disk store. */

export function createPersistentDedupe(options: PersistentDedupeOptions): PersistentDedupe {

const ttlMs = resolveDedupeNonNegativeInteger(options.ttlMs, 0);

const memoryMaxSize = resolveDedupeNonNegativeInteger(options.memoryMaxSize, 0);

const fileMaxEntries = Math.max(1, resolveDedupeNonNegativeInteger(options.fileMaxEntries, 1));

const ttlMs = resolveNonNegativeIntegerOption(options.ttlMs, 0);

const memoryMaxSize = resolveNonNegativeIntegerOption(options.memoryMaxSize, 0);

const fileMaxEntries = Math.max(1, resolveNonNegativeIntegerOption(options.fileMaxEntries, 1));

const lockOptions = mergeLockOptions(options.lockOptions);

const memory = createDedupeCache({ ttlMs, maxSize: memoryMaxSize });

const inflight = new Map<string, Promise<boolean>>();

/** Create a claim/commit/release dedupe guard backed by memory and optional persistent storage. */

export function createClaimableDedupe(options: ClaimableDedupeOptions): ClaimableDedupe {

const ttlMs = resolveDedupeNonNegativeInteger(options.ttlMs, 0);

const memoryMaxSize = resolveDedupeNonNegativeInteger(options.memoryMaxSize, 0);

const ttlMs = resolveNonNegativeIntegerOption(options.ttlMs, 0);

const memoryMaxSize = resolveNonNegativeIntegerOption(options.memoryMaxSize, 0);

const memory = createDedupeCache({ ttlMs, maxSize: memoryMaxSize });

const persistent =

options.resolveFilePath != null

? createPersistentDedupe({

ttlMs,

memoryMaxSize,

fileMaxEntries: Math.max(1, resolveDedupeNonNegativeInteger(options.fileMaxEntries, 1)),

fileMaxEntries: Math.max(1, resolveNonNegativeIntegerOption(options.fileMaxEntries, 1)),

resolveFilePath: options.resolveFilePath,

lockOptions: options.lockOptions,

onDiskError: options.onDiskError,