Compare commits

...

4 Commits

Author SHA1 Message Date
Bas950
acd9afb2b1 chore: release v0.0.12 2024-09-13 11:32:55 +02:00
Bas950
4bd42390eb chore: move some code 2024-09-13 11:32:44 +02:00
Florian Metz
c014504464 chore: release v0.0.11 2024-09-13 11:00:16 +02:00
Florian Metz
24fe349b60 chore: optimize session cleanup with batch deletion 2024-09-13 10:59:13 +02:00
2 changed files with 19 additions and 6 deletions

View File

@@ -1,7 +1,7 @@
{
"name": "@premid/api-master",
"type": "module",
"version": "0.0.10",
"version": "0.0.12",
"private": true,
"description": "PreMiD's api master",
"license": "MPL-2.0",

View File

@@ -13,12 +13,14 @@ export async function clearOldSessions() {
let cursor = "0";
let totalSessions = 0;
let cleared = 0;
const batchSize = 100;
let keysToDelete = [];
mainLog("Starting session cleanup");
do {
//* Use hscan to iterate through sessions
const [nextCursor, result] = await redis.hscan("pmd-api.sessions", cursor, "COUNT", "100");
const [nextCursor, result] = await redis.hscan("pmd-api.sessions", cursor, "COUNT", batchSize);
cursor = nextCursor;
totalSessions += result.length / 2;
@@ -40,7 +42,7 @@ export async function clearOldSessions() {
if (now - session.lastUpdated < 30000)
continue;
//* Delete the session
//* Mark the session for deletion
try {
const discord = new REST({ version: "10", authPrefix: "Bearer" });
discord.setToken(session.token);
@@ -49,16 +51,27 @@ export async function clearOldSessions() {
token: session.session,
},
});
await redis.hdel("pmd-api.sessions", key);
cleared++;
}
catch (error) {
mainLog(`Failed to delete session: %O`, (typeof error === "object" && error && "message" in error ? error.message : error));
}
keysToDelete.push(key);
cleared++;
//* Delete in batches to avoid memory bloat
if (keysToDelete.length >= batchSize) {
await redis.hdel("pmd-api.sessions", ...keysToDelete);
keysToDelete = [];
}
}
} while (cursor !== "0");
//* Delete any remaining keys
if (keysToDelete.length > 0) {
await redis.hdel("pmd-api.sessions", ...keysToDelete);
}
if (totalSessions === 0) {
mainLog("No sessions to clear");
}