Method publish

packages/socket.io-redis-streams-emitter/lib/index.ts:472–495

(
    message: DistributiveOmit<ClusterMessage, "uid" | "nsp">,
  )

  }

  protected override publish(
    message: DistributiveOmit<ClusterMessage, "uid" | "nsp">,
  ) {
    (message as ClusterMessage).uid = EMITTER_UID;
    (message as ClusterMessage).nsp = this.#nsp;

    debug(
      "publishing message %s to stream %s",
      message.type,
      this.#opts.streamName,
    );

    if (message.type === MessageType.BROADCAST) {
      // @ts-expect-error FIXME untyped packet object
      message.data.packet.nsp = this.#nsp;
    }

    return XADD(
      this.#redisClient,
      this.#opts.streamName,
      flattenPayload(message as ClusterMessage),
      this.#opts.maxLen,
    );
  }
}