cache-handler.mjs

import { CacheHandler } from '@neshca/cache-handler'
import createLruHandler from '@neshca/cache-handler/local-lru'
import createRedisHandler from '@neshca/cache-handler/redis-stack'
import { createClient } from 'redis'

CacheHandler.onCreation(async () => {
  let client

  try {
    client = createClient({
      url: process.env.REDIS_URL ?? 'redis://localhost:6379'
    })

    client.on('error', (error) => {
      console.error('Redis error:', error.message)
    })
  } catch (error) {
    console.warn('Failed to create Redis client:', error)
  }

  let redisHandler

  if (process.env.REDIS_AVAILABLE) {
    try {
      console.info('Connecting Redis client...')

      await client.connect()

      console.info('Redis client connected.')

      redisHandler = await createRedisHandler({
        client,
        timeoutMs: 5000
      })
    } catch (error) {
      console.warn('Failed to connect Redis client:', error)
      console.warn('Disconnecting the Redis client...')
      client
        .disconnect()
        .then(() => {
          console.info('  ** Redis client disconnected. **')
        })
        .catch(() => {
          console.warn('Failed to quit the Redis client after failing to connect.')
        })
    }
  }

  const localHandler = createLruHandler()

  return {
    handlers: [redisHandler, localHandler]
  }
})

export default CacheHandler