First code commit

Author: delvedor

index.js

@@ -0,0 +1,26 @@
+'use strict'
+
+const fp = require('fastify-plugin')
+const redis = require('redis')
+
+function fastifyRedis (fastify, options, next) {
+  var client = null
+
+  try {
+    client = redis.createClient(options)
+  } catch (err) {
+    return next(err)
+  }
+
+  fastify
+    .decorate('redis', client)
+    .addHook('onClose', close)
+
+  next()
+}
+
+function close (fastify, done) {
+  fastify.redis.quit(done)
+}
+
+module.exports = fp(fastifyRedis, '>=0.13.1')

package.json

@@ -0,0 +1,36 @@
+{
+  "name": "fastify-redis",
+  "version": "0.1.0",
+  "description": "Plugin to share a common Redis connection across Fastify.",
+  "main": "index.js",
+  "scripts": {
+    "test": "standard && tap test.js",
+    "redis": "docker run -p 6379:6379 redis:3.0.7"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/fastify/fastify-redis.git"
+  },
+  "keywords": [
+    "fastify",
+    "redis",
+    "database",
+    "speed",
+    "cache"
+  ],
+  "author": "Tomas Della Vedova - @delvedor (http://delved.org)",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/fastify/fastify-redis/issues"
+  },
+  "homepage": "https://github.com/fastify/fastify-redis#readme",
+  "devDependencies": {
+    "fastify": "^0.14.0",
+    "standard": "^10.0.0",
+    "tap": "^10.3.1"
+  },
+  "dependencies": {
+    "fastify-plugin": "^0.1.0",
+    "redis": "^2.7.1"
+  }
+}

test.js

@@ -0,0 +1,68 @@
+'use strict'
+
+const t = require('tap')
+const test = t.test
+const Fastify = require('fastify')
+const fastifyRedis = require('./index')
+
+t.beforeEach(done => {
+  const fastify = Fastify()
+
+  fastify.register(fastifyRedis, {
+    host: '127.0.0.1'
+  }, (err) => {
+    t.error(err)
+  })
+
+  fastify.ready(err => {
+    t.error(err)
+
+    fastify.redis.flushdb(() => {
+      fastify.close()
+      done()
+    })
+  })
+})
+
+test('fastify.redis should exist', t => {
+  t.plan(3)
+  const fastify = Fastify()
+
+  fastify.register(fastifyRedis, {
+    host: '127.0.0.1'
+  }, (err) => {
+    t.error(err)
+  })
+
+  fastify.ready(err => {
+    t.error(err)
+    t.ok(fastify.redis)
+
+    fastify.close()
+  })
+})
+
+test('fastify.redis should be the redis client', t => {
+  t.plan(5)
+  const fastify = Fastify()
+
+  fastify.register(fastifyRedis, {
+    host: '127.0.0.1'
+  }, (err) => {
+    t.error(err)
+  })
+
+  fastify.ready(err => {
+    t.error(err)
+
+    fastify.redis.set('key', 'value', err => {
+      t.error(err)
+      fastify.redis.get('key', (err, val) => {
+        t.error(err)
+        t.equal(val, 'value')
+
+        fastify.close()
+      })
+    })
+  })
+})