Customized message dispatch/handler for NestJS WS

customer.adapter.ts

import { WsAdapter } from '@nestjs/platform-ws';
import { MessageMappingProperties } from '@nestjs/websockets';
import { EMPTY as empty, Observable } from 'rxjs';

export class CustomWsAdapter extends WsAdapter {
  public bindMessageHandler(
    buffer: any,
    handlers: MessageMappingProperties[],
    transform: (data: any) => Observable<any>,
  ): Observable<any> {
    try {
      const message = JSON.parse(buffer.data);
      const messageHandler = handlers.find(
        (handler) => handler.message === 'message',
      );
      const { callback } = messageHandler;
      return transform(callback(message));
    } catch {
      return empty;
    }
  }
}

you are the best