fix: clearTimeout if item is evicted from cache

This commit is contained in:
Barış Soner Uşaklı
2025-07-27 10:35:17 -04:00
parent 2d1a5fea11
commit 0997fbfa4d

View File

@@ -348,7 +348,16 @@ ActivityPub.get = async (type, id, uri, options) => {
} }
}; };
ActivityPub.retryQueue = lru({ name: 'activitypub-retry-queue', max: 4000, ttl: 1000 * 60 * 60 * 24 * 60 }); ActivityPub.retryQueue = lru({
name: 'activitypub-retry-queue',
max: 4000,
ttl: 1000 * 60 * 60 * 24 * 60,
dispose: (value) => {
if (value) {
clearTimeout(value);
}
},
});
// handle clearing retry queue from another member of the cluster // handle clearing retry queue from another member of the cluster
pubsub.on(`activitypub-retry-queue:lruCache:del`, (keys) => { pubsub.on(`activitypub-retry-queue:lruCache:del`, (keys) => {