engineering
/
cloudservices
3
0
Fork 1
Code Issues 5 Pull Requests Packages Projects Releases Wiki Activity

fix for disk blocking

merge-requests/1/merge
Matthew 2019-12-13 19:23:48 -05:00
parent 0838022eae
commit cb097067b5
No known key found for this signature in database
GPG Key ID: 766BE43AE75F7559
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/intervals/storage.ts
View File

@ -6,16 +6,18 @@ export default async function storage(client: Client) {
const main = async () => { const main = async () => {
const accounts = await client.db.Account.find(); const accounts = await client.db.Account.find();
for (const account of accounts) { for (const account of accounts) {
const res = await client.util.exec(`du -bs /home/${account.username}`); setTimeout(async () => {
let bytes = Number(res.split('/')[0].replace('\t', '')); const res = await client.util.exec(`du -bs /home/${account.username}`);
try { let bytes = Number(res.split('/')[0].replace('\t', ''));
await fs.access(`/var/mail/${account.username}`, fs.constants.F_OK); try {
const res2 = await client.util.exec(`du -bs /var/mail/${account.username}`); await fs.access(`/var/mail/${account.username}`, fs.constants.F_OK);
bytes += Number(res2.split('/')[0].replace('\t', '')); const res2 = await client.util.exec(`du -bs /var/mail/${account.username}`);
} catch { bytes += Number(res2.split('/')[0].replace('\t', ''));
bytes += 0; } catch {
} bytes += 0;
await client.redis.set(`storage-${account.username}`, bytes); }
await client.redis.set(`storage-${account.username}`, bytes);
}, 600000);
} }
}; };
await main(); await main();