Function onMessage

packages/socket.io-adapter/lib/cluster-adapter.ts:197–352

* Called when receiving a message from another member of the cluster. * * @param message * @param offset * @protected

(message: ClusterMessage, offset?: string)

   * @protected
   */
  protected onMessage(message: ClusterMessage, offset?: string) {
    if (message.uid === this.uid) {
      return debug("[%s] ignore message from self", this.uid);
    }

    if (message.nsp !== this.nsp.name) {
      return debug(
        "[%s] ignore message from another namespace (%s)",
        this.uid,
        message.nsp,
      );
    }

    debug(
      "[%s] new event of type %d from %s",
      this.uid,
      message.type,
      message.uid,
    );

    switch (message.type) {
      case MessageType.BROADCAST: {
        const withAck = message.data.requestId !== undefined;
        if (withAck) {
          super.broadcastWithAck(
            message.data.packet,
            decodeOptions(message.data.opts),
            (clientCount) => {
              debug(
                "[%s] waiting for %d client acknowledgements",
                this.uid,
                clientCount,
              );
              this.publishResponse(message.uid, {
                type: MessageType.BROADCAST_CLIENT_COUNT,
                data: {
                  requestId: message.data.requestId,
                  clientCount,
                },
              });
            },
            (arg) => {
              debug(
                "[%s] received acknowledgement with value %j",
                this.uid,
                arg,
              );
              this.publishResponse(message.uid, {
                type: MessageType.BROADCAST_ACK,
                data: {
                  requestId: message.data.requestId,
                  packet: arg,
                },
              });
            },
          );
        } else {
          const packet = message.data.packet;