Nest.js cluster mode and sticky sessions

[Bubuioc]

Hello community, i am developing a chat app with Nest.js and SocketIo and i want to run it in cluster mode and still have polling as transport,I know that for this i need to have an adapter and sticky sessions enabled.With the adapter i succeed(here is the code)

import { INestApplicationContext } from '@nestjs/common';
import { IoAdapter } from '@nestjs/platform-socket.io';
import { Server, ServerOptions } from 'socket.io';
import { WsAuthMiddleware } from '../../../core/socket/middlewares/ws.auth.middleware';
import { createAdapter } from '@socket.io/redis-streams-adapter';
import { ConfigService } from '@nestjs/config';
import { RedisService } from 'src/core/redis/redis.service';
import { DEFAULT_NAMESPACE } from 'src/common/constants/constants';
import { SocketService } from '../socket.service';
import { WsQueryValidationMiddleware } from '../middlewares/ws.query.validation.middleware';

export class SocketIOAdapter extends IoAdapter {
  private configService: ConfigService;
  private redisService: RedisService;
  private adapterConstructor: ReturnType<typeof createAdapter>;

  constructor(private app: INestApplicationContext) {
    super(app);
    this.configService = this.app.get(ConfigService);
    this.redisService = this.app.get(RedisService);
    this._createClient();
  }

  private _createClient(): void {
    const streamName = this.configService.get<string>('redisConfig.streamName');
    const redisClient = this.redisService.getClient();
    this.adapterConstructor = createAdapter(redisClient, { streamName });
  }

  createIOServer(port: number, options?: ServerOptions): Server {
    const server: Server = super.createIOServer(port, options);
    server.adapter(this.adapterConstructor);

    server.of(DEFAULT_NAMESPACE).use(WsAuthMiddleware);
    server.of(DEFAULT_NAMESPACE).use(WsQueryValidationMiddleware);

    return server;
  }
}

But i got stuck for sticky sessions here is mine main.ts

async function bootstrap() {
  const logger = new Logger();
  const app = await NestFactory.create(AppModule);
  app.useGlobalPipes(new ValidationPipe({ transform: true }));
  app.enableCors({
    origin: '*',
  });

  const socketIOAdapter = new SocketIOAdapter(app);
  app.useWebSocketAdapter(socketIOAdapter);
  const configService: ConfigService = app.get(ConfigService);

  const port: number = configService.get('port');
  const nodeEnv: string = configService.get('NODE_ENV');

  if (nodeEnv !== NODE_ENV.PRODUCTION) {
    const config = new DocumentBuilder()
      .setTitle('Chat application')
      .setDescription('The corporative chat application written in Nest')
      .setVersion('1.0')
      .addBearerAuth({ type: 'http', name: 'accessToken' })
      .build();
    const document = SwaggerModule.createDocument(app, config);
    SwaggerModule.setup('api/docs', app, document);
  }
  const httpServer = app.getHttpServer();
  const io = new Server(httpServer);
  setupWorker(io);
  await app.listen(port);

  logger.log(
    `Find docs on http://localhost:${port}/api/docs`,
    'NestApplication',
  );
}

const runningOnCluster: boolean =
  Object.values(NODE_ENV)
    .filter((env) => env !== NODE_ENV.LOCAL)
    .findIndex((env) => env === process.env.NODE_ENV) > -1;

if (runningOnCluster) {
  if (clusterInstance.isPrimary) {
    const httpServer = http.createServer();

    setupMaster(httpServer, {
      loadBalancingMethod: 'least-connection',
    });

    clusterInstance.setupPrimary({
      serialization: 'advanced',
    });

    const cpuCount = os.cpus().length;
    for (let i = 0; i < cpuCount; i += 1) {
      clusterInstance.fork();
    }
    clusterInstance.on('online', (worker) => {
      Logger.log(`${worker.process.pid} is online`, 'NestApplication::Cluster');
    });
    clusterInstance.on('exit', ({ process }) => {
      Logger.log(`${process.pid} died`, 'NestApplication::Cluster');
    });
  } else {
    bootstrap();
  }
} else {
  bootstrap();
}

getting the error:
Error: server.handleUpgrade() was called more than once with the same socket, possibly due to a misconfiguration
at WebSocketServer.completeUpgrade (C:\chat-backend\node_modules\ws\lib\websocket-server.js:363:13)
at WebSocketServer.handleUpgrade (C:\chat-backend\node_modules\ws\lib\websocket-server.js:339:10)
at callback (C:\chat-backend\node_modules\engine.io\build\server.js:564:21)