test: added tests

package.json

@@ -25,9 +25,10 @@
   "devDependencies": {
     "@commitlint/cli": "^8.1.0",
     "@commitlint/config-conventional": "^8.1.0",
-    "ava": "^2.3.0",
+    "ava": "^3.10.1",
     "codecov": "^3.5.0",
     "cross-env": "^5.2.1",
+    "delay": "^4.4.0",
     "eslint": "6.3.0",
     "eslint-config-xo-lass": "^1.0.3",
     "eslint-plugin-node": "^10.0.0",
@@ -37,6 +38,7 @@
     "nyc": "^14.1.1",
     "remark-cli": "^7.0.0",
     "remark-preset-github": "^0.0.16",
+    "sinon": "^9.0.2",
     "xo": "^0.24.0"
   },
   "engines": {

test/test.js

@@ -1,3 +1,173 @@
 const test = require('ava');
+const delay = require('delay');
+const sinon = require('sinon');
 
-test.todo('write tests');
+const IORedis = require('ioredis');
+const Redis = require('..');
+
+test.beforeEach(t => {
+  t.context.logger = {
+    debug: () => {},
+    error: () => {}
+  };
+});
+
+test('creates Redis', t => {
+  const redis = new Redis();
+  t.is(typeof redis, 'object');
+});
+
+test('creates Redis with logger', async t => {
+  t.plan(10);
+
+  const { logger } = t.context;
+  logger.debug = message => {
+    switch (message) {
+      case 'redis connection established':
+        t.true(true);
+        break;
+      case 'redis connection ready':
+        t.true(true);
+        break;
+      case 'redis connection closed':
+        t.true(true);
+        break;
+      case 'redis reconnecting':
+        t.true(true);
+        break;
+      case 'redis connection ended':
+        t.true(true);
+        break;
+      case 'redis node connected':
+        t.true(true);
+        break;
+      case 'redis node disconnected':
+        t.true(true);
+        break;
+      default:
+    }
+  };
+
+  logger.error = message => {
+    switch (message) {
+      case 'node error':
+        t.true(true);
+        break;
+      case 'error':
+        t.true(true);
+        break;
+      default:
+    }
+  };
+
+  const redis = await new Redis({}, logger);
+
+  t.is(typeof redis, 'object');
+  redis.monitor();
+  await delay(1000);
+  redis.emit('reconnecting');
+  redis.emit('+node');
+  redis.emit('-node');
+  redis.emit('node error', 'node error');
+  redis.emit('error', 'error');
+  redis.disconnect();
+  await delay(1000);
+});
+
+test('creates Redis with monitor', async t => {
+  t.plan(13);
+
+  const { logger } = t.context;
+  logger.debug = message => {
+    // console.debug(message);
+    switch (message) {
+      case 'redis monitor instance created':
+        t.true(true);
+        break;
+      case 'redis monitor':
+        t.true(true);
+        break;
+      case 'redis connection established':
+        t.true(true);
+        break;
+      case 'redis connection ready':
+        t.true(true);
+        break;
+      case 'redis connection closed':
+        t.true(true);
+        break;
+      case 'redis reconnecting':
+        t.true(true);
+        break;
+      case 'redis connection ended':
+        t.true(true);
+        break;
+      case 'redis node connected':
+        t.true(true);
+        break;
+      case 'redis node disconnected':
+        t.true(true);
+        break;
+      default:
+    }
+  };
+
+  logger.error = message => {
+    // console.error(message);
+    switch (message) {
+      case 'node error':
+        t.true(true);
+        break;
+      case 'error':
+        t.true(true);
+        break;
+      default:
+    }
+  };
+
+  const redis = await new Redis({}, logger, true);
+
+  t.is(typeof redis, 'object');
+  await delay(1000);
+  t.is(redis._monitor.status, 'monitoring');
+  redis.emit('reconnecting');
+  redis.emit('+node');
+  redis.emit('-node');
+  redis.emit('node error', 'node error');
+  redis.emit('error', 'error');
+  redis._monitor.emit('monitor');
+  redis.disconnect();
+  await delay(1000);
+});
+
+test('getMeta > empty status', t => {
+  t.plan(1);
+
+  const { logger } = t.context;
+  logger.debug = (...args) => {
+    // console.debug(args);
+    if (args[1].status === '[empty]') t.true(true);
+  };
+
+  const redis = new Redis({}, logger);
+  redis.setStatus(undefined);
+  redis.emit('connect');
+});
+
+test.serial('errors when creating monitor', t => {
+  t.plan(1);
+
+  const { logger } = t.context;
+  logger.error = message => {
+    if (message === 'error') t.true(true);
+  };
+
+  const monitor = sinon.stub(IORedis.prototype, 'monitor').returns(() => {});
+  monitor.yields('error', null);
+
+  // eslint-disable-next-line no-unused-vars
+  const redis = new Redis({}, logger, true);
+
+  sinon.assert.called(monitor);
+  sinon.restore();
+});