aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/io/stream_ut.cpp
diff options
context:
space:
mode:
authorArseny Smalyuk <smalukav@gmail.com>2022-02-10 16:48:05 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:05 +0300
commit12559cd7f2fa0cf54ffb0d961949fea58c0e18cb (patch)
tree1c6e1bb383ce1ed8ea168386f913410dd55ccb7f /library/cpp/http/io/stream_ut.cpp
parent5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (diff)
downloadydb-12559cd7f2fa0cf54ffb0d961949fea58c0e18cb.tar.gz
Restoring authorship annotation for Arseny Smalyuk <smalukav@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/io/stream_ut.cpp')
-rw-r--r--library/cpp/http/io/stream_ut.cpp54
1 files changed, 27 insertions, 27 deletions
diff --git a/library/cpp/http/io/stream_ut.cpp b/library/cpp/http/io/stream_ut.cpp
index 1ea35df675..47060a3948 100644
--- a/library/cpp/http/io/stream_ut.cpp
+++ b/library/cpp/http/io/stream_ut.cpp
@@ -14,7 +14,7 @@
#include <util/stream/zlib.h>
#include <util/stream/null.h>
-Y_UNIT_TEST_SUITE(THttpStreamTest) {
+Y_UNIT_TEST_SUITE(THttpStreamTest) {
class TTestHttpServer: public THttpServer::ICallBack {
class TRequest: public THttpClientRequestEx {
public:
@@ -443,7 +443,7 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
Y_UNIT_TEST(CodecsPriority) {
TMemoryInput request("GET / HTTP/1.1\r\nAccept-Encoding: gzip, br\r\n\r\n");
- TVector<TStringBuf> codecs = {"br", "gzip"};
+ TVector<TStringBuf> codecs = {"br", "gzip"};
THttpInput i(&request);
TString result;
@@ -451,7 +451,7 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
THttpOutput httpOut(&out, &i);
httpOut.EnableKeepAlive(true);
- httpOut.EnableCompression(codecs);
+ httpOut.EnableCompression(codecs);
httpOut << "HTTP/1.1 200 OK\r\n";
char answer[] = "Mary had a little lamb.";
httpOut << "Content-Length: " << strlen(answer) << "\r\n"
@@ -466,7 +466,7 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
Y_UNIT_TEST(CodecsPriority2) {
TMemoryInput request("GET / HTTP/1.1\r\nAccept-Encoding: gzip, br\r\n\r\n");
- TVector<TStringBuf> codecs = {"gzip", "br"};
+ TVector<TStringBuf> codecs = {"gzip", "br"};
THttpInput i(&request);
TString result;
@@ -474,7 +474,7 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
THttpOutput httpOut(&out, &i);
httpOut.EnableKeepAlive(true);
- httpOut.EnableCompression(codecs);
+ httpOut.EnableCompression(codecs);
httpOut << "HTTP/1.1 200 OK\r\n";
char answer[] = "Mary had a little lamb.";
httpOut << "Content-Length: " << strlen(answer) << "\r\n"
@@ -665,27 +665,27 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
UNIT_ASSERT(!result.Contains(TStringBuf("0\r\n")));
}
- Y_UNIT_TEST(TestHttpOutputDisableCompressionHeader) {
- TMemoryInput request("GET / HTTP/1.1\r\nAccept-Encoding: gzip\r\n\r\n");
- const TString data = "qqqqqqqqqqqqqqqqqqqqqqqqqqqqqq";
-
- THttpInput httpInput(&request);
- TString result;
-
- {
- TStringOutput output(result);
- THttpOutput httpOutput(&output, &httpInput);
- httpOutput.EnableCompressionHeader(false);
- httpOutput << "HTTP/1.1 200 OK\r\n"
- "content-encoding: gzip\r\n"
- "\r\n" + data;
- httpOutput.Finish();
- }
-
- UNIT_ASSERT(result.Contains("content-encoding: gzip"));
- UNIT_ASSERT(result.Contains(data));
- }
-
+ Y_UNIT_TEST(TestHttpOutputDisableCompressionHeader) {
+ TMemoryInput request("GET / HTTP/1.1\r\nAccept-Encoding: gzip\r\n\r\n");
+ const TString data = "qqqqqqqqqqqqqqqqqqqqqqqqqqqqqq";
+
+ THttpInput httpInput(&request);
+ TString result;
+
+ {
+ TStringOutput output(result);
+ THttpOutput httpOutput(&output, &httpInput);
+ httpOutput.EnableCompressionHeader(false);
+ httpOutput << "HTTP/1.1 200 OK\r\n"
+ "content-encoding: gzip\r\n"
+ "\r\n" + data;
+ httpOutput.Finish();
+ }
+
+ UNIT_ASSERT(result.Contains("content-encoding: gzip"));
+ UNIT_ASSERT(result.Contains(data));
+ }
+
size_t DoTestHttpOutputSize(const TString& res, bool enableCompession) {
TTestHttpServer serverImpl(res);
TPortManager pm;
@@ -729,4 +729,4 @@ Y_UNIT_TEST_SUITE(THttpStreamTest) {
UNIT_ASSERT_VALUES_EQUAL(res.size(), DoTestHttpOutputSize(res, false));
UNIT_ASSERT_VALUES_UNEQUAL(res.size(), DoTestHttpOutputSize(res, true));
}
-} // THttpStreamTest suite
+} // THttpStreamTest suite