Required import.meta.url to be passed (#276)

* feature, bugfix: Required import.meta.url to be passed

* chore: Added changeset

Author: ijlee2

.changeset/silver-planes-sink.md

@@ -0,0 +1,5 @@
+---
+"@codemod-utils/threads": minor
+---
+
+Required import.meta.url to be passed

packages/threads/src/parallelize.ts

@@ -5,6 +5,11 @@ import { runTask, type Task } from './run-task.js';
 
 const MIN_NUM_TASKS_PER_WORKER = 100;
 
+type WorkerOptions = {
+  importMetaUrl: string;
+  workerFilePath: string;
+};
+
 function batchDatasets<T>(
   datasets: T[],
   numTasksPerWorker: number,
@@ -22,11 +27,13 @@ function batchDatasets<T>(
 }
 
 function createRunWorker<U>(
-  workerFilePath: string,
+  workerOptions: WorkerOptions,
 ): <T>(datasets: T[]) => Promise<U[]> {
+  const { importMetaUrl, workerFilePath } = workerOptions;
+
   function runWorker<T>(datasets: T[]): Promise<U[]> {
     return new Promise((resolve, reject) => {
-      const workerUrl = new URL(workerFilePath, import.meta.url);
+      const workerUrl = new URL(workerFilePath, importMetaUrl);
 
       const worker = new Worker(workerUrl, {
         env: SHARE_ENV,
@@ -50,12 +57,9 @@ function createRunWorker<U>(
 
 export async function parallelize<T extends unknown[], U>(
   task: Task<T, U>,
-  options: {
-    datasets: T[];
-    workerFilePath: string;
-  },
+  datasets: T[],
+  workerOptions: WorkerOptions,
 ): Promise<U[]> {
-  const { datasets, workerFilePath } = options;
   const numTasks = datasets.length;
 
   if (numTasks < MIN_NUM_TASKS_PER_WORKER) {
@@ -74,7 +78,7 @@ export async function parallelize<T extends unknown[], U>(
     numTasksPerWorker,
   );
 
-  const runWorker = createRunWorker<U>(workerFilePath);
+  const runWorker = createRunWorker<U>(workerOptions);
 
   const [mainThreadResults, ...workerResults] = await Promise.all([
     runTask(task, datasetsForMainThread),

packages/threads/tests/parallelize/vector-1.test.ts

@@ -7,9 +7,9 @@ test('parallelize > vector (1)', async function () {
   const numTasks = 0;
   const datasets = getDatasets(numTasks);
 
-  const output = await parallelize(task, {
-    datasets,
-    workerFilePath: '../tests/helpers/vector/worker.js',
+  const output = await parallelize(task, datasets, {
+    importMetaUrl: import.meta.url,
+    workerFilePath: '../helpers/vector/worker.js',
   });
 
   assertOutput(output);

packages/threads/tests/parallelize/vector-2.test.ts

@@ -9,9 +9,9 @@ test('parallelize > vector (2)', async function () {
   const numTasks = MIN_NUM_TASKS_PER_WORKER - 1;
   const datasets = getDatasets(numTasks);
 
-  const output = await parallelize(task, {
-    datasets,
-    workerFilePath: '../tests/helpers/vector/worker.js',
+  const output = await parallelize(task, datasets, {
+    importMetaUrl: import.meta.url,
+    workerFilePath: '../helpers/vector/worker.js',
   });
 
   assertOutput(output);

packages/threads/tests/parallelize/vector-3.test.ts

@@ -9,9 +9,9 @@ test('parallelize > vector (3)', async function () {
   const numTasks = MIN_NUM_TASKS_PER_WORKER;
   const datasets = getDatasets(numTasks);
 
-  const output = await parallelize(task, {
-    datasets,
-    workerFilePath: '../tests/helpers/vector/worker.js',
+  const output = await parallelize(task, datasets, {
+    importMetaUrl: import.meta.url,
+    workerFilePath: '../helpers/vector/worker.js',
   });
 
   assertOutput(output);

packages/threads/tests/parallelize/vector-4.test.ts

@@ -11,9 +11,9 @@ test('parallelize > vector (4)', async function () {
   const numTasks = availableParallelism() * MIN_NUM_TASKS_PER_WORKER;
   const datasets = getDatasets(numTasks);
 
-  const output = await parallelize(task, {
-    datasets,
-    workerFilePath: '../tests/helpers/vector/worker.js',
+  const output = await parallelize(task, datasets, {
+    importMetaUrl: import.meta.url,
+    workerFilePath: '../helpers/vector/worker.js',
   });
 
   assertOutput(output);

packages/threads/tests/parallelize/vector-5.test.ts

@@ -11,9 +11,9 @@ test('parallelize > vector (5)', async function () {
   const numTasks = availableParallelism() * (3 * MIN_NUM_TASKS_PER_WORKER);
   const datasets = getDatasets(numTasks);
 
-  const output = await parallelize(task, {
-    datasets,
-    workerFilePath: '../tests/helpers/vector/worker.js',
+  const output = await parallelize(task, datasets, {
+    importMetaUrl: import.meta.url,
+    workerFilePath: '../helpers/vector/worker.js',
   });
 
   assertOutput(output);

packages/threads/tests/parallelize/vector-error.test.ts

@@ -11,9 +11,9 @@ test('parallelize > vector (error)', async function () {
 
   await assert.rejects(
     async () => {
-      await parallelize(taskThatErrors, {
-        datasets,
-        workerFilePath: '../tests/helpers/vector/worker.js',
+      await parallelize(taskThatErrors, datasets, {
+        importMetaUrl: import.meta.url,
+        workerFilePath: '../helpers/vector/worker.js',
       });
     },
     (error: Error) => {