Function addSockets

packages/socket.io-adapter/lib/cluster-adapter.ts:510–528

(opts: BroadcastOptions, rooms: Room[])

  }

  override async addSockets(opts: BroadcastOptions, rooms: Room[]) {
    const onlyLocal = opts.flags?.local;

    if (!onlyLocal) {
      try {
        await this.publishAndReturnOffset({
          type: MessageType.SOCKETS_JOIN,
          data: {
            opts: encodeOptions(opts),
            rooms,
          },
        });
      } catch (e) {
        debug("[%s] error while publishing message: %s", this.uid, e.message);
      }
    }

    super.addSockets(opts, rooms);
  }

  override async delSockets(opts: BroadcastOptions, rooms: Room[]) {
    const onlyLocal = opts.flags?.local;