chrome/browser/sync/profile_sync_service_unittest.cc

   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
   3 // found in the LICENSE file.
   4
   5 #include "base/basictypes.h"
   6 #include "base/callback.h"
   7 #include "base/command_line.h"
   8 #include "base/compiler_specific.h"
   9 #include "base/location.h"
  10 #include "base/memory/scoped_ptr.h"
  11 #include "base/run_loop.h"
  12 #include "base/single_thread_task_runner.h"
  13 #include "base/strings/string_number_conversions.h"
  14 #include "base/strings/utf_string_conversions.h"
  15 #include "base/thread_task_runner_handle.h"
  16 #include "base/values.h"
  17 #include "chrome/browser/invalidation/fake_invalidation_service.h"
  18 #include "chrome/browser/invalidation/profile_invalidation_provider_factory.h"
  19 #include "chrome/browser/signin/account_tracker_service_factory.h"
  20 #include "chrome/browser/signin/fake_profile_oauth2_token_service_builder.h"
  21 #include "chrome/browser/signin/profile_oauth2_token_service_factory.h"
  22 #include "chrome/browser/signin/signin_manager_factory.h"
  23 #include "chrome/browser/sync/glue/sync_backend_host_mock.h"
  24 #include "chrome/browser/sync/profile_sync_components_factory_mock.h"
  25 #include "chrome/browser/sync/profile_sync_service.h"
  26 #include "chrome/common/chrome_switches.h"
  27 #include "chrome/common/pref_names.h"
  28 #include "chrome/grit/generated_resources.h"
  29 #include "chrome/test/base/testing_browser_process.h"
  30 #include "chrome/test/base/testing_pref_service_syncable.h"
  31 #include "chrome/test/base/testing_profile.h"
  32 #include "chrome/test/base/testing_profile_manager.h"
  33 #include "components/invalidation/impl/profile_invalidation_provider.h"
  34 #include "components/invalidation/public/invalidation_service.h"
  35 #include "components/signin/core/browser/account_tracker_service.h"
  36 #include "components/signin/core/browser/fake_profile_oauth2_token_service.h"
  37 #include "components/signin/core/browser/signin_manager.h"
  38 #include "components/signin/core/browser/signin_manager.h"
  39 #include "components/sync_driver/data_type_manager.h"
  40 #include "components/sync_driver/data_type_manager_observer.h"
  41 #include "components/sync_driver/fake_data_type_controller.h"
  42 #include "components/sync_driver/pref_names.h"
  43 #include "components/sync_driver/signin_manager_wrapper.h"
  44 #include "components/sync_driver/sync_driver_switches.h"
  45 #include "components/sync_driver/sync_prefs.h"
  46 #include "components/sync_driver/sync_service_observer.h"
  47 #include "components/sync_driver/sync_util.h"
  48 #include "components/version_info/version_info_values.h"
  49 #include "content/public/test/test_browser_thread_bundle.h"
  50 #include "google_apis/gaia/gaia_constants.h"
  51 #include "testing/gmock/include/gmock/gmock.h"
  52 #include "testing/gtest/include/gtest/gtest.h"
  53 #include "ui/base/l10n/l10n_util.h"
  54
  55 namespace content {
  56 class BrowserContext;
  57 }
  58
  59 namespace browser_sync {
  60
  61 namespace {
  62
  63 const char kGaiaId[] = "12345";
  64 const char kEmail[] = "test_user@gmail.com";
  65
  66 class FakeDataTypeManager : public sync_driver::DataTypeManager {
  67  public:
  68   typedef base::Callback<void(syncer::ConfigureReason)> ConfigureCalled;
  69
  70   explicit FakeDataTypeManager(const ConfigureCalled& configure_called)
  71       : configure_called_(configure_called) {}
  72
  73   ~FakeDataTypeManager() override{};
  74
  75   void Configure(syncer::ModelTypeSet desired_types,
  76                  syncer::ConfigureReason reason) override {
  77     DCHECK(!configure_called_.is_null());
  78     configure_called_.Run(reason);
  79   }
  80
  81   void ReenableType(syncer::ModelType type) override {}
  82   void ResetDataTypeErrors() override {}
  83   void PurgeForMigration(syncer::ModelTypeSet undesired_types,
  84                          syncer::ConfigureReason reason) override {}
  85   void Stop() override{};
  86   State state() const override {
  87     return sync_driver::DataTypeManager::CONFIGURED;
  88   };
  89
  90  private:
  91   ConfigureCalled configure_called_;
  92 };
  93
  94 ACTION_P(ReturnNewDataTypeManager, configure_called) {
  95   return new FakeDataTypeManager(configure_called);
  96 }
  97
  98 using testing::Return;
  99 using testing::StrictMock;
 100 using testing::_;
 101
 102 class TestSyncServiceObserver : public sync_driver::SyncServiceObserver {
 103  public:
 104   explicit TestSyncServiceObserver(ProfileSyncService* service)
 105       : service_(service), first_setup_in_progress_(false) {}
 106   void OnStateChanged() override {
 107     first_setup_in_progress_ = service_->IsFirstSetupInProgress();
 108   }
 109   bool first_setup_in_progress() const { return first_setup_in_progress_; }
 110  private:
 111   ProfileSyncService* service_;
 112   bool first_setup_in_progress_;
 113 };
 114
 115 // A variant of the SyncBackendHostMock that won't automatically
 116 // call back when asked to initialized.  Allows us to test things
 117 // that could happen while backend init is in progress.
 118 class SyncBackendHostNoReturn : public SyncBackendHostMock {
 119   void Initialize(
 120       sync_driver::SyncFrontend* frontend,
 121       scoped_ptr<base::Thread> sync_thread,
 122       const syncer::WeakHandle<syncer::JsEventHandler>& event_handler,
 123       const GURL& service_url,
 124       const std::string& sync_user_agent,
 125       const syncer::SyncCredentials& credentials,
 126       bool delete_sync_data_folder,
 127       scoped_ptr<syncer::SyncManagerFactory> sync_manager_factory,
 128       const syncer::WeakHandle<syncer::UnrecoverableErrorHandler>&
 129           unrecoverable_error_handler,
 130       const base::Closure& report_unrecoverable_error_function,
 131       syncer::NetworkResources* network_resources,
 132       scoped_ptr<syncer::SyncEncryptionHandler::NigoriState> saved_nigori_state)
 133       override {}
 134 };
 135
 136 class SyncBackendHostMockCollectDeleteDirParam : public SyncBackendHostMock {
 137  public:
 138   explicit SyncBackendHostMockCollectDeleteDirParam(
 139       std::vector<bool>* delete_dir_param)
 140      : delete_dir_param_(delete_dir_param) {}
 141
 142   void Initialize(
 143       sync_driver::SyncFrontend* frontend,
 144       scoped_ptr<base::Thread> sync_thread,
 145       const syncer::WeakHandle<syncer::JsEventHandler>& event_handler,
 146       const GURL& service_url,
 147       const std::string& sync_user_agent,
 148       const syncer::SyncCredentials& credentials,
 149       bool delete_sync_data_folder,
 150       scoped_ptr<syncer::SyncManagerFactory> sync_manager_factory,
 151       const syncer::WeakHandle<syncer::UnrecoverableErrorHandler>&
 152           unrecoverable_error_handler,
 153       const base::Closure& report_unrecoverable_error_function,
 154       syncer::NetworkResources* network_resources,
 155       scoped_ptr<syncer::SyncEncryptionHandler::NigoriState> saved_nigori_state)
 156       override {
 157     delete_dir_param_->push_back(delete_sync_data_folder);
 158     SyncBackendHostMock::Initialize(frontend, sync_thread.Pass(),
 159                                     event_handler, service_url, sync_user_agent,
 160                                     credentials, delete_sync_data_folder,
 161                                     sync_manager_factory.Pass(),
 162                                     unrecoverable_error_handler,
 163                                     report_unrecoverable_error_function,
 164                                     network_resources,
 165                                     saved_nigori_state.Pass());
 166   }
 167
 168  private:
 169   std::vector<bool>* delete_dir_param_;
 170 };
 171
 172 // SyncBackendHostMock that calls an external callback when ClearServerData is
 173 // called.
 174 class SyncBackendHostCaptureClearServerData : public SyncBackendHostMock {
 175  public:
 176   typedef base::Callback<void(
 177       const syncer::SyncManager::ClearServerDataCallback&)>
 178       ClearServerDataCalled;
 179   explicit SyncBackendHostCaptureClearServerData(
 180       const ClearServerDataCalled& clear_server_data_called)
 181       : clear_server_data_called_(clear_server_data_called) {}
 182
 183   void ClearServerData(
 184       const syncer::SyncManager::ClearServerDataCallback& callback) override {
 185     clear_server_data_called_.Run(callback);
 186   }
 187
 188  private:
 189   ClearServerDataCalled clear_server_data_called_;
 190 };
 191
 192 ACTION(ReturnNewSyncBackendHostMock) {
 193   return new browser_sync::SyncBackendHostMock();
 194 }
 195
 196 ACTION(ReturnNewSyncBackendHostNoReturn) {
 197   return new browser_sync::SyncBackendHostNoReturn();
 198 }
 199
 200 ACTION_P(ReturnNewMockHostCollectDeleteDirParam, delete_dir_param) {
 201   return new browser_sync::SyncBackendHostMockCollectDeleteDirParam(
 202       delete_dir_param);
 203 }
 204
 205 void OnClearServerDataCalled(
 206     syncer::SyncManager::ClearServerDataCallback* captured_callback,
 207     const syncer::SyncManager::ClearServerDataCallback& callback) {
 208   *captured_callback = callback;
 209 }
 210
 211 ACTION_P(ReturnNewMockHostCaptureClearServerData, captured_callback) {
 212   return new SyncBackendHostCaptureClearServerData(base::Bind(
 213       &OnClearServerDataCalled, base::Unretained(captured_callback)));
 214 }
 215
 216 scoped_ptr<KeyedService> BuildFakeProfileInvalidationProvider(
 217     content::BrowserContext* context) {
 218   return make_scoped_ptr(new invalidation::ProfileInvalidationProvider(
 219       scoped_ptr<invalidation::InvalidationService>(
 220           new invalidation::FakeInvalidationService)));
 221 }
 222
 223 // A test harness that uses a real ProfileSyncService and in most cases a
 224 // MockSyncBackendHost.
 225 //
 226 // This is useful if we want to test the ProfileSyncService and don't care about
 227 // testing the SyncBackendHost.
 228 class ProfileSyncServiceTest : public ::testing::Test {
 229  protected:
 230   ProfileSyncServiceTest()
 231       : thread_bundle_(content::TestBrowserThreadBundle::IO_MAINLOOP),
 232         profile_manager_(TestingBrowserProcess::GetGlobal()) {}
 233   ~ProfileSyncServiceTest() override {}
 234
 235   void SetUp() override {
 236     base::CommandLine::ForCurrentProcess()->AppendSwitchASCII(
 237         switches::kSyncDeferredStartupTimeoutSeconds, "0");
 238
 239     CHECK(profile_manager_.SetUp());
 240
 241     TestingProfile::TestingFactories testing_factories;
 242     testing_factories.push_back(
 243         std::make_pair(ProfileOAuth2TokenServiceFactory::GetInstance(),
 244                        BuildAutoIssuingFakeProfileOAuth2TokenService));
 245     testing_factories.push_back(std::make_pair(
 246         invalidation::ProfileInvalidationProviderFactory::GetInstance(),
 247         BuildFakeProfileInvalidationProvider));
 248
 249     profile_ = profile_manager_.CreateTestingProfile(
 250         "sync-service-test", scoped_ptr<PrefServiceSyncable>(),
 251         base::UTF8ToUTF16("sync-service-test"), 0, std::string(),
 252         testing_factories);
 253   }
 254
 255   void TearDown() override {
 256     // Kill the service before the profile.
 257     if (service_)
 258       service_->Shutdown();
 259
 260     service_.reset();
 261   }
 262
 263   void IssueTestTokens() {
 264     std::string account_id =
 265         AccountTrackerServiceFactory::GetForProfile(profile_)
 266             ->SeedAccountInfo(kGaiaId, kEmail);
 267     ProfileOAuth2TokenServiceFactory::GetForProfile(profile_)
 268         ->UpdateCredentials(account_id, "oauth2_login_token");
 269   }
 270
 271   void CreateService(ProfileSyncServiceStartBehavior behavior) {
 272     SigninManagerBase* signin =
 273         SigninManagerFactory::GetForProfile(profile_);
 274     signin->SetAuthenticatedAccountInfo(kGaiaId, kEmail);
 275     ProfileOAuth2TokenService* oauth2_token_service =
 276         ProfileOAuth2TokenServiceFactory::GetForProfile(profile_);
 277     components_factory_ = new ProfileSyncComponentsFactoryMock();
 278     service_.reset(new ProfileSyncService(
 279         scoped_ptr<sync_driver::SyncApiComponentFactory>(components_factory_),
 280         profile_,
 281         make_scoped_ptr(new SigninManagerWrapper(signin)),
 282         oauth2_token_service,
 283         behavior));
 284     service_->SetClearingBrowseringDataForTesting(
 285         base::Bind(&ProfileSyncServiceTest::ClearBrowsingDataCallback,
 286                    base::Unretained(this)));
 287     service_->RegisterDataTypeController(
 288         new sync_driver::FakeDataTypeController(syncer::BOOKMARKS));
 289   }
 290
 291 #if defined(OS_WIN) || defined(OS_MACOSX) || (defined(OS_LINUX) && !defined(OS_CHROMEOS))
 292   void CreateServiceWithoutSignIn() {
 293     CreateService(browser_sync::AUTO_START);
 294     SigninManagerFactory::GetForProfile(profile())->SignOut(
 295         signin_metrics::SIGNOUT_TEST);
 296   }
 297 #endif
 298
 299   void ShutdownAndDeleteService() {
 300     if (service_)
 301       service_->Shutdown();
 302     service_.reset();
 303   }
 304
 305   void InitializeForNthSync() {
 306     // Set first sync time before initialize to disable backup and simulate
 307     // a complete sync setup.
 308     sync_driver::SyncPrefs sync_prefs(service()->profile()->GetPrefs());
 309     sync_prefs.SetFirstSyncTime(base::Time::Now());
 310     sync_prefs.SetSyncSetupCompleted();
 311     sync_prefs.SetKeepEverythingSynced(true);
 312     service_->Initialize();
 313   }
 314
 315   void InitializeForFirstSync() {
 316     service_->Initialize();
 317   }
 318
 319   void TriggerPassphraseRequired() {
 320     service_->OnPassphraseRequired(syncer::REASON_DECRYPTION,
 321                                    sync_pb::EncryptedData());
 322   }
 323
 324   void TriggerDataTypeStartRequest() {
 325     service_->OnDataTypeRequestsSyncStartup(syncer::BOOKMARKS);
 326   }
 327
 328   void OnConfigureCalled(syncer::ConfigureReason configure_reason) {
 329     sync_driver::DataTypeManager::ConfigureResult result;
 330     result.status = sync_driver::DataTypeManager::OK;
 331     service()->OnConfigureDone(result);
 332   }
 333
 334   FakeDataTypeManager::ConfigureCalled GetDefaultConfigureCalledCallback() {
 335     return base::Bind(&ProfileSyncServiceTest::OnConfigureCalled,
 336                       base::Unretained(this));
 337   }
 338
 339   void OnConfigureCalledRecordReason(syncer::ConfigureReason* reason_dest,
 340                                      syncer::ConfigureReason reason) {
 341     DCHECK(reason_dest);
 342     *reason_dest = reason;
 343   }
 344
 345   FakeDataTypeManager::ConfigureCalled GetRecordingConfigureCalledCallback(
 346       syncer::ConfigureReason* reason) {
 347     return base::Bind(&ProfileSyncServiceTest::OnConfigureCalledRecordReason,
 348                       base::Unretained(this), reason);
 349   }
 350
 351   void ExpectDataTypeManagerCreation(
 352       int times,
 353       const FakeDataTypeManager::ConfigureCalled& callback) {
 354     EXPECT_CALL(*components_factory_, CreateDataTypeManager(_, _, _, _, _))
 355         .Times(times)
 356         .WillRepeatedly(ReturnNewDataTypeManager(callback));
 357   }
 358
 359   void ExpectSyncBackendHostCreation(int times) {
 360     EXPECT_CALL(*components_factory_, CreateSyncBackendHost(_, _, _, _))
 361         .Times(times)
 362         .WillRepeatedly(ReturnNewSyncBackendHostMock());
 363   }
 364
 365   void ExpectSyncBackendHostCreationCollectDeleteDir(
 366       int times, std::vector<bool> *delete_dir_param) {
 367     EXPECT_CALL(*components_factory_, CreateSyncBackendHost(_, _, _, _))
 368         .Times(times)
 369         .WillRepeatedly(ReturnNewMockHostCollectDeleteDirParam(
 370             delete_dir_param));
 371   }
 372
 373   void ExpectSyncBackendHostCreationCaptureClearServerData(
 374       syncer::SyncManager::ClearServerDataCallback* captured_callback) {
 375     EXPECT_CALL(*components_factory_, CreateSyncBackendHost(_, _, _, _))
 376         .Times(1)
 377         .WillOnce(ReturnNewMockHostCaptureClearServerData(captured_callback));
 378   }
 379
 380   void PrepareDelayedInitSyncBackendHost() {
 381     EXPECT_CALL(*components_factory_, CreateSyncBackendHost(_, _, _, _)).
 382         WillOnce(ReturnNewSyncBackendHostNoReturn());
 383   }
 384
 385   TestingProfile* profile() {
 386     return profile_;
 387   }
 388
 389   ProfileSyncService* service() {
 390     return service_.get();
 391   }
 392
 393   ProfileSyncComponentsFactoryMock* components_factory() {
 394     return components_factory_;
 395   }
 396
 397   void ClearBrowsingDataCallback(BrowsingDataRemover::Observer* observer,
 398                                  Profile* profile,
 399                                  base::Time start,
 400                                  base::Time end) {
 401     EXPECT_EQ(profile_, profile);
 402     clear_browsing_date_start_ = start;
 403   }
 404
 405  protected:
 406   void PumpLoop() {
 407     base::RunLoop run_loop;
 408     base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
 409                                                   run_loop.QuitClosure());
 410     run_loop.Run();
 411   }
 412
 413   // The requested start time when ClearBrowsingDataCallback is called.
 414   base::Time clear_browsing_date_start_;
 415
 416  private:
 417   content::TestBrowserThreadBundle thread_bundle_;
 418   TestingProfileManager profile_manager_;
 419   TestingProfile* profile_;
 420   scoped_ptr<ProfileSyncService> service_;
 421
 422   // Pointer to the components factory.  Not owned.  May be null.
 423   ProfileSyncComponentsFactoryMock* components_factory_;
 424 };
 425
 426 // Verify that the server URLs are sane.
 427 TEST_F(ProfileSyncServiceTest, InitialState) {
 428   CreateService(browser_sync::AUTO_START);
 429   InitializeForNthSync();
 430   const std::string& url = service()->sync_service_url().spec();
 431   EXPECT_TRUE(url == internal::kSyncServerUrl ||
 432               url == internal::kSyncDevServerUrl);
 433 }
 434
 435 // Verify a successful initialization.
 436 TEST_F(ProfileSyncServiceTest, SuccessfulInitialization) {
 437   profile()->GetTestingPrefService()->SetManagedPref(
 438       sync_driver::prefs::kSyncManaged, new base::FundamentalValue(false));
 439   IssueTestTokens();
 440   CreateService(browser_sync::AUTO_START);
 441   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 442   ExpectSyncBackendHostCreation(1);
 443   InitializeForNthSync();
 444   EXPECT_FALSE(service()->IsManaged());
 445   EXPECT_TRUE(service()->IsSyncActive());
 446   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 447 }
 448
 449
 450 // Verify that the SetSetupInProgress function call updates state
 451 // and notifies observers.
 452 TEST_F(ProfileSyncServiceTest, SetupInProgress) {
 453   CreateService(browser_sync::AUTO_START);
 454   InitializeForFirstSync();
 455
 456   TestSyncServiceObserver observer(service());
 457   service()->AddObserver(&observer);
 458
 459   service()->SetSetupInProgress(true);
 460   EXPECT_TRUE(observer.first_setup_in_progress());
 461   service()->SetSetupInProgress(false);
 462   EXPECT_FALSE(observer.first_setup_in_progress());
 463
 464   service()->RemoveObserver(&observer);
 465 }
 466
 467 // Verify that disable by enterprise policy works.
 468 TEST_F(ProfileSyncServiceTest, DisabledByPolicyBeforeInit) {
 469   profile()->GetTestingPrefService()->SetManagedPref(
 470       sync_driver::prefs::kSyncManaged, new base::FundamentalValue(true));
 471   IssueTestTokens();
 472   CreateService(browser_sync::AUTO_START);
 473   InitializeForNthSync();
 474   EXPECT_TRUE(service()->IsManaged());
 475   EXPECT_FALSE(service()->IsSyncActive());
 476 }
 477
 478 // Verify that disable by enterprise policy works even after the backend has
 479 // been initialized.
 480 TEST_F(ProfileSyncServiceTest, DisabledByPolicyAfterInit) {
 481   IssueTestTokens();
 482   CreateService(browser_sync::AUTO_START);
 483   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 484   ExpectSyncBackendHostCreation(1);
 485   InitializeForNthSync();
 486
 487   EXPECT_FALSE(service()->IsManaged());
 488   EXPECT_TRUE(service()->IsSyncActive());
 489
 490   profile()->GetTestingPrefService()->SetManagedPref(
 491       sync_driver::prefs::kSyncManaged, new base::FundamentalValue(true));
 492
 493   EXPECT_TRUE(service()->IsManaged());
 494   EXPECT_FALSE(service()->IsSyncActive());
 495 }
 496
 497 // Exercies the ProfileSyncService's code paths related to getting shut down
 498 // before the backend initialize call returns.
 499 TEST_F(ProfileSyncServiceTest, AbortedByShutdown) {
 500   CreateService(browser_sync::AUTO_START);
 501   PrepareDelayedInitSyncBackendHost();
 502
 503   IssueTestTokens();
 504   InitializeForNthSync();
 505   EXPECT_FALSE(service()->IsSyncActive());
 506
 507   ShutdownAndDeleteService();
 508 }
 509
 510 // Test RequestStop() before we've initialized the backend.
 511 TEST_F(ProfileSyncServiceTest, EarlyRequestStop) {
 512   CreateService(browser_sync::AUTO_START);
 513   IssueTestTokens();
 514
 515   service()->RequestStop(ProfileSyncService::KEEP_DATA);
 516   EXPECT_TRUE(profile()->GetPrefs()->GetBoolean(
 517       sync_driver::prefs::kSyncSuppressStart));
 518
 519   // Because of suppression, this should fail.
 520   sync_driver::SyncPrefs sync_prefs(service()->profile()->GetPrefs());
 521   sync_prefs.SetFirstSyncTime(base::Time::Now());
 522   service()->Initialize();
 523   EXPECT_FALSE(service()->IsSyncActive());
 524
 525   // Request start.  This should be enough to allow init to happen.
 526   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 527   ExpectSyncBackendHostCreation(1);
 528   service()->RequestStart();
 529   EXPECT_TRUE(service()->IsSyncActive());
 530   EXPECT_FALSE(profile()->GetPrefs()->GetBoolean(
 531       sync_driver::prefs::kSyncSuppressStart));
 532 }
 533
 534 // Test RequestStop() after we've initialized the backend.
 535 TEST_F(ProfileSyncServiceTest, DisableAndEnableSyncTemporarily) {
 536   CreateService(browser_sync::AUTO_START);
 537   IssueTestTokens();
 538   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 539   ExpectSyncBackendHostCreation(1);
 540   InitializeForNthSync();
 541
 542   EXPECT_TRUE(service()->IsSyncActive());
 543   EXPECT_FALSE(profile()->GetPrefs()->GetBoolean(
 544       sync_driver::prefs::kSyncSuppressStart));
 545
 546   testing::Mock::VerifyAndClearExpectations(components_factory());
 547
 548   service()->RequestStop(ProfileSyncService::KEEP_DATA);
 549   EXPECT_FALSE(service()->IsSyncActive());
 550   EXPECT_TRUE(profile()->GetPrefs()->GetBoolean(
 551       sync_driver::prefs::kSyncSuppressStart));
 552
 553   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 554   ExpectSyncBackendHostCreation(1);
 555
 556   service()->RequestStart();
 557   EXPECT_TRUE(service()->IsSyncActive());
 558   EXPECT_FALSE(profile()->GetPrefs()->GetBoolean(
 559       sync_driver::prefs::kSyncSuppressStart));
 560 }
 561
 562 // Certain ProfileSyncService tests don't apply to Chrome OS, for example
 563 // things that deal with concepts like "signing out" and policy.
 564 #if !defined (OS_CHROMEOS)
 565 TEST_F(ProfileSyncServiceTest, EnableSyncAndSignOut) {
 566   CreateService(browser_sync::AUTO_START);
 567   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 568   ExpectSyncBackendHostCreation(1);
 569   IssueTestTokens();
 570   InitializeForNthSync();
 571
 572   EXPECT_TRUE(service()->IsSyncActive());
 573   EXPECT_FALSE(profile()->GetPrefs()->GetBoolean(
 574       sync_driver::prefs::kSyncSuppressStart));
 575
 576   SigninManagerFactory::GetForProfile(profile())->SignOut(
 577       signin_metrics::SIGNOUT_TEST);
 578   EXPECT_FALSE(service()->IsSyncActive());
 579 }
 580 #endif  // !defined(OS_CHROMEOS)
 581
 582 TEST_F(ProfileSyncServiceTest, GetSyncTokenStatus) {
 583   CreateService(browser_sync::AUTO_START);
 584   IssueTestTokens();
 585   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 586   ExpectSyncBackendHostCreation(1);
 587   InitializeForNthSync();
 588
 589   // Initial status.
 590   ProfileSyncService::SyncTokenStatus token_status =
 591       service()->GetSyncTokenStatus();
 592   EXPECT_EQ(syncer::CONNECTION_NOT_ATTEMPTED, token_status.connection_status);
 593   EXPECT_TRUE(token_status.connection_status_update_time.is_null());
 594   EXPECT_TRUE(token_status.token_request_time.is_null());
 595   EXPECT_TRUE(token_status.token_receive_time.is_null());
 596
 597   // Simulate an auth error.
 598   service()->OnConnectionStatusChange(syncer::CONNECTION_AUTH_ERROR);
 599
 600   // The token request will take the form of a posted task.  Run it.
 601   base::RunLoop loop;
 602   loop.RunUntilIdle();
 603
 604   token_status = service()->GetSyncTokenStatus();
 605   EXPECT_EQ(syncer::CONNECTION_AUTH_ERROR, token_status.connection_status);
 606   EXPECT_FALSE(token_status.connection_status_update_time.is_null());
 607   EXPECT_FALSE(token_status.token_request_time.is_null());
 608   EXPECT_FALSE(token_status.token_receive_time.is_null());
 609   EXPECT_EQ(GoogleServiceAuthError::AuthErrorNone(),
 610             token_status.last_get_token_error);
 611   EXPECT_TRUE(token_status.next_token_request_time.is_null());
 612
 613   // Simulate successful connection.
 614   service()->OnConnectionStatusChange(syncer::CONNECTION_OK);
 615   token_status = service()->GetSyncTokenStatus();
 616   EXPECT_EQ(syncer::CONNECTION_OK, token_status.connection_status);
 617 }
 618
 619 #if defined(ENABLE_PRE_SYNC_BACKUP)
 620 TEST_F(ProfileSyncServiceTest, DontStartBackupOnBrowserStart) {
 621   CreateServiceWithoutSignIn();
 622   InitializeForFirstSync();
 623   PumpLoop();
 624   EXPECT_EQ(ProfileSyncService::IDLE, service()->backend_mode());
 625 }
 626
 627 TEST_F(ProfileSyncServiceTest, BackupBeforeFirstSync) {
 628   CreateServiceWithoutSignIn();
 629   ExpectDataTypeManagerCreation(2, GetDefaultConfigureCalledCallback());
 630   std::vector<bool> delete_dir_param;
 631   ExpectSyncBackendHostCreationCollectDeleteDir(2, &delete_dir_param);
 632   InitializeForFirstSync();
 633
 634   SigninManagerFactory::GetForProfile(profile())
 635       ->SetAuthenticatedAccountInfo(kGaiaId, kEmail);
 636   IssueTestTokens();
 637   PumpLoop();
 638
 639   // At this time, backup is finished. Task is posted to start sync again.
 640   EXPECT_EQ(ProfileSyncService::BACKUP, service()->backend_mode());
 641   EXPECT_FALSE(service()->IsSyncActive());
 642   EXPECT_EQ(1u, delete_dir_param.size());
 643   EXPECT_TRUE(delete_dir_param[0]);
 644
 645   // Pump loop to start sync.
 646   PumpLoop();
 647   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 648   EXPECT_TRUE(service()->IsSyncActive());
 649   EXPECT_EQ(2u, delete_dir_param.size());
 650   EXPECT_TRUE(delete_dir_param[0]);
 651 }
 652
 653 // Test backup is done again on browser start if user signed in last session
 654 // but backup didn't finish when last session was closed.
 655 TEST_F(ProfileSyncServiceTest, ResumeBackupIfAborted) {
 656   IssueTestTokens();
 657   CreateService(AUTO_START);
 658   ExpectDataTypeManagerCreation(2, GetDefaultConfigureCalledCallback());
 659   std::vector<bool> delete_dir_param;
 660   ExpectSyncBackendHostCreationCollectDeleteDir(2, &delete_dir_param);
 661   InitializeForFirstSync();
 662   PumpLoop();
 663
 664   // At this time, backup is finished. Task is posted to start sync again.
 665   EXPECT_EQ(ProfileSyncService::BACKUP, service()->backend_mode());
 666   EXPECT_FALSE(service()->IsSyncActive());
 667   EXPECT_EQ(1u, delete_dir_param.size());
 668   EXPECT_TRUE(delete_dir_param[0]);
 669
 670   // Pump loop to start sync.
 671   PumpLoop();
 672   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 673   EXPECT_TRUE(service()->IsSyncActive());
 674   EXPECT_EQ(2u, delete_dir_param.size());
 675   EXPECT_TRUE(delete_dir_param[0]);
 676 }
 677
 678 TEST_F(ProfileSyncServiceTest, Rollback) {
 679   CreateService(browser_sync::MANUAL_START);
 680   service()->SetSyncSetupCompleted();
 681   ExpectDataTypeManagerCreation(2, GetDefaultConfigureCalledCallback());
 682   std::vector<bool> delete_dir_param;
 683   ExpectSyncBackendHostCreationCollectDeleteDir(2, &delete_dir_param);
 684   IssueTestTokens();
 685   InitializeForNthSync();
 686   EXPECT_TRUE(service()->IsSyncActive());
 687   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 688
 689   // First sync time should be recorded.
 690   sync_driver::SyncPrefs sync_prefs(service()->profile()->GetPrefs());
 691   base::Time first_sync_time = sync_prefs.GetFirstSyncTime();
 692   EXPECT_FALSE(first_sync_time.is_null());
 693
 694   syncer::SyncProtocolError client_cmd;
 695   client_cmd.action = syncer::DISABLE_SYNC_AND_ROLLBACK;
 696   service()->OnActionableError(client_cmd);
 697   EXPECT_EQ(ProfileSyncService::IDLE, service()->backend_mode());
 698
 699   // Pump loop to run rollback.
 700   PumpLoop();
 701   EXPECT_EQ(ProfileSyncService::ROLLBACK, service()->backend_mode());
 702
 703   // Browser data should be cleared during rollback.
 704   EXPECT_EQ(first_sync_time, clear_browsing_date_start_);
 705
 706   client_cmd.action = syncer::ROLLBACK_DONE;
 707   service()->OnActionableError(client_cmd);
 708   EXPECT_EQ(ProfileSyncService::IDLE, service()->backend_mode());
 709
 710   // First sync time is erased after rollback is done.
 711   EXPECT_TRUE(sync_prefs.GetFirstSyncTime().is_null());
 712
 713   EXPECT_EQ(2u, delete_dir_param.size());
 714   EXPECT_FALSE(delete_dir_param[0]);
 715   EXPECT_FALSE(delete_dir_param[1]);
 716 }
 717
 718 #endif
 719
 720 // Verify that LastSyncedTime is cleared when the user signs out.
 721 TEST_F(ProfileSyncServiceTest, ClearLastSyncedTimeOnSignOut) {
 722   IssueTestTokens();
 723   CreateService(AUTO_START);
 724   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 725   ExpectSyncBackendHostCreation(1);
 726   InitializeForNthSync();
 727   EXPECT_TRUE(service()->IsSyncActive());
 728   EXPECT_EQ(l10n_util::GetStringUTF16(IDS_SYNC_TIME_JUST_NOW),
 729             service()->GetLastSyncedTimeString());
 730
 731   // Sign out.
 732   service()->RequestStop(ProfileSyncService::CLEAR_DATA);
 733   PumpLoop();
 734
 735   EXPECT_EQ(l10n_util::GetStringUTF16(IDS_SYNC_TIME_NEVER),
 736             service()->GetLastSyncedTimeString());
 737 }
 738
 739 // Verify that the disable sync flag disables sync.
 740 TEST_F(ProfileSyncServiceTest, DisableSyncFlag) {
 741   base::CommandLine::ForCurrentProcess()->AppendSwitch(switches::kDisableSync);
 742   EXPECT_FALSE(ProfileSyncService::IsSyncAllowedByFlag());
 743 }
 744
 745 // Verify that no disable sync flag enables sync.
 746 TEST_F(ProfileSyncServiceTest, NoDisableSyncFlag) {
 747   EXPECT_TRUE(ProfileSyncService::IsSyncAllowedByFlag());
 748 }
 749
 750 // Test Sync will stop after receive memory pressure
 751 TEST_F(ProfileSyncServiceTest, MemoryPressureRecording) {
 752   CreateService(browser_sync::AUTO_START);
 753   IssueTestTokens();
 754   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 755   ExpectSyncBackendHostCreation(1);
 756   InitializeForNthSync();
 757
 758   EXPECT_TRUE(service()->IsSyncActive());
 759   EXPECT_FALSE(profile()->GetPrefs()->GetBoolean(
 760       sync_driver::prefs::kSyncSuppressStart));
 761
 762   testing::Mock::VerifyAndClearExpectations(components_factory());
 763
 764   sync_driver::SyncPrefs sync_prefs(service()->profile()->GetPrefs());
 765
 766   EXPECT_EQ(profile()->GetPrefs()->GetInteger(
 767                 sync_driver::prefs::kSyncMemoryPressureWarningCount),
 768             0);
 769   EXPECT_FALSE(sync_prefs.DidSyncShutdownCleanly());
 770
 771   // Simulate memory pressure notification.
 772   base::MemoryPressureListener::NotifyMemoryPressure(
 773       base::MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL);
 774   base::RunLoop().RunUntilIdle();
 775
 776   // Verify memory pressure recorded.
 777   EXPECT_EQ(profile()->GetPrefs()->GetInteger(
 778                 sync_driver::prefs::kSyncMemoryPressureWarningCount),
 779             1);
 780   EXPECT_FALSE(sync_prefs.DidSyncShutdownCleanly());
 781
 782   // Simulate memory pressure notification.
 783   base::MemoryPressureListener::NotifyMemoryPressure(
 784       base::MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL);
 785   base::RunLoop().RunUntilIdle();
 786   ShutdownAndDeleteService();
 787
 788   // Verify memory pressure and shutdown recorded.
 789   EXPECT_EQ(profile()->GetPrefs()->GetInteger(
 790                 sync_driver::prefs::kSyncMemoryPressureWarningCount),
 791             2);
 792   EXPECT_TRUE(sync_prefs.DidSyncShutdownCleanly());
 793 }
 794
 795 // Verify that OnLocalSetPassphraseEncryption triggers catch up configure sync
 796 // cycle, calls ClearServerData, shuts down and restarts sync.
 797 TEST_F(ProfileSyncServiceTest, OnLocalSetPassphraseEncryption) {
 798   base::CommandLine::ForCurrentProcess()->AppendSwitch(
 799       switches::kSyncEnableClearDataOnPassphraseEncryption);
 800   IssueTestTokens();
 801   CreateService(browser_sync::AUTO_START);
 802
 803   syncer::SyncManager::ClearServerDataCallback captured_callback;
 804   syncer::ConfigureReason configure_reason = syncer::CONFIGURE_REASON_UNKNOWN;
 805
 806   // Initialize sync, ensure that both DataTypeManager and SyncBackendHost are
 807   // initialized and DTM::Configure is called with
 808   // CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE.
 809   ExpectSyncBackendHostCreationCaptureClearServerData(&captured_callback);
 810   ExpectDataTypeManagerCreation(
 811       1, GetRecordingConfigureCalledCallback(&configure_reason));
 812   InitializeForNthSync();
 813   EXPECT_TRUE(service()->IsSyncActive());
 814   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 815   testing::Mock::VerifyAndClearExpectations(components_factory());
 816   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 817   sync_driver::DataTypeManager::ConfigureResult result;
 818   result.status = sync_driver::DataTypeManager::OK;
 819   service()->OnConfigureDone(result);
 820
 821   // Simulate user entering encryption passphrase. Ensure that catch up
 822   // configure cycle is started (DTM::Configure is called with
 823   // CONFIGURE_REASON_CATCH_UP).
 824   const syncer::SyncEncryptionHandler::NigoriState nigori_state;
 825   service()->OnLocalSetPassphraseEncryption(nigori_state);
 826   EXPECT_EQ(syncer::CONFIGURE_REASON_CATCH_UP, configure_reason);
 827   EXPECT_TRUE(captured_callback.is_null());
 828
 829   // Simulate configure successful. Ensure that SBH::ClearServerData is called.
 830   service()->OnConfigureDone(result);
 831   EXPECT_FALSE(captured_callback.is_null());
 832
 833   // Once SBH::ClearServerData finishes successfully ensure that sync is
 834   // restarted.
 835   configure_reason = syncer::CONFIGURE_REASON_UNKNOWN;
 836   ExpectSyncBackendHostCreation(1);
 837   ExpectDataTypeManagerCreation(
 838       1, GetRecordingConfigureCalledCallback(&configure_reason));
 839   captured_callback.Run();
 840   testing::Mock::VerifyAndClearExpectations(components_factory());
 841   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 842   service()->OnConfigureDone(result);
 843 }
 844
 845 // Verify that if after OnLocalSetPassphraseEncryption catch up configure sync
 846 // cycle gets interrupted, it starts again after browser restart.
 847 TEST_F(ProfileSyncServiceTest,
 848        OnLocalSetPassphraseEncryption_RestartDuringCatchUp) {
 849   syncer::ConfigureReason configure_reason = syncer::CONFIGURE_REASON_UNKNOWN;
 850   base::CommandLine::ForCurrentProcess()->AppendSwitch(
 851       switches::kSyncEnableClearDataOnPassphraseEncryption);
 852   IssueTestTokens();
 853   CreateService(browser_sync::AUTO_START);
 854   ExpectSyncBackendHostCreation(1);
 855   ExpectDataTypeManagerCreation(
 856       1, GetRecordingConfigureCalledCallback(&configure_reason));
 857   InitializeForNthSync();
 858   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 859   testing::Mock::VerifyAndClearExpectations(components_factory());
 860   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 861   sync_driver::DataTypeManager::ConfigureResult result;
 862   result.status = sync_driver::DataTypeManager::OK;
 863   service()->OnConfigureDone(result);
 864
 865   // Simulate user entering encryption passphrase. Ensure Configure was called
 866   // but don't let it continue.
 867   const syncer::SyncEncryptionHandler::NigoriState nigori_state;
 868   service()->OnLocalSetPassphraseEncryption(nigori_state);
 869   EXPECT_EQ(syncer::CONFIGURE_REASON_CATCH_UP, configure_reason);
 870
 871   // Simulate browser restart. First configuration is a regular one.
 872   service()->Shutdown();
 873   syncer::SyncManager::ClearServerDataCallback captured_callback;
 874   ExpectSyncBackendHostCreationCaptureClearServerData(&captured_callback);
 875   ExpectDataTypeManagerCreation(
 876       1, GetRecordingConfigureCalledCallback(&configure_reason));
 877   service()->RequestStart();
 878   testing::Mock::VerifyAndClearExpectations(components_factory());
 879   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 880   EXPECT_TRUE(captured_callback.is_null());
 881
 882   // Simulate configure successful. This time it should be catch up.
 883   service()->OnConfigureDone(result);
 884   EXPECT_EQ(syncer::CONFIGURE_REASON_CATCH_UP, configure_reason);
 885   EXPECT_TRUE(captured_callback.is_null());
 886
 887   // Simulate catch up configure successful. Ensure that SBH::ClearServerData is
 888   // called.
 889   service()->OnConfigureDone(result);
 890   EXPECT_FALSE(captured_callback.is_null());
 891
 892   ExpectSyncBackendHostCreation(1);
 893   ExpectDataTypeManagerCreation(
 894       1, GetRecordingConfigureCalledCallback(&configure_reason));
 895   captured_callback.Run();
 896   testing::Mock::VerifyAndClearExpectations(components_factory());
 897   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 898 }
 899
 900 // Verify that if after OnLocalSetPassphraseEncryption ClearServerData gets
 901 // interrupted, transition again from catch up sync cycle after browser restart.
 902 TEST_F(ProfileSyncServiceTest,
 903        OnLocalSetPassphraseEncryption_RestartDuringClearServerData) {
 904   syncer::SyncManager::ClearServerDataCallback captured_callback;
 905   syncer::ConfigureReason configure_reason = syncer::CONFIGURE_REASON_UNKNOWN;
 906   base::CommandLine::ForCurrentProcess()->AppendSwitch(
 907       switches::kSyncEnableClearDataOnPassphraseEncryption);
 908   IssueTestTokens();
 909   CreateService(browser_sync::AUTO_START);
 910   ExpectSyncBackendHostCreationCaptureClearServerData(&captured_callback);
 911   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 912   InitializeForNthSync();
 913   EXPECT_EQ(ProfileSyncService::SYNC, service()->backend_mode());
 914   testing::Mock::VerifyAndClearExpectations(components_factory());
 915
 916   // Simulate user entering encryption passphrase.
 917   const syncer::SyncEncryptionHandler::NigoriState nigori_state;
 918   service()->OnLocalSetPassphraseEncryption(nigori_state);
 919   EXPECT_FALSE(captured_callback.is_null());
 920   captured_callback.Reset();
 921
 922   // Simulate browser restart. First configuration is a regular one.
 923   service()->Shutdown();
 924   ExpectSyncBackendHostCreationCaptureClearServerData(&captured_callback);
 925   ExpectDataTypeManagerCreation(
 926       1, GetRecordingConfigureCalledCallback(&configure_reason));
 927   service()->RequestStart();
 928   testing::Mock::VerifyAndClearExpectations(components_factory());
 929   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 930   EXPECT_TRUE(captured_callback.is_null());
 931
 932   // Simulate configure successful. This time it should be catch up.
 933   sync_driver::DataTypeManager::ConfigureResult result;
 934   result.status = sync_driver::DataTypeManager::OK;
 935   service()->OnConfigureDone(result);
 936   EXPECT_EQ(syncer::CONFIGURE_REASON_CATCH_UP, configure_reason);
 937   EXPECT_TRUE(captured_callback.is_null());
 938
 939   // Simulate catch up configure successful. Ensure that SBH::ClearServerData is
 940   // called.
 941   service()->OnConfigureDone(result);
 942   EXPECT_FALSE(captured_callback.is_null());
 943
 944   ExpectSyncBackendHostCreation(1);
 945   ExpectDataTypeManagerCreation(
 946       1, GetRecordingConfigureCalledCallback(&configure_reason));
 947   captured_callback.Run();
 948   testing::Mock::VerifyAndClearExpectations(components_factory());
 949   EXPECT_EQ(syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE, configure_reason);
 950 }
 951
 952 // Test that the passphrase prompt due to version change logic gets triggered
 953 // on a datatype type requesting startup, but only happens once.
 954 TEST_F(ProfileSyncServiceTest, PassphrasePromptDueToVersion) {
 955   IssueTestTokens();
 956   CreateService(browser_sync::AUTO_START);
 957   ExpectDataTypeManagerCreation(1, GetDefaultConfigureCalledCallback());
 958   ExpectSyncBackendHostCreation(1);
 959   InitializeForNthSync();
 960
 961   sync_driver::SyncPrefs sync_prefs(service()->profile()->GetPrefs());
 962   EXPECT_EQ(PRODUCT_VERSION, sync_prefs.GetLastRunVersion());
 963
 964   sync_prefs.SetPassphrasePrompted(true);
 965
 966   // Until a datatype requests startup while a passphrase is required the
 967   // passphrase prompt bit should remain set.
 968   EXPECT_TRUE(sync_prefs.IsPassphrasePrompted());
 969   TriggerPassphraseRequired();
 970   EXPECT_TRUE(sync_prefs.IsPassphrasePrompted());
 971
 972   // Because the last version was unset, this run should be treated as a new
 973   // version and force a prompt.
 974   TriggerDataTypeStartRequest();
 975   EXPECT_FALSE(sync_prefs.IsPassphrasePrompted());
 976
 977   // At this point further datatype startup request should have no effect.
 978   sync_prefs.SetPassphrasePrompted(true);
 979   TriggerDataTypeStartRequest();
 980   EXPECT_TRUE(sync_prefs.IsPassphrasePrompted());
 981 }
 982
 983 }  // namespace
 984 }  // namespace browser_sync