Method constructor

src/adapters/redis-adapter.ts:13–45

(private readonly client: CacheClient)

  private scriptShas: Map<string, string> = new Map()

  public constructor(private readonly client: CacheClient) {
    this.connection = client.isOpen ? Promise.resolve() : client.connect()

    this.connection.catch((error) => this.onClientError(error))

    this.client
      .on('connect', () => logger('connecting'))
      .on('ready', () => logger('connected'))
      .on('error', (error) => this.onClientError(error))
      .on('reconnecting', () => {
        logger('reconnecting')
        this.connection = new Promise((resolve, reject) => {
          const cleanup = () => {
            this.client.removeListener('ready', onReady)
            this.client.removeListener('error', onError)
          }

          const onError = (error: Error) => {
            cleanup()
            reject(error)
          }

          const onReady = () => {
            cleanup()
            resolve()
          }

          this.client.once('ready', onReady)

          this.client.once('error', onError)
        })
      })
  }

  private onClientError(error: Error) {
    logger.error('Unable to connect to Redis.', error)