Update autodelete.js
This commit is contained in:
@@ -6,8 +6,8 @@ let ignoredMessages = new Set();
|
|||||||
let isFirstDeletion = true;
|
let isFirstDeletion = true;
|
||||||
|
|
||||||
const DELETION_DELAY = 5 * 60 * 1000;
|
const DELETION_DELAY = 5 * 60 * 1000;
|
||||||
const MIN_DELETE_INTERVAL = 1500;
|
const MIN_DELETE_INTERVAL = 2500;
|
||||||
const MAX_DELETE_INTERVAL = 3000;
|
const MAX_DELETE_INTERVAL = 3500;
|
||||||
|
|
||||||
const getRandomInterval = () => {
|
const getRandomInterval = () => {
|
||||||
return Math.floor(Math.random() * (MAX_DELETE_INTERVAL - MIN_DELETE_INTERVAL)) + MIN_DELETE_INTERVAL;
|
return Math.floor(Math.random() * (MAX_DELETE_INTERVAL - MIN_DELETE_INTERVAL)) + MIN_DELETE_INTERVAL;
|
||||||
@@ -20,12 +20,23 @@ const processDeleteQueue = async () => {
|
|||||||
const messageToDelete = deleteQueue.shift();
|
const messageToDelete = deleteQueue.shift();
|
||||||
if (!messageToDelete) return;
|
if (!messageToDelete) return;
|
||||||
|
|
||||||
|
const deleteDelay = Math.floor(Math.random() * 100) + 50;
|
||||||
|
await new Promise(resolve => setTimeout(resolve, deleteDelay));
|
||||||
|
console.log(`[AUTODELETE] Waited ${deleteDelay}ms before processing`);
|
||||||
|
|
||||||
if (isFirstDeletion || Math.random() < 0.2) {
|
if (isFirstDeletion || Math.random() < 0.2) {
|
||||||
console.log(`[AUTODELETE] Checking message ${messageToDelete.id} existence${isFirstDeletion ? ' (first deletion)' : ''}`);
|
console.log(`[AUTODELETE] Checking message ${messageToDelete.id} existence${isFirstDeletion ? ' (first deletion)' : ''}`);
|
||||||
const exists = await messageToDelete.fetch().catch(() => null);
|
const exists = await messageToDelete.fetch().catch(() => null);
|
||||||
if (!exists) {
|
if (!exists) {
|
||||||
console.log(`[AUTODELETE] Message ${messageToDelete.id} no longer exists, skipping`);
|
console.log(`[AUTODELETE] Message ${messageToDelete.id} no longer exists, skipping`);
|
||||||
isFirstDeletion = false;
|
isFirstDeletion = false;
|
||||||
|
if (deleteQueue.length > 0 && isProcessingQueue) {
|
||||||
|
const nextInterval = getRandomInterval();
|
||||||
|
console.log(`[AUTODELETE] Next deletion in ${nextInterval}ms | Queue size: ${deleteQueue.length}`);
|
||||||
|
setTimeout(processDeleteQueue, nextInterval);
|
||||||
|
} else {
|
||||||
|
isProcessingQueue = false;
|
||||||
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user