Sự khác biệt duy nhất giữa lớp exception filter ở HTTP và lớp tương ứng ở web sockets là thay vì throw HttpException, bạn nên dùng WsException.
throw new WsException('Invalid credentials.');
Gợi ý Class WsException được import từ package @nestjs/websockets.
Với ví dụ trên, Nest sẽ xử lý exception được throw và emit message exception với cấu trúc sau:
{
status: 'error',
message: 'Invalid credentials.'
}
Filter
Exception filter ở web sockets hoạt động tương đương với exception filter ở HTTP. Ví dụ sau dùng một filter được khởi tạo thủ công theo phạm vi method (method-scoped). Giống như với ứng dụng dựa trên HTTP, bạn cũng có thể dùng filter theo phạm vi gateway (gateway-scoped) (tức là đặt decorator @UseFilters() trước class gateway).
@UseFilters(new WsExceptionFilter())
@SubscribeMessage('events')
onEvent(client, data: any): WsResponse<any> {
const event = 'events';
return { event, data };
}
Kế thừa (Inheritance)
Thông thường, bạn sẽ tạo các exception filter được tùy chỉnh hoàn toàn để đáp ứng yêu cầu của ứng dụng. Tuy nhiên, cũng có những trường hợp bạn chỉ muốn kế thừa (extend) exception filter mặc định của core, và override lại hành vi dựa trên một số yếu tố nhất định.
Để giao việc xử lý exception lại cho filter gốc, bạn cần extend BaseWsExceptionFilter và gọi method catch() đã được kế thừa.
import { Catch, ArgumentsHost } from '@nestjs/common';
import { BaseWsExceptionFilter } from '@nestjs/websockets';
@Catch()
export class AllExceptionsFilter extends BaseWsExceptionFilter {
catch(exception: unknown, host: ArgumentsHost) {
super.catch(exception, host);
}
}
import { Catch } from '@nestjs/common';
import { BaseWsExceptionFilter } from '@nestjs/websockets';
@Catch()
export class AllExceptionsFilter extends BaseWsExceptionFilter {
catch(exception, host) {
super.catch(exception, host);
}
}
Ghi chú người dịch Đoạn code trên chỉ là một cái shell (khung rỗng) để minh họa cách tiếp cận — nó không tự thêm logic gì mới so với hành vi mặc định. Trong PHP/Laravel, đây tương tự việc bạn extend ExceptionHandler mặc định rồi gọi parent::render(): bạn chỉ nên làm vậy khi thật sự cần chèn thêm xử lý riêng (ví dụ log, gửi metric) trước hoặc sau khi gọi hành vi gốc.
Cách triển khai ở trên chỉ là một cái shell minh họa cho cách tiếp cận. Triển khai thực tế của bạn cho exception filter kế thừa này nên bao gồm business logic riêng phù hợp với nhu cầu (ví dụ: xử lý các điều kiện khác nhau).