claujson.cpp


#include "claujson.h"

#include <future>

#include <set>
#include <execution>
#include <array>

#include "fmt/format.h"

#if __cpp_lib_string_view

#else

	claujson::StringView operator""sv(const char* str, size_t sz) {
		return claujson::StringView(str, sz);
	}

	bool operator==(const std::string& str, claujson::StringView sv) {
		return claujson::StringView(str.data(), str.size()) == sv;
	}

#endif

	namespace claujson {


		int64_t Arena::counter = 0;

		// todo? make Document class? like simdjson?
		_Value _Value::empty_value{ nullptr, false }; // valid is false..
		const uint64_t _Value::npos = -1; // 
#if __cpp_lib_string_view

#else
		const uint64_t StringView::npos = -1;
#endif

		Log::Info info;
		Log::Warning warn;



		const uint64_t StructuredPtr::npos = -1;
		_Value StructuredPtr::empty_value{ nullptr, false };

		Log log;

		StructuredPtr::StructuredPtr(_Value& x) {
			arr = x.as_array();
			if (arr) {
				type = 1;
				return;
			}
			obj = x.as_object();
			if (obj) {
				type = 2;
				return;
			}
			pj = x.as_partial_json();
			if (pj) {
				type = 3;
				return;
			}
		}


		StructuredPtr::StructuredPtr(const _Value& x) {
			arr = const_cast<Array*>(x.as_array());
			if (arr) {
				type = 1;
				return;
			}
			obj = const_cast<Object*>(x.as_object());
			if (obj) {
				type = 2;
				return;
			}
			pj = const_cast<PartialJson*>(x.as_partial_json());
			if (pj) {
				type = 3;
				return;
			}
		}

		uint64_t StructuredPtr::get_data_size() const {
			if (type == 1) {
				return arr->get_data_size();
			}
			if (type == 2) {
				return obj->get_data_size();
			}
			if (type == 3) {
				return pj->get_data_size();
			}
			return 0; // make npos!
		}
		uint64_t StructuredPtr::size() const {
			if (type == 1) {
				return arr->size();
			}
			if (type == 2) {
				return obj->size();
			}
			if (type == 3) {
				return pj->get_data_size();
			}
			return 0;
		}
		bool StructuredPtr::empty() const {
			if (type == 1) {
				return arr->empty();
			}
			if (type == 2) {
				return obj->empty();
			}
			return true;
		}
		_Value& StructuredPtr::get_value_list(uint64_t idx) {
			if (type == 1) {
				return arr->get_value_list(idx);
			}
			if (type == 2) {
				return obj->get_value_list(idx);
			}
			if (type == 3) {
				return pj->get_value_list(idx);
			}
			return empty_value;
		}
		_Value& StructuredPtr::get_key_list(uint64_t idx) {
			if (type == 2) {
				return obj->get_key_list(idx);
			}
			else if (type == 3) {
				return pj->get_key_list(idx);
			}
			return empty_value;
		}
		const _Value& StructuredPtr::get_value_list(uint64_t idx) const {
			if (type == 1) {
				return arr->get_value_list(idx);
			}
			if (type == 2) {
				return obj->get_value_list(idx);
			}
			if (type == 3) {
				return pj->get_value_list(idx);
			}
			return empty_value;
		}
		const _Value& StructuredPtr::get_key_list(uint64_t idx) const {
			if (type == 2) {
				return obj->get_key_list(idx);
			}
			else if (type == 3) {
				return pj->get_key_list(idx);
			}
			return empty_value;
		}
		bool StructuredPtr::insert(uint64_t idx, Value val) { // from Array
			if (type == 1) {
				return arr->insert(idx, std::move(val));
			}
			return false;
		}

		const _Value& StructuredPtr::get_const_key_list(uint64_t idx) {
			if (type == 2) {
				return obj->get_const_key_list(idx);
			}
			return empty_value;
		}

		const _Value& StructuredPtr::get_const_key_list(uint64_t idx) const {
			if (type == 2) {
				return obj->get_const_key_list(idx);
			}
			return empty_value;
		}

		bool StructuredPtr::change_key(const _Value& key, Value&& next_key) {
			if (type == 2) {
				return obj->change_key(key, std::move(next_key));
			}
			return false;
		}
		bool StructuredPtr::change_key(uint64_t idx, Value&& next_key) {
			if (type == 2) {
				return obj->change_key(idx, std::move(next_key));
			}
			return false;
		}
		
		bool StructuredPtr::has_pool() const {
			if (type == 1) {
				return arr->has_pool();
			}
			if (type == 2) {
				return obj->has_pool();
			}
			return false;

		}


		bool StructuredPtr::chk_key_dup(uint64_t* idx) const {
			if (type == 2) {
				return obj->chk_key_dup(idx);
			}
			return false;
		}
		
		uint64_t StructuredPtr::find_by_key(const _Value & key) const{ // find without key`s converting ( \uxxxx )
			if (type == 2) {
				return obj->find(key);
			}
			return npos;
		}

		_Value& StructuredPtr::operator[](const _Value& key) { // if not exist key, then _Value <- is not valid.
			if (type == 2) {
				return obj->operator[](key);
			}
			return empty_value;
		}
		const _Value& StructuredPtr::operator[](const _Value& key) const {// if not exist key, then _Value <- is not valid.
			if (type == 2) {
				return obj->operator[](key);
			}
			return empty_value;
		}

		bool StructuredPtr::add_array_element(Value v) {
			if (type == 1) {
				return arr->add_element(std::move(v));
			}
			if (type == 2) {
				return false;
			}
			if (type == 3) {
				return pj->add_array_element(std::move(v));
			}
			return false;
		}
		bool StructuredPtr::add_object_element(Value key, Value v) {
			if (type == 1) {
				return false;
			}
			if (type == 2) {
				return obj->add_element(std::move(key), std::move(v));
			}
			if (type == 3) {
				return pj->add_object_element(std::move(key), std::move(v));
			}
			return false;
		}

		uint64_t StructuredPtr::find_by_value(const _Value& value, uint64_t start) const { // find without key`s converting ( \uxxxx )
			if (type == 1) {
				return arr->find(value, start);
			}
			return npos;
		}
		_Value& StructuredPtr::operator[](uint64_t idx) {
			if (type == 1) {
				return arr->operator[](idx);
			}
			if (type == 2) {
				return obj->operator[](idx);
			}
			return empty_value;
		}

		const _Value& StructuredPtr::operator[](uint64_t idx) const {
			if (type == 1) {
				return arr->operator[](idx);
			}
			if (type == 2) {
				return obj->operator[](idx);
			}
			return empty_value;
		}

		void StructuredPtr::erase(uint64_t idx, bool real) {
			if (type == 1) {
				return arr->erase(idx, real);
			}
			if (type == 2) {
				return obj->erase(idx, real);
			}
			if (type == 3) {
				return;
			}
			return;
		}
		void StructuredPtr::erase(const _Value& key, bool real) {
			if (type == 2) {
				return obj->erase(key, real);
			}
			return;
		}

		void StructuredPtr::Delete() {
			if (type == 1) {
				delete arr;
				arr = nullptr;
			}
			else if (type == 2) {
				delete obj;
				obj = nullptr;
			}
			else if (type == 3) {
				delete pj;
				pj = nullptr;
			}
			type = 0;
		}
		void StructuredPtr::clear() {
			if (type == 1) {
				return arr->clear();
			}
			if (type == 2) {
				return obj->clear();
			}
			if (type == 3) {
				return pj->clear();
			}
			return;
		}

		void StructuredPtr::clear(uint64_t idx) {
			if (type == 1) {
				return arr->clear(idx);
			}
			if (type == 2) {
				return obj->clear(idx);
			}
			return;
		}

		bool StructuredPtr::assign_value(uint64_t idx, Value val) {
			if (type == 1) {
				return arr->assign_element(idx, std::move(val));
			}
			if (type == 2) {
				return obj->assign_value_element(idx, std::move(val));
			}
			return false;
		}


		void StructuredPtr::MergeWith(StructuredPtr j, int start_offset) {
			if (type == 1) {
				if (j.is_array()) {
					return arr->MergeWith(j.arr, start_offset);
				}
				if (j.is_object()) {
					return arr->MergeWith(j.obj, start_offset);
				}
				if (j.is_partial_json()) {
					return arr->MergeWith(j.pj, start_offset);
				}
			}
			if (type == 2) {
				if (j.is_array()) {
					return obj->MergeWith(j.arr, start_offset);
				}
				if (j.is_object()) {
					return obj->MergeWith(j.obj, start_offset);
				}
				if (j.is_partial_json()) {
					return obj->MergeWith(j.pj, start_offset);
				}
			}
			if (type == 3) {
				if (j.is_array()) {
					return pj->MergeWith(j.arr, start_offset);
				}
				if (j.is_object()) {
					return pj->MergeWith(j.obj, start_offset);
				}
				if (j.is_partial_json()) {
					return pj->MergeWith(j.pj, start_offset);
				}
			}
		}

		void StructuredPtr::reserve_data_list(uint64_t sz) {
			if (type == 1) {
				return arr->reserve_data_list(sz);
			}
			if (type == 2) {
				return obj->reserve_data_list(sz);
			}
			return;
		}

		// need rename param....!

		void StructuredPtr::add_item_type(int64_t key_buf_idx, int64_t key_next_buf_idx, int64_t val_buf_idx, int64_t val_next_buf_idx,
			char* buf, uint64_t key_token_idx, uint64_t val_token_idx, Arena* pool) {
			if (type == 1) {
				return arr->add_item_type(key_buf_idx, key_next_buf_idx, val_buf_idx, val_next_buf_idx, buf, key_token_idx, val_token_idx);
			}
			if (type == 2) {
				return obj->add_item_type(key_buf_idx, key_next_buf_idx, val_buf_idx, val_next_buf_idx, buf, key_token_idx, val_token_idx, pool);
			}
			if (type == 3) {
				return pj->add_item_type(key_buf_idx, key_next_buf_idx, val_buf_idx, val_next_buf_idx, buf, key_token_idx, val_token_idx);
			}
			//std::cout << "chk 1";
			return;
		}

		void StructuredPtr::add_item_type(int64_t val_buf_idx, int64_t val_next_buf_idx,
			char* buf, uint64_t val_token_idx, Arena* pool) {
			if (type == 1) {
				return arr->add_item_type(val_buf_idx, val_next_buf_idx, buf, val_token_idx, pool);
			}
			if (type == 2) {
				return obj->add_item_type(val_buf_idx, val_next_buf_idx, buf, val_token_idx);
			}
			if (type == 3) {
				return pj->add_item_type(val_buf_idx, val_next_buf_idx, buf, val_token_idx);
			}
			//std::cout << "chk 2";
			return;
		}

		void StructuredPtr::add_user_type(int64_t key_buf_idx, int64_t key_next_buf_idx, char* buf,
			_ValueType type, uint64_t key_token_idx, Arena* pool) {
			if (this->type == 1) {
				return arr->add_user_type(key_buf_idx, key_next_buf_idx, buf, type, key_token_idx, pool);
			}
			if (this->type == 2) {
				return obj->add_user_type(key_buf_idx, key_next_buf_idx, buf, type, key_token_idx, pool);
			}
			if (this->type == 3) {
				return pj->add_user_type(key_buf_idx, key_next_buf_idx, buf, type, key_token_idx, pool);
			}
			//std::cout << "chk 3";
			return;
		}

		void StructuredPtr::add_user_type(_ValueType type, Arena* pool) {
			if (this->type == 1) {
				return arr->add_user_type(type, pool);
			}
			if (this->type == 2) {
				return obj->add_user_type(type, pool);
			}
			if (this->type == 3) {
				return pj->add_user_type(type, pool);
			}
			//std::cout << "chk 4";
			return;
		}

		bool StructuredPtr::is_virtual() const {
			if (type == 1) {
				return arr->is_virtual();
			}
			if (type == 2) {
				return obj->is_virtual();
			}
			return false;
		}
		void StructuredPtr::set_parent(StructuredPtr p) {
			if (type == 1) {
				arr->set_parent(p);
			}
			else if (type == 2) {
				obj->set_parent(p);
			}
		}

		StructuredPtr StructuredPtr::get_parent() {
			StructuredPtr p;

			if (type == 1) {
				p = arr->get_parent();
			}
			if (type == 2) {
				p = obj->get_parent();
			}

			return p;
		}

		std::ostream& operator<<(std::ostream& stream, const claujson::_Value& data) {

			if (false == data.is_valid()) {
				stream << "--not valid\n";
				return stream;
			}

			switch (data._type) {
			case claujson::_ValueType::INT:
				stream << data._int_val;
				break;
			case claujson::_ValueType::UINT:
				stream << data._uint_val;
				break;
			case claujson::_ValueType::FLOAT:
				stream << data._float_val;
				break;
			case claujson::_ValueType::STRING:
			case claujson::_ValueType::SHORT_STRING:
				stream << "\"" << (data._str_val->data()) << "\"";
				break;
			case claujson::_ValueType::BOOL:
				stream << data._bool_val;
				break;
			case claujson::_ValueType::NULL_:
				stream << "null";
				break;
			case claujson::_ValueType::ARRAY:
			{
				//	stream << "array_or_object";
				auto* x = data.as_array();
				if (x) {
					stream << "[ ";
					uint64_t sz = x->get_data_size();
					for (uint64_t i = 0; i < sz; ++i) {
						stream << x->get_value_list(i) << " ";
						if (i < sz - 1) {
							stream << " , ";
						}
					}
					stream << "]\n";
				}
				break;
			}
			case claujson::_ValueType::OBJECT:
			{
				auto* x = data.as_object();
				if (x) {
					stream << "{ ";
					uint64_t sz = x->get_data_size();
					for (uint64_t i = 0; i < sz; ++i) {
						stream << x->get_key_list(i) << " : ";
						stream << x->get_value_list(i) << " ";
						if (i < sz - 1) {
							stream << " , ";
						}
					}
					stream << "}\n";
				}
			}
			break;
			}

			return stream;
		}
	}

namespace claujson {


	claujson_inline StringView sub_route(StringView route, uint64_t found_idx, uint64_t new_idx) {
		if (found_idx + 1 == new_idx) {
			return ""sv;
		}
		return route.substr(found_idx + 1, new_idx - found_idx - 1);
	}
#if __cpp_lib_char8_t
	claujson_inline std::u8string_view sub_route(std::u8string_view route, uint64_t found_idx, uint64_t new_idx) {
		if (found_idx + 1 == new_idx) {
			return u8""sv;
		}
		return route.substr(found_idx + 1, new_idx - found_idx - 1);
	}
#endif
	claujson_inline bool to_uint_for_json_pointer(StringView x, uint64_t* val, _simdjson::internal::dom_parser_implementation* simdjson_imple) {
		const char* buf = x.data();
		uint64_t idx = 0;
		uint64_t idx2 = x.size();

		switch (x[0]) {
		case '0':
		case '1': case '2': case '3': case '4':
		case '5': case '6': case '7': case '8': case '9':
		{
			std::unique_ptr<uint8_t[]> copy;

			uint64_t temp[2] = { 0 };

			const uint8_t* value = reinterpret_cast<const uint8_t*>(buf + idx);

			{ // chk code...
				copy = std::unique_ptr<uint8_t[]>(new (std::nothrow) uint8_t[idx2 - idx + _simdjson::_SIMDJSON_PADDING]); // x.size() + padding
				if (copy.get() == nullptr) { return false; } // cf) new Json?
				std::memcpy(copy.get(), &buf[idx], idx2 - idx);
				std::memset(copy.get() + idx2 - idx, ' ', _simdjson::_SIMDJSON_PADDING);
				value = copy.get();
			}
			auto x = simdjson_imple->parse_number(value, temp);

			if (x != _simdjson::SUCCESS) {
				log << warn << "parse number error. " << x << "\n";
				return false;
			}

			long long int_val = 0;
			unsigned long long uint_val = 0;
			//double float_val = 0;

			switch (static_cast<_simdjson::internal::tape_type>(temp[0] >> 56)) {
			case _simdjson::internal::tape_type::INT64:
				memcpy(&int_val, &temp[1], sizeof(uint64_t));
				*val = int_val;

				return true;
				break;
			case _simdjson::internal::tape_type::UINT64:
				memcpy(&uint_val, &temp[1], sizeof(uint64_t));
				*val = uint_val;

				return true;
				break;
			case _simdjson::internal::tape_type::DOUBLE:
				// error.
				return false;
				break;
			}
		}
		break;
		}

		return false;
	}
#if __cpp_lib_char8_t
	bool to_uint_for_json_pointer(std::u8string_view x, uint64_t* val, _simdjson::internal::dom_parser_implementation* simdjson_imple) {
		auto* buf = x.data();
		uint64_t idx = 0;
		uint64_t idx2 = x.size();

		switch (x[0]) {
		case '0':
		case '1': case '2': case '3': case '4':
		case '5': case '6': case '7': case '8': case '9':
		{
			std::unique_ptr<uint8_t[]> copy;

			uint64_t temp[2] = { 0 };

			const uint8_t* value = reinterpret_cast<const uint8_t*>(buf + idx);

			{ // chk code...
				copy = std::unique_ptr<uint8_t[]>(new (std::nothrow) uint8_t[idx2 - idx + _simdjson::_SIMDJSON_PADDING]); // x.size() + padding
				if (copy.get() == nullptr) { return false; } // cf) new Json?
				std::memcpy(copy.get(), &buf[idx], idx2 - idx);
				std::memset(copy.get() + idx2 - idx, ' ', _simdjson::_SIMDJSON_PADDING);
				value = copy.get();
			}

			if (auto x = simdjson_imple->parse_number(value, temp)
				; x != _simdjson::SUCCESS) {
				log << warn << "parse number error. " << x << "\n";
				return false;
			}

			long long int_val = 0;
			unsigned long long uint_val = 0;
			//double float_val = 0;

			switch (static_cast<_simdjson::internal::tape_type>(temp[0] >> 56)) {
			case _simdjson::internal::tape_type::INT64:
				memcpy(&int_val, &temp[1], sizeof(uint64_t));
				*val = int_val;

				return true;
				break;
			case _simdjson::internal::tape_type::UINT64:
				memcpy(&uint_val, &temp[1], sizeof(uint64_t));
				*val = uint_val;

				return true;
				break;
			case _simdjson::internal::tape_type::DOUBLE:
				// error.
				return false;
				break;
			}
		}
		break;
		}

		return false;
	}
#endif

