Method constructor

packages/socket.io-cluster-engine/lib/redis.ts:137–164

(pubClient: any, subClient: any, opts?: RedisEngineOptions)

  private readonly _channelPrefix: string;

  constructor(pubClient: any, subClient: any, opts?: RedisEngineOptions) {
    super(opts);
    this._pubClient = pubClient;
    this._channelPrefix = opts?.channelPrefix || "engine.io";
    const channels = [
      channelName(this._channelPrefix),
      channelName(this._channelPrefix, this._nodeId),
    ];

    debug("subscribing to redis channels: %s", channels);
    SUBSCRIBE(subClient, channels, (buffer: Buffer) => {
      let message: Message & { _source?: string; _primaryId?: string };
      try {
        message = decode(buffer) as Message;
      } catch (e) {
        debug("ignore malformed buffer");
        return;
      }

      if (message._source !== MESSAGE_SOURCE) {
        debug("ignore message from unknown source");
        return;
      }

      debug("received message: %j", message);
      this.onMessage(message);
    });
  }

  publishMessage(message: Message & { _source?: string }): void {
    // @ts-expect-error recipientId is not defined for all messages