Function getIdempotencyStore

server/src/training-agent/idempotency.ts:116–123

()

let storeInstance: IdempotencyStore | null = null;

export function getIdempotencyStore(): IdempotencyStore {
  if (storeInstance) return storeInstance;
  const backend = isDatabaseInitialized()
    ? pgBackend(getPool())
    : memoryBackend();
  storeInstance = createIdempotencyStore({ backend, ttlSeconds: REPLAY_TTL_SECONDS });
  return storeInstance;
}

/** Reset the store — tests only. Safe to call when no store has been created. */
export async function clearIdempotencyCache(): Promise<void> {