| Index: chrome/browser/extensions/api/storage/settings_sync_unittest.cc
|
| diff --git a/chrome/browser/extensions/api/storage/settings_sync_unittest.cc b/chrome/browser/extensions/api/storage/settings_sync_unittest.cc
|
| index 1e54aaf3ddb3f0492199a2f802738b6403ff8b19..afd33baa503a9f2fe35967c1b3820eef649a19b5 100644
|
| --- a/chrome/browser/extensions/api/storage/settings_sync_unittest.cc
|
| +++ b/chrome/browser/extensions/api/storage/settings_sync_unittest.cc
|
| @@ -20,6 +20,7 @@
|
| #include "extensions/browser/extension_system.h"
|
| #include "extensions/common/manifest.h"
|
| #include "sync/api/sync_change_processor.h"
|
| +#include "sync/api/sync_change_processor_wrapper_for_test.h"
|
| #include "sync/api/sync_error_factory.h"
|
| #include "sync/api/sync_error_factory_mock.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| @@ -157,33 +158,6 @@ class MockSyncChangeProcessor : public syncer::SyncChangeProcessor {
|
| bool fail_all_requests_;
|
| };
|
|
|
| -class SyncChangeProcessorDelegate : public syncer::SyncChangeProcessor {
|
| - public:
|
| - explicit SyncChangeProcessorDelegate(syncer::SyncChangeProcessor* recipient)
|
| - : recipient_(recipient) {
|
| - DCHECK(recipient_);
|
| - }
|
| - virtual ~SyncChangeProcessorDelegate() {}
|
| -
|
| - // syncer::SyncChangeProcessor implementation.
|
| - virtual syncer::SyncError ProcessSyncChanges(
|
| - const tracked_objects::Location& from_here,
|
| - const syncer::SyncChangeList& change_list) OVERRIDE {
|
| - return recipient_->ProcessSyncChanges(from_here, change_list);
|
| - }
|
| -
|
| - virtual syncer::SyncDataList GetAllSyncData(syncer::ModelType type) const
|
| - OVERRIDE {
|
| - return recipient_->GetAllSyncData(type);
|
| - }
|
| -
|
| - private:
|
| - // The recipient of all sync changes.
|
| - syncer::SyncChangeProcessor* recipient_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(SyncChangeProcessorDelegate);
|
| -};
|
| -
|
| // SettingsStorageFactory which always returns TestingValueStore objects,
|
| // and allows individually created objects to be returned.
|
| class TestingValueStoreFactory : public SettingsStorageFactory {
|
| @@ -220,7 +194,7 @@ class ExtensionSettingsSyncTest : public testing::Test {
|
| file_thread_(BrowserThread::FILE, base::MessageLoop::current()),
|
| storage_factory_(new util::ScopedSettingsStorageFactory()),
|
| sync_processor_(new MockSyncChangeProcessor),
|
| - sync_processor_delegate_(new SyncChangeProcessorDelegate(
|
| + sync_processor_wrapper_(new syncer::SyncChangeProcessorWrapperForTest(
|
| sync_processor_.get())) {}
|
|
|
| virtual void SetUp() OVERRIDE {
|
| @@ -281,7 +255,7 @@ class ExtensionSettingsSyncTest : public testing::Test {
|
| scoped_ptr<SettingsFrontend> frontend_;
|
| scoped_refptr<util::ScopedSettingsStorageFactory> storage_factory_;
|
| scoped_ptr<MockSyncChangeProcessor> sync_processor_;
|
| - scoped_ptr<SyncChangeProcessorDelegate> sync_processor_delegate_;
|
| + scoped_ptr<syncer::SyncChangeProcessorWrapperForTest> sync_processor_wrapper_;
|
| };
|
|
|
| // Get a semblance of coverage for both EXTENSION_SETTINGS and APP_SETTINGS
|
| @@ -300,7 +274,7 @@ TEST_F(ExtensionSettingsSyncTest, NoDataDoesNotInvokeSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| AddExtensionAndGetStorage("s2", type);
|
| @@ -341,8 +315,9 @@ TEST_F(ExtensionSettingsSyncTest, InSyncDataDoesNotInvokeSync) {
|
| "s2", "bar", value2, model_type));
|
|
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| - model_type, sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + model_type,
|
| + sync_data,
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // Already in sync, so no changes.
|
| @@ -379,7 +354,7 @@ TEST_F(ExtensionSettingsSyncTest, LocalDataWithNoSyncDataIsPushedToSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // All settings should have been pushed to sync.
|
| @@ -416,8 +391,9 @@ TEST_F(ExtensionSettingsSyncTest, AnySyncDataOverwritesLocalData) {
|
| sync_data.push_back(settings_sync_util::CreateData(
|
| "s2", "bar", value2, model_type));
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| - model_type, sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + model_type,
|
| + sync_data,
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
| expected1.Set("foo", value1.DeepCopy());
|
| expected2.Set("bar", value2.DeepCopy());
|
| @@ -458,8 +434,9 @@ TEST_F(ExtensionSettingsSyncTest, ProcessSyncChanges) {
|
| "s2", "bar", value2, model_type));
|
|
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| - model_type, sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + model_type,
|
| + sync_data,
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
| expected2.Set("bar", value2.DeepCopy());
|
|
|
| @@ -532,8 +509,9 @@ TEST_F(ExtensionSettingsSyncTest, PushToSync) {
|
| "s4", "bar", value2, model_type));
|
|
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| - model_type, sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + model_type,
|
| + sync_data,
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // Add something locally.
|
| @@ -683,7 +661,7 @@ TEST_F(ExtensionSettingsSyncTest, ExtensionAndAppSettingsSyncSeparately) {
|
| GetSyncableService(syncer::EXTENSION_SETTINGS)->MergeDataAndStartSyncing(
|
| syncer::EXTENSION_SETTINGS,
|
| sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
| GetSyncableService(syncer::EXTENSION_SETTINGS)->
|
| StopSyncing(syncer::EXTENSION_SETTINGS);
|
| @@ -693,8 +671,8 @@ TEST_F(ExtensionSettingsSyncTest, ExtensionAndAppSettingsSyncSeparately) {
|
| sync_data.push_back(settings_sync_util::CreateData(
|
| "s2", "bar", value2, syncer::APP_SETTINGS));
|
|
|
| - scoped_ptr<SyncChangeProcessorDelegate> app_settings_delegate_(
|
| - new SyncChangeProcessorDelegate(sync_processor_.get()));
|
| + scoped_ptr<syncer::SyncChangeProcessorWrapperForTest> app_settings_delegate_(
|
| + new syncer::SyncChangeProcessorWrapperForTest(sync_processor_.get()));
|
| GetSyncableService(syncer::APP_SETTINGS)->MergeDataAndStartSyncing(
|
| syncer::APP_SETTINGS,
|
| sync_data,
|
| @@ -732,7 +710,7 @@ TEST_F(ExtensionSettingsSyncTest, FailingStartSyncingDisablesSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(
|
| new syncer::SyncErrorFactoryMock()));
|
| }
|
| @@ -846,12 +824,12 @@ TEST_F(ExtensionSettingsSyncTest, FailingStartSyncingDisablesSync) {
|
| // Restarting sync should make bad start syncing again.
|
| sync_processor_->ClearChanges();
|
| GetSyncableService(model_type)->StopSyncing(model_type);
|
| - sync_processor_delegate_.reset(new SyncChangeProcessorDelegate(
|
| - sync_processor_.get()));
|
| + sync_processor_wrapper_.reset(
|
| + new syncer::SyncChangeProcessorWrapperForTest(sync_processor_.get()));
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // Local settings will have been pushed to sync, since it's empty (in this
|
| @@ -928,7 +906,7 @@ TEST_F(ExtensionSettingsSyncTest, FailingProcessChangesDisablesSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| sync_data,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(
|
| new syncer::SyncErrorFactoryMock()));
|
| }
|
| @@ -1034,7 +1012,7 @@ TEST_F(ExtensionSettingsSyncTest, FailingGetAllSyncDataDoesntStopSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| EXPECT_EQ(
|
| @@ -1080,7 +1058,7 @@ TEST_F(ExtensionSettingsSyncTest, FailureToReadChangesToPushDisablesSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
| testing_factory->GetExisting("bad")->set_error_code(ValueStore::OK);
|
|
|
| @@ -1127,12 +1105,12 @@ TEST_F(ExtensionSettingsSyncTest, FailureToReadChangesToPushDisablesSync) {
|
| // to be pushed to sync successfully, as should future changes to bad.
|
| sync_processor_->ClearChanges();
|
| GetSyncableService(model_type)->StopSyncing(model_type);
|
| - sync_processor_delegate_.reset(new SyncChangeProcessorDelegate(
|
| - sync_processor_.get()));
|
| + sync_processor_wrapper_.reset(
|
| + new syncer::SyncChangeProcessorWrapperForTest(sync_processor_.get()));
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| EXPECT_EQ(
|
| @@ -1182,7 +1160,7 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalStateDisablesSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
| sync_processor_->set_fail_all_requests(false);
|
|
|
| @@ -1221,12 +1199,12 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalStateDisablesSync) {
|
| // Restarting sync makes everything work again.
|
| sync_processor_->ClearChanges();
|
| GetSyncableService(model_type)->StopSyncing(model_type);
|
| - sync_processor_delegate_.reset(new SyncChangeProcessorDelegate(
|
| - sync_processor_.get()));
|
| + sync_processor_wrapper_.reset(
|
| + new syncer::SyncChangeProcessorWrapperForTest(sync_processor_.get()));
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| EXPECT_EQ(
|
| @@ -1269,7 +1247,7 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalChangeDisablesSync) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // bad will fail to send changes.
|
| @@ -1318,12 +1296,12 @@ TEST_F(ExtensionSettingsSyncTest, FailureToPushLocalChangeDisablesSync) {
|
| // Restarting sync makes everything work again.
|
| sync_processor_->ClearChanges();
|
| GetSyncableService(model_type)->StopSyncing(model_type);
|
| - sync_processor_delegate_.reset(new SyncChangeProcessorDelegate(
|
| - sync_processor_.get()));
|
| + sync_processor_wrapper_.reset(
|
| + new syncer::SyncChangeProcessorWrapperForTest(sync_processor_.get()));
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| EXPECT_EQ(
|
| @@ -1365,7 +1343,7 @@ TEST_F(ExtensionSettingsSyncTest,
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| syncer::SyncDataList(),
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(new syncer::SyncErrorFactoryMock()));
|
|
|
| // Large local change rejected and doesn't get sent out.
|
| @@ -1408,7 +1386,7 @@ TEST_F(ExtensionSettingsSyncTest, Dots) {
|
| GetSyncableService(model_type)->MergeDataAndStartSyncing(
|
| model_type,
|
| sync_data_list,
|
| - sync_processor_delegate_.PassAs<syncer::SyncChangeProcessor>(),
|
| + sync_processor_wrapper_.PassAs<syncer::SyncChangeProcessor>(),
|
| scoped_ptr<syncer::SyncErrorFactory>(
|
| new syncer::SyncErrorFactoryMock()));
|
| }
|
|
|