diff options
| author | Dmitry Mikushin <dmitry@kernelgen.org> | 2023-02-12 22:38:29 +0100 |
|---|---|---|
| committer | Dmitry Mikushin <dmitry@kernelgen.org> | 2023-02-12 22:38:29 +0100 |
| commit | 97b0eb447e36308cd6783add28de88e429627bfe (patch) | |
| tree | dc2bc2f55b504dd9970091ca6c96441936127cfd /src | |
| parent | 0519ebae651d8d7466d4392a2ddb718c19c5c650 (diff) | |
Parameterizing the number of retries and backoff duration for HttpClient.makeRequest
Diffstat (limited to 'src')
| -rw-r--r-- | src/Api.cpp | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/src/Api.cpp b/src/Api.cpp index dcb2b36..b6dba9a 100644 --- a/src/Api.cpp +++ b/src/Api.cpp @@ -2499,7 +2499,9 @@ boost::property_tree::ptree Api::sendRequest(const std::string& method, const st url += "/"; url += method; - while(1) + int requestRetryBackoff = _httpClient.getRequestBackoff(); + int retries = 0; + while (1) { std::string serverResponse = _httpClient.makeRequest(url, args); if (!serverResponse.compare(0, 6, "<html>")) { @@ -2511,9 +2513,14 @@ boost::property_tree::ptree Api::sendRequest(const std::string& method, const st if (result.get<bool>("ok", false)) { return result.get_child("result"); } else { - std::this_thread::sleep_for(std::chrono::seconds(1)); - continue; - //throw TgException(result.get("description", "")); + if (retries == _httpClient.getRequestMaxRetries()) { + throw TgException(result.get("description", "")); + } + else { + std::this_thread::sleep_for(std::chrono::seconds(requestRetryBackoff)); + retries++; + continue; + } } } catch (boost::property_tree::ptree_error& e) { throw TgException("tgbot-cpp library can't parse json response. " + std::string(e.what())); |