1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192 |
- "use strict";
- var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
- return new (P || (P = Promise))(function (resolve, reject) {
- function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
- function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
- function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
- step((generator = generator.apply(thisArg, _arguments || [])).next());
- });
- };
- var __importDefault = (this && this.__importDefault) || function (mod) {
- return (mod && mod.__esModule) ? mod : { "default": mod };
- };
- Object.defineProperty(exports, "__esModule", { value: true });
- const p_defer_1 = __importDefault(require("p-defer"));
- function mapAgeCleaner(map, property = 'maxAge') {
- let processingKey;
- let processingTimer;
- let processingDeferred;
- const cleanup = () => __awaiter(this, void 0, void 0, function* () {
- if (processingKey !== undefined) {
-
- return;
- }
- const setupTimer = (item) => __awaiter(this, void 0, void 0, function* () {
- processingDeferred = p_defer_1.default();
- const delay = item[1][property] - Date.now();
- if (delay <= 0) {
-
- map.delete(item[0]);
- processingDeferred.resolve();
- return;
- }
-
- processingKey = item[0];
- processingTimer = setTimeout(() => {
-
- map.delete(item[0]);
- if (processingDeferred) {
- processingDeferred.resolve();
- }
- }, delay);
-
- if (typeof processingTimer.unref === 'function') {
-
- processingTimer.unref();
- }
- return processingDeferred.promise;
- });
- try {
- for (const entry of map) {
- yield setupTimer(entry);
- }
- }
- catch (_a) {
-
- }
- processingKey = undefined;
- });
- const reset = () => {
- processingKey = undefined;
- if (processingTimer !== undefined) {
- clearTimeout(processingTimer);
- processingTimer = undefined;
- }
- if (processingDeferred !== undefined) {
- processingDeferred.reject(undefined);
- processingDeferred = undefined;
- }
- };
- const originalSet = map.set.bind(map);
- map.set = (key, value) => {
- if (map.has(key)) {
-
- map.delete(key);
- }
-
- const result = originalSet(key, value);
-
- if (processingKey && processingKey === key) {
- reset();
- }
-
- cleanup();
- return result;
- };
- cleanup();
- return map;
- }
- exports.default = mapAgeCleaner;
- module.exports = mapAgeCleaner;
- module.exports.default = mapAgeCleaner;
|