test: fix tz ega transport queue & add queue redis cleanups

test/integration/boostrap.spec.js

@@ -2,16 +2,37 @@
 
 
 /* dependencies */
+const async = require('async');
+const kue = require('kue');
 const { connect, clear, drop } = require('@lykmapipo/mongoose-test-helpers');
 
+/* clear redis database */
+const clean = done => {
+  const redis = kue.redis.createClientFactory({
+    redis: {}
+  });
+  redis.keys('q*', (error, rows) => {
+    if (error) {
+      done(error);
+    } else {
+      async.each(rows, (row, next) => {
+        redis.del(row, next);
+      }, done);
+    }
+  });
+};
+
+/* clear redis */
+before(clean);
 
 /* setup database */
 before((done) => connect(done));
 
-
 /* clear database */
 before((done) => clear(done));
 
-
 /* drop database */
 after((done) => drop(done));
+
+/* clear redis */
+after(clean);

test/integration/message.queue.smtp.spec.js

@@ -9,7 +9,7 @@ const { worker } = require('mongoose-kue');
 const { Message } = require(path.join(__dirname, '..', '..'));
 
 
-describe.only('smtp transport queue', () => {
+describe('smtp transport queue', () => {
 
   before(() => {
     process.env.DEBUG = true;

test/integration/message.queue.tz.ega.spec.js

@@ -4,27 +4,22 @@
 /* dependencies */
 const path = require('path');
 const { expect } = require('chai');
+const { clear } = require('@lykmapipo/mongoose-test-helpers');
 const { worker } = require('mongoose-kue');
 const { Message } = require(path.join(__dirname, '..', '..'));
 
 
-describe('tz ega transport queue', () => {
+describe.only('tz ega transport queue', () => {
 
   before(() => {
     process.env.DEBUG = true;
   });
 
-  before((done) => {
-    Message.deleteMany(done);
-  });
+  before(done => clear(done));
 
-  before((done) => {
-    worker.reset(done);
-  });
+  before(done => worker.reset(done));
 
-  before(() => {
-    worker.start({ types: Message.TYPES });
-  });
+  before(() => worker.start({ types: Message.TYPES }));
 
 
   it('should be able to queue message', (done) => {
@@ -63,13 +58,9 @@ describe('tz ega transport queue', () => {
 
   });
 
-  after((done) => {
-    worker.stop(done);
-  });
+  after(done => worker.stop(done));
 
-  after((done) => {
-    Message.deleteMany(done);
-  });
+  after(done => clear(done));
 
   after(() => {
     delete process.env.DEBUG;