1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
#include "Tracker.h"
#include <QGeoPositionInfoSource>
#include <QVariantMap>
#include <QNetworkRequest>
#include <QNetworkConfigurationManager>
#include <QTimer>
#include <QSslError>
#include <QSslCertificate>
#include <QList>
#include <QDebug>
using namespace QtMobility;
Tracker::Tracker(const QString &server, const QString &serverPath, const QString &username, const QString &password, const QString &certPath, unsigned int serverPort, QObject *parent) :
QObject(parent),
m_session(QNetworkConfigurationManager().defaultConfiguration()),
m_isUploading(false)
{
m_url.setPath(QString("%1/update.py").arg(serverPath));
m_url.setScheme(QLatin1String("https"));
m_url.setHost(server);
m_url.setPort(serverPort);
m_url.setUserName(username);
m_url.setPassword(password);
if (!certPath.isEmpty()) {
foreach (const QSslCertificate &cert, QSslCertificate::fromPath(certPath, QSsl::Der)) {
qDebug() << cert << cert.issuerInfo(QSslCertificate::CommonName);
m_expectedSslErrors.append(QSslError(QSslError::SelfSignedCertificate, cert));
}
}
connect(&m_session, SIGNAL(opened()), this, SLOT(nextUpload()));
QGeoPositionInfoSource *gps = QGeoPositionInfoSource::createDefaultSource(this);
if (!gps)
return;
connect(gps, SIGNAL(positionUpdated(QGeoPositionInfo)), this, SLOT(positionUpdated(QGeoPositionInfo)));
gps->setUpdateInterval(1000 * 60 * 15);
gps->startUpdates();
}
void Tracker::positionUpdated(const QGeoPositionInfo &update)
{
if (!update.isValid() || !update.coordinate().isValid())
return;
QVariantMap map;
map.insert(QLatin1String("timestamp"), update.timestamp().toMSecsSinceEpoch());
if (update.coordinate().type() == QGeoCoordinate::Coordinate3D)
map.insert(QLatin1String("altitude"), update.coordinate().altitude());
map.insert(QLatin1String("latitude"), update.coordinate().latitude());
map.insert(QLatin1String("longitude"), update.coordinate().longitude());
if (update.hasAttribute(QGeoPositionInfo::Direction))
map.insert(QLatin1String("direction"), update.attribute(QGeoPositionInfo::Direction));
if (update.hasAttribute(QGeoPositionInfo::GroundSpeed))
map.insert(QLatin1String("groundSpeed"), update.attribute(QGeoPositionInfo::GroundSpeed));
if (update.hasAttribute(QGeoPositionInfo::VerticalSpeed))
map.insert(QLatin1String("verticalSpeed"), update.attribute(QGeoPositionInfo::VerticalSpeed));
if (update.hasAttribute(QGeoPositionInfo::MagneticVariation))
map.insert(QLatin1String("magneticVariation"), update.attribute(QGeoPositionInfo::MagneticVariation));
if (update.hasAttribute(QGeoPositionInfo::HorizontalAccuracy))
map.insert(QLatin1String("horizontalAccuracy"), update.attribute(QGeoPositionInfo::HorizontalAccuracy));
if (update.hasAttribute(QGeoPositionInfo::VerticalAccuracy))
map.insert(QLatin1String("verticalAccuracy"), update.attribute(QGeoPositionInfo::VerticalAccuracy));
m_positions.enqueue(m_json.serialize(map));
upload();
}
void Tracker::upload()
{
if (m_isUploading)
return;
m_isUploading = true;
m_session.open();
}
void Tracker::nextUpload()
{
if (m_positions.empty()) {
m_session.close();
m_isUploading = false;
return;
}
if (qobject_cast<QNetworkReply*>(sender())) {
m_positions.dequeue();
sender()->deleteLater();
}
QNetworkRequest request(m_url);
request.setHeader(QNetworkRequest::ContentTypeHeader, QLatin1String("application/json"));
QNetworkReply *reply = m_network.post(request, m_positions.head());
reply->ignoreSslErrors(m_expectedSslErrors);
connect(reply, SIGNAL(finished()), this, SLOT(nextUpload()));
connect(reply, SIGNAL(error(QNetworkReply::NetworkError)), this, SLOT(uploadError(QNetworkReply::NetworkError)));
}
void Tracker::uploadError(QNetworkReply::NetworkError)
{
QNetworkReply *reply = qobject_cast<QNetworkReply*>(sender());
if (!reply)
return;
qDebug() << reply->errorString();
reply->deleteLater();
QTimer::singleShot(1000 * 60 * 5, this, SLOT(nextUpload()));
}
|
