1 const { expect
} = require('expect')
2 const { ClusterWorker
} = require('../../lib')
4 describe('Cluster worker test suite', () => {
5 let numberOfMessagesSent
= 0
6 const send = function () {
9 class SpyWorker
extends ClusterWorker
{
15 it('Verify worker has default maxInactiveTime', () => {
16 const worker
= new ClusterWorker(() => {})
17 expect(worker
.opts
.maxInactiveTime
).toStrictEqual(60000)
20 it('Verify that handleError() method works properly', () => {
21 const errorMessage
= 'Error as a string'
22 const worker
= new ClusterWorker(() => {})
23 expect(worker
.handleError(errorMessage
)).toStrictEqual(errorMessage
)
26 it('Verify worker invoke the getMainWorker() and send() methods', () => {
27 const worker
= new SpyWorker(() => {})
28 worker
.sendToMainWorker({ ok
: 1 })
29 expect(numberOfMessagesSent
).toBe(1)