Register multiple Redis client instances with Typescript

index.d.ts

@@ -3,20 +3,20 @@ import { Redis, RedisOptions } from 'ioredis';
 
 declare module 'fastify' {
   interface FastifyInstance {
-    redis: Redis;
+    redis: Redis & Record<string, Redis>;
   }
 }
 
-export type FastifyRedisPlugin = RedisOptions &
-{
-  url?: string;
-  namespace?: string;
-} |
-{
-  client: Redis;
-  namespace?: string;
-  closeClient?: boolean;
-}
+export type FastifyRedisPlugin =
+  | (RedisOptions & {
+      url?: string;
+      namespace?: string;
+    })
+  | {
+      client: Redis;
+      namespace?: string;
+      closeClient?: boolean;
+    };
 
 declare const fastifyRedis: FastifyPluginCallback<FastifyRedisPlugin>;
 

test/test.js

@@ -73,15 +73,17 @@ test('fastify.redis should support url', (t) => {
         otherOption: 'foo'
       })
       this.quit = () => {}
-      this.info = cb => cb(null, 'info')
+      this.info = (cb) => cb(null, 'info')
       this.on = function (name, handler) {
         if (name === 'ready') {
           handler(null, 'ready')
         }
 
         return this
       }
-      this.off = function () { return this }
+      this.off = function () {
+        return this
+      }
 
       return this
     }
@@ -190,7 +192,10 @@ test('promises support', (t) => {
 test('custom client', (t) => {
   t.plan(7)
   const fastify = Fastify()
-  const redis = require('redis').createClient({ host: 'localhost', port: 6379 })
+  const redis = require('redis').createClient({
+    host: 'localhost',
+    port: 6379
+  })
 
   fastify.register(fastifyRedis, { client: redis })
 
@@ -218,7 +223,10 @@ test('custom client', (t) => {
 test('custom client gets closed', (t) => {
   t.plan(7)
   const fastify = Fastify()
-  const redis = require('redis').createClient({ host: 'localhost', port: 6379 })
+  const redis = require('redis').createClient({
+    host: 'localhost',
+    port: 6379
+  })
 
   fastify.register(fastifyRedis, { client: redis, closeClient: true })
 
@@ -249,7 +257,10 @@ test('custom client gets closed', (t) => {
 test('custom client inside a namespace', (t) => {
   t.plan(7)
   const fastify = Fastify()
-  const redis = require('redis').createClient({ host: 'localhost', port: 6379 })
+  const redis = require('redis').createClient({
+    host: 'localhost',
+    port: 6379
+  })
 
   fastify.register(fastifyRedis, {
     namespace: 'test',
@@ -280,7 +291,10 @@ test('custom client inside a namespace', (t) => {
 test('custom client inside a namespace gets closed', (t) => {
   t.plan(7)
   const fastify = Fastify()
-  const redis = require('redis').createClient({ host: 'localhost', port: 6379 })
+  const redis = require('redis').createClient({
+    host: 'localhost',
+    port: 6379
+  })
 
   fastify.register(fastifyRedis, {
     namespace: 'test',
@@ -331,7 +345,10 @@ test('fastify.redis.test should throw with duplicate connection namespaces', (t)
     })
 
   fastify.ready((err) => {
-    t.equal(err.message, `Redis '${namespace}' instance namespace has already been registered`)
+    t.equal(
+      err.message,
+      `Redis '${namespace}' instance namespace has already been registered`
+    )
   })
 })
 
@@ -391,10 +408,9 @@ test('Should throw when trying to connect on an invalid host', (t) => {
   const fastify = Fastify({ pluginTimeout: 20000 })
   t.teardown(() => fastify.close())
 
-  fastify
-    .register(fastifyRedis, {
-      host: 'invalid_host'
-    })
+  fastify.register(fastifyRedis, {
+    host: 'invalid_host'
+  })
 
   fastify.ready((err) => {
     t.ok(err)
@@ -407,11 +423,10 @@ test('Should not throw when trying to connect on an invalid host but the lazyCon
   const fastify = Fastify()
   t.teardown(() => fastify.close())
 
-  fastify
-    .register(fastifyRedis, {
-      host: 'invalid_host',
-      lazyConnect: true
-    })
+  fastify.register(fastifyRedis, {
+    host: 'invalid_host',
+    lazyConnect: true
+  })
 
   fastify.ready((err) => {
     t.error(err)
@@ -427,17 +442,16 @@ test('Should throw authentication error when trying to connect on a valid host w
     await unsetRedisPassword(TEST_PASSWORD)
   })
 
-  setRedisPassword(TEST_PASSWORD)
-    .then(_ => {
-      fastify.register(fastifyRedis, {
-        host: '127.0.0.1',
-        password: 'my_wrong_secret_password'
-      })
+  setRedisPassword(TEST_PASSWORD).then((_) => {
+    fastify.register(fastifyRedis, {
+      host: '127.0.0.1',
+      password: 'my_wrong_secret_password'
+    })
 
-      fastify.ready(err => {
-        t.ok(err)
-      })
+    fastify.ready((err) => {
+      t.ok(err)
     })
+  })
 })
 
 test('Should throw authentication error when trying to connect on a valid host without a password', (t) => {
@@ -449,14 +463,37 @@ test('Should throw authentication error when trying to connect on a valid host w
     await unsetRedisPassword(TEST_PASSWORD)
   })
 
-  setRedisPassword(TEST_PASSWORD)
-    .then(_ => {
-      fastify.register(fastifyRedis, {
-        host: '127.0.0.1'
-      })
+  setRedisPassword(TEST_PASSWORD).then((_) => {
+    fastify.register(fastifyRedis, {
+      host: '127.0.0.1'
+    })
 
-      fastify.ready(err => {
-        t.ok(err)
-      })
+    fastify.ready((err) => {
+      t.ok(err)
     })
+  })
+})
+
+test('Registering multiple Redis client instances', (t) => {
+  t.plan(2)
+
+  const fastify = Fastify()
+
+  fastify
+    .register(fastifyRedis, {
+      host: '127.0.0.1',
+      namespace: 'hello'
+    })
+    .register(fastifyRedis, {
+      host: '127.0.0.1',
+      namespace: 'world'
+    })
+
+  fastify.ready((err) => {
+    t.error(err)
+    t.ok(fastify.redis.hello)
+    t.ok(fastify.redis.world)
+
+    fastify.close()
+  })
 })