w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update event handlers in tests

Browse Source 
use constants values for listeners
This commit is contained in:
Joe Fleming
2016-07-08 15:35:46 -07:00
parent 3934f0cd1b
commit a2391a30c5
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/src/worker.js
View File

@@ -390,7 +390,7 @@ describe('Worker class', function () {
mockQueue.client.update.restore(); mockQueue.client.update.restore();
sinon.stub(mockQueue.client, 'update').returns(Promise.reject({ statusCode: 401 })); sinon.stub(mockQueue.client, 'update').returns(Promise.reject({ statusCode: 401 }));
worker.on('claim_error', function (err) { worker.on(constants.EVENT_WORKER_JOB_CLAIM_ERROR, function (err) {
expect(err).to.have.property('statusCode', 401); expect(err).to.have.property('statusCode', 401);
done(); done();
}); });
@@ -461,7 +461,7 @@ describe('Worker class', function () {
mockQueue.client.update.restore(); mockQueue.client.update.restore();
sinon.stub(mockQueue.client, 'update').returns(Promise.reject({ statusCode: 401 })); sinon.stub(mockQueue.client, 'update').returns(Promise.reject({ statusCode: 401 }));
worker.on('fail_error', function (err) { worker.on(constants.EVENT_WORKER_FAIL_UPDATE_ERROR, function (err) {
expect(err).to.have.property('statusCode', 401); expect(err).to.have.property('statusCode', 401);
done(); done();
}); });
@@ -609,9 +609,8 @@ describe('Worker class', function () {
}); });
}; };
const worker = new Worker(mockQueue, 'test', workerFn); const worker = new Worker(mockQueue, 'test', workerFn);
const failStub = sinon.stub(worker, '_failJob');
worker.once('job_error', (err) => { worker.once(constants.EVENT_WORKER_JOB_EXECUTION_ERROR, (err) => {
try { try {
expect(err).to.have.property('type', 'UnspecifiedWorkerError'); expect(err).to.have.property('type', 'UnspecifiedWorkerError');
done(); done();
@@ -653,7 +652,7 @@ describe('Worker class', function () {
let performJobPromise; let performJobPromise;
// check for timeout event // check for timeout event
worker.once('job_timeout', (err) => { worker.once(constants.EVENT_WORKER_JOB_TIMEOUT_ERROR, (err) => {
try { try {
expect(err).to.have.property('type', 'WorkerTimeoutError'); expect(err).to.have.property('type', 'WorkerTimeoutError');
performJobPromise.then(() => { performJobPromise.then(() => {