Method onReplyError

app/src/AI/Conversation.cpp:978–1024

* @brief Records a network or stream error and ends the turn. Transient failures (429, * 5xx, timeouts) retry with backoff when nothing has streamed yet, instead of * throwing away the whole turn. */

 *        throwing away the whole turn.
 */
void AI::Conversation::onReplyError(const QString& message)
{
  qCWarning(serialStudioAI) << "Reply error:" << message;

  if (shouldRetryAfterError()) {
    scheduleTransientRetry(message);
    return;
  }

  setLastError(message);
  Q_EMIT errorOccurred(message);

  m_streamFlushTimer->stop();
  if (m_streamDirty)
    flushPendingStreamUpdate();

  if (m_assistantIndex >= 0 && m_assistantIndex < m_uiMessages.size()) {
    auto map = m_uiMessages.at(m_assistantIndex).toMap();
    map.insert(QStringLiteral("streaming"), false);
    m_uiMessages[m_assistantIndex] = map;
  }

  QVariantMap errorRow;
  errorRow[QStringLiteral("role")]      = QStringLiteral("error");
  errorRow[QStringLiteral("text")]      = message;
  errorRow[QStringLiteral("toolCalls")] = QVariantList();
  m_uiMessages.append(errorRow);
  Q_EMIT messagesChanged();

  if (!m_awaitingConfirm.isEmpty()) {
    for (auto it = m_awaitingConfirm.constBegin(); it != m_awaitingConfirm.constEnd(); ++it)
      updateToolCallCard(it.key(), CallStatus::Error);

    m_awaitingConfirm.clear();
    setAwaitingConfirmation(false);
  }

  m_assistantText.clear();
  m_assistantThinking.clear();
  m_assistantIndex          = -1;
  m_pendingThinkingBlocks   = QJsonArray();
  m_pendingToolUseBlocks    = QJsonArray();
  m_pendingToolResultBlocks = QJsonArray();
  m_outstandingToolResults  = 0;
  teardownReply();
  setBusy(false);
}

/**
 * @brief Returns true when the failed request is safe to retry: transient cause, retry