Method processRawJsonCommand

app/src/API/Server.cpp:943–1007

* @brief Processes a JSON "raw" command that forwards base64 data to the device. */

 * @brief Processes a JSON "raw" command that forwards base64 data to the device.
 */
void API::Server::processRawJsonCommand(QTcpSocket* socket,
                                        ConnectionState& state,
                                        const QJsonObject& json)
{
  Q_ASSERT(socket);

  const QString id = json.value(QStringLiteral("id")).toString();

  if (!json.contains(QStringLiteral("data"))) {
    sendResponseToSocket(
      socket,
      CommandResponse::makeError(
        id, ErrorCode::MissingParam, QStringLiteral("Missing required parameter: data"))
        .toJsonBytes());
    return;
  }

  const QString dataStr    = json.value(QStringLiteral("data")).toString();
  const QByteArray rawData = QByteArray::fromBase64(dataStr.toUtf8());
  if (rawData.isEmpty() && !dataStr.isEmpty()) {
    sendResponseToSocket(
      socket,
      CommandResponse::makeError(id, ErrorCode::InvalidParam, QStringLiteral("Invalid base64 data"))
        .toJsonBytes());
    return;
  }

  if (rawData.size() > kMaxApiRawBytes) {
    qWarning() << "[API] Raw data size limit exceeded:" << state.peerAddress << ":"
               << state.peerPort << "- Raw data size:" << rawData.size()
               << "- Limit:" << kMaxApiRawBytes;

    sendResponseToSocket(
      socket,
      CommandResponse::makeError(
        id, ErrorCode::ExecutionError, QStringLiteral("Raw payload exceeds size limit"))
        .toJsonBytes());
    return;
  }

  if (!authorizeDeviceWrite()) {
    sendResponseToSocket(socket,
                         CommandResponse::makeError(id,
                                                    ErrorCode::ExecutionError,
                                                    QStringLiteral("Device write denied by user"))
                           .toJsonBytes());
    return;
  }

  auto& manager = IO::ConnectionManager::instance();
  if (!manager.isConnected()) {
    sendResponseToSocket(
      socket,
      CommandResponse::makeError(id, ErrorCode::ExecutionError, QStringLiteral("Not connected"))
        .toJsonBytes());
    return;
  }