Method constructor

packages/client/lib/client/index.ts:678–734

(options?: RedisClientOptions<M, F, S, RESP, TYPE_MAPPING>)

  }

  constructor(options?: RedisClientOptions<M, F, S, RESP, TYPE_MAPPING>) {
    super();
    this.#validateOptions(options)
    this.#options = this.#initiateOptions(options);

    const socketOpts = this.#options.socket as { host?: string; port?: number } | undefined;
    this.#clientIdentity = {
      id: generateClientId(socketOpts?.host, socketOpts?.port, this.#selectedDB),
      role: ClientRole.STANDALONE
    };

    this.#queue = this.#initiateQueue(this.#clientIdentity.id);
    this.#socket = this.#initiateSocket(this.#clientIdentity.id);

    this.#registerForMetrics();

    if(this.#options.maintNotifications !== 'disabled') {
      new EnterpriseMaintenanceManager(this.#queue, this, this.#options);
    };

    if (this.#options.clientSideCache) {
      if (this.#options.clientSideCache instanceof ClientSideCacheProvider) {
        this.#clientSideCache = this.#options.clientSideCache;
      } else {
        const cscConfig = this.#options.clientSideCache;
        this.#clientSideCache = new BasicClientSideCache(cscConfig);
      }
      // eslint-disable-next-line @typescript-eslint/no-explicit-any
      this.#queue.addPushHandler((push: Array<any>): boolean => {
        if (push[0].toString() !== 'invalidate') return false;

        if (push[1] !== null) {
          for (const key of push[1]) {
            this.#clientSideCache?.invalidate(key)
          }
        } else {
          this.#clientSideCache?.invalidate(null)
        }

        return true
      });
    } else if (options?.emitInvalidate) {
      // eslint-disable-next-line @typescript-eslint/no-explicit-any
      this.#queue.addPushHandler((push: Array<any>): boolean => {
        if (push[0].toString() !== 'invalidate') return false;

        if (push[1] !== null) {
          for (const key of push[1]) {
            this.emit('invalidate', key);
          }
        } else {
          this.emit('invalidate', null);
        }
        return true
      });
    }
  }