From 3d22913869737e9e0e78d26315a3ce298630b2ad Mon Sep 17 00:00:00 2001 From: sunlei Date: Thu, 4 Jun 2026 13:33:05 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8DQQBot=E5=8F=8D?= =?UTF-8?q?=E5=90=91WS=E5=90=AF=E5=8A=A8=E5=B4=A9=E6=BA=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/qqbot/connection/qqbot-reverse-ws.service.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/qqbot/connection/qqbot-reverse-ws.service.ts b/src/qqbot/connection/qqbot-reverse-ws.service.ts index 3bd0e24..651720b 100644 --- a/src/qqbot/connection/qqbot-reverse-ws.service.ts +++ b/src/qqbot/connection/qqbot-reverse-ws.service.ts @@ -8,7 +8,7 @@ import { } from '@nestjs/common'; import { ConfigService } from '@nestjs/config'; import { HttpAdapterHost, ModuleRef } from '@nestjs/core'; -import WebSocket from 'ws'; +import { WebSocket, WebSocketServer } from 'ws'; import { ToolsService } from '@/common'; import { QQBOT_MQTT_TOPICS, QQBOT_REVERSE_WS_PATH } from '../qqbot.constants'; import type { @@ -28,7 +28,7 @@ export class QqbotReverseWsService private readonly logger = new Logger(QqbotReverseWsService.name); private readonly connections = new Map(); private readonly pendingActions = new Map(); - private server: WebSocket.Server | null = null; + private server: WebSocketServer | null = null; constructor( private readonly configService: ConfigService, @@ -46,7 +46,7 @@ export class QqbotReverseWsService } const httpServer = this.httpAdapterHost.httpAdapter.getHttpServer(); - this.server = new WebSocket.Server({ noServer: true }); + this.server = new WebSocketServer({ noServer: true }); httpServer.on( 'upgrade', (request: IncomingMessage, socket: Socket, head) => {