| Index: components/browser_sync/browser/profile_sync_test_util.cc
|
| diff --git a/components/browser_sync/browser/profile_sync_test_util.cc b/components/browser_sync/browser/profile_sync_test_util.cc
|
| deleted file mode 100644
|
| index 03925bbc094562181c92c65c34e2a1b52fcbbde3..0000000000000000000000000000000000000000
|
| --- a/components/browser_sync/browser/profile_sync_test_util.cc
|
| +++ /dev/null
|
| @@ -1,275 +0,0 @@
|
| -// Copyright 2016 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 "components/browser_sync/browser/profile_sync_test_util.h"
|
| -
|
| -#include "base/memory/ptr_util.h"
|
| -#include "components/bookmarks/browser/bookmark_model.h"
|
| -#include "components/history/core/browser/history_model_worker.h"
|
| -#include "components/pref_registry/pref_registry_syncable.h"
|
| -#include "components/signin/core/browser/signin_manager_base.h"
|
| -#include "components/sync/driver/glue/browser_thread_model_worker.h"
|
| -#include "components/sync/driver/glue/ui_model_worker.h"
|
| -#include "components/sync/driver/signin_manager_wrapper.h"
|
| -#include "components/sync/driver/sync_prefs.h"
|
| -#include "components/sync/engine/passive_model_worker.h"
|
| -#include "net/url_request/url_request_test_util.h"
|
| -
|
| -namespace browser_sync {
|
| -
|
| -namespace {
|
| -
|
| -class BundleSyncClient : public sync_driver::FakeSyncClient {
|
| - public:
|
| - BundleSyncClient(
|
| - sync_driver::SyncApiComponentFactory* factory,
|
| - PrefService* pref_service,
|
| - sync_sessions::SyncSessionsClient* sync_sessions_client,
|
| - autofill::PersonalDataManager* personal_data_manager,
|
| - const base::Callback<base::WeakPtr<syncer::SyncableService>(
|
| - syncer::ModelType type)>& get_syncable_service_callback,
|
| - const base::Callback<sync_driver::SyncService*(void)>&
|
| - get_sync_service_callback,
|
| - const base::Callback<bookmarks::BookmarkModel*(void)>&
|
| - get_bookmark_model_callback,
|
| - scoped_refptr<base::SingleThreadTaskRunner> db_thread,
|
| - scoped_refptr<base::SingleThreadTaskRunner> file_thread,
|
| - history::HistoryService* history_service);
|
| -
|
| - ~BundleSyncClient() override;
|
| -
|
| - PrefService* GetPrefService() override;
|
| - sync_sessions::SyncSessionsClient* GetSyncSessionsClient() override;
|
| - autofill::PersonalDataManager* GetPersonalDataManager() override;
|
| - base::WeakPtr<syncer::SyncableService> GetSyncableServiceForType(
|
| - syncer::ModelType type) override;
|
| - sync_driver::SyncService* GetSyncService() override;
|
| - scoped_refptr<syncer::ModelSafeWorker> CreateModelWorkerForGroup(
|
| - syncer::ModelSafeGroup group,
|
| - syncer::WorkerLoopDestructionObserver* observer) override;
|
| - history::HistoryService* GetHistoryService() override;
|
| - bookmarks::BookmarkModel* GetBookmarkModel() override;
|
| -
|
| - private:
|
| - PrefService* const pref_service_;
|
| - sync_sessions::SyncSessionsClient* const sync_sessions_client_;
|
| - autofill::PersonalDataManager* const personal_data_manager_;
|
| - const base::Callback<base::WeakPtr<syncer::SyncableService>(
|
| - syncer::ModelType type)>
|
| - get_syncable_service_callback_;
|
| - const base::Callback<sync_driver::SyncService*(void)>
|
| - get_sync_service_callback_;
|
| - const base::Callback<bookmarks::BookmarkModel*(void)>
|
| - get_bookmark_model_callback_;
|
| - // These task runners, if not null, are used in CreateModelWorkerForGroup.
|
| - const scoped_refptr<base::SingleThreadTaskRunner> db_thread_;
|
| - const scoped_refptr<base::SingleThreadTaskRunner> file_thread_;
|
| - history::HistoryService* history_service_;
|
| -};
|
| -
|
| -BundleSyncClient::BundleSyncClient(
|
| - sync_driver::SyncApiComponentFactory* factory,
|
| - PrefService* pref_service,
|
| - sync_sessions::SyncSessionsClient* sync_sessions_client,
|
| - autofill::PersonalDataManager* personal_data_manager,
|
| - const base::Callback<base::WeakPtr<syncer::SyncableService>(
|
| - syncer::ModelType type)>& get_syncable_service_callback,
|
| - const base::Callback<sync_driver::SyncService*(void)>&
|
| - get_sync_service_callback,
|
| - const base::Callback<bookmarks::BookmarkModel*(void)>&
|
| - get_bookmark_model_callback,
|
| - scoped_refptr<base::SingleThreadTaskRunner> db_thread,
|
| - scoped_refptr<base::SingleThreadTaskRunner> file_thread,
|
| - history::HistoryService* history_service)
|
| - : sync_driver::FakeSyncClient(factory),
|
| - pref_service_(pref_service),
|
| - sync_sessions_client_(sync_sessions_client),
|
| - personal_data_manager_(personal_data_manager),
|
| - get_syncable_service_callback_(get_syncable_service_callback),
|
| - get_sync_service_callback_(get_sync_service_callback),
|
| - get_bookmark_model_callback_(get_bookmark_model_callback),
|
| - db_thread_(db_thread),
|
| - file_thread_(file_thread),
|
| - history_service_(history_service) {
|
| - DCHECK_EQ(!!db_thread_, !!file_thread_);
|
| -}
|
| -
|
| -BundleSyncClient::~BundleSyncClient() = default;
|
| -
|
| -PrefService* BundleSyncClient::GetPrefService() {
|
| - return pref_service_;
|
| -}
|
| -
|
| -sync_sessions::SyncSessionsClient* BundleSyncClient::GetSyncSessionsClient() {
|
| - return sync_sessions_client_;
|
| -}
|
| -
|
| -autofill::PersonalDataManager* BundleSyncClient::GetPersonalDataManager() {
|
| - return personal_data_manager_;
|
| -}
|
| -
|
| -base::WeakPtr<syncer::SyncableService>
|
| -BundleSyncClient::GetSyncableServiceForType(syncer::ModelType type) {
|
| - if (get_syncable_service_callback_.is_null())
|
| - return sync_driver::FakeSyncClient::GetSyncableServiceForType(type);
|
| - return get_syncable_service_callback_.Run(type);
|
| -}
|
| -
|
| -sync_driver::SyncService* BundleSyncClient::GetSyncService() {
|
| - if (get_sync_service_callback_.is_null())
|
| - return sync_driver::FakeSyncClient::GetSyncService();
|
| - return get_sync_service_callback_.Run();
|
| -}
|
| -
|
| -scoped_refptr<syncer::ModelSafeWorker>
|
| -BundleSyncClient::CreateModelWorkerForGroup(
|
| - syncer::ModelSafeGroup group,
|
| - syncer::WorkerLoopDestructionObserver* observer) {
|
| - if (!db_thread_)
|
| - return FakeSyncClient::CreateModelWorkerForGroup(group, observer);
|
| - DCHECK(file_thread_) << "DB thread was specified but FILE thread was not.";
|
| - switch (group) {
|
| - case syncer::GROUP_DB:
|
| - return new BrowserThreadModelWorker(db_thread_, syncer::GROUP_DB,
|
| - observer);
|
| - case syncer::GROUP_FILE:
|
| - return new BrowserThreadModelWorker(file_thread_, syncer::GROUP_FILE,
|
| - observer);
|
| - case syncer::GROUP_UI:
|
| - return new UIModelWorker(base::ThreadTaskRunnerHandle::Get(), observer);
|
| - case syncer::GROUP_PASSIVE:
|
| - return new syncer::PassiveModelWorker(observer);
|
| - case syncer::GROUP_HISTORY: {
|
| - history::HistoryService* history_service = GetHistoryService();
|
| - if (!history_service)
|
| - return nullptr;
|
| - return new HistoryModelWorker(history_service->AsWeakPtr(),
|
| - base::ThreadTaskRunnerHandle::Get(),
|
| - observer);
|
| - }
|
| - default:
|
| - return nullptr;
|
| - }
|
| -}
|
| -
|
| -history::HistoryService* BundleSyncClient::GetHistoryService() {
|
| - if (history_service_)
|
| - return history_service_;
|
| - return FakeSyncClient::GetHistoryService();
|
| -}
|
| -
|
| -bookmarks::BookmarkModel* BundleSyncClient::GetBookmarkModel() {
|
| - if (get_bookmark_model_callback_.is_null())
|
| - return FakeSyncClient::GetBookmarkModel();
|
| - return get_bookmark_model_callback_.Run();
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -void EmptyNetworkTimeUpdate(const base::Time&,
|
| - const base::TimeDelta&,
|
| - const base::TimeDelta&) {}
|
| -
|
| -void RegisterPrefsForProfileSyncService(
|
| - user_prefs::PrefRegistrySyncable* registry) {
|
| - sync_driver::SyncPrefs::RegisterProfilePrefs(registry);
|
| - AccountTrackerService::RegisterPrefs(registry);
|
| - SigninManagerBase::RegisterProfilePrefs(registry);
|
| - SigninManagerBase::RegisterPrefs(registry);
|
| -}
|
| -
|
| -ProfileSyncServiceBundle::SyncClientBuilder::~SyncClientBuilder() = default;
|
| -
|
| -ProfileSyncServiceBundle::SyncClientBuilder::SyncClientBuilder(
|
| - ProfileSyncServiceBundle* bundle)
|
| - : bundle_(bundle) {}
|
| -
|
| -void ProfileSyncServiceBundle::SyncClientBuilder::SetPersonalDataManager(
|
| - autofill::PersonalDataManager* personal_data_manager) {
|
| - personal_data_manager_ = personal_data_manager;
|
| -}
|
| -
|
| -// The client will call this callback to produce the service.
|
| -void ProfileSyncServiceBundle::SyncClientBuilder::SetSyncableServiceCallback(
|
| - const base::Callback<base::WeakPtr<syncer::SyncableService>(
|
| - syncer::ModelType type)>& get_syncable_service_callback) {
|
| - get_syncable_service_callback_ = get_syncable_service_callback;
|
| -}
|
| -
|
| -// The client will call this callback to produce the service.
|
| -void ProfileSyncServiceBundle::SyncClientBuilder::SetSyncServiceCallback(
|
| - const base::Callback<sync_driver::SyncService*(void)>&
|
| - get_sync_service_callback) {
|
| - get_sync_service_callback_ = get_sync_service_callback;
|
| -}
|
| -
|
| -void ProfileSyncServiceBundle::SyncClientBuilder::SetHistoryService(
|
| - history::HistoryService* history_service) {
|
| - history_service_ = history_service;
|
| -}
|
| -
|
| -void ProfileSyncServiceBundle::SyncClientBuilder::SetBookmarkModelCallback(
|
| - const base::Callback<bookmarks::BookmarkModel*(void)>&
|
| - get_bookmark_model_callback) {
|
| - get_bookmark_model_callback_ = get_bookmark_model_callback;
|
| -}
|
| -
|
| -std::unique_ptr<sync_driver::FakeSyncClient>
|
| -ProfileSyncServiceBundle::SyncClientBuilder::Build() {
|
| - return base::MakeUnique<BundleSyncClient>(
|
| - bundle_->component_factory(), bundle_->pref_service(),
|
| - bundle_->sync_sessions_client(), personal_data_manager_,
|
| - get_syncable_service_callback_, get_sync_service_callback_,
|
| - get_bookmark_model_callback_,
|
| - activate_model_creation_ ? bundle_->db_thread() : nullptr,
|
| - activate_model_creation_ ? base::ThreadTaskRunnerHandle::Get() : nullptr,
|
| - history_service_);
|
| -}
|
| -
|
| -ProfileSyncServiceBundle::ProfileSyncServiceBundle()
|
| - : db_thread_(base::ThreadTaskRunnerHandle::Get()),
|
| - worker_pool_owner_(2, "sync test worker pool"),
|
| - signin_client_(&pref_service_),
|
| -#if defined(OS_CHROMEOS)
|
| - signin_manager_(&signin_client_, &account_tracker_),
|
| -#else
|
| - signin_manager_(&signin_client_,
|
| - &auth_service_,
|
| - &account_tracker_,
|
| - nullptr),
|
| -#endif
|
| - url_request_context_(new net::TestURLRequestContextGetter(
|
| - base::ThreadTaskRunnerHandle::Get())) {
|
| - browser_sync::RegisterPrefsForProfileSyncService(pref_service_.registry());
|
| - auth_service_.set_auto_post_fetch_response_on_message_loop(true);
|
| - account_tracker_.Initialize(&signin_client_);
|
| - signin_manager_.Initialize(&pref_service_);
|
| -}
|
| -
|
| -ProfileSyncServiceBundle::~ProfileSyncServiceBundle() {}
|
| -
|
| -ProfileSyncService::InitParams ProfileSyncServiceBundle::CreateBasicInitParams(
|
| - ProfileSyncService::StartBehavior start_behavior,
|
| - std::unique_ptr<sync_driver::SyncClient> sync_client) {
|
| - ProfileSyncService::InitParams init_params;
|
| -
|
| - init_params.start_behavior = start_behavior;
|
| - init_params.sync_client = std::move(sync_client);
|
| - init_params.signin_wrapper =
|
| - base::MakeUnique<SigninManagerWrapper>(signin_manager());
|
| - init_params.oauth2_token_service = auth_service();
|
| - init_params.network_time_update_callback =
|
| - base::Bind(&EmptyNetworkTimeUpdate);
|
| - init_params.base_directory = base::FilePath(FILE_PATH_LITERAL("dummyPath"));
|
| - init_params.url_request_context = url_request_context();
|
| - init_params.debug_identifier = "dummyDebugName";
|
| - init_params.channel = version_info::Channel::UNKNOWN;
|
| - init_params.db_thread = db_thread_;
|
| - init_params.file_thread = base::ThreadTaskRunnerHandle::Get();
|
| - init_params.blocking_pool = worker_pool_owner_.pool().get();
|
| -
|
| - return init_params;
|
| -}
|
| -
|
| -} // namespace browser_sync
|
|
|