OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "testing/gtest/include/gtest/gtest.h" | 5 #include "testing/gtest/include/gtest/gtest.h" |
6 | 6 |
7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
9 #include "base/prefs/pref_service.h" | 9 #include "base/prefs/pref_service.h" |
10 #include "chrome/browser/signin/fake_signin_manager.h" | 10 #include "chrome/browser/signin/fake_signin_manager.h" |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
75 profile_(new TestingProfile), | 75 profile_(new TestingProfile), |
76 sync_(NULL) {} | 76 sync_(NULL) {} |
77 | 77 |
78 virtual ~ProfileSyncServiceStartupTest() { | 78 virtual ~ProfileSyncServiceStartupTest() { |
79 } | 79 } |
80 | 80 |
81 virtual void SetUp() { | 81 virtual void SetUp() { |
82 file_thread_.Start(); | 82 file_thread_.Start(); |
83 io_thread_.StartIOThread(); | 83 io_thread_.StartIOThread(); |
84 profile_->CreateRequestContext(); | 84 profile_->CreateRequestContext(); |
85 CreateSyncService(); | 85 #if defined(OS_CHROMEOS) |
86 sync_->AddObserver(&observer_); | 86 SigninManagerFactory::GetInstance()->SetTestingFactory( |
87 sync_->set_synchronous_sync_configuration(); | 87 profile_.get(), FakeSigninManagerBase::Build); |
| 88 #else |
| 89 SigninManagerFactory::GetInstance()->SetTestingFactory( |
| 90 profile_.get(), FakeSigninManager::Build); |
| 91 #endif |
88 } | 92 } |
89 | 93 |
90 virtual void TearDown() { | 94 virtual void TearDown() { |
91 sync_->RemoveObserver(&observer_); | 95 sync_->RemoveObserver(&observer_); |
92 ProfileSyncServiceFactory::GetInstance()->SetTestingFactory( | 96 ProfileSyncServiceFactory::GetInstance()->SetTestingFactory( |
93 profile_.get(), NULL); | 97 profile_.get(), NULL); |
94 profile_.reset(); | 98 profile_.reset(); |
95 | 99 |
96 // Pump messages posted by the sync core thread (which may end up | 100 // Pump messages posted by the sync core thread (which may end up |
97 // posting on the IO thread). | 101 // posting on the IO thread). |
98 ui_loop_.RunUntilIdle(); | 102 ui_loop_.RunUntilIdle(); |
99 io_thread_.Stop(); | 103 io_thread_.Stop(); |
100 file_thread_.Stop(); | 104 file_thread_.Stop(); |
101 ui_loop_.RunUntilIdle(); | 105 ui_loop_.RunUntilIdle(); |
102 } | 106 } |
103 | 107 |
104 void Signin() { | |
105 sync_->signin()->SetAuthenticatedUsername("test_user"); | |
106 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, | |
107 "test_user"); | |
108 GoogleServiceSigninSuccessDetails details("test_user", ""); | |
109 content::NotificationService::current()->Notify( | |
110 chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL, | |
111 content::Source<Profile>(profile_.get()), | |
112 content::Details<const GoogleServiceSigninSuccessDetails>(&details)); | |
113 } | |
114 | |
115 static ProfileKeyedService* BuildService(content::BrowserContext* profile) { | 108 static ProfileKeyedService* BuildService(content::BrowserContext* profile) { |
116 SigninManagerBase* signin = static_cast<SigninManagerBase*>( | |
117 SigninManagerFactory::GetInstance()->SetTestingFactoryAndUse( | |
118 profile, FakeSigninManagerBase::Build)); | |
119 signin->SetAuthenticatedUsername("test_user"); | |
120 return new TestProfileSyncService( | 109 return new TestProfileSyncService( |
121 new ProfileSyncComponentsFactoryMock(), | 110 new ProfileSyncComponentsFactoryMock(), |
122 static_cast<Profile*>(profile), | 111 static_cast<Profile*>(profile), |
123 signin, | 112 SigninManagerFactory::GetForProfile(static_cast<Profile*>(profile)), |
124 ProfileSyncService::MANUAL_START, | 113 ProfileSyncService::MANUAL_START, |
125 true); | 114 true); |
126 } | 115 } |
127 | 116 |
128 protected: | 117 void CreateSyncService() { |
129 // Overridden below by ProfileSyncServiceStartupCrosTest. | |
130 virtual void CreateSyncService() { | |
131 sync_ = static_cast<TestProfileSyncService*>( | 118 sync_ = static_cast<TestProfileSyncService*>( |
132 ProfileSyncServiceFactory::GetInstance()->SetTestingFactoryAndUse( | 119 ProfileSyncServiceFactory::GetInstance()->SetTestingFactoryAndUse( |
133 profile_.get(), BuildService)); | 120 profile_.get(), BuildService)); |
| 121 sync_->AddObserver(&observer_); |
| 122 sync_->set_synchronous_sync_configuration(); |
134 } | 123 } |
135 | 124 |
| 125 protected: |
136 DataTypeManagerMock* SetUpDataTypeManager() { | 126 DataTypeManagerMock* SetUpDataTypeManager() { |
137 DataTypeManagerMock* data_type_manager = new DataTypeManagerMock(); | 127 DataTypeManagerMock* data_type_manager = new DataTypeManagerMock(); |
138 EXPECT_CALL(*sync_->components_factory_mock(), | 128 EXPECT_CALL(*sync_->components_factory_mock(), |
139 CreateDataTypeManager(_, _, _, _, _)). | 129 CreateDataTypeManager(_, _, _, _, _)). |
140 WillOnce(Return(data_type_manager)); | 130 WillOnce(Return(data_type_manager)); |
141 return data_type_manager; | 131 return data_type_manager; |
142 } | 132 } |
143 | 133 |
144 MessageLoop ui_loop_; | 134 MessageLoop ui_loop_; |
145 content::TestBrowserThread ui_thread_; | 135 content::TestBrowserThread ui_thread_; |
146 content::TestBrowserThread db_thread_; | 136 content::TestBrowserThread db_thread_; |
147 content::TestBrowserThread file_thread_; | 137 content::TestBrowserThread file_thread_; |
148 content::TestBrowserThread io_thread_; | 138 content::TestBrowserThread io_thread_; |
149 scoped_ptr<TestingProfile> profile_; | 139 scoped_ptr<TestingProfile> profile_; |
150 TestProfileSyncService* sync_; | 140 TestProfileSyncService* sync_; |
151 ProfileSyncServiceObserverMock observer_; | 141 ProfileSyncServiceObserverMock observer_; |
152 }; | 142 }; |
153 | 143 |
154 class ProfileSyncServiceStartupCrosTest : public ProfileSyncServiceStartupTest { | 144 class ProfileSyncServiceStartupCrosTest : public ProfileSyncServiceStartupTest { |
155 public: | 145 public: |
| 146 virtual void SetUp() { |
| 147 ProfileSyncServiceStartupTest::SetUp(); |
| 148 sync_ = static_cast<TestProfileSyncService*>( |
| 149 ProfileSyncServiceFactory::GetInstance()->SetTestingFactoryAndUse( |
| 150 profile_.get(), BuildCrosService)); |
| 151 sync_->AddObserver(&observer_); |
| 152 sync_->set_synchronous_sync_configuration(); |
| 153 } |
| 154 |
156 static ProfileKeyedService* BuildCrosService( | 155 static ProfileKeyedService* BuildCrosService( |
157 content::BrowserContext* context) { | 156 content::BrowserContext* context) { |
158 Profile* profile = static_cast<Profile*>(context); | 157 Profile* profile = static_cast<Profile*>(context); |
159 SigninManagerBase* signin = | 158 SigninManagerBase* signin = |
160 SigninManagerFactory::GetForProfile(profile); | 159 SigninManagerFactory::GetForProfile(profile); |
161 signin->SetAuthenticatedUsername("test_user"); | 160 profile->GetPrefs()->SetString(prefs::kGoogleServicesUsername, |
| 161 "test_user"); |
| 162 signin->Initialize(profile); |
| 163 EXPECT_FALSE(signin->GetAuthenticatedUsername().empty()); |
162 return new TestProfileSyncService( | 164 return new TestProfileSyncService( |
163 new ProfileSyncComponentsFactoryMock(), | 165 new ProfileSyncComponentsFactoryMock(), |
164 profile, | 166 profile, |
165 signin, | 167 signin, |
166 ProfileSyncService::AUTO_START, | 168 ProfileSyncService::AUTO_START, |
167 true); | 169 true); |
168 } | 170 } |
169 | |
170 protected: | |
171 virtual void CreateSyncService() OVERRIDE { | |
172 sync_ = static_cast<TestProfileSyncService*>( | |
173 ProfileSyncServiceFactory::GetInstance()->SetTestingFactoryAndUse( | |
174 profile_.get(), BuildCrosService)); | |
175 } | |
176 }; | 171 }; |
177 | 172 |
| 173 ProfileKeyedService* BuildFakeTokenService(content::BrowserContext* profile) { |
| 174 return new FakeTokenService(); |
| 175 } |
| 176 |
178 TEST_F(ProfileSyncServiceStartupTest, StartFirstTime) { | 177 TEST_F(ProfileSyncServiceStartupTest, StartFirstTime) { |
| 178 // We've never completed startup. |
| 179 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); |
| 180 SigninManagerFactory::GetForProfile( |
| 181 profile_.get())->Initialize(profile_.get()); |
| 182 CreateSyncService(); |
179 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 183 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
180 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); | 184 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); |
181 | 185 |
182 // We've never completed startup. | |
183 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); | |
184 // Make sure SigninManager doesn't think we're signed in (undoes the call to | |
185 // SetAuthenticatedUsername() in CreateSyncService()). | |
186 SigninManagerFactory::GetForProfile(profile_.get())->SignOut(); | |
187 | |
188 // Should not actually start, rather just clean things up and wait | 186 // Should not actually start, rather just clean things up and wait |
189 // to be enabled. | 187 // to be enabled. |
190 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 188 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
191 sync_->Initialize(); | 189 sync_->Initialize(); |
192 | 190 |
193 // Preferences should be back to defaults. | 191 // Preferences should be back to defaults. |
194 EXPECT_EQ(0, profile_->GetPrefs()->GetInt64(prefs::kSyncLastSyncedTime)); | 192 EXPECT_EQ(0, profile_->GetPrefs()->GetInt64(prefs::kSyncLastSyncedTime)); |
195 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)); | 193 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)); |
196 Mock::VerifyAndClearExpectations(data_type_manager); | 194 Mock::VerifyAndClearExpectations(data_type_manager); |
197 | 195 |
198 // Then start things up. | 196 // Then start things up. |
199 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(1); | 197 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(1); |
200 EXPECT_CALL(*data_type_manager, state()). | 198 EXPECT_CALL(*data_type_manager, state()). |
201 WillOnce(Return(DataTypeManager::CONFIGURED)). | 199 WillOnce(Return(DataTypeManager::CONFIGURED)). |
202 WillOnce(Return(DataTypeManager::CONFIGURED)); | 200 WillOnce(Return(DataTypeManager::CONFIGURED)); |
203 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 201 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
204 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 202 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
205 | 203 |
206 // Create some tokens in the token service; the service will startup when | |
207 // it is notified that tokens are available. | |
208 sync_->SetSetupInProgress(true); | 204 sync_->SetSetupInProgress(true); |
209 Signin(); | 205 |
| 206 // Simulate successful signin as test_user. |
| 207 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, |
| 208 "test_user"); |
| 209 sync_->signin()->SetAuthenticatedUsername("test_user"); |
| 210 GoogleServiceSigninSuccessDetails details("test_user", ""); |
| 211 content::NotificationService::current()->Notify( |
| 212 chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL, |
| 213 content::Source<Profile>(profile_.get()), |
| 214 content::Details<const GoogleServiceSigninSuccessDetails>(&details)); |
| 215 |
| 216 // Create some tokens in the token service. |
210 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 217 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
211 GaiaConstants::kSyncService, "sync_token"); | 218 GaiaConstants::kSyncService, "sync_token"); |
212 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 219 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
213 GaiaConstants::kGaiaOAuth2LoginRefreshToken, "oauth2_login_token"); | 220 GaiaConstants::kGaiaOAuth2LoginRefreshToken, "oauth2_login_token"); |
| 221 |
| 222 // Simulate the UI telling sync it has finished setting up. |
214 sync_->SetSetupInProgress(false); | 223 sync_->SetSetupInProgress(false); |
215 EXPECT_TRUE(sync_->ShouldPushChanges()); | 224 EXPECT_TRUE(sync_->ShouldPushChanges()); |
216 } | 225 } |
217 | 226 |
218 ProfileKeyedService* BuildFakeTokenService(content::BrowserContext* profile) { | |
219 return new FakeTokenService(); | |
220 } | |
221 | |
222 TEST_F(ProfileSyncServiceStartupTest, StartNoCredentials) { | 227 TEST_F(ProfileSyncServiceStartupTest, StartNoCredentials) { |
223 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 228 // We've never completed startup. |
224 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); | 229 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); |
| 230 SigninManagerFactory::GetForProfile( |
| 231 profile_.get())->Initialize(profile_.get()); |
225 TokenService* token_service = static_cast<TokenService*>( | 232 TokenService* token_service = static_cast<TokenService*>( |
226 TokenServiceFactory::GetInstance()->SetTestingFactoryAndUse( | 233 TokenServiceFactory::GetInstance()->SetTestingFactoryAndUse( |
227 profile_.get(), BuildFakeTokenService)); | 234 profile_.get(), BuildFakeTokenService)); |
228 | 235 CreateSyncService(); |
229 // We've never completed startup. | 236 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
230 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); | 237 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); |
231 // Make sure SigninManager doesn't think we're signed in (undoes the call to | |
232 // SetAuthenticatedUsername() in CreateSyncService()). | |
233 SigninManagerFactory::GetForProfile(profile_.get())->SignOut(); | |
234 | 238 |
235 // Should not actually start, rather just clean things up and wait | 239 // Should not actually start, rather just clean things up and wait |
236 // to be enabled. | 240 // to be enabled. |
237 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 241 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
238 sync_->Initialize(); | 242 sync_->Initialize(); |
239 EXPECT_FALSE(sync_->GetBackendForTest()); | 243 EXPECT_FALSE(sync_->GetBackendForTest()); |
240 | 244 |
241 // Preferences should be back to defaults. | 245 // Preferences should be back to defaults. |
242 EXPECT_EQ(0, profile_->GetPrefs()->GetInt64(prefs::kSyncLastSyncedTime)); | 246 EXPECT_EQ(0, profile_->GetPrefs()->GetInt64(prefs::kSyncLastSyncedTime)); |
243 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)); | 247 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)); |
244 Mock::VerifyAndClearExpectations(data_type_manager); | 248 Mock::VerifyAndClearExpectations(data_type_manager); |
245 | 249 |
246 // Then start things up. | 250 // Then start things up. |
247 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(1); | 251 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(1); |
248 EXPECT_CALL(*data_type_manager, state()). | 252 EXPECT_CALL(*data_type_manager, state()). |
249 WillOnce(Return(DataTypeManager::CONFIGURED)). | 253 WillOnce(Return(DataTypeManager::CONFIGURED)). |
250 WillOnce(Return(DataTypeManager::CONFIGURED)); | 254 WillOnce(Return(DataTypeManager::CONFIGURED)); |
251 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 255 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
252 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 256 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
253 | 257 |
254 sync_->SetSetupInProgress(true); | 258 sync_->SetSetupInProgress(true); |
255 Signin(); | 259 |
| 260 // Simulate successful signin as test_user. |
| 261 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, |
| 262 "test_user"); |
| 263 sync_->signin()->SetAuthenticatedUsername("test_user"); |
| 264 GoogleServiceSigninSuccessDetails details("test_user", ""); |
| 265 content::NotificationService::current()->Notify( |
| 266 chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL, |
| 267 content::Source<Profile>(profile_.get()), |
| 268 content::Details<const GoogleServiceSigninSuccessDetails>(&details)); |
256 // NOTE: Unlike StartFirstTime, this test does not issue any auth tokens. | 269 // NOTE: Unlike StartFirstTime, this test does not issue any auth tokens. |
257 token_service->LoadTokensFromDB(); | 270 token_service->LoadTokensFromDB(); |
| 271 |
258 sync_->SetSetupInProgress(false); | 272 sync_->SetSetupInProgress(false); |
259 // Backend should initialize using a bogus GAIA token for credentials. | 273 // Backend should initialize using a bogus GAIA token for credentials. |
260 EXPECT_TRUE(sync_->ShouldPushChanges()); | 274 EXPECT_TRUE(sync_->ShouldPushChanges()); |
261 } | 275 } |
262 | 276 |
263 TEST_F(ProfileSyncServiceStartupTest, StartInvalidCredentials) { | 277 TEST_F(ProfileSyncServiceStartupTest, StartInvalidCredentials) { |
| 278 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, |
| 279 "test_user"); |
| 280 SigninManagerFactory::GetForProfile( |
| 281 profile_.get())->Initialize(profile_.get()); |
| 282 CreateSyncService(); |
264 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 283 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
265 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); | 284 EXPECT_CALL(*data_type_manager, Configure(_, _)).Times(0); |
266 TokenService* token_service = static_cast<TokenService*>( | 285 TokenService* token_service = static_cast<TokenService*>( |
267 TokenServiceFactory::GetInstance()->SetTestingFactoryAndUse( | 286 TokenServiceFactory::GetInstance()->SetTestingFactoryAndUse( |
268 profile_.get(), BuildFakeTokenService)); | 287 profile_.get(), BuildFakeTokenService)); |
269 token_service->LoadTokensFromDB(); | 288 token_service->LoadTokensFromDB(); |
270 | 289 |
271 // Tell the backend to stall while downloading control types (simulating an | 290 // Tell the backend to stall while downloading control types (simulating an |
272 // auth error). | 291 // auth error). |
273 sync_->fail_initial_download(); | 292 sync_->fail_initial_download(); |
274 | 293 |
275 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 294 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
276 sync_->Initialize(); | 295 sync_->Initialize(); |
277 EXPECT_TRUE(sync_->GetBackendForTest()); | 296 EXPECT_TRUE(sync_->GetBackendForTest()); |
278 EXPECT_FALSE(sync_->sync_initialized()); | 297 EXPECT_FALSE(sync_->sync_initialized()); |
279 EXPECT_FALSE(sync_->ShouldPushChanges()); | 298 EXPECT_FALSE(sync_->ShouldPushChanges()); |
280 Mock::VerifyAndClearExpectations(data_type_manager); | 299 Mock::VerifyAndClearExpectations(data_type_manager); |
281 | 300 |
282 // Update the credentials, unstalling the backend. | 301 // Update the credentials, unstalling the backend. |
283 EXPECT_CALL(*data_type_manager, Configure(_, _)); | 302 EXPECT_CALL(*data_type_manager, Configure(_, _)); |
284 EXPECT_CALL(*data_type_manager, state()). | 303 EXPECT_CALL(*data_type_manager, state()). |
285 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); | 304 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); |
286 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 305 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
287 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 306 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
288 sync_->SetSetupInProgress(true); | 307 sync_->SetSetupInProgress(true); |
289 Signin(); | 308 |
| 309 // Simulate successful signin. |
| 310 GoogleServiceSigninSuccessDetails details("test_user", std::string()); |
| 311 content::NotificationService::current()->Notify( |
| 312 chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL, |
| 313 content::Source<Profile>(profile_.get()), |
| 314 content::Details<const GoogleServiceSigninSuccessDetails>(&details)); |
| 315 |
290 token_service->IssueAuthTokenForTest( | 316 token_service->IssueAuthTokenForTest( |
291 GaiaConstants::kSyncService, "sync_token"); | 317 GaiaConstants::kSyncService, "sync_token"); |
292 sync_->SetSetupInProgress(false); | 318 sync_->SetSetupInProgress(false); |
293 MessageLoop::current()->Run(); | 319 MessageLoop::current()->Run(); |
294 | 320 |
295 // Verify we successfully finish startup and configuration. | 321 // Verify we successfully finish startup and configuration. |
296 EXPECT_TRUE(sync_->ShouldPushChanges()); | 322 EXPECT_TRUE(sync_->ShouldPushChanges()); |
297 } | 323 } |
298 | 324 |
299 TEST_F(ProfileSyncServiceStartupCrosTest, StartCrosNoCredentials) { | 325 TEST_F(ProfileSyncServiceStartupCrosTest, StartCrosNoCredentials) { |
(...skipping 26 matching lines...) Expand all Loading... |
326 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 352 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
327 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 353 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
328 | 354 |
329 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 355 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
330 GaiaConstants::kSyncService, "sync_token"); | 356 GaiaConstants::kSyncService, "sync_token"); |
331 sync_->Initialize(); | 357 sync_->Initialize(); |
332 EXPECT_TRUE(sync_->ShouldPushChanges()); | 358 EXPECT_TRUE(sync_->ShouldPushChanges()); |
333 } | 359 } |
334 | 360 |
335 TEST_F(ProfileSyncServiceStartupTest, StartNormal) { | 361 TEST_F(ProfileSyncServiceStartupTest, StartNormal) { |
| 362 // Pre load the tokens |
| 363 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 364 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 365 profile_.get()); |
| 366 CreateSyncService(); |
336 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 367 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
337 EXPECT_CALL(*data_type_manager, Configure(_, _)); | 368 EXPECT_CALL(*data_type_manager, Configure(_, _)); |
338 EXPECT_CALL(*data_type_manager, state()). | 369 EXPECT_CALL(*data_type_manager, state()). |
339 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); | 370 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); |
340 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 371 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
341 | |
342 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 372 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
343 | 373 |
344 // Pre load the tokens | |
345 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 374 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
346 GaiaConstants::kSyncService, "sync_token"); | 375 GaiaConstants::kSyncService, "sync_token"); |
347 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | 376 |
348 sync_->Initialize(); | 377 sync_->Initialize(); |
349 } | 378 } |
350 | 379 |
351 // Test that we can recover from a case where a bug in the code resulted in | 380 // Test that we can recover from a case where a bug in the code resulted in |
352 // OnUserChoseDatatypes not being properly called and datatype preferences | 381 // OnUserChoseDatatypes not being properly called and datatype preferences |
353 // therefore being left unset. | 382 // therefore being left unset. |
354 TEST_F(ProfileSyncServiceStartupTest, StartRecoverDatatypePrefs) { | 383 TEST_F(ProfileSyncServiceStartupTest, StartRecoverDatatypePrefs) { |
355 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | |
356 EXPECT_CALL(*data_type_manager, Configure(_, _)); | |
357 EXPECT_CALL(*data_type_manager, state()). | |
358 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); | |
359 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | |
360 | |
361 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | |
362 | |
363 // Clear the datatype preference fields (simulating bug 154940). | 384 // Clear the datatype preference fields (simulating bug 154940). |
364 profile_->GetPrefs()->ClearPref(prefs::kSyncKeepEverythingSynced); | 385 profile_->GetPrefs()->ClearPref(prefs::kSyncKeepEverythingSynced); |
365 syncer::ModelTypeSet user_types = syncer::UserTypes(); | 386 syncer::ModelTypeSet user_types = syncer::UserTypes(); |
366 for (syncer::ModelTypeSet::Iterator iter = user_types.First(); | 387 for (syncer::ModelTypeSet::Iterator iter = user_types.First(); |
367 iter.Good(); iter.Inc()) { | 388 iter.Good(); iter.Inc()) { |
368 profile_->GetPrefs()->ClearPref( | 389 profile_->GetPrefs()->ClearPref( |
369 browser_sync::SyncPrefs::GetPrefNameForDataType(iter.Get())); | 390 browser_sync::SyncPrefs::GetPrefNameForDataType(iter.Get())); |
370 } | 391 } |
371 | 392 |
372 // Pre load the tokens | 393 // Pre load the tokens |
| 394 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 395 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 396 profile_.get()); |
| 397 CreateSyncService(); |
| 398 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
| 399 EXPECT_CALL(*data_type_manager, Configure(_, _)); |
| 400 EXPECT_CALL(*data_type_manager, state()). |
| 401 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); |
| 402 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
| 403 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
| 404 |
373 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 405 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
374 GaiaConstants::kSyncService, "sync_token"); | 406 GaiaConstants::kSyncService, "sync_token"); |
375 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | |
376 sync_->Initialize(); | 407 sync_->Initialize(); |
377 | 408 |
378 EXPECT_TRUE(profile_->GetPrefs()->GetBoolean( | 409 EXPECT_TRUE(profile_->GetPrefs()->GetBoolean( |
379 prefs::kSyncKeepEverythingSynced)); | 410 prefs::kSyncKeepEverythingSynced)); |
380 } | 411 } |
381 | 412 |
382 // Verify that the recovery of datatype preferences doesn't overwrite a valid | 413 // Verify that the recovery of datatype preferences doesn't overwrite a valid |
383 // case where only bookmarks are enabled. | 414 // case where only bookmarks are enabled. |
384 TEST_F(ProfileSyncServiceStartupTest, StartDontRecoverDatatypePrefs) { | 415 TEST_F(ProfileSyncServiceStartupTest, StartDontRecoverDatatypePrefs) { |
| 416 // Explicitly set Keep Everything Synced to false and have only bookmarks |
| 417 // enabled. |
| 418 profile_->GetPrefs()->SetBoolean(prefs::kSyncKeepEverythingSynced, false); |
| 419 |
| 420 // Pre load the tokens |
| 421 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 422 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 423 profile_.get()); |
| 424 CreateSyncService(); |
385 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 425 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
386 EXPECT_CALL(*data_type_manager, Configure(_, _)); | 426 EXPECT_CALL(*data_type_manager, Configure(_, _)); |
387 EXPECT_CALL(*data_type_manager, state()). | 427 EXPECT_CALL(*data_type_manager, state()). |
388 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); | 428 WillRepeatedly(Return(DataTypeManager::CONFIGURED)); |
389 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 429 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
390 | |
391 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 430 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
392 | |
393 // Explicitly set Keep Everything Synced to false and have only bookmarks | |
394 // enabled. | |
395 profile_->GetPrefs()->SetBoolean(prefs::kSyncKeepEverythingSynced, false); | |
396 | |
397 // Pre load the tokens | |
398 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 431 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
399 GaiaConstants::kSyncService, "sync_token"); | 432 GaiaConstants::kSyncService, "sync_token"); |
400 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | |
401 sync_->Initialize(); | 433 sync_->Initialize(); |
402 | 434 |
403 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean( | 435 EXPECT_FALSE(profile_->GetPrefs()->GetBoolean( |
404 prefs::kSyncKeepEverythingSynced)); | 436 prefs::kSyncKeepEverythingSynced)); |
405 } | 437 } |
406 | 438 |
407 TEST_F(ProfileSyncServiceStartupTest, ManagedStartup) { | 439 TEST_F(ProfileSyncServiceStartupTest, ManagedStartup) { |
| 440 // Service should not be started by Initialize() since it's managed. |
| 441 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 442 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 443 profile_.get()); |
| 444 CreateSyncService(); |
| 445 |
408 // Disable sync through policy. | 446 // Disable sync through policy. |
409 profile_->GetPrefs()->SetBoolean(prefs::kSyncManaged, true); | 447 profile_->GetPrefs()->SetBoolean(prefs::kSyncManaged, true); |
410 | |
411 EXPECT_CALL(*sync_->components_factory_mock(), | 448 EXPECT_CALL(*sync_->components_factory_mock(), |
412 CreateDataTypeManager(_, _, _, _, _)).Times(0); | 449 CreateDataTypeManager(_, _, _, _, _)).Times(0); |
413 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 450 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
414 | 451 |
415 // Service should not be started by Initialize() since it's managed. | |
416 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 452 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
417 GaiaConstants::kSyncService, "sync_token"); | 453 GaiaConstants::kSyncService, "sync_token"); |
418 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | |
419 sync_->Initialize(); | 454 sync_->Initialize(); |
420 } | 455 } |
421 | 456 |
422 TEST_F(ProfileSyncServiceStartupTest, SwitchManaged) { | 457 TEST_F(ProfileSyncServiceStartupTest, SwitchManaged) { |
| 458 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 459 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 460 profile_.get()); |
| 461 CreateSyncService(); |
423 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 462 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
424 EXPECT_CALL(*data_type_manager, Configure(_, _)); | 463 EXPECT_CALL(*data_type_manager, Configure(_, _)); |
425 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 464 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
426 | |
427 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 465 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
428 GaiaConstants::kSyncService, "sync_token"); | 466 GaiaConstants::kSyncService, "sync_token"); |
429 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | |
430 sync_->Initialize(); | 467 sync_->Initialize(); |
431 | 468 |
432 // The service should stop when switching to managed mode. | 469 // The service should stop when switching to managed mode. |
433 Mock::VerifyAndClearExpectations(data_type_manager); | 470 Mock::VerifyAndClearExpectations(data_type_manager); |
434 EXPECT_CALL(*data_type_manager, state()). | 471 EXPECT_CALL(*data_type_manager, state()). |
435 WillOnce(Return(DataTypeManager::CONFIGURED)); | 472 WillOnce(Return(DataTypeManager::CONFIGURED)); |
436 EXPECT_CALL(*data_type_manager, Stop()).Times(1); | 473 EXPECT_CALL(*data_type_manager, Stop()).Times(1); |
437 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 474 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
438 profile_->GetPrefs()->SetBoolean(prefs::kSyncManaged, true); | 475 profile_->GetPrefs()->SetBoolean(prefs::kSyncManaged, true); |
439 | 476 |
440 // When switching back to unmanaged, the state should change, but the service | 477 // When switching back to unmanaged, the state should change, but the service |
441 // should not start up automatically (kSyncSetupCompleted will be false). | 478 // should not start up automatically (kSyncSetupCompleted will be false). |
442 Mock::VerifyAndClearExpectations(data_type_manager); | 479 Mock::VerifyAndClearExpectations(data_type_manager); |
443 EXPECT_CALL(*sync_->components_factory_mock(), | 480 EXPECT_CALL(*sync_->components_factory_mock(), |
444 CreateDataTypeManager(_, _, _, _, _)).Times(0); | 481 CreateDataTypeManager(_, _, _, _, _)).Times(0); |
445 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 482 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
446 profile_->GetPrefs()->ClearPref(prefs::kSyncManaged); | 483 profile_->GetPrefs()->ClearPref(prefs::kSyncManaged); |
447 } | 484 } |
448 | 485 |
449 TEST_F(ProfileSyncServiceStartupTest, StartFailure) { | 486 TEST_F(ProfileSyncServiceStartupTest, StartFailure) { |
| 487 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 488 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 489 profile_.get()); |
| 490 CreateSyncService(); |
450 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); | 491 DataTypeManagerMock* data_type_manager = SetUpDataTypeManager(); |
451 DataTypeManager::ConfigureStatus status = DataTypeManager::ABORTED; | 492 DataTypeManager::ConfigureStatus status = DataTypeManager::ABORTED; |
452 syncer::SyncError error( | 493 syncer::SyncError error( |
453 FROM_HERE, "Association failed.", syncer::BOOKMARKS); | 494 FROM_HERE, "Association failed.", syncer::BOOKMARKS); |
454 std::list<syncer::SyncError> errors; | 495 std::list<syncer::SyncError> errors; |
455 errors.push_back(error); | 496 errors.push_back(error); |
456 DataTypeManager::ConfigureResult result( | 497 DataTypeManager::ConfigureResult result( |
457 status, | 498 status, |
458 syncer::ModelTypeSet(), | 499 syncer::ModelTypeSet(), |
459 errors, | 500 errors, |
460 syncer::ModelTypeSet()); | 501 syncer::ModelTypeSet()); |
461 EXPECT_CALL(*data_type_manager, Configure(_, _)). | 502 EXPECT_CALL(*data_type_manager, Configure(_, _)). |
462 WillRepeatedly( | 503 WillRepeatedly( |
463 DoAll(InvokeOnConfigureStart(sync_), | 504 DoAll(InvokeOnConfigureStart(sync_), |
464 InvokeOnConfigureDone(sync_, result))); | 505 InvokeOnConfigureDone(sync_, result))); |
465 EXPECT_CALL(*data_type_manager, state()). | 506 EXPECT_CALL(*data_type_manager, state()). |
466 WillOnce(Return(DataTypeManager::STOPPED)); | 507 WillOnce(Return(DataTypeManager::STOPPED)); |
467 | |
468 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 508 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
469 | |
470 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 509 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
471 GaiaConstants::kSyncService, "sync_token"); | 510 GaiaConstants::kSyncService, "sync_token"); |
472 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); | |
473 sync_->Initialize(); | 511 sync_->Initialize(); |
474 EXPECT_TRUE(sync_->HasUnrecoverableError()); | 512 EXPECT_TRUE(sync_->HasUnrecoverableError()); |
475 } | 513 } |
476 | 514 |
477 TEST_F(ProfileSyncServiceStartupTest, StartDownloadFailed) { | 515 TEST_F(ProfileSyncServiceStartupTest, StartDownloadFailed) { |
| 516 // Pre load the tokens |
| 517 profile_->GetPrefs()->SetString(prefs::kGoogleServicesUsername, "test_user"); |
| 518 SigninManagerFactory::GetForProfile(profile_.get())->Initialize( |
| 519 profile_.get()); |
| 520 CreateSyncService(); |
| 521 |
478 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); | 522 profile_->GetPrefs()->ClearPref(prefs::kSyncHasSetupCompleted); |
479 | 523 |
480 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); | 524 EXPECT_CALL(observer_, OnStateChanged()).Times(AnyNumber()); |
481 | |
482 // Preload the tokens. | |
483 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( | 525 TokenServiceFactory::GetForProfile(profile_.get())->IssueAuthTokenForTest( |
484 GaiaConstants::kSyncService, "sync_token"); | 526 GaiaConstants::kSyncService, "sync_token"); |
485 sync_->fail_initial_download(); | 527 sync_->fail_initial_download(); |
486 | 528 |
487 sync_->Initialize(); | 529 sync_->Initialize(); |
488 EXPECT_FALSE(sync_->sync_initialized()); | 530 EXPECT_FALSE(sync_->sync_initialized()); |
489 EXPECT_FALSE(sync_->GetBackendForTest()); | 531 EXPECT_FALSE(sync_->GetBackendForTest()); |
490 } | 532 } |
OLD | NEW |