Hessenuk/DiscordTickets
Hessenuk/DiscordTickets
2
0
Fork 0
mirror of https://github.com/Hessenuk/DiscordTickets.git synced 2025-02-23 10:51:22 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(stats): should have retested that...

Browse Source
This commit is contained in:
Isaac 2025-02-12 01:44:56 +00:00
parent 6b0146e099
commit c185afcdfe
No known key found for this signature in database
GPG Key ID: 0DE40AE37BBA5C33
2 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/lib/stats.js
View File

@ -39,16 +39,14 @@ async function sendToHouston(client) {
activated_users: users._count, activated_users: users._count,
arch: process.arch, arch: process.arch,
database: process.env.DB_PROVIDER, database: process.env.DB_PROVIDER,
guilds: await Promise.all( guilds: await relativePool(0.25, 'stats', async pool => Promise.all(
await relativePool(0.25, 'stats', pool => guilds
guilds .filter(guild => client.guilds.cache.has(guild.id))
.filter(guild => client.guilds.cache.has(guild.id)) .map(async guild => {
.map(async guild => { guild.members = client.guilds.cache.get(guild.id).memberCount;
guild.members = client.guilds.cache.get(guild.id).memberCount; return pool.queue(w => w.aggregateGuildForHouston(guild, messages));
return pool.queue(w => w.aggregateGuildForHouston(guild, messages)); }),
}), )),
),
),
id: md5(client.user.id), id: md5(client.user.id),
node: process.version, node: process.version,
os: process.platform, os: process.platform,

5
src/lib/threads.js
View File

@ -18,8 +18,7 @@ async function pool(size, name, fun) {
try { try {
return await fun(pool); return await fun(pool);
} finally { } finally {
await pool.settled(); pool.settled().then(() => pool.terminate());
await pool.terminate();
} }
}; };
@ -35,7 +34,7 @@ async function quick(name, fun) {
// ! this await is extremely important // ! this await is extremely important
return await fun(thread); return await fun(thread);
} finally { } finally {
await Thread.terminate(thread); Thread.terminate(thread);
} }
}; };