core: import.syzoj: async

packages/hydrooj/src/handler/import.syzoj.ts

@@ -12,7 +12,7 @@ import type { ContentNode } from '../interface';
 import * as problem from '../model/problem';
 import { PERM } from '../model/builtin';
 import {
-    Route, Handler, Types, param, post,
+    Route, Handler, Types, post,
 } from '../service/server';
 import storage from '../service/storage';
 import { isPid } from '../lib/validator';
@@ -212,8 +212,8 @@ class ProblemImportSYZOJHandler extends Handler {
     }
 
     @post('url', Types.String, true)
-    @param('pid', Types.String, true, isPid)
-    @param('hidden', Types.Boolean)
+    @post('pid', Types.String, true, isPid)
+    @post('hidden', Types.Boolean)
     @post('prefix', Types.String, true)
     @post('start', Types.UnsignedInt, true)
     @post('end', Types.UnsignedInt, true)
@@ -226,16 +226,19 @@ class ProblemImportSYZOJHandler extends Handler {
             const base = `${prefix}${start}/`;
             assert(base.match(RE_SYZOJ), new ValidationError('prefix'));
             const [, protocol, host] = RE_SYZOJ.exec(base);
-            for (let i = start; i <= end; i++) {
-                // eslint-disable-next-line no-await-in-loop
-                await this.v3(domainId, undefined, hidden, protocol, host, i, true);
-            }
+            (async () => {
+                for (let i = start; i <= end; i++) {
+                    // eslint-disable-next-line no-await-in-loop
+                    await this.v3(domainId, undefined, hidden, protocol, host, i, true);
+                    logger.info('%s %d-%d-%d', prefix, start, i, end);
+                }
+            })().catch(logger.error);
+            this.response.redirect = this.url('problem_main');
         } else {
             assert(url.match(RE_SYZOJ), new ValidationError('url'));
             if (!url.endsWith('/')) url += '/';
             const [, protocol, host, n, pid] = RE_SYZOJ.exec(url);
             if (n === 'p') {
-                // SYZOJ-NG
                 const docId = await this.v3(
                     domainId, targetPid, hidden,
                     protocol, host, pid, false,

packages/hydrooj/src/service/monitor.ts

@@ -5,8 +5,10 @@ import { safeDump } from 'js-yaml';
 import db from './db';
 import * as bus from './bus';
 import * as sysinfo from '../lib/sysinfo';
+import { Logger } from '../logger';
 
 const coll = db.collection('status');
+const logger = new Logger('monitor');
 
 function crypt(str: string) {
     const cipher = crypto.createCipheriv('des-ecb', 'hydro-oj', '');
@@ -47,7 +49,9 @@ export async function feedback() {
         cpu: inf.cpu,
         flags: inf.flags,
     }));
-    axios.post('https://feedback.undefined.moe/', { payload });
+    axios.post('https://feedback.undefined.moe/', { payload }).catch(() => {
+        logger.warn('Cannot connect to hydro center.');
+    });
 }
 
 export async function update() {

packages/hydrooj/src/service/server.ts

@@ -556,7 +556,10 @@ export class Handler {
             const templateName = this.request.query.template || this.response.template;
             if (templateName) {
                 this.response.body = this.response.body || {};
-                await this.render(templateName, this.response.body);
+                const s = templateName.split('.');
+                if (global.Hydro.ui.template[`${s[0]}.${this.domainId}.${s[1]}`]) {
+                    await this.render(`${s[0]}.${this.domainId}.${s[1]}`, this.response.body);
+                } else await this.render(templateName, this.response.body);
             }
         }
     }
@@ -620,8 +623,9 @@ export class Handler {
 
     async onerror(error: HydroError) {
         if (!error.msg) error.msg = () => error.message;
+        if (error instanceof UserFacingError) error.stack = '';
         if (!(error instanceof NotFoundError)) {
-            logger.error(error.msg(), error.params);
+            logger.error(this.request.path, error.msg(), error.params);
             logger.error(error.stack);
         }
         this.response.status = error instanceof UserFacingError ? error.code : 500;
@@ -813,6 +817,7 @@ export class ConnectionHandler {
     async message(message: any) { } // eslint-disable-line
 
     onerror(err: HydroError) {
+        if (err instanceof UserFacingError) err.stack = this.conn.pathname;
         if (!(err instanceof NotFoundError)) logger.error(err);
         this.send({
             error: {