diff options
author | say <say@yandex-team.com> | 2023-02-14 17:24:43 +0300 |
---|---|---|
committer | say <say@yandex-team.com> | 2023-02-14 17:24:43 +0300 |
commit | e0094c4ad6964e11564777bc0d859c68d8aa9de2 (patch) | |
tree | 5d2ad1a4df88da1f74385888891a2a5f9fbbc3ef /library/cpp/pybind/typedesc.cpp | |
parent | 65a08c9fdece8dba50da8beb4d7c81447211dd45 (diff) | |
download | ydb-e0094c4ad6964e11564777bc0d859c68d8aa9de2.tar.gz |
Migrate black linter on custom_lint pipeline
Diffstat (limited to 'library/cpp/pybind/typedesc.cpp')
-rw-r--r-- | library/cpp/pybind/typedesc.cpp | 79 |
1 files changed, 79 insertions, 0 deletions
diff --git a/library/cpp/pybind/typedesc.cpp b/library/cpp/pybind/typedesc.cpp new file mode 100644 index 0000000000..75f39fd126 --- /dev/null +++ b/library/cpp/pybind/typedesc.cpp @@ -0,0 +1,79 @@ +#include "typedesc.h" + +#include <util/generic/singleton.h> + +static void RegisterJSONBridgeImpl() { + PyRun_SimpleString("import json\n" + "class PyBindEncoder(json.JSONEncoder):\n" + " def default(self, obj):\n" + " if isinstance(obj, bytes):\n" + " try:\n" + " return obj.decode()\n" + " except UnicodeDecodeError:\n" + " return obj.hex()\n" + " dct = None\n" + " if hasattr(obj, '__getstate__'):\n" + " dct = obj.__getstate__()\n" + " elif hasattr(obj, '__dict__'):\n" + " dct = obj.__dict__\n" + " if dct is None:\n" + " return json.JSONEncoder.default(self, obj)\n" + " if hasattr(obj, '__class__'):\n" + " if hasattr(obj.__class__, '__name__'):\n" + " dct['__name__'] = obj.__class__.__name__\n" + " if hasattr(obj.__class__, '__module__'):\n" + " dct['__module__'] = obj.__class__.__module__\n" + " if hasattr(obj, 'GetPropertiesNames'):\n" + " dct['__properties__'] = obj.GetPropertiesNames()\n" + " return dct"); + + PyRun_SimpleString("def PyBindObjectHook(dct):\n" + " if '__name__' in dct:\n" + " name = dct['__name__']\n" + " module = dct['__module__']\n" + " del dct['__name__']\n" + " del dct['__module__']\n" + " cls = getattr(__import__(module), name)\n" + " if '__properties__' in dct:\n" + " props = dct['__properties__']\n" + " del dct['__properties__']\n" + " if len(props) == 0:\n" + " return dct\n" + " instance = cls(__properties__ = props)\n" + " else:\n" + " instance = cls()\n" + " if hasattr(instance, '__setstate__'):\n" + " instance.__setstate__(dct)\n" + " elif hasattr(instance, '__dict__'):\n" + " instance.__dict__ = dct\n" + " else:\n" + " return dct\n" + " return instance\n" + " return dct"); + + PyRun_SimpleString("def json_dump(*args, **kwargs):\n" + " kwargs['cls'] = PyBindEncoder\n" + " return json.dump(*args, **kwargs)\n" + "def json_dumps(*args, **kwargs):\n" + " kwargs['cls'] = PyBindEncoder\n" + " return json.dumps(*args, **kwargs)"); + + PyRun_SimpleString("def json_load(*args, **kwargs):\n" + " kwargs['object_hook'] = PyBindObjectHook\n" + " return json.load(*args, **kwargs)\n" + "def json_loads(*args, **kwargs):\n" + " kwargs['object_hook'] = PyBindObjectHook\n" + " return json.loads(*args, **kwargs)"); +} + +namespace { + struct TJSONBridge { + TJSONBridge() { + RegisterJSONBridgeImpl(); + } + }; +} + +void NPyBind::RegisterJSONBridge() { + Singleton<TJSONBridge>(); +} |