Rewrite DTM to support dynamic data type configuration

chrome/browser/sync/profile_sync_service.h

 // Copyright (c) 2006-2008 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.
 
 #ifndef CHROME_BROWSER_SYNC_PROFILE_SYNC_SERVICE_H_
 #define CHROME_BROWSER_SYNC_PROFILE_SYNC_SERVICE_H_
 
 #include <string>
 #include <map>
 
 #include "base/basictypes.h"
 #include "base/observer_list.h"
 #include "base/scoped_ptr.h"
 #include "base/time.h"
 #include "chrome/browser/google_service_auth_error.h"
 #include "chrome/browser/profile.h"
 #include "chrome/browser/sync/glue/data_type_controller.h"
 #include "chrome/browser/sync/glue/data_type_manager.h"
 #include "chrome/browser/sync/glue/sync_backend_host.h"
 #include "chrome/browser/sync/notification_method.h"
 #include "chrome/browser/sync/sync_setup_wizard.h"
 #include "chrome/browser/sync/syncable/model_type.h"
 #include "chrome/browser/sync/unrecoverable_error_handler.h"
+#include "chrome/common/notification_observer.h"
+#include "chrome/common/notification_registrar.h"
 #include "googleurl/src/gurl.h"
 #include "testing/gtest/include/gtest/gtest_prod.h"
 
+class NotificationDetails;
+class NotificationSource;
+class NotificationType;
+
 // Various UI components such as the New Tab page can be driven by observing
 // the ProfileSyncService through this interface.
 class ProfileSyncServiceObserver {
  public:
   // When one of the following events occurs, OnStateChanged() is called.
   // Observers should query the service to determine what happened.
   // - We initialized successfully.
   // - There was an authentication error and the user needs to reauthenticate.
   // - The sync servers are unavailable at this time.
   // - Credentials are now in flight for authentication.
   virtual void OnStateChanged() = 0;
  protected:
   virtual ~ProfileSyncServiceObserver() { }
 };
 
 // ProfileSyncService is the layer between browser subsystems like bookmarks,
 // and the sync backend.
 class ProfileSyncService : public browser_sync::SyncFrontend,
-                           public browser_sync::UnrecoverableErrorHandler {
+                           public browser_sync::UnrecoverableErrorHandler,
+                           public NotificationObserver {
  public:
   typedef ProfileSyncServiceObserver Observer;
   typedef browser_sync::SyncBackendHost::Status Status;
 
   enum SyncEventCodes  {
     MIN_SYNC_EVENT_CODE = 0,
 
     // Events starting the sync service.
     START_FROM_NTP = 1,      // Sync was started from the ad in NTP
     START_FROM_WRENCH = 2,   // Sync was started from the Wrench menu.
@@ skipping 139 matching lines @@
 
   browser_sync::SyncBackendHost* backend() { return backend_.get(); }
 
   virtual void ActivateDataType(
       browser_sync::DataTypeController* data_type_controller,
       browser_sync::ChangeProcessor* change_processor);
   virtual void DeactivateDataType(
       browser_sync::DataTypeController* data_type_controller,
       browser_sync::ChangeProcessor* change_processor);
 
+  // NotificationObserver implementation.
+  virtual void Observe(NotificationType type,
+                       const NotificationSource& source,
+                       const NotificationDetails& details);
+
  protected:
   // Call this after any of the subsystems being synced (the bookmark
   // model and the sync backend) finishes its initialization.  When everything
   // is ready, this function will bootstrap the subsystems so that they are
   // initially in sync, and start forwarding changes between the two models.
   void StartProcessingChangesIfReady();
 
   // Returns whether processing changes is allowed.  Check this before doing
   // any model-modifying operations.
   bool ShouldPushChanges();
 
   // Starts up the backend sync components.
   void StartUp();
   // Shuts down the backend sync components.
   // |sync_disabled| indicates if syncing is being disabled or not.
   void Shutdown(bool sync_disabled);
 
   // Methods to register and remove preferences.
   void RegisterPreferences();
   void ClearPreferences();
 
-  void DataTypeManagerStartCallback(
-      browser_sync::DataTypeManager::StartResult result);
-
   // Tests need to override this.  If |delete_sync_data_folder| is true, then
   // this method will delete all previous "Sync Data" folders. (useful if the
   // folder is partial/corrupt)
   virtual void InitializeBackend(bool delete_sync_data_folder);
 
   // We keep track of the last auth error observed so we can cover up the first
   // "expected" auth failure from observers.
   // TODO(timsteele): Same as expecting_first_run_auth_needed_event_. Remove
   // this!
   GoogleServiceAuthError last_auth_error_;
@@ skipping 70 matching lines @@
   // As its name suggests, this should NOT be used for anything other than UI.
   bool is_auth_in_progress_;
 
   SyncSetupWizard wizard_;
 
   // True if an unrecoverable error (e.g. violation of an assumed invariant)
   // occurred during syncer operation.  This value should be checked before
   // doing any work that might corrupt things further.
   bool unrecoverable_error_detected_;
 
-  // True if at least one of the data types started up was started for
-  // the first time.  TODO(sync): Remove this when we have full
-  // support for starting multiple data types.
-  bool startup_had_first_time_;
-
   // Which peer-to-peer notification method to use.
   browser_sync::NotificationMethod notification_method_;
 
   // Manages the start and stop of the various data types.
   scoped_ptr<browser_sync::DataTypeManager> data_type_manager_;
 
   ObserverList<Observer> observers_;
 
+  NotificationRegistrar registrar_;
+
   DISALLOW_COPY_AND_ASSIGN(ProfileSyncService);
 };
 
 #endif  // CHROME_BROWSER_SYNC_PROFILE_SYNC_SERVICE_H_