Fixes 195 (#196)

Signed-off-by: Matteo Collina <[email protected]>

Author: mcollina

index.js

@@ -118,7 +118,7 @@ function fastifyRedis (fastify, options, next) {
       .on('error', onError)
       .on('ready', onReady)
 
-    client.ping()
+    client.ping().catch(onError)
   }
 }
 

package.json

@@ -9,6 +9,7 @@
     "lint": "standard",
     "lint:fix": "standard --fix",
     "redis": "docker run -p 6379:6379 --rm redis",
+    "valkey": "docker run -p 6379:6379 --rm valkey/valkey:7.2",
     "test": "npm run unit && npm run typescript",
     "typescript": "tsd",
     "unit": "tap",

test/index.test.js

@@ -490,6 +490,35 @@ test('Should throw when @fastify/redis is initialized with a namespace and an op
   })
 })
 
+test('catch .ping() errors', (t) => {
+  t.plan(2)
+  const fastify = Fastify()
+
+  const fastifyRedis = proxyquire('..', {
+    ioredis: function Redis (path, options) {
+      this.ping = () => {
+        return Promise.reject(new Redis.ReplyError('ping error'))
+      }
+      this.quit = () => {}
+      this.info = cb => cb(null, 'info')
+      this.on = function (name, handler) {
+        return this
+      }
+      this.off = function () { return this }
+
+      return this
+    }
+  })
+
+  fastify.register(fastifyRedis)
+
+  fastify.ready((err) => {
+    t.ok(err)
+    t.equal(err.message, 'ping error')
+    fastify.close()
+  })
+})
+
 setInterval(() => {
   whyIsNodeRunning()
 }, 5000).unref()