Method processBufferedJson

app/src/API/Server.cpp:1051–1115

* @brief Attempts to parse buffered data as a complete JSON message. */

 * @brief Attempts to parse buffered data as a complete JSON message.
 */
void API::Server::processBufferedJson(QTcpSocket* socket,
                                      ConnectionState& state,
                                      const QByteArray& trimmed)
{
  Q_ASSERT(socket);
  Q_ASSERT(!trimmed.isEmpty());

  auto& buffer = state.buffer;

  if (trimmed.size() > kMaxApiMessageBytes) {
    qWarning() << "[API] Message size limit exceeded:" << state.peerAddress << ":" << state.peerPort
               << "- Message size:" << trimmed.size() << "- Limit:" << kMaxApiMessageBytes;

    sendResponseToSocket(
      socket,
      CommandResponse::makeError(
        QString(), ErrorCode::ExecutionError, QStringLiteral("API message exceeds size limit"))
        .toJsonBytes());
    buffer.clear();
    return;
  }

  if (exceedsJsonDepthLimit(trimmed, kMaxApiJsonDepth)) {
    qWarning() << "[API] JSON depth limit exceeded (buffered):" << state.peerAddress << ":"
               << state.peerPort << "- Max depth:" << kMaxApiJsonDepth;

    sendResponseToSocket(
      socket,
      CommandResponse::makeError(
        QString(), ErrorCode::ExecutionError, QStringLiteral("JSON nesting depth exceeds limit"))
        .toJsonBytes());
    buffer.clear();
    return;
  }

  QString type;
  QJsonObject json;
  try {
    const char firstChar = trimmed.at(0);
    const char lastChar  = trimmed.back();
    const bool complete =
      (firstChar == '{' && lastChar == '}') || (firstChar == '[' && lastChar == ']');

    if (API::parseMessage(trimmed, type, json) || MCP::isMCPMessage(trimmed)) {
      handleJsonMessage(socket, state, trimmed);
      buffer.clear();
    } else if (complete) {
      sendResponseToSocket(
        socket,
        CommandResponse::makeError(
          QString(), ErrorCode::InvalidJson, QStringLiteral("Failed to parse JSON message"))
          .toJsonBytes());
      buffer.clear();
    }
  } catch (...) {
    qWarning() << "[API] JSON parsing exception (buffered):" << state.peerAddress << ":"
               << state.peerPort << "- Buffer size:" << trimmed.size()
               << "- Disconnecting client (malformed or too deep JSON)";