summaryrefslogtreecommitdiffstats
path: root/library/cpp/string_utils/tskv_format
diff options
context:
space:
mode:
authorhcpp <[email protected]>2023-11-08 22:36:26 +0300
committerhcpp <[email protected]>2023-11-08 22:59:37 +0300
commit202a1ac82d1e5912c218f715e2b51eedca69d71b (patch)
tree820c756d93da98ab7b9645687587f102507ac275 /library/cpp/string_utils/tskv_format
parent56be5c51d62e26ec258cc3171e3417ab1516a178 (diff)
Revert "metrics have been added"
This reverts commit 16e792be75335b09a4f9f254e3972030af83b1ad, reversing changes made to 3790f3d771d1a65ed6c0d05f3e0d79ff13308142.
Diffstat (limited to 'library/cpp/string_utils/tskv_format')
-rw-r--r--library/cpp/string_utils/tskv_format/builder.cpp1
-rw-r--r--library/cpp/string_utils/tskv_format/builder.h67
-rw-r--r--library/cpp/string_utils/tskv_format/escape.cpp112
-rw-r--r--library/cpp/string_utils/tskv_format/escape.h10
-rw-r--r--library/cpp/string_utils/tskv_format/tskv_map.cpp60
-rw-r--r--library/cpp/string_utils/tskv_format/tskv_map.h62
-rw-r--r--library/cpp/string_utils/tskv_format/ya.make9
7 files changed, 0 insertions, 321 deletions
diff --git a/library/cpp/string_utils/tskv_format/builder.cpp b/library/cpp/string_utils/tskv_format/builder.cpp
deleted file mode 100644
index ede90740221..00000000000
--- a/library/cpp/string_utils/tskv_format/builder.cpp
+++ /dev/null
@@ -1 +0,0 @@
-#include "builder.h"
diff --git a/library/cpp/string_utils/tskv_format/builder.h b/library/cpp/string_utils/tskv_format/builder.h
deleted file mode 100644
index 40689ddc85e..00000000000
--- a/library/cpp/string_utils/tskv_format/builder.h
+++ /dev/null
@@ -1,67 +0,0 @@
-#pragma once
-
-#include "escape.h"
-
-#include <util/stream/str.h>
-
-namespace NTskvFormat {
- class TLogBuilder {
- private:
- TStringStream Out;
-
- public:
- TLogBuilder() = default;
-
- TLogBuilder(TStringBuf logType, ui32 unixtime) {
- Begin(logType, unixtime);
- }
-
- TLogBuilder(TStringBuf logType) {
- Begin(logType);
- }
-
- TLogBuilder& Add(TStringBuf fieldName, TStringBuf fieldValue) {
- if (!Out.Empty()) {
- Out << '\t';
- }
- Escape(fieldName, Out.Str());
- Out << '=';
- Escape(fieldValue, Out.Str());
-
- return *this;
- }
-
- TLogBuilder& AddUnescaped(TStringBuf fieldName, TStringBuf fieldValue) {
- if (!Out.Empty()) {
- Out << '\t';
- }
- Out << fieldName << '=' << fieldValue;
- return *this;
- }
-
- TLogBuilder& Begin(TStringBuf logType, ui32 unixtime) {
- Out << "tskv\ttskv_format=" << logType << "\tunixtime=" << unixtime;
- return *this;
- }
-
- TLogBuilder& Begin(TStringBuf logType) {
- Out << "tskv\ttskv_format=" << logType;
- return *this;
- }
-
- TLogBuilder& End() {
- Out << '\n';
- return *this;
- }
-
- TLogBuilder& Clear() {
- Out.Clear();
- return *this;
- }
-
- TString& Str() {
- return Out.Str();
- }
- };
-
-}
diff --git a/library/cpp/string_utils/tskv_format/escape.cpp b/library/cpp/string_utils/tskv_format/escape.cpp
deleted file mode 100644
index 3dc78bec8c0..00000000000
--- a/library/cpp/string_utils/tskv_format/escape.cpp
+++ /dev/null
@@ -1,112 +0,0 @@
-#include <util/generic/yexception.h>
-#include "escape.h"
-
-namespace NTskvFormat {
- namespace {
- const TStringBuf ESCAPE_CHARS("\t\n\r\\\0=\"", 7);
-
- TString& EscapeImpl(const char* src, size_t len, TString& dst) {
- TStringBuf srcStr(src, len);
- size_t noEscapeStart = 0;
-
- while (noEscapeStart < len) {
- size_t noEscapeEnd = srcStr.find_first_of(ESCAPE_CHARS, noEscapeStart);
-
- if (noEscapeEnd == TStringBuf::npos) {
- dst.append(src + noEscapeStart, len - noEscapeStart);
- break;
- }
-
- dst.append(src + noEscapeStart, noEscapeEnd - noEscapeStart);
-
- switch (src[noEscapeEnd]) {
- case '\t':
- dst.append(TStringBuf("\\t"));
- break;
- case '\n':
- dst.append(TStringBuf("\\n"));
- break;
- case '\r':
- dst.append(TStringBuf("\\r"));
- break;
- case '\0':
- dst.append(TStringBuf("\\0"));
- break;
- case '\\':
- dst.append(TStringBuf("\\\\"));
- break;
- case '=':
- dst.append(TStringBuf("\\="));
- break;
- case '"':
- dst.append(TStringBuf("\\\""));
- break;
- }
-
- noEscapeStart = noEscapeEnd + 1;
- }
-
- return dst;
- }
-
- TString& UnescapeImpl(const char* src, const size_t len, TString& dst) {
- TStringBuf srcStr(src, len);
- size_t noEscapeStart = 0;
-
- while (noEscapeStart < len) {
- size_t noEscapeEnd = srcStr.find('\\', noEscapeStart);
-
- if (noEscapeEnd == TStringBuf::npos) {
- dst.append(src + noEscapeStart, len - noEscapeStart);
- break;
- }
-
- dst.append(src + noEscapeStart, noEscapeEnd - noEscapeStart);
-
- if (noEscapeEnd + 1 >= len) {
- throw yexception() << "expected (t|n|r|0|\\|=|\"|) after \\. Got end of line.";
- }
-
- switch (src[noEscapeEnd + 1]) {
- case 't':
- dst.append('\t');
- break;
- case 'n':
- dst.append('\n');
- break;
- case 'r':
- dst.append('\r');
- break;
- case '0':
- dst.append('\0');
- break;
- case '\\':
- dst.append('\\');
- break;
- case '=':
- dst.append('=');
- break;
- case '"':
- dst.append('"');
- break;
- default:
- throw yexception() << "unexpected symbol '" << src[noEscapeEnd + 1] << "' after \\";
- }
-
- noEscapeStart = noEscapeEnd + 2;
- }
-
- return dst;
- }
-
- }
-
- TString& Escape(const TStringBuf& src, TString& dst) {
- return EscapeImpl(src.data(), src.size(), dst);
- }
-
- TString& Unescape(const TStringBuf& src, TString& dst) {
- return UnescapeImpl(src.data(), src.size(), dst);
- }
-
-}
diff --git a/library/cpp/string_utils/tskv_format/escape.h b/library/cpp/string_utils/tskv_format/escape.h
deleted file mode 100644
index 2e3dd02c983..00000000000
--- a/library/cpp/string_utils/tskv_format/escape.h
+++ /dev/null
@@ -1,10 +0,0 @@
-#pragma once
-
-#include <util/generic/strbuf.h>
-#include <util/generic/string.h>
-
-namespace NTskvFormat {
- TString& Escape(const TStringBuf& src, TString& dst);
- TString& Unescape(const TStringBuf& src, TString& dst);
-
-}
diff --git a/library/cpp/string_utils/tskv_format/tskv_map.cpp b/library/cpp/string_utils/tskv_format/tskv_map.cpp
deleted file mode 100644
index 99e5f19731b..00000000000
--- a/library/cpp/string_utils/tskv_format/tskv_map.cpp
+++ /dev/null
@@ -1,60 +0,0 @@
-#include "tskv_map.h"
-
-namespace {
- void Split(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, bool& keyHasEscapes) {
- size_t delimiter = 0;
- keyHasEscapes = false;
- for (delimiter = 0; delimiter < kv.size() && kv[delimiter] != '='; ++delimiter) {
- if (kv[delimiter] == '\\') {
- ++delimiter;
- keyHasEscapes = true;
- }
- }
-
- if (delimiter < kv.size()) {
- key = kv.Head(delimiter);
- value = kv.Tail(delimiter + 1);
- } else {
- throw yexception() << "Incorrect tskv format";
- }
- }
-
- TStringBuf DeserializeTokenToBuffer(const TStringBuf& token, TString& buffer) {
- size_t tokenStart = buffer.size();
- NTskvFormat::Unescape(token, buffer);
- return TStringBuf(buffer).Tail(tokenStart);
- }
-
- void DeserializeTokenToString(const TStringBuf& token, TString& result, bool unescape) {
- if (unescape) {
- result.clear();
- NTskvFormat::Unescape(token, result);
- } else {
- result = token;
- }
-
- }
-}
-
-void NTskvFormat::NDetail::DeserializeKvToStringBufs(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, TString& buffer, bool unescape) {
- bool keyHasEscapes = false;
- Split(kv, key, value, keyHasEscapes);
- if (unescape) {
- if (keyHasEscapes) {
- key = DeserializeTokenToBuffer(key, buffer);
- }
- if (value.Contains('\\')) {
- value = DeserializeTokenToBuffer(value, buffer);
- }
- }
-}
-
-void NTskvFormat::NDetail::DeserializeKvToStrings(const TStringBuf& kv, TString& key, TString& value, bool unescape) {
- TStringBuf keyBuf, valueBuf;
- bool keyHasEscapes = false;
- Split(kv, keyBuf, valueBuf, keyHasEscapes);
-
- Y_UNUSED(keyHasEscapes);
- DeserializeTokenToString(keyBuf, key, unescape);
- DeserializeTokenToString(valueBuf, value, unescape);
-}
diff --git a/library/cpp/string_utils/tskv_format/tskv_map.h b/library/cpp/string_utils/tskv_format/tskv_map.h
deleted file mode 100644
index 4f4978fcf50..00000000000
--- a/library/cpp/string_utils/tskv_format/tskv_map.h
+++ /dev/null
@@ -1,62 +0,0 @@
-#pragma once
-
-#include "escape.h"
-#include <util/string/cast.h>
-#include <util/string/split.h>
-
-namespace NTskvFormat {
- namespace NDetail {
- void DeserializeKvToStringBufs(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, TString& buffer, bool unescape);
- void DeserializeKvToStrings(const TStringBuf& kv, TString& key, TString& value, bool unescape);
- }
-
- template <typename T>
- TString& SerializeMap(const T& data, TString& result) {
- result.clear();
- for (const auto& kv : data) {
- if (result.size() > 0) {
- result.push_back('\t');
- }
- Escape(ToString(kv.first), result);
- result.push_back('=');
- Escape(ToString(kv.second), result);
- }
- return result;
- }
-
- /**
- * Deserializing to TStringBuf is faster, just remember that `data'
- * must not be invalidated while `result' is still in use.
- */
- template <typename T>
- void DeserializeMap(const TStringBuf& data, T& result, TString& buffer, bool unescape = true) {
- result.clear();
- buffer.clear();
- buffer.reserve(data.size());
- TStringBuf key, value;
-
- StringSplitter(data.begin(), data.end()).Split('\t').Consume([&](const TStringBuf kv){
- NDetail::DeserializeKvToStringBufs(kv, key, value, buffer, unescape);
- result[key] = value;
- });
-
- Y_ASSERT(buffer.size() <= data.size());
- }
-
- template <typename T>
- void DeserializeMap(const TStringBuf& data, T& result, bool unescape = true) {
- if constexpr(std::is_same<typename T::key_type, TStringBuf>::value ||
- std::is_same<typename T::mapped_type, TStringBuf>::value)
- {
- DeserializeMap(data, result, result.DeserializeBuffer, unescape); // we can't unescape values w/o buffer
- return;
- }
- result.clear();
- TString key, value;
-
- StringSplitter(data.begin(), data.end()).Split('\t').Consume([&](const TStringBuf kv){
- NDetail::DeserializeKvToStrings(kv, key, value, unescape);
- result[key] = value;
- });
- }
-}
diff --git a/library/cpp/string_utils/tskv_format/ya.make b/library/cpp/string_utils/tskv_format/ya.make
deleted file mode 100644
index 1283d748b38..00000000000
--- a/library/cpp/string_utils/tskv_format/ya.make
+++ /dev/null
@@ -1,9 +0,0 @@
-LIBRARY()
-
-SRCS(
- builder.cpp
- escape.cpp
- tskv_map.cpp
-)
-
-END()