aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/json/yson/json2yson.cpp
diff options
context:
space:
mode:
authorelshiko <elshiko@yandex-team.ru>2022-02-10 16:49:20 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:20 +0300
commit455ab915435b70e433ed91eee2ca84f03122d6cb (patch)
tree4570335e510c5cb009cca313349e2a29b4c62310 /library/cpp/json/yson/json2yson.cpp
parent85ad20a00eb9c7d4dcae0debe5172d5f9bc6792f (diff)
downloadydb-455ab915435b70e433ed91eee2ca84f03122d6cb.tar.gz
Restoring authorship annotation for <elshiko@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/json/yson/json2yson.cpp')
-rw-r--r--library/cpp/json/yson/json2yson.cpp184
1 files changed, 92 insertions, 92 deletions
diff --git a/library/cpp/json/yson/json2yson.cpp b/library/cpp/json/yson/json2yson.cpp
index f72cb7a9ef..237fe1a60f 100644
--- a/library/cpp/json/yson/json2yson.cpp
+++ b/library/cpp/json/yson/json2yson.cpp
@@ -1,108 +1,108 @@
-#include "json2yson.h"
-
+#include "json2yson.h"
+
#include <library/cpp/yson/parser.h>
#include <library/cpp/yson/json/json_writer.h>
#include <library/cpp/yson/json/yson2json_adapter.h>
-
-namespace NJson2Yson {
- static void WriteJsonValue(const NJson::TJsonValue& jsonValue, NYT::TYson2JsonCallbacksAdapter* adapter) {
- switch (jsonValue.GetType()) {
- default:
- case NJson::JSON_NULL:
- adapter->OnNull();
- break;
- case NJson::JSON_BOOLEAN:
- adapter->OnBoolean(jsonValue.GetBoolean());
- break;
- case NJson::JSON_DOUBLE:
- adapter->OnDouble(jsonValue.GetDouble());
- break;
- case NJson::JSON_INTEGER:
- adapter->OnInteger(jsonValue.GetInteger());
- break;
- case NJson::JSON_UINTEGER:
- adapter->OnUInteger(jsonValue.GetUInteger());
- break;
- case NJson::JSON_STRING:
- adapter->OnString(jsonValue.GetString());
- break;
- case NJson::JSON_ARRAY: {
- adapter->OnOpenArray();
- const NJson::TJsonValue::TArray& arr = jsonValue.GetArray();
- for (const auto& it : arr)
- WriteJsonValue(it, adapter);
- adapter->OnCloseArray();
- break;
- }
- case NJson::JSON_MAP: {
- adapter->OnOpenMap();
+
+namespace NJson2Yson {
+ static void WriteJsonValue(const NJson::TJsonValue& jsonValue, NYT::TYson2JsonCallbacksAdapter* adapter) {
+ switch (jsonValue.GetType()) {
+ default:
+ case NJson::JSON_NULL:
+ adapter->OnNull();
+ break;
+ case NJson::JSON_BOOLEAN:
+ adapter->OnBoolean(jsonValue.GetBoolean());
+ break;
+ case NJson::JSON_DOUBLE:
+ adapter->OnDouble(jsonValue.GetDouble());
+ break;
+ case NJson::JSON_INTEGER:
+ adapter->OnInteger(jsonValue.GetInteger());
+ break;
+ case NJson::JSON_UINTEGER:
+ adapter->OnUInteger(jsonValue.GetUInteger());
+ break;
+ case NJson::JSON_STRING:
+ adapter->OnString(jsonValue.GetString());
+ break;
+ case NJson::JSON_ARRAY: {
+ adapter->OnOpenArray();
+ const NJson::TJsonValue::TArray& arr = jsonValue.GetArray();
+ for (const auto& it : arr)
+ WriteJsonValue(it, adapter);
+ adapter->OnCloseArray();
+ break;
+ }
+ case NJson::JSON_MAP: {
+ adapter->OnOpenMap();
const NJson::TJsonValue::TMapType& map = jsonValue.GetMap();
- for (const auto& it : map) {
- adapter->OnMapKey(it.first);
- WriteJsonValue(it.second, adapter);
- }
- adapter->OnCloseMap();
- break;
- }
- }
- }
-
+ for (const auto& it : map) {
+ adapter->OnMapKey(it.first);
+ WriteJsonValue(it.second, adapter);
+ }
+ adapter->OnCloseMap();
+ break;
+ }
+ }
+ }
+
void SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue, NYson::TYsonWriter* ysonWriter) {
NYT::TYson2JsonCallbacksAdapter adapter(ysonWriter);
WriteJsonValue(inputValue, &adapter);
}
- void SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue, IOutputStream* outputStream) {
+ void SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue, IOutputStream* outputStream) {
NYson::TYsonWriter ysonWriter(outputStream, NYson::EYsonFormat::Binary, ::NYson::EYsonType::Node, false);
SerializeJsonValueAsYson(inputValue, &ysonWriter);
- }
-
- void SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue, TString& result) {
- TStringOutput resultStream(result);
- SerializeJsonValueAsYson(inputValue, &resultStream);
- }
-
- TString SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue) {
- TString result;
- SerializeJsonValueAsYson(inputValue, result);
- return result;
- }
-
- bool DeserializeYsonAsJsonValue(IInputStream* inputStream, NJson::TJsonValue* outputValue, bool throwOnError) {
- NJson::TParserCallbacks parser(*outputValue);
- NJson2Yson::TJsonBuilder consumer(&parser);
+ }
+
+ void SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue, TString& result) {
+ TStringOutput resultStream(result);
+ SerializeJsonValueAsYson(inputValue, &resultStream);
+ }
+
+ TString SerializeJsonValueAsYson(const NJson::TJsonValue& inputValue) {
+ TString result;
+ SerializeJsonValueAsYson(inputValue, result);
+ return result;
+ }
+
+ bool DeserializeYsonAsJsonValue(IInputStream* inputStream, NJson::TJsonValue* outputValue, bool throwOnError) {
+ NJson::TParserCallbacks parser(*outputValue);
+ NJson2Yson::TJsonBuilder consumer(&parser);
NYson::TYsonParser ysonParser(&consumer, inputStream, ::NYson::EYsonType::Node);
- try {
- ysonParser.Parse();
- } catch (...) {
- if (throwOnError) {
- throw;
- }
- return false;
- }
- return true;
- }
-
- bool DeserializeYsonAsJsonValue(TStringBuf str, NJson::TJsonValue* outputValue, bool throwOnError) {
- TMemoryInput inputStream(str);
- return DeserializeYsonAsJsonValue(&inputStream, outputValue, throwOnError);
- }
-
- void ConvertYson2Json(IInputStream* inputStream, IOutputStream* outputStream) {
+ try {
+ ysonParser.Parse();
+ } catch (...) {
+ if (throwOnError) {
+ throw;
+ }
+ return false;
+ }
+ return true;
+ }
+
+ bool DeserializeYsonAsJsonValue(TStringBuf str, NJson::TJsonValue* outputValue, bool throwOnError) {
+ TMemoryInput inputStream(str);
+ return DeserializeYsonAsJsonValue(&inputStream, outputValue, throwOnError);
+ }
+
+ void ConvertYson2Json(IInputStream* inputStream, IOutputStream* outputStream) {
NYT::TJsonWriter writer(outputStream, ::NYson::EYsonType::Node, NYT::JF_TEXT, NYT::JAM_ON_DEMAND, NYT::SBF_BOOLEAN);
NYson::TYsonParser ysonParser(&writer, inputStream, ::NYson::EYsonType::Node);
- ysonParser.Parse();
- }
-
- void ConvertYson2Json(TStringBuf yson, IOutputStream* outputStream) {
- TMemoryInput inputStream(yson);
- ConvertYson2Json(&inputStream, outputStream);
- }
+ ysonParser.Parse();
+ }
- TString ConvertYson2Json(TStringBuf yson) {
- TString json;
- TStringOutput outputStream(json);
- ConvertYson2Json(yson, &outputStream);
- return json;
+ void ConvertYson2Json(TStringBuf yson, IOutputStream* outputStream) {
+ TMemoryInput inputStream(yson);
+ ConvertYson2Json(&inputStream, outputStream);
}
-}
+
+ TString ConvertYson2Json(TStringBuf yson) {
+ TString json;
+ TStringOutput outputStream(json);
+ ConvertYson2Json(yson, &outputStream);
+ return json;
+ }
+}