fix: support redis cluster

Close #87

Author: Julien-R44

compose.yml

@@ -4,6 +4,20 @@ services:
     ports:
       - '6379:6379'
 
+  redis-cluster:
+    profiles:
+      - cluster
+    image: grokzen/redis-cluster:7.0.8
+    environment:
+      - IP=0.0.0.0
+      - INITIAL_PORT=7000
+      - MASTERS=3
+      - SLAVES_PER_MASTER=0
+    ports:
+      - '7000:7000'
+      - '7001:7001'
+      - '7002:7002'
+
   redis-insight:
     image: redis/redisinsight:latest
     ports:

packages/bentocache/src/drivers/redis.ts

@@ -1,6 +1,6 @@
-import { Redis as IoRedis } from 'ioredis'
 import type { RedisOptions as IoRedisOptions } from 'ioredis'
 import { RedisTransport } from '@boringnode/bus/transports/redis'
+import { Redis as IoRedis, Cluster as IoRedisCluster } from 'ioredis'
 import type { RedisTransportConfig } from '@boringnode/bus/types/main'
 
 import { BaseDriver } from './base_driver.js'
@@ -43,13 +43,13 @@ export function redisBusDriver(
  */
 export class RedisDriver extends BaseDriver implements L2CacheDriver {
   type = 'l2' as const
-  #connection: IoRedis
+  #connection: IoRedis | IoRedisCluster
   declare config: RedisConfig
 
   constructor(config: RedisConfig) {
     super(config)
 
-    if (config.connection instanceof IoRedis) {
+    if (config.connection instanceof IoRedis || config.connection instanceof IoRedisCluster) {
       this.#connection = config.connection
       return
     }

packages/bentocache/src/types/options/drivers_options.ts

@@ -1,8 +1,12 @@
 import type { Knex } from 'knex'
 import type { Kysely } from 'kysely'
 import type { DynamoDBClientConfig } from '@aws-sdk/client-dynamodb'
-import type { Redis as IoRedis, RedisOptions as IoRedisOptions } from 'ioredis'
 import type { DbResult, DefaultColumnTypes, DefaultSchemaConfig } from 'orchid-orm'
+import type {
+  Redis as IoRedis,
+  RedisOptions as IoRedisOptions,
+  Cluster as IoRedisCluster,
+} from 'ioredis'
 
 import type { Logger } from '../../logger.js'
 import type { Duration } from '../helpers.js'
@@ -105,9 +109,9 @@ export type MemoryConfig = {
  */
 export type RedisConfig = {
   /**
-   * A IoRedis connection instance or connection options
+   * A IoRedis connection instance (Redis or Cluster) or connection options
    */
-  connection: IoRedis | IoRedisOptions
+  connection: IoRedis | IoRedisCluster | IoRedisOptions
 } & DriverCommonOptions
 
 /**

packages/bentocache/tests/drivers/redis.spec.ts

@@ -1,5 +1,5 @@
 import { test } from '@japa/runner'
-import { Redis as IoRedis } from 'ioredis'
+import { Redis as IoRedis, Cluster as IoRedisCluster } from 'ioredis'
 
 import { REDIS_CREDENTIALS } from '../helpers/index.js'
 import { RedisDriver } from '../../src/drivers/redis.js'
@@ -23,6 +23,15 @@ test.group('Redis driver', (group) => {
     await ioredis.quit()
   })
 
+  test('should be able to provide an instance of ioredis cluster', async ({ assert }) => {
+    const cluster = new IoRedisCluster([{ host: '127.0.0.1', port: 7000 }])
+    const redis = new RedisDriver({ connection: cluster })
+
+    assert.equal(redis.getConnection(), cluster)
+
+    await redis.disconnect()
+  }).skip(!!process.env.CI, 'Skipping cluster test on CI')
+
   test('should works with ioredis keyPrefix', async ({ assert }) => {
     const ioredis = new IoRedis({ ...REDIS_CREDENTIALS, keyPrefix: 'test:' })
     const ioRedis2 = new IoRedis({ ...REDIS_CREDENTIALS })