Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(365)

Unified Diff: components/sync_driver/ui_model_type_controller_unittest.cc

Issue 2203673002: [Sync] Move //components/sync_driver to //components/sync/driver. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@sd-a
Patch Set: Full change rebased on static lib. Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/sync_driver/ui_model_type_controller_unittest.cc
diff --git a/components/sync_driver/ui_model_type_controller_unittest.cc b/components/sync_driver/ui_model_type_controller_unittest.cc
deleted file mode 100644
index 08e19f109ba4c31ecdcaa27725f90af6f26d9647..0000000000000000000000000000000000000000
--- a/components/sync_driver/ui_model_type_controller_unittest.cc
+++ /dev/null
@@ -1,292 +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/sync_driver/ui_model_type_controller.h"
-
-#include "base/bind.h"
-#include "base/callback.h"
-#include "base/logging.h"
-#include "base/memory/ptr_util.h"
-#include "base/memory/ref_counted.h"
-#include "base/memory/weak_ptr.h"
-#include "base/message_loop/message_loop.h"
-#include "base/run_loop.h"
-#include "base/sequenced_task_runner.h"
-#include "base/test/test_simple_task_runner.h"
-#include "base/threading/thread.h"
-#include "components/sync/api/fake_model_type_service.h"
-#include "components/sync/core/activation_context.h"
-#include "components/sync/core/shared_model_type_processor.h"
-#include "components/sync/engine_impl/commit_queue.h"
-#include "components/sync_driver/backend_data_type_configurer.h"
-#include "components/sync_driver/fake_sync_client.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace sync_driver_v2 {
-
-namespace {
-
-// Test controller derived from UIModelTypeController.
-class TestUIModelTypeController : public UIModelTypeController {
- public:
- TestUIModelTypeController(
- const scoped_refptr<base::SingleThreadTaskRunner>& ui_thread,
- const base::Closure& error_callback,
- syncer::ModelType model_type,
- sync_driver::SyncClient* sync_client)
- : UIModelTypeController(ui_thread,
- error_callback,
- model_type,
- sync_client) {}
-
- private:
- ~TestUIModelTypeController() override {}
-};
-
-// A no-op instance of CommitQueue.
-class NullCommitQueue : public syncer_v2::CommitQueue {
- public:
- NullCommitQueue() {}
- ~NullCommitQueue() override {}
-
- void EnqueueForCommit(const syncer_v2::CommitRequestDataList& list) override {
- NOTREACHED() << "Not implemented.";
- }
-};
-
-// A class that pretends to be the sync backend.
-class MockSyncBackend {
- public:
- void Connect(
- syncer::ModelType type,
- std::unique_ptr<syncer_v2::ActivationContext> activation_context) {
- enabled_types_.Put(type);
- activation_context->type_processor->ConnectSync(
- base::WrapUnique(new NullCommitQueue()));
- }
-
- void Disconnect(syncer::ModelType type) {
- DCHECK(enabled_types_.Has(type));
- enabled_types_.Remove(type);
- }
-
- private:
- syncer::ModelTypeSet enabled_types_;
-};
-
-// Fake implementation of BackendDataTypeConfigurer that pretends to be Sync
-// backend.
-class MockBackendDataTypeConfigurer
- : public sync_driver::BackendDataTypeConfigurer {
- public:
- MockBackendDataTypeConfigurer(
- MockSyncBackend* backend,
- const scoped_refptr<base::TaskRunner>& sync_task_runner)
- : backend_(backend), sync_task_runner_(sync_task_runner) {}
- ~MockBackendDataTypeConfigurer() override {}
-
- syncer::ModelTypeSet ConfigureDataTypes(
- syncer::ConfigureReason reason,
- const DataTypeConfigStateMap& config_state_map,
- const base::Callback<void(syncer::ModelTypeSet, syncer::ModelTypeSet)>&
- ready_task,
- const base::Callback<void()>& retry_callback) override {
- NOTREACHED() << "Not implemented.";
- return syncer::ModelTypeSet();
- }
-
- void ActivateDirectoryDataType(
- syncer::ModelType type,
- syncer::ModelSafeGroup group,
- sync_driver::ChangeProcessor* change_processor) override {
- NOTREACHED() << "Not implemented.";
- }
-
- void DeactivateDirectoryDataType(syncer::ModelType type) override {
- NOTREACHED() << "Not implemented.";
- }
-
- void ActivateNonBlockingDataType(syncer::ModelType type,
- std::unique_ptr<syncer_v2::ActivationContext>
- activation_context) override {
- // Post on Sync thread just like the real implementation does.
- sync_task_runner_->PostTask(
- FROM_HERE,
- base::Bind(&MockSyncBackend::Connect, base::Unretained(backend_), type,
- base::Passed(std::move(activation_context))));
- }
-
- void DeactivateNonBlockingDataType(syncer::ModelType type) override {
- sync_task_runner_->PostTask(FROM_HERE,
- base::Bind(&MockSyncBackend::Disconnect,
- base::Unretained(backend_), type));
- }
-
- private:
- MockSyncBackend* backend_;
- scoped_refptr<base::TaskRunner> sync_task_runner_;
-};
-
-} // namespace
-
-class UIModelTypeControllerTest : public testing::Test,
- public sync_driver::FakeSyncClient {
- public:
- UIModelTypeControllerTest()
- : auto_run_tasks_(true),
- load_models_callback_called_(false),
- association_callback_called_(false),
- configurer_(&backend_, ui_loop_.task_runner()) {}
-
- ~UIModelTypeControllerTest() override {}
-
- void SetUp() override {
- controller_ = new TestUIModelTypeController(
- ui_loop_.task_runner(), base::Closure(), syncer::DEVICE_INFO, this);
- service_.reset(new syncer_v2::FakeModelTypeService(base::Bind(
- &UIModelTypeControllerTest::CreateProcessor, base::Unretained(this))));
- }
-
- void TearDown() override {
- controller_ = NULL;
- RunAllTasks();
- }
-
- syncer_v2::ModelTypeService* GetModelTypeServiceForType(
- syncer::ModelType type) override {
- return service_.get();
- }
-
- protected:
- std::unique_ptr<syncer_v2::ModelTypeChangeProcessor> CreateProcessor(
- syncer::ModelType type,
- syncer_v2::ModelTypeService* service) {
- std::unique_ptr<syncer_v2::SharedModelTypeProcessor> processor =
- base::WrapUnique(
- new syncer_v2::SharedModelTypeProcessor(type, service));
- type_processor_ = processor.get();
- return std::move(processor);
- }
-
- void ExpectProcessorConnected(bool isConnected) {
- DCHECK(type_processor_);
- EXPECT_EQ(isConnected, type_processor_->IsConnected());
- }
-
- void LoadModels() {
- controller_->LoadModels(base::Bind(
- &UIModelTypeControllerTest::LoadModelsDone, base::Unretained(this)));
- if (!type_processor_->IsAllowingChanges()) {
- type_processor_->OnMetadataLoaded(
- syncer::SyncError(),
- base::WrapUnique(new syncer_v2::MetadataBatch()));
- }
-
- if (auto_run_tasks_) {
- RunAllTasks();
- }
- }
-
- void RegisterWithBackend() {
- controller_->RegisterWithBackend(&configurer_);
- if (auto_run_tasks_) {
- RunAllTasks();
- }
- }
-
- void StartAssociating() {
- controller_->StartAssociating(base::Bind(
- &UIModelTypeControllerTest::AssociationDone, base::Unretained(this)));
- // The callback is expected to be promptly called.
- EXPECT_TRUE(association_callback_called_);
- }
-
- void DeactivateDataTypeAndStop() {
- controller_->DeactivateDataType(&configurer_);
- controller_->Stop();
- if (auto_run_tasks_) {
- RunAllTasks();
- }
- }
-
- // These threads can ping-pong for a bit so we run the UI thread twice.
- void RunAllTasks() {
- base::RunLoop().RunUntilIdle();
- }
-
- void SetAutoRunTasks(bool auto_run_tasks) {
- auto_run_tasks_ = auto_run_tasks;
- }
-
- void LoadModelsDone(syncer::ModelType type, syncer::SyncError error) {
- load_models_callback_called_ = true;
- load_models_error_ = error;
- }
-
- void AssociationDone(sync_driver::DataTypeController::ConfigureResult result,
- const syncer::SyncMergeResult& local_merge_result,
- const syncer::SyncMergeResult& syncer_merge_result) {
- EXPECT_EQ(sync_driver::DataTypeController::OK, result);
- association_callback_called_ = true;
- }
-
- syncer_v2::SharedModelTypeProcessor* type_processor_;
- scoped_refptr<TestUIModelTypeController> controller_;
-
- bool auto_run_tasks_;
- bool load_models_callback_called_;
- syncer::SyncError load_models_error_;
- bool association_callback_called_;
- base::MessageLoopForUI ui_loop_;
- MockSyncBackend backend_;
- MockBackendDataTypeConfigurer configurer_;
- std::unique_ptr<syncer_v2::FakeModelTypeService> service_;
-};
-
-TEST_F(UIModelTypeControllerTest, InitialState) {
- EXPECT_EQ(syncer::DEVICE_INFO, controller_->type());
- EXPECT_EQ(sync_driver::DataTypeController::NOT_RUNNING, controller_->state());
-}
-
-TEST_F(UIModelTypeControllerTest, LoadModelsOnUIThread) {
- LoadModels();
- EXPECT_EQ(sync_driver::DataTypeController::MODEL_LOADED,
- controller_->state());
- EXPECT_TRUE(load_models_callback_called_);
- EXPECT_FALSE(load_models_error_.IsSet());
- ExpectProcessorConnected(false);
-}
-
-TEST_F(UIModelTypeControllerTest, LoadModelsTwice) {
- LoadModels();
- SetAutoRunTasks(false);
- LoadModels();
- EXPECT_EQ(sync_driver::DataTypeController::MODEL_LOADED,
- controller_->state());
- // The second LoadModels call should set the error.
- EXPECT_TRUE(load_models_error_.IsSet());
-}
-
-TEST_F(UIModelTypeControllerTest, ActivateDataTypeOnUIThread) {
- LoadModels();
- EXPECT_EQ(sync_driver::DataTypeController::MODEL_LOADED,
- controller_->state());
- RegisterWithBackend();
- ExpectProcessorConnected(true);
-
- StartAssociating();
- EXPECT_EQ(sync_driver::DataTypeController::RUNNING, controller_->state());
-}
-
-TEST_F(UIModelTypeControllerTest, Stop) {
- LoadModels();
- RegisterWithBackend();
- ExpectProcessorConnected(true);
- StartAssociating();
-
- DeactivateDataTypeAndStop();
- EXPECT_EQ(sync_driver::DataTypeController::NOT_RUNNING, controller_->state());
-}
-
-} // namespace sync_driver_v2
« no previous file with comments | « components/sync_driver/ui_model_type_controller.cc ('k') | components/sync_driver/user_selectable_sync_type.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698