1 // Copyright 2020 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "cast/protocol/castv2/validation.h"
6
7 #include <mutex> // NOLINT
8 #include <string>
9
10 #include "cast/protocol/castv2/receiver_schema_data.h"
11 #include "cast/protocol/castv2/streaming_schema_data.h"
12 #include "third_party/valijson/src/include/valijson/adapters/jsoncpp_adapter.hpp"
13 #include "third_party/valijson/src/include/valijson/schema.hpp"
14 #include "third_party/valijson/src/include/valijson/schema_parser.hpp"
15 #include "third_party/valijson/src/include/valijson/utils/jsoncpp_utils.hpp"
16 #include "third_party/valijson/src/include/valijson/validator.hpp"
17 #include "util/json/json_serialization.h"
18 #include "util/osp_logging.h"
19 #include "util/std_util.h"
20 #include "util/stringprintf.h"
21
22 namespace openscreen {
23 namespace cast {
24
25 namespace {
26
MapErrors(const valijson::ValidationResults & results)27 std::vector<Error> MapErrors(const valijson::ValidationResults& results) {
28 std::vector<Error> errors;
29 errors.reserve(results.numErrors());
30 for (const auto& result : results) {
31 const std::string context = Join(result.context, ", ");
32 errors.emplace_back(Error::Code::kJsonParseError,
33 StringPrintf("Node: %s, Message: %s", context.c_str(),
34 result.description.c_str()));
35 }
36 return errors;
37 }
38
LoadSchema(const char * schema_json,valijson::Schema * schema)39 void LoadSchema(const char* schema_json, valijson::Schema* schema) {
40 Json::Value root = json::Parse(schema_json).value();
41 valijson::adapters::JsonCppAdapter adapter(root);
42 valijson::SchemaParser parser;
43 parser.populateSchema(adapter, *schema);
44 }
45
Validate(const Json::Value & document,const valijson::Schema & schema)46 std::vector<Error> Validate(const Json::Value& document,
47 const valijson::Schema& schema) {
48 valijson::Validator validator;
49 valijson::adapters::JsonCppAdapter document_adapter(document);
50 valijson::ValidationResults results;
51 if (validator.validate(schema, document_adapter, &results)) {
52 return {};
53 }
54 return MapErrors(results);
55 }
56
57 } // anonymous namespace
Validate(const Json::Value & document,const Json::Value & schema_root)58 std::vector<Error> Validate(const Json::Value& document,
59 const Json::Value& schema_root) {
60 valijson::adapters::JsonCppAdapter adapter(schema_root);
61 valijson::Schema schema;
62 valijson::SchemaParser parser;
63 parser.populateSchema(adapter, schema);
64
65 return Validate(document, schema);
66 }
67
ValidateStreamingMessage(const Json::Value & message)68 std::vector<Error> ValidateStreamingMessage(const Json::Value& message) {
69 static valijson::Schema schema;
70 static std::once_flag flag;
71 std::call_once(flag, [] { LoadSchema(kStreamingSchema, &schema); });
72 return Validate(message, schema);
73 }
74
ValidateReceiverMessage(const Json::Value & message)75 std::vector<Error> ValidateReceiverMessage(const Json::Value& message) {
76 static valijson::Schema schema;
77 static std::once_flag flag;
78 std::call_once(flag, [] { LoadSchema(kReceiverSchema, &schema); });
79 return Validate(message, schema);
80 }
81
82 } // namespace cast
83 } // namespace openscreen
84