Spaces:
Paused
Paused
File size: 2,783 Bytes
35743bd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 | /**
* Idempotency Layer — Phase 9.2
*
* In-memory deduplication of requests with the same idempotency key.
* If a request with the same key arrives within 5 seconds, returns
* the cached response instead of making a new API call.
*
* Headers: X-Request-Id or Idempotency-Key
*
* @module lib/idempotencyLayer
*/
import { getSettings } from "@/lib/localDb";
const DEFAULT_WINDOW_MS = 5000;
/** @type {Map<string, { response: object, status: number, expiresAt: number }>} */
const idempotencyStore = new Map();
// Periodic cleanup every 30s
let cleanupInterval;
function ensureCleanup() {
if (cleanupInterval) return;
cleanupInterval = setInterval(() => {
const now = Date.now();
for (const [key, entry] of idempotencyStore) {
if (now >= entry.expiresAt) {
idempotencyStore.delete(key);
}
}
}, 30000);
// Don't prevent process exit
if (cleanupInterval.unref) cleanupInterval.unref();
}
/**
* Extract idempotency key from request headers.
* @param {Headers|object} headers
* @returns {string|null}
*/
export function getIdempotencyKey(headers) {
if (!headers) return null;
const get = typeof headers.get === "function" ? (k) => headers.get(k) : (k) => headers[k];
return get("idempotency-key") || get("x-request-id") || null;
}
/**
* Check if a response exists for the given idempotency key.
* @param {string} key
* @returns {{ response: object, status: number }|null}
*/
export function checkIdempotency(key) {
if (!key) return null;
const entry = idempotencyStore.get(key);
if (!entry) return null;
if (Date.now() >= entry.expiresAt) {
idempotencyStore.delete(key);
return null;
}
return { response: entry.response, status: entry.status };
}
/**
* Save a response for idempotency dedup.
* @param {string} key
* @param {object} response - Response body to cache
* @param {number} status - HTTP status code
* @param {number} [windowMs=5000] - Dedup window in ms
*/
export function saveIdempotency(key, response, status, windowMs = DEFAULT_WINDOW_MS) {
if (!key) return;
ensureCleanup();
idempotencyStore.set(key, {
response,
status,
expiresAt: Date.now() + windowMs,
});
}
/**
* Get current idempotency store stats.
*/
export async function getIdempotencyStats() {
let windowMs = DEFAULT_WINDOW_MS;
try {
const settings = await getSettings();
if (typeof settings.idempotencyWindowMs === "number" && settings.idempotencyWindowMs > 0) {
windowMs = settings.idempotencyWindowMs;
}
} catch {
// Fallback to default if settings unavailable
}
return {
activeKeys: idempotencyStore.size,
windowMs,
};
}
/**
* Clear all idempotency entries (for testing).
*/
export function clearIdempotency() {
idempotencyStore.clear();
}
|