Method queryResultsMsgPack

cpp_src/server/httpserver.cc:1684–1747

}

int HTTPServer::queryResultsMsgPack(http::Context& ctx, reindexer::QueryResults& res, const IQRSerializingOption& qrOption,
									bool withColumns, int width) {
	int paramsToSend = 3;
	if (!res.GetAggregationResults().empty()) {
		++paramsToSend;
	}
	if (!res.GetExplainResults().empty()) {
		++paramsToSend;
	}
	if (withColumns) {
		++paramsToSend;
	}
	if (qrOption.TotalCount().has_value()) {
		++paramsToSend;
	}
	if (qrOption.QueryTotalCount().has_value()) {
		++paramsToSend;
	}

	auto ser = makeRestrictedWrSerializer(ctx);
	MsgPackBuilder msgpackBuilder(ser, ObjType::TypeObject, paramsToSend);

	const auto offset = qrOption.ExternalOffset();
	const auto limit = qrOption.ExternalLimit();
	WrSerializer itemSer;
	std::vector<std::string> jsonData;
	if (withColumns) {
		size_t size = res.Count();
		if (limit > offset && limit - offset < size) {
			size = limit - offset;
		}
		jsonData.reserve(size);
	}
	auto itemsArray = msgpackBuilder.Array(kParamItems, std::min(size_t(limit), size_t(res.Count() - offset)));
	auto it = res.begin() + offset;
	for (size_t i = 0; it != res.end() && i < limit; ++i, ++it) {
		auto err = it.GetMsgPack(ser, false);
		if (!err.ok()) {
			return msgpackStatus(ctx, http::HttpStatus(err));
		}
		if (withColumns) {
			itemSer.Reset();
			err = it.GetJSON(itemSer, false);
			if (!err.ok()) {
				return msgpackStatus(ctx, http::HttpStatus(err));
			}
			jsonData.emplace_back(itemSer.Slice());
		}
	}
	itemsArray.End();

	if (!res.GetAggregationResults().empty()) {
		auto& aggs = res.GetAggregationResults();
		auto aggregationsArray = msgpackBuilder.Array(kParamAggregations, aggs.size());
		for (auto& agg : aggs) {
			agg.GetMsgPack(ser);
		}
	}