	Value::~Value() noexcept {
		//claujson::clean(x);
	}

	Document::~Document() noexcept {
		//claujson::clean(x);
		if (pool) {
			delete pool;
		}
	}

	claujson_inline 
	bool ConvertString(Arena* pool, claujson::_Value& data, const char* text, uint64_t len) {
		uint8_t sbuf[1024 + 1 + _simdjson::_SIMDJSON_PADDING];
		std::unique_ptr<uint8_t[]> ubuf;
		uint8_t* string_buf = nullptr;

		if (len <= 1024) {
			string_buf = sbuf;
		}
		else {
			ubuf = std::make_unique<uint8_t[]>(len + _simdjson::_SIMDJSON_PADDING);
			string_buf = &ubuf[0];
		}
		auto* x = _simdjson::parse_string((const uint8_t*)text + 1, string_buf, false);
		if (x == nullptr) {
			return false; // ERROR("Error in Convert for string");
		}
		else {
			*x = '\0';
			auto string_length = uint32_t(x - string_buf);
			data.set_str_in_parse(pool, reinterpret_cast<char*>(string_buf), string_length);
		}
		return true;
	}

	claujson_inline bool ConvertNumber(claujson::_Value& data, const char* text, uint64_t len, bool isFirst) {

		std::unique_ptr<uint8_t[]> copy;

		uint64_t temp[2] = { 0 };

		const uint8_t* value = reinterpret_cast<const uint8_t*>(text);


		// todo : number -> fixed size? -> len <- limit... -> no new!
		if (isFirst) { // if this case may be root number -> chk.. visit_root_number. in tape_builder in simdjson.cpp
			copy = std::unique_ptr<uint8_t[]>(new (std::nothrow) uint8_t[len + _simdjson::_SIMDJSON_PADDING]);
			if (copy.get() == nullptr) { return false; } // ERROR("Error in Convert for new"); } // cf) new Json?
			std::memcpy(copy.get(), text, len);
			std::memset(copy.get() + len, ' ', _simdjson::_SIMDJSON_PADDING);
			value = copy.get();
		}

		auto x = _simdjson::parse_number(value, temp);

		if (x != _simdjson::SUCCESS) {
			log << warn << StringView((char*)value, 20) << "\n";
			log << warn << "parse number error. " << x << "\n";
			return false; //ERROR("parse number error. ");
			//throw "Error in Convert to parse number";
		}

		long long int_val = 0;
		unsigned long long uint_val = 0;
		double float_val = 0;

		switch (static_cast<_simdjson::internal::tape_type>(temp[0] >> 56)) {
		case _simdjson::internal::tape_type::INT64:
			memcpy(&int_val, &temp[1], sizeof(int64_t));

			data.set_int(int_val);
			break;
		case _simdjson::internal::tape_type::UINT64:
			memcpy(&uint_val, &temp[1], sizeof(uint64_t));

			data.set_uint(uint_val);
			break;
		case _simdjson::internal::tape_type::DOUBLE:
			memcpy(&float_val, &temp[1], sizeof(double));

			data.set_float(float_val);
			break;
		}

		return true;
	}

	claujson::_Value& Convert(Arena* pool, claujson::_Value& data, uint64_t buf_idx, uint64_t next_buf_idx, bool key,
		char* buf, uint64_t token_idx, bool& err) {
		
		data.clear(true);

		int ch = buf[buf_idx];
		//try {
		
		switch (ch) {
		case '"':
			if (ConvertString(pool, data, &buf[buf_idx], next_buf_idx - buf_idx)) {}
			else {
				goto ERR;
			}
			break;
		case '-':
		case '0':
		case '1': case '2': case '3': case '4':
		case '5': case '6': case '7': case '8': case '9':
		{
			if (ConvertNumber(data, &buf[buf_idx], next_buf_idx - buf_idx, token_idx == 0)) {}
			else {
				goto ERR;
			}

			break;
		}
		case 't':
		{
			if (!_simdjson::is_valid_true_atom(reinterpret_cast<uint8_t*>(&buf[buf_idx]), next_buf_idx - buf_idx)) {
				goto ERR; //ERROR("Error in Convert for true");
			}

			data.set_bool(true);
		}
		break;
		case 'f':
			if (!_simdjson::is_valid_false_atom(reinterpret_cast<uint8_t*>(&buf[buf_idx]), next_buf_idx - buf_idx)) {
				goto ERR; //ERROR("Error in Convert for false");
			}

			data.set_bool(false);
			break;
		case 'n':
			if (!_simdjson::is_valid_null_atom(reinterpret_cast<uint8_t*>(&buf[buf_idx]), next_buf_idx - buf_idx)) {
				goto ERR; //ERROR("Error in Convert for null");
			}

			data.set_null();
			break;

		default:
			log << warn << "convert error : " << (int)buf[buf_idx] << " " << buf[buf_idx] << "\n";
			goto ERR; //ERROR("convert Error");
			//throw "Error in Convert : not expected";
		}

		//

		return data;
		//}

		//catch (const char* str) {
	ERR:
		//log << warn << str << "\n";
		//ERROR(str);
		err = true;
		return data;
	}

	//bool Structured::is_valid() const {
	//	return valid;
	//}

	//Structured::Structured(bool valid) : valid(valid) { }
	/*
	Structured::Structured() { }


	Structured::~Structured() {

	}

	
	uint64_t Structured::find(const _Value& key) const {
		if (!is_object() || !key.is_str()) { // } || !is_valid()) {
			return npos;
		}

		uint64_t len = get_data_size();
		for (uint64_t i = 0; i < len; ++i) {
			if (get_key_list(i) == key) {
				return i;
			}
		}

		return -1;
	}

	_Value& Structured::operator[](uint64_t idx) {
		if (idx >= get_data_size()) {
			return data_null;
		}
		return get_value_list(idx);
	}

	const _Value& Structured::operator[](uint64_t idx) const {
		if (idx >= get_data_size()) {
			return data_null;
		}
		return get_value_list(idx);
	}

	_Value& Structured::operator[](const _Value& key) { // if not exist key, then nothing.
		uint64_t idx = npos;
		if ((idx = find(key)) == npos) {
			return data_null;
		}

		return get_value_list(idx);
	}
	const _Value& Structured::operator[](const _Value& key) const { // if not exist key, then nothing.
		uint64_t idx = npos;
		if ((idx = find(key)) == npos) {
			return data_null;
		}

		return get_value_list(idx);
	}

	PtrWeak<Structured> Structured::get_parent() const {
		return parent;
	}

	bool Structured::change_key(const _Value& key, Value new_key) { // chk test...
		if (this->is_object() && key.is_str() && new_key.Get().is_str()) {
			auto idx = find(key);
			if (idx == npos) {
				return false;
			}

			get_key_list(idx) = std::move(new_key.Get());

			return true;
		}
		return false;
	}

	bool Structured::change_key(uint64_t idx, Value new_key) {
		if (this->is_object() && new_key.Get().is_str()) {
			if (idx == npos) {
				return false;
			}

			get_key_list(idx) = std::move(new_key.Get());

			return true;
		}
		return false;
	}

	_Value& Structured::get_value() {
		return data_null;
	}

	bool Structured::is_partial_json() const { return false; }

	bool Structured::is_user_type() const {
		return is_object() || is_array() || is_partial_json();
	}

	void Structured::set_parent(PtrWeak<Structured> j) {
		parent = j;
	}

	*/

	//Object::Object(bool valid) : Structured(valid) { }
		
	// class PartialJson, only used in class LoadData2.
		// todo - rename? PartialNode ?

	class StrStream {
	private:
		//std::string m_buffer;
		fmt::memory_buffer m_buffer;
	public:

		const char* buf() const {
			return m_buffer.data();
		}
		uint64_t buf_size() const {
			return m_buffer.size();
		}

		StrStream& add_char(char x) {
			m_buffer.push_back(x);
			return *this;
		}

		StrStream& add_float(double x) {
			fmt::format_to(std::back_inserter(m_buffer), "{:f}", x);
			//m_buffer.Double(x); // fmt::format_to(std::back_inserter(out), "{:f}", x);
			return *this;
		}

		StrStream& add_int(int64_t x) {
			fmt::format_to(std::back_inserter(m_buffer), "{}", x);
			//m_buffer.Int64(x); // fmt::format_to(std::back_inserter(out), "{}", x);
			return *this;
		}

		StrStream& add_uint(uint64_t x) {
			fmt::format_to(std::back_inserter(m_buffer), "{}", x);
			//m_buffer.Uint64(x); // fmt::format_to(std::back_inserter(out), "{}", x);
			return *this;
		}

		StrStream& add_2(const char* str) {
			while (str[0] != '\0') {
				add_char(str[0]);
				++str;
			}
			return *this;
		}
	};

	class LoadData2 {
	private:
		ThreadPool* pool;
	public:
		LoadData2(ThreadPool* pool) : pool(pool) {
			//
		}
	public:
		friend class LoadData;

		 uint64_t Size(Array* root) {
			if (root == nullptr) { return 0; }
			return _Size(root) + 1;
		 }
		 uint64_t Size(Object* root) {
			 if (root == nullptr) { return 0; }
			 return _Size(root) + 1;
		 }


		 uint64_t _Size(Array* root) {
			if (root == nullptr) {
				return 0;
			}
			

			uint64_t len = root->get_data_size();
			uint64_t x = 0;

			for (uint64_t i = 0; i < len; ++i) {
				{
					auto* ptr = root->get_value_list(i).as_array();
					if (ptr) {
						x += Size(ptr);
					}
				}
				{
					auto* ptr = root->get_value_list(i).as_object();
					if (ptr) {
						x += Size(ptr);
					}
				}
			}

			return x;

		}
		 uint64_t _Size(Object* root) {
			 if (root == nullptr) {
				 return 0;
			 }

			 uint64_t len = root->get_data_size();
			 uint64_t x = 0;

			 for (uint64_t i = 0; i < len; ++i) {
				 {
					 auto* ptr = root->get_value_list(i).as_array();
					 if (ptr) {
						 x += Size(ptr);
					 }
				 }
				 {
					 auto* ptr = root->get_value_list(i).as_object();
					 if (ptr) {
						 x += Size(ptr);
					 }
				 }
			 }

			 return x;

		 }

		 uint64_t Size2(const _Value& root) {
			if (!root.as_array() && !root.as_object()) {
				return 0;
			}

			// root is usertype. (is not primitive.)
			uint64_t len = 0;
			if (root.is_array()) {
				len = root.as_array()->get_data_size();
			}
			else if (root.is_object()) {
				len = root.as_object()->get_data_size();
			}
			uint64_t x = len;

			if (root.is_array() && len > 0) {
				x = x; // VALUE VALUE VALUE
			}
			else if (root.is_object() && len > 0) {
				x = x * 2; // KEY VALUE KEY VALUE
			}

			x += 2; // (ARRAY or OBJECT), END
			
			if (root.is_array()) {
				for (uint64_t i = 0; i < len; ++i) {
					if (root.as_array()->get_value_list(i).as_array()) {
						x -= 1;
						x += Size2(root.as_array()->get_value_list(i));
					}
					else if (root.as_array()->get_value_list(i).as_object()) {
						x -= 1;
						x += Size2(root.as_array()->get_value_list(i));
					}
				}
			}
			else if (root.is_object()) {
				for (uint64_t i = 0; i < len; ++i) {
					if (root.as_object()->get_value_list(i).as_array()) {
						x -= 1;
						x += Size2(root.as_object()->get_value_list(i));
					}
					else if (root.as_object()->get_value_list(i).as_object()) {
						x -= 1;
						x += Size2(root.as_object()->get_value_list(i));
					}
				}
			}

			return x;
		}

		// find n node.. , need rename..
		 void Find2(const _Value& root, const uint64_t n, uint64_t& idx, bool chk_hint, uint64_t& _len, std_vector<uint64_t>& offset,
			 std_vector<uint64_t>& offset2, std_vector<StructuredPtr>& out, std_vector<int>& hint) {
			if (idx >= n) {
				return;
			}

			offset[idx]--; // initial offset must >= 1

			if (offset[idx] == 0) {

				if (!out[idx]) {
					if (root.is_array()) {
						out[idx] = StructuredPtr(root.as_array());
					}
					else  if (root.is_object()) {
						out[idx] = StructuredPtr(root.as_object());
					}

					if (chk_hint) {
						hint[idx] = 1;
					}

					++idx;
					if (idx >= n) {
						return;
					}

					uint64_t sz = 0;
					if (root.is_array()) {
						sz = Size(out[idx - 1].arr);
					}
					else  if (root.is_object()) {
						sz = Size(out[idx - 1].obj);
					}

					if (_len < offset2[idx - 1] + sz - 1) {
						return;
					}

					_len = _len - (offset2[idx - 1] + sz - 1); // chk...

					if (_len <= 0) {
						return;
					}

					for (uint64_t k = idx; k < n; ++k) {
						offset[k] = _len / (n - idx + 1);
					}
					offset[n - 1] = _len - _len / (n - idx + 1) * (n - idx);

					for (uint64_t k = idx; k < n; ++k) {
						offset2[k] = offset[k];
					}
				}

				return;
			}

			uint64_t len = 0;
			if (root.is_array()) {
				len = root.as_array()->get_data_size();
			}
			else  if (root.is_object()) {
				len = root.as_object()->get_data_size();
			}

			for (uint64_t i = 0; i < len; ++i) {
				if (root.is_array() && root.as_array()->get_value_list(i).is_structured()) {

					Find2(root.as_array()->get_value_list(i), n, idx, i < len - 1, _len, offset, offset2, out, hint);

					if (idx >= n) {
						return;
					}
				}
				else if (root.is_object() && root.as_object()->get_value_list(i).is_structured()) {

					Find2(root.as_object()->get_value_list(i), n, idx, i < len - 1, _len, offset, offset2, out, hint);

					if (idx >= n) {
						return;
					}
				}
			}
		}


		 void Divide(Arena* pool, StructuredPtr pos, StructuredPtr& result) { // after pos.. -> to result.
			if (!pos.is_array() && !pos.is_object()) {
				return;
			}

			StructuredPtr pos_ = pos;

			StructuredPtr parent(pos.get_parent());
			
			PartialJson* out = new (std::nothrow) PartialJson(pool); //

			if (out == nullptr) {
				log << warn << "new error";
				return;
			}

			while (parent && !parent.is_partial_json()) { // parent && parent->is_partial_json() == false) {
				long long idx = 0;
				uint64_t len = parent.get_data_size();
				for (uint64_t i = 0; i < len; ++i) {
					if (parent.get_value_list(i).is_structured() && parent.get_value_list(i).as_structured() == pos_) {
						idx = i;
						break;
					}
				}
				
				//int a = clock();
				if (parent.is_array()) {
					out->arr_vec = parent.arr->arr_vec.Divide(idx + 1);
				}
				else {
					out->obj_data = parent.obj->obj_data.Divide(idx + 1);
				}
				/*
				for (uint64_t i = idx + 1; i < len; ++i) {
					if (parent.get_value_list(i).is_structured()) {
						if (parent.is_array()) {
							out->add_array_element(std::move(parent.get_value_list(i)));
						}
						else {
							out->add_object_element(std::move(parent.get_key_list(i)), std::move(parent.get_value_list(i)));
						}
					}
					else {
						if (parent.get_key_list(i).is_str() == false) {
							out->add_array_element(std::move(parent.get_value_list(i)));
						}
						else { // out->is_object
							out->add_object_element(std::move(parent.get_key_list(i)), std::move(parent.get_value_list(i)));
						}
					}
				}*/

				//std::cout << "chk.. " << clock() - a << "ms\n";
				{
					_Value vrt;
					if (parent.is_object()) {
						vrt = Object::MakeVirtual(pool);
						
						if (vrt.as_object() == nullptr) {
							delete out;
							log << warn << "new error";
							return;
						}
					}
					else if (parent.is_array()) { // parent->is_array()
						vrt = Array::MakeVirtual(pool);
					
						if (vrt.as_array() == nullptr) {
							delete out;
							log << warn << "new error";
							return;
						}
					}
					else { // PartialJson
						// none
					}

					StructuredPtr temp = vrt;

					uint64_t len = out->get_data_size();

					if (len > 0 && out->get_value_list(0).is_virtual()) {
						if (temp.is_array()) {
							temp.add_array_element(std::move(out->get_value_list(0)));
						}
						else {
							temp.add_object_element(_Value(), std::move(out->get_value_list(0)));
						}
						--len;
					}

					for (uint64_t i = 0; i < len; ++i) {
						if (out->get_value_list(i).is_structured()) {

							if (temp.is_array()) {
								temp.add_array_element(std::move(out->get_value_list(i)));
							}
							else {
								if (out->get_value_list(i).is_virtual()) {
									temp.add_object_element(_Value(), std::move(out->get_value_list(i)));
								}
								else {
									temp.add_object_element(std::move(out->get_key_list(i)), std::move(out->get_value_list(i)));
								}
							}
						}
						else {
							if (temp.is_object()) {
								temp.add_object_element(std::move(out->get_key_list(i)),
									std::move(out->get_value_list(i)));
							}
							else {
								temp.add_array_element(std::move(out->get_value_list(i)));
							}
						}
					}

					out->clear();
					out->add_array_element(std::move(vrt));
				}

				//for (long long i = (long long)parent.get_data_size() - 1; i > idx; --i) {
				//	parent.erase(i);
				//}

				pos_ = parent;
				parent = parent.get_parent();
			}

			result = StructuredPtr(out);
		}

