Function ensureRuntimeHost

desktop/runtime-host/client-bridge.ts:350–427

(host: HostConnection)

}

async function ensureRuntimeHost(host: HostConnection) {
  if (runtimeHostsShuttingDown) {
    throw new Error('Pi runtime host is shutting down.')
  }

  registerHostShutdownHandlers()
  if (host.process && !host.process.killed && host.process.exitCode === null) {
    clearHostIdleTimer(host)
    return host.process
  }

  if (host.startPromise) {
    return host.startPromise
  }

  clearHostIdleTimer(host)
  host.startPromise = (async () => {
    const nodeExecutable = await getNodeExecutable()
    if (runtimeHostsShuttingDown) {
      throw new Error('Pi runtime host is shutting down.')
    }

    return await new Promise<ChildProcess>((resolve, reject) => {
      const child = spawn(nodeExecutable, [getRuntimeHostPath()], {
        cwd: getDesktopWorkingDirectory(),
        env: {
          ...process.env,
          HOWCODE_REPO_ROOT: getDesktopWorkingDirectory(),
          HOWCODE_ELECTRON_RESOURCES_PATH: getElectronResourcesPath(),
          HOWCODE_BUNDLED_SKILLS_PATH: getBundledSkillsPath(),
        },
        stdio: ['ignore', 'pipe', 'pipe', 'ipc'],
      }) as ChildProcess

      let settled = false
      const settleFailure = (error: Error) => {
        if (settled) {
          return
        }
        settled = true
        host.startPromise = null
        host.process = null
        if (host.role === 'thread') {
          forgetHost(host)
        }
        reject(error)
      }

      child.once('spawn', () => {
        if (runtimeHostsShuttingDown) {
          terminateHostProcess(child)
          settleFailure(new Error('Pi runtime host is shutting down.'))
          return
        }

        settled = true
        host.process = child
        host.startPromise = null