]> Piment Noir Git Repositories - poolifier.git/commitdiff
test: update imports to .mjs files
authorJérôme Benoit <jerome.benoit@piment-noir.org>
Sun, 22 Feb 2026 22:22:20 +0000 (23:22 +0100)
committerJérôme Benoit <jerome.benoit@piment-noir.org>
Sun, 22 Feb 2026 22:22:20 +0000 (23:22 +0100)
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
18 files changed:
tests/circular-buffer.test.mjs
tests/pools/abstract-pool.test.mjs
tests/pools/cluster/dynamic.test.mjs
tests/pools/cluster/fixed.test.mjs
tests/pools/selection-strategies/selection-strategies-utils.test.mjs
tests/pools/selection-strategies/selection-strategies.test.mjs
tests/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.test.mjs
tests/pools/selection-strategies/worker-choice-strategies-context.test.mjs
tests/pools/thread/dynamic.test.mjs
tests/pools/thread/fixed.test.mjs
tests/pools/utils.test.mjs
tests/pools/worker-node.test.mjs
tests/utils.test.mjs
tests/worker/abort-error.test.mjs
tests/worker/abstract-worker.test.mjs
tests/worker/cluster-worker.test.mjs
tests/worker/thread-worker.test.mjs
vitest.config.ts

index a0224650d46d212323bf44b30beae3e928b1fa65..d86f744183df1c66c0e1434adf84e40c3f3abf0f 100644 (file)
@@ -1,6 +1,6 @@
 import { describe, expect, it } from 'vitest'
 
