Function createStorageAdapter

apps/sim/lib/core/rate-limiter/storage/factory.ts:21–52

()

}

export function createStorageAdapter(): RateLimitStorageAdapter {
  if (g._rlCachedAdapter) {
    return g._rlCachedAdapter
  }

  if (!g._rlReconnectListenerRegistered) {
    onRedisReconnect(() => {
      g._rlCachedAdapter = null
    })
    g._rlReconnectListenerRegistered = true
  }

  const storageMethod = getStorageMethod()

  if (storageMethod === 'redis') {
    const redis = getRedisClient()
    if (!redis) {
      logger.warn(
        'Redis configured but client unavailable - falling back to PostgreSQL for rate limiting'
      )
      g._rlCachedAdapter = new DbTokenBucket()
    } else {
      logger.info('Rate limiting: Using Redis')
      g._rlCachedAdapter = new RedisTokenBucket(redis)
    }
  } else {
    logger.info('Rate limiting: Using PostgreSQL')
    g._rlCachedAdapter = new DbTokenBucket()
  }

  return g._rlCachedAdapter!
}

export function getAdapterType(): StorageMethod {
  return getStorageMethod()