worker.js

// worker.js - Worker thread implementation

import { parentPort, workerData } from "worker_threads";

async function executeFunction() {
  try {
    // Deserialize the function and arguments
    const fnStr = workerData.fn;
    const args = workerData.args;

    // Convert string representation back to function
    // Note: This approach has security implications if untrusted code is passed
    const fn = new Function(`return ${fnStr}`)();

    // Execute the function with provided arguments
    const result = await fn(...args);

    // Send result back to main thread
    parentPort.postMessage(result);
  } catch (error) {
    // Convert error to a serializable object
    const serializableError = {
      message: error.message,
      stack: error.stack,
      name: error.name,
    };

    throw serializableError;
  }
}

executeFunction().catch((error) => {
  // Forward any errors to the parent
  parentPort.emit("error", error);
});