Revert of [Sync] Componentize ProfileSyncComponentsFactoryImpl

chrome/browser/sync/profile_sync_components_factory_impl.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 "chrome/browser/sync/profile_sync_components_factory_impl.h"
+
+#include "base/command_line.h"
+#include "base/memory/ref_counted.h"
+#include "base/prefs/pref_service.h"
+#include "build/build_config.h"
+#include "chrome/browser/bookmarks/bookmark_model_factory.h"
+#include "chrome/browser/profiles/profile.h"
+#include "chrome/browser/search_engines/template_url_service_factory.h"
+#include "chrome/browser/sync/glue/theme_data_type_controller.h"
+#include "chrome/common/channel_info.h"
+#include "chrome/common/chrome_switches.h"
+#include "chrome/common/pref_names.h"
+#include "components/autofill/core/browser/autofill_wallet_data_type_controller.h"
+#include "components/autofill/core/browser/webdata/autofill_data_type_controller.h"
+#include "components/autofill/core/browser/webdata/autofill_profile_data_type_controller.h"
+#include "components/autofill/core/common/autofill_pref_names.h"
+#include "components/autofill/core/common/autofill_switches.h"
+#include "components/browser_sync/browser/profile_sync_service.h"
+#include "components/browser_sync/common/browser_sync_switches.h"
+#include "components/dom_distiller/core/dom_distiller_features.h"
+#include "components/history/core/browser/history_delete_directives_data_type_controller.h"
+#include "components/history/core/browser/typed_url_change_processor.h"
+#include "components/history/core/browser/typed_url_data_type_controller.h"
+#include "components/history/core/browser/typed_url_model_associator.h"
+#include "components/password_manager/sync/browser/password_data_type_controller.h"
+#include "components/search_engines/search_engine_data_type_controller.h"
+#include "components/sync_bookmarks/bookmark_change_processor.h"
+#include "components/sync_bookmarks/bookmark_data_type_controller.h"
+#include "components/sync_bookmarks/bookmark_model_associator.h"
+#include "components/sync_driver/data_type_manager_impl.h"
+#include "components/sync_driver/device_info_data_type_controller.h"
+#include "components/sync_driver/glue/chrome_report_unrecoverable_error.h"
+#include "components/sync_driver/glue/sync_backend_host.h"
+#include "components/sync_driver/glue/sync_backend_host_impl.h"
+#include "components/sync_driver/local_device_info_provider_impl.h"
+#include "components/sync_driver/proxy_data_type_controller.h"
+#include "components/sync_driver/sync_client.h"
+#include "components/sync_driver/ui_data_type_controller.h"
+#include "components/sync_sessions/session_data_type_controller.h"
+#include "content/public/browser/browser_thread.h"
+#include "google_apis/gaia/oauth2_token_service.h"
+#include "google_apis/gaia/oauth2_token_service_request.h"
+#include "net/url_request/url_request_context_getter.h"
+#include "sync/internal_api/public/attachments/attachment_downloader.h"
+#include "sync/internal_api/public/attachments/attachment_service.h"
+#include "sync/internal_api/public/attachments/attachment_service_impl.h"
+#include "sync/internal_api/public/attachments/attachment_uploader_impl.h"
+#include "ui/base/device_form_factor.h"
+
+#if defined(ENABLE_APP_LIST)
+#include "ui/app_list/app_list_switches.h"
+#endif
+
+#if defined(ENABLE_EXTENSIONS)
+#include "chrome/browser/sync/glue/extension_data_type_controller.h"
+#include "chrome/browser/sync/glue/extension_setting_data_type_controller.h"
+#endif
+
+#if defined(ENABLE_SUPERVISED_USERS)
+#include "chrome/browser/supervised_user/supervised_user_sync_data_type_controller.h"
+#endif
+
+using bookmarks::BookmarkModel;
+using browser_sync::AutofillDataTypeController;
+using browser_sync::AutofillProfileDataTypeController;
+using browser_sync::BookmarkChangeProcessor;
+using browser_sync::BookmarkDataTypeController;
+using browser_sync::BookmarkModelAssociator;
+using browser_sync::ChromeReportUnrecoverableError;
+#if defined(ENABLE_EXTENSIONS)
+using browser_sync::ExtensionDataTypeController;
+using browser_sync::ExtensionSettingDataTypeController;
+#endif
+using browser_sync::HistoryDeleteDirectivesDataTypeController;
+using browser_sync::PasswordDataTypeController;
+using browser_sync::SearchEngineDataTypeController;
+using browser_sync::SessionDataTypeController;
+using browser_sync::SyncBackendHost;
+using browser_sync::ThemeDataTypeController;
+using browser_sync::TypedUrlChangeProcessor;
+using browser_sync::TypedUrlDataTypeController;
+using browser_sync::TypedUrlModelAssociator;
+using content::BrowserThread;
+using sync_driver::DataTypeController;
+using sync_driver::DataTypeErrorHandler;
+using sync_driver::DataTypeManager;
+using sync_driver::DataTypeManagerImpl;
+using sync_driver::DataTypeManagerObserver;
+using sync_driver::DeviceInfoDataTypeController;
+using sync_driver::ProxyDataTypeController;
+using sync_driver::UIDataTypeController;
+
+namespace {
+
+syncer::ModelTypeSet GetDisabledTypesFromCommandLine(
+    const base::CommandLine& command_line) {
+  syncer::ModelTypeSet disabled_types;
+  std::string disabled_types_str =
+      command_line.GetSwitchValueASCII(switches::kDisableSyncTypes);
+
+  disabled_types = syncer::ModelTypeSetFromString(disabled_types_str);
+  return disabled_types;
+}
+
+syncer::ModelTypeSet GetEnabledTypesFromCommandLine(
+    const base::CommandLine& command_line) {
+  syncer::ModelTypeSet enabled_types;
+  if (command_line.HasSwitch(autofill::switches::kEnableWalletMetadataSync))
+    enabled_types.Put(syncer::AUTOFILL_WALLET_METADATA);
+
+  return enabled_types;
+}
+
+}  // namespace
+
+ProfileSyncComponentsFactoryImpl::ProfileSyncComponentsFactoryImpl(
+    Profile* profile,
+    base::CommandLine* command_line,
+    const GURL& sync_service_url,
+    OAuth2TokenService* token_service,
+    net::URLRequestContextGetter* url_request_context_getter)
+    : profile_(profile),
+      command_line_(command_line),
+      sync_service_url_(sync_service_url),
+      token_service_(token_service),
+      url_request_context_getter_(url_request_context_getter),
+      weak_factory_(this) {
+  DCHECK(token_service_);
+  DCHECK(url_request_context_getter_);
+}
+
+ProfileSyncComponentsFactoryImpl::~ProfileSyncComponentsFactoryImpl() {
+}
+
+void ProfileSyncComponentsFactoryImpl::RegisterDataTypes(
+    sync_driver::SyncClient* sync_client) {
+  syncer::ModelTypeSet disabled_types =
+      GetDisabledTypesFromCommandLine(*command_line_);
+  syncer::ModelTypeSet enabled_types =
+      GetEnabledTypesFromCommandLine(*command_line_);
+  RegisterCommonDataTypes(disabled_types, enabled_types, sync_client);
+#if !defined(OS_ANDROID)
+  RegisterDesktopDataTypes(disabled_types, enabled_types, sync_client);
+#endif
+}
+
+void ProfileSyncComponentsFactoryImpl::RegisterCommonDataTypes(
+    syncer::ModelTypeSet disabled_types,
+    syncer::ModelTypeSet enabled_types,
+    sync_driver::SyncClient* sync_client) {
+  sync_driver::SyncService* sync_service = sync_client->GetSyncService();
+  base::Closure error_callback =
+      base::Bind(&ChromeReportUnrecoverableError, chrome::GetChannel());
+  const scoped_refptr<base::SingleThreadTaskRunner> ui_thread =
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
+  const scoped_refptr<base::SingleThreadTaskRunner> db_thread =
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::DB);
+
+  // TODO(stanisc): can DEVICE_INFO be one of disabled datatypes?
+  sync_service->RegisterDataTypeController(new DeviceInfoDataTypeController(
+      ui_thread, error_callback, sync_client,
+      sync_service->GetLocalDeviceInfoProvider()));
+
+  // Autofill sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::AUTOFILL)) {
+    sync_service->RegisterDataTypeController(new AutofillDataTypeController(
+        ui_thread, db_thread, error_callback, sync_client));
+  }
+
+  // Autofill profile sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::AUTOFILL_PROFILE)) {
+    sync_service->RegisterDataTypeController(
+        new AutofillProfileDataTypeController(ui_thread, db_thread,
+                                              error_callback, sync_client));
+  }
+
+  // Wallet data sync is enabled by default, but behind a syncer experiment
+  // enforced by the datatype controller. Register unless explicitly disabled.
+  bool wallet_disabled = disabled_types.Has(syncer::AUTOFILL_WALLET_DATA);
+  if (!wallet_disabled) {
+    sync_service->RegisterDataTypeController(
+        new browser_sync::AutofillWalletDataTypeController(
+            ui_thread, db_thread, error_callback, sync_client,
+            syncer::AUTOFILL_WALLET_DATA));
+  }
+
+  // Wallet metadata sync depends on Wallet data sync and is disabled by
+  // default. Register if Wallet data is syncing and metadata sync is explicitly
+  // enabled.
+  if (!wallet_disabled && enabled_types.Has(syncer::AUTOFILL_WALLET_METADATA)) {
+    sync_service->RegisterDataTypeController(
+        new browser_sync::AutofillWalletDataTypeController(
+            ui_thread, db_thread, error_callback, sync_client,
+            syncer::AUTOFILL_WALLET_METADATA));
+  }
+
+  // Bookmark sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::BOOKMARKS)) {
+    sync_service->RegisterDataTypeController(
+        new BookmarkDataTypeController(ui_thread, error_callback, sync_client));
+  }
+
+  const bool history_disabled =
+      profile_->GetPrefs()->GetBoolean(prefs::kSavingBrowserHistoryDisabled);
+  // TypedUrl sync is enabled by default.  Register unless explicitly disabled,
+  // or if saving history is disabled.
+  if (!disabled_types.Has(syncer::TYPED_URLS) && !history_disabled) {
+    sync_service->RegisterDataTypeController(
+        new TypedUrlDataTypeController(ui_thread, error_callback, sync_client,
+                                       prefs::kSavingBrowserHistoryDisabled));
+  }
+
+  // Delete directive sync is enabled by default.  Register unless full history
+  // sync is disabled.
+  if (!disabled_types.Has(syncer::HISTORY_DELETE_DIRECTIVES) &&
+      !history_disabled) {
+    sync_service->RegisterDataTypeController(
+        new HistoryDeleteDirectivesDataTypeController(ui_thread, error_callback,
+                                                      sync_client));
+  }
+
+  // Session sync is enabled by default.  Register unless explicitly disabled.
+  // This is also disabled if the browser history is disabled, because the
+  // tab sync data is added to the web history on the server.
+  if (!disabled_types.Has(syncer::PROXY_TABS) && !history_disabled) {
+    sync_service->RegisterDataTypeController(
+        new ProxyDataTypeController(ui_thread, syncer::PROXY_TABS));
+    // TODO(zea): remove this once SyncedWindowDelegateGetter is componentized.
+    // For now, we know that the implementation of SyncService is always a
+    // ProfileSyncService at this level.
+    ProfileSyncService* pss = static_cast<ProfileSyncService*>(sync_service);
+    sync_service->RegisterDataTypeController(new SessionDataTypeController(
+        ui_thread, error_callback, sync_client,
+        pss->GetSyncedWindowDelegatesGetter(),
+        sync_service->GetLocalDeviceInfoProvider(),
+        prefs::kSavingBrowserHistoryDisabled));
+  }
+
+  // Favicon sync is enabled by default. Register unless explicitly disabled.
+  if (!disabled_types.Has(syncer::FAVICON_IMAGES) &&
+      !disabled_types.Has(syncer::FAVICON_TRACKING) &&
+      !history_disabled) {
+    // crbug/384552. We disable error uploading for this data types for now.
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, base::Closure(), syncer::FAVICON_IMAGES, sync_client));
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, base::Closure(), syncer::FAVICON_TRACKING, sync_client));
+  }
+
+  // Password sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::PASSWORDS)) {
+    sync_service->RegisterDataTypeController(new PasswordDataTypeController(
+        ui_thread, error_callback, sync_client,
+        sync_client->GetPasswordStateChangedCallback()));
+  }
+
+  if (!disabled_types.Has(syncer::PRIORITY_PREFERENCES)) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::PRIORITY_PREFERENCES, sync_client));
+  }
+
+  // Article sync is disabled by default.  Register only if explicitly enabled.
+  if (dom_distiller::IsEnableSyncArticlesSet()) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::ARTICLES, sync_client));
+  }
+
+#if defined(ENABLE_SUPERVISED_USERS)
+  sync_service->RegisterDataTypeController(
+      new SupervisedUserSyncDataTypeController(syncer::SUPERVISED_USER_SETTINGS,
+                                               error_callback, sync_client,
+                                               profile_));
+  sync_service->RegisterDataTypeController(
+      new SupervisedUserSyncDataTypeController(
+          syncer::SUPERVISED_USER_WHITELISTS, error_callback, sync_client,
+          profile_));
+#endif
+}
+
+void ProfileSyncComponentsFactoryImpl::RegisterDesktopDataTypes(
+    syncer::ModelTypeSet disabled_types,
+    syncer::ModelTypeSet enabled_types,
+    sync_driver::SyncClient* sync_client) {
+  sync_driver::SyncService* sync_service = sync_client->GetSyncService();
+  base::Closure error_callback =
+      base::Bind(&ChromeReportUnrecoverableError, chrome::GetChannel());
+  const scoped_refptr<base::SingleThreadTaskRunner> ui_thread =
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
+
+#if defined(ENABLE_EXTENSIONS)
+  // App sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::APPS)) {
+    sync_service->RegisterDataTypeController(new ExtensionDataTypeController(
+        syncer::APPS, error_callback, sync_client, profile_));
+  }
+
+  // Extension sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::EXTENSIONS)) {
+    sync_service->RegisterDataTypeController(new ExtensionDataTypeController(
+        syncer::EXTENSIONS, error_callback, sync_client, profile_));
+  }
+#endif
+
+  // Preference sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::PREFERENCES)) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::PREFERENCES, sync_client));
+  }
+
+#if defined(ENABLE_THEMES)
+  // Theme sync is enabled by default.  Register unless explicitly disabled.
+  if (!disabled_types.Has(syncer::THEMES)) {
+    sync_service->RegisterDataTypeController(
+        new ThemeDataTypeController(error_callback, sync_client, profile_));
+  }
+#endif
+
+  // Search Engine sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::SEARCH_ENGINES)) {
+    sync_service->RegisterDataTypeController(new SearchEngineDataTypeController(
+        ui_thread, error_callback, sync_client,
+        TemplateURLServiceFactory::GetForProfile(profile_)));
+  }
+
+#if defined(ENABLE_EXTENSIONS)
+  // Extension setting sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::EXTENSION_SETTINGS)) {
+    sync_service->RegisterDataTypeController(
+        new ExtensionSettingDataTypeController(
+            syncer::EXTENSION_SETTINGS, error_callback, sync_client, profile_));
+  }
+
+  // App setting sync is enabled by default.  Register unless explicitly
+  // disabled.
+  if (!disabled_types.Has(syncer::APP_SETTINGS)) {
+    sync_service->RegisterDataTypeController(
+        new ExtensionSettingDataTypeController(
+            syncer::APP_SETTINGS, error_callback, sync_client, profile_));
+  }
+#endif
+
+#if defined(ENABLE_APP_LIST)
+  if (app_list::switches::IsAppListSyncEnabled()) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::APP_LIST, sync_client));
+  }
+#endif
+
+#if defined(OS_LINUX) || defined(OS_WIN) || defined(OS_CHROMEOS)
+  // Dictionary sync is enabled by default.
+  if (!disabled_types.Has(syncer::DICTIONARY)) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::DICTIONARY, sync_client));
+  }
+#endif
+
+#if defined(ENABLE_SUPERVISED_USERS)
+  sync_service->RegisterDataTypeController(
+      new SupervisedUserSyncDataTypeController(
+          syncer::SUPERVISED_USERS, error_callback, sync_client, profile_));
+  sync_service->RegisterDataTypeController(
+      new SupervisedUserSyncDataTypeController(
+          syncer::SUPERVISED_USER_SHARED_SETTINGS, error_callback, sync_client,
+          profile_));
+#endif
+
+#if defined(OS_CHROMEOS)
+  if (command_line_->HasSwitch(switches::kEnableWifiCredentialSync) &&
+      !disabled_types.Has(syncer::WIFI_CREDENTIALS)) {
+    sync_service->RegisterDataTypeController(new UIDataTypeController(
+        ui_thread, error_callback, syncer::WIFI_CREDENTIALS, sync_client));
+  }
+#endif
+}
+
+DataTypeManager* ProfileSyncComponentsFactoryImpl::CreateDataTypeManager(
+    const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>&
+        debug_info_listener,
+    const DataTypeController::TypeMap* controllers,
+    const sync_driver::DataTypeEncryptionHandler* encryption_handler,
+    SyncBackendHost* backend,
+    DataTypeManagerObserver* observer) {
+  return new DataTypeManagerImpl(debug_info_listener, controllers,
+                                 encryption_handler, backend, observer);
+}
+
+browser_sync::SyncBackendHost*
+ProfileSyncComponentsFactoryImpl::CreateSyncBackendHost(
+    const std::string& name,
+    sync_driver::SyncClient* sync_client,
+    invalidation::InvalidationService* invalidator,
+    const base::WeakPtr<sync_driver::SyncPrefs>& sync_prefs,
+    const base::FilePath& sync_folder) {
+  return new browser_sync::SyncBackendHostImpl(
+      name, sync_client,
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI),
+      invalidator, sync_prefs, sync_folder);
+}
+
+scoped_ptr<sync_driver::LocalDeviceInfoProvider>
+ProfileSyncComponentsFactoryImpl::CreateLocalDeviceInfoProvider() {
+  return scoped_ptr<sync_driver::LocalDeviceInfoProvider>(
+      new browser_sync::LocalDeviceInfoProviderImpl(
+          chrome::GetChannel(),
+          chrome::GetVersionString(),
+          ui::GetDeviceFormFactor() == ui::DEVICE_FORM_FACTOR_TABLET));
+}
+
+class TokenServiceProvider
+    : public OAuth2TokenServiceRequest::TokenServiceProvider {
+ public:
+  TokenServiceProvider(
+      const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
+      OAuth2TokenService* token_service);
+
+  // OAuth2TokenServiceRequest::TokenServiceProvider implementation.
+  scoped_refptr<base::SingleThreadTaskRunner> GetTokenServiceTaskRunner()
+      override;
+  OAuth2TokenService* GetTokenService() override;
+
+ private:
+  ~TokenServiceProvider() override;
+
+  scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
+  OAuth2TokenService* token_service_;
+};
+
+TokenServiceProvider::TokenServiceProvider(
+    const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
+    OAuth2TokenService* token_service)
+    : task_runner_(task_runner), token_service_(token_service) {
+}
+
+TokenServiceProvider::~TokenServiceProvider() {
+}
+
+scoped_refptr<base::SingleThreadTaskRunner>
+TokenServiceProvider::GetTokenServiceTaskRunner() {
+  return task_runner_;
+}
+
+OAuth2TokenService* TokenServiceProvider::GetTokenService() {
+  return token_service_;
+}
+
+scoped_ptr<syncer::AttachmentService>
+ProfileSyncComponentsFactoryImpl::CreateAttachmentService(
+    scoped_ptr<syncer::AttachmentStoreForSync> attachment_store,
+    const syncer::UserShare& user_share,
+    const std::string& store_birthday,
+    syncer::ModelType model_type,
+    syncer::AttachmentService::Delegate* delegate) {
+  scoped_ptr<syncer::AttachmentUploader> attachment_uploader;
+  scoped_ptr<syncer::AttachmentDownloader> attachment_downloader;
+  // Only construct an AttachmentUploader and AttachmentDownload if we have sync
+  // credentials. We may not have sync credentials because there may not be a
+  // signed in sync user (e.g. sync is running in "backup" mode).
+  if (!user_share.sync_credentials.email.empty() &&
+      !user_share.sync_credentials.scope_set.empty()) {
+    const scoped_refptr<base::SingleThreadTaskRunner> ui_thread =
+        BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
+
+    scoped_refptr<OAuth2TokenServiceRequest::TokenServiceProvider>
+        token_service_provider(
+            new TokenServiceProvider(ui_thread, token_service_));
+    // TODO(maniscalco): Use shared (one per profile) thread-safe instances of
+    // AttachmentUploader and AttachmentDownloader instead of creating a new one
+    // per AttachmentService (bug 369536).
+    attachment_uploader.reset(new syncer::AttachmentUploaderImpl(
+        sync_service_url_, url_request_context_getter_,
+        user_share.sync_credentials.email,
+        user_share.sync_credentials.scope_set, token_service_provider,
+        store_birthday, model_type));
+
+    token_service_provider =
+        new TokenServiceProvider(ui_thread, token_service_);
+    attachment_downloader = syncer::AttachmentDownloader::Create(
+        sync_service_url_, url_request_context_getter_,
+        user_share.sync_credentials.email,
+        user_share.sync_credentials.scope_set, token_service_provider,
+        store_birthday, model_type);
+  }
+
+  // It is important that the initial backoff delay is relatively large.  For
+  // whatever reason, the server may fail all requests for a short period of
+  // time.  When this happens we don't want to overwhelm the server with
+  // requests so we use a large initial backoff.
+  const base::TimeDelta initial_backoff_delay =
+      base::TimeDelta::FromMinutes(30);
+  const base::TimeDelta max_backoff_delay = base::TimeDelta::FromHours(4);
+  scoped_ptr<syncer::AttachmentService> attachment_service(
+      new syncer::AttachmentServiceImpl(
+          attachment_store.Pass(), attachment_uploader.Pass(),
+          attachment_downloader.Pass(), delegate, initial_backoff_delay,
+          max_backoff_delay));
+  return attachment_service.Pass();
+}
+
+sync_driver::SyncApiComponentFactory::SyncComponents
+    ProfileSyncComponentsFactoryImpl::CreateBookmarkSyncComponents(
+        sync_driver::SyncService* sync_service,
+        sync_driver::DataTypeErrorHandler* error_handler) {
+  BookmarkModel* bookmark_model =
+      BookmarkModelFactory::GetForProfile(profile_);
+  syncer::UserShare* user_share = sync_service->GetUserShare();
+  // TODO(akalin): We may want to propagate this switch up eventually.
+#if defined(OS_ANDROID)
+  const bool kExpectMobileBookmarksFolder = true;
+#else
+  const bool kExpectMobileBookmarksFolder = false;
+#endif
+  BookmarkModelAssociator* model_associator = new BookmarkModelAssociator(
+      bookmark_model, sync_service->GetSyncClient(), user_share, error_handler,
+      kExpectMobileBookmarksFolder);
+  BookmarkChangeProcessor* change_processor = new BookmarkChangeProcessor(
+      sync_service->GetSyncClient(), model_associator, error_handler);
+  return SyncComponents(model_associator, change_processor);
+}
+
+sync_driver::SyncApiComponentFactory::SyncComponents
+    ProfileSyncComponentsFactoryImpl::CreateTypedUrlSyncComponents(
+        sync_driver::SyncService* sync_service,
+        history::HistoryBackend* history_backend,
+        sync_driver::DataTypeErrorHandler* error_handler) {
+  DCHECK(!BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  const scoped_refptr<base::SingleThreadTaskRunner> ui_thread =
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
+
+  // TODO(zea): Once TypedURLs are converted to SyncableService, remove
+  // |sync_service_| member, and make GetSyncService require it be called on
+  // the UI thread.
+  TypedUrlModelAssociator* model_associator =
+      new TypedUrlModelAssociator(sync_service,
+                                  history_backend,
+                                  error_handler);
+  TypedUrlChangeProcessor* change_processor = new TypedUrlChangeProcessor(
+      model_associator, history_backend, error_handler, ui_thread);
+  return SyncComponents(model_associator, change_processor);
+}