Revert "Revert 142517 - [Sync] Refactor sync configuration logic."

sync/internal_api/test/fake_sync_manager.cc

+// Copyright (c) 2012 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 "sync/internal_api/public/test/fake_sync_manager.h"
+
+#include "sync/internal_api/public/http_post_provider_factory.h"
+#include "sync/internal_api/public/util/weak_handle.h"
+#include "sync/notifier/sync_notifier.h"
+
+namespace syncer {
+
+FakeSyncManager::FakeSyncManager(std::string name)
+    : SyncManager(name) {}
+FakeSyncManager::~FakeSyncManager() {
+}
+
+void FakeSyncManager::set_initial_sync_ended_types(
+    syncer::ModelTypeSet types) {
+  initial_sync_ended_types_ = types;
+}
+
+void FakeSyncManager::set_progress_marker_types(
+    syncer::ModelTypeSet types) {
+  progress_marker_types_ = types;
+}
+
+void FakeSyncManager::set_configure_fail_types(syncer::ModelTypeSet types) {
+  configure_fail_types_ = types;
+}
+
+syncer::ModelTypeSet FakeSyncManager::GetAndResetCleanedTypes() {
+  syncer::ModelTypeSet cleaned_types = cleaned_types_;
+  cleaned_types_.Clear();
+  return cleaned_types;
+}
+
+syncer::ModelTypeSet FakeSyncManager::GetAndResetDownloadedTypes() {
+  syncer::ModelTypeSet downloaded_types = downloaded_types_;
+  downloaded_types_.Clear();
+  return downloaded_types;
+}
+
+bool FakeSyncManager::Init(
+    const FilePath& database_location,
+    const syncer::WeakHandle<syncer::JsEventHandler>& event_handler,
+    const std::string& sync_server_and_path,
+    int sync_server_port,
+    bool use_ssl,
+    const scoped_refptr<base::TaskRunner>& blocking_task_runner,
+    scoped_ptr<HttpPostProviderFactory> post_factory,
+    const syncer::ModelSafeRoutingInfo& model_safe_routing_info,
+    const std::vector<syncer::ModelSafeWorker*>& workers,
+    syncer::ExtensionsActivityMonitor* extensions_activity_monitor,
+    ChangeDelegate* change_delegate,
+    const SyncCredentials& credentials,
+    scoped_ptr<syncer::SyncNotifier> sync_notifier,
+    const std::string& restored_key_for_bootstrapping,
+    TestingMode testing_mode,
+    syncer::Encryptor* encryptor,
+    syncer::UnrecoverableErrorHandler* unrecoverable_error_handler,
+    syncer::ReportUnrecoverableErrorFunction
+        report_unrecoverable_error_function) {
+  FOR_EACH_OBSERVER(SyncManager::Observer, observers_,
+                    OnInitializationComplete(
+                        syncer::WeakHandle<syncer::JsBackend>(),
+                        true));
+  return true;
+}
+
+syncer::ModelTypeSet FakeSyncManager::InitialSyncEndedTypes() {
+  return initial_sync_ended_types_;
+}
+
+syncer::ModelTypeSet FakeSyncManager::GetTypesWithEmptyProgressMarkerToken(
+    syncer::ModelTypeSet types) {
+  syncer::ModelTypeSet empty_types = types;
+  empty_types.RemoveAll(progress_marker_types_);
+  return empty_types;
+}
+
+void FakeSyncManager::UpdateEnabledTypes(const syncer::ModelTypeSet& types) {
+}
+
+void FakeSyncManager::ConfigureSyncer(
+    ConfigureReason reason,
+    const syncer::ModelTypeSet& types_to_config,
+    const syncer::ModelSafeRoutingInfo& new_routing_info,
+    const base::Closure& ready_task,
+    const base::Closure& retry_task) {
+  syncer::ModelTypeSet enabled_types = GetRoutingInfoTypes(new_routing_info);
+  syncer::ModelTypeSet disabled_types = Difference(
+      syncer::ModelTypeSet::All(), enabled_types);
+  syncer::ModelTypeSet success_types = types_to_config;
+  success_types.RemoveAll(configure_fail_types_);
+
+  DVLOG(1) << "Faking configuration. Downloading: "
+           << syncer::ModelTypeSetToString(success_types) << ". Cleaning: "
+           << syncer::ModelTypeSetToString(disabled_types);
+
+  // Simulate cleaning up disabled types.
+  // TODO(sync): consider only cleaning those types that were recently disabled,
+  // if this isn't the first cleanup, which more accurately reflects the
+  // behavior of the real cleanup logic.
+  initial_sync_ended_types_.RemoveAll(disabled_types);
+  progress_marker_types_.RemoveAll(disabled_types);
+  cleaned_types_.PutAll(disabled_types);
+
+  // Now simulate the actual configuration for those types that successfully
+  // download + apply.
+  progress_marker_types_.PutAll(success_types);
+  initial_sync_ended_types_.PutAll(success_types);
+  downloaded_types_.PutAll(success_types);
+
+  ready_task.Run();
+}
+
+void FakeSyncManager::AddObserver(Observer* observer) {
+  observers_.AddObserver(observer);
+}
+
+void FakeSyncManager::RemoveObserver(Observer* observer) {
+  observers_.RemoveObserver(observer);
+}
+
+void FakeSyncManager::ShutdownOnSyncThread() {
+}
+
+void FakeSyncManager::RefreshNigori(const std::string& chrome_version,
+                                    const base::Closure& done_callback) {
+  done_callback.Run();
+}
+
+bool FakeSyncManager::ReceivedExperiment(
+    syncer::Experiments* experiments) const {
+  return false;
+}
+
+}  // namespace syncer