source: ntrip/branches/BNC_2.12/src/bncnetqueryv2.cpp@ 8443

Last change on this file since 8443 was 7851, checked in by stuerze, 9 years ago

minor changes

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