core: add RecordDetailHandler.postCancel

judge: allow judge without config

packages/hydrojudge/package.json

@@ -1,7 +1,7 @@
 {
     "name": "@hydrooj/hydrojudge",
     "bin": "bin/hydrojudge.js",
-    "version": "2.1.8",
+    "version": "2.1.9",
     "main": "package.json",
     "author": "masnn",
     "dependencies": {

packages/hydrojudge/src/cases.ts

@@ -281,7 +281,7 @@ function convertIniConfig(ini: string) {
     return res;
 }
 
-export default async function readCases(folder: string, cfg: Record<string, any>, args) {
+export default async function readCases(folder: string, cfg: Record<string, any> = {}, args) {
     const iniConfig = path.resolve(folder, 'config.ini');
     const yamlConfig = path.resolve(folder, 'config.yaml');
     let config;

packages/hydrojudge/src/judge/interactive.ts

@@ -39,7 +39,7 @@ function judgeCase(c) {
             status = STATUS.STATUS_RUNTIME_ERROR;
             if (code < 32) message = signals[code];
             else message = `您的程序返回了 ${code}.`;
-        } else[status, score, message] = resInteractor.files.stderr.split('\n');
+        } else [status, score, message] = resInteractor.files.stderr.split('\n');
         ctxSubtask.score = Score[ctxSubtask.subtask.type](ctxSubtask.score, score);
         ctxSubtask.status = Math.max(ctxSubtask.status, status);
         ctx.total_time_usage_ms += time_usage_ms;

packages/hydrojudge/src/service.ts

@@ -16,7 +16,7 @@ declare module 'hydrooj/dist/interface' {
 
 async function postInit() {
     // Only start a single daemon
-    if (!cluster.isFirstWorker) return;
+    if (!global.Hydro.isFirstWorker) return;
     const { compilerText } = require('./utils');
     const tmpfs = require('./tmpfs');
     const { FormatError, CompileError, SystemError } = require('./error');

packages/hydrooj/package.json

@@ -1,6 +1,6 @@
 {
     "name": "hydrooj",
-    "version": "2.13.27",
+    "version": "2.13.28",
     "bin": "bin/hydrooj.js",
     "main": "dist/loader.js",
     "typings": "dist/loader.d.ts",

packages/hydrooj/src/handler/record.ts

@@ -1,6 +1,6 @@
 import { ObjectID } from 'mongodb';
 import { PermissionError, RecordNotFoundError } from '../error';
-import { PERM, CONSTANT } from '../model/builtin';
+import { PERM, CONSTANT, STATUS } from '../model/builtin';
 import * as problem from '../model/problem';
 import * as file from '../model/file';
 import * as record from '../model/record';
@@ -97,6 +97,27 @@ class RecordDetailHandler extends RecordHandler {
         }
         this.back();
     }
+
+    @param('rid', Types.ObjectID)
+    async postCancel(domainId: string, rid: ObjectID) {
+        const rdoc = await record.get(domainId, rid);
+        if (rdoc) {
+            const $set = {
+                status: STATUS.STATUS_CANCELED,
+                score: 0,
+                time: 0,
+                memory: 0,
+                testCases: [{
+                    status: 9, score: 0, time: 0, memory: 0, message: 'score canceled',
+                }],
+            };
+            await Promise.all([
+                record.update(domainId, rid, $set),
+                bus.emit('record/change', rdoc, $set),
+            ]);
+        }
+        this.back();
+    }
 }
 
 class RecordHackHandler extends Handler {
@@ -130,11 +151,11 @@ class RecordHackHandler extends Handler {
 
 /**
  * @deprecated
+ * use RecordDetailHandler.postRejudge instead.
  */
 class RecordRejudgeHandler extends Handler {
     @param('rid', Types.ObjectID)
     async post(domainId: string, rid: ObjectID) {
-        this.checkPerm(PERM.PERM_REJUDGE);
         const rdoc = await record.get(domainId, rid);
         if (rdoc) {
             await record.reset(domainId, rid, true);

packages/hydrooj/src/interface.ts

@@ -569,12 +569,9 @@ declare global {
                 error: typeof import('./error'),
                 Logger: typeof import('./logger'),
                 locales: Dict<Dict<string>>,
+                isFirstWorker: boolean,
             },
             addons: string[],
         }
     }
 }
-
-declare module 'cluster' {
-    let isFirstWorker: boolean;
-}

packages/hydrooj/src/loader.ts

@@ -228,8 +228,8 @@ export async function load() {
             await entry({ entry: argv.entry as string });
             logger.success(`Worker ${process.pid} Started as ${argv.entry}`);
         } else {
-            if (argv.firstWorker) cluster.isFirstWorker = true;
-            else cluster.isFirstWorker = false;
+            if (argv.firstWorker) global.Hydro.isFirstWorker = true;
+            else global.Hydro.isFirstWorker = false;
             logger.info(`Worker ${process.pid} Starting`);
             await entry({ entry: 'worker' });
             logger.success(`Worker ${process.pid} Started`);