Dynamic namespaces randomly fail to dispatch

[iliasmentz]

Hello,

I have a socket.io server that has two dynamic namespaces:

export class Server {
  public server: IOServer;
  private em: EntityManager;
  private userNamespace: Namespace;
  private venueNamespace: Namespace;

  constructor() {
    this.server = new IOServer({
      cors: {
        origin: '*',
        methods: ['GET', 'POST'],
      },
    });

    // Set global dynamic namespace to accept venueIds
    this.userNamespace = this.server.of(/\d+$/);
    this.venueNamespace = this.server.of(/\d+\/venue$/);
  }

  private async initializeDB() {
    const db = new DB();
    await db.connectDb();
    this.em = db.getEm();
    logger.info(`Initialized API database`);
  }

  private async initializeMiddlewares() {
    // Initialize middleware functions
    const lookupUser = lookupUserMiddleware(this.em);
    const lookupVenue = lookupVenueMiddleware(this.em);

    // Attach middleware to the server
    this.userNamespace.use(loggerConnectionMiddleware);
    this.userNamespace.use(isAuthenticated);
    this.userNamespace.use(lookupUser);
    this.userNamespace.use(lookupVenue);

    // Attach venue user middleware
    this.userNamespace.use(loggerConnectionMiddleware);
    this.venueNamespace.use(isAuthenticatedVenueUser);
  }

  private async initializeEventListeners() {
    const onConnect = onConnectHandler(this.server, this.em);

    require('events').captureRejections = true;
    // Attach handlers to events
    this.userNamespace.on('connection', onConnect);

    this.venueNamespace.on('connection', onVenueConnect);
  }

  async initialize(): Promise<void> {
    const port = 3060;
    await this.initializeDB();
    await this.initializeMiddlewares();
    await this.initializeEventListeners();

    this.server.listen(port);
    logger.info(`Venue websocket server listening on the port ${port}`);
  }
}

Although this seems to work fine in the beginning, after a while, one of them (not a specific one) stops dispatching the events. It happens only to one of the dynamic namespaces, meaning only the namespace /1 or the /1/venue stops dispatching events. Namespaces /3 and /3/venue work without an issue.

I also enabled the socket.io logs and I see this (example where naming /1 stopped working:

/1/venue working (you can see my custom logs as well)

Date,Host,Service,Message
"2022-12-08T18:18:01.785Z","2022-12-08T18:18:01.784Z socket.io:socket dispatching an event [""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""},null]"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io-parser decoded 2/1,0[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}] as {""type"":2,""nsp"":""/1"",""id"":0,""data"":[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]}"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket emitting event [""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket attaching ack callback to event"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket got packet {""type"":2,""nsp"":""/1"",""id"":0,""data"":[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:namespace adding socket to nsp /1"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io-parser encoding packet {""type"":0,""data"":{""sid"":""lVYef_Zges2fImPNAAFJ""},""nsp"":""/1""}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:socket join room lVYef_Zges2fImPNAAFJ"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io-parser encoded {""type"":0,""data"":{""sid"":""lVYef_Zges2fImPNAAFJ""},""nsp"":""/1""} as 0/1,{""sid"":""lVYef_Zges2fImPNAAFJ""}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:socket socket connected - writing packet"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.494Z socket.io:client connecting to namespace /1"
"2022-12-08T18:17:58.494Z","2022-12-08T18:17:58.494Z socket.io-parser decoded 0/1,{""token"":""<TOKEN>""} as {""type"":0,""nsp"":""/1"",""data"":{""token"":""<TOKEN>""}}"
"2022-12-08T18:17:58.306Z","2022-12-08T18:17:58.306Z engine handshaking client ""EhBqLYg7LENNOb3KAAFI"""
"2022-12-08T18:17:58.306Z","2022-12-08T18:17:58.306Z socket.io:server incoming connection with id EhBqLYg7LENNOb3KAAFI"

/1 not working (custom logs missing)

Date,Host,Service,Message
"2022-12-08T18:18:01.785Z","2022-12-08T18:18:01.784Z socket.io:socket dispatching an event [""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""},null]"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io-parser decoded 2/1,0[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}] as {""type"":2,""nsp"":""/1"",""id"":0,""data"":[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]}"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket emitting event [""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket attaching ack callback to event"
"2022-12-08T18:18:01.784Z","2022-12-08T18:18:01.784Z socket.io:socket got packet {""type"":2,""nsp"":""/1"",""id"":0,""data"":[""client.venue.message"",{""id"":""1f27448f-6858-4690-8d76-1aa47161196b"",""created_at"":""2022-12-08T18:18:02.397+0000"",""content"":""Mob""}]}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:namespace adding socket to nsp /1"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io-parser encoding packet {""type"":0,""data"":{""sid"":""lVYef_Zges2fImPNAAFJ""},""nsp"":""/1""}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:socket join room lVYef_Zges2fImPNAAFJ"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io-parser encoded {""type"":0,""data"":{""sid"":""lVYef_Zges2fImPNAAFJ""},""nsp"":""/1""} as 0/1,{""sid"":""lVYef_Zges2fImPNAAFJ""}"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.495Z socket.io:socket socket connected - writing packet"
"2022-12-08T18:17:58.495Z","2022-12-08T18:17:58.494Z socket.io:client connecting to namespace /1"
"2022-12-08T18:17:58.494Z","2022-12-08T18:17:58.494Z socket.io-parser decoded 0/1,{""token"":""<TOKEN>""} as {""type"":0,""nsp"":""/1"",""data"":{""token"":""<TOKEN>""}}"
"2022-12-08T18:17:58.306Z","2022-12-08T18:17:58.306Z engine handshaking client ""EhBqLYg7LENNOb3KAAFI"""
"2022-12-08T18:17:58.306Z","2022-12-08T18:17:58.306Z socket.io:server incoming connection with id EhBqLYg7LENNOb3KAAFI"

any ideas on what can introduce this?

Thank you in advance