		 std_vector<claujson::StructuredPtr> Divide2(Arena* pool, uint64_t n, claujson::_Value& j, std_vector<claujson::StructuredPtr>& result, 
			 std_vector<int>& hint) {
			if (j.is_structured() == false) {
				return { };
			}

			if (n == 0) {
				return { };
			}
			auto a = std::chrono::steady_clock::now();
			uint64_t len = 0;
			
			if (j.is_array()) { len = Size(j.as_array()); }
			else if(j.is_object()) { len = Size(j.as_object()); }

			auto b= std::chrono::steady_clock::now();
			auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a); 
			log << info << "size is " << dur.count() << "ms\n";
			if (len / n == 0) {
				return { };
			}

			std_vector<uint64_t> offset(n - 1);

			for (uint64_t i = 0; i < offset.size(); ++i) {
				offset[i] = len / n;
			}
			offset.back() = len - len / n * (n - 1);

			hint = std_vector<int>(n - 1);

			std_vector<claujson::StructuredPtr> pos(n);

			a = std::chrono::steady_clock::now();
			{
				uint64_t idx = 0;
				auto offset2 = offset;

				Find2(j, n - 1, idx, false, len, offset, offset2, pos, hint);
			}
			b = std::chrono::steady_clock::now();
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
			log << info << "Find2 is " << dur.count() << "ms\n";

			for (uint64_t i = 0; i < n - 1; ++i) {
				if (!pos[i]) {
					return { };
				}
			}


			std_vector<StructuredPtr> temp_parent(n);
			{
				uint64_t i = 0;
				for (; i < n - 1; ++i) {

					if (i > 0 && temp_parent[i - 1] == nullptr) {
						for (uint64_t j = 0; j < i; ++j) {
							int op = 0;
							
							Merge2(temp_parent[j], result[j], &temp_parent[j + 1], op);

						}

						for (uint64_t j = 0; j < result.size(); ++j) {
							if (result[i]) {
								result[i].Delete();
							}
						}

						return { };
					}

					Divide(pool, pos[i], result[i]);

					temp_parent[i] = pos[i].get_parent();

				}

				if (i > 0 && temp_parent[i - 1] == nullptr) {
					for (uint64_t j = 0; j < i; ++j) {
						int op = 0;
						
						Merge2(temp_parent[j], result[j], &temp_parent[j + 1], op);
					}

					for (uint64_t j = 0; j < result.size(); ++j) {
						if (result[i]) {
							result[i].Delete();
						}
					}

					return { };
				}
			}


			return pos;
		}

		 int Merge(StructuredPtr next, StructuredPtr ut, StructuredPtr* ut_next)
		{

			// check!!
			while (ut.get_data_size() >= 1
				&& ut.get_value_list(0).is_structured() && (ut.get_value_list(0).is_virtual()))
			{
				ut = StructuredPtr(ut.get_value_list(0));
			}

			while (true) {

				class StructuredPtr _ut = ut;
				class StructuredPtr _next = next;

				//log << warn  << "chk\n";
				if (ut_next && _ut == *ut_next) { // chk_next_ut
					*ut_next = _next;

					log << info << "chked in merge...\n"; // special case!
				}

				if (_next.is_array() && _ut.is_object()) {
					ERROR("Error in Merge, next is array but child? is object");
				}
				if (_next.is_object() && _ut.is_array()) {
					ERROR("Error in Merge, next is object but child? is array");
				}

				int start_offset = 0;
				if (_ut.get_data_size() > 0 && _ut.get_value_list(0).is_structured() && _ut.get_value_list(0).is_virtual()) {
					++start_offset;
				}

				_next.MergeWith(_ut, start_offset);

				if (_ut.get_data_size() > 0 && _ut.get_value_list(0).is_structured() && _ut.get_value_list(0).is_virtual()) {
					//clean(_ut.get_value_list(0));
				}

				_ut.clear();

				ut = ut.get_parent();
				next = next.get_parent();


				if (next && ut) {
					//
				}
				else {
					// right_depth > left_depth
					if (!next && ut) {
						return -1;
					}
					else if (next && !ut) {
						return 1;
					}

					return 0;
				}
			}
		}

		 int Merge2(StructuredPtr next, StructuredPtr ut, StructuredPtr* ut_next, int& op)
		{

			if (!ut) {
				*ut_next = next;
				return 0;
			}

			// check!!
			while (ut.get_data_size() >= 1
				&& ut.get_value_list(0).is_structured() && (ut.get_value_list(0).is_virtual()))
			{
				ut = StructuredPtr(ut.get_value_list(0));
			}


			while (true) {
				//log << warn  << "chk\n";

				class StructuredPtr _ut = ut;
				class StructuredPtr _next = next;

				if (_next.is_array() && _ut.is_object()) {
					ERROR("Error in Merge, next is array but child? is object");
				}
				if (_next.is_object() && _ut.is_array()) {
					ERROR("Error in Merge, next is object but child? is array");
				}

				if (ut_next && _ut == (*ut_next)) {
					*ut_next = _next;
					log << info << "chked in merge2...\n";
				}

				int start_offset = 0;
				if (_ut.get_data_size() > 0 && _ut.get_value_list(0).is_structured() && _ut.get_value_list(0).is_virtual()) {
					++start_offset;
				}

				_next.MergeWith(_ut, start_offset);

				if (_ut.get_data_size() > 0 && _ut.get_value_list(0).is_structured() && _ut.get_value_list(0).is_virtual()) {
					//clean(_ut.get_value_list(0)); // chk?
				}

				_ut.clear();

				ut = ut.get_parent();
				next = next.get_parent();


				if (next && ut) {
					//
				}
				else {
					// right_depth > left_depth
					if (!next && ut) {
						return -1;
					}
					else if (next && !ut) {
						return 1;
					}

					return 0;
				}
			}
		}


		struct TokenTemp { // need to rename.
			// 
			int64_t buf_idx;  // buf_idx?
			int64_t next_buf_idx; // next_buf_idx?
			//Json
			uint64_t token_idx; // token_idx?
			//
			bool is_key = false;
		};

		 static bool __LoadData(char* buf, uint64_t buf_len,
			_simdjson::internal::dom_parser_implementation* imple,
			int64_t token_arr_start, uint64_t token_arr_len, StructuredPtr _global,
			int start_state, int last_state, // this line : now not used..
			class StructuredPtr* next, uint64_t* count_vec, 

			 int* err, uint64_t no, Arena* pool)
		 {
			try {
				if (token_arr_len <= 0) {
					return false;
				}
				
				// token_arr_len >= 1

				uint64_t left_no = token_arr_start;

				class StructuredPtr global = _global;

				uint64_t braceNum = 0;

				StructuredPtr nowUT = global; // use get_parent(), not std_vector<StructuredPtr>

				TokenTemp key;

				for (uint64_t i = 0; i < token_arr_len; ++i) {
					const char type = (buf[imple->structural_indexes[token_arr_start + i]]);

					switch (type) {
					case ',':
						continue;
					default:
					{
						bool is_key = token_arr_start + i + 1 < imple->n_structural_indexes && buf[imple->structural_indexes[token_arr_start + i + 1]] == ':';

						{
							TokenTemp data;

							data.buf_idx = imple->structural_indexes[token_arr_start + i];
							data.token_idx = token_arr_start + i;

							if (token_arr_start + i + 1 < imple->n_structural_indexes) {
								data.next_buf_idx = imple->structural_indexes[token_arr_start + i + 1];
							}
							else {
								data.next_buf_idx = buf_len;
							}


							if (is_key) {
								data.is_key = true;

								key = std::move(data);

								++i; // pass key
							}
							else {

								if (key.is_key) {
									nowUT.add_item_type(key.buf_idx, key.next_buf_idx, 
										data.buf_idx, data.next_buf_idx, buf,
										key.token_idx, data.token_idx, pool);
									key.is_key = false;
								}
								else {
									nowUT.add_item_type(data.buf_idx, data.next_buf_idx,
										buf, data.token_idx, pool);
								}
							}
						}
					}
					break;
					case '{':
					case '[':
						// Left 1
					{ // object start, array start

						if (key.is_key) {
							nowUT.add_user_type(key.buf_idx, key.next_buf_idx, buf,
								type == '{' ? _ValueType::OBJECT : _ValueType::ARRAY, key.token_idx, pool
							); // object vs array
							key.is_key = false;
						}
						else {
							nowUT.add_user_type(type == '{' ? _ValueType::OBJECT : _ValueType::ARRAY, pool
							);
						}
						
						class StructuredPtr pTemp = nowUT.get_value_list(nowUT.get_data_size() - 1);
						
						braceNum++;

						/// initial new nestedUT.
						nowUT = pTemp;
						nowUT.reserve_data_list(count_vec[left_no++]);
					}
					break;
					// Right 2
					case '}':
					case ']':
					{
						if (braceNum == 0) {

							_Value _ut; // is v_array or v_object.

							if (type == '}') {
								_ut = Object::MakeVirtual(pool);
							}
							else {
								_ut = Array::MakeVirtual(pool);
							}
							StructuredPtr ut = _ut;
							uint64_t len = nowUT.get_data_size();
							ut.reserve_data_list(len);

							if (len > 0 && nowUT.get_value_list(0).is_virtual()) {
								if (ut.is_array()) {
									ut.add_array_element(std::move(nowUT.get_value_list(0)));
								}
								else { // ut->is_object()
									ut.add_object_element(_Value(), std::move(nowUT.get_value_list(0)));
								}
								--len;
							}

							for (uint64_t i = 0; i < len; ++i) {
								if (nowUT.get_value_list(i).is_structured()) {
									if (ut.is_array()) {
										ut.add_array_element(std::move(nowUT.get_value_list(i)));
									}
									else { // ut->is_object()
										if (nowUT.get_value_list(i).is_virtual()) {
											ut.add_object_element(_Value(), std::move(nowUT.get_value_list(i)));
										}
										else {
											ut.add_object_element(std::move(nowUT.get_key_list(i)), std::move(nowUT.get_value_list(i)));
										}
									}
								}
								else {
									if (ut.is_object()) {
										ut.add_object_element(std::move(nowUT.get_key_list(i)),
											std::move(nowUT.get_value_list(i)));
									}
									else {
										ut.add_array_element(std::move(nowUT.get_value_list(i)));
									}
								}
							}

							nowUT.clear();
							nowUT.add_array_element(std::move(_ut)); // this nowUT is always PartialJson.
						}
						else {
							braceNum--;

							nowUT = nowUT.get_parent();
							
						}
					}
					break;
					
					}
				}

				if (next) {
					*next = nowUT;
				}

				return true;
			}
			catch (const char* _err) {
				*err = -10;

				log << warn << _err << "\n";

				return false;
			}
			catch (...) {
				*err = -11;
				log << warn << "unknown error....\n";
				return false;
			}
		}

