Move browsing_data counter sync tests to separate file

chrome/browser/browsing_data/history_counter_browsertest.cc

 // Copyright (c) 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/browsing_data/core/counters/history_counter.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/run_loop.h"
 #include "chrome/browser/history/history_service_factory.h"
 #include "chrome/browser/history/web_history_service_factory.h"
 #include "chrome/browser/signin/profile_oauth2_token_service_factory.h"
 #include "chrome/browser/signin/signin_manager_factory.h"
 #include "chrome/browser/sync/profile_sync_service_factory.h"
-#include "chrome/browser/sync/test/integration/sync_test.h"
 #include "chrome/browser/ui/browser.h"
+#include "chrome/test/base/in_process_browser_test.h"
 #include "components/browser_sync/profile_sync_service.h"
 #include "components/browsing_data/core/browsing_data_utils.h"
 #include "components/browsing_data/core/pref_names.h"
 #include "components/history/core/browser/history_service.h"
 #include "components/history/core/browser/web_history_service.h"
 #include "components/history/core/test/fake_web_history_service.h"
 #include "components/prefs/pref_service.h"
 #include "components/signin/core/browser/profile_oauth2_token_service.h"
 #include "components/signin/core/browser/signin_manager.h"
 #include "net/http/http_status_code.h"
 #include "url/gurl.h"
 
 namespace {
 
-class HistoryCounterTest : public SyncTest {
+using browsing_data::BrowsingDataCounter;
+
+class HistoryCounterTest : public InProcessBrowserTest {
  public:
-  HistoryCounterTest() : SyncTest(SINGLE_CLIENT) {
-    // TODO(msramek): Only one of the test cases, RestartOnSyncChange, is a Sync
-    // integration test. Extract it and move it to the rest of integration tests
-    // in chrome/browser/sync/test/integration/. Change this class back to
-    // InProcessBrowserTest.
-  }
-
+  HistoryCounterTest() {}
   ~HistoryCounterTest() override {};
 
   void SetUpOnMainThread() override {
     time_ = base::Time::Now();
     history_service_ = HistoryServiceFactory::GetForProfileWithoutCreating(
         browser()->profile());
     fake_web_history_service_.reset(new history::FakeWebHistoryService(
         ProfileOAuth2TokenServiceFactory::GetForProfile(browser()->profile()),
         SigninManagerFactory::GetForProfile(browser()->profile()),
         browser()->profile()->GetRequestContext()));
@@ skipping 22 matching lines @@
   void SetDeletionPeriodPref(browsing_data::TimePeriod period) {
     browser()->profile()->GetPrefs()->SetInteger(
         browsing_data::prefs::kDeleteTimePeriod, static_cast<int>(period));
   }
 
   void WaitForCounting() {
     run_loop_.reset(new base::RunLoop());
     run_loop_->Run();
   }
 
-  browsing_data::BrowsingDataCounter::ResultInt GetLocalResult() {
+  BrowsingDataCounter::ResultInt GetLocalResult() {
     DCHECK(finished_);
     return local_result_;
   }
 
   bool HasSyncedVisits() {
     DCHECK(finished_);
     return has_synced_visits_;
   }
 
-  void Callback(
-      std::unique_ptr<browsing_data::BrowsingDataCounter::Result> result) {
+  void Callback(std::unique_ptr<BrowsingDataCounter::Result> result) {
     finished_ = result->Finished();
 
     if (finished_) {
-      browsing_data::HistoryCounter::HistoryResult* history_result =
-          static_cast<browsing_data::HistoryCounter::HistoryResult*>(
-              result.get());
+      auto* history_result =
+          static_cast<BrowsingDataCounter::SyncResult*>(result.get());
 
       local_result_ = history_result->Value();
-      has_synced_visits_ = history_result->has_synced_visits();
+      has_synced_visits_ = history_result->IsSyncEnabled();
     }
 
     if (run_loop_ && finished_)
       run_loop_->Quit();
   }
 
-  bool CountingFinishedSinceLastAsked() {
-    bool result = finished_;
-    finished_ = false;
-    return result;
-  }
-
-  void WaitForCountingOrConfirmFinished() {
-    if (CountingFinishedSinceLastAsked())
-      return;
-
-    WaitForCounting();
-    CountingFinishedSinceLastAsked();
-  }
-
   history::WebHistoryService* GetFakeWebHistoryService(Profile* profile,
                                                        bool check_sync_status) {
     // |check_sync_status| is true when the factory should check if
     // history sync is enabled.
     if (!check_sync_status ||
         WebHistoryServiceFactory::GetForProfile(profile)) {
       return fake_web_history_service_.get();
     }
     return nullptr;
   }
 
   history::WebHistoryService* GetRealWebHistoryService(Profile* profile) {
     return WebHistoryServiceFactory::GetForProfile(profile);
   }
 
   history::HistoryService* GetHistoryService() { return history_service_; }
 
  private:
   std::unique_ptr<base::RunLoop> run_loop_;
   history::HistoryService* history_service_;
   std::unique_ptr<history::FakeWebHistoryService> fake_web_history_service_;
   base::Time time_;
 
   bool finished_;
-  browsing_data::BrowsingDataCounter::ResultInt local_result_;
+  BrowsingDataCounter::ResultInt local_result_;
   bool has_synced_visits_;
 };
 
 // Tests that the counter considers duplicate visits from the same day
 // to be a single item.
 IN_PROC_BROWSER_TEST_F(HistoryCounterTest, DuplicateVisits) {
   AddVisit("https://www.google.com");   // 1 item
   AddVisit("https://www.google.com");
   AddVisit("https://www.chrome.com");   // 2 items
   AddVisit("https://www.chrome.com");
@@ skipping 193 matching lines @@
 
   // Nonzero local count, empty sync.
   service->ClearSyncedVisits();
   service->SetupFakeResponse(true /* success */, net::HTTP_OK);
   counter.Restart();
   WaitForCounting();
   EXPECT_EQ(2u, GetLocalResult());
   EXPECT_FALSE(HasSyncedVisits());
 }
 
-// Test that the counting restarts when history sync state changes.
-// TODO(crbug.com/553421): Move this to the sync/test/integration directory?
-IN_PROC_BROWSER_TEST_F(HistoryCounterTest, RestartOnSyncChange) {
-  // Set up the Sync client.
-  ASSERT_TRUE(SetupClients());
-  static const int kFirstProfileIndex = 0;
-  browser_sync::ProfileSyncService* sync_service =
-      GetSyncService(kFirstProfileIndex);
-  Profile* profile = GetProfile(kFirstProfileIndex);
-
-  // Set up the fake web history service and the counter.
-
-  browsing_data::HistoryCounter counter(
-      GetHistoryService(),
-      base::Bind(&HistoryCounterTest::GetFakeWebHistoryService,
-                 base::Unretained(this),
-                 base::Unretained(profile),
-                 true),
-      sync_service);
-
-  counter.Init(
-      profile->GetPrefs(), browsing_data::ClearBrowsingDataTab::ADVANCED,
-      base::Bind(&HistoryCounterTest::Callback, base::Unretained(this)));
-
-  // Note that some Sync operations notify observers immediately (and thus there
-  // is no need to call |WaitForCounting()|; in fact, it would block the test),
-  // while other operations only post the task on UI thread's message loop
-  // (which requires calling |WaitForCounting()| for them to run). Therefore,
-  // this test always checks if the callback has already run and only waits
-  // if it has not.
-
-  // We sync all datatypes by default, so starting Sync means that we start
-  // syncing history deletion, and this should restart the counter.
-  ASSERT_TRUE(SetupSync());
-  ASSERT_TRUE(sync_service->IsSyncActive());
-  ASSERT_TRUE(sync_service->GetPreferredDataTypes().Has(
-      syncer::HISTORY_DELETE_DIRECTIVES));
-  WaitForCountingOrConfirmFinished();
-
-  // We stop syncing history deletion in particular. This restarts the counter.
-  syncer::ModelTypeSet everything_except_history =
-      syncer::UserSelectableTypes();
-  everything_except_history.Remove(syncer::HISTORY_DELETE_DIRECTIVES);
-  auto sync_blocker = sync_service->GetSetupInProgressHandle();
-  sync_service->OnUserChoseDatatypes(/*sync_everything=*/false,
-                                     everything_except_history);
-  sync_blocker.reset();
-  WaitForCountingOrConfirmFinished();
-
-  // If the history deletion sync is not affected, the counter is not restarted.
-  syncer::ModelTypeSet only_passwords(syncer::PASSWORDS);
-  sync_service->ChangePreferredDataTypes(only_passwords);
-  sync_blocker = sync_service->GetSetupInProgressHandle();
-  sync_service->ChangePreferredDataTypes(only_passwords);
-  sync_blocker.reset();
-  EXPECT_FALSE(counter.HasTrackedTasks());
-  EXPECT_FALSE(CountingFinishedSinceLastAsked());
-
-  // Same in this case.
-  syncer::ModelTypeSet autofill_and_passwords(
-      syncer::AUTOFILL, syncer::PASSWORDS);
-  sync_blocker = sync_service->GetSetupInProgressHandle();
-  sync_service->ChangePreferredDataTypes(autofill_and_passwords);
-  sync_blocker.reset();
-  EXPECT_FALSE(counter.HasTrackedTasks());
-  EXPECT_FALSE(CountingFinishedSinceLastAsked());
-
-  // We start syncing history deletion again. This restarts the counter.
-  sync_blocker = sync_service->GetSetupInProgressHandle();
-  sync_service->ChangePreferredDataTypes(syncer::ModelTypeSet::All());
-  sync_blocker.reset();
-  WaitForCountingOrConfirmFinished();
-
-  // Changing the syncing datatypes to another set that still includes history
-  // deletion should technically not trigger a restart, because the state of
-  // history deletion did not change. However, in reality we can get two
-  // notifications, one that history sync has stopped and another that it is
-  // active again.
-
-  // Stopping the Sync service triggers a restart.
-  sync_service->RequestStop(syncer::SyncService::CLEAR_DATA);
-  WaitForCountingOrConfirmFinished();
-}
-
 }  // namespace