[Sync] Enable adding notifier observers from ProfileSyncService

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 "base/message_loop.h"
+#include <cstddef>
+
+#include "base/bind.h"
+#include "base/location.h"
+#include "base/logging.h"
+#include "base/sequenced_task_runner.h"
+#include "base/single_thread_task_runner.h"
+#include "base/thread_task_runner_handle.h"
 #include "sync/internal_api/public/http_post_provider_factory.h"
 #include "sync/internal_api/public/internal_components_factory.h"
 #include "sync/internal_api/public/util/weak_handle.h"
+#include "sync/notifier/notifications_disabled_reason.h"
+#include "sync/notifier/object_id_payload_map.h"
 #include "sync/notifier/sync_notifier.h"
 
 namespace syncer {
 
-FakeSyncManager::FakeSyncManager() {
-}
+FakeSyncManager::FakeSyncManager() {}
 
-FakeSyncManager::~FakeSyncManager() {
-}
+FakeSyncManager::~FakeSyncManager() {}
 
 void FakeSyncManager::set_initial_sync_ended_types(ModelTypeSet types) {
   initial_sync_ended_types_ = types;
 }
 
 void FakeSyncManager::set_progress_marker_types(ModelTypeSet types) {
   progress_marker_types_ = types;
 }
 
 void FakeSyncManager::set_configure_fail_types(ModelTypeSet types) {
@@ skipping 11 matching lines @@
   downloaded_types_.Clear();
   return downloaded_types;
 }
 
 ModelTypeSet FakeSyncManager::GetAndResetEnabledTypes() {
   ModelTypeSet enabled_types = enabled_types_;
   enabled_types_.Clear();
   return enabled_types;
 }
 
+void FakeSyncManager::Invalidate(
+    const ObjectIdPayloadMap& id_payloads,
+    IncomingNotificationSource source) {
+  if (!sync_task_runner_->PostTask(
+      FROM_HERE,
+      base::Bind(&FakeSyncManager::InvalidateOnSyncThread,
+                 base::Unretained(this), id_payloads, source))) {
+    NOTREACHED();
+  }
+}
+
+void FakeSyncManager::EnableNotifications() {
+  if (!sync_task_runner_->PostTask(
+      FROM_HERE,
+      base::Bind(&FakeSyncManager::EnableNotificationsOnSyncThread,
+                 base::Unretained(this)))) {
+    NOTREACHED();
+  }
+}
+
+void FakeSyncManager::DisableNotifications(
+    NotificationsDisabledReason reason) {
+  if (!sync_task_runner_->PostTask(
+      FROM_HERE,
+      base::Bind(&FakeSyncManager::DisableNotificationsOnSyncThread,
+                 base::Unretained(this), reason))) {
+    NOTREACHED();
+  }
+}
+
 bool FakeSyncManager::Init(
     const FilePath& database_location,
     const WeakHandle<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 std::vector<ModelSafeWorker*>& workers,
     ExtensionsActivityMonitor* extensions_activity_monitor,
     ChangeDelegate* change_delegate,
     const SyncCredentials& credentials,
     scoped_ptr<SyncNotifier> sync_notifier,
     const std::string& restored_key_for_bootstrapping,
     scoped_ptr<InternalComponentsFactory> internal_components_factory,
     Encryptor* encryptor,
     UnrecoverableErrorHandler* unrecoverable_error_handler,
     ReportUnrecoverableErrorFunction
         report_unrecoverable_error_function) {
-  sync_loop_ = MessageLoop::current();
+  sync_task_runner_ = base::ThreadTaskRunnerHandle::Get();
   PurgePartiallySyncedTypes();
   FOR_EACH_OBSERVER(SyncManager::Observer, observers_,
                     OnInitializationComplete(
                         syncer::WeakHandle<syncer::JsBackend>(),
                         true, initial_sync_ended_types_));
   return true;
 }
 
 void FakeSyncManager::ThrowUnrecoverableError() {
   NOTIMPLEMENTED();
@@ skipping 23 matching lines @@
 }
 
 void FakeSyncManager::UpdateCredentials(const SyncCredentials& credentials) {
   NOTIMPLEMENTED();
 }
 
 void FakeSyncManager::UpdateEnabledTypes(const ModelTypeSet& types) {
   enabled_types_ = types;
 }
 
+void FakeSyncManager::UpdateRegisteredIds(
+    SyncNotifierObserver* handler, const ObjectIdSet& ids) {
+  notifier_helper_.UpdateRegisteredIds(handler, ids);
+}
+
 void FakeSyncManager::StartSyncingNormally(
       const ModelSafeRoutingInfo& routing_info) {
   // Do nothing.
 }
 
 void FakeSyncManager::SetEncryptionPassphrase(const std::string& passphrase,
                                               bool is_explicit) {
   NOTIMPLEMENTED();
 }
 
@@ skipping 50 matching lines @@
 bool FakeSyncManager::IsUsingExplicitPassphrase() {
   NOTIMPLEMENTED();
   return false;
 }
 
 void FakeSyncManager::SaveChanges() {
   // Do nothing.
 }
 
 void FakeSyncManager::StopSyncingForShutdown(const base::Closure& callback) {
-  sync_loop_->PostTask(FROM_HERE, callback);
+  if (!sync_task_runner_->PostTask(FROM_HERE, callback)) {
+    NOTREACHED();
+  }
 }
 
 void FakeSyncManager::ShutdownOnSyncThread() {
-  // Do nothing.
+  DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
 }
 
 UserShare* FakeSyncManager::GetUserShare() {
   NOTIMPLEMENTED();
   return NULL;
 }
 
 void FakeSyncManager::RefreshNigori(const std::string& chrome_version,
                                     const base::Closure& done_callback) {
   done_callback.Run();
 }
 
 void FakeSyncManager::EnableEncryptEverything() {
   NOTIMPLEMENTED();
 }
 
 bool FakeSyncManager::ReceivedExperiment(Experiments* experiments) {
   return false;
 }
 
 bool FakeSyncManager::HasUnsyncedItems() {
   NOTIMPLEMENTED();
   return false;
 }
 
+void FakeSyncManager::InvalidateOnSyncThread(
+    const ObjectIdPayloadMap& id_payloads,
+    IncomingNotificationSource source) {
+  DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
+  notifier_helper_.DispatchInvalidationsToHandlers(id_payloads, source);
+}
+
+void FakeSyncManager::EnableNotificationsOnSyncThread() {
+  DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
+  notifier_helper_.EmitOnNotificationsEnabled();
+}
+
+void FakeSyncManager::DisableNotificationsOnSyncThread(
+    NotificationsDisabledReason reason) {
+  DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
+  notifier_helper_.EmitOnNotificationsDisabled(reason);
+}
+
 }  // namespace syncer
-