vjudge: add support CSG-CPC online judge (#426)

packages/vjudge/src/interface.ts

@@ -1,3 +1,5 @@
+import { JudgeResultBody } from 'hydrooj';
+
 export interface RemoteAccount {
     _id: string;
     type: string;
@@ -20,6 +22,7 @@ declare module 'hydrooj/src/interface' {
         mountInfo?: any;
     }
 }
+type NextFunction = (body: Partial<JudgeResultBody>) => void;
 export interface IBasicProvider {
     ensureLogin(): Promise<boolean | string>;
     getProblem(id: string, meta: Record<string, any>): Promise<{
@@ -32,8 +35,8 @@ export interface IBasicProvider {
     }>;
     entryProblemLists?: string[];
     listProblem(page: number, resync: boolean, listId: string): Promise<string[]>;
-    submitProblem(id: string, lang: string, code: string, info: any, next: any, end: any): Promise<string | void>;
-    waitForSubmission(id: string, next: any, end: any): Promise<void>;
+    submitProblem(id: string, lang: string, code: string, info: any, next: NextFunction, end: NextFunction): Promise<string | void>;
+    waitForSubmission(id: string, next: NextFunction, end: NextFunction): Promise<void>;
 }
 
 export interface BasicProvider {

packages/vjudge/src/providers/csgoj.ts

@@ -0,0 +1,199 @@
+/* eslint-disable no-await-in-loop */
+import { PassThrough } from 'stream';
+import { JSDOM } from 'jsdom';
+import * as superagent from 'superagent';
+import proxy from 'superagent-proxy';
+import { STATUS } from '@hydrooj/utils/lib/status';
+import { sleep } from '@hydrooj/utils/lib/utils';
+import { Logger } from 'hydrooj/src/logger';
+import { IBasicProvider, RemoteAccount } from '../interface';
+
+proxy(superagent as any);
+const logger = new Logger('remote/csgoj');
+const statusDict = {
+    0: STATUS.STATUS_COMPILING,
+    1: STATUS.STATUS_COMPILING,
+    2: STATUS.STATUS_COMPILING,
+    3: STATUS.STATUS_JUDGING,
+    4: STATUS.STATUS_ACCEPTED,
+    5: STATUS.STATUS_WRONG_ANSWER,
+    6: STATUS.STATUS_WRONG_ANSWER,
+    7: STATUS.STATUS_TIME_LIMIT_EXCEEDED,
+    8: STATUS.STATUS_MEMORY_LIMIT_EXCEEDED,
+    9: STATUS.STATUS_OUTPUT_LIMIT_EXCEEDED,
+    10: STATUS.STATUS_RUNTIME_ERROR,
+    11: STATUS.STATUS_COMPILE_ERROR,
+};
+
+/* langs
+csgoj:
+  display: CsgOJ
+  execute: /bin/echo Invalid
+  hidden: true
+  remote: csgoj
+csgoj.0:
+  display: C
+  monaco: c
+  highlight: c astyle-c
+  comment: //
+csgoj.1:
+  display: C++
+  monaco: cpp
+  highlight: cpp astyle-c
+  comment: //
+csgoj.2:
+  display: Pascal
+  monaco: pascal
+  highlight: pascal
+  comment: //
+csgoj.3:
+  display: Java
+  monaco: java
+  highlight: java astyle-java
+  comment: //
+*/
+
+const userAgent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:104.0) Gecko/20100101 Firefox/104.0';
+
+export default class CSGOJProvider implements IBasicProvider {
+    constructor(public account: RemoteAccount, private save: (data: any) => Promise<void>) {
+        if (account.cookie) this.cookie = account.cookie;
+    }
+
+    cookie: string[] = [];
+
+    get(url: string) {
+        logger.debug('get', url);
+        if (!url.includes('//')) url = `${this.account.endpoint || 'https://cpc.csgrandeur.cn'}${url}`;
+        const req = superagent.get(url)
+            .set('Cookie', this.cookie)
+            .set('User-Agent', userAgent);
+        if (this.account.proxy) return req.proxy(this.account.proxy);
+        return req;
+    }
+
+    post(url: string) {
+        logger.debug('post', url, this.cookie);
+        if (!url.includes('//')) url = `${this.account.endpoint || 'https://cpc.csgrandeur.cn'}${url}`;
+        const req = superagent.post(url)
+            .set('Cookie', this.cookie)
+            .set('X-Requested-With', 'XMLHttpRequest')
+            .set('User-Agent', userAgent)
+            .type('form');
+        if (this.account.proxy) return req.proxy(this.account.proxy);
+        return req;
+    }
+
+    get loggedIn() {
+        return this.get('/').then(({ text: html }) => !html
+            .includes('<form id="login_form" class="form-signin" method="post" action="/csgoj/user/login_ajax">'));
+    }
+
+    async ensureLogin() {
+        if (await this.loggedIn) return true;
+        logger.info('retry login');
+        const { header } = await this.get('/csgoj/user/login_ajax');
+        if (header['set-cookie']) {
+            await this.save({ cookie: header['set-cookie'] });
+            this.cookie = header['set-cookie'];
+        }
+        await this.post('/csgoj/user/login_ajax')
+            .set('referer', 'https://cpc.csgrandeur.cn/')
+            .send({
+                user_id: this.account.handle,
+                password: this.account.password,
+            });
+        return this.loggedIn;
+    }
+
+    async getProblem(id: string) {
+        logger.info(id);
+        const res = await this.get(`/csgoj/problemset/problem?pid=${id.split('P')[1]}`);
+        const { window: { document } } = new JSDOM(res.text);
+        const title = document.getElementsByTagName('title')[0].innerHTML.replace(`${id.split('P')[1]}:`, '');
+        const pDescription = document.querySelector('div[name="Description"]');
+        const files = {};
+        const images = {};
+        pDescription.querySelectorAll('img[src]').forEach((ele) => {
+            let src = ele.getAttribute('src').replace('.svg', '.png');
+            src = new URL(src, 'https://cpc.csgrandeur.cn').toString();
+            if (images[src]) {
+                ele.setAttribute('src', `file://${images[src]}.png`);
+                return;
+            }
+            const file = new PassThrough();
+            this.get(src).pipe(file);
+            const fid = String.random(8);
+            images[src] = fid;
+            files[`${fid}.png`] = file;
+            ele.setAttribute('src', `file://${fid}.png`);
+        });
+        const description = [...pDescription.children].map((i) => i.outerHTML).join('');
+        const input = [...document.querySelector('div[name="Input"]').children].map((i) => i.outerHTML).join('');
+        const output = [...document.querySelector('div[name="Output"]').children].map((i) => i.outerHTML).join('');
+        const sampleInput = `\`\`\`input1\n${document.querySelector('div[name="Sample Input"]>pre').innerHTML.trim()}\n\`\`\``;
+        const sampleOutput = `\`\`\`output1\n${document.querySelector('div[name="Sample Output"]>pre').innerHTML.trim()}\n\`\`\``;
+        const contents = [description, input, output, sampleInput, sampleOutput];
+        const hint = document.querySelector('div[name="Hint"]');
+        if (hint.textContent.trim().length > 4) {
+            contents.push([...hint.children].map((i) => i.outerHTML).join(''));
+        }
+        const tag = document.querySelector('div[name="Source"]>a').textContent.trim();
+        const limit = document.querySelectorAll('span[class="inline_span"]');
+        const time = `${+limit[0].textContent.split(' ')[6] * 1000}`;
+        const memory = limit[1].textContent.split(' ')[2];
+        return {
+            title,
+            data: {
+                'config.yaml': Buffer.from(`time: ${time}\nmemory: ${memory}\ntype: remote_judge\nsubType: csgoj\ntarget: ${id}`),
+            },
+            files,
+            tag: [tag],
+            content: JSON.stringify({ zh: contents.join('\n\n') }),
+        };
+    }
+
+    async listProblem(page: number, resync = false) {
+        if (resync && page > 1) return [];
+        const offset = (page - 1) * 100;
+        const result = await this
+            .get(`/csgoj/problemset/problemset_ajax?search=&sort=problem_id&order=asc&offset=${offset}&limit=100`)
+            .set('referer', 'https://cpc.csgrandeur.cn/csgoj/problemset')
+            .set('X-Requested-With', 'XMLHttpRequest');
+        return result.body.rows.map((i) => `P${+i.problem_id}`);
+    }
+
+    async submitProblem(id: string, lang: string, source: string, info, next, end) {
+        await this.ensureLogin();
+        if (!lang.includes('csgoj')) {
+            end({ status: STATUS.STATUS_COMPILE_ERROR, message: `Language not supported: ${lang}` });
+            return null;
+        }
+        const result = await this.post('/csgoj/Problemset/submit_ajax')
+            .set('referer', `https://cpc.csgrandeur.cn/csgoj/problemset/submit?pid=${id.split('P')[1]}`)
+            .send({
+                pid: id.split('P')[1],
+                language: lang.split('csgoj.')[1],
+                source,
+            });
+        return result.body.data.solution_id;
+    }
+
+    async waitForSubmission(id: string, next, end) {
+        let count = 0;
+        while (count < 60) {
+            count++;
+            await sleep(3000);
+            const { body } = await this.get(`/csgoj/Status/status_ajax?solution_id=${id}`).set('X-Requested-With', 'XMLHttpRequest');
+            const status = statusDict[body.rows[0].result] || STATUS.STATUS_SYSTEM_ERROR;
+            if (status === STATUS.STATUS_JUDGING) continue;
+            await end({
+                status,
+                score: status === STATUS.STATUS_ACCEPTED ? 100 : 0,
+                time: body.rows[0].time,
+                memory: body.rows[0].memory,
+            });
+            return;
+        }
+    }
+}

packages/vjudge/src/providers/index.ts

@@ -1,4 +1,5 @@
 import codeforces from './codeforces';
+import csgoj from './csgoj';
 import luogu from './luogu';
 import poj from './poj';
 import spoj from './spoj';
@@ -11,7 +12,7 @@ declare module 'hydrooj/src/interface' {
 }
 
 const vjudge: Record<string, any> = {
-    codeforces, luogu, poj, spoj, uoj,
+    codeforces, csgoj, luogu, poj, spoj, uoj,
 };
 global.Hydro.vjudge = vjudge;
 export = vjudge;