core: load monitor as plugin

packages/hydrooj/src/entry/worker.ts

@@ -44,7 +44,7 @@ export async function apply(ctx: Context) {
     await ctx.root.start();
     require('../lib/index');
     await lib(pending, fail, ctx);
-    require('../service/monitor');
+    ctx.plugin(require('../service/monitor'));
     await service(pending, fail, ctx);
     await builtinModel(ctx);
     await model(pending, fail, ctx);

packages/hydrooj/src/interface.ts

@@ -649,7 +649,6 @@ export interface HydroService {
     /** @deprecated */
     bus: Context,
     db: typeof import('./service/db').default,
-    monitor: typeof import('./service/monitor'),
     server: typeof import('./service/server'),
     storage: typeof import('./service/storage').default,
 }

packages/hydrooj/src/service/monitor.ts

@@ -2,6 +2,7 @@ import { dump } from 'js-yaml';
 import superagent from 'superagent';
 import type { StatusUpdate } from '@hydrooj/utils/lib/sysinfo';
 import * as sysinfo from '@hydrooj/utils/lib/sysinfo';
+import { Context } from '../context';
 import { Logger } from '../logger';
 import * as bus from './bus';
 import db from './db';
@@ -90,8 +91,9 @@ export async function updateJudge(args) {
     );
 }
 
-if (process.env.NODE_APP_INSTANCE === '0') {
-    bus.on('ready', async () => {
+export function apply(ctx: Context) {
+    if (process.env.NODE_APP_INSTANCE !== '0') return;
+    ctx.on('app/started', async () => {
         sysinfo.get().then((info) => {
             coll.updateOne(
                 { mid: info.mid, type: 'server' },
@@ -103,5 +105,3 @@ if (process.env.NODE_APP_INSTANCE === '0') {
         });
     });
 }
-
-global.Hydro.service.monitor = { feedback, update, updateJudge };