Function handleError

apps/sim/lib/copilot/request/lifecycle/finalize.ts:107–162

(
  result: OrchestratorResult,
  publisher: StreamWriter,
  runId: string,
  requestId: string
)

}

async function handleError(
  result: OrchestratorResult,
  publisher: StreamWriter,
  runId: string,
  requestId: string
): Promise<void> {
  const errorMessage =
    result.error ||
    result.errors?.[0] ||
    'An unexpected error occurred while processing the response.'

  // Persist whatever was generated before the failure, exactly like an abort —
  // a transient provider error (e.g. overloaded) shouldn't discard the partial
  // assistant output the user already saw streaming.
  const partialContent = result.content || undefined
  const partialContentLen = result.content?.length ?? 0
  const toolCallCount = result.toolCalls?.length ?? 0

  if (publisher.clientDisconnected) {
    logger.info(`[${requestId}] Stream failed after client disconnect`, { error: errorMessage })
  }
  logger.error(`[${requestId}] Orchestration returned failure`, {
    error: errorMessage,
    partialContentLen,
    toolCallCount,
  })

  // Surface the real error (Go already classifies provider errors like
  // "overloaded" into a friendly displayMessage). Don't clobber it with a
  // generic string.
  await publisher.publish({
    type: MothershipStreamV1EventType.error,
    payload: {
      message: errorMessage,
      error: errorMessage,
      displayMessage: errorMessage,
      data: { displayMessage: errorMessage },
    },
  })
  if (!publisher.sawComplete) {
    await publisher.publish({
      type: MothershipStreamV1EventType.complete,
      payload: {
        status: MothershipStreamV1CompletionStatus.error,
        ...(partialContent ? { partialContent } : {}),
        ...(partialContentLen ? { partialContentLen } : {}),
        ...(toolCallCount ? { toolCallCount } : {}),
      },
    })
  }
  await publisher.flush()
  await loggedRunStatusUpdate(runId, MothershipStreamV1CompletionStatus.error, requestId, {
    completedAt: new Date(),
    error: errorMessage,
  })
}

async function handleSuccess(