		 int64_t FindDivisionPlace(char* buf, _simdjson::internal::dom_parser_implementation* imple, int64_t start, int64_t last)
		{
			for (int64_t a = start; a <= last; ++a) {
				auto& x = imple->structural_indexes[a]; //  token_arr[a];
				const _simdjson::internal::tape_type type = (_simdjson::internal::tape_type)buf[x];

				switch ((int)type) {
				case ',':
					return a ;
				default:
					break;
				}
			}
			return -1;
		}
		 // _global_memory_pool is not nullptr
		 bool _LoadData(_Value& global, Arena* _global_memory_pool, char* buf, uint64_t buf_len,

			_simdjson::internal::dom_parser_implementation* imple, int64_t& length,
			std_vector<int64_t>& start, uint64_t* count_vec,

			 uint64_t parse_num) // first, strVec.empty() must be true!!
		{	
			StructuredPtr _global = (new PartialJson(_global_memory_pool));
			std_vector<StructuredPtr> __global;
			std::vector<Arena*> memory_pool;

			try {
				 
				{
					uint64_t pivot_num = parse_num;
					
					{ 
					std::set<int64_t> _pivots;
					std_vector<int64_t> pivots;
					//const int64_t num = token_arr_len; //

					if (pivot_num > 0) {
						std_vector<int64_t> pivot;
						pivots.reserve(pivot_num + 1);
						pivot.reserve(pivot_num);

						pivot.push_back(start[0]);

						for (uint64_t i = 1; i < parse_num; ++i) {
							pivot.push_back(FindDivisionPlace(buf, imple, start[i], start[i + 1] - 1));
						}

						for (uint64_t i = 0; i < pivot.size(); ++i) {
							if (pivot[i] != -1) {
								_pivots.insert(pivot[i]);
							}
						}

						for (auto& x : _pivots) {
							pivots.push_back(x);
						}

						pivots.push_back(length);
					}
					else {
						pivots.push_back(start[0]);
						pivots.push_back(length);
					}

					std_vector<StructuredPtr> next(pivots.size() - 1);
					{
						memory_pool = std::vector<Arena*>(pivots.size() - 1);
						for (auto*& x : memory_pool) {
							x = new Arena();
						}

						__global = std_vector<StructuredPtr>(pivots.size() - 1);
						for (uint64_t i = 0; i < __global.size(); ++i) {
							__global[i] = (new PartialJson(memory_pool[i]));
						}

						std_vector<std::future<bool>> result(pivots.size() - 1);
						std_vector<int> err(pivots.size() - 1);
						
						

						{
							int64_t idx = pivots[1] - pivots[0];
							int64_t _token_arr_len = idx;


							result[0] = pool->enqueue(__LoadData, (buf), buf_len, (imple), start[0], _token_arr_len, (__global[0]), 0, 0,
								&next[0], count_vec,

								&err[0], 0, memory_pool[0]);
						}

						auto a = std::chrono::steady_clock::now();

						for (uint64_t i = 1; i < pivots.size() - 1; ++i) {
							int64_t _token_arr_len = pivots[i + 1] - pivots[i];

							result[i] = pool->enqueue(__LoadData, (buf), buf_len, (imple), pivots[i], _token_arr_len, (__global[i]), 0, 0,
								&next[i], count_vec,

								& err[i], i, memory_pool[i]);

						}


						// wait
						for (uint64_t i = 0; i < result.size(); ++i) {
							result[i].get();
						}

						auto b = std::chrono::steady_clock::now();
						auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
						log << info << "parse1 " << dur.count() << "ms\n";

						// check..
						for (uint64_t i = 0; i < err.size(); ++i) {
							switch (err[i]) {
							case 0:
								break;
							case -10:
							case -11:
								return false;
								break;
							case -1:
							case -4:
								log << warn << "Syntax Error\n"; return false;
								break;
							case -2:
								log << warn << "error final state is not last_state!\n"; return false;
								break;
							case -3:
								log << warn << "error x > buffer + buffer_len:\n"; return false;
								break;
							default:
								log << warn << "unknown parser error " << err[i] << "\n"; return false;
								break;
							}
						}

						// Merge

						{
							int i = 0;
							std_vector<int> chk(parse_num);
							auto x = next.begin();
							auto y = __global.begin();
							while (true) {
								if ((y)->get_data_size() == 0) {
									chk[i] = 1;
								}

								++x;
								++y;
								++i;

								if (x == next.end()) {
									break;
								}
							}

							uint64_t start = 0;
							uint64_t last = pivots.size() - 1 - 1;

							for (uint64_t i = 0; i < pivots.size() - 1; ++i) {
								if (chk[i] == 0) {
									start = i;
									break;
								}
							}

							for (uint64_t i = pivots.size() - 1; i > 0; --i) {
								if (chk[i - 1] == 0) {
									last = i - 1;
									break;
								}
							}

							if (__global[start].get_data_size() > 0 && __global[start].get_value_list(0).is_structured()
								&& (__global[start].get_value_list(0).is_virtual())) {
								log << warn << "not valid file1\n";
								throw 1;
							}
							if (next[last] && !(next[last].get_parent() == nullptr)) {
								log << warn << "not valid file2\n";
								throw 2;
							}


							int err = Merge(_global, __global[start], &next[start]);
							if (-1 == err || (pivots.size() == 0 && 1 == err)) {
								log << warn << "not valid file3\n";
								throw 3;
							}

							for (uint64_t i = start + 1; i <= last; ++i) {

								if (chk[i]) {
									continue;
								}

								// linearly merge and error check...
								uint64_t before = i - 1;
								for (uint64_t k = i; k > 0; --k) {
									if (chk[k - 1] == 0) {
										before = k - 1;
										break;
									}
								}

								int err = Merge(next[before], __global[i], &next[i]);

								if (-1 == err) {
									log << warn << "chk " << i << " " << __global.size() << "\n";
									log << warn << "not valid file4\n";
									throw 4;
								}
								else if (i == last && 1 == err) {
									log << warn << "not valid file5\n";
									throw 5;
								}
							}

							_global_memory_pool->link_from(memory_pool[start]);
							for (uint64_t i = start + 1; i <= last; ++i) {
								if (chk[i]) { delete memory_pool[start]; continue; }
								_global_memory_pool->link_from(memory_pool[i]);
							}
						}
						//catch (...) {
							//throw "in Merge, error";
						//	return false;
						//}
						//

						if (_global.get_data_size() > 1) { // bug fix..
							log << warn << "not valid file6\n";
							throw 6;
						}

						auto c = std::chrono::steady_clock::now();
						auto dur2 = std::chrono::duration_cast<std::chrono::milliseconds>(c - b);
						log << info << "parse2 " << dur2.count() << "ms\n";
					}
					}
					auto a = std::chrono::steady_clock::now();


					if (_global.get_value_list(0).is_structured()) {
						StructuredPtr x = _global.get_value_list(0);
						x.set_parent({});
					}

					global = std::move(_global.get_value_list(0));


					auto b = std::chrono::steady_clock::now();
					auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);

					log << info << "chk " << dur.count() << "ms\n";

					//	log << warn  << std::chrono::steady_clock::now() - a__ << "ms\n";
				}
				//	log << warn  << std::chrono::steady_clock::now() - a__ << "ms\n";

				for (uint64_t i = 0; i < __global.size(); ++i) {
					if (__global[i]) {
						__global[i].Delete();
					}
				}
				if (_global) {
					_global.Delete();
				}

				return true;
			}
			catch (int err) {

				log << warn << "merge error " << err << "\n";
				//ERROR("Merge Error"sv);
				for (uint64_t i = 0; i < __global.size(); ++i) {
					if (__global[i]) {
						__global[i].Delete();
					}
				}
				if (_global) {
					_global.Delete();
				}
				for (uint64_t i = 0; i < memory_pool.size(); ++i) {
					delete memory_pool[i];
				}
				return false;
			}
			catch (const char* err) {

				log << warn << err << "\n";
				//ERROR("Merge Error"sv);
				for (uint64_t i = 0; i < __global.size(); ++i) {
					if (__global[i]) {
						__global[i].Delete();
					}
				}
				if (_global) {
					_global.Delete();
				}
				for (uint64_t i = 0; i < memory_pool.size(); ++i) {
					delete memory_pool[i];
				}
				return false;
			}
			catch (...) {

				log << warn  << "internal error or new error \n";
				for (uint64_t i = 0; i < __global.size(); ++i) {
					if (__global[i]) {
						__global[i].Delete();
					}
				}
				if (_global) {
					_global.Delete();
				}
				for (uint64_t i = 0; i < memory_pool.size(); ++i) {
					delete memory_pool[i];
				}

				//ERROR("Internal Error"sv);
				return false;
			}

		}
		 bool parse(_Value& global, Arena* _global_memory_pool ,char* buf, uint64_t buf_len,

			_simdjson::internal::dom_parser_implementation* imple,
			int64_t length, std_vector<int64_t>& start, uint64_t* count_vec, 

			 uint64_t thr_num) {

			return _LoadData(global, _global_memory_pool, buf, buf_len, imple, length, start, count_vec,

				thr_num);
		}

	private:
		//                         
		 static void _write(StrStream& stream, const _Value& data, std_vector<StructuredPtr>& chk_list, const int depth, bool pretty);
		 static void _write(StrStream& stream, const _Value& data, const int depth, bool pretty);

		 static void write_(StrStream& stream, const _Value& global, StructuredPtr temp, bool pretty, bool hint);

	public:
		// test?... just Data has one element 
		 void write(const std::string& fileName, const _Value& global, bool pretty, bool hint = false);

		 void write(std::ostream& stream, const _Value& data, bool pretty);

		 std::string write_to_str(const _Value& data, bool pretty);
		 std::string write_to_str2(const _Value& data, bool pretty);

		 void write_parallel(Arena* pool, const std::string& fileName, _Value& j, uint64_t thr_num, bool pretty);
		 void write_parallel2(const std::string& fileName, const _Value& j, uint64_t thr_num, bool pretty);

	};

	claujson_inline void _write_string(StrStream& stream, char ch) {
		switch (ch) {
		case '\\':
			stream.add_2("\\\\");
			break;
		case '\"':
			stream.add_2("\\\"");
			break;
		case '\n':
			stream.add_2("\\n");
			break;
		case '\b':
			stream.add_2("\\b");
			break;
		case '\f':
			stream.add_2("\\f");
			break;
		case '\r':
			stream.add_2("\\r");
			break;
		case '\t':
			stream.add_2("\\t");
			break;
		default:
		{
			int code = ch;
			if ((code >= 0 && code < 0x20) || code == 0x7F)
			{
				char buf[] = "\\uDDDD";
				snprintf(buf + 2, 5, "%04X", code);
				stream.add_2(buf);
			}
			else {
				char buf[] = { ch, '\0' };
				stream.add_2(buf);
			}
		}
		}
	}

	claujson_inline void write_string(StrStream& stream, const StringView str) {
		stream.add_char('\"');
		for (uint64_t i = 0; i < str.size(); ++i) {
			_write_string(stream, str[i]);
		}
		stream.add_char('\"');
	}

	static    const char* str_open_array[] = { "[", " [ \n",  };
	static   const  char* str_open_object[] = { "{", " { \n",  };
	static   const  char* str_close_array[] = { "]", " ] \n", };
	static   const  char* str_close_object[] = { "}", " } \n", };
	static   const  char* str_comma[] = { ",", " , " };
	static   const  char* str_colon[] = { ":", " : " };
	static   const  char* str_space[] = { "", " " };

	claujson_inline void write_primitive(StrStream& stream, const _Value& x) {
		if (x.is_str()) {

			write_string(stream, StringView(x.str_val().data(), x.str_val().size()));

		}
		else if (x.type() == _ValueType::BOOL) {
			stream.add_2(x.bool_val() ? "true" : "false");
		}
		else if (x.type() == _ValueType::FLOAT) {
			stream.add_float(x.float_val());
		}
		else if (x.type() == _ValueType::INT) {
			stream.add_int(x.int_val());
		}
		else if (x.type() == _ValueType::UINT) {
			stream.add_uint(x.uint_val());
		}
		else if (x.type() == _ValueType::NULL_) {
			stream.add_2("null");
		}
	}
	std::string LoadData2::write_to_str(const _Value& global, bool pretty) {
		StrStream stream;

		if (global.is_structured()) {
			bool is_arr = global.is_array();

			if (is_arr) {
				stream.add_2(str_open_array[pretty ? 1 : 0]);
			}
			else {
				stream.add_2(str_open_object[pretty ? 1 : 0]);
			}

			_write(stream, global, 0, pretty);

			if (is_arr) {
				stream.add_2(str_close_array[pretty ? 1 : 0]);
			}
			else {
				stream.add_2(str_close_object[pretty ? 1 : 0]);
			}

		}
		else {
			auto& x = global;
			write_primitive(stream, x);
		}

		return std::string(stream.buf(), stream.buf_size());
	}

		//                           
	void LoadData2::_write(StrStream& stream, const _Value& data, std_vector<StructuredPtr>& chk_list, const int depth, bool pretty) {
		StructuredPtr ut;

		if (data.is_structured()) {
			ut = StructuredPtr(data);
		}
		else {
			return;
		}

		if (ut && ut.is_object()) {
			uint64_t len = ut.get_data_size();
			for (uint64_t i = 0; i < len; ++i) {
				if (ut.get_value_list(i).is_structured()) {
					auto& x = ut.get_key_list(i);

					if (x.is_str()) {
						write_string(stream, StringView(x.str_val().data(), x.str_val().size()));

						{
							stream.add_2(str_colon[pretty ? 1 : 0]);
						}
					}
					else {
						//log << warn  << "Error : no key\n";
					}

					auto y = (StructuredPtr(ut.get_value_list(i)));

					if (y.is_object() && y.is_virtual() == false) {
						stream.add_2(str_open_object[pretty ? 1 : 0]); // "{";
					}
					else if (y.is_array() && y.is_virtual() == false) {
						stream.add_2(str_open_array[pretty ? 1 : 0]); // "[";
					}

					_write(stream, ut.get_value_list(i), chk_list, depth + 1, pretty);

					if (y.is_object() && std::find(chk_list.begin(), chk_list.end(), y) == chk_list.end()) {
						stream.add_2(str_close_object[pretty ? 1 : 0]); // "}";
					}
					else if (y.is_array() && std::find(chk_list.begin(), chk_list.end(), y) == chk_list.end()) {
						stream.add_2(str_close_array[pretty ? 1 : 0]); // "]";
					}
				}
				else {
					auto& x = ut.get_key_list(i);

					if (x.is_str()) {
						write_string(stream, StringView(x.str_val().data(), x.str_val().size()));

						{
							stream.add_2(str_colon[pretty ? 1 : 0]); // " : ";
						}
					}

					{
						auto& x = ut.get_value_list(i);

						write_primitive(stream, x);
					}
				}

				if (i < ut.get_data_size() - 1) {
					stream.add_2(str_comma[pretty ? 1 : 0]); // ",";
				}
			}
		}
		else if (ut && ut.is_array()) {
			uint64_t len = ut.get_data_size();
			for (uint64_t i = 0; i < len; ++i) {
				if (ut.get_value_list(i).is_structured()) {

					auto y = (StructuredPtr(ut.get_value_list(i)));

					if (y.is_object() && y.is_virtual() == false) {
						stream.add_2(str_open_object[pretty ? 1 : 0]); // "{";
					}
					else if (y.is_array() && y.is_virtual() == false) {
						stream.add_2(str_open_array[pretty ? 1 : 0]); // "[";
					}

					_write(stream, ut.get_value_list(i), chk_list, depth + 1, pretty);

					y = ((StructuredPtr)(ut.get_value_list(i)));


					if (y.is_object() && std::find(chk_list.begin(), chk_list.end(), y) == chk_list.end()) {
						stream.add_2(str_close_object[pretty ? 1 : 0]); // "}";
					}
					else if (y.is_array() && std::find(chk_list.begin(), chk_list.end(), y) == chk_list.end()) {
						stream.add_2(str_close_array[pretty ? 1 : 0]); // "]";
					}

				}
				else {
					auto& x = ut.get_value_list(i);


					write_primitive(stream, x);
				}

				if (i < ut.get_data_size() - 1) {
					stream.add_2(str_comma[pretty ? 1 : 0]); // ",";
				}
			}
		}
		else if (data) { // valid
			auto& x = data;

			write_primitive(stream, x);
		}
	}

	void LoadData2::_write(StrStream& stream, const _Value& data, const int depth, bool pretty) {
		StructuredPtr ut;

		if (data.is_structured()) {
			ut = StructuredPtr(data);
		}
		else {
			return;
		}

		if (ut && ut.is_object()) {
			uint64_t len = ut.get_data_size();
			for (uint64_t i = 0; i < len; ++i) {
				if (ut.get_value_list(i).is_structured()) {
					auto& x = ut.get_key_list(i);

					if (x.is_str()) {


						uint64_t len = x.str_val().size();

						write_string(stream, StringView(x.str_val().data(), x.str_val().size()));


						{
							stream.add_2(str_colon[pretty ? 1 : 0]); // " : ";
						}
					}
					else {
						//log << warn  << "Error : no key\n"; // chk...
					}

					auto y = (StructuredPtr(ut.get_value_list(i)));

					if (y.is_object() && y.is_virtual() == false) {
						stream.add_2(str_open_object[pretty ? 1 : 0]);
					}
					else if (y.is_array() && y.is_virtual() == false) {
						stream.add_2(str_open_array[pretty ? 1 : 0]);
					}

					_write(stream, ut.get_value_list(i), depth + 1, pretty);

					if (y.is_object()) {
						stream.add_2(str_close_object[pretty ? 1 : 0]);
					}
					else if (y.is_array()) {
						stream.add_2(str_close_array[pretty ? 1 : 0]);
					}
				}
				else {
					auto& x = ut.get_key_list(i);

					if (x.is_str()) {
				

						uint64_t len = x.str_val().size();
						write_string(stream, StringView(x.str_val().data(), x.str_val().size()));




						{
							stream.add_2(str_colon[pretty ? 1 : 0]);
						}
					}

					{
						auto& x = ut.get_value_list(i);

						write_primitive(stream, x);
					}
				}

				if (i < ut.get_data_size() - 1) {
					stream.add_2(str_comma[pretty ? 1 : 0]);
				}
			}
		}
		else if (ut && ut.is_array()) {
			uint64_t len = ut.get_data_size();
			for (uint64_t i = 0; i < len; ++i) {
				if (ut.get_value_list(i).is_structured()) {

					auto y = (StructuredPtr(ut.get_value_list(i)));

					if (y.is_object() && y.is_virtual() == false) {
						stream.add_2(str_open_object[pretty ? 1 : 0]);
					}
					else if (y.is_array() && y.is_virtual() == false) {
						stream.add_2(str_open_array[pretty ? 1 : 0]);
					}

					_write(stream, ut.get_value_list(i), depth + 1, pretty);

					y = StructuredPtr(ut.get_value_list(i));


					if (y.is_object()) {
						stream.add_2(str_close_object[pretty ? 1 : 0]);
					}
					else if (y.is_array()) {
						stream.add_2(str_close_array[pretty ? 1 : 0]);
					}

				}
				else {
					auto& x = ut.get_value_list(i);

					write_primitive(stream, x);
				}

				if (i < ut.get_data_size() - 1) {
					stream.add_2(str_comma[pretty? 1 : 0]);
				}
			}
		}
		else if (data) { // valid
			auto& x = data;

			write_primitive(stream, x);
		}
	}

	// todo... just Data has one element 
	void LoadData2::write(const std::string& fileName, const _Value& global, bool pretty, bool hint) {
		StrStream stream;

		if (global.is_structured()) {
			if (hint) {
				stream.add_2(str_comma[pretty ? 1 : 0]);
			}
			bool is_arr = global.is_array();

			if (is_arr) {
				stream.add_2(str_open_array[pretty ? 1 : 0]);
			}
			else {
				stream.add_2(str_open_object[pretty ? 1 : 0]);
			}

			_write(stream, global, 1, pretty);

			if (is_arr) {
				stream.add_2(str_close_array[pretty ? 1 : 0]);
			}
			else {
				stream.add_2(str_close_object[pretty ? 1 : 0]);
			}

		}
		else {
			if (hint) {
				stream.add_2(str_comma[pretty ? 1 : 0]);
			}
			auto& x = global;

			write_primitive(stream, x);
		}

		std::ofstream outFile;
		outFile.open(fileName, std::ios::binary); // binary!
		if (outFile) {
			outFile.write(stream.buf(), stream.buf_size());
			outFile.close();
		}
	}

	void LoadData2::write(std::ostream& stream, const _Value& data, bool pretty) {
		StrStream str_stream;
		_write(str_stream, data, 0, pretty);
		stream << StringView(str_stream.buf(), str_stream.buf_size());
	}

	void LoadData2::write_(StrStream& stream, const _Value& global, StructuredPtr temp, bool pretty, bool hint) {

		std_vector<StructuredPtr> chk_list; // point for division?, virtual nodes? }}}?

		{
			while (temp) {
				chk_list.push_back(temp);
				temp = temp.get_parent();
			}
		}

		if (global.is_structured()) {
			if (hint) {
				stream.add_2(str_comma[pretty ? 1 : 0]); // stream << ",";
			}

			StructuredPtr j = global;


			if (j.is_array() && j.is_virtual() == false) {
				stream.add_2(str_open_array[pretty ? 1 : 0]);
			}
			else if (j.is_object() && j.is_virtual() == false) {
				stream.add_2(str_open_object[pretty ? 1 : 0]);
			}

			_write(stream, global, chk_list, 1, pretty);

			if (j.is_array() && std::find(chk_list.begin(), chk_list.end(), j) == chk_list.end()) {
				stream.add_2(str_close_array[pretty ? 1 : 0]);
			}
			else if (j.is_object() && std::find(chk_list.begin(), chk_list.end(), j) == chk_list.end()) {
				stream.add_2(str_close_object[pretty ? 1 : 0]);
			}
		}
		else {
			if (hint) {
				stream.add_2(str_comma[pretty ? 1 : 0]);
			}

			auto& x = global;

			write_primitive(stream, x);
		}
	}


	void LoadData2::write_parallel(Arena* memory_pool, const std::string& fileName, _Value& j, uint64_t thr_num, bool pretty) {

		if (!j.is_structured()) {
			write(fileName, j, pretty, false);
			return;
		}

		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);

		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		if (thr_num == 1) {
			write(fileName, j, pretty, false);
			return;
		}

		//std_vector<claujson::StructuredPtr> temp(thr_num, nullptr); //
		std_vector<claujson::StructuredPtr> temp_parent(thr_num);
		
		auto a = std::chrono::steady_clock::now();
		
		std_vector<claujson::StructuredPtr> result(thr_num - 1);

		std_vector<int> hint(thr_num - 1);
		bool quit = false;

		std_vector<claujson::StructuredPtr> pos(thr_num);

		std_vector<claujson::StrStream> stream(thr_num);

		//std_vector<std::thread> thr(thr_num);
		std_vector<std::future<void>> thr_result(thr_num);

		//temp = Divide2(thr_num, j, result, hint);
		
		{	
			auto n = thr_num;
			while (true) {
				if (j.is_structured() == false) {
					quit = true;
					break;
				}

				auto a = std::chrono::steady_clock::now();
				uint64_t len = 0;
				if (j.is_array()) {
					len = Size(j.as_array());
				}
				else if (j.is_object()) {
					len = Size(j.as_object());
				}
				auto b = std::chrono::steady_clock::now();
				auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
				log << info << "size is " << dur.count() << "ms\n";
				if (len / n == 0) {
					quit = true;
					break;
				}

				std_vector<uint64_t> offset(n - 1);

				for (uint64_t i = 0; i < offset.size(); ++i) {
					offset[i] = len / n;
				}
				offset.back() = len - len / n * (n - 1);

				hint = std_vector<int>(n - 1);

				std_vector<claujson::StructuredPtr> pos(n);

				a = std::chrono::steady_clock::now();
				{
					uint64_t idx = 0;
					auto offset2 = offset;

					Find2(j, n - 1, idx, false, len, offset, offset2, pos, hint);
				}
				b = std::chrono::steady_clock::now();
				dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
				log << info << "Find2 is " << dur.count() << "ms\n";

				for (uint64_t i = 0; i < n - 1; ++i) {
					if (!pos[i]) {
						quit = true;
					}
				}

				if (quit) {
					break;
				}

				{
					uint64_t i = 0;
					for (; i < n - 1; ++i) {

						if (i > 0 && temp_parent[i - 1] == nullptr) {

							for (uint64_t j = 0; j < i; ++j) {
								thr_result[j].get();
							}

							for (uint64_t j = 0; j < i; ++j) {
								int op = 0;

								Merge2(temp_parent[j], result[j], &temp_parent[j + 1], op);

							}

							for (uint64_t j = 0; j < result.size(); ++j) {
								if (result[i]) {
									result[i].Delete();
								}
							}
							quit = true;
							break;
						}

						Divide(memory_pool, pos[i], result[i]);

						temp_parent[i] = pos[i].get_parent();

						// chk....-2024.04.21 with json explorer?
						if (pos[i] == j) {
							temp_parent[i] = nullptr;
						}

						if (i == 0) {
							thr_result[0] = pool->enqueue(write_, std::ref(stream[0]), std::cref(j), temp_parent[0], pretty, (false));
						}
						else {
							thr_result[i] = pool->enqueue(write_, std::ref(stream[i]), std::cref(result[i - 1].get_value_list(0)), temp_parent[i], pretty, (hint[i - 1]));
						}
					}

					if (quit) {
						break;
					}

					if (i > 0 && temp_parent[i - 1] == nullptr) {
						for (uint64_t j = 0; j < i; ++j) {
							for (uint64_t j = 0; j < i; ++j) {
								thr_result[j].get();
							}

							int op = 0;

							Merge2(temp_parent[j], result[j], &temp_parent[j + 1], op);


						}

						for (uint64_t j = 0; j < result.size(); ++j) {
							if (result[i]) {
								result[i].Delete();
							}
						}

						quit = true;
						break;
					}

					thr_result[i] = pool->enqueue(write_, std::ref(stream[i]), 
						std::cref(result[i - 1].get_value_list(0)), temp_parent[i], pretty, (hint[i - 1]));
				}

				break;
			}
		}
		if (quit) {
			write(fileName, j, pretty, false);
			return;
		}

		auto b = std::chrono::steady_clock::now();
		auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);

		log << info << "divide... " << dur.count() << "ms\n";
		//if (temp.size() == 1 && temp[0] == nullptr) {
		//	write(fileName, j, pretty, false);
		//	return;
		//}
		//auto& temp  = result;
		//for (uint64_t i = 0; i < temp.size() - 1; ++i) {
		//	temp_parent[i] = temp[i]->get_parent();
		//}

		a = std::chrono::steady_clock::now();

		//	thr_result[0] = pool->enqueue(write_, std::ref(stream[0]), std::cref(j), temp_parent[0], pretty, (false));

		//	for (uint64_t i = 1; i < thr_num; ++i) {
		//		thr_result[i] = pool->enqueue(write_, std::ref(stream[i]), std::cref(result[i - 1]->get_value_list(0)), temp_parent[i], pretty, (hint[i - 1]));
		//	}

		for (uint64_t i = 0; i < thr_num; ++i) {
			thr_result[i].get();
		}

		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);

		log << info << "write_ " << dur.count() << "ms\n";
		a = std::chrono::steady_clock::now();
		int op = 0;

		Merge2(temp_parent[0], result[0], &temp_parent[1], op);

		for (uint64_t i = 1; i < thr_num - 1; ++i) {
			Merge2(temp_parent[i], result[i], &temp_parent[i + 1], op);
			op = 0;
		}
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);

		log << info << "merge " << dur.count() << "ms\n";

		for (uint64_t i = 0; i < result.size(); ++i) {
			if (result[i]) {
				result[i].Delete();
			}
		}
		a = std::chrono::steady_clock::now();
		std::ofstream outFile(fileName, std::ios::binary);
		if (outFile) {
			for (uint64_t i = 0; i < stream.size(); ++i) {
				outFile.write(stream[i].buf(), stream[i].buf_size());
			}

			outFile.close();
		}
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "write to file " << dur.count() << "ms\n";
	}

	class JsonView {
	public:
		const _Value* value;
		int32_t type; // enum? 0 - ARRAY, 1 - OBJECT, 2 - KEY, 3 - VALUE, 4 - END_ARRAY, 5 - END_OBJECT
	};

	JsonView* _run(JsonView* view_arr, const _Value* x);

	JsonView* run(JsonView* view_arr, const _Value* x) {
		auto* view_arr2 = _run(view_arr, x);
		if (view_arr == view_arr2) {
			return nullptr;
		}
		view_arr2->type = -1;
		return view_arr2;
	}
	JsonView* _run(JsonView* view_arr, const _Value* x) {
		if (x == nullptr) {
			return view_arr;
		}

		if (x->is_array()) {
			// ARRAY
			JsonView* start = view_arr;
			(*view_arr) = JsonView{ x, 0 };
			++view_arr;
			uint64_t sz = x->as_array()->get_data_size();
			for (uint64_t i = 0; i < sz; ++i) {
				if (x->as_array()->get_value_list(i).is_structured()) {
					view_arr = _run(view_arr, &x->as_array()->get_value_list(i));
				}
				else {
					(*view_arr) = JsonView{ &x->as_array()->get_value_list(i), 3 };
					++view_arr;
				}
			}
			(*view_arr) = JsonView{ nullptr, 4 };
			++view_arr;
		}
		else if (x->is_object()) {
			// OBJECT
			JsonView* start = view_arr;
			(*view_arr) = JsonView{ x, 1 };
			++view_arr;
			uint64_t sz = x->as_object()->get_data_size();
			for (uint64_t i = 0; i < sz; ++i) {
				(*view_arr) = JsonView{ &x->as_object()->get_const_key_list(i), 2 };
				++view_arr;

				if (x->as_object()->get_value_list(i).is_structured()) {
					view_arr = _run(view_arr, &x->as_object()->get_value_list(i));
				}
				else {
					(*view_arr) = JsonView{ &x->as_object()->get_value_list(i), 3 };
					++view_arr;
				}
			}
			(*view_arr) = JsonView{ nullptr, 5 };
			++view_arr;
		}
		else {
			(*view_arr) = JsonView{ x, 3 };
			++view_arr;
		}

		return view_arr;
	}

	void print(JsonView* json_view, JsonView* end, claujson::StrStream& strStream) {
		
		while (json_view->type != -1) {
			if (json_view == end) {
				return;
			}

			switch (json_view->type) {
			case 0: // ARRAY
				strStream.add_char('[');
				//strStream.add_char(' ');
				break;
			case 1: // OBJECT
				strStream.add_char('{');
				//strStream.add_char(' ');
				break;
			case 2: // KEY
				write_primitive(strStream, *json_view->value); //strStream.add_1(json_view->value->get_string().data(), json_view->value->get_string().size());
				//strStream.add_char(' '); 
				strStream.add_char(':');
				//strStream.add_char(' '); 
				break;
			case 3: // VALUE
				write_primitive(strStream, *json_view->value);

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view + 1)->type != -1) {

					strStream.add_char(',');
					//strStream.add_char(' ');
				}
				break;
			case 4: // END_ARRAY
				strStream.add_char(']');
				//strStream.add_char('\n');

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view +1)->type != -1) {

					strStream.add_char(',');
					//strStream.add_char(' ');
				}

				break;
			case 5: // END_OBJECT
				strStream.add_char('}');
				//strStream.add_char('\n');

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view + 1)->type != -1) {

					strStream.add_char(',');
					//strStream.add_char(' ');
				}
				break;
			}

			++json_view;
		}
	}

	void print_pretty(JsonView* json_view, JsonView* end, claujson::StrStream& strStream) {

		while (json_view->type != -1) {
			if (json_view == end) {
				return;
			}

			switch (json_view->type) {
			case 0: // ARRAY
				strStream.add_char('[');
				strStream.add_char(' ');
				break;
			case 1: // OBJECT
				strStream.add_char('{');
				strStream.add_char(' ');
				break;
			case 2: // KEY
				write_primitive(strStream, *json_view->value);
				strStream.add_char(' '); 
				strStream.add_char(':');
				strStream.add_char(' '); 
				break;
			case 3: // VALUE
				write_primitive(strStream, *json_view->value);

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view + 1)->type != -1) {

					strStream.add_char(',');
					strStream.add_char(' ');
				}
				break;
			case 4: // END_ARRAY
				strStream.add_char(']');
				strStream.add_char('\n');

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view + 1)->type != -1) {

					strStream.add_char(',');
					strStream.add_char(' ');
				}

				break;
			case 5: // END_OBJECT
				strStream.add_char('}');
				strStream.add_char('\n');

				if ((json_view + 1)->type != 4 && (json_view + 1)->type != 5 && (json_view + 1)->type != -1) {

					strStream.add_char(',');
					strStream.add_char(' ');
				}
				break;
			}

			++json_view;
		}
	}

	void LoadData2::write_parallel2(const std::string& fileName, const _Value& j, uint64_t thr_num, bool pretty) {
		if (!j.is_structured()) {
			write(fileName, j, pretty, false);
			return;
		}

		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);

		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		if (thr_num == 1) {
			write(fileName, j, pretty, false);
			return;
		}

		auto a = std::chrono::steady_clock::now();
		auto b = std::chrono::steady_clock::now();

		std_vector<claujson::StrStream> stream(thr_num);

		a = std::chrono::steady_clock::now();
		uint64_t size = Size2(j);
		b = std::chrono::steady_clock::now();
		auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "Size2 " << size << " " << dur.count() << "\n";

		a = std::chrono::steady_clock::now();
		JsonView* view_arr = (JsonView*)calloc(size + 1, sizeof(JsonView));
		JsonView* view_end = run(view_arr, &j);
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "run " << dur.count() << "\n";

		size = view_end - view_arr;
		log << info << "size... " << size << "\n";
		a = std::chrono::steady_clock::now();
		
		std_vector<uint64_t> start(thr_num + 1);
		std_vector<uint64_t> last(thr_num);
		
		{
			std::set<uint64_t> _set; // remove dup.

			for (uint64_t i = 1; i < thr_num; ++i) {
				uint64_t middle = size / thr_num * i;
				_set.insert(middle);
			}

			_set.insert(0);
			
			start.resize(1 + _set.size());
			last.resize(_set.size());

			uint64_t count = 0;
			for (auto x : _set) { // order is important.
				start[count] = x;
				++count;
			}
			
			start.back() = size;

			for (uint64_t i = 0; i < count; ++i) {
				last[i] = start[i + 1];
			}

			thr_num = start.size() - 1;
		}

		std_vector<std::future<void>> thr_result(thr_num);
		if (pretty) {
			std_vector<std::thread> thread_print(thr_num);

			for (uint64_t i = 0; i < thread_print.size(); ++i) {  // end[i] ?
				thr_result[i] = pool->enqueue(print_pretty, view_arr + start[i], view_arr + last[i], std::ref(stream[i]));
			}

			for (uint64_t i = 0; i < thread_print.size(); ++i) {
				thr_result[i].get();
			}
		}
		else {
			std_vector<std::thread> thread_print(thr_num);
			
			for (uint64_t i = 0; i < thread_print.size(); ++i) {
				thr_result[i] = pool->enqueue(print, view_arr + start[i], view_arr + last[i], std::ref(stream[i]));
			}
			
			for (uint64_t i = 0; i < thread_print.size(); ++i) {
				thr_result[i].get();
			}
		}
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "print " << dur.count() << "\n";

		a = std::chrono::steady_clock::now();
		std::ofstream outFile(fileName, std::ios::binary);
		if (outFile) {
			for (uint64_t i = 0; i < thr_num; ++i) {
				outFile.write(stream[i].buf(), stream[i].buf_size());
			}

			outFile.close();
		}
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "write to file " << dur.count() << "ms\n";
	
		free(view_arr);
	}

	std::string LoadData2::write_to_str2(const _Value& j, bool pretty) {
		if (j.is_primitive()) {
			return write_to_str(j, pretty);
		}

		auto a = std::chrono::steady_clock::now();
		auto b = std::chrono::steady_clock::now();

		claujson::StrStream stream;

		a = std::chrono::steady_clock::now();
		uint64_t size = Size2(j);
		b = std::chrono::steady_clock::now();
		auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "Size2 " << dur.count() << "\n";

		a = std::chrono::steady_clock::now();
		JsonView* view_arr = (JsonView*)calloc(size + 1, sizeof(JsonView));
		JsonView* view_end = run(view_arr, &j);
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "run " << dur.count() << "\n";

		size = view_end - view_arr;

		a = std::chrono::steady_clock::now();
		if (pretty) {
			print_pretty(view_arr, view_arr + size, stream);
		}
		else {
			print(view_arr, view_arr + size, stream);
		}
		b = std::chrono::steady_clock::now();
		dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
		log << info << "print " << dur.count() << "\n";

		free(view_arr);

		return std::string(stream.buf(), stream.buf_size());
	}

	bool is_valid2(_simdjson::dom::parser_for_claujson& dom_parser, uint64_t start, uint64_t last,
		int* _start_state, int* _last_state,
		Vector<int8_t>* _is_array, Vector<int8_t>* _is_virtual_array,
		uint64_t* count = nullptr
		) {

		const auto& buf = dom_parser.raw_buf();

		auto* simdjson_imple = dom_parser.raw_implementation().get();
		uint64_t idx = start;
		uint64_t depth = 0;

		Vector<int8_t> is_array;
		Vector<int8_t> is_virtual_array;
		Vector<uint64_t> _stack;

		int state = 0;
		uint64_t no = start;

		if (start > last) {
			return false;
		}

		if (start > 0 && start == last) {
			return false; // 
		}
		//
// Start the document
//
		///if (at_eof()) { return EMPTY; }

		if (simdjson_imple->n_structural_indexes == 0) {
			return true; // chk?
		}

		//log_start_value("document");
		//SIMDJSON_TRY(visitor.visit_document_start(*this));

		//
		// Read first value
		//
		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]]; //advance();

			// Make sure the outer object or array is closed before continuing; otherwise, there are ways we
			// could get into memory corruption. See https://github.com/simdjson/simdjson/issues/906
			//if (!STREAMING) {
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[simdjson_imple->n_structural_indexes - 1]] != '}') {
				log << warn << ("starting brace unmatched");

				//if (err) {
				//	*err = 1;
				//}

				return false;
			}
					break;
			case '[': if (buf[simdjson_imple->structural_indexes[simdjson_imple->n_structural_indexes - 1]] != ']') {
				log << warn << ("starting bracket unmatched");
				//if (err) {
				//	*err = 1;
				//}
				return false;
			}
					break;
			}
			//	}

			switch (value) { // start == 0
			case '{': { if (buf[simdjson_imple->structural_indexes[idx]] == '}') {
				++idx; log << warn << ("empty object"); count[no++] = 0;
				break;
			} *_start_state = 0;  goto object_begin;
			}
			case '[': { if (buf[simdjson_imple->structural_indexes[idx]] == ']') {
				++idx; log << warn << ("empty array"); count[no++] = 0; 
				break;
			} *_start_state = 4;  goto array_begin;
			}

			default: break;
			}


			if (start > 0 && value == ',') {
				if (idx < simdjson_imple->n_structural_indexes - 1) {
					if (buf[simdjson_imple->structural_indexes[idx + 1]] == ':') {
						--idx;
						*_start_state = 2;
						goto object_continue;
					}
					else {
						--idx;
						*_start_state = 6;
						goto array_continue;
					}
				}
				else { // idx >= n_~~  // error
					//*err = true;
					return false;
				}
			}

			switch (value) {
			case ':':
			case ',':
			case '}':
			case ']':
			{ log << warn << "not primitive"; return false; } break;
			}
		}
		goto document_end;

		//
		// Object parser states
		//
	object_begin:
		//log_start_value("object");
		depth++;
		count[no] = 0;
		{
			if (idx > last) {
				goto document_end;
			}
			//if (err && *err) {
			//	return false;
			//}
		}
		state = 0;
		if (is_array.size() < depth) {
			is_array.push_back(0);
		}

		_stack.push_back(no++); 
		//dom_parser.is_array[depth] = false;
		is_array[depth - 1] = 0;
		//SIMDJSON_TRY(visitor.visit_object_start(*this));

		{
			auto key = buf[simdjson_imple->structural_indexes[idx++]]; // advance();
			if (key != '"') {
				log << warn << ("Object does not start with a key");
				//if (err) {
				//	*err = 1;
				//}
				return false;
			}
			//SIMDJSON_TRY(visitor.increment_count(*this));
			//SIMDJSON_TRY(visitor.visit_key(*this, key));
		}

	object_field:

		{
			if (idx > last) {
				goto document_end;
			}
			//if (err && *err) {
			//	return false;
			//}
		}

		state = 1;

		if (_simdjson_unlikely(buf[simdjson_imple->structural_indexes[idx++]] != ':')) { log << warn << ("Missing colon after key in object"); return false; }
		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]];
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[idx]] == '}') {
				++idx;count[no++] = 0;
				break;
			}
					goto object_begin;
			case '[': if (buf[simdjson_imple->structural_indexes[idx]] == ']') {
				++idx;count[no++] = 0; 
				break;
			} 
					goto array_begin;
			case ',': { log << warn << "wrong comma.";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			case ':': { log << warn << "wrong colon.";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			case '}': { log << warn << "wrong }.";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			case ']': { log << warn << "wrong ].";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			default: //SIMDJSON_TRY(visitor.visit_primitive(*this, value)); 
				break;
			}
		}

	object_continue:


		if (!_stack.empty()) {
			count[_stack.back()]++;
		}
		//else {
			//if (virtual_count == 0) {
			//	virtual_idx = idx - 1;
			//}
			//virtual_count++;
		//}

		{
			if (idx > last) {
				goto document_end;
			}
			//if (err && *err) {
			//	return false;
			//}
		}
		state = 2;
		switch (buf[simdjson_imple->structural_indexes[idx++]]) {
		case ',':
			//SIMDJSON_TRY(visitor.increment_count(*this));
		{
			auto key = buf[simdjson_imple->structural_indexes[idx++]]; // advance();
			if (_simdjson_unlikely(key != '"')) {
				log << warn << ("Key string missing at beginning of field in object");
				//if (err) {
				//	*err = 1;
				//}
				return false;
			}
			//SIMDJSON_TRY(visitor.visit_key(*this, key));
		}
		goto object_field;
		case '}': goto scope_end;
		case ':': { log << warn << "wrong colon.";
			//if (err) {
			//	*err = 1;
			//}
			return false; }
		default: log << warn << ("No comma between object fields"); return false;
		}

	scope_end:
		{
			state = 3;
			if (depth > 0) {
				depth--; is_array.pop_back(); _stack.pop_back(); // if (_stack.empty()) { virtual_count = 0; }
			}
			else {
				// depth <= 0.. virtual array or virtual object..
				switch (buf[simdjson_imple->structural_indexes[idx - 1]]) {
				case ']': 
					is_virtual_array.push_back(1); //count[virtual_idx] = virtual_count; virtual_count = 0;
					break;
				case '}':
					is_virtual_array.push_back(0); //count[virtual_idx] = virtual_count;  virtual_count = 0;
					break;
				}
			}

			if (idx > last) { // depth == 0) {
				goto document_end;
			}

			if (depth == 0) {
				// is in array or object ?
				if (buf[simdjson_imple->structural_indexes[idx]] == ',') {
					++idx;
					if (idx < simdjson_imple->n_structural_indexes - 1) {
						if (buf[simdjson_imple->structural_indexes[idx + 1]] == ':') {
							--idx;
							goto object_continue;
						}
						else {
							--idx;
							goto array_continue;
						}
					}
					else { // idx >= n_~~  // error
				//		*err = true;
						return false;
					}
				}
				else {
					switch (buf[simdjson_imple->structural_indexes[idx]]) {
					case ']':
					case '}':
						++idx;
						goto scope_end;
						break;
					default:
						// error
				//		*err = true;
						return false;
					}
				}
			}

			if (is_array[depth - 1]) { goto array_continue; }
			goto object_continue;
		}

		//
		// Array parser states
		//
	array_begin:
		
		count[no] = 0;
		{
			if (idx > last) {
				goto document_end;
			}
			//if (err && *err) {
			//	return false;
			//}
		}
		state = 4;
		//log_start_value("array");
		depth++;
		if (is_array.size() < depth) { is_array.push_back(1); }
		is_array[depth - 1] = 1;

		_stack.push_back(no++);

		//SIMDJSON_TRY(visitor.visit_array_start(*this));
	//	SIMDJSON_TRY(visitor.increment_count(*this));

	array_value:
		{
			if (idx > last) {
				goto document_end;
			}
			//if (err && *err) {
			//	return false;
			//}
		}

		state = 5;
		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]];
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[idx]] == '}') { ++idx; count[no++] = 0; 
				break; } goto object_begin;
			case '[': if (buf[simdjson_imple->structural_indexes[idx]] == ']') { ++idx; count[no++] = 0;
				break; } goto array_begin;
			case ',': { log << warn << "wrong comma.";
				//if (err) {
				//	*err = 1;
			//	}
				return false; }
			case ':': { log << warn << "wrong colon.";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			case '}': { log << warn << "wrong }.";
				//if (err) {
				///	*err = 1;
				//}
				return false; }
			case ']': { log << warn << "wrong ].";
				//if (err) {
				//	*err = 1;
				//}
				return false; }
			default: break;
			}
		}

	array_continue:
		if (!_stack.empty()) {
			count[_stack.back()]++;
		}
		//else {
			//if (virtual_count == 0) {
			//	virtual_idx = idx - 1;
			//}
			//virtual_count++;
		//}

		{
			if (idx > last) {
				goto document_end;
			}
		//	if (err && *err) {
			//	return false;
		//	}
		}

		state = 6;
		switch (buf[simdjson_imple->structural_indexes[idx++]]) {
		case ',': goto array_value;
		case ']': goto scope_end;
		case ':': { log << warn << "wrong colon.";
			//if (err) {
			//	*err = 1;
			//}
			return false; }
		default: log << warn << ("Missing comma between array values");
			//if (err) {
			//	*err = 1;
			//}
			return false;
		}

	document_end:

		*_last_state = state;

		// If we didn't make it to the end, it's an error
		if (idx <= last) {
			log << warn << ("More than one JSON value at the root of the document, or extra characters at the end of the JSON!"); // chk...

			//if (err) {
			//	*err = 1;
			//}
			return false;
		}

		if (_is_array) {
			*_is_array = std::move(is_array);
		}

		if (_is_virtual_array) {
			*_is_virtual_array = std::move(is_virtual_array);
		}

		return true;
	}

	bool is_valid(_simdjson::dom::parser_for_claujson& dom_parser, uint64_t middle, std_vector<int>* _is_array = nullptr, int* err = nullptr) {

		const auto& buf = dom_parser.raw_buf();
		const auto buf_len = dom_parser.raw_len();

		auto* simdjson_imple = dom_parser.raw_implementation().get();
		uint64_t idx = 0;
		uint64_t depth = 0;
		std_vector<int> is_array;

		is_array.reserve(1024);

		//
// Start the document
//
		///if (at_eof()) { return EMPTY; }

		if (simdjson_imple->n_structural_indexes == 0) {
			return true; // chk?
		}

		//log_start_value("document");
		//SIMDJSON_TRY(visitor.visit_document_start(*this));

		//
		// Read first value
		//
		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]]; //advance();

			// Make sure the outer object or array is closed before continuing; otherwise, there are ways we
			// could get into memory corruption. See https://github.com/simdjson/simdjson/issues/906
			//if (!STREAMING) {
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[simdjson_imple->n_structural_indexes - 1]] != '}') {
				log << warn << ("starting brace unmatched");

				if (err) {
					*err = 1;
				}

				return false;
			}
					break;
			case '[': if (buf[simdjson_imple->structural_indexes[simdjson_imple->n_structural_indexes - 1]] != ']') {
				log << warn << ("starting bracket unmatched");
				if (err) {
					*err = 1;
				}
				return false;
			}
					break;
			}
			//	}

			switch (value) {
			case '{': { if (buf[simdjson_imple->structural_indexes[idx]] == '}') {
				++idx; log << warn << ("empty object"); break;
			} goto object_begin; }
			case '[': { if (buf[simdjson_imple->structural_indexes[idx]] == ']') {
				++idx; log << warn << ("empty array"); break;
			} goto array_begin; }

			default: break;
			}


			switch (value) {
			case ':':
			case ',':
			case '}':
			case ']':
			{ log << warn << "not primitive"; return false; } break;
			}
		}
		goto document_end;

		//
		// Object parser states
		//
	object_begin:
		//log_start_value("object");
		depth++;
		if (is_array.size() < depth) {
			is_array.push_back(0);
		}
		
		//dom_parser.is_array[depth] = false;
		is_array[depth - 1] = 0;
		//SIMDJSON_TRY(visitor.visit_object_start(*this));

		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}


		{
			auto key = buf[simdjson_imple->structural_indexes[idx++]]; // advance();
			if (key != '"') {
				log << warn << ("Object does not start with a key");
				if (err) {
					*err = 1;
				}
				return false;
			}
			//SIMDJSON_TRY(visitor.increment_count(*this));
			//SIMDJSON_TRY(visitor.visit_key(*this, key));
		}

	object_field:

		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}

		if (_simdjson_unlikely(buf[simdjson_imple->structural_indexes[idx++]] != ':')) { log << warn << ("Missing colon after key in object"); return false; }
		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]];
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[idx]] == '}') { ++idx; break; } goto object_begin;
			case '[': if (buf[simdjson_imple->structural_indexes[idx]] == ']') { ++idx; break; } goto array_begin;
			case ',': { log << warn << "wrong comma.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ':': { log << warn << "wrong colon.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '}': { log << warn << "wrong }.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ']': { log << warn << "wrong ].";
				if (err) {
					*err = 1;
				}
				return false; }
			default: //SIMDJSON_TRY(visitor.visit_primitive(*this, value)); 
				break;
			}
		}

	object_continue:
		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}

		switch (buf[simdjson_imple->structural_indexes[idx++]]) {
		case ',':
			//SIMDJSON_TRY(visitor.increment_count(*this));
		{
			auto key = buf[simdjson_imple->structural_indexes[idx++]]; // advance();
			if (_simdjson_unlikely(key != '"')) {
				log << warn << ("Key string missing at beginning of field in object");
				if (err) {
					*err = 1;
				}
				return false;
			}
			//SIMDJSON_TRY(visitor.visit_key(*this, key));
		}
		goto object_field;
		case '}': goto scope_end;
		case ':': { log << warn << "wrong colon.";
			if (err) {
				*err = 1;
			}
			return false; }
		default: log << warn << ("No comma between object fields"); return false;
		}

	scope_end:
		depth--; is_array.pop_back();
		if (depth == 0) {
			goto document_end;
		}
		if (is_array[depth - 1]) { goto array_continue; }
		goto object_continue;

		//
		// Array parser states
		//
	array_begin:
		//log_start_value("array");
		depth++;
		if (is_array.size() < depth) { is_array.push_back(1); }
		is_array[depth - 1] = 1;

		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}

		//SIMDJSON_TRY(visitor.visit_array_start(*this));
	//	SIMDJSON_TRY(visitor.increment_count(*this));

	array_value:
		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}

		{
			auto value = buf[simdjson_imple->structural_indexes[idx++]];
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[idx]] == '}') { ++idx; break; } goto object_begin;
			case '[': if (buf[simdjson_imple->structural_indexes[idx]] == ']') { ++idx; break; } goto array_begin;
			case ',': { log << warn << "wrong comma.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ':': { log << warn << "wrong colon.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '}': { log << warn << "wrong }.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ']': { log << warn << "wrong ].";
				if (err) {
					*err = 1;
				}
				return false; }
			default: break;
			}
		}

	array_continue:
		{
			if (idx > middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}
		}

		switch (buf[simdjson_imple->structural_indexes[idx++]]) {
		case ',': goto array_value;
		case ']': goto scope_end;
		case ':': { log << warn << "wrong colon.";
			if (err) {
				*err = 1;
			}
			return false; }
		default: log << warn << ("Missing comma between array values");
			if (err) {
				*err = 1;
			}
			return false;
		}

	document_end:

		// If we didn't make it to the end, it's an error
		if (idx < middle) {
			log << warn << ("More than one JSON value at the root of the document, or extra characters at the end of the JSON!"); // chk...

			if (err) {
				*err = 1;
			}
			return false;
		}

		if (_is_array) {
			*_is_array = std::move(is_array);
		}

		return true;
	}
	bool is_valid_reverse(_simdjson::dom::parser_for_claujson& dom_parser, int64_t middle, std_vector<int>* _is_array = nullptr, int* err = nullptr) { // str[middle] == ','

		const auto& buf = dom_parser.raw_buf();

		auto* simdjson_imple = dom_parser.raw_implementation().get();
		int64_t idx = simdjson_imple->n_structural_indexes - 1;
		uint64_t depth = 0;
		std_vector<int> is_array;

		is_array.reserve(1024);

		//
// Start the document
//
		///if (at_eof()) { return EMPTY; }

		//if (idx == middle) { // , (nothing) <- error
		//	return false; 
		//}
		//else 
		if (idx < middle) {
			return true; // chk?
		}

		//log_start_value("document");
		//SIMDJSON_TRY(visitor.visit_document_start(*this));

		//
		// Read first value
		//
		{
			auto value = buf[simdjson_imple->structural_indexes[idx--]]; //advance();

			// Make sure the outer object or array is closed before continuing; otherwise, there are ways we
			// could get into memory corruption. See https://github.com/simdjson/simdjson/issues/906
			//if (!STREAMING) {
			switch (value) {
			case '{': if (buf[simdjson_imple->structural_indexes[0]] != '}') {
				log << warn << ("starting brace unmatched");
				if (err) {
					*err = 1;
				}
				return false;
			}
					break;
			case '[': if (buf[simdjson_imple->structural_indexes[0]] != ']') {
				log << warn << ("starting bracket unmatched");
				if (err) {
					*err = 1;
				}
				return false;
			}
					break;
			}
			//	}

			switch (value) {
			case '}': { if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '{') {
				--idx; log << warn << ("empty object"); break;
			} goto scope_end; }
			case ']': { if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '[') {
				--idx; log << warn << ("empty array"); break;
			} goto scope_end; }

			default: break;
			}


			switch (value) {
			case ':':
			case ',':
			case '{':
			case '[':
			{ log << warn << "not primitive";
			if (err) {
				*err = 1;
			}
			return false; } break;
			}
		}
		if (idx < middle) {
			goto document_end;
		}
		goto scope_end;

		//
		// Object parser states
		//
	object_begin:
		depth--; is_array.pop_back();
		if (depth == 0) {
			goto document_end;
		}

		{
			auto value = buf[simdjson_imple->structural_indexes[idx + 1]];

			if (is_array[depth - 1]) {
				goto array_continue;
			}
			goto object_key;

		}



	object_value:
		{
			if (idx < middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}

			auto value = buf[simdjson_imple->structural_indexes[idx--]];

			switch (value) {
			case '}':
				if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '{') { --idx; break; } goto scope_end;
			case ']':
				if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '[') { --idx; break; } goto scope_end;
			case ',': { log << warn << "wrong comma.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ':': { log << warn << "wrong colon.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '{': { log << warn << "wrong {.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '[': { log << warn << "wrong [.";
				if (err) {
					*err = 1;
				}
				return false; }
			default: //SIMDJSON_TRY(visitor.visit_primitive(*this, value)); 
				break;
			}
		}

	object_key:
		if (idx < middle) {
			goto document_end;
		}
		if (err && *err) {
			return false;
		}


		if (_simdjson_unlikely(buf[simdjson_imple->structural_indexes[idx--]] != ':')) {
			log << warn << ("Missing colon after key in object");
			if (err) {
				*err = 1;
			}
			return false;
		}

		//log_start_value("object");
		{
			if (idx < middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}


			auto key = buf[simdjson_imple->structural_indexes[idx--]]; // advance();
			if (key != '"') {
				log << warn << ("Object does not start with a key");
				if (err) {
					*err = 1;
				}
				return false;
			}
			//SIMDJSON_TRY(visitor.increment_count(*this));
			//SIMDJSON_TRY(visitor.visit_key(*this, key));

			if (idx < middle) {
				goto document_end;
			}
			if (err && *err) {
				return false;
			}

		}

	object_continue:
		if (idx < middle) {
			goto document_end;
		}
		if (err && *err) {
			return false;
		}


		switch (buf[simdjson_imple->structural_indexes[idx--]]) {
		case ',': goto object_value;
		case '{': goto object_begin;
		case ':': { log << warn << "wrong colon.";
			if (err) {
				*err = 1;
			}
			return false; }
		default: log << warn << ("No comma between object fields");
			if (err) {
				*err = 1;
			}
			return false;
		}

	scope_end:
		{
			depth++;
			if (is_array.size() < depth) {
				is_array.push_back(0);
			}
		
			if (idx < middle) {
				goto document_end;
			}

			if (err && *err) {
				return false;
			}

			auto value = buf[simdjson_imple->structural_indexes[idx + 1]];

			switch (value) {
			case '}':
				is_array[depth - 1] = 0;
				goto object_value;
			case ']':
				is_array[depth - 1] = 1;
				goto array_value;
			}

			log << warn << "not } or ]";
			if (err) {
				*err = 1;
			}

			return false;
		}
		//depth--;
		//if (depth == 0) {
		//	goto document_end;
		//}
		//if (is_array[depth - 1]) { goto array_continue; }
		//goto object_continue;

		//
		// Array parser states
		//
	array_begin:
		//log_start_value("array");
		depth--; is_array.pop_back();
		if (depth == 0) {
			goto document_end;
		}

		if (idx < middle) {
			goto document_end;
		}

		if (err && *err) {
			return false;
		}

		{
			auto value = buf[simdjson_imple->structural_indexes[idx + 1]];

			if (is_array[depth - 1]) {
				goto array_continue;
			}
			goto object_key;
		}

		//SIMDJSON_TRY(visitor.visit_array_start(*this));
		//SIMDJSON_TRY(visitor.increment_count(*this));

	array_value:

		if (idx < middle) {
			goto document_end;
		}
		if (err && *err) {
			return false;
		}


		{
			auto value = buf[simdjson_imple->structural_indexes[idx--]];
			switch (value) {
			case '}': if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '{') { --idx; break; } goto scope_end;
			case ']': if (idx >= 0 && buf[simdjson_imple->structural_indexes[idx]] == '[') { --idx; break; } goto scope_end;
			case ',': { log << warn << "wrong comma.";
				if (err) {
					*err = 1;
				}
				return false; }
			case ':': { log << warn << "wrong colon.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '{': { log << warn << "wrong {.";
				if (err) {
					*err = 1;
				}
				return false; }
			case '[': { log << warn << "wrong [.";
				if (err) {
					*err = 1;
				}
				return false; }
			default: break;
			}
		}

	array_continue:
		if (idx < middle) {
			goto document_end;
		}
		if (err && *err) {
			return false;
		}


		switch (buf[simdjson_imple->structural_indexes[idx--]]) {
		case ',': goto array_value;
		case '[': goto array_begin;
		case ':': { log << warn << "wrong colon.";
			if (err) {
				*err = 1;
			}
			return false; }
		default: log << warn << ("Missing comma between array values");
			if (err) {
				*err = 1;
			}
			return false;
		}

	document_end:

		if (idx >= middle) {
			log << warn << ("json is not valid");
			if (err) {
				*err = 1;
			}

			return false;
		}

		log << info << "test end\n";

		if (_is_array) {
			*_is_array = std::move(is_array);
		}

		return true;
	}

	[[nodiscard]]
	std::unique_ptr<ThreadPool> pool_init(int thr_num);

	parser::parser(int thr_num) {
		pool = pool_init(thr_num);
	}

	std::pair<bool, uint64_t> parser::parse(const std::string& fileName, Document& d, uint64_t thr_num)
	{
		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);
		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		_Value& ut = d.Get();

		uint64_t length = 0;

		auto _ = std::chrono::steady_clock::now();

		uint64_t* count_vec = nullptr;
		{

			log << info << "simdjson-stage1 start\n";
			// not static??
			auto x = test_.load(fileName);

			if (x.error() != _simdjson::error_code::SUCCESS) {
				log << warn << "stage1 error : ";
				log << warn << x.error() << "\n";

				//ERROR(_simdjson::error_message(x.error()));

				return { false, 0 };
			}

			const auto& buf = test_.raw_buf();
			const auto buf_len = test_.raw_len();

			auto* simdjson_imple_ = test_.raw_implementation().get();

			std_vector<int64_t> start(thr_num + 1);
			//std_vector<int> key;

			auto a = std::chrono::steady_clock::now();
			auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(a - _);
			log << info << dur.count() << "ms\n";


			{
				uint64_t how_many = simdjson_imple_->n_structural_indexes;
				length = how_many;

				start[0] = 0;
				for (uint64_t i = 1; i < thr_num; ++i) {
					start[i] = how_many / thr_num * i;
				}
			}

			if (length == 0) {
				log << warn << "empty string is not valid json";
				return { false, 0 };
			}

			auto b = std::chrono::steady_clock::now();
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);
			log << info << "valid1 " << dur.count() << "ms\n";

			b = std::chrono::steady_clock::now();

				std::set<uint64_t> _set;
			//if (!is_valid(test, length - 1)) {
			//	return { false, 0 };
			//}
			// find ,
			{

				auto a = std::chrono::steady_clock::now();
								
				//if (use_all_function) 
				{

				//	std_vector<uint64_t> start(thr_num + 1);
					std_vector<uint64_t> last(thr_num);

					std_vector<int> start_state(thr_num);
					for (auto& x : start_state) {
						x = -1;
					}
					std_vector<int> last_state(thr_num);
					for (auto& x : last_state) {
						x = -1;
					}
					for (uint64_t i = 1; i < thr_num; ++i) {
						uint64_t middle = length / thr_num * i;
						for (uint64_t i = middle; i < length; ++i) {
							if (buf[simdjson_imple_->structural_indexes[i]] == ',') {
								middle = i; _set.insert(i); break;
							}

							if (i == length - 1) {
								middle = length;
							}
						}
					}

					_set.insert(0);

					start.resize(1 + _set.size());
					last.resize(_set.size());

					int count = 0;
					for (auto x : _set) {
						start[count] = x;
						++count;
					}
					start[_set.size()] = length - 1;

					for (uint64_t i = 0; i < _set.size(); ++i) {
						last[i] = start[i + 1];
					}

					std_vector<Vector<int8_t>> is_array(_set.size()), is_virtual_array(_set.size());
					std_vector<std::future<bool>> thr_result(_set.size());
					//int err = 0;

					count_vec = (uint64_t*)malloc(length * sizeof(uint64_t));
					if (!count_vec) {
						log << "malloc fail in parse function.";
						return { false, -55 };
					}

					if (thr_num > 1) {

						for (uint64_t i = 0; i < _set.size(); ++i) {
							thr_result[i] = pool->enqueue(is_valid2, std::ref(test_), start[i], last[i], &start_state[i], &last_state[i],
								&is_array[i], &is_virtual_array[i], count_vec);
						}
						std_vector<int> result(_set.size());

						for (uint64_t i = 0; i < _set.size(); ++i) {
							result[i] = static_cast<int>(thr_result[i].get());
						}

						for (uint64_t i = 0; i < result.size(); ++i) {
							if (result[i] == false) {
								free(count_vec);
								return { false, -1 };
							}
						}

						for (uint64_t i = 0; i < _set.size() - 1; ++i) {
							if (start_state[i + 1] != last_state[i]) { // need more tests.
								free(count_vec); return { false, -2 };
							}
						}

						if (is_virtual_array[0].empty() == false) { // first block has no virtual array or virtual object.!
							free(count_vec); return { false, -3 };
						}

						for (uint64_t i = 1; i < _set.size(); ++i) {
							if (false == is_virtual_array[i].empty()) {
								// remove? matched is_array(or object) and is_virtual_array(or object)
								if (is_array[0].size() >= is_virtual_array[i].size()) {
									for (uint64_t j = 0; j < is_virtual_array[i].size(); ++j) {
										if (is_array[0].back() != is_virtual_array[i][j]) {
											free(count_vec); return { false, -3 };
										}
										is_array[0].pop_back();
									}
								}
								else {
									free(count_vec); return { false, -3 };
								}
							}
							// added...
							for (uint64_t x = 0; x < is_array[i].size(); ++x) {
								is_array[0].push_back(is_array[i][x]);
							}

							//is_array[0].insert(is_array[0].end(), is_array[i].begin(), is_array[i].end());
						}

						if (false == is_array[0].empty()) {
							free(count_vec); return { false, -4 };
						}
					}
					else {
						int start_state = 0;
						int last_state = 0;

						if (!is_valid2(test_, 0, length - 1, &start_state, &last_state,
							nullptr, nullptr, count_vec)) {
							free(count_vec);
							return { false, 0 };
						}
					}
				}

				dur = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - a);
				log << info << "test time " << dur.count() << "ms\n";
			}
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - b);
			log << info << dur.count() << "ms\n";

			b = std::chrono::steady_clock::now();

			start[_set.size()] = length;
			thr_num = _set.size();

			LoadData2 p(pool.get());
						
			if (false == p.parse(ut, d.pool, buf.get(), buf_len, simdjson_imple_, length, start, count_vec,
				thr_num)) // 0 : use all thread..
			{
				free(count_vec);
				return { false, 0 };
			}
			auto c = std::chrono::steady_clock::now();
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(c - b);

			log << info << dur.count() << "ms\n";
		}
		auto c = std::chrono::steady_clock::now();
		auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(c - _);
		log << info << dur.count() << "ms\n";

		free(count_vec);
		return  { true, length };
	}
	



	
	/*
	Object2 ParseObject(Document2* d, Wizard* wiz,  _simdjson::dom::parser_for_claujson* scanner, uint64_t start) {
		//Object2 obj(d);

		//Primitive2 key;

		auto* buf = scanner->raw_buf().get();
		auto* tokens = scanner->raw_implementation()->structural_indexes.get();

		// while() {
			// chk key
			// chk :
			// chk value
			// chk (,)
		// }

		//obj.add_element(key, value);

		return obj;
	}
	Array2 ParseArray(Document2* d, Wizard* wiz, _simdjson::dom::parser_for_claujson* scanner, uint64_t start) {
		return {d};
	}
	Primitive2 ParsePrimitive(Document2* d, Wizard* wiz, _simdjson::dom::parser_for_claujson* scanner, uint64_t start) {
		return {};
	}

	void Parse(Document2* d, Wizard* wiz, _simdjson::dom::parser_for_claujson* scanner, uint64_t start = 0) {
		auto* buf = scanner->raw_buf().get();
		auto* tokens = scanner->raw_implementation()->structural_indexes.get();
		
		if (buf[tokens[start]] == '{') {
			//ParseObject(d, wiz, scanner, start + 1);
		}
		else if (buf[tokens[0]] == '[') {
			//ParseArray(d, wiz, scanner, start + 1);
		}
		else {
			///ParsePrimitive(d, wiz,scanner, start + 1);
		}
	}

	// experimental...
	std::pair<bool, uint64_t> parser::parse2(const std::string& fileName, Document2*& d, uint64_t thr_num)
	{
		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);
		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		uint64_t length = 0;

		auto _ = std::chrono::steady_clock::now();

		uint64_t* count_vec = nullptr;
		{
			log << info << "simdjson-stage1 start\n";
			auto x = test_.load(fileName);

			if (x.error() != _simdjson::error_code::SUCCESS) {
				log << warn << "stage1 error : ";
				log << warn << x.error() << "\n";

				//ERROR(_simdjson::error_message(x.error()));

				return { false, 0 };
			}

			const auto& buf = test_.raw_buf();
			const auto buf_len = test_.raw_len();
			auto* simdjson_imple_ = test_.raw_implementation().get(); // token array.
			const auto token_len = simdjson_imple_->n_structural_indexes;
			const auto* tokens = simdjson_imple_->structural_indexes.get();
			

			Document2* dom = new Document2;
			Wizard* wiz = new Wizard(dom);

			{
				Parse(dom, wiz, &test_);
				// if(d) { } // ?
				d = dom;
			}
		}
		

		return { true, length };
	}
	*/
	
	std::pair<bool, uint64_t> parser::parse_str(StringView str, Document& d, uint64_t thr_num)
	{
		_Value& ut = d.Get();

		log << info << str << "\n";

		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);

		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		uint64_t length = 0;

		auto _ = std::chrono::steady_clock::now();
		uint64_t* count_vec = nullptr;
		{
		
			// not static?
			static _simdjson::dom::parser_for_claujson test;

			auto x = test.parse(str.data(), str.length());

			if (x.error() != _simdjson::error_code::SUCCESS) {
				log << warn << "stage1 error : ";
				log << warn << x.error() << "\n";

				return { false, 0 };
			}
			const auto& buf = test.raw_buf();
			const auto buf_len = test.raw_len();
			auto* simdjson_imple_ = test.raw_implementation().get();

			std_vector<int64_t> start(thr_num + 1);
			//std_vector<int> key;

			auto a = std::chrono::steady_clock::now();
			auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(a - _);
			log << info << dur.count() << "ms\n";


			{
				uint64_t how_many = simdjson_imple_->n_structural_indexes;
				length = how_many;

				start[0] = 0;
				for (uint64_t i = 1; i < thr_num; ++i) {
					start[i] = how_many / thr_num * i;
				}
			}

			if (length == 0) {
				log << warn << "empty string is not valid json";
				return { false, 0 };
			}

			auto b = std::chrono::steady_clock::now();
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(b - a);

			log << info << dur.count() << "ms\n";
			b = std::chrono::steady_clock::now();

			//if (use_all_function)
			
			std::set<uint64_t> _set;
			{

				

				//std_vector<uint64_t> start(thr_num + 1);
				std_vector<uint64_t> last(thr_num);

				std_vector<int> start_state(thr_num);
				std_vector<int> last_state(thr_num);
				for (auto& x : start_state) { x = -1; }
				for (auto& x : last_state) { x = -1; }

				for (uint64_t i = 1; i < thr_num; ++i) {
					uint64_t middle = length / thr_num * i;
					for (uint64_t i = middle; i < length; ++i) {
						if (buf[simdjson_imple_->structural_indexes[i]] == ',') {
							middle = i; _set.insert(i); break;
						}

						if (i == length - 1) {
							middle = length;
						}
					}
				}

				_set.insert(0);

				start.resize(1 + _set.size());
				last.resize(_set.size());

				int count = 0;
				for (auto x : _set) {
					start[count] = x;
					++count;
				}
				start[_set.size()] = length - 1;

				for (uint64_t i = 0; i < _set.size(); ++i) {
					last[i] = start[i + 1];
				}

				std_vector<Vector<int8_t>> is_array(_set.size()), is_virtual_array(_set.size());
				std_vector<std::future<bool>> thr_result(_set.size());
				count_vec = (uint64_t*)malloc(length * sizeof(uint64_t));
				if (!count_vec) {
					log << "malloc fail in parse_str function.";
					return { false, -55 };
				}
				for (uint64_t i = 0; i < _set.size(); ++i) {
					thr_result[i] = pool->enqueue(is_valid2, std::ref(test), start[i], last[i], &start_state[i], &last_state[i],
						&is_array[i], &is_virtual_array[i], count_vec);
				}
				std_vector<int> vec(_set.size());

				for (uint64_t i = 0; i < _set.size(); ++i) {
					vec[i] = (int)thr_result[i].get();
				}

				bool result = true;

				for (uint64_t i = 0; i < vec.size(); ++i) {
					if (vec[i] == false) {
						free(count_vec); 
						return { false, -1 };
					}
				}

				for (uint64_t i = 0; i < _set.size() - 1; ++i) {
					if (start_state[i + 1] != last_state[i]) {
						free(count_vec); 
						return { false, -2 };
					}
				}

				if (is_virtual_array[0].empty() == false) { // first block has no virtual array or virtual object.!
					free(count_vec); 
					return { false, -3 };
				}

				for (uint64_t i = 1; i < _set.size(); ++i) {
					if (false == is_virtual_array[i].empty()) {
						//  
						if (is_array[0].size() >= is_virtual_array[i].size()) {
							for (uint64_t j = 0; j < is_virtual_array[i].size(); ++j) {
								if (is_array[0].back() != is_virtual_array[i][j]) {
									free(count_vec);
									return { false, -3 };
								}
								is_array[0].pop_back();
							}
						}
						else {
							free(count_vec); 
							return { false, -3 };
						}
					}

					for (uint64_t x = 0; x < is_array[i].size(); ++x) {
						is_array[0].push_back(is_array[i][x]);
					}
					
					//is_array[0].insert(is_array[0].end(), is_array[i].begin(), is_array[i].end());
				}

				if (false == is_array[0].empty()) {
					free(count_vec); 
					return { false, -4 };

				}
			}
			//else {
			//	if (!is_valid(test, length)) {
			//		free(count_vec); return { false, 0 };
			//	}
			//}

			dur = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - b);
			log << info << dur.count() << "ms\n";

			b = std::chrono::steady_clock::now();

			start[_set.size()] = length;
			thr_num = _set.size();

			LoadData2 p(pool.get());

			if (false == p.parse(ut, d.pool, buf.get(), buf_len, simdjson_imple_, length, start, count_vec,
				thr_num)) // 0 : use all thread..
			{
				free(count_vec);
				return { false, 0 };
			}
			auto c = std::chrono::steady_clock::now();
			dur = std::chrono::duration_cast<std::chrono::milliseconds>(c - b);
			log << info << dur.count() << "ms\n";
		}
		auto c = std::chrono::steady_clock::now();
		auto dur = std::chrono::duration_cast<std::chrono::milliseconds>(c - _);
		log << info << dur.count() << "ms\n";

		free(count_vec);
		return  { true, length };
	}

