Я пытаюсь добавить проверку в мой WebSocketGateway в Nest JS. Вот код:
// MessageDTO
import { IsNotEmpty, MinLength } from 'class-validator';
export class MessageDTO {
@IsNotEmpty()
username: string;
@IsNotEmpty()
@MinLength(10)
text: string;
}
// Gateway
import { ValidationPipe, UsePipes } from '@nestjs/common';
import { MessageBody, SubscribeMessage, WebSocketGateway, WsResponse } from '@nestjs/websockets';
import { MessageService } from './message/message.service';
import { MessageDTO } from './message/message.dto';
import { Message } from './message/message.entity';
@WebSocketGateway()
export class AppGateway {
constructor(private readonly messageService: MessageService) {}
@UsePipes(new ValidationPipe())
@SubscribeMessage('message')
async handleMessage(@MessageBody() dto: MessageDTO): Promise<WsResponse<Message>> {
const message = await this.messageService.saveMessage(dto);
return { event: 'message', data: message };
}
}
Теперь, когда я пытаюсь отправить сообщение, которое не соответствует правилам проверки, оно выдает ошибку, но клиент всегда получает { status: 'error', message: 'Internal server error'}
. Кроме того, Nest регистрирует ошибку на консоли (что, я полагаю, не должно произойти ...?):
thing_api | Error: Bad Request Exception
thing_api | at ValidationPipe.exceptionFactory (/usr/src/app/node_modules/@nestjs/common/pipes/validation.pipe.js:78:20)
thing_api | at ValidationPipe.transform (/usr/src/app/node_modules/@nestjs/common/pipes/validation.pipe.js:50:24)
thing_api | at processTicksAndRejections (internal/process/task_queues.js:89:5)
thing_api | at async resolveParamValue (/usr/src/app/node_modules/@nestjs/websockets/context/ws-context-creator.js:104:31)
thing_api | at async Promise.all (index 0)
thing_api | at async pipesFn (/usr/src/app/node_modules/@nestjs/websockets/context/ws-context-creator.js:106:13)
thing_api | at async /usr/src/app/node_modules/@nestjs/websockets/context/ws-context-creator.js:41:17
thing_api | at async AppGateway.<anonymous> (/usr/src/app/node_modules/@nestjs/websockets/context/ws-proxy.js:11:32)
thing_api | at async WebSocketsController.pickResult (/usr/src/app/node_modules/@nestjs/websockets/web-sockets-controller.js:85:24)
Однако, если я использую тот же DTO и канал проверки в обычном контроллере, он работает как Очарование - с искаженной полезной нагрузкой я получаю правильно отформатированное сообщение об ошибке. Может кто-нибудь указать, что я делаю не так?