aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/rain_check/http/client.cpp
diff options
context:
space:
mode:
authorfamilom <familom@yandex-team.ru>2022-02-10 16:49:49 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:49 +0300
commit9c61d3a2cac2a16341e82c613b030fcc03bf277a (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/rain_check/http/client.cpp
parentf281aaf77179d27d6208b873e95ae6cd45765a63 (diff)
downloadydb-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.cpp50
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();
}
-
+
}