cls_network_manager.cpp

#include <QJsonArray>
#include <QNetworkReply>

#include <cl_frontend.h>

extern "C"
{
  #include <cl_common.h>
  #include <cl_json.h>
}

#include "cls_network_manager.h"

ClsNetworkManager::ClsNetworkManager()
{
  qRegisterMetaType<cls_net_cb>();
  connect(this, SIGNAL(finished(QNetworkReply*)),
          this, SLOT(onFinished(QNetworkReply*)));
  connect(this, SIGNAL(request(QString,QString,cls_net_cb)),
          this, SLOT(onRequest(QString,QString,cls_net_cb)));
}

void ClsNetworkManager::onFinished(QNetworkReply *reply)
{
  cls_net_cb cb = m_Requests.at(reply);
  cl_network_response_t response;

  response.error_code = reply->error();

  QByteArray response_array = reply->readAll();
  response.data = response_array.data();

  bool success;
  if (cl_json_get(&success, response.data, CL_JSON_KEY_SUCCESS, CL_JSON_TYPE_BOOLEAN, sizeof(bool)))
  {
    if (!success)
    {
      char reason[2048];

      if (cl_json_get(reason, response.data, CL_JSON_KEY_REASON, CL_JSON_TYPE_STRING, sizeof(reason)))
        cl_fe_display_message(CL_MSG_ERROR, reason);
      else
        cl_fe_display_message(CL_MSG_ERROR, "Request failed with no given reason.");
    }
  }
  else
    cl_fe_display_message(CL_MSG_ERROR, reply->errorString().toStdString().c_str());

  if (cb.function)
    cb.function(response, cb.userdata);

  m_Requests.erase(reply);
}

void ClsNetworkManager::onRequest(QString url, QString data, cls_net_cb callback)
{
  QUrl url_data = QUrl(url);
  if (!url_data.isValid())
    return;

  QNetworkRequest request;
  request.setHeader(QNetworkRequest::ContentTypeHeader,
                    QStringLiteral("application/x-www-form-urlencoded"));
#ifdef GIT_VERSION
  request.setRawHeader("User-Agent", QStringLiteral("classicslive-standalone %1").arg(GIT_VERSION).toUtf8());
#else
  request.setRawHeader("User-Agent", "classicslive-standalone");
#endif
  request.setUrl(QUrl(url));

  QByteArray post_data;
  post_data.append(data);

  QNetworkReply *reply = post(request, post_data);
  m_Requests.insert(std::pair<QNetworkReply*, cls_net_cb>(reply, callback));
}