mirror of
https://github.com/diegosouzapw/OmniRoute.git
synced 2026-07-31 12:22:14 +03:00
3f7765fdc8
- Add MemoryCards, CachePerformance, CacheTrends, IdempotencyLayer components - Add loading states, error handling, empty state messages - Add auth guard to /api/cache/stats endpoint (returns 401 unauthenticated) - Add idempotencyWindowMs to settings (configurable via UI) - Update getIdempotencyStats() to read window from settings - Add vitest config for component testing - Add TDD tests for all 4 components (30 tests passing) Wave 1-3 complete. Tests pass, build passes.
106 lines
2.7 KiB
TypeScript
106 lines
2.7 KiB
TypeScript
/**
|
|
* 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();
|
|
}
|