source: ntrip/trunk/BNC/bncnetrequest.cpp@ 1315

/* -------------------------------------------------------------------------
 * BKG NTRIP Client
 * -------------------------------------------------------------------------
 *
 * Class:      bncNetRequest
 *
 * Purpose:    Prepare and submit network request
 *
 * Author:     L. Mervart
 *
 * Created:    09-Dec-2008
 *
 * Changes:    
 *
 * -----------------------------------------------------------------------*/

#include <iostream>
#include <iomanip>

#include "bncnetrequest.h"

using namespace std;

#define AGENTVERSION "1.7"

// Constructor
////////////////////////////////////////////////////////////////////////////
bncNetRequest::bncNetRequest() {
  _manager = 0;
  _reply   = 0;
}

// Destructor
////////////////////////////////////////////////////////////////////////////
bncNetRequest::~bncNetRequest() {
  delete _reply;
  delete _manager;
}

// Network Request
////////////////////////////////////////////////////////////////////////////
t_irc bncNetRequest::request(const QUrl& mountPoint, const QByteArray& ggaStr) {

  // Network Access Manager
  // ----------------------
  if (_manager == 0) {
    _manager = new QNetworkAccessManager(this);
  }
  else {
    return failure;
  }

  // Proxy
  // -----
  QSettings settings;
  QString proxyHost = settings.value("proxyHost").toString();
  if (proxyHost.isEmpty()) {
    QNetworkProxy proxy(QNetworkProxy::NoProxy);
    _manager->setProxy(proxy);
  }
  else {
    QNetworkProxy proxy(QNetworkProxy::Socks5Proxy);
    proxy.setHostName(proxyHost);
    proxy.setPort(settings.value("proxyPort").toInt());
    _manager->setProxy(proxy);
  }

  connect(_manager, SIGNAL(finished(QNetworkReply*)),
          this, SLOT(slotReplyFinished(QNetworkReply*)));

  // Network Request
  // ---------------
///  QNetworkRequest request;
///  request.setUrl(mountPoint);
///  request.setRawHeader("User-Agent", "NTRIP BNC/" AGENTVERSION);
///  request.setRawHeader("Host", mountPoint.host().toAscii());
///
///  QString uName = QUrl::fromPercentEncoding(mountPoint.userName().toAscii());
///  QString passW = QUrl::fromPercentEncoding(mountPoint.password().toAscii());
///  if (!uName.isEmpty() || !passW.isEmpty()) {
///    QByteArray userAndPwd = "Basic " + (uName.toAscii() + ":" +
///                                        passW.toAscii()).toBase64();
///    request.setRawHeader("Authorization", userAndPwd);
///  }
///  
///  if (!ggaStr.isEmpty()) {
///    request.setRawHeader("", ggaStr);
///  }

  QHttpRequestHeader header("GET", "/CBRU0", 1, 1);

  header.addValue("User-Agent", "NTRIP BNC/1.7");

  QByteArray userAndPwd = "Basic " + QByteArray("cvutlukes:monitoring").toBase64();
  header.addValue("Authorization", userAndPwd);

  QHttp* http = new QHttp("czeposr.cuzk.cz", 2101);

  connect(http, SIGNAL(readyRead(const QHttpResponseHeader&)), 
          this, SLOT(slotReadyRead()));

  QBuffer buffer;
  http->request(header, 0, &buffer);

  while (true) {
    if (buffer.bytesAvailable()) {
      QByteArray arr = buffer.readAll();
      cout << arr.data();
    }
    else {
      buffer.waitForReadyRead(1000);
    }
  }


  return success;
}

// 
////////////////////////////////////////////////////////////////////////////
void bncNetRequest::slotReplyFinished(QNetworkReply*) {
  cout << "slotReplyFinished" << endl;
  this->deleteLater();
}

// 
////////////////////////////////////////////////////////////////////////////
void bncNetRequest::slotReadyRead() {
  cout << "slotReadyRead" << endl;
  QByteArray buffer = _reply->readAll();
  cout << buffer.data();
}

// 
////////////////////////////////////////////////////////////////////////////
void bncNetRequest::slotError(QNetworkReply::NetworkError) {
  cout << "slotError " << _reply->error() << endl
       << _reply->errorString().toAscii().data() << endl;
}

// 
////////////////////////////////////////////////////////////////////////////
void bncNetRequest::slotSslErrors(QList<QSslError>) {
  cout << "slotSslError" << endl;
}