-import { CircularBuffer, defaultBufferSize } from '../lib/circular-buffer.cjs'
+import { CircularBuffer, defaultBufferSize } from '../lib/circular-buffer.mjs'
 
 describe('Circular buffer test suite', () => {
   it('Verify that circular buffer can be instantiated', () => {
index 4a026d9b02b25b936ba13319afe2f25054c4069e..9748f9e602666fbf236543e2c426064f2845e2e4 100644 (file)
@@ -6,7 +6,7 @@ import { dirname, join } from 'node:path'
 import { fileURLToPath } from 'node:url'
 import { describe, expect, it } from 'vitest'
 
-import { CircularBuffer } from '../../lib/circular-buffer.cjs'
+import { CircularBuffer } from '../../lib/circular-buffer.mjs'
 import {
   DynamicClusterPool,
   DynamicThreadPool,
@@ -16,11 +16,11 @@ import {
   PoolTypes,
   WorkerChoiceStrategies,
   WorkerTypes,
-} from '../../lib/index.cjs'
-import { WorkerNode } from '../../lib/pools/worker-node.cjs'
-import { PriorityQueue } from '../../lib/queues/priority-queue.cjs'
-import { defaultBucketSize } from '../../lib/queues/queue-types.cjs'
-import { DEFAULT_TASK_NAME } from '../../lib/utils.cjs'
+} from '../../lib/index.mjs'
+import { WorkerNode } from '../../lib/pools/worker-node.mjs'
+import { PriorityQueue } from '../../lib/queues/priority-queue.mjs'
+import { defaultBucketSize } from '../../lib/queues/queue-types.mjs'
+import { DEFAULT_TASK_NAME } from '../../lib/utils.mjs'
 import { waitPoolEvents } from '../test-utils.cjs'
 
 describe('Abstract pool test suite', () => {
index 337a97f0612ad8202070f803dfce057ea886d617..1028b0007b12d3c87313fcb4008cef87f8f19118 100644 (file)
@@ -4,7 +4,7 @@ import {
   DynamicClusterPool,
   PoolEvents,
   WorkerChoiceStrategies,
-} from '../../../lib/index.cjs'
+} from '../../../lib/index.mjs'
 import { TaskFunctions } from '../../test-types.cjs'
 import { sleep, waitPoolEvents, waitWorkerEvents } from '../../test-utils.cjs'
 
index 1c0e7f8e40fa5674a3772bcb6918757d53a5ab10..3f41c6e4c3ffa021a3c1ab286eb5fe93f4a504f1 100644 (file)
@@ -1,8 +1,8 @@
 import cluster from 'node:cluster'
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
 
-import { FixedClusterPool, PoolEvents } from '../../../lib/index.cjs'
-import { DEFAULT_TASK_NAME } from '../../../lib/utils.cjs'
+import { FixedClusterPool, PoolEvents } from '../../../lib/index.mjs'
+import { DEFAULT_TASK_NAME } from '../../../lib/utils.mjs'
 import { TaskFunctions } from '../../test-types.cjs'
 import { sleep, waitWorkerEvents } from '../../test-utils.cjs'
 
index d93f808b0c5a56595fef0ab7eb2499cffc203b25..f55f59f878663ac5bde236b0c91d4a062cda6f79 100644 (file)
@@ -1,10 +1,10 @@
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
 
-import { FixedClusterPool, FixedThreadPool } from '../../../lib/index.cjs'
+import { FixedClusterPool, FixedThreadPool } from '../../../lib/index.mjs'
 import {
   buildWorkerChoiceStrategyOptions,
   getWorkerChoiceStrategiesRetries,
-} from '../../../lib/pools/selection-strategies/selection-strategies-utils.cjs'
+} from '../../../lib/pools/selection-strategies/selection-strategies-utils.mjs'
 
 describe('Selection strategies utils test suite', () => {
   const numberOfWorkers = 4
index 54ed4a854bffa6017dcc632cfbbe879299f506c0..df69f2f66e96d8edb6b722f7a41331b9dcd344d3 100644 (file)
@@ -1,14 +1,14 @@
 import { randomInt } from 'node:crypto'
 import { describe, expect, it } from 'vitest'
 
-import { CircularBuffer } from '../../../lib/circular-buffer.cjs'
+import { CircularBuffer } from '../../../lib/circular-buffer.mjs'
 import {
   DynamicClusterPool,
   DynamicThreadPool,
   FixedClusterPool,
   FixedThreadPool,
   WorkerChoiceStrategies,
-} from '../../../lib/index.cjs'
+} from '../../../lib/index.mjs'
 
 describe('Selection strategies test suite', () => {
   const min = 0
index 7ae280759b751e4543d1bf373374034aa04d0ecf..2c19b03bfa83af887938e9a457724bc1ec8f4d94 100644 (file)
@@ -1,14 +1,14 @@
 import { randomInt } from 'node:crypto'
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
 
-import { FixedThreadPool } from '../../../lib/index.cjs'
-import { FairShareWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy.cjs'
-import { InterleavedWeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.cjs'
-import { LeastBusyWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy.cjs'
-import { LeastEluWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy.cjs'
-import { LeastUsedWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-used-worker-choice-strategy.cjs'
-import { RoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/round-robin-worker-choice-strategy.cjs'
-import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.cjs'
+import { FixedThreadPool } from '../../../lib/index.mjs'
+import { FairShareWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy.mjs'
+import { InterleavedWeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.mjs'
+import { LeastBusyWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy.mjs'
+import { LeastEluWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy.mjs'
+import { LeastUsedWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-used-worker-choice-strategy.mjs'
+import { RoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/round-robin-worker-choice-strategy.mjs'
+import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.mjs'
 
 describe('Weighted round robin worker choice strategy test suite', () => {
   const max = 3
index cbfc2aaa3617a0c2eee00aa947abdbaa818023b9..1b7045c45a0270a52715020816538a90e9ff0887 100644 (file)
@@ -5,15 +5,15 @@ import {
   DynamicThreadPool,
   FixedThreadPool,
   WorkerChoiceStrategies,
-} from '../../../lib/index.cjs'
-import { FairShareWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy.cjs'
-import { InterleavedWeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.cjs'
-import { LeastBusyWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy.cjs'
-import { LeastEluWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy.cjs'
-import { LeastUsedWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-used-worker-choice-strategy.cjs'
-import { RoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/round-robin-worker-choice-strategy.cjs'
-import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.cjs'
-import { WorkerChoiceStrategiesContext } from '../../../lib/pools/selection-strategies/worker-choice-strategies-context.cjs'
+} from '../../../lib/index.mjs'
+import { FairShareWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy.mjs'
+import { InterleavedWeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.mjs'
+import { LeastBusyWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy.mjs'
+import { LeastEluWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy.mjs'
+import { LeastUsedWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/least-used-worker-choice-strategy.mjs'
+import { RoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/round-robin-worker-choice-strategy.mjs'
+import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.mjs'
+import { WorkerChoiceStrategiesContext } from '../../../lib/pools/selection-strategies/worker-choice-strategies-context.mjs'
 
 describe('Worker choice strategies context test suite', () => {
   const min = 1
index 6bf049dfd8f7f34748aaa70ef9971530e70fdbbb..21d8803526cabbeeaea0bd4c507ccccd5c775e1a 100644 (file)
@@ -4,7 +4,7 @@ import {
   DynamicThreadPool,
   PoolEvents,
   WorkerChoiceStrategies,
-} from '../../../lib/index.cjs'
+} from '../../../lib/index.mjs'
 import { TaskFunctions } from '../../test-types.cjs'
 import { sleep, waitPoolEvents, waitWorkerEvents } from '../../test-utils.cjs'
 
index ae46df8038e41c407c74004a00db9e2ef62e8e0a..48e0fcdafe2629dadffac5693ef70b50db11249c 100644 (file)
@@ -1,7 +1,7 @@
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
 
-import { FixedThreadPool, PoolEvents } from '../../../lib/index.cjs'
-import { DEFAULT_TASK_NAME } from '../../../lib/utils.cjs'
+import { FixedThreadPool, PoolEvents } from '../../../lib/index.mjs'
+import { DEFAULT_TASK_NAME } from '../../../lib/utils.mjs'
 import { TaskFunctions } from '../../test-types.cjs'
 import { sleep, waitWorkerEvents } from '../../test-utils.cjs'
 
index 6d75a0066203f61c745cddf2674e84c810fa69d7..cc3e980eab98006715b728999807ab6669c12847 100644 (file)
@@ -2,8 +2,8 @@ import { Worker as ClusterWorker } from 'node:cluster'
 import { Worker as ThreadWorker } from 'node:worker_threads'
 import { describe, expect, it } from 'vitest'
 
-import { CircularBuffer } from '../../lib/circular-buffer.cjs'
-import { WorkerTypes } from '../../lib/index.cjs'
+import { CircularBuffer } from '../../lib/circular-buffer.mjs'
+import { WorkerTypes } from '../../lib/index.mjs'
 import {
   checkValidWorkerNodeKeys,
   createWorker,
@@ -11,8 +11,8 @@ import {
   getDefaultTasksQueueOptions,
   initWorkerInfo,
   updateMeasurementStatistics,
-} from '../../lib/pools/utils.cjs'
-import { MeasurementHistorySize } from '../../lib/pools/worker.cjs'
+} from '../../lib/pools/utils.mjs'
+import { MeasurementHistorySize } from '../../lib/pools/worker.mjs'
 
 describe('Pool utils test suite', () => {
   it('Verify DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS values', () => {
@@ -118,7 +118,7 @@ describe('Pool utils test suite', () => {
     expect(
       createWorker(
         WorkerTypes.cluster,
-        './tests/worker-files/cluster/testWorker.mjs',
+        './tests/worker-files/cluster/testWorker.cjs',
         {}
       )
     ).toBeInstanceOf(ClusterWorker)
@@ -145,7 +145,7 @@ describe('Pool utils test suite', () => {
     })
     const clusterWorker = createWorker(
       WorkerTypes.cluster,
-      './tests/worker-files/cluster/testWorker.mjs',
+      './tests/worker-files/cluster/testWorker.cjs',
       {}
     )
     const clusterWorkerInfo = initWorkerInfo(clusterWorker)
index 35243c03bbf04657dc429fb5cc1aa13de6432975..2803d80ce2ec658d3e7b1de1f53609bd967b2873 100644 (file)
@@ -2,12 +2,12 @@ import { Worker as ClusterWorker } from 'node:cluster'
 import { MessageChannel, Worker as ThreadWorker } from 'node:worker_threads'
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
 
-import { CircularBuffer } from '../../lib/circular-buffer.cjs'
-import { WorkerTypes } from '../../lib/index.cjs'
-import { WorkerNode } from '../../lib/pools/worker-node.cjs'
-import { MeasurementHistorySize } from '../../lib/pools/worker.cjs'
-import { PriorityQueue } from '../../lib/queues/priority-queue.cjs'
-import { DEFAULT_TASK_NAME } from '../../lib/utils.cjs'
+import { CircularBuffer } from '../../lib/circular-buffer.mjs'
+import { WorkerTypes } from '../../lib/index.mjs'
+import { WorkerNode } from '../../lib/pools/worker-node.mjs'
+import { MeasurementHistorySize } from '../../lib/pools/worker.mjs'
+import { PriorityQueue } from '../../lib/queues/priority-queue.mjs'
+import { DEFAULT_TASK_NAME } from '../../lib/utils.mjs'
 
 describe('Worker node test suite', () => {
   let clusterWorkerNode, threadWorkerNode
index 242f7d59e25667bc29ed98ffe796e7429d007105..6db56dc78b93f3d8c174305a5e37031376510a90 100644 (file)
@@ -3,7 +3,7 @@ import os from 'node:os'
 import { useFakeTimers } from 'sinon'
 import { describe, expect, it } from 'vitest'
 
-import { KillBehaviors } from '../lib/index.cjs'
+import { KillBehaviors } from '../lib/index.mjs'
 import {
   availableParallelism,
   average,
@@ -20,7 +20,7 @@ import {
   round,
   secureRandom,
   sleep,
-} from '../lib/utils.cjs'
+} from '../lib/utils.mjs'
 
 describe('Utils test suite', () => {
   it('Verify DEFAULT_TASK_NAME value', () => {
index 143227e03ad75e57d0fa7f43533aac9892166648..245de00a3cc1eeb4f0965951775286bbad327590 100644 (file)
@@ -1,6 +1,6 @@
 import { describe, expect, it } from 'vitest'
 
-import { AbortError } from '../../lib/worker/abort-error.cjs'
+import { AbortError } from '../../lib/worker/abort-error.mjs'
 
 describe('Abort error test suite', () => {
   it('Verify constructor() behavior', () => {
index 158197004a4d6b203de05f529b47aeeaac761963..03e4e87a12c8b1e404ea821f2e590c07be7f4a0b 100644 (file)
@@ -6,8 +6,8 @@ import {
   KillBehaviors,
   ThreadWorker,
   WorkerChoiceStrategies,
-} from '../../lib/index.cjs'
-import { DEFAULT_TASK_NAME, EMPTY_FUNCTION } from '../../lib/utils.cjs'
+} from '../../lib/index.mjs'
+import { DEFAULT_TASK_NAME, EMPTY_FUNCTION } from '../../lib/utils.mjs'
 
 describe('Abstract worker test suite', () => {
   class StubWorkerWithMainWorker extends ThreadWorker {
index 46f94cd0c6553b80e9e832a1af386f93110e1ba0..ec455085a081b2507022c50e0bf5afdfbf365266 100644 (file)
@@ -1,8 +1,8 @@
 import { restore, stub } from 'sinon'
 import { afterEach, describe, expect, it } from 'vitest'
 
-import { ClusterWorker } from '../../lib/index.cjs'
-import { DEFAULT_TASK_NAME } from '../../lib/utils.cjs'
+import { ClusterWorker } from '../../lib/index.mjs'
+import { DEFAULT_TASK_NAME } from '../../lib/utils.mjs'
 
 describe('Cluster worker test suite', () => {
   afterEach(() => {
index 966f0cf074680c12d0b049288fa59bb28da9bf07..cfc140eccdd3750a4466c2a412a5cf9b1c62d88e 100644 (file)
@@ -1,8 +1,8 @@
 import { restore, stub } from 'sinon'
 import { afterEach, describe, expect, it } from 'vitest'
 
-import { ThreadWorker } from '../../lib/index.cjs'
-import { DEFAULT_TASK_NAME } from '../../lib/utils.cjs'
+import { ThreadWorker } from '../../lib/index.mjs'
+import { DEFAULT_TASK_NAME } from '../../lib/utils.mjs'
 
 describe('Thread worker test suite', () => {
   afterEach(() => {
index 957a41a397be38f18c0281a820b883166cba5f39..21c98edaa063ae9c7aee70911594865e2ee47127 100644 (file)
@@ -5,7 +5,6 @@ export default defineConfig({
     coverage: {
       provider: 'v8',
       reporter: ['text', 'html', 'lcov'],
-      reportsDirectory: 'outputs/coverage',
       thresholds: {
         branches: 90,
         functions: 90,