96 lines
2.7 KiB
JavaScript
96 lines
2.7 KiB
JavaScript
import cfg from "../src/inc/config.mjs";
|
|
import db from "../src/inc/sql.mjs";
|
|
import fs from "node:fs";
|
|
import readline from 'node:readline/promises';
|
|
|
|
const rl = readline.createInterface({ input: process.stdin, output: process.stdout });
|
|
|
|
// npm run clean -- --dry-run
|
|
const dry = !!process.argv.filter(a => a == '--dry-run').length;
|
|
console.log(`dry run? ${dry}`);
|
|
|
|
const dirs = {
|
|
b: "./public/b",
|
|
t: "./public/t",
|
|
tmp: "./tmp"
|
|
};
|
|
const files = {
|
|
b: (await fs.promises.readdir(dirs.b)) .filter(f => f !== '.empty'),
|
|
t: (await fs.promises.readdir(dirs.t)) .filter(f => f !== '.empty'),
|
|
tmp: (await fs.promises.readdir(dirs.tmp)).filter(f => f !== '.empty')
|
|
};
|
|
const extensions = [ ...Object.values(cfg.mimes), 'mov' ];
|
|
const count = {
|
|
missing: { b: [], t: [] },
|
|
invalid: { b: [], t: [] },
|
|
spare: { b: [], t: [] },
|
|
tmp: files.tmp
|
|
};
|
|
const rows = await db`select id, dest from items where active = true`;
|
|
const f0cks = {
|
|
b: rows.flatMap(f => f.dest),
|
|
t: rows.flatMap(f => `${f.id}.webp`)
|
|
};
|
|
|
|
// missing
|
|
for(const row of rows) {
|
|
if(!fs.existsSync(`${dirs.b}/${row.dest}`))
|
|
count.missing.b.push(row.id);
|
|
if(!fs.existsSync(`${dirs.t}/${row.id}.webp`))
|
|
count.missing.t.push(row.id);
|
|
}
|
|
|
|
// invalid
|
|
count.invalid.b = files.b.filter(f => !extensions.includes(f.toLowerCase().split('.')[1]));
|
|
count.invalid.t = files.t.filter(f => !f.endsWith('.webp'));
|
|
|
|
// spare
|
|
for(const file of files.b)
|
|
if(!f0cks.b.includes(file))
|
|
count.spare.b.push(`${dirs.b}/${file}`);
|
|
|
|
for(const file of files.t)
|
|
if(!f0cks.t.includes(file))
|
|
count.spare.t.push(`${dirs.t}/${file}`);
|
|
|
|
// show confusing summary
|
|
console.log(count);
|
|
|
|
// delete spare if --dry-run
|
|
if(!dry) {
|
|
let q;
|
|
if(count.spare.b.length > 0) {
|
|
q = (await rl.question(`delete ${count.spare.b.length} unnecessary files in ${dirs.b}? [y/N] `)) == 'y';
|
|
if(q) {
|
|
await Promise.all(count.spare.b.map(f => fs.promises.unlink(f)));
|
|
console.log(`deleted ${count.spare.b.length} files`);
|
|
}
|
|
else
|
|
console.log('abort...');
|
|
}
|
|
|
|
if(count.spare.t.length > 0) {
|
|
q = (await rl.question(`delete ${count.spare.t.length} unnecessary files in ${dirs.t}? [y/N] `)) == 'y';
|
|
if(q) {
|
|
await Promise.all(count.spare.t.map(f => fs.promises.unlink(f)));
|
|
console.log(`deleted ${count.spare.t.length} files`);
|
|
}
|
|
else
|
|
console.log('abort...');
|
|
}
|
|
|
|
if(files.tmp.length > 0) {
|
|
q = (await rl.question(`delete ${files.tmp.length} files in ${dirs.tmp}? [y/N] `)) == 'y';
|
|
if(q) {
|
|
await Promise.all(files.tmp.map(f => fs.promises.unlink(`${dirs.tmp}/${f}`)));
|
|
console.log(`deleted ${files.tmp.length} files`);
|
|
}
|
|
else
|
|
console.log('abort...');
|
|
}
|
|
}
|
|
|
|
// close connection
|
|
await db.end();
|
|
process.exit();
|