| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 // Make sure stdint.h includes SIZE_MAX. (See C89, p259, footnote 221.) |
| 6 #ifndef __STDC_LIMIT_MACROS |
| 7 #define __STDC_LIMIT_MACROS 1 |
| 8 #endif |
| 9 |
| 5 #include "components/domain_reliability/config.h" | 10 #include "components/domain_reliability/config.h" |
| 6 | 11 |
| 12 #include <stdint.h> |
| 13 |
| 7 #include "base/json/json_reader.h" | 14 #include "base/json/json_reader.h" |
| 8 #include "base/json/json_value_converter.h" | 15 #include "base/json/json_value_converter.h" |
| 9 #include "base/rand_util.h" | 16 #include "base/rand_util.h" |
| 10 #include "base/strings/string_util.h" | 17 #include "base/strings/string_util.h" |
| 11 | 18 |
| 12 namespace { | 19 namespace { |
| 13 | 20 |
| 14 bool ConvertURL(const base::StringPiece& string_piece, GURL* url) { | 21 bool ConvertURL(const base::StringPiece& string_piece, GURL* url) { |
| 15 *url = GURL(string_piece.as_string()); | 22 *url = GURL(string_piece.as_string()); |
| 16 return url->is_valid(); | 23 return url->is_valid(); |
| 17 } | 24 } |
| 18 | 25 |
| 19 bool IsValidSampleRate(double p) { return p >= 0.0 && p <= 1.0; } | 26 bool IsValidSampleRate(double p) { return p >= 0.0 && p <= 1.0; } |
| 20 | 27 |
| 21 } // namespace | 28 } // namespace |
| 22 | 29 |
| 23 namespace domain_reliability { | 30 namespace domain_reliability { |
| 24 | 31 |
| 25 DomainReliabilityConfig::Resource::Resource() {} | 32 // static |
| 33 const size_t DomainReliabilityConfig::kInvalidResourceIndex = SIZE_MAX; |
| 26 | 34 |
| 35 DomainReliabilityConfig::Resource::Resource() { |
| 36 } |
| 27 DomainReliabilityConfig::Resource::~Resource() {} | 37 DomainReliabilityConfig::Resource::~Resource() {} |
| 28 | 38 |
| 29 bool DomainReliabilityConfig::Resource::MatchesUrlString( | 39 bool DomainReliabilityConfig::Resource::MatchesUrl(const GURL& url) const { |
| 30 const std::string& url_string) const { | 40 const std::string& spec = url.spec(); |
| 41 |
| 31 ScopedVector<std::string>::const_iterator it; | 42 ScopedVector<std::string>::const_iterator it; |
| 32 | |
| 33 for (it = url_patterns.begin(); it != url_patterns.end(); it++) { | 43 for (it = url_patterns.begin(); it != url_patterns.end(); it++) { |
| 34 if (MatchPattern(url_string, **it)) | 44 if (MatchPattern(spec, **it)) |
| 35 return true; | 45 return true; |
| 36 } | 46 } |
| 37 | 47 |
| 38 return false; | 48 return false; |
| 39 } | 49 } |
| 40 | 50 |
| 41 bool DomainReliabilityConfig::Resource::DecideIfShouldReportRequest( | 51 bool DomainReliabilityConfig::Resource::DecideIfShouldReportRequest( |
| 42 bool success) const { | 52 bool success) const { |
| 43 double sample_rate = success ? success_sample_rate : failure_sample_rate; | 53 double sample_rate = success ? success_sample_rate : failure_sample_rate; |
| 54 DCHECK(IsValidSampleRate(sample_rate)); |
| 44 return base::RandDouble() < sample_rate; | 55 return base::RandDouble() < sample_rate; |
| 45 } | 56 } |
| 46 | 57 |
| 47 // static | 58 // static |
| 48 void DomainReliabilityConfig::Resource::RegisterJSONConverter( | 59 void DomainReliabilityConfig::Resource::RegisterJSONConverter( |
| 49 base::JSONValueConverter<DomainReliabilityConfig::Resource>* converter) { | 60 base::JSONValueConverter<DomainReliabilityConfig::Resource>* converter) { |
| 50 converter->RegisterStringField("resource_name", &Resource::name); | 61 converter->RegisterStringField("resource_name", &Resource::name); |
| 51 converter->RegisterRepeatedString("url_patterns", &Resource::url_patterns); | 62 converter->RegisterRepeatedString("url_patterns", &Resource::url_patterns); |
| 52 converter->RegisterDoubleField("success_sample_rate", | 63 converter->RegisterDoubleField("success_sample_rate", |
| 53 &Resource::success_sample_rate); | 64 &Resource::success_sample_rate); |
| 54 converter->RegisterDoubleField("failure_sample_rate", | 65 converter->RegisterDoubleField("failure_sample_rate", |
| 55 &Resource::failure_sample_rate); | 66 &Resource::failure_sample_rate); |
| 56 } | 67 } |
| 57 | 68 |
| 58 bool DomainReliabilityConfig::Resource::IsValid() const { | 69 bool DomainReliabilityConfig::Resource::IsValid() const { |
| 59 return !name.empty() && !url_patterns.empty() && | 70 return !name.empty() && !url_patterns.empty() && |
| 60 IsValidSampleRate(success_sample_rate) && | 71 IsValidSampleRate(success_sample_rate) && |
| 61 IsValidSampleRate(failure_sample_rate); | 72 IsValidSampleRate(failure_sample_rate); |
| 62 } | 73 } |
| 63 | 74 |
| 64 DomainReliabilityConfig::Collector::Collector() {} | 75 DomainReliabilityConfig::Collector::Collector() {} |
| 65 | |
| 66 DomainReliabilityConfig::Collector::~Collector() {} | 76 DomainReliabilityConfig::Collector::~Collector() {} |
| 67 | 77 |
| 68 // static | 78 // static |
| 69 void DomainReliabilityConfig::Collector::RegisterJSONConverter( | 79 void DomainReliabilityConfig::Collector::RegisterJSONConverter( |
| 70 base::JSONValueConverter<DomainReliabilityConfig::Collector>* converter) { | 80 base::JSONValueConverter<DomainReliabilityConfig::Collector>* converter) { |
| 71 converter->RegisterCustomField<GURL>("upload_url", &Collector::upload_url, | 81 converter->RegisterCustomField<GURL>("upload_url", &Collector::upload_url, |
| 72 &ConvertURL); | 82 &ConvertURL); |
| 73 } | 83 } |
| 74 | 84 |
| 75 bool DomainReliabilityConfig::Collector::IsValid() const { | 85 bool DomainReliabilityConfig::Collector::IsValid() const { |
| 76 return upload_url.is_valid(); | 86 return upload_url.is_valid(); |
| 77 } | 87 } |
| 78 | 88 |
| 79 DomainReliabilityConfig::DomainReliabilityConfig() : valid_until(0.0) {} | 89 DomainReliabilityConfig::DomainReliabilityConfig() : valid_until(0.0) {} |
| 80 | |
| 81 DomainReliabilityConfig::~DomainReliabilityConfig() {} | 90 DomainReliabilityConfig::~DomainReliabilityConfig() {} |
| 82 | 91 |
| 83 // static | 92 // static |
| 84 scoped_ptr<const DomainReliabilityConfig> DomainReliabilityConfig::FromJSON( | 93 scoped_ptr<const DomainReliabilityConfig> DomainReliabilityConfig::FromJSON( |
| 85 const base::StringPiece& json) { | 94 const base::StringPiece& json) { |
| 86 scoped_ptr<base::Value> value(base::JSONReader::Read(json)); | 95 scoped_ptr<base::Value> value(base::JSONReader::Read(json)); |
| 87 if (!value) | 96 base::JSONValueConverter<DomainReliabilityConfig> converter; |
| 97 DomainReliabilityConfig* config = new DomainReliabilityConfig(); |
| 98 |
| 99 // If we can parse and convert the JSON into a valid config, return that. |
| 100 if (value && converter.Convert(*value, config) && config->IsValid()) |
| 101 return scoped_ptr<const DomainReliabilityConfig>(config); |
| 102 else |
| 88 return scoped_ptr<const DomainReliabilityConfig>(); | 103 return scoped_ptr<const DomainReliabilityConfig>(); |
| 89 | |
| 90 DomainReliabilityConfig* config = new DomainReliabilityConfig(); | |
| 91 base::JSONValueConverter<DomainReliabilityConfig> converter; | |
| 92 if (!converter.Convert(*value, config)) { | |
| 93 return scoped_ptr<const DomainReliabilityConfig>(); | |
| 94 } | |
| 95 | |
| 96 if (!config->IsValid()) | |
| 97 return scoped_ptr<const DomainReliabilityConfig>(); | |
| 98 | |
| 99 return scoped_ptr<const DomainReliabilityConfig>(config); | |
| 100 } | 104 } |
| 101 | 105 |
| 102 bool DomainReliabilityConfig::IsValid() const { | 106 bool DomainReliabilityConfig::IsValid() const { |
| 103 if (valid_until == 0.0 || domain.empty() || version.empty() || | 107 if (valid_until == 0.0 || domain.empty() || version.empty() || |
| 104 resources.empty() || collectors.empty()) { | 108 resources.empty() || collectors.empty()) { |
| 105 return false; | 109 return false; |
| 106 } | 110 } |
| 107 | 111 |
| 108 for (size_t i = 0; i < resources.size(); ++i) { | 112 for (size_t i = 0; i < resources.size(); ++i) { |
| 109 if (!resources[i]->IsValid()) | 113 if (!resources[i]->IsValid()) |
| 110 return false; | 114 return false; |
| 111 } | 115 } |
| 112 | 116 |
| 113 for (size_t i = 0; i < collectors.size(); ++i) { | 117 for (size_t i = 0; i < collectors.size(); ++i) { |
| 114 if (!collectors[i]->IsValid()) | 118 if (!collectors[i]->IsValid()) |
| 115 return false; | 119 return false; |
| 116 } | 120 } |
| 117 | 121 |
| 118 return true; | 122 return true; |
| 119 } | 123 } |
| 120 | 124 |
| 121 bool DomainReliabilityConfig::IsExpired(base::Time now) const { | 125 bool DomainReliabilityConfig::IsExpired(base::Time now) const { |
| 126 DCHECK_NE(0.0, valid_until); |
| 122 base::Time valid_until_time = base::Time::FromDoubleT(valid_until); | 127 base::Time valid_until_time = base::Time::FromDoubleT(valid_until); |
| 123 return now > valid_until_time; | 128 return now > valid_until_time; |
| 124 } | 129 } |
| 125 | 130 |
| 126 int DomainReliabilityConfig::GetResourceIndexForUrl(const GURL& url) const { | 131 size_t DomainReliabilityConfig::GetResourceIndexForUrl(const GURL& url) const { |
| 127 const std::string& url_string = url.spec(); | 132 // Removes username, password, and fragment. |
| 133 GURL sanitized_url = url.GetAsReferrer(); |
| 128 | 134 |
| 129 for (size_t i = 0; i < resources.size(); ++i) { | 135 for (size_t i = 0; i < resources.size(); ++i) { |
| 130 if (resources[i]->MatchesUrlString(url_string)) | 136 if (resources[i]->MatchesUrl(sanitized_url)) |
| 131 return static_cast<int>(i); | 137 return i; |
| 132 } | 138 } |
| 133 | 139 |
| 134 return -1; | 140 return kInvalidResourceIndex; |
| 135 } | 141 } |
| 136 | 142 |
| 137 // static | 143 // static |
| 138 void DomainReliabilityConfig::RegisterJSONConverter( | 144 void DomainReliabilityConfig::RegisterJSONConverter( |
| 139 base::JSONValueConverter<DomainReliabilityConfig>* converter) { | 145 base::JSONValueConverter<DomainReliabilityConfig>* converter) { |
| 140 converter->RegisterStringField("config_version", | 146 converter->RegisterStringField("config_version", |
| 141 &DomainReliabilityConfig::version); | 147 &DomainReliabilityConfig::version); |
| 142 converter->RegisterDoubleField("config_valid_until", | 148 converter->RegisterDoubleField("config_valid_until", |
| 143 &DomainReliabilityConfig::valid_until); | 149 &DomainReliabilityConfig::valid_until); |
| 144 converter->RegisterStringField("monitored_domain", | 150 converter->RegisterStringField("monitored_domain", |
| 145 &DomainReliabilityConfig::domain); | 151 &DomainReliabilityConfig::domain); |
| 146 converter->RegisterRepeatedMessage("monitored_resources", | 152 converter->RegisterRepeatedMessage("monitored_resources", |
| 147 &DomainReliabilityConfig::resources); | 153 &DomainReliabilityConfig::resources); |
| 148 converter->RegisterRepeatedMessage("collectors", | 154 converter->RegisterRepeatedMessage("collectors", |
| 149 &DomainReliabilityConfig::collectors); | 155 &DomainReliabilityConfig::collectors); |
| 150 } | 156 } |
| 151 | 157 |
| 152 } // namespace domain_reliability | 158 } // namespace domain_reliability |
| OLD | NEW |