From fd118fa7467c2a9f55c230062ecc99705f53b91b Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Tue, 12 Jul 2016 13:31:40 -0700
Subject: [PATCH] add test for passing params to workers

---
 test/src/index.js | 28 +++++++++++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/test/src/index.js b/test/src/index.js
index 1c872e0..299473a 100644
--- a/test/src/index.js
+++ b/test/src/index.js
@@ -98,8 +98,13 @@ describe('Esqueue class', function () {
   });
 
   describe('Registering workers', function () {
+    let queue;
+
+    beforeEach(function () {
+      queue = new Esqueue('esqueue', { client });
+    });
+
     it('should keep track of workers', function () {
-      const queue = new Esqueue('esqueue', { client });
       expect(queue.getWorkers()).to.eql([]);
       expect(queue.getWorkers()).to.have.length(0);
 
@@ -108,6 +113,27 @@ describe('Esqueue class', function () {
       queue.registerWorker('test2', noop);
       expect(queue.getWorkers()).to.have.length(3);
     });
+
+    it('should pass instance of queue, type, and worker function', function () {
+      const workerType = 'test-worker';
+      const workerFn = () => true;
+
+      const worker = queue.registerWorker(workerType, workerFn);
+      expect(worker.getProp('queue')).to.equal(queue);
+      expect(worker.getProp('type')).to.equal(workerType);
+      expect(worker.getProp('workerFn')).to.equal(workerFn);
+    });
+
+    it('should pass worker options', function () {
+      const workerOptions = {
+        size: 12,
+        doctype: 'tests'
+      };
+
+      queue = new Esqueue('esqueue', { client });
+      const worker = queue.registerWorker('type', noop, workerOptions);
+      expect(worker.getProp('options')).to.equal(workerOptions);
+    });
   });
 
   describe('Destroy', function () {