feat: redis migrations + redis tests (#26)

* feat: redis migrations + redis tests

* fix: lint settings

Author: pajgo

.eslintrc

@@ -2,6 +2,7 @@
   "extends": "makeomatic",
   "rules": {
     "semi": ["error", "never"],
-    "quotes": ["error", "single", { "allowTemplateLiterals": true }]
+    "quotes": ["error", "single", { "allowTemplateLiterals": true }],
+    "no-multiple-empty-lines": ["error", { "max": 1, "maxEOF": 1, "maxBOF": 0 }]
   }
 }

migrations/redis/01-create-constants/index.js

@@ -0,0 +1,15 @@
+async function createConstantKeys(service) {
+  const { redis } = service
+  const pipeline = redis.pipeline()
+  pipeline.set('some.key')
+  pipeline.sadd('some.set', 'value')
+  pipeline.sadd('some.set', 'other value')
+
+  await pipeline.exec()
+}
+
+module.exports = {
+  min: 0,
+  final: 1,
+  script: createConstantKeys,
+}

migrations/redis/02-lua-migration/index.js

@@ -0,0 +1,5 @@
+module.exports = {
+  min: 1,
+  final: 2,
+  script: `${__dirname}/update-data.lua`,
+}

migrations/redis/02-lua-migration/update-data.lua

@@ -0,0 +1,3 @@
+redis.call('del', '{demo-app}some.key')
+redis.call('srem', '{demo-app}some.set', 'value')
+redis.call('sadd', '{demo-app}some.set', 'new value')

package.json

@@ -18,6 +18,7 @@
     "@microfleet/transport-amqp": "^15.0.0",
     "@microfleet/validation": "^8.1.2",
     "common-errors": "^1.0.5",
+    "ioredis": "^4.14.1",
     "ms-conf": "^5.0.2",
     "uuid": "^3.3.3"
   },

src/config.js

@@ -24,6 +24,7 @@ module.exports = {
     'http',
     'router',
     'amqp',
+    'redisCluster',
   ],
   app: {
     someSecret: {
@@ -46,6 +47,11 @@ module.exports = {
       directory: path.resolve(`${__dirname}/../migrations/knex`),
     },
   },
+  redis: {
+    options: {
+      keyPrefix: '{demo-app}',
+    },
+  },
   amqp: {
     transport: {
       connection: {

src/index.js

@@ -14,6 +14,10 @@ class DemoApp extends Microfleet {
     this.addConnector(ConnectorsTypes.migration, async () => {
       await this.migrate('knex')
     }, 'knex-migration')
+
+    this.addConnector(ConnectorsTypes.migration, async () => {
+      await this.migrate('redis', path.resolve(`${__dirname}/../migrations/redis`))
+    }, 'redis-migration')
   }
 }
 

test/config/test.js

@@ -7,6 +7,12 @@ module.exports = {
       },
     },
   },
+  redis: {
+    hosts: Array.from({ length: 5 }).map((_, i) => ({
+      host: 'redis',
+      port: 7000 + i,
+    })),
+  },
   knex: {
     debug: false,
     client: 'pg',

test/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     image: rabbitmq:3.8-alpine
     expose: 
       - "5672"
+  redis:
+    image: grokzen/redis-cluster
   tester:
     expose:
       - "3000"

test/suites/amqp.js

@@ -3,7 +3,6 @@ const rp = require('request-promise')
 const DemoApp = require('../../src')
 
 describe('#amqp action test', () => {
-  // eslint-disable-next-line no-unused-vars
   const query = rp.defaults({
     baseUrl: 'http://0.0.0.0:3000/amqp',
     method: 'POST',