diff options
author | familom <familom@yandex-team.ru> | 2022-02-10 16:49:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:49 +0300 |
commit | 9c61d3a2cac2a16341e82c613b030fcc03bf277a (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/rain_check/http/client.cpp | |
parent | f281aaf77179d27d6208b873e95ae6cd45765a63 (diff) | |
download | ydb-9c61d3a2cac2a16341e82c613b030fcc03bf277a.tar.gz |
Restoring authorship annotation for <familom@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/rain_check/http/client.cpp')
-rw-r--r-- | library/cpp/messagebus/rain_check/http/client.cpp | 50 |
1 files changed, 25 insertions, 25 deletions
diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp index c72fbd33e0..5ef5ceeece 100644 --- a/library/cpp/messagebus/rain_check/http/client.cpp +++ b/library/cpp/messagebus/rain_check/http/client.cpp @@ -1,5 +1,5 @@ -#include "client.h" - +#include "client.h" + #include "http_code_extractor.h" #include <library/cpp/http/io/stream.h> @@ -7,13 +7,13 @@ #include <library/cpp/neh/http_common.h> #include <library/cpp/neh/location.h> #include <library/cpp/neh/neh.h> - + #include <util/generic/ptr.h> #include <util/generic/strbuf.h> #include <util/network/socket.h> #include <util/stream/str.h> - -namespace NRainCheck { + +namespace NRainCheck { class THttpCallback: public NNeh::IOnRecv { public: THttpCallback(NRainCheck::THttpFuture* future) @@ -21,7 +21,7 @@ namespace NRainCheck { { Y_VERIFY(!!future, "future is NULL"); } - + void OnRecv(NNeh::THandle& handle) override { THolder<THttpCallback> self(this); NNeh::TResponseRef response = handle.Get(); @@ -35,24 +35,24 @@ namespace NRainCheck { THttpFuture::THttpFuture() : Task(nullptr) , ErrorCode(THttpFuture::NoError) - { - } - + { + } + THttpFuture::~THttpFuture() { - } - + } + bool THttpFuture::HasError() const { return (ErrorCode != THttpFuture::NoError); } - + THttpFuture::EError THttpFuture::GetErrorCode() const { return ErrorCode; } - + TString THttpFuture::GetErrorDescription() const { return ErrorDescription; } - + THttpClientService::THttpClientService() : GetProtocol(NNeh::ProtocolFactory()->Protocol("http")) , FullProtocol(NNeh::ProtocolFactory()->Protocol("full")) @@ -60,10 +60,10 @@ namespace NRainCheck { Y_VERIFY(!!GetProtocol, "GET protocol is NULL."); Y_VERIFY(!!FullProtocol, "POST protocol is NULL."); } - + THttpClientService::~THttpClientService() { } - + void THttpClientService::SendPost(TString addr, const TString& data, const THttpHeaders& headers, THttpFuture* future) { Y_VERIFY(!!future, "future is NULL."); @@ -86,10 +86,10 @@ namespace NRainCheck { future->SetFail(THttpFuture::OtherError, err.AsStrBuf()); } } - + void THttpClientService::Send(const TString& request, THttpFuture* future) { Y_VERIFY(!!future, "future is NULL."); - + TTaskRunnerBase* current = TTaskRunnerBase::CurrentTask(); future->SetRunning(current); future->Task = current; @@ -115,18 +115,18 @@ namespace NRainCheck { bool THttpFuture::HasResponseBody() const { return !!Response; } - + ui32 THttpFuture::GetHttpCode() const { Y_ASSERT(IsDone()); Y_ASSERT(HasHttpCode()); - + return static_cast<ui32>(*HttpCode); } - + TString THttpFuture::GetResponseBody() const { Y_ASSERT(IsDone()); Y_ASSERT(HasResponseBody()); - + return Response->Data; } @@ -137,18 +137,18 @@ namespace NRainCheck { } else { ErrorCode = THttpFuture::BadHttpCodeError; ErrorDescription = response->GetErrorText(); - + HttpCode = TryGetHttpCodeFromErrorDescription(ErrorDescription); } Response.Reset(response); SetDone(); } - + void THttpFuture::SetFail(THttpFuture::EError errorCode, const TStringBuf& errorDescription) { ErrorCode = errorCode; ErrorDescription = errorDescription; Response.Destroy(); SetDone(); } - + } |