Sự kiện WebSocket

Xử lý sự kiện thời gian thực với các decorator.

Decorator tin nhắn

import { 
  SubscribeMessage, 
  MessageBody, 
  ConnectedSocket 
} from '@galaxy-stack/orbit-websockets';

@WebSocketGateway()
export class EventsGateway {
  @SubscribeMessage('createItem')
  handleCreate(
    @MessageBody() data: CreateItemDto,
    @ConnectedSocket() client: WebSocket,
  ) {
    const item = this.itemsService.create(data);
    return { event: 'itemCreated', data: item };
  }
}

Xác nhận sự kiện

@SubscribeMessage('saveData')
async handleSave(@MessageBody() data: any): Promise<WsResponse<boolean>> {
  await this.dataService.save(data);
  return { event: 'dataSaved', data: true };
}

Nhiều sự kiện

@WebSocketGateway()
export class NotificationsGateway {
  @SubscribeMessage('subscribe')
  handleSubscribe(client: WebSocket, channels: string[]) {
    channels.forEach(channel => client.join(channel));
    return { event: 'subscribed', data: channels };
  }

  @SubscribeMessage('unsubscribe')
  handleUnsubscribe(client: WebSocket, channels: string[]) {
    channels.forEach(channel => client.leave(channel));
    return { event: 'unsubscribed', data: channels };
  }
}

Xử lý lỗi

import { WsException } from '@galaxy-stack/orbit-websockets';

@SubscribeMessage('riskyOperation')
async handleRisky(@MessageBody() data: any) {
  if (!this.isValid(data)) {
    throw new WsException('Dữ liệu không hợp lệ');
  }
  return this.process(data);
}

Interceptor

@UseInterceptors(LoggingInterceptor)
@SubscribeMessage('tracked')
handleTracked(@MessageBody() data: any) {
  return this.process(data);
}

Pipes

@SubscribeMessage('validated')
handleValidated(
  @MessageBody(new ValidationPipe()) data: CreateDto,
) {
  return this.create(data);
}

Phát sự kiện từ Services

@Injectable()
export class AlertsService {
  constructor(private gateway: AlertsGateway) {}

  sendAlert(userId: string, alert: Alert) {
    this.gateway.server.to(userId).emit('alert', alert);
  }

  broadcastAlert(alert: Alert) {
    this.gateway.server.emit('globalAlert', alert);
  }
}