import-qduoj: skip invalid problems

This commit is contained in:
undefined committed 2022-12-16 15:52:04 +08:00
1 parent 58a5cc0f9e
commit ed68dcf7be
1 file changed
+6 -2
+6 -2
View File
@@ -20,9 +20,11 @@ class ImportQduojHandler extends Handler {
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
zip.extractAllToAsync(tmp, true, (err) => (err ? reject(err) : resolve(null))); zip.extractAllToAsync(tmp, true, (err) => (err ? reject(err) : resolve(null)));
}); });
let cnt = 0;
try { try {
const folders = await fs.readdir(tmp); const folders = await fs.readdir(tmp, { withFileTypes: true });
for (const folder of folders) { for (const { name: folder } of folders.filter((i) => i.isDirectory())) {
if (!fs.existsSync(path.join(tmp, folder, 'problem.json'))) continue;
const buf = await fs.readFile(path.join(tmp, folder, 'problem.json')); const buf = await fs.readFile(path.join(tmp, folder, 'problem.json'));
const pdoc = JSON.parse(buf.toString()); const pdoc = JSON.parse(buf.toString());
const content: ContentNode[] = []; const content: ContentNode[] = [];
@@ -115,10 +117,12 @@ class ImportQduojHandler extends Handler {
ProblemModel.edit(domainId, pid, { html: true }), ProblemModel.edit(domainId, pid, { html: true }),
); );
await Promise.all(tasks); await Promise.all(tasks);
cnt++;
} }
} finally { } finally {
await fs.remove(tmp); await fs.remove(tmp);
} }
if (!cnt) throw new ValidationError('zip', 'No problemset imported');
} }
async get() { async get() {