Function createReadyFetchProxyProc

apps/sim/lib/execution/isolated-vm.test.ts:133–171

(fetchMessage: { url: string; optionsJson?: string })

}

function createReadyFetchProxyProc(fetchMessage: { url: string; optionsJson?: string }): MockProc {
  const proc = createBaseProc()
  let currentExecutionId = 0

  proc.send = (message: unknown) => {
    const msg = message as { type?: string; executionId?: number; request?: { requestId?: string } }

    if (msg.type === 'execute') {
      currentExecutionId = msg.executionId ?? 0
      setImmediate(() => {
        proc.emit('message', {
          type: 'fetch',
          fetchId: 1,
          requestId: msg.request?.requestId ?? 'fetch-test',
          url: fetchMessage.url,
          optionsJson: fetchMessage.optionsJson,
        })
      })
      return true
    }

    if (msg.type === 'fetchResponse') {
      const fetchResponse = message as { response?: string }
      setImmediate(() => {
        proc.emit('message', {
          type: 'result',
          executionId: currentExecutionId,
          result: { result: fetchResponse.response ?? '', stdout: '' },
        })
      })
      return true
    }

    return true
  }

  setImmediate(() => proc.emit('message', { type: 'ready' }))
  return proc
}

const { mockSpawn, mockExecSync, mockSanitizeUrl, mockEnv } = vi.hoisted(() => ({
  mockSpawn: vi.fn(),