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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#include "http_request.hpp"
#include "http_file_source.hpp"
#include <mbgl/storage/response.hpp>
#include <mbgl/util/chrono.hpp>
#include <mbgl/util/http_header.hpp>
#include <mbgl/util/string.hpp>
#include <QByteArray>
#include <QNetworkReply>
#include <QPair>
namespace mbgl {
HTTPRequest::HTTPRequest(HTTPFileSource::Impl* context, const Resource& resource, FileSource::Callback callback)
: m_context(context)
, m_resource(resource)
, m_callback(callback)
{
m_context->request(this);
}
HTTPRequest::~HTTPRequest()
{
if (!m_handled) {
m_context->cancel(this);
}
}
QUrl HTTPRequest::requestUrl() const
{
return QUrl::fromPercentEncoding(QByteArray(m_resource.url.data(), m_resource.url.size()));
}
QNetworkRequest HTTPRequest::networkRequest() const
{
QNetworkRequest req = QNetworkRequest(requestUrl());
req.setAttribute(QNetworkRequest::CacheLoadControlAttribute, QNetworkRequest::PreferCache);
req.setRawHeader("User-Agent", "MapboxGL/1.0 [Qt]");
if (m_resource.priorEtag) {
req.setRawHeader("If-None-Match", QByteArray(m_resource.priorEtag->data(), m_resource.priorEtag->size()));
} else if (m_resource.priorModified) {
req.setRawHeader("If-Modified-Since", util::rfc1123(*m_resource.priorModified).c_str());
}
return req;
}
void HTTPRequest::handleNetworkReply(QNetworkReply *reply)
{
m_handled = true;
// Calling `callback` may result in deleting `this`.
// Copy data to temporaries first.
auto callback = m_callback;
mbgl::Response response;
using Error = Response::Error;
// Handle non-HTTP errors (i.e. like connection).
if (reply->error() && reply->error() < 100) {
response.error = std::make_unique<Error>(
Error::Reason::Connection, reply->errorString().toStdString());
callback(response);
return;
}
QPair<QByteArray, QByteArray> line;
foreach(line, reply->rawHeaderPairs()) {
QString header = QString(line.first).toLower();
if (header == "last-modified") {
response.modified = util::parseTimestamp(line.second.constData());
} else if (header == "etag") {
response.etag = std::string(line.second.constData(), line.second.size());
} else if (header == "cache-control") {
response.expires = http::CacheControl::parse(line.second.constData()).toTimePoint();
} else if (header == "expires") {
response.expires = util::parseTimestamp(line.second.constData());
}
}
int responseCode = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
switch(responseCode) {
case 200: {
QByteArray bytes = reply->readAll();
if (bytes.isEmpty()) {
response.data = std::make_shared<std::string>();
} else {
response.data = std::make_shared<std::string>(bytes.data(), bytes.size());
}
break;
}
case 204:
response.noContent = true;
break;
case 304:
response.notModified = true;
break;
case 404: {
if (m_resource.kind == Resource::Kind::Tile) {
response.noContent = true;
} else {
response.error = std::make_unique<Error>(
Error::Reason::NotFound, "HTTP status code 404");
}
break;
}
default:
Response::Error::Reason reason = (responseCode >= 500 && responseCode < 600) ?
Error::Reason::Server : Error::Reason::Other;
response.error = std::make_unique<Error>(
reason, "HTTP status code " + util::toString(responseCode));
}
callback(response);
}
} // namespace mbgl
|
