fix: limit queue cleanup to expired users
This commit is contained in:
+2
-2
@@ -236,8 +236,8 @@ class Appv2 {
|
|||||||
const afterFetchFromDb = Date.now();
|
const afterFetchFromDb = Date.now();
|
||||||
console.log("Fetch from db: "+(Date.now() - startTimeToDebug) / 1000 + " seconds");
|
console.log("Fetch from db: "+(Date.now() - startTimeToDebug) / 1000 + " seconds");
|
||||||
|
|
||||||
for (const user of users) {
|
for (const userId of userToDel) {
|
||||||
const storage = new storageObj(user.id);
|
const storage = new storageObj(userId);
|
||||||
await storage.removeQueue();
|
await storage.removeQueue();
|
||||||
count++;
|
count++;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -55,8 +55,10 @@ class Storage {
|
|||||||
try {
|
try {
|
||||||
await fsp.unlink(this.fileName);
|
await fsp.unlink(this.fileName);
|
||||||
} catch(err) {
|
} catch(err) {
|
||||||
|
if (err?.code !== 'ENOENT') {
|
||||||
console.log(err);
|
console.log(err);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
this.dbObj.deleteUser(this.userId);
|
this.dbObj.deleteUser(this.userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user