Function spawnWorker

apps/sim/lib/execution/isolated-vm.ts:893–1036

()

}

function spawnWorker(): Promise<WorkerInfo> {
  const workerId = nextWorkerId++
  spawnInProgress++
  let spawnSettled = false
  let childProcess: ChildProcess | null = null

  const settleSpawnInProgress = () => {
    if (spawnSettled) {
      return false
    }
    spawnSettled = true
    spawnInProgress--
    return true
  }

  const workerInfo: WorkerInfo = {
    get process() {
      if (!childProcess) {
        throw new Error('Worker process is not initialized')
      }
      return childProcess
    },
    ready: false,
    readyPromise: null,
    activeExecutions: 0,
    pendingExecutions: new Map(),
    idleTimeout: null,
    id: workerId,
    lifetimeExecutions: 0,
    retiring: false,
  }

  workerInfo.readyPromise = new Promise<void>((resolve, reject) => {
    if (!checkNodeAvailable()) {
      settleSpawnInProgress()
      reject(
        new Error(
          'Node.js is required for code execution but was not found. ' +
            'Please install Node.js (v20+) from https://nodejs.org'
        )
      )
      return
    }

    const currentDir = path.dirname(fileURLToPath(import.meta.url))
    const candidatePaths = [
      path.join(currentDir, 'isolated-vm-worker.cjs'),
      path.join(currentDir, '..', '..', 'lib', 'execution', 'isolated-vm-worker.cjs'),
      path.join(process.cwd(), 'apps', 'sim', 'lib', 'execution', 'isolated-vm-worker.cjs'),
      path.join(process.cwd(), 'lib', 'execution', 'isolated-vm-worker.cjs'),
    ]
    const workerPath = candidatePaths.find((p) => fs.existsSync(p))

    if (!workerPath) {
      settleSpawnInProgress()
      reject(new Error(`Worker file not found at any of: ${candidatePaths.join(', ')}`))
      return
    }