#include <grpc/support/port_platform.h>
+#include "absl/strings/numbers.h"
+#include "absl/strings/str_cat.h"
+
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/json/json.h"
// Returns true on success, false otherwise.
bool ParseDurationFromJson(const Json& field, grpc_millis* duration);
+//
+// Helper functions for extracting types from JSON.
+// Return true on success, false otherwise. If an error is encountered during
+// parsing, a descriptive error is appended to \a error_list.
+//
+template <typename NumericType, typename ErrorVectorType>
+inline bool ExtractJsonNumber(const Json& json, const std::string& field_name,
+ NumericType* output,
+ ErrorVectorType* error_list) {
+ static_assert(std::is_integral<NumericType>::value, "Integral required");
+ if (json.type() != Json::Type::NUMBER) {
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:type should be NUMBER")));
+ return false;
+ }
+ if (!absl::SimpleAtoi(json.string_value(), output)) {
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:failed to parse.")));
+ return false;
+ }
+ return true;
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonBool(const Json& json, const std::string& field_name,
+ bool* output, ErrorVectorType* error_list) {
+ switch (json.type()) {
+ case Json::Type::JSON_TRUE:
+ *output = true;
+ return true;
+ case Json::Type::JSON_FALSE:
+ *output = false;
+ return true;
+ default:
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:type should be BOOLEAN")));
+ return false;
+ }
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonString(const Json& json, const std::string& field_name,
+ std::string* output,
+ ErrorVectorType* error_list) {
+ if (json.type() != Json::Type::STRING) {
+ *output = "";
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:type should be STRING")));
+ return false;
+ }
+ *output = json.string_value();
+ return true;
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonArray(const Json& json, const std::string& field_name,
+ const Json::Array** output,
+ ErrorVectorType* error_list) {
+ if (json.type() != Json::Type::ARRAY) {
+ *output = nullptr;
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:type should be ARRAY")));
+ return false;
+ }
+ *output = &json.array_value();
+ return true;
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonObject(const Json& json, const std::string& field_name,
+ const Json::Object** output,
+ ErrorVectorType* error_list) {
+ if (json.type() != Json::Type::OBJECT) {
+ *output = nullptr;
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:type should be OBJECT")));
+ return false;
+ }
+ *output = &json.object_value();
+ return true;
+}
+
+template <typename NumericType, typename ErrorVectorType>
+inline bool ExtractJsonType(const Json& json, const std::string& field_name,
+ NumericType* output, ErrorVectorType* error_list) {
+ return ExtractJsonNumber(json, field_name, output, error_list);
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonType(const Json& json, const std::string& field_name,
+ bool* output, ErrorVectorType* error_list) {
+ return ExtractJsonBool(json, field_name, output, error_list);
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonType(const Json& json, const std::string& field_name,
+ std::string* output, ErrorVectorType* error_list) {
+ return ExtractJsonString(json, field_name, output, error_list);
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonType(const Json& json, const std::string& field_name,
+ const Json::Array** output,
+ ErrorVectorType* error_list) {
+ return ExtractJsonArray(json, field_name, output, error_list);
+}
+
+template <typename ErrorVectorType>
+inline bool ExtractJsonType(const Json& json, const std::string& field_name,
+ const Json::Object** output,
+ ErrorVectorType* error_list) {
+ return ExtractJsonObject(json, field_name, output, error_list);
+}
+
+template <typename T, typename ErrorVectorType>
+inline bool ParseJsonObjectField(const Json::Object& object,
+ const std::string& field_name, T* output,
+ ErrorVectorType* error_list,
+ bool required = true) {
+ auto it = object.find(field_name);
+ if (it == object.end()) {
+ if (required) {
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:does not exist.")));
+ }
+ return false;
+ }
+ auto& child_object_json = it->second;
+ return ExtractJsonType(child_object_json, field_name, output, error_list);
+}
+
+template <typename ErrorVectorType>
+inline bool ParseJsonObjectFieldAsDuration(const Json::Object& object,
+ const std::string& field_name,
+ grpc_millis* output,
+ ErrorVectorType* error_list,
+ bool required = true) {
+ auto it = object.find(field_name);
+ if (it == object.end()) {
+ if (required) {
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name, " error:does not exist.")));
+ }
+ return false;
+ }
+ if (!ParseDurationFromJson(it->second, output)) {
+ *output = GRPC_MILLIS_INF_PAST;
+ error_list->push_back(GRPC_ERROR_CREATE_FROM_CPP_STRING(
+ absl::StrCat("field:", field_name,
+ " error:type should be STRING of the form given by "
+ "google.proto.Duration.")));
+ return false;
+ }
+ return true;
+}
+
} // namespace grpc_core
#endif // GRPC_CORE_LIB_JSON_JSON_UTIL_H
projects / platform / upstream / grpc.git / blobdiff