[qt] HttpFileSource - rate limit

1 files changed, 12 insertions, 0 deletions

diff --git a/platform/qt/src/http_request.cpp b/platform/qt/src/http_request.cpp
index ac7d969e36..e19316fe2f 100644
--- a/platform/qt/src/http_request.cpp
+++ b/platform/qt/src/http_request.cpp
@@ -3,6 +3,7 @@
 
 #include <mbgl/storage/response.hpp>
 #include <mbgl/util/chrono.hpp>
+#include <mbgl/util/optional.hpp>
 #include <mbgl/util/http_header.hpp>
 #include <mbgl/util/string.hpp>
 
@@ -68,6 +69,8 @@ void HTTPRequest::handleNetworkReply(QNetworkReply *reply)
     }
 
     QPair<QByteArray, QByteArray> line;
+    optional<std::string> retryAfter;
+    optional<std::string> xRateLimitReset;
     foreach(line, reply->rawHeaderPairs()) {
         QString header = QString(line.first).toLower();
 
@@ -79,6 +82,10 @@ void HTTPRequest::handleNetworkReply(QNetworkReply *reply)
             response.expires = http::CacheControl::parse(line.second.constData()).toTimePoint();
         } else if (header == "expires") {
             response.expires = util::parseTimestamp(line.second.constData());
+        } else if (header == "retry-after") {
+            retryAfter = std::string(line.second.constData(), line.second.size());
+        } else if (header == "x-rate-limit-reset") {
+            xRateLimitReset = std::string(line.second.constData(), line.second.size());
         }
     }
 
@@ -109,6 +116,11 @@ void HTTPRequest::handleNetworkReply(QNetworkReply *reply)
         }
         break;
     }
+    case 429:
+        response.error = std::make_unique<Error>(
+                Error::Reason::RateLimit, "HTTP status code 429", 
+                http::parseRetryHeaders(retryAfter, xRateLimitReset));
+        break;
     default:
         Response::Error::Reason reason = (responseCode >= 500 && responseCode < 600) ?
             Error::Reason::Server : Error::Reason::Other;