From 77c4f6dd270f514379c5fc2e215d72f4464d9bf9 Mon Sep 17 00:00:00 2001 From: undefined Date: Sat, 7 Aug 2021 12:20:03 +0800 Subject: [PATCH] core: typo fix --- packages/hydrooj/src/handler/contest.ts | 8 ++++---- packages/hydrooj/src/handler/homework.ts | 2 +- packages/hydrooj/src/handler/judge.ts | 6 +++--- packages/hydrooj/src/handler/problem.ts | 4 ++-- packages/hydrooj/src/model/message.ts | 2 +- packages/hydrooj/src/model/system.ts | 8 ++++---- packages/hydrooj/src/service/bus.ts | 4 ++-- 7 files changed, 17 insertions(+), 17 deletions(-) diff --git a/packages/hydrooj/src/handler/contest.ts b/packages/hydrooj/src/handler/contest.ts index acb2de81c..837510d99 100644 --- a/packages/hydrooj/src/handler/contest.ts +++ b/packages/hydrooj/src/handler/contest.ts @@ -113,9 +113,9 @@ export class ContestBoardcastHandler extends Handler { ['Hydro', 'homepage'], ['contest_main', 'contest_main'], [tdoc.title, 'contest_detail', { tid }, true], - ['contest_boardcast'], + ['contest_broadcast'], ]; - this.response.template = 'contest_boardcast.html'; + this.response.template = 'contest_broadcast.html'; this.response.body = path; } @@ -372,7 +372,7 @@ export class ContestDetailProblemSubmitHandler extends ContestProblemHandler { contest.updateStatus(domainId, tid, this.user._id, rid, pid), ]); } - bus.boardcast('record/change', rdoc); + bus.broadcast('record/change', rdoc); if (!pretest && !contest.canShowSelfRecord.call(this, this.tdoc)) { this.response.body = { tid }; this.response.redirect = this.url('contest_detail', { tid }); @@ -415,7 +415,7 @@ export async function apply() { Route('contest_create', '/contest/create', ContestEditHandler); Route('contest_main', '/contest', ContestListHandler, PERM.PERM_VIEW_CONTEST); Route('contest_detail', '/contest/:tid', ContestDetailHandler, PERM.PERM_VIEW_CONTEST); - Route('contest_boardcast', '/contest/:tid/boardcast', ContestBoardcastHandler); + Route('contest_broadcast', '/contest/:tid/broadcast', ContestBoardcastHandler); Route('contest_edit', '/contest/:tid/edit', ContestEditHandler, PERM.PERM_VIEW_CONTEST); Route('contest_scoreboard', '/contest/:tid/scoreboard', ContestScoreboardHandler, PERM.PERM_VIEW_CONTEST); Route('contest_scoreboard_download', '/contest/:tid/export/:ext', ContestScoreboardDownloadHandler, PERM.PERM_VIEW_CONTEST); diff --git a/packages/hydrooj/src/handler/homework.ts b/packages/hydrooj/src/handler/homework.ts index 8a1d5e914..8b5eb1005 100644 --- a/packages/hydrooj/src/handler/homework.ts +++ b/packages/hydrooj/src/handler/homework.ts @@ -240,7 +240,7 @@ class HomeworkDetailProblemSubmitHandler extends HomeworkDetailProblemHandler { rid, pid, false, 0, document.TYPE_HOMEWORK), ]); } - bus.boardcast('record/change', rdoc); + bus.broadcast('record/change', rdoc); this.response.body.tid = tid; this.response.body.rid = rid; if (pretest || contest.canShowSelfRecord.call(this, this.tdoc)) this.response.redirect = this.url('record_detail', { rid }); diff --git a/packages/hydrooj/src/handler/judge.ts b/packages/hydrooj/src/handler/judge.ts index 592ed3902..67a3d57a0 100644 --- a/packages/hydrooj/src/handler/judge.ts +++ b/packages/hydrooj/src/handler/judge.ts @@ -72,7 +72,7 @@ export async function next(body: JudgeResultBody) { if (body.memory !== undefined) $set.memory = body.memory; if (body.progress !== undefined) $set.progress = body.progress; rdoc = await record.update(rdoc.domainId, body.rid, $set, $push); - bus.boardcast('record/change', rdoc, $set, $push); + bus.broadcast('record/change', rdoc, $set, $push); } export async function end(body: JudgeResultBody) { @@ -98,7 +98,7 @@ export async function end(body: JudgeResultBody) { await sleep(100); // Make sure that all 'next' event already triggered rdoc = await record.update(rdoc.domainId, body.rid, $set, $push, $unset); await postJudge(rdoc); - bus.boardcast('record/change', rdoc); // trigger a full update + bus.broadcast('record/change', rdoc); // trigger a full update } export class JudgeFilesDownloadHandler extends Handler { @@ -153,7 +153,7 @@ class JudgeConnectionHandler extends ConnectionHandler { this.processing = t; const $set = { status: builtin.STATUS.STATUS_FETCHED }; const rdoc = await record.update(t.domainId, t.rid, $set, {}); - bus.boardcast('record/change', rdoc, $set, {}); + bus.broadcast('record/change', rdoc, $set, {}); } async message(msg) { diff --git a/packages/hydrooj/src/handler/problem.ts b/packages/hydrooj/src/handler/problem.ts index f01222397..378908554 100644 --- a/packages/hydrooj/src/handler/problem.ts +++ b/packages/hydrooj/src/handler/problem.ts @@ -267,7 +267,7 @@ export class ProblemSubmitHandler extends ProblemDetailHandler { domain.incUserInDomain(domainId, this.user._id, 'nSubmit'), ]); } - bus.boardcast('record/change', rdoc); + bus.broadcast('record/change', rdoc); this.response.body = { rid }; this.response.redirect = this.url('record_detail', { rid }); } @@ -284,7 +284,7 @@ export class ProblemPretestHandler extends ProblemDetailHandler { lang, code, true, input, ); const rdoc = await record.get(domainId, rid); - bus.boardcast('record/change', rdoc); + bus.broadcast('record/change', rdoc); this.response.body = { rid }; } } diff --git a/packages/hydrooj/src/model/message.ts b/packages/hydrooj/src/model/message.ts index dab45f0af..bd57e42c2 100644 --- a/packages/hydrooj/src/model/message.ts +++ b/packages/hydrooj/src/model/message.ts @@ -22,7 +22,7 @@ class MessageModel { const mdoc = { from, to, content, _id: res.insertedId, flag, }; - if (from !== to) bus.boardcast('user/message', to, mdoc); + if (from !== to) bus.broadcast('user/message', to, mdoc); await user.inc(to, 'unreadMsg', 1); return mdoc; } diff --git a/packages/hydrooj/src/model/system.ts b/packages/hydrooj/src/model/system.ts index 3d3f610fd..99731f9cc 100644 --- a/packages/hydrooj/src/model/system.ts +++ b/packages/hydrooj/src/model/system.ts @@ -36,10 +36,10 @@ export function getMany(keys: string[]): any[] { return keys.map((key) => cache[key]); } -export async function set(_id: K, value: SystemKeys[K], boardcast?: boolean): Promise; -export async function set(_id: string, value: K, boardcast?: boolean): Promise; -export async function set(_id: string, value: any, boardcast = true) { - if (boardcast) bus.boardcast('system/setting', { [_id]: value }); +export async function set(_id: K, value: SystemKeys[K], broadcast?: boolean): Promise; +export async function set(_id: string, value: K, broadcast?: boolean): Promise; +export async function set(_id: string, value: any, broadcast = true) { + if (broadcast) bus.broadcast('system/setting', { [_id]: value }); const res = await coll.findOneAndUpdate( { _id }, { $set: { value } }, diff --git a/packages/hydrooj/src/service/bus.ts b/packages/hydrooj/src/service/bus.ts index 0e1f83719..4615611f4 100644 --- a/packages/hydrooj/src/service/bus.ts +++ b/packages/hydrooj/src/service/bus.ts @@ -184,7 +184,7 @@ export async function bail(name: K, ...args: Parameter return null; } -export function boardcast(event: K, ...payload: Parameters) { +export function broadcast(event: K, ...payload: Parameters) { // Process forked by pm2 would also have process.send if (process.send && !cluster.isMaster) { process.send({ @@ -217,5 +217,5 @@ process.on('message', messageHandler); cluster.on('message', messageHandler); global.Hydro.service.bus = { - addListener, bail, boardcast, emit, on, off, once, parallel, prependListener, removeListener, serial, + addListener, bail, broadcast, emit, on, off, once, parallel, prependListener, removeListener, serial, };