Vitaly Buka | 4615e0d | 2015-10-14 15:35:12 -0700 | [diff] [blame] | 1 | // Copyright 2015 The Weave Authors. All rights reserved. |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
Stefan Sauer | 2d16dfa | 2015-09-25 17:08:35 +0200 | [diff] [blame] | 5 | #include "src/config.h" |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 6 | |
| 7 | #include <set> |
| 8 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 9 | #include <base/bind.h> |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 10 | #include <base/guid.h> |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 11 | #include <base/json/json_reader.h> |
| 12 | #include <base/json/json_writer.h> |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 13 | #include <base/logging.h> |
| 14 | #include <base/strings/string_number_conversions.h> |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 15 | #include <base/values.h> |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 16 | #include <weave/enum_to_string.h> |
| 17 | |
Stefan Sauer | 2d16dfa | 2015-09-25 17:08:35 +0200 | [diff] [blame] | 18 | #include "src/privet/privet_types.h" |
| 19 | #include "src/string_utils.h" |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 20 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 21 | namespace weave { |
| 22 | |
| 23 | namespace config_keys { |
| 24 | |
Vitaly Buka | bced5af | 2015-10-12 17:42:30 -0700 | [diff] [blame] | 25 | const char kVersion[] = "version"; |
| 26 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 27 | const char kClientId[] = "client_id"; |
| 28 | const char kClientSecret[] = "client_secret"; |
| 29 | const char kApiKey[] = "api_key"; |
| 30 | const char kOAuthURL[] = "oauth_url"; |
| 31 | const char kServiceURL[] = "service_url"; |
| 32 | const char kName[] = "name"; |
| 33 | const char kDescription[] = "description"; |
| 34 | const char kLocation[] = "location"; |
| 35 | const char kLocalAnonymousAccessRole[] = "local_anonymous_access_role"; |
| 36 | const char kLocalDiscoveryEnabled[] = "local_discovery_enabled"; |
| 37 | const char kLocalPairingEnabled[] = "local_pairing_enabled"; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 38 | const char kRefreshToken[] = "refresh_token"; |
Johan Euphrosine | 312c2f5 | 2015-09-29 00:04:29 -0700 | [diff] [blame] | 39 | const char kCloudId[] = "cloud_id"; |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 40 | const char kDeviceId[] = "device_id"; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 41 | const char kRobotAccount[] = "robot_account"; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 42 | const char kLastConfiguredSsid[] = "last_configured_ssid"; |
Vitaly Buka | 8589b05 | 2015-09-29 00:46:14 -0700 | [diff] [blame] | 43 | const char kSecret[] = "secret"; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 44 | |
| 45 | } // namespace config_keys |
| 46 | |
Vitaly Buka | 0d7aac8 | 2015-11-16 23:02:24 -0800 | [diff] [blame] | 47 | const char kWeaveUrl[] = "https://www.googleapis.com/weave/v1/"; |
| 48 | const char kDeprecatedUrl[] = "https://www.googleapis.com/clouddevices/v1/"; |
| 49 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 50 | namespace { |
| 51 | |
Vitaly Buka | bced5af | 2015-10-12 17:42:30 -0700 | [diff] [blame] | 52 | const int kCurrentConfigVersion = 1; |
| 53 | |
| 54 | void MigrateFromV0(base::DictionaryValue* dict) { |
| 55 | std::string cloud_id; |
| 56 | if (dict->GetString(config_keys::kCloudId, &cloud_id) && !cloud_id.empty()) |
| 57 | return; |
| 58 | scoped_ptr<base::Value> tmp; |
| 59 | if (dict->Remove(config_keys::kDeviceId, &tmp)) |
| 60 | dict->Set(config_keys::kCloudId, std::move(tmp)); |
| 61 | } |
| 62 | |
Vitaly Buka | 238db69 | 2015-09-29 16:58:39 -0700 | [diff] [blame] | 63 | Config::Settings CreateDefaultSettings() { |
| 64 | Config::Settings result; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 65 | result.oauth_url = "https://accounts.google.com/o/oauth2/"; |
Vitaly Buka | 0d7aac8 | 2015-11-16 23:02:24 -0800 | [diff] [blame] | 66 | result.service_url = kWeaveUrl; |
Vitaly Buka | b624bc4 | 2015-09-29 19:13:55 -0700 | [diff] [blame] | 67 | result.local_anonymous_access_role = AuthScope::kViewer; |
Vitaly Buka | 52d006a | 2015-11-21 17:14:51 -0800 | [diff] [blame] | 68 | result.pairing_modes.insert(PairingType::kPinCode); |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 69 | result.device_id = base::GenerateGUID(); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 70 | return result; |
| 71 | } |
| 72 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 73 | } // namespace |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 74 | |
Vitaly Buka | 1e36367 | 2015-09-25 14:01:16 -0700 | [diff] [blame] | 75 | Config::Config(provider::ConfigStore* config_store) |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 76 | : settings_{CreateDefaultSettings()}, config_store_{config_store} { |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 77 | } |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 78 | |
| 79 | void Config::AddOnChangedCallback(const OnChangedCallback& callback) { |
| 80 | on_changed_.push_back(callback); |
| 81 | // Force to read current state. |
| 82 | callback.Run(settings_); |
| 83 | } |
| 84 | |
Vitaly Buka | 238db69 | 2015-09-29 16:58:39 -0700 | [diff] [blame] | 85 | const Config::Settings& Config::GetSettings() const { |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 86 | return settings_; |
| 87 | } |
| 88 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 89 | void Config::Load() { |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 90 | Transaction change{this}; |
| 91 | change.save_ = false; |
| 92 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 93 | settings_ = CreateDefaultSettings(); |
| 94 | |
| 95 | if (!config_store_) |
| 96 | return; |
| 97 | |
| 98 | // Crash on any mistakes in defaults. |
| 99 | CHECK(config_store_->LoadDefaults(&settings_)); |
| 100 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 101 | CHECK(!settings_.client_id.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 102 | CHECK(!settings_.client_secret.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 103 | CHECK(!settings_.api_key.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 104 | CHECK(!settings_.oauth_url.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 105 | CHECK(!settings_.service_url.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 106 | CHECK(!settings_.oem_name.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 107 | CHECK(!settings_.model_name.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 108 | CHECK(!settings_.model_id.empty()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 109 | CHECK(!settings_.name.empty()); |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 110 | CHECK(!settings_.device_id.empty()); |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 111 | CHECK_EQ( |
| 112 | settings_.embedded_code.empty(), |
| 113 | std::find(settings_.pairing_modes.begin(), settings_.pairing_modes.end(), |
| 114 | PairingType::kEmbeddedCode) == settings_.pairing_modes.end()); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 115 | |
Vitaly Buka | 8589b05 | 2015-09-29 00:46:14 -0700 | [diff] [blame] | 116 | // Values below will be generated at runtime. |
| 117 | CHECK(settings_.cloud_id.empty()); |
| 118 | CHECK(settings_.refresh_token.empty()); |
| 119 | CHECK(settings_.robot_account.empty()); |
| 120 | CHECK(settings_.last_configured_ssid.empty()); |
| 121 | CHECK(settings_.secret.empty()); |
| 122 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 123 | change.LoadState(); |
| 124 | } |
| 125 | |
| 126 | void Config::Transaction::LoadState() { |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 127 | if (!config_->config_store_) |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 128 | return; |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 129 | std::string json_string = config_->config_store_->LoadSettings(); |
| 130 | if (json_string.empty()) |
| 131 | return; |
| 132 | |
| 133 | auto value = base::JSONReader::Read(json_string); |
Vitaly Buka | bced5af | 2015-10-12 17:42:30 -0700 | [diff] [blame] | 134 | base::DictionaryValue* dict = nullptr; |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 135 | if (!value || !value->GetAsDictionary(&dict)) { |
| 136 | LOG(ERROR) << "Failed to parse settings."; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 137 | return; |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 138 | } |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 139 | |
Vitaly Buka | bced5af | 2015-10-12 17:42:30 -0700 | [diff] [blame] | 140 | int loaded_version = 0; |
| 141 | dict->GetInteger(config_keys::kVersion, &loaded_version); |
| 142 | |
| 143 | if (loaded_version != kCurrentConfigVersion) { |
| 144 | LOG(INFO) << "State version mismatch. expected: " << kCurrentConfigVersion |
| 145 | << ", loaded: " << loaded_version; |
| 146 | save_ = true; |
| 147 | } |
| 148 | |
| 149 | if (loaded_version == 0) { |
| 150 | MigrateFromV0(dict); |
| 151 | } |
| 152 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 153 | std::string tmp; |
| 154 | bool tmp_bool{false}; |
| 155 | |
| 156 | if (dict->GetString(config_keys::kClientId, &tmp)) |
| 157 | set_client_id(tmp); |
| 158 | |
| 159 | if (dict->GetString(config_keys::kClientSecret, &tmp)) |
| 160 | set_client_secret(tmp); |
| 161 | |
| 162 | if (dict->GetString(config_keys::kApiKey, &tmp)) |
| 163 | set_api_key(tmp); |
| 164 | |
| 165 | if (dict->GetString(config_keys::kOAuthURL, &tmp)) |
| 166 | set_oauth_url(tmp); |
| 167 | |
Vitaly Buka | 0d7aac8 | 2015-11-16 23:02:24 -0800 | [diff] [blame] | 168 | if (dict->GetString(config_keys::kServiceURL, &tmp)) { |
| 169 | if (tmp == kDeprecatedUrl) |
| 170 | tmp = kWeaveUrl; |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 171 | set_service_url(tmp); |
Vitaly Buka | 0d7aac8 | 2015-11-16 23:02:24 -0800 | [diff] [blame] | 172 | } |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 173 | |
| 174 | if (dict->GetString(config_keys::kName, &tmp)) |
| 175 | set_name(tmp); |
| 176 | |
| 177 | if (dict->GetString(config_keys::kDescription, &tmp)) |
| 178 | set_description(tmp); |
| 179 | |
| 180 | if (dict->GetString(config_keys::kLocation, &tmp)) |
| 181 | set_location(tmp); |
| 182 | |
Vitaly Buka | b624bc4 | 2015-09-29 19:13:55 -0700 | [diff] [blame] | 183 | AuthScope scope{AuthScope::kNone}; |
| 184 | if (dict->GetString(config_keys::kLocalAnonymousAccessRole, &tmp) && |
| 185 | StringToEnum(tmp, &scope)) { |
| 186 | set_local_anonymous_access_role(scope); |
| 187 | } |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 188 | |
| 189 | if (dict->GetBoolean(config_keys::kLocalDiscoveryEnabled, &tmp_bool)) |
| 190 | set_local_discovery_enabled(tmp_bool); |
| 191 | |
| 192 | if (dict->GetBoolean(config_keys::kLocalPairingEnabled, &tmp_bool)) |
| 193 | set_local_pairing_enabled(tmp_bool); |
| 194 | |
Vitaly Buka | 8589b05 | 2015-09-29 00:46:14 -0700 | [diff] [blame] | 195 | if (dict->GetString(config_keys::kCloudId, &tmp)) |
| 196 | set_cloud_id(tmp); |
| 197 | |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 198 | if (dict->GetString(config_keys::kDeviceId, &tmp)) |
| 199 | set_device_id(tmp); |
| 200 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 201 | if (dict->GetString(config_keys::kRefreshToken, &tmp)) |
| 202 | set_refresh_token(tmp); |
| 203 | |
| 204 | if (dict->GetString(config_keys::kRobotAccount, &tmp)) |
| 205 | set_robot_account(tmp); |
| 206 | |
| 207 | if (dict->GetString(config_keys::kLastConfiguredSsid, &tmp)) |
| 208 | set_last_configured_ssid(tmp); |
| 209 | |
Vitaly Buka | 8589b05 | 2015-09-29 00:46:14 -0700 | [diff] [blame] | 210 | if (dict->GetString(config_keys::kSecret, &tmp)) |
| 211 | set_secret(tmp); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 212 | } |
| 213 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 214 | void Config::Save() { |
| 215 | if (!config_store_) |
| 216 | return; |
| 217 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 218 | base::DictionaryValue dict; |
Vitaly Buka | bced5af | 2015-10-12 17:42:30 -0700 | [diff] [blame] | 219 | dict.SetInteger(config_keys::kVersion, kCurrentConfigVersion); |
| 220 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 221 | dict.SetString(config_keys::kClientId, settings_.client_id); |
| 222 | dict.SetString(config_keys::kClientSecret, settings_.client_secret); |
| 223 | dict.SetString(config_keys::kApiKey, settings_.api_key); |
| 224 | dict.SetString(config_keys::kOAuthURL, settings_.oauth_url); |
| 225 | dict.SetString(config_keys::kServiceURL, settings_.service_url); |
| 226 | dict.SetString(config_keys::kRefreshToken, settings_.refresh_token); |
Johan Euphrosine | 312c2f5 | 2015-09-29 00:04:29 -0700 | [diff] [blame] | 227 | dict.SetString(config_keys::kCloudId, settings_.cloud_id); |
Johan Euphrosine | 0b7bb9f | 2015-09-29 01:11:21 -0700 | [diff] [blame] | 228 | dict.SetString(config_keys::kDeviceId, settings_.device_id); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 229 | dict.SetString(config_keys::kRobotAccount, settings_.robot_account); |
| 230 | dict.SetString(config_keys::kLastConfiguredSsid, |
| 231 | settings_.last_configured_ssid); |
Vitaly Buka | 8589b05 | 2015-09-29 00:46:14 -0700 | [diff] [blame] | 232 | dict.SetString(config_keys::kSecret, settings_.secret); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 233 | dict.SetString(config_keys::kName, settings_.name); |
| 234 | dict.SetString(config_keys::kDescription, settings_.description); |
| 235 | dict.SetString(config_keys::kLocation, settings_.location); |
| 236 | dict.SetString(config_keys::kLocalAnonymousAccessRole, |
Vitaly Buka | b624bc4 | 2015-09-29 19:13:55 -0700 | [diff] [blame] | 237 | EnumToString(settings_.local_anonymous_access_role)); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 238 | dict.SetBoolean(config_keys::kLocalDiscoveryEnabled, |
| 239 | settings_.local_discovery_enabled); |
| 240 | dict.SetBoolean(config_keys::kLocalPairingEnabled, |
| 241 | settings_.local_pairing_enabled); |
| 242 | |
Vitaly Buka | c11a17d | 2015-08-15 10:36:10 -0700 | [diff] [blame] | 243 | std::string json_string; |
| 244 | base::JSONWriter::WriteWithOptions( |
| 245 | dict, base::JSONWriter::OPTIONS_PRETTY_PRINT, &json_string); |
| 246 | |
| 247 | config_store_->SaveSettings(json_string); |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 248 | } |
| 249 | |
| 250 | Config::Transaction::~Transaction() { |
| 251 | Commit(); |
| 252 | } |
| 253 | |
Vitaly Buka | d322a3c | 2015-08-16 01:03:02 -0700 | [diff] [blame] | 254 | void Config::Transaction::Commit() { |
| 255 | if (!config_) |
| 256 | return; |
| 257 | if (save_) |
| 258 | config_->Save(); |
| 259 | for (const auto& cb : config_->on_changed_) |
| 260 | cb.Run(*settings_); |
| 261 | config_ = nullptr; |
| 262 | } |
| 263 | |
| 264 | } // namespace weave |