test: refine UTs

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

diff --git a/rollup.config.mjs b/rollup.config.mjs
index e40f170d422e4b09a18f5e64f975a24d2b15bfb2..90d56e6034a53764bc90c4ccc8e744a5d21c44a6 100644 (file)
--- a/rollup.config.mjs
+++ b/rollup.config.mjs
@@ -10,9 +10,9 @@ const availableParallelism = () => {
   try {
     availableParallelism = os.availableParallelism()
   } catch {
-    const numberOfCpus = os.cpus()
-    if (Array.isArray(numberOfCpus) && numberOfCpus.length > 0) {
-      availableParallelism = numberOfCpus.length
+    const cpus = os.cpus()
+    if (Array.isArray(cpus) && cpus.length > 0) {
+      availableParallelism = cpus.length
     }
   }
   return availableParallelism

diff --git a/src/utils.ts b/src/utils.ts
index 82c38c09e7161fd06e2c6f1628fdaad1e8f4c63f..e1d6c11859936dfef95d5e4777e509ca50df5f0f 100644 (file)
--- a/src/utils.ts
+++ b/src/utils.ts
@@ -59,9 +59,9 @@ export const availableParallelism = (): number => {
   try {
     availableParallelism = os.availableParallelism()
   } catch {
-    const numberOfCpus = os.cpus()
-    if (Array.isArray(numberOfCpus) && numberOfCpus.length > 0) {
-      availableParallelism = numberOfCpus.length
+    const cpus = os.cpus()
+    if (Array.isArray(cpus) && cpus.length > 0) {
+      availableParallelism = cpus.length
     }
   }
   return availableParallelism

diff --git a/tests/utils.test.js b/tests/utils.test.js
index b91929a6fb9414bbc778460825eecfb59302edbe..fdb67478c471e38f152b7f87d5d63dc6b775a820 100644 (file)
--- a/tests/utils.test.js
+++ b/tests/utils.test.js
@@ -1,6 +1,7 @@
 const { randomInt } = require('crypto')
 const { Worker } = require('worker_threads')
 const cluster = require('cluster')
+const os = require('os')
 const { expect } = require('expect')
 const {
   CircularArray,
@@ -56,7 +57,13 @@ describe('Utils test suite', () => {
   it('Verify availableParallelism() behavior', () => {
     const parallelism = availableParallelism()
     expect(typeof parallelism === 'number').toBe(true)
-    expect(parallelism).toBeGreaterThan(0)
+    let expectedParallelism = 1
+    try {
+      expectedParallelism = os.availableParallelism()
+    } catch {
+      expectedParallelism = os.cpus().length
+    }
+    expect(parallelism).toBe(expectedParallelism)
     expect(Number.isSafeInteger(parallelism)).toBe(true)
   })