X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Futils.test.js;h=061c1648d4f2217583f6b0a9370802578fb222a6;hb=67b26ae264d8879654e66d4320a4d3f2190c00d4;hp=21a6a7c4aac6d07d8e1ec215ff8df9703a30f1f2;hpb=4a45e8d2e79023615e5c5a3ea4b1c6a5e5cf963f;p=poolifier.git diff --git a/tests/utils.test.js b/tests/utils.test.js index 21a6a7c4..061c1648 100644 --- a/tests/utils.test.js +++ b/tests/utils.test.js @@ -1,13 +1,127 @@ +const { randomInt } = require('node:crypto') +const { Worker } = require('node:worker_threads') +const cluster = require('node:cluster') +const os = require('node:os') const { expect } = require('expect') -const { isPlainObject, median } = require('../lib/utils') +const { + DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, + DEFAULT_TASK_NAME, + DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS, + EMPTY_FUNCTION, + availableParallelism, + average, + exponentialDelay, + getWorkerType, + getWorkerId, + isAsyncFunction, + isKillBehavior, + isPlainObject, + max, + median, + min, + round, + secureRandom, + sleep +} = require('../lib/utils') +const { KillBehaviors, WorkerTypes } = require('../lib') describe('Utils test suite', () => { - it('Verify median computation', () => { + it('Verify DEFAULT_TASK_NAME value', () => { + expect(DEFAULT_TASK_NAME).toBe('default') + }) + + it('Verify EMPTY_FUNCTION value', () => { + expect(EMPTY_FUNCTION).toStrictEqual(expect.any(Function)) + }) + + it('Verify DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS values', () => { + expect(DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS).toStrictEqual({ + retries: 6, + runTime: { median: false }, + waitTime: { median: false }, + elu: { median: false } + }) + }) + + it('Verify DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS values', () => { + expect(DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS).toStrictEqual({ + aggregate: false, + average: false, + median: false + }) + }) + + it('Verify availableParallelism() behavior', () => { + const parallelism = availableParallelism() + expect(typeof parallelism === 'number').toBe(true) + expect(Number.isSafeInteger(parallelism)).toBe(true) + let expectedParallelism = 1 + try { + expectedParallelism = os.availableParallelism() + } catch { + expectedParallelism = os.cpus().length + } + expect(parallelism).toBe(expectedParallelism) + }) + + it('Verify getWorkerType() behavior', () => { + expect( + getWorkerType(new Worker('./tests/worker-files/thread/testWorker.js')) + ).toBe(WorkerTypes.thread) + expect(getWorkerType(cluster.fork())).toBe(WorkerTypes.cluster) + }) + + it('Verify getWorkerId() behavior', () => { + const threadWorker = new Worker('./tests/worker-files/thread/testWorker.js') + const clusterWorker = cluster.fork() + expect(getWorkerId(threadWorker)).toBe(threadWorker.threadId) + expect(getWorkerId(clusterWorker)).toBe(clusterWorker.id) + }) + + it('Verify sleep() behavior', async () => { + const start = performance.now() + await sleep(1000) + const elapsed = performance.now() - start + expect(elapsed).toBeGreaterThanOrEqual(999) + }) + + it('Verify exponentialDelay() behavior', () => { + const delay = exponentialDelay(randomInt(1000)) + expect(typeof delay === 'number').toBe(true) + expect(delay).toBeGreaterThanOrEqual(Number.MIN_VALUE) + expect(delay).toBeLessThanOrEqual(Number.MAX_VALUE) + }) + + it('Verify average() computation', () => { + expect(average([])).toBe(0) + expect(average([0.08])).toBe(0.08) + expect(average([0.25, 4.75, 3.05, 6.04, 1.01, 2.02, 5.03])).toBe( + 3.1642857142857146 + ) + expect(average([0.25, 4.75, 3.05, 6.04, 1.01, 2.02])).toBe( + 2.8533333333333335 + ) + }) + + it('Verify median() computation', () => { expect(median([])).toBe(0) - const array0 = [0.08] - expect(median(array0)).toBe(0.08) - const array1 = [0.25, 4.75, 3.05, 6.04, 1.01, 2.02, 5.03] - expect(median(array1)).toBe(3.05) + expect(median([0.08])).toBe(0.08) + expect(median([0.25, 4.75, 3.05, 6.04, 1.01, 2.02, 5.03])).toBe(3.05) + expect(median([0.25, 4.75, 3.05, 6.04, 1.01, 2.02])).toBe(2.535) + }) + + it('Verify round() behavior', () => { + expect(round(0)).toBe(0) + expect(round(0.5, 0)).toBe(1) + expect(round(0.5)).toBe(0.5) + expect(round(-0.5, 0)).toBe(-1) + expect(round(-0.5)).toBe(-0.5) + expect(round(1.005)).toBe(1.01) + expect(round(2.175)).toBe(2.18) + expect(round(5.015)).toBe(5.02) + expect(round(-1.005)).toBe(-1.01) + expect(round(-2.175)).toBe(-2.18) + expect(round(-5.015)).toBe(-5.02) }) it('Verify isPlainObject() behavior', () => { @@ -46,4 +160,79 @@ describe('Utils test suite', () => { expect(isPlainObject({})).toBe(true) expect(isPlainObject({ a: 1 })).toBe(true) }) + + it('Verify isKillBehavior() behavior', () => { + expect(isKillBehavior(KillBehaviors.SOFT, KillBehaviors.SOFT)).toBe(true) + expect(isKillBehavior(KillBehaviors.SOFT, KillBehaviors.HARD)).toBe(false) + expect(isKillBehavior(KillBehaviors.HARD, KillBehaviors.HARD)).toBe(true) + expect(isKillBehavior(KillBehaviors.HARD, KillBehaviors.SOFT)).toBe(false) + expect(isKillBehavior(KillBehaviors.SOFT)).toBe(false) + expect(isKillBehavior(KillBehaviors.HARD)).toBe(false) + expect(isKillBehavior(KillBehaviors.HARD, null)).toBe(false) + expect(isKillBehavior(KillBehaviors.HARD, undefined)).toBe(false) + expect(isKillBehavior(KillBehaviors.SOFT, 'unknown')).toBe(false) + }) + + it('Verify isAsyncFunction() behavior', () => { + expect(isAsyncFunction(null)).toBe(false) + expect(isAsyncFunction(undefined)).toBe(false) + expect(isAsyncFunction(true)).toBe(false) + expect(isAsyncFunction(false)).toBe(false) + expect(isAsyncFunction(0)).toBe(false) + expect(isAsyncFunction('')).toBe(false) + expect(isAsyncFunction([])).toBe(false) + expect(isAsyncFunction(new Date())).toBe(false) + expect(isAsyncFunction(new RegExp())).toBe(false) + expect(isAsyncFunction(new Error())).toBe(false) + expect(isAsyncFunction(new Map())).toBe(false) + expect(isAsyncFunction(new Set())).toBe(false) + expect(isAsyncFunction(new WeakMap())).toBe(false) + expect(isAsyncFunction(new WeakSet())).toBe(false) + expect(isAsyncFunction(new Int8Array())).toBe(false) + expect(isAsyncFunction(new Uint8Array())).toBe(false) + expect(isAsyncFunction(new Uint8ClampedArray())).toBe(false) + expect(isAsyncFunction(new Int16Array())).toBe(false) + expect(isAsyncFunction(new Uint16Array())).toBe(false) + expect(isAsyncFunction(new Int32Array())).toBe(false) + expect(isAsyncFunction(new Uint32Array())).toBe(false) + expect(isAsyncFunction(new Float32Array())).toBe(false) + expect(isAsyncFunction(new Float64Array())).toBe(false) + expect(isAsyncFunction(new BigInt64Array())).toBe(false) + expect(isAsyncFunction(new BigUint64Array())).toBe(false) + expect(isAsyncFunction(new Promise(() => {}))).toBe(false) + expect(isAsyncFunction(new WeakRef({}))).toBe(false) + expect(isAsyncFunction(new FinalizationRegistry(() => {}))).toBe(false) + expect(isAsyncFunction(new ArrayBuffer())).toBe(false) + expect(isAsyncFunction(new SharedArrayBuffer())).toBe(false) + expect(isAsyncFunction(new DataView(new ArrayBuffer()))).toBe(false) + expect(isAsyncFunction({})).toBe(false) + expect(isAsyncFunction({ a: 1 })).toBe(false) + expect(isAsyncFunction(() => {})).toBe(false) + expect(isAsyncFunction(function () {})).toBe(false) + expect(isAsyncFunction(function named () {})).toBe(false) + expect(isAsyncFunction(async () => {})).toBe(true) + expect(isAsyncFunction(async function () {})).toBe(true) + expect(isAsyncFunction(async function named () {})).toBe(true) + }) + + it('Verify secureRandom() behavior', () => { + const randomNumber = secureRandom() + expect(typeof randomNumber === 'number').toBe(true) + expect(randomNumber).toBeGreaterThanOrEqual(0) + expect(randomNumber).toBeLessThan(1) + }) + + it('Verify min() behavior', () => { + expect(min()).toBe(Infinity) + expect(min(1, 2)).toBe(1) + expect(min(2, 1)).toBe(1) + expect(min(1, 1)).toBe(1) + }) + + it('Verify max() behavior', () => { + expect(max()).toBe(-Infinity) + expect(max(1, 2)).toBe(2) + expect(max(2, 1)).toBe(2) + expect(max(1, 1)).toBe(1) + }) })