#if __cpp_lib_char8_t
	// C++20~
	std::pair<bool, uint64_t> parser::parse_str(std::u8string_view str, Document& d, uint64_t thr_num) {
		return parse_str(StringView(reinterpret_cast<const char*>(str.data()), str.size()), d, thr_num);
	}
#endif

	writer::writer(int thr_num) {
		pool = pool_init(thr_num);
	}
		
	std::string writer::write_to_str(const _Value& global, bool pretty) {
		LoadData2 p(pool.get()); 
		return p.write_to_str(global, pretty);
	}

	std::string writer::write_to_str2(const _Value& global, bool pretty) {
		LoadData2 p(pool.get());
		return p.write_to_str2(global, pretty);
	}

	void writer::write(const std::string& fileName, const _Value& global, bool pretty) {
		LoadData2 p(pool.get());
		p.write(fileName, global, pretty, false);
	}

	void writer::write_parallel(Arena* memory_pool, const std::string& fileName, _Value& j, uint64_t thr_num, bool pretty) {
		LoadData2 p(pool.get()); 
		p.write_parallel(memory_pool, fileName, j, thr_num, pretty);
	}
	void writer::write_parallel2(const std::string& fileName, const _Value& j, uint64_t thr_num, bool pretty) {
		LoadData2 p(pool.get()); 
		p.write_parallel2(fileName, j, thr_num, pretty);
	}

	static std::string escape_for_json_pointer(std::string str) {
		// 1. ~ -> ~0
		// 2. / -> ~1
		
		{
			uint64_t idx = 0;
			idx = str.find('~');
			while (idx != std::string::npos) {
				str = str.replace(str.begin() + idx, str.begin() + idx + 1, "~0");
				idx = str.find("~", idx + 2);
			}
		}

		{
			uint64_t idx = 0;
			idx = str.find('/');
			while (idx != std::string::npos) {
				str = str.replace(str.begin() + idx, str.begin() + idx + 1, "~1");
				idx = str.find('/', idx + 2);
			}
		}

		return str;
	}

	static _Value _diff(Arena* pool, const _Value& x, const _Value& y, 
		std_vector<_Value>& route) {
		_Value result;
		{
			_Value temp = Array::Make(pool);
			if (temp.as_array() == nullptr) {
				return _Value(nullptr, false);
			}
			result = std::move(temp);
		}

		Array* j = result.as_array();

		if (x == y) {
			return result;
		}

		static Document d;
		static const _Value _op_str = _Value(d.GetAllocator(), "op"sv);
		static const _Value _path_str = _Value(d.GetAllocator(), "path"sv);
		static const _Value _value_str = _Value(d.GetAllocator(), "value"sv);
		static const _Value _key_str = _Value(d.GetAllocator(), "key"sv);
		static const _Value _last_key_str = _Value(d.GetAllocator(), "last_key"sv);
		static const _Value _last_idx_str = _Value(d.GetAllocator(), "last_idx"sv);
		static const _Value _replace_str = _Value(d.GetAllocator(), "replace"sv);
		static const _Value _remove_str = _Value(d.GetAllocator(), "remove"sv);
		static const _Value _add_str = _Value(d.GetAllocator(), "add"sv);
	
		if (x.type() != y.type()) {
			_Value obj = Object::Make(pool);
			
			if (obj.as_object() == nullptr) {
				//clean(result);
				return _Value(nullptr, false);
			}

			obj.as_object()->add_element(_op_str.clone(pool), 
				_replace_str.clone(pool));
			{
				_Value temp = Array::Make(pool);
				if (temp.as_array() == nullptr) {
					//clean(result);
					return _Value(nullptr, false);
				}
				for (uint64_t i = 0; i < route.size(); ++i) {
					temp.as_array()->add_element(route[i].clone(pool));
				}
				obj.as_object()->add_element(_path_str.clone(pool), 
					std::move(temp));
			}
			
			obj.as_object()->add_element(_value_str.clone(pool), 
				_Value(y.clone(pool)));

			j->add_element(std::move(obj));
			return result;
		}

	

		switch (x.type()) {
		case _ValueType::ARRAY:
		case _ValueType::OBJECT:
		{
			const _Value& jx = x;
			const _Value& jy = y;

			if (jx.is_array()) {
				uint64_t i = 0;
				uint64_t sz_x = jx.as_array()->get_data_size();
				uint64_t sz_y = jy.as_array()->get_data_size();

				for (; i < sz_x && i < sz_y; ++i) {
					route.push_back(_Value(i));

					_Value inner_diff = _diff(pool, 
						jx.as_array()->get_value_list(i), jy.as_array()->get_value_list(i), route);

					route.pop_back();

					{
						Array* w = inner_diff.as_array();
						uint64_t sz_w = w->get_data_size();

						for (uint64_t t = 0; t < sz_w; ++t) {
							_Value temp = std::move(w->get_value_list(t));
							if (temp.is_array()) {
								j->add_element(_Value(temp.as_array()));
							}
							else if (temp.is_object()) {
								j->add_element(_Value(temp.as_object()));
							}
						}

						//clean(inner_diff);
					}
				}

				if (i < sz_x) {
					for (uint64_t _i = sz_x; _i > i; --_i) {
						_Value obj = Object::Make(pool);
						
						if (obj.as_object() == nullptr) {
							//clean(result);
							return _Value(nullptr, false);
						}

						obj.as_object()->add_element(_op_str.clone(pool),
							_remove_str.clone(pool));

						{
							_Value temp = Array::Make(pool);
							
							if (temp.as_array() == nullptr) {
								//clean(result);
								return _Value(nullptr, false);
							}
							for (uint64_t i = 0; i < route.size(); ++i) {
								temp.as_array()->add_element(route[i].clone(pool));
							}
							obj.as_object()->add_element(_path_str.clone(pool), std::move(temp));
						}

						//obj->add_element(_path_str.clone(pool), _Value(route));

						obj.as_object()->add_element(_last_idx_str.clone(pool), _Value(_i - 1));

						j->add_element(std::move(obj));
					}
				}
				else {
					for (; i < sz_y; ++i) {
						_Value obj = Object::Make(pool);
						
						if (obj.as_object() == nullptr) {
							//clean(result);
							return _Value(nullptr, false);
						}

						obj.as_object()->add_element(_op_str.clone(pool), _add_str.clone(pool));

						{
							_Value temp = Array::Make(pool);
							
							if (temp.as_array() == nullptr) {
								//clean(result);
								//delete obj;
								return _Value(nullptr, false);
							}
							for (uint64_t i = 0; i < route.size(); ++i) {
								temp.as_array()->add_element(route[i].clone(pool));
							}
							obj.as_object()->add_element(_path_str.clone(pool), std::move(temp));
						}
						//obj->add_element(_path_str.clone(pool), _Value(route));

						obj.as_object()->add_element(_value_str.clone(pool), _Value(jy.as_array()->get_value_list(i).clone(pool)));

						j->add_element(std::move(obj));
					}
				}
			}
			else if (jx.is_object()) {
				uint64_t sz_x = jx.as_object()->get_data_size();
				uint64_t sz_y = jy.as_object()->get_data_size();

				for (uint64_t i = sz_x; i > 0; --i) {
					const _Value& key = jx.as_object()->get_key_list(i - 1);
					uint64_t idx = jy.as_object()->find(key);
					if (idx != Object::npos) {
						route.push_back(key.clone(pool));
						
						_Value inner_diff = _diff(pool, (jx.as_object()->get_value_list(i - 1)), 
							jy.as_object()->get_value_list(idx), route);

						route.pop_back();

						{
							Array* w = inner_diff.as_array();
							uint64_t sz_w = w->get_data_size();

							for (uint64_t t = 0; t < sz_w; ++t) {
								_Value temp = std::move(w->get_value_list(t));
								if (temp.is_array()) {
									j->add_element(_Value(temp.as_array()));
								}
								else if (temp.is_object()) {
									j->add_element(_Value(temp.as_object()));
								}
							}

						//	clean(inner_diff);
						}
					}
					else {
						_Value obj = Object::Make(pool);
						
						if (obj.as_object() == nullptr) {
							//clean(result);
							return _Value(nullptr, false);
						}
						obj.as_object()->add_element(_op_str.clone(pool), _remove_str.clone(pool));

						{
							_Value temp = Array::Make(pool);
							
							if (temp.as_array() == nullptr) {
								//clean(result);
								//delete obj;
								return _Value(nullptr, false);
							}
							for (uint64_t i = 0; i < route.size(); ++i) {
								temp.as_array()->add_element(route[i].clone(pool));
							}
							obj.as_object()->add_element(_path_str.clone(pool), std::move(temp));
						}
						
						//obj->add_element(_path_str.clone(pool), _Value(route));
						
						obj.as_object()->add_element(_last_key_str.clone(pool), key.clone(pool));

						j->add_element(std::move(obj));
					}
				}

				for (uint64_t i = 0; i < sz_y; ++i) {
					const _Value& key = jy.as_object()->get_key_list(i);
					uint64_t idx = jx.as_object()->find(key);
					if (idx == Object::npos) {
						_Value obj = Object::Make(pool);

						if (obj.as_object() == nullptr) {
							//clean(result);
							return _Value(nullptr, false);
						}

						obj.as_object()->add_element(_op_str.clone(pool), _add_str.clone(pool));

						{
							_Value temp = Array::Make(pool);

							if (temp.as_array() == nullptr) {
								//clean(result);
								//delete obj;
								return _Value(nullptr, false);
							}
							for (uint64_t i = 0; i < route.size(); ++i) {
								temp.as_array()->add_element(route[i].clone(pool));
							}
							obj.as_object()->add_element(_path_str.clone(pool), std::move(temp));
						}
						
						//obj->add_element(_path_str.clone(pool), _Value(route));
						
						obj.as_object()->add_element(_key_str.clone(pool), _Value(jy.as_object()->get_key_list(i).clone(pool)));
						obj.as_object()->add_element(_value_str.clone(pool), _Value(jy.as_object()->get_value_list(i).clone(pool)));

						j->add_element(std::move(obj));
					}
				}
			}
		}
		break;

		case _ValueType::BOOL:
		case _ValueType::NULL_:
		case _ValueType::FLOAT:
		case _ValueType::INT:
		case _ValueType::UINT:
		case _ValueType::STRING:
		case _ValueType::SHORT_STRING:
		{
			_Value obj = Object::Make(pool);
			
			if (obj.as_object() == nullptr) {
				//clean(result);
				return _Value(nullptr, false);
			}

			obj.as_object()->add_element(_op_str.clone(pool), _replace_str.clone(pool));

			{
				_Value temp = Array::Make(pool);
				
				if (temp.as_array() == nullptr) {
					//clean(result);
					//delete obj;
					return _Value(nullptr, false);
				}
				for (uint64_t i = 0; i < route.size(); ++i) {
					temp.as_array()->add_element(route[i].clone(pool));
				}
				obj.as_object()->add_element(_path_str.clone(pool), std::move(temp));
			}

			//obj->add_element(_path_str.clone(pool), _Value(route));
			
			obj.as_object()->add_element(_value_str.clone(pool), _Value(y.clone(pool)));

			j->add_element(std::move(obj));
			break;
		}
		}

		return result;
	}


	_Value diff(Arena* pool, const _Value& x, const _Value& y) {
		std_vector<_Value> vec;
		return _diff(pool, x, y, vec);
	}

	_Value& patch(Arena* pool, _Value& x, const _Value& diff) {
		static _Value unvalid_data(nullptr, false);

		const Array* j_diff = diff.as_array();

		if (!j_diff) {
			return unvalid_data;
		}

		static Document d;
		static const _Value _op_str = _Value(d.GetAllocator(), "op"sv);
		static const _Value _path_str = _Value(d.GetAllocator(), "path"sv);
		static const _Value _value_str = _Value(d.GetAllocator(), "value"sv);
		static const _Value _key_str = _Value(d.GetAllocator(), "key"sv);
		static const _Value _last_key_str = _Value(d.GetAllocator(), "last_key"sv);
		static const _Value _last_idx_str = _Value(d.GetAllocator(), "last_idx"sv);

		_Value& result = x;

		uint64_t sz_diff = j_diff->get_data_size();

		for (uint64_t i = 0; i < sz_diff; ++i) {
			const Object* obj = (const Object*)j_diff->get_value_list(i).as_object();
			uint64_t op_idx = obj->find(_op_str);
			uint64_t path_idx = obj->find(_path_str);
			uint64_t value_idx = obj->find(_value_str);
			uint64_t key_idx = obj->find(_key_str);

			if (op_idx == Object::npos) {
				clean(result);
				return unvalid_data;
			}

			if (path_idx == Object::npos) {
				clean(result);
				return unvalid_data;
			}

			if (obj->get_value_list(op_idx).str_val() == "replace"sv) {
				if (value_idx == Object::npos) {
					clean(result);
					return unvalid_data;
				}

				std_vector<_Value> vec;
				const Array* arr = obj->get_value_list(path_idx).as_array();
				if (arr == nullptr) {
					clean(result);
					return unvalid_data;
				}
				for (uint64_t i = 0; i < arr->size(); ++i) {
					vec.push_back(arr->get_value_list(i).clone(pool));
				}
				_Value& value = result.json_pointerB(vec);

				value = obj->get_value_list(value_idx).clone(pool); // clone -> std::move(~~)??
			}
			else if (obj->get_value_list(op_idx).str_val() == "remove"sv) {
				std_vector<_Value> vec;
				const Array* arr = obj->get_value_list(path_idx).as_array();
				if (arr == nullptr) {
					clean(result);
					return unvalid_data;
				}
				for (uint64_t i = 0; i < arr->size(); ++i) {
					vec.push_back(arr->get_value_list(i).clone(pool));
				}
				_Value& value = result.json_pointerB(vec);
				_Value& parent = value;

				// case : result.json_pointer returns root?
				if (!parent) {
					if (result.is_structured()) {
						clean(result);
					}
					result.clear(false);
				}
				else if (parent.is_array()) {
					uint64_t last_idx_idx = obj->find(_last_idx_str);
					if (last_idx_idx == Object::npos) {
						clean(result);
						return unvalid_data;
					}

					uint64_t last_idx = obj->get_value_list(last_idx_idx).uint_val();

					claujson::clean(parent.as_array()->get_value_list(last_idx));
					parent.as_array()->erase(last_idx);
				}
				else {
					uint64_t last_key_idx = obj->find(_last_key_str);
					if (last_key_idx == Object::npos) {
						clean(result);
						return unvalid_data;
					}

					const _Value& last_key = obj->get_value_list(last_key_idx);
					uint64_t _idx = parent.as_object()->find(last_key);
					claujson::clean(parent.as_object()->get_value_list(_idx));
					parent.as_object()->erase(_idx);
				}
			}
			else if (obj->get_value_list(op_idx).str_val() == "add"sv) {
				if (value_idx == Object::npos) {
					clean(result);
					return unvalid_data;
				}

				std_vector<_Value> vec;
				const Array* arr = obj->get_value_list(path_idx).as_array();
				if (arr == nullptr) {
					clean(result);
					return unvalid_data;
				}
				for (uint64_t i = 0; i < arr->size(); ++i) {
					vec.push_back(arr->get_value_list(i).clone(pool));
				}

				_Value& _ = result.json_pointerB(vec);

				if (_.is_array()) {
					StructuredPtr parent = (_.as_array()->get_parent());

					// case : result.json_pointer returns root?
					if (!parent) {
						result = obj->get_value_list(value_idx).clone(pool);
					}
					else if (parent.is_array()) {
						parent.add_array_element(obj->get_value_list(value_idx).clone(pool));
					}
					else if (parent.is_object()) {
						if (key_idx == Object::npos) {
							clean(result);
							return unvalid_data;
						}
						parent.add_object_element(obj->get_value_list(key_idx).clone(pool), obj->get_value_list(value_idx).clone(pool));
					}
				}
			}
		}

		return result;
	}

	void clean(_Value& x) {

		return;

		if (x.is_structured()) {
			if (x.is_array() && !x.as_array()->has_pool()) {
				delete x.as_array();
			}
			else if (x.is_array()) {
				x.as_array()->~Array();
			}
			else if (x.is_object() && !x.as_object()->has_pool()) {
				delete x.as_object();
			}
			else if (x.is_object()) {
				x.as_object()->~Object();
			}
			else if (x.is_partial_json()) {
				delete x.as_partial_json();
			}

			x.set_none();
		}
		else if(x.is_str()) {
			x.clear(true);
			x.set_none(); 
		}
	}

	[[nodiscard]]
	std::unique_ptr<ThreadPool> pool_init(int thr_num) {
		if (thr_num <= 0) {
			thr_num = std::max((int)std::thread::hardware_concurrency() - 2, 1);

		}
		if (thr_num <= 0) {
			thr_num = 1;
		}

		return std::make_unique<ThreadPool>(thr_num);
	}


	bool is_valid_string_in_json(StringView x) {
		const char* str = x.data();
		uint64_t len = x.size();
		const uint64_t block_size = 1024;


		uint8_t buf_src[block_size + _simdjson::_SIMDJSON_PADDING];
		uint8_t buf_dest[block_size + _simdjson::_SIMDJSON_PADDING];


		if (len >= block_size) {
			uint8_t* buf_src = (uint8_t*)calloc(len + 1 + _simdjson::_SIMDJSON_PADDING, sizeof(uint8_t));
			uint8_t* buf_dest = (uint8_t*)calloc(len + 1 + _simdjson::_SIMDJSON_PADDING, sizeof(uint8_t));
			if (!buf_src || !buf_dest) {
				if (buf_src) { free(buf_src); }
				if (buf_dest) { free(buf_dest); }

				return false;
			}
			memset(buf_src, '"', len + 1 + _simdjson::_SIMDJSON_PADDING);
			memset(buf_dest, '"', len + 1 + _simdjson::_SIMDJSON_PADDING);

			memcpy(buf_src, str, len);
			buf_src[len] = '"';

			// chk... fallback..
			{
				bool valid = _simdjson::validate_utf8(reinterpret_cast<char*>(buf_src), len);

				if (!valid) {
					free(buf_src);
					free(buf_dest);

					log << warn << "not valid utf8" << "\n";
					log << warn << "Error in Convert for string, validate...";
					return false;
				}
			}
			auto* x = _simdjson::parse_string(buf_src, buf_dest, false);
			if (x == nullptr) {
				free(buf_src);
				free(buf_dest);

				log << warn << "Error in Convert for string";
				return false;
			}
			else {
				//
			}

			free(buf_src);
			free(buf_dest);
		}
		else {
			memset(buf_src, '"', block_size + _simdjson::_SIMDJSON_PADDING);
			memset(buf_dest, '"', block_size + _simdjson::_SIMDJSON_PADDING);

			memcpy(buf_src, str, len);
			buf_src[len] = '"';

			{
				bool valid = _simdjson::validate_utf8(reinterpret_cast<char*>(buf_src), len);

				if (!valid) {
					log << warn << "not valid utf8" << "\n";
					log << warn << "Error in Convert for string, validate...";
					return false;
				}
			}
			auto* x = _simdjson::parse_string(buf_src, buf_dest, false);
			if (x == nullptr) {
				log << warn << "Error in Convert for string";
				return false;
			}
			else {
				//
			}
		}

		return true;
	}

	std::pair<bool, std::string> convert_to_string_in_json(StringView x) {
		const char* str = x.data();
		uint64_t len = x.size();
		const uint64_t block_size = 1024;


		uint8_t buf_src[block_size + _simdjson::_SIMDJSON_PADDING];
		uint8_t buf_dest[block_size + _simdjson::_SIMDJSON_PADDING];

		uint64_t string_length = 0;

		if (len >= block_size) {
			uint8_t* buf_src = (uint8_t*)calloc(len + 1 + _simdjson::_SIMDJSON_PADDING, sizeof(uint8_t));
			uint8_t* buf_dest = (uint8_t*)calloc(len + 1 + _simdjson::_SIMDJSON_PADDING, sizeof(uint8_t));
			if (!buf_src || !buf_dest) {
				if (buf_src) { free(buf_src); }
				if (buf_dest) { free(buf_dest); }

				return { false, "" };
			}
			memset(buf_src, '"', len + 1 + _simdjson::_SIMDJSON_PADDING);
			memset(buf_dest, '"', len + 1 + _simdjson::_SIMDJSON_PADDING);

			memcpy(buf_src, str, len);
			buf_src[len] = '"';

			// chk... fallback..
			{
				bool valid = _simdjson::validate_utf8(reinterpret_cast<char*>(buf_src), len);

				if (!valid) {
					free(buf_src);
					free(buf_dest);

					log << warn << "not valid utf8" << "\n";
					log << warn << "Error in Convert for string, validate...";
					return { false, "" };
				}
			}
			auto* x = _simdjson::parse_string(buf_src, buf_dest, false);
			if (x == nullptr) {
				free(buf_src);
				free(buf_dest);

				log << warn << "Error in Convert for string";
				return { false, "" };
			}
			else {
				*x = '\0';
				string_length = uint32_t(x - buf_dest);
			}

			std::string result(reinterpret_cast<char*>(buf_dest), string_length);

			free(buf_src);
			free(buf_dest);

			return { true, result };
		}
		else {
			memset(buf_src, '"', block_size + _simdjson::_SIMDJSON_PADDING);
			memset(buf_dest, '"', block_size + _simdjson::_SIMDJSON_PADDING);

			memcpy(buf_src, str, len);
			buf_src[len] = '"';

			{
				bool valid = _simdjson::validate_utf8(reinterpret_cast<char*>(buf_src), len);

				if (!valid) {
					log << warn << "not valid utf8" << "\n";
					log << warn << "Error in Convert for string, validate...";
					return { false, "" };
				}
			}
			auto* x = _simdjson::parse_string(buf_src, buf_dest, false);
			if (x == nullptr) {
				log << warn << "Error in Convert for string";
				return { false, "" };
			}
			else {
				*x = '\0';
				string_length = uint32_t(x - buf_dest);
			}

			return { true, std::string(reinterpret_cast<char*>(buf_dest), string_length) };
		}

	}

	/*
	bool convert_number(StringView x, claujson::_Value& data) {
		return ConvertNumber(data, x.data(), x.size(), true);
	}

	bool convert_string(StringView x, claujson::_Value& data) {
		return ConvertString(nullptr, data, x.data(), x.size());
	}
	*/
#if __cpp_lib_char8_t
	bool is_valid_string_in_json(std::u8string_view x) {
		return is_valid_string_in_json(StringView((const char*)x.data(), x.size()));
	}

	std::pair<bool, std::string> convert_to_string_in_json(std::u8string_view x) {
		return convert_to_string_in_json(StringView(reinterpret_cast<const char*>(x.data()), x.size()));
	}
#endif

}