test: fix infobip transport queue

lykmapipo · Apr 16, 2019 · 6fc652e · 6fc652e
1 parent 9997d06
commit 6fc652e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 18 deletions.
diff --git a/test/integration/message.queue.echo.spec.js b/test/integration/message.queue.echo.spec.js
@@ -9,7 +9,7 @@ const { worker } = require('mongoose-kue');
 const { Message } = require(path.join(__dirname, '..', '..'));
 
 
-describe.only('echo transport queue', () => {
+describe('echo transport queue', () => {
 
   before(() => {
     process.env.DEBUG = true;

diff --git a/test/integration/message.queue.infobip.spec.js b/test/integration/message.queue.infobip.spec.js
@@ -4,28 +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('infobip transport queue', () => {
+describe.only('infobip transport queue', () => {
 
   before(() => {
     process.env.DEBUG = true;
   });
 
-  before((done) => {
-    Message.deleteMany(done);
-  });
+  before(done => clear(done));
 
-  before((done) => {
-    worker.reset(done);
-  });
-
-  before(() => {
-    worker.start({ types: Message.TYPES });
-  });
+  before(done => worker.reset(done));
 
+  before(() => worker.start({ types: Message.TYPES }));
 
   it('should be able to queue message', (done) => {
 
@@ -57,13 +51,9 @@ describe('infobip 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;