Method queryResultsJSON

cpp_src/server/httpserver.cc:1516–1613

}

int HTTPServer::queryResultsJSON(http::Context& ctx, reindexer::QueryResults& res, const IQRSerializingOption& qrOption, bool withColumns,
								 int width) {
	const auto offset = qrOption.ExternalOffset();
	const auto limit = qrOption.ExternalLimit();

	auto ser = makeRestrictedWrSerializer(ctx);
	JsonBuilder builder(ser);

	auto iarray = builder.Array(kParamItems);
	auto it = offset < res.Count() ? (res.begin() + offset) : res.end();
	std::vector<std::string> jsonData;
	if (withColumns) {
		size_t size = res.Count();
		if (limit > offset && limit - offset < size) {
			size = limit - offset;
		}
		jsonData.reserve(size);
	}
	WrSerializer itemSer;
	std::optional<Reindexer> db;
	auto cjsonViewer = [this, &res, &ctx, &db](std::string_view cjson) {
		if (!db.has_value()) {
			db.emplace(getDB<kRoleDataRead>(ctx));
		}
		auto item = db->NewItem(res.GetNamespaces()[0]);
		const auto err = item.FromCJSON(cjson);
		if (!err.ok()) {
			throw Error(err.code(), "Unable to parse CJSON for WAL item: {}", err.whatStr());
		}
		return std::string(item.GetJSON());
	};
	const bool isWALQuery = res.IsWALQuery();
	for (size_t i = 0; it != res.end() && i < limit; ++i, ++it) {
		if (!isWALQuery) {
			iarray.Raw("");
			if (withColumns) {
				itemSer.Reset();
				const auto err = it.GetJSON(itemSer, false);
				if (!err.ok()) {
					return jsonStatus(ctx, http::HttpStatus(err));
				}
				jsonData.emplace_back(itemSer.Slice());
				ser.Write(itemSer.Slice());
			} else {
				const auto err = it.GetJSON(ser, false);
				if (!err.ok()) {
					return jsonStatus(ctx, http::HttpStatus(err));
				}
			}
		} else {
			auto obj = iarray.Object();
			{
				auto lsnObj = obj.Object(kWALParamLsn);
				it.GetLSN().GetJSON(lsnObj);
			}
			if (!it.IsRaw()) {
				iarray.Raw(kWALParamItem, "");
				if (withColumns) {