Function handleBrokerMessage

apps/sim/lib/execution/isolated-vm.ts:619–728

(
  workerInfo: WorkerInfo | undefined,
  msg: Record<string, unknown>
)

}

function handleBrokerMessage(
  workerInfo: WorkerInfo | undefined,
  msg: Record<string, unknown>
): void {
  if (!workerInfo) return
  const brokerId = msg.brokerId as number
  const executionId = msg.executionId as number
  const brokerName = msg.brokerName as string
  const argsJson = msg.argsJson as string | undefined

  const sendResponse = (payload: Record<string, unknown>) => {
    try {
      workerInfo.process.send({ type: 'brokerResponse', brokerId, ...payload })
    } catch (err) {
      logger.error('Failed to send broker response to worker', {
        err,
        brokerId,
        brokerName,
        workerId: workerInfo.id,
      })
    }
  }

  const logReject = (reason: string, extra?: Record<string, unknown>) => {
    logger.warn('Sandbox broker call rejected', {
      reason,
      brokerName,
      executionId,
      workerId: workerInfo.id,
      ...extra,
    })
  }

  const pending = workerInfo.pendingExecutions.get(executionId)
  if (!pending) {
    sendResponse({ error: 'Execution no longer active' })
    return
  }

  if (pending.cancelled) {
    sendResponse({ error: 'Execution cancelled' })
    return
  }

  if (argsJson && argsJson.length > MAX_BROKER_ARGS_JSON_CHARS) {
    logReject('args_too_large', { argsJsonLength: argsJson.length })
    sendResponse({
      error: `Broker args exceed maximum size (${MAX_BROKER_ARGS_JSON_CHARS} chars)`,
    })
    return
  }

  pending.brokerCallCount++
  if (pending.brokerCallCount > MAX_BROKERS_PER_EXECUTION) {
    logReject('rate_limit', { brokerCallCount: pending.brokerCallCount })
    sendResponse({
      error: `Broker call limit exceeded (${MAX_BROKERS_PER_EXECUTION} per execution)`,
    })