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

server: fix ws import

Browse Source
This commit is contained in:
undefined committed 2024-06-10 21:22:13 +08:00
1 parent 3df346289a
commit ae057fee95
2 files changed
+3 -3
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

framework/framework/package.json
+1 -1
View File
@@ -1,6 +1,6 @@
{ {
"name": "@hydrooj/framework", "name": "@hydrooj/framework",
"version": "0.0.2", "version": "0.0.3",
"main": "index.ts", "main": "index.ts",
"peerDependencies": { "peerDependencies": {
"cordis": "*" "cordis": "*"
framework/framework/server.ts
+2 -2
View File
@@ -8,7 +8,7 @@ import Koa from 'koa';
import Body from 'koa-body'; import Body from 'koa-body';
import Compress from 'koa-compress'; import Compress from 'koa-compress';
import { Shorty } from 'shorty.js'; import { Shorty } from 'shorty.js';
import WebSocket from 'ws'; import { WebSocketServer } from 'ws';
import { import {
Counter, errorMessage, isClass, Logger, parseMemoryMB, Counter, errorMessage, isClass, Logger, parseMemoryMB,
} from '@hydrooj/utils/lib/utils'; } from '@hydrooj/utils/lib/utils';
@@ -91,7 +91,7 @@ export const koa = new Koa<Koa.DefaultState, KoaContext>({
}); });
export const router = new Router(); export const router = new Router();
export const httpServer = http.createServer(koa.callback()); export const httpServer = http.createServer(koa.callback());
export const wsServer = new WebSocket.Server({ server: httpServer }); export const wsServer = new WebSocketServer({ server: httpServer });
koa.on('error', (error) => { koa.on('error', (error) => {
if (error.code !== 'EPIPE' && error.code !== 'ECONNRESET' && !error.message.includes('Parse Error')) { if (error.code !== 'EPIPE' && error.code !== 'ECONNRESET' && !error.message.includes('Parse Error')) {
logger.error('Koa app-level error', { error }); logger.error('Koa app-level error', { error });