Method queryResultsProtobuf

cpp_src/server/httpserver.cc:1749–1825

}

int HTTPServer::queryResultsProtobuf(http::Context& ctx, reindexer::QueryResults& res, const IQRSerializingOption& qrOption,
									 bool withColumns, int width) {
	auto ser = makeRestrictedWrSerializer(ctx);
	ProtobufBuilder protobufBuilder(ser);

	const auto offset = qrOption.ExternalOffset();
	const auto limit = qrOption.ExternalLimit();
	auto& lres = res.ToLocalQr();
	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);
	}
	for (size_t i = offset; i < lres.Count() && i < offset + limit; i++) {
		auto it = lres[i];
		auto err = it.GetProtobuf(ser);
		if (!err.ok()) {
			return protobufStatus(ctx, http::HttpStatus(err));
		}
		if (withColumns) {
			itemSer.Reset();
			err = it.GetJSON(itemSer, false);
			if (!err.ok()) {
				return protobufStatus(ctx, http::HttpStatus(err));
			}
			jsonData.emplace_back(itemSer.Slice());
		}
	}

	const TagName aggregationField = kProtoQueryResultsFields.at(kParamAggregations);
	for (auto& agg : res.GetAggregationResults()) {
		auto aggregation = protobufBuilder.Object(aggregationField);
		agg.GetProtobuf(ser);
		aggregation.End();
	}

	const TagName nsField = kProtoQueryResultsFields.at(kParamNamespaces);
	h_vector<std::string_view, 1> namespaces(res.GetNamespaces());
	for (auto ns : namespaces) {
		protobufBuilder.Put(nsField, ns);
	}

	protobufBuilder.Put(kProtoQueryResultsFields.at(kParamCacheEnabled), res.IsCacheEnabled() && !res.IsWALQuery());

	if (!res.GetExplainResults().empty()) {
		protobufBuilder.Put(kProtoQueryResultsFields.at(kParamExplain), res.GetExplainResults());
	}

	if (auto totalCount = qrOption.TotalCount(); totalCount.has_value()) {
		protobufBuilder.Put(kProtoQueryResultsFields.at(kParamTotalItems), int64_t(*totalCount));
	}
	if (auto queryTotalCount = qrOption.QueryTotalCount(); queryTotalCount.has_value()) {
		protobufBuilder.Put(kProtoQueryResultsFields.at(kParamQueryTotalItems), int64_t(*queryTotalCount));
	}