diff --git a/packages/hydrooj/package.json b/packages/hydrooj/package.json index d3eaa1585..ceb433fb3 100644 --- a/packages/hydrooj/package.json +++ b/packages/hydrooj/package.json @@ -1,6 +1,6 @@ { "name": "hydrooj", - "version": "3.12.0", + "version": "3.12.1", "bin": "bin/hydrooj.js", "main": "src/loader", "module": "src/loader", diff --git a/packages/hydrooj/src/service/server.ts b/packages/hydrooj/src/service/server.ts index b5d97f409..c15ceaee7 100644 --- a/packages/hydrooj/src/service/server.ts +++ b/packages/hydrooj/src/service/server.ts @@ -388,13 +388,11 @@ export function Connection( if (h._prepare) await h._prepare(args); if (h.prepare) await h.prepare(args); if (h.message) { - conn.on('data', (data) => { - h.message(JSON.parse(data)); - }); + conn.onmessage = (e) => { + h.message(JSON.parse(e.data.toString())); + }; } - conn.on('close', async () => { - if (h.cleanup) await h.cleanup(args); - }); + conn.onclose = () => h.cleanup?.(args); } catch (e) { await h.onerror(e); }