Weishen/Hydro
2
0 Fork 0
mirror of https://gitcode.com/gh_mirrors/hy/Hydro.git synced 2026-10-20 01:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

judge: handle heartbeat event

Browse Source
This commit is contained in:
undefined committed 2024-01-01 02:55:01 +08:00
1 parent 08839fa0ea
commit 5aa0377b58
1 file changed
+4
Download Patch File Download Diff File Expand all files Collapse all files
packages/hydrojudge/src/hosts/hydro.ts
+4
View File
@@ -198,6 +198,10 @@ export default class Hydro implements Session {
: '{"key":"ping"}'; : '{"key":"ping"}';
setInterval(() => this.ws?.send?.(content), 30000); setInterval(() => this.ws?.send?.(content), 30000);
this.ws.on('message', (data) => { this.ws.on('message', (data) => {
if (data.toString() === 'ping') {
this.ws.send('pong');
return;
}
const request = JSON.parse(data.toString()); const request = JSON.parse(data.toString());
if (request.language) this.language = request.language; if (request.language) this.language = request.language;
if (request.task) queue.add(() => new JudgeTask(this, request.task).handle().catch((e) => log.error(e))); if (request.task) queue.add(() => new JudgeTask(this, request.task).handle().catch((e) => log.error(e)));