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 #include "chrome/browser/supervised_user/legacy/supervised_user_shared_settings_
service.h" | 5 #include "chrome/browser/supervised_user/legacy/supervised_user_shared_settings_
service.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <set> | 8 #include <set> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
11 #include "base/json/json_reader.h" | 11 #include "base/json/json_reader.h" |
12 #include "base/json/json_writer.h" | 12 #include "base/json/json_writer.h" |
| 13 #include "base/memory/ptr_util.h" |
13 #include "base/values.h" | 14 #include "base/values.h" |
14 #include "chrome/common/pref_names.h" | 15 #include "chrome/common/pref_names.h" |
15 #include "components/pref_registry/pref_registry_syncable.h" | 16 #include "components/pref_registry/pref_registry_syncable.h" |
16 #include "components/prefs/pref_service.h" | 17 #include "components/prefs/pref_service.h" |
17 #include "components/prefs/scoped_user_pref_update.h" | 18 #include "components/prefs/scoped_user_pref_update.h" |
18 #include "components/sync/model/sync_change.h" | 19 #include "components/sync/model/sync_change.h" |
19 #include "components/sync/model/sync_data.h" | 20 #include "components/sync/model/sync_data.h" |
20 #include "components/sync/model/sync_error.h" | 21 #include "components/sync/model/sync_error.h" |
21 #include "components/sync/model/sync_error_factory.h" | 22 #include "components/sync/model/sync_error_factory.h" |
22 #include "components/sync/model/sync_merge_result.h" | 23 #include "components/sync/model/sync_merge_result.h" |
(...skipping 14 matching lines...) Expand all Loading... |
37 | 38 |
38 namespace { | 39 namespace { |
39 | 40 |
40 const char kAcknowledged[] = "acknowledged"; | 41 const char kAcknowledged[] = "acknowledged"; |
41 const char kValue[] = "value"; | 42 const char kValue[] = "value"; |
42 | 43 |
43 DictionaryValue* FindOrCreateDictionary(DictionaryValue* parent, | 44 DictionaryValue* FindOrCreateDictionary(DictionaryValue* parent, |
44 const std::string& key) { | 45 const std::string& key) { |
45 DictionaryValue* dict = nullptr; | 46 DictionaryValue* dict = nullptr; |
46 if (!parent->GetDictionaryWithoutPathExpansion(key, &dict)) { | 47 if (!parent->GetDictionaryWithoutPathExpansion(key, &dict)) { |
47 dict = new DictionaryValue; | 48 dict = parent->SetDictionaryWithoutPathExpansion( |
48 parent->SetWithoutPathExpansion(key, dict); | 49 key, base::MakeUnique<base::DictionaryValue>()); |
49 } | 50 } |
50 return dict; | 51 return dict; |
51 } | 52 } |
52 | 53 |
53 class ScopedSupervisedUserSharedSettingsUpdate { | 54 class ScopedSupervisedUserSharedSettingsUpdate { |
54 public: | 55 public: |
55 ScopedSupervisedUserSharedSettingsUpdate(PrefService* prefs, | 56 ScopedSupervisedUserSharedSettingsUpdate(PrefService* prefs, |
56 const std::string& su_id) | 57 const std::string& su_id) |
57 : update_(prefs, prefs::kSupervisedUserSharedSettings), su_id_(su_id) { | 58 : update_(prefs, prefs::kSupervisedUserSharedSettings), su_id_(su_id) { |
58 DCHECK(!su_id.empty()); | 59 DCHECK(!su_id.empty()); |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
103 const std::string& su_id, | 104 const std::string& su_id, |
104 const std::string& key, | 105 const std::string& key, |
105 const Value& value, | 106 const Value& value, |
106 bool acknowledged) { | 107 bool acknowledged) { |
107 ScopedSupervisedUserSharedSettingsUpdate update(prefs_, su_id); | 108 ScopedSupervisedUserSharedSettingsUpdate update(prefs_, su_id); |
108 DictionaryValue* update_dict = update.Get(); | 109 DictionaryValue* update_dict = update.Get(); |
109 | 110 |
110 DictionaryValue* dict = nullptr; | 111 DictionaryValue* dict = nullptr; |
111 bool has_key = update_dict->GetDictionaryWithoutPathExpansion(key, &dict); | 112 bool has_key = update_dict->GetDictionaryWithoutPathExpansion(key, &dict); |
112 if (!has_key) { | 113 if (!has_key) { |
113 dict = new DictionaryValue; | 114 dict = update_dict->SetDictionaryWithoutPathExpansion( |
114 update_dict->SetWithoutPathExpansion(key, dict); | 115 key, base::MakeUnique<base::DictionaryValue>()); |
115 } | 116 } |
116 dict->SetWithoutPathExpansion(kValue, value.DeepCopy()); | 117 dict->SetWithoutPathExpansion(kValue, base::MakeUnique<base::Value>(value)); |
117 dict->SetBooleanWithoutPathExpansion(kAcknowledged, acknowledged); | 118 dict->SetBooleanWithoutPathExpansion(kAcknowledged, acknowledged); |
118 | 119 |
119 if (!sync_processor_) | 120 if (!sync_processor_) |
120 return; | 121 return; |
121 | 122 |
122 SyncData data = CreateSyncDataForSetting(su_id, key, value, acknowledged); | 123 SyncData data = CreateSyncDataForSetting(su_id, key, value, acknowledged); |
123 SyncChange::SyncChangeType change_type = | 124 SyncChange::SyncChangeType change_type = |
124 has_key ? SyncChange::ACTION_UPDATE : SyncChange::ACTION_ADD; | 125 has_key ? SyncChange::ACTION_UPDATE : SyncChange::ACTION_ADD; |
125 SyncChangeList changes; | 126 SyncChangeList changes; |
126 changes.push_back(SyncChange(FROM_HERE, change_type, data)); | 127 changes.push_back(SyncChange(FROM_HERE, change_type, data)); |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
223 DCHECK_EQ(SUPERVISED_USER_SHARED_SETTINGS, sync_data.GetDataType()); | 224 DCHECK_EQ(SUPERVISED_USER_SHARED_SETTINGS, sync_data.GetDataType()); |
224 const ::sync_pb::ManagedUserSharedSettingSpecifics& | 225 const ::sync_pb::ManagedUserSharedSettingSpecifics& |
225 supervised_user_shared_setting = | 226 supervised_user_shared_setting = |
226 sync_data.GetSpecifics().managed_user_shared_setting(); | 227 sync_data.GetSpecifics().managed_user_shared_setting(); |
227 std::unique_ptr<Value> value = | 228 std::unique_ptr<Value> value = |
228 base::JSONReader::Read(supervised_user_shared_setting.value()); | 229 base::JSONReader::Read(supervised_user_shared_setting.value()); |
229 const std::string& su_id = supervised_user_shared_setting.mu_id(); | 230 const std::string& su_id = supervised_user_shared_setting.mu_id(); |
230 ScopedSupervisedUserSharedSettingsUpdate update(prefs_, su_id); | 231 ScopedSupervisedUserSharedSettingsUpdate update(prefs_, su_id); |
231 const std::string& key = supervised_user_shared_setting.key(); | 232 const std::string& key = supervised_user_shared_setting.key(); |
232 DictionaryValue* dict = FindOrCreateDictionary(update.Get(), key); | 233 DictionaryValue* dict = FindOrCreateDictionary(update.Get(), key); |
233 dict->SetWithoutPathExpansion(kValue, value.release()); | 234 dict->SetWithoutPathExpansion(kValue, std::move(value)); |
234 | 235 |
235 // Every setting we get from the server should have the acknowledged flag | 236 // Every setting we get from the server should have the acknowledged flag |
236 // set. | 237 // set. |
237 DCHECK(supervised_user_shared_setting.acknowledged()); | 238 DCHECK(supervised_user_shared_setting.acknowledged()); |
238 dict->SetBooleanWithoutPathExpansion( | 239 dict->SetBooleanWithoutPathExpansion( |
239 kAcknowledged, supervised_user_shared_setting.acknowledged()); | 240 kAcknowledged, supervised_user_shared_setting.acknowledged()); |
240 callbacks_.Notify(su_id, key); | 241 callbacks_.Notify(su_id, key); |
241 | 242 |
242 if (pref_seen_keys.find(su_id) == pref_seen_keys.end()) | 243 if (pref_seen_keys.find(su_id) == pref_seen_keys.end()) |
243 num_added++; | 244 num_added++; |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
334 // flag set. | 335 // flag set. |
335 DCHECK(supervised_user_shared_setting.acknowledged()); | 336 DCHECK(supervised_user_shared_setting.acknowledged()); |
336 | 337 |
337 if (has_key) { | 338 if (has_key) { |
338 // If the supervised user already exists, it should be an update | 339 // If the supervised user already exists, it should be an update |
339 // action. | 340 // action. |
340 DCHECK_EQ(SyncChange::ACTION_UPDATE, sync_change.change_type()); | 341 DCHECK_EQ(SyncChange::ACTION_UPDATE, sync_change.change_type()); |
341 } else { | 342 } else { |
342 // Otherwise, it should be an add action. | 343 // Otherwise, it should be an add action. |
343 DCHECK_EQ(SyncChange::ACTION_ADD, sync_change.change_type()); | 344 DCHECK_EQ(SyncChange::ACTION_ADD, sync_change.change_type()); |
344 dict = new DictionaryValue; | 345 dict = update_dict->SetDictionaryWithoutPathExpansion( |
345 update_dict->SetWithoutPathExpansion(key, dict); | 346 key, base::MakeUnique<base::DictionaryValue>()); |
346 } | 347 } |
347 std::unique_ptr<Value> value = | 348 std::unique_ptr<Value> value = |
348 base::JSONReader::Read(supervised_user_shared_setting.value()); | 349 base::JSONReader::Read(supervised_user_shared_setting.value()); |
349 dict->SetWithoutPathExpansion(kValue, value.release()); | 350 dict->SetWithoutPathExpansion(kValue, std::move(value)); |
350 dict->SetBooleanWithoutPathExpansion( | 351 dict->SetBooleanWithoutPathExpansion( |
351 kAcknowledged, supervised_user_shared_setting.acknowledged()); | 352 kAcknowledged, supervised_user_shared_setting.acknowledged()); |
352 break; | 353 break; |
353 } | 354 } |
354 case SyncChange::ACTION_DELETE: { | 355 case SyncChange::ACTION_DELETE: { |
355 if (has_key) | 356 if (has_key) |
356 update_dict->RemoveWithoutPathExpansion(key, nullptr); | 357 update_dict->RemoveWithoutPathExpansion(key, nullptr); |
357 else | 358 else |
358 NOTREACHED() << "Trying to delete nonexistent key " << key; | 359 NOTREACHED() << "Trying to delete nonexistent key " << key; |
359 break; | 360 break; |
360 } | 361 } |
361 case SyncChange::ACTION_INVALID: { | 362 case SyncChange::ACTION_INVALID: { |
362 NOTREACHED(); | 363 NOTREACHED(); |
363 break; | 364 break; |
364 } | 365 } |
365 } | 366 } |
366 callbacks_.Notify(su_id, key); | 367 callbacks_.Notify(su_id, key); |
367 } | 368 } |
368 | 369 |
369 SyncError error; | 370 SyncError error; |
370 return error; | 371 return error; |
371 } | 372 } |
OLD | NEW |