diff --git a/packages/hydrooj/package.json b/packages/hydrooj/package.json index 505ac2826..07e933abf 100644 --- a/packages/hydrooj/package.json +++ b/packages/hydrooj/package.json @@ -1,6 +1,6 @@ { "name": "hydrooj", - "version": "2.37.0", + "version": "2.37.1", "bin": "bin/hydrooj.js", "main": "src/loader", "module": "src/loader", diff --git a/packages/hydrooj/src/model/task.ts b/packages/hydrooj/src/model/task.ts index 5537788bf..60f0ae4da 100644 --- a/packages/hydrooj/src/model/task.ts +++ b/packages/hydrooj/src/model/task.ts @@ -160,7 +160,9 @@ bus.once('app/started', async () => { { ack: { $not: { $elemMatch: { $eq: id } } } }, { $push: { ack: id } }, ); - if (res.value) bus.parallel(res.value.event, ...JSON.parse(res.value.payload)); + const payload = JSON.parse(res.value.payload); + if (process.send) process.send({ type: 'hydro:broadcast', data: { event: res.value.event, payload } }); + if (res.value) bus.parallel(res.value.event, ...payload); // eslint-disable-next-line no-await-in-loop else await sleep(100); }