OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "base/bind.h" | |
6 #include "base/json/json_writer.h" | |
7 #include "base/prefs/pref_service.h" | |
8 #include "chrome/browser/managed_mode/managed_user_shared_settings_service.h" | |
9 #include "chrome/common/pref_names.h" | |
10 #include "chrome/test/base/testing_profile.h" | |
11 #include "sync/api/fake_sync_change_processor.h" | |
12 #include "sync/api/sync_change.h" | |
13 #include "sync/api/sync_change_processor_wrapper_for_test.h" | |
14 #include "sync/api/sync_error_factory_mock.h" | |
15 #include "sync/protocol/sync.pb.h" | |
16 #include "testing/gtest/include/gtest/gtest.h" | |
17 | |
18 using base::DictionaryValue; | |
19 using base::FundamentalValue; | |
20 using base::StringValue; | |
21 using base::Value; | |
22 using sync_pb::ManagedUserSharedSettingSpecifics; | |
23 using syncer::SUPERVISED_USER_SHARED_SETTINGS; | |
24 using syncer::SyncChange; | |
25 using syncer::SyncChangeList; | |
26 using syncer::SyncChangeProcessor; | |
27 using syncer::SyncChangeProcessorWrapperForTest; | |
28 using syncer::SyncData; | |
29 using syncer::SyncDataList; | |
30 using syncer::SyncError; | |
31 using syncer::SyncErrorFactory; | |
32 using syncer::SyncMergeResult; | |
33 | |
34 namespace { | |
35 | |
36 class MockSyncErrorFactory : public syncer::SyncErrorFactory { | |
37 public: | |
38 explicit MockSyncErrorFactory(syncer::ModelType type); | |
39 virtual ~MockSyncErrorFactory(); | |
40 | |
41 // SyncErrorFactory implementation: | |
42 virtual syncer::SyncError CreateAndUploadError( | |
43 const tracked_objects::Location& location, | |
44 const std::string& message) OVERRIDE; | |
45 | |
46 private: | |
47 syncer::ModelType type_; | |
48 | |
49 DISALLOW_COPY_AND_ASSIGN(MockSyncErrorFactory); | |
50 }; | |
51 | |
52 MockSyncErrorFactory::MockSyncErrorFactory(syncer::ModelType type) | |
53 : type_(type) {} | |
54 | |
55 MockSyncErrorFactory::~MockSyncErrorFactory() {} | |
56 | |
57 syncer::SyncError MockSyncErrorFactory::CreateAndUploadError( | |
58 const tracked_objects::Location& location, | |
59 const std::string& message) { | |
60 return syncer::SyncError(location, SyncError::DATATYPE_ERROR, message, type_); | |
61 } | |
62 | |
63 // Convenience method to allow us to use EXPECT_EQ to compare values. | |
64 std::string ToJson(const Value* value) { | |
65 if (!value) | |
66 return std::string(); | |
67 | |
68 std::string json_value; | |
69 base::JSONWriter::Write(value, &json_value); | |
70 return json_value; | |
71 } | |
72 | |
73 } // namespace | |
74 | |
75 class ManagedUserSharedSettingsServiceTest : public ::testing::Test { | |
76 protected: | |
77 typedef base::CallbackList<void(const std::string&, const std::string&)> | |
78 CallbackList; | |
79 | |
80 ManagedUserSharedSettingsServiceTest() | |
81 : settings_service_(profile_.GetPrefs()) {} | |
82 virtual ~ManagedUserSharedSettingsServiceTest() {} | |
83 | |
84 void StartSyncing(const syncer::SyncDataList& initial_sync_data) { | |
85 sync_processor_.reset(new syncer::FakeSyncChangeProcessor); | |
86 scoped_ptr<syncer::SyncErrorFactory> error_handler( | |
87 new MockSyncErrorFactory(SUPERVISED_USER_SHARED_SETTINGS)); | |
88 SyncMergeResult result = settings_service_.MergeDataAndStartSyncing( | |
89 SUPERVISED_USER_SHARED_SETTINGS, | |
90 initial_sync_data, | |
91 scoped_ptr<SyncChangeProcessor>( | |
92 new SyncChangeProcessorWrapperForTest(sync_processor_.get())), | |
93 error_handler.Pass()); | |
94 EXPECT_FALSE(result.error().IsSet()); | |
95 } | |
96 | |
97 const base::DictionaryValue* GetAllSettings() { | |
98 return profile_.GetPrefs()->GetDictionary( | |
99 prefs::kSupervisedUserSharedSettings); | |
100 } | |
101 | |
102 void VerifySyncChangesAndClear() { | |
103 SyncChangeList& changes = sync_processor_->changes(); | |
104 for (SyncChangeList::const_iterator it = changes.begin(); | |
105 it != changes.end(); | |
106 ++it) { | |
107 const sync_pb::ManagedUserSharedSettingSpecifics& setting = | |
108 it->sync_data().GetSpecifics().managed_user_shared_setting(); | |
109 EXPECT_EQ( | |
110 setting.value(), | |
111 ToJson(settings_service_.GetValue(setting.mu_id(), setting.key()))); | |
112 } | |
113 changes.clear(); | |
114 } | |
115 | |
116 // testing::Test overrides: | |
117 virtual void SetUp() OVERRIDE { | |
118 subscription_ = settings_service_.Subscribe( | |
119 base::Bind(&ManagedUserSharedSettingsServiceTest::OnSettingChanged, | |
120 base::Unretained(this))); | |
121 } | |
122 | |
123 virtual void TearDown() OVERRIDE { settings_service_.Shutdown(); } | |
124 | |
125 void OnSettingChanged(const std::string& mu_id, const std::string& key) { | |
126 const Value* value = settings_service_.GetValue(mu_id, key); | |
127 ASSERT_TRUE(value); | |
128 changed_settings_.push_back( | |
129 ManagedUserSharedSettingsService::CreateSyncDataForSetting( | |
130 mu_id, key, *value, true)); | |
131 } | |
132 | |
133 TestingProfile profile_; | |
134 ManagedUserSharedSettingsService settings_service_; | |
135 SyncDataList changed_settings_; | |
136 | |
137 scoped_ptr<CallbackList::Subscription> subscription_; | |
138 | |
139 scoped_ptr<syncer::FakeSyncChangeProcessor> sync_processor_; | |
140 }; | |
141 | |
142 TEST_F(ManagedUserSharedSettingsServiceTest, Empty) { | |
143 StartSyncing(SyncDataList()); | |
144 EXPECT_EQ(0u, sync_processor_->changes().size()); | |
145 EXPECT_EQ(0u, changed_settings_.size()); | |
146 EXPECT_EQ( | |
147 0u, | |
148 settings_service_.GetAllSyncData(SUPERVISED_USER_SHARED_SETTINGS).size()); | |
149 EXPECT_EQ(0u, GetAllSettings()->size()); | |
150 } | |
151 | |
152 TEST_F(ManagedUserSharedSettingsServiceTest, SetAndGet) { | |
153 StartSyncing(SyncDataList()); | |
154 | |
155 const char kIdA[] = "aaaaaa"; | |
156 const char kIdB[] = "bbbbbb"; | |
157 const char kIdC[] = "cccccc"; | |
158 | |
159 StringValue name("Jack"); | |
160 FundamentalValue age(8); | |
161 StringValue bar("bar"); | |
162 settings_service_.SetValue(kIdA, "name", name); | |
163 ASSERT_EQ(1u, sync_processor_->changes().size()); | |
164 VerifySyncChangesAndClear(); | |
165 settings_service_.SetValue(kIdA, "age", FundamentalValue(6)); | |
166 ASSERT_EQ(1u, sync_processor_->changes().size()); | |
167 VerifySyncChangesAndClear(); | |
168 settings_service_.SetValue(kIdA, "age", age); | |
169 ASSERT_EQ(1u, sync_processor_->changes().size()); | |
170 VerifySyncChangesAndClear(); | |
171 settings_service_.SetValue(kIdB, "foo", bar); | |
172 ASSERT_EQ(1u, sync_processor_->changes().size()); | |
173 VerifySyncChangesAndClear(); | |
174 | |
175 EXPECT_EQ( | |
176 3u, | |
177 settings_service_.GetAllSyncData(SUPERVISED_USER_SHARED_SETTINGS).size()); | |
178 | |
179 EXPECT_EQ(ToJson(&name), ToJson(settings_service_.GetValue(kIdA, "name"))); | |
180 EXPECT_EQ(ToJson(&age), ToJson(settings_service_.GetValue(kIdA, "age"))); | |
181 EXPECT_EQ(ToJson(&bar), ToJson(settings_service_.GetValue(kIdB, "foo"))); | |
182 EXPECT_FALSE(settings_service_.GetValue(kIdA, "foo")); | |
183 EXPECT_FALSE(settings_service_.GetValue(kIdB, "name")); | |
184 EXPECT_FALSE(settings_service_.GetValue(kIdC, "name")); | |
185 } | |
186 | |
187 TEST_F(ManagedUserSharedSettingsServiceTest, Merge) { | |
188 // Set initial values, then stop syncing so we can restart. | |
189 StartSyncing(SyncDataList()); | |
190 | |
191 const char kIdA[] = "aaaaaa"; | |
192 const char kIdB[] = "bbbbbb"; | |
193 const char kIdC[] = "cccccc"; | |
194 | |
195 FundamentalValue age(8); | |
196 StringValue bar("bar"); | |
197 settings_service_.SetValue(kIdA, "name", StringValue("Jack")); | |
198 settings_service_.SetValue(kIdA, "age", age); | |
199 settings_service_.SetValue(kIdB, "foo", bar); | |
200 | |
201 settings_service_.StopSyncing(SUPERVISED_USER_SHARED_SETTINGS); | |
202 | |
203 StringValue name("Jill"); | |
204 StringValue blurp("blurp"); | |
205 SyncDataList sync_data; | |
206 sync_data.push_back( | |
207 ManagedUserSharedSettingsService::CreateSyncDataForSetting( | |
208 kIdA, "name", name, true)); | |
209 sync_data.push_back( | |
210 ManagedUserSharedSettingsService::CreateSyncDataForSetting( | |
211 kIdC, "baz", blurp, true)); | |
212 | |
213 StartSyncing(sync_data); | |
214 EXPECT_EQ(2u, sync_processor_->changes().size()); | |
215 VerifySyncChangesAndClear(); | |
216 EXPECT_EQ(2u, changed_settings_.size()); | |
217 | |
218 EXPECT_EQ( | |
219 4u, | |
220 settings_service_.GetAllSyncData(SUPERVISED_USER_SHARED_SETTINGS).size()); | |
221 EXPECT_EQ(ToJson(&name), | |
222 ToJson(settings_service_.GetValue(kIdA, "name"))); | |
223 EXPECT_EQ(ToJson(&age), ToJson(settings_service_.GetValue(kIdA, "age"))); | |
224 EXPECT_EQ(ToJson(&bar), ToJson(settings_service_.GetValue(kIdB, "foo"))); | |
225 EXPECT_EQ(ToJson(&blurp), ToJson(settings_service_.GetValue(kIdC, "baz"))); | |
226 EXPECT_FALSE(settings_service_.GetValue(kIdA, "foo")); | |
227 EXPECT_FALSE(settings_service_.GetValue(kIdB, "name")); | |
228 EXPECT_FALSE(settings_service_.GetValue(kIdC, "name")); | |
229 } | |
230 | |
231 TEST_F(ManagedUserSharedSettingsServiceTest, ProcessChanges) { | |
232 StartSyncing(SyncDataList()); | |
233 | |
234 const char kIdA[] = "aaaaaa"; | |
235 const char kIdB[] = "bbbbbb"; | |
236 const char kIdC[] = "cccccc"; | |
237 | |
238 FundamentalValue age(8); | |
239 StringValue bar("bar"); | |
240 settings_service_.SetValue(kIdA, "name", StringValue("Jack")); | |
241 settings_service_.SetValue(kIdA, "age", age); | |
242 settings_service_.SetValue(kIdB, "foo", bar); | |
243 | |
244 StringValue name("Jill"); | |
245 StringValue blurp("blurp"); | |
246 SyncChangeList changes; | |
247 changes.push_back( | |
248 SyncChange(FROM_HERE, | |
249 SyncChange::ACTION_UPDATE, | |
250 ManagedUserSharedSettingsService::CreateSyncDataForSetting( | |
251 kIdA, "name", name, true))); | |
252 changes.push_back( | |
253 SyncChange(FROM_HERE, | |
254 SyncChange::ACTION_ADD, | |
255 ManagedUserSharedSettingsService::CreateSyncDataForSetting( | |
256 kIdC, "baz", blurp, true))); | |
257 SyncError error = settings_service_.ProcessSyncChanges(FROM_HERE, changes); | |
258 EXPECT_FALSE(error.IsSet()) << error.ToString(); | |
259 EXPECT_EQ(2u, changed_settings_.size()); | |
260 | |
261 EXPECT_EQ( | |
262 4u, | |
263 settings_service_.GetAllSyncData(SUPERVISED_USER_SHARED_SETTINGS).size()); | |
264 EXPECT_EQ(ToJson(&name), | |
265 ToJson(settings_service_.GetValue(kIdA, "name"))); | |
266 EXPECT_EQ(ToJson(&age), ToJson(settings_service_.GetValue(kIdA, "age"))); | |
267 EXPECT_EQ(ToJson(&bar), ToJson(settings_service_.GetValue(kIdB, "foo"))); | |
268 EXPECT_EQ(ToJson(&blurp), ToJson(settings_service_.GetValue(kIdC, "baz"))); | |
269 EXPECT_FALSE(settings_service_.GetValue(kIdA, "foo")); | |
270 EXPECT_FALSE(settings_service_.GetValue(kIdB, "name")); | |
271 EXPECT_FALSE(settings_service_.GetValue(kIdC, "name")); | |
272 } | |
OLD | NEW |