[1378] | 1 | /* -------------------------------------------------------------------------
|
---|
| 2 | * BKG NTRIP Client
|
---|
| 3 | * -------------------------------------------------------------------------
|
---|
| 4 | *
|
---|
| 5 | * Class: bncNetQueryV2
|
---|
| 6 | *
|
---|
| 7 | * Purpose: Blocking Network Requests (NTRIP Version 2)
|
---|
| 8 | *
|
---|
| 9 | * Author: L. Mervart
|
---|
| 10 | *
|
---|
| 11 | * Created: 27-Dec-2008
|
---|
| 12 | *
|
---|
[7612] | 13 | * Changes:
|
---|
[1378] | 14 | *
|
---|
| 15 | * -----------------------------------------------------------------------*/
|
---|
| 16 |
|
---|
[1583] | 17 | #include <iostream>
|
---|
| 18 |
|
---|
[1379] | 19 | #include "bncnetqueryv2.h"
|
---|
[1535] | 20 | #include "bncsettings.h"
|
---|
[2011] | 21 | #include "bncversion.h"
|
---|
[3349] | 22 | #include "bncsslconfig.h"
|
---|
[3359] | 23 | #include "bncsettings.h"
|
---|
[1378] | 24 |
|
---|
| 25 | // Constructor
|
---|
| 26 | ////////////////////////////////////////////////////////////////////////////
|
---|
[3337] | 27 | bncNetQueryV2::bncNetQueryV2(bool secure) {
|
---|
| 28 | _secure = secure;
|
---|
[1378] | 29 | _manager = new QNetworkAccessManager(this);
|
---|
[9706] | 30 | connect(_manager, SIGNAL(proxyAuthenticationRequired(const QNetworkProxy&, QAuthenticator*)),
|
---|
| 31 | this, SLOT(slotProxyAuthenticationRequired(const QNetworkProxy&, QAuthenticator*)));
|
---|
[1378] | 32 | _reply = 0;
|
---|
| 33 | _eventLoop = new QEventLoop(this);
|
---|
[1583] | 34 | _firstData = true;
|
---|
[1378] | 35 | _status = init;
|
---|
[3359] | 36 |
|
---|
| 37 | bncSettings settings;
|
---|
[7612] | 38 | _sslIgnoreErrors =
|
---|
[7513] | 39 | (Qt::CheckState(settings.value("sslIgnoreErrors").toInt()) == Qt::Checked);
|
---|
[3359] | 40 |
|
---|
[3352] | 41 | if (_secure && !QSslSocket::supportsSsl()) {
|
---|
[5068] | 42 | BNC_CORE->slotMessage("No SSL support, install OpenSSL run-time libraries", true);
|
---|
[3352] | 43 | stop();
|
---|
| 44 | }
|
---|
[1378] | 45 | }
|
---|
| 46 |
|
---|
| 47 | // Destructor
|
---|
| 48 | ////////////////////////////////////////////////////////////////////////////
|
---|
| 49 | bncNetQueryV2::~bncNetQueryV2() {
|
---|
| 50 | delete _eventLoop;
|
---|
[7704] | 51 | if (_reply) {
|
---|
| 52 | _reply->abort();
|
---|
| 53 | delete _reply;
|
---|
| 54 | }
|
---|
[1378] | 55 | delete _manager;
|
---|
| 56 | }
|
---|
| 57 |
|
---|
[1713] | 58 | // Stop (quit event loop)
|
---|
[1390] | 59 | ////////////////////////////////////////////////////////////////////////////
|
---|
| 60 | void bncNetQueryV2::stop() {
|
---|
[1393] | 61 | if (_reply) {
|
---|
[1395] | 62 | _reply->abort();
|
---|
[7704] | 63 | delete _reply;
|
---|
| 64 | _reply = 0;
|
---|
[1393] | 65 | }
|
---|
[1394] | 66 | _eventLoop->quit();
|
---|
[1398] | 67 | _status = finished;
|
---|
[1390] | 68 | }
|
---|
| 69 |
|
---|
[1389] | 70 | // End of Request
|
---|
| 71 | ////////////////////////////////////////////////////////////////////////////
|
---|
[1378] | 72 | void bncNetQueryV2::slotFinished() {
|
---|
[1704] | 73 | _eventLoop->quit();
|
---|
| 74 | if (_reply && _reply->error() != QNetworkReply::NoError) {
|
---|
| 75 | _status = error;
|
---|
[9723] | 76 | if (!_reply->attribute(QNetworkRequest::HttpReasonPhraseAttribute).toByteArray().isEmpty()) {
|
---|
[8203] | 77 | emit newMessage(_url.path().toLatin1().replace(0,1,"") +
|
---|
[7612] | 78 | ": NetQueryV2: server replied: " +
|
---|
[1704] | 79 | _reply->attribute(QNetworkRequest::HttpReasonPhraseAttribute).toByteArray(),
|
---|
| 80 | true);
|
---|
[9723] | 81 | } else {
|
---|
| 82 | emit newMessage(_url.path().toLatin1().replace(0,1,"") +
|
---|
| 83 | ": NetQueryV2: server replied: " +
|
---|
| 84 | _reply->errorString().toLatin1(),
|
---|
| 85 | true);
|
---|
| 86 | }
|
---|
[1704] | 87 | }
|
---|
| 88 | else {
|
---|
[1378] | 89 | _status = finished;
|
---|
| 90 | }
|
---|
| 91 | }
|
---|
| 92 |
|
---|
[7612] | 93 | //
|
---|
[1405] | 94 | ////////////////////////////////////////////////////////////////////////////
|
---|
[7612] | 95 | void bncNetQueryV2::slotProxyAuthenticationRequired(const QNetworkProxy&,
|
---|
[1405] | 96 | QAuthenticator*) {
|
---|
| 97 | emit newMessage("slotProxyAuthenticationRequired", true);
|
---|
| 98 | }
|
---|
| 99 |
|
---|
[1389] | 100 | // Start request, block till the next read
|
---|
[1378] | 101 | ////////////////////////////////////////////////////////////////////////////
|
---|
[1380] | 102 | void bncNetQueryV2::startRequest(const QUrl& url, const QByteArray& gga) {
|
---|
[1389] | 103 | startRequestPrivate(url, gga, false);
|
---|
[1378] | 104 | }
|
---|
| 105 |
|
---|
[6787] | 106 | // Start request, block till the next read
|
---|
| 107 | ////////////////////////////////////////////////////////////////////////////
|
---|
| 108 | void bncNetQueryV2::keepAliveRequest(const QUrl& url, const QByteArray& gga) {
|
---|
| 109 | startRequestPrivate(url, gga, false);
|
---|
| 110 | }
|
---|
| 111 |
|
---|
[1389] | 112 | // Start Request (Private Method)
|
---|
[1378] | 113 | ////////////////////////////////////////////////////////////////////////////
|
---|
[1389] | 114 | void bncNetQueryV2::startRequestPrivate(const QUrl& url, const QByteArray& gga,
|
---|
| 115 | bool full) {
|
---|
[1378] | 116 |
|
---|
| 117 | _status = running;
|
---|
| 118 |
|
---|
| 119 | // Default scheme and path
|
---|
| 120 | // -----------------------
|
---|
[1509] | 121 | _url = url;
|
---|
| 122 | if (_url.scheme().isEmpty()) {
|
---|
[3337] | 123 | if (_secure) {
|
---|
| 124 | _url.setScheme("https");
|
---|
| 125 | }
|
---|
| 126 | else {
|
---|
| 127 | _url.setScheme("http");
|
---|
| 128 | }
|
---|
[1378] | 129 | }
|
---|
[1509] | 130 | if (_url.path().isEmpty()) {
|
---|
| 131 | _url.setPath("/");
|
---|
[1378] | 132 | }
|
---|
| 133 |
|
---|
| 134 | // Network Request
|
---|
| 135 | // ---------------
|
---|
[1716] | 136 | QNetworkRequest request;
|
---|
[9739] | 137 | request.setSslConfiguration(BNC_SSL_CONFIG);
|
---|
[1716] | 138 | request.setUrl(_url);
|
---|
[8203] | 139 | request.setRawHeader("Host" , _url.host().toLatin1());
|
---|
[1716] | 140 | request.setRawHeader("Ntrip-Version", "Ntrip/2.0");
|
---|
[8203] | 141 | request.setRawHeader("User-Agent" , "NTRIP BNC/" BNCVERSION " (" BNC_OS ")");
|
---|
[1509] | 142 | if (!_url.userName().isEmpty()) {
|
---|
[8203] | 143 | QString uName = QUrl::fromPercentEncoding(_url.userName().toLatin1());
|
---|
| 144 | QString passW = QUrl::fromPercentEncoding(_url.password().toLatin1());
|
---|
[7612] | 145 | request.setRawHeader("Authorization", "Basic " +
|
---|
[8203] | 146 | (uName + ":" + passW).toLatin1().toBase64());
|
---|
[7612] | 147 | }
|
---|
[1389] | 148 | if (!gga.isEmpty()) {
|
---|
[1716] | 149 | request.setRawHeader("Ntrip-GGA", gga);
|
---|
[1389] | 150 | }
|
---|
[1716] | 151 | request.setRawHeader("Connection" , "close");
|
---|
[1378] | 152 |
|
---|
[7851] | 153 | if (_reply) {
|
---|
| 154 | delete _reply;
|
---|
| 155 | _reply = 0;
|
---|
| 156 | }
|
---|
[1716] | 157 | _reply = _manager->get(request);
|
---|
[1378] | 158 |
|
---|
| 159 | // Connect Signals
|
---|
| 160 | // ---------------
|
---|
| 161 | connect(_reply, SIGNAL(finished()), this, SLOT(slotFinished()));
|
---|
[9722] | 162 | connect(_reply, SIGNAL(finished()), _eventLoop, SLOT(quit()));
|
---|
[9721] | 163 | connect(_reply, SIGNAL(sslErrors(QList<QSslError>)),this, SLOT(slotSslErrors(QList<QSslError>)));
|
---|
[1378] | 164 | if (!full) {
|
---|
[9722] | 165 | connect(_reply, SIGNAL(readyRead()), _eventLoop, SLOT(quit()));
|
---|
[1378] | 166 | }
|
---|
| 167 | }
|
---|
| 168 |
|
---|
| 169 | // Start Request, wait for its completion
|
---|
| 170 | ////////////////////////////////////////////////////////////////////////////
|
---|
| 171 | void bncNetQueryV2::waitForRequestResult(const QUrl& url, QByteArray& outData) {
|
---|
| 172 |
|
---|
| 173 | // Send Request
|
---|
| 174 | // ------------
|
---|
[1389] | 175 | startRequestPrivate(url, "", true);
|
---|
[1378] | 176 |
|
---|
| 177 | // Wait Loop
|
---|
| 178 | // ---------
|
---|
[1394] | 179 | _eventLoop->exec();
|
---|
[1378] | 180 |
|
---|
| 181 | // Copy Data and Return
|
---|
| 182 | // --------------------
|
---|
[7813] | 183 | if (_reply) {
|
---|
| 184 | outData = _reply->readAll();
|
---|
| 185 | }
|
---|
[1378] | 186 | }
|
---|
| 187 |
|
---|
| 188 | // Wait for next data
|
---|
| 189 | ////////////////////////////////////////////////////////////////////////////
|
---|
| 190 | void bncNetQueryV2::waitForReadyRead(QByteArray& outData) {
|
---|
| 191 |
|
---|
| 192 | // Wait Loop
|
---|
| 193 | // ---------
|
---|
| 194 | if (!_reply->bytesAvailable()) {
|
---|
[1394] | 195 | _eventLoop->exec();
|
---|
[1378] | 196 | }
|
---|
[9723] | 197 | if (!_reply) {
|
---|
| 198 | return;
|
---|
| 199 | }
|
---|
[1378] | 200 |
|
---|
[1701] | 201 | // Check NTRIPv2 error code
|
---|
| 202 | // ------------------------
|
---|
| 203 | if (_reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt() != 200) {
|
---|
| 204 | _reply->abort();
|
---|
| 205 | }
|
---|
| 206 |
|
---|
[1378] | 207 | // Append Data
|
---|
| 208 | // -----------
|
---|
[1701] | 209 | else {
|
---|
| 210 | outData.append(_reply->readAll());
|
---|
[1583] | 211 | }
|
---|
[1378] | 212 | }
|
---|
[1712] | 213 |
|
---|
[7612] | 214 | // TSL/SSL
|
---|
[3332] | 215 | ////////////////////////////////////////////////////////////////////////////
|
---|
[3349] | 216 | void bncNetQueryV2::slotSslErrors(QList<QSslError> errors) {
|
---|
[3332] | 217 |
|
---|
[9723] | 218 | QString msg = "SSL Error: ";
|
---|
[3351] | 219 | QSslCertificate cert = _reply->sslConfiguration().peerCertificate();
|
---|
[9708] | 220 | if (!cert.isNull() &&
|
---|
| 221 | cert.issuerInfo(QSslCertificate::OrganizationalUnitName).count() &&
|
---|
| 222 | cert.issuerInfo(QSslCertificate::Organization).count()) {
|
---|
[9719] | 223 |
|
---|
[3354] | 224 | msg += QString("Server Certificate Issued by:\n"
|
---|
| 225 | "%1\n%2\nCannot be verified\n")
|
---|
[8203] | 226 | #if QT_VERSION >= 0x050000
|
---|
| 227 | .arg(cert.issuerInfo(QSslCertificate::OrganizationalUnitName).at(0))
|
---|
| 228 | .arg(cert.issuerInfo(QSslCertificate::Organization).at(0));
|
---|
| 229 | #else
|
---|
[3354] | 230 | .arg(cert.issuerInfo(QSslCertificate::OrganizationalUnitName))
|
---|
| 231 | .arg(cert.issuerInfo(QSslCertificate::Organization));
|
---|
[8203] | 232 | #endif
|
---|
[3351] | 233 | }
|
---|
[9719] | 234 |
|
---|
[9723] | 235 | QListIterator<QSslError> it(errors);
|
---|
[3363] | 236 | while (it.hasNext()) {
|
---|
| 237 | const QSslError& err = it.next();
|
---|
[9723] | 238 | msg += err.errorString();
|
---|
[3353] | 239 | }
|
---|
[9739] | 240 | BNC_CORE->slotMessage(msg.toLatin1(), true);
|
---|
[3346] | 241 |
|
---|
[7513] | 242 | if (_sslIgnoreErrors) {
|
---|
[3353] | 243 | _reply->ignoreSslErrors();
|
---|
[9723] | 244 | BNC_CORE->slotMessage("BNC ignores SSL errors as configured", true);
|
---|
[3353] | 245 | }
|
---|
| 246 | else {
|
---|
| 247 | stop();
|
---|
| 248 | }
|
---|
[9723] | 249 | return;
|
---|
[3332] | 250 | }
|
---|