From: Jérôme Benoit Date: Fri, 25 Aug 2023 18:25:08 +0000 (+0200) Subject: test: add UTs X-Git-Tag: v2.6.35~2 X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=98446b391031d7add0e0d7f7e310e25a014370e2;p=poolifier.git test: add UTs Signed-off-by: Jérôme Benoit --- diff --git a/.eslintrc.js b/.eslintrc.js index a6ad5b1d..9a058e82 100644 --- a/.eslintrc.js +++ b/.eslintrc.js @@ -96,6 +96,7 @@ module.exports = defineConfig({ 'unref', 'unregister', 'utf8', + 'webcrypto', 'workerpool', 'ws', 'wss', diff --git a/src/pools/selection-strategies/selection-strategies-types.ts b/src/pools/selection-strategies/selection-strategies-types.ts index 855c7ad1..e7bf0e1e 100644 --- a/src/pools/selection-strategies/selection-strategies-types.ts +++ b/src/pools/selection-strategies/selection-strategies-types.ts @@ -97,7 +97,7 @@ export interface WorkerChoiceStrategyOptions { readonly elu?: MeasurementOptions /** * Worker weights to use for weighted round robin worker selection strategies. - * A weight is the tasks maximum execution time in milliseconds for each worker node. + * A weight is tasks maximum execution time in milliseconds for a worker node. * * @defaultValue Weights computed automatically given the CPU performance. */ diff --git a/src/utils.ts b/src/utils.ts index 7a0ed2f6..b84c4c80 100644 --- a/src/utils.ts +++ b/src/utils.ts @@ -1,4 +1,5 @@ import * as os from 'node:os' +import { webcrypto } from 'node:crypto' import type { MeasurementStatisticsRequirements, WorkerChoiceStrategyOptions @@ -253,5 +254,5 @@ export const once = ( * @returns A number in the [0,1[ range */ export const secureRandom = (): number => { - return crypto.getRandomValues(new Uint32Array(1))[0] / 0x100000000 + return webcrypto.getRandomValues(new Uint32Array(1))[0] / 0x100000000 } diff --git a/tests/utils.test.js b/tests/utils.test.js index 76abf046..c00f0307 100644 --- a/tests/utils.test.js +++ b/tests/utils.test.js @@ -1,3 +1,4 @@ +const { randomInt } = require('crypto') const { expect } = require('expect') const { CircularArray, @@ -6,12 +7,14 @@ const { const { availableParallelism, average, + exponentialDelay, isAsyncFunction, isKillBehavior, isPlainObject, median, round, secureRandom, + sleep, updateMeasurementStatistics } = require('../lib/utils') const { KillBehaviors } = require('../lib/worker/worker-options') @@ -23,6 +26,23 @@ describe('Utils test suite', () => { expect(Number.isSafeInteger(availableParallelism())).toBe(true) }) + it('Verify sleep() behavior', async () => { + const now = performance.now() + await sleep(1000) + const elapsed = performance.now() - now + expect(elapsed).toBeGreaterThanOrEqual(1000) + }) + + it('Verify exponentialDelay() behavior', () => { + expect(typeof exponentialDelay(randomInt(1000)) === 'number').toBe(true) + expect(exponentialDelay(randomInt(1000))).toBeGreaterThanOrEqual( + Number.MIN_VALUE + ) + expect(exponentialDelay(randomInt(1000))).toBeLessThanOrEqual( + Number.MAX_VALUE + ) + }) + it('Verify average() computation', () => { expect(average([])).toBe(0) expect(average([0.08])).toBe(0.08)