X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fabstract-worker.test.js;h=fbc9a06d26082b007d01572e95f02f610dc1f1a5;hb=710826bc287a006d90f9cdda42fdbac655757973;hp=9b4864c77dda745d3d162b833875b6709a38b6d9;hpb=8620fb25c8b80fc7ef55d76e19781181571c5502;p=poolifier.git diff --git a/tests/worker/abstract-worker.test.js b/tests/worker/abstract-worker.test.js index 9b4864c7..fbc9a06d 100644 --- a/tests/worker/abstract-worker.test.js +++ b/tests/worker/abstract-worker.test.js @@ -1,25 +1,31 @@ -const expect = require('expect') +const { expect } = require('expect') const { ClusterWorker, KillBehaviors, ThreadWorker } = require('../../lib') -class StubPoolWithIsMainWorker extends ThreadWorker { - constructor (fn, opts) { - super(fn, opts) - this.mainWorker = false +describe('Abstract worker test suite', () => { + class StubPoolWithIsMainWorker extends ThreadWorker { + constructor (fn, opts) { + super(fn, opts) + this.mainWorker = undefined + } } -} -describe('Abstract worker test suite', () => { - it('Verify that fn function is mandatory', () => { + it('Verify that fn parameter is mandatory', () => { expect(() => new ClusterWorker()).toThrowError( new Error('fn parameter is mandatory') ) }) - it('Verify worker default values', () => { + it('Verify that fn parameter is a function', () => { + expect(() => new ClusterWorker({})).toThrowError( + new TypeError('fn parameter is not a function') + ) + }) + + it('Verify worker options default values', () => { const worker = new ThreadWorker(() => {}) - expect(worker.maxInactiveTime).toBe(1000 * 60) - expect(worker.killBehavior).toBe(KillBehaviors.SOFT) - expect(worker.async).toBe(false) + expect(worker.opts.maxInactiveTime).toStrictEqual(60000) + expect(worker.opts.killBehavior).toBe(KillBehaviors.SOFT) + expect(worker.opts.async).toBe(false) }) it('Verify that worker options are set at worker creation', () => { @@ -28,15 +34,15 @@ describe('Abstract worker test suite', () => { async: true, killBehavior: KillBehaviors.HARD }) - expect(worker.maxInactiveTime).toBe(6000) - expect(worker.killBehavior).toBe(KillBehaviors.HARD) - expect(worker.async).toBe(true) + expect(worker.opts.maxInactiveTime).toStrictEqual(6000) + expect(worker.opts.killBehavior).toBe(KillBehaviors.HARD) + expect(worker.opts.async).toBe(true) }) it('Verify that handleError function is working properly', () => { const error = new Error('My error') const worker = new ThreadWorker(() => {}) - expect(worker.handleError(error)).toBe(error) + expect(worker.handleError(error)).toStrictEqual(error) }) it('Verify that get main worker throw error if main worker is not set', () => {