forked from engineering/cloudservices
storage interval code cleanup
parent
1371b0efdf
commit
2955aec793
|
@ -4,27 +4,6 @@ import { spawn } from 'child_process';
|
||||||
import { Client } from '..';
|
import { Client } from '..';
|
||||||
|
|
||||||
export default async function storage(client: Client) {
|
export default async function storage(client: Client) {
|
||||||
/* const main = async () => {
|
|
||||||
const accounts = await client.db.Account.find();
|
|
||||||
for (const account of accounts) {
|
|
||||||
setTimeout(async () => {
|
|
||||||
const res = await client.util.exec(`du -bs /home/${account.username}`);
|
|
||||||
let bytes = Number(res.split('/')[0].replace('\t', ''));
|
|
||||||
try {
|
|
||||||
await fs.access(`/opt/mail/${account.username}`, fs.constants.F_OK);
|
|
||||||
const res2 = await client.util.exec(`du -bs /opt/mail/${account.username}`);
|
|
||||||
bytes += Number(res2.split('/')[0].replace('\t', ''));
|
|
||||||
} catch {
|
|
||||||
bytes += 0;
|
|
||||||
}
|
|
||||||
await client.redis.set(`storage-${account.username}`, bytes);
|
|
||||||
}, 600000);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
await main();
|
|
||||||
setInterval(async () => {
|
|
||||||
await main();
|
|
||||||
}, 900000); */
|
|
||||||
let storageGo = spawn(`${__dirname}/../bin/storage`, [], { cwd: __dirname });
|
let storageGo = spawn(`${__dirname}/../bin/storage`, [], { cwd: __dirname });
|
||||||
storageGo.stdout.on('data', (data) => client.signale.log(data.toString()));
|
storageGo.stdout.on('data', (data) => client.signale.log(data.toString()));
|
||||||
storageGo.stderr.on('data', (data) => client.signale.log(data.toString()));
|
storageGo.stderr.on('data', (data) => client.signale.log(data.toString()));
|
||||||
|
|
Loading…
Reference in New Issue