cpp_src/core/cjson/jsondecoder.h - master - uzer_007/reindexer

cpp_src/core/cjson/jsondecoder.h
62 строки2 KB
madschemas
Update to version v5.12.0
20 мар 2026, 08:17
20 мар 2026, 08:172eef2e6
#pragma once

#include "core/payload/payloadiface.h"
#include "gason/gason.h"

namespace reindexer {

class FloatVectorsHolderVector;

namespace builders {
class CJsonBuilder;
}  // namespace builders
using builders::CJsonBuilder;

namespace item_fields_validator {

class SparseValidator;
class SparseArrayValidator;

}  // namespace item_fields_validator

class [[nodiscard]] JsonDecoder {
public:
	explicit JsonDecoder(TagsMatcher& tagsMatcher, FloatVectorsHolderVector& floatVectorsHolder, ScalarIndexesSetT& objectScalarIndexes,
						 const FieldsSet* filter = nullptr) noexcept
		: tagsMatcher_(tagsMatcher), filter_(filter), floatVectorsHolder_(floatVectorsHolder), objectScalarIndexes_(objectScalarIndexes) {}
	Error Decode(Payload& pl, WrSerializer& wrSer, const gason::JsonValue& v) noexcept;
	void Decode(std::string_view json, CJsonBuilder&, const TagsPath& fieldPath);

private:
	struct [[nodiscard]] HeteroArrayFastAnalizeResult {
		bool isHetero_{false};
		size_t outterSize_{0};
	};
	struct [[nodiscard]] HeteroArrayAnalizeResult {
		bool isHetero_{false};
		size_t outterSize_{0};
		size_t fullSize_{0};
	};
	HeteroArrayAnalizeResult analizeHeteroArray(const gason::JsonValue& array) const;
	HeteroArrayFastAnalizeResult fastAnalizeHeteroArray(const gason::JsonValue& array) const;
	void decodeHeteroArray(Payload&, CJsonBuilder&, const gason::JsonValue& array, int indexNumber, int& pos, KeyValueType fieldType,
						   std::string_view fieldName) const;
	void decodeJsonObject(const gason::JsonValue& root, CJsonBuilder&);
	void decodeJsonObject(Payload&, CJsonBuilder&, const gason::JsonValue&, Matched);
	void decodeJson(Payload*, CJsonBuilder&, const gason::JsonValue&, TagName, Matched);
	void decodeJsonSparse(Payload*, CJsonBuilder&, const gason::JsonValue&, TagName, Matched,
						  const item_fields_validator::SparseValidator&);
	void decodeJsonArraySparse(Payload*, CJsonBuilder&, const gason::JsonValue&, TagName, Matched,
							   item_fields_validator::SparseArrayValidator&);
	InArray isInArray() const noexcept { return InArray(arrayLevel_ > 0); }

	TagsMatcher& tagsMatcher_;
	TagsPath tagsPath_;
	const FieldsSet* filter_{nullptr};
	int32_t arrayLevel_{0};

	FloatVectorsHolderVector& floatVectorsHolder_;
	ScalarIndexesSetT& objectScalarIndexes_;
};

}  // namespace reindexer