[Sync] Add RequestCleanupDisabledTypes() method to SyncManager

chrome/browser/sync/engine/syncer_unittest.cc

 // Copyright (c) 2011 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.
 //
 // Syncer unit tests. Unfortunately a lot of these tests
 // are outdated and need to be reworked and updated.
 
 #include <algorithm>
 #include <limits>
 #include <list>
@@ skipping 29 matching lines @@
 #include "chrome/test/sync/engine/test_syncable_utils.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using base::TimeDelta;
 
 using std::map;
 using std::multimap;
 using std::set;
 using std::string;
 
+using ::testing::_;
+
 namespace browser_sync {
 
 using syncable::BaseTransaction;
 using syncable::Blob;
 using syncable::CountEntriesWithName;
 using syncable::Directory;
 using syncable::Entry;
 using syncable::GetFirstEntryWithName;
 using syncable::GetOnlyEntryWithName;
 using syncable::Id;
@@ skipping 4430 matching lines @@
   DisableDatatype(syncable::AUTOFILL);
   SyncShareAsDelegate();
   EXPECT_EQ(1, mock_server_->GetAndClearNumGetUpdatesRequests());
 
   DisableDatatype(syncable::PREFERENCES);
   EnableDatatype(syncable::AUTOFILL);
   SyncShareAsDelegate();
   EXPECT_EQ(1, mock_server_->GetAndClearNumGetUpdatesRequests());
 }
 
+TEST_F(SyncerTest, CleanupDisabledTypes) {
+  // Set up mock directory and expectations.
+  MockDirectorySetterUpper mock_setter_upper;
+  mock_setter_upper.SetUp();
+  EXPECT_CALL(*mock_setter_upper.directory(), PurgeEntriesWithTypeIn(_));
+
+  // Set up context.
+  std::vector<SyncEngineEventListener*> listeners;
+  SyncSessionContext context(mock_server_.get(),
+                             mock_setter_upper.manager(), this, listeners);
+  context.set_account_name(mock_setter_upper.name());
+
+  // Set up session.
+  ModelSafeRoutingInfo info;
+  std::vector<ModelSafeWorker*> workers;
+  GetModelSafeRoutingInfo(&info);
+  GetWorkers(&workers);
+  syncable::ModelTypePayloadMap types =
+      syncable::ModelTypePayloadMapFromRoutingInfo(info, std::string());
+  SyncSession sync_session(
+      &context, this,
+      sessions::SyncSourceInfo(sync_pb::GetUpdatesCallerInfo::UNKNOWN, types),
+      info, workers);
+
+  // Do cleanup.
+  syncer_->CleanupDisabledTypes(&sync_session);
+}
+
 // Test what happens if a client deletes, then recreates, an object very
 // quickly.  It is possible that the deletion gets sent as a commit, and
 // the undelete happens during the commit request.  The principle here
 // is that with a single committing client, conflicts should never
 // be encountered, and a client encountering its past actions during
 // getupdates should never feed back to override later actions.
 //
 // In cases of ordering A-F below, the outcome should be the same.
 //   Exercised by UndeleteDuringCommit:
 //     A. Delete - commit - undelete - commitresponse.
@@ skipping 667 matching lines @@
   Add(low_id_);
   Add(high_id_);
   SyncShareAsDelegate();
   ExpectLocalOrderIsByServerId();
 }
 
 const SyncerTest::CommitOrderingTest
 SyncerTest::CommitOrderingTest::LAST_COMMIT_ITEM = {-1, TestIdFactory::root()};
 
 }  // namespace browser_sync