Index: components/sync/model/fake_model_type_service.cc |
diff --git a/components/sync/model/fake_model_type_service.cc b/components/sync/model/fake_model_type_service.cc |
index 2ece834f789da6ad027d281adad343934bb8a624..f90b72178107ccdb7b0ae7b9384f88617f5c7539 100644 |
--- a/components/sync/model/fake_model_type_service.cc |
+++ b/components/sync/model/fake_model_type_service.cc |
@@ -137,7 +137,8 @@ void FakeModelTypeService::Store::Reset() { |
FakeModelTypeService::FakeModelTypeService( |
const ChangeProcessorFactory& change_processor_factory) |
- : ModelTypeService(change_processor_factory, PREFERENCES) {} |
+ : ModelTypeService(change_processor_factory, PREFERENCES), |
+ db_(base::MakeUnique<Store>()) {} |
FakeModelTypeService::~FakeModelTypeService() { |
CheckPostConditions(); |
@@ -154,7 +155,7 @@ EntitySpecifics FakeModelTypeService::WriteItem(const std::string& key, |
// Overloaded form to allow passing of custom entity data. |
void FakeModelTypeService::WriteItem(const std::string& key, |
std::unique_ptr<EntityData> entity_data) { |
- db_.PutData(key, *entity_data); |
+ db_->PutData(key, *entity_data); |
if (change_processor()) { |
std::unique_ptr<MetadataChangeList> change_list( |
new SimpleMetadataChangeList()); |
@@ -164,7 +165,7 @@ void FakeModelTypeService::WriteItem(const std::string& key, |
} |
void FakeModelTypeService::DeleteItem(const std::string& key) { |
- db_.RemoveData(key); |
+ db_->RemoveData(key); |
if (change_processor()) { |
std::unique_ptr<MetadataChangeList> change_list( |
new SimpleMetadataChangeList()); |
@@ -187,7 +188,7 @@ SyncError FakeModelTypeService::MergeSyncData( |
return error; |
} |
// Commit any local entities that aren't being overwritten by the server. |
- for (const auto& kv : db_.all_data()) { |
+ for (const auto& kv : db_->all_data()) { |
if (data_map.find(kv.first) == data_map.end()) { |
change_processor()->Put(kv.first, CopyEntityData(*kv.second), |
metadata_changes.get()); |
@@ -195,7 +196,7 @@ SyncError FakeModelTypeService::MergeSyncData( |
} |
// Store any new remote entities. |
for (const auto& kv : data_map) { |
- db_.PutData(kv.first, kv.second.value()); |
+ db_->PutData(kv.first, kv.second.value()); |
} |
ApplyMetadataChangeList(std::move(metadata_changes)); |
return SyncError(); |
@@ -212,16 +213,16 @@ SyncError FakeModelTypeService::ApplySyncChanges( |
for (const EntityChange& change : entity_changes) { |
switch (change.type()) { |
case EntityChange::ACTION_ADD: |
- EXPECT_FALSE(db_.HasData(change.storage_key())); |
- db_.PutData(change.storage_key(), change.data()); |
+ EXPECT_FALSE(db_->HasData(change.storage_key())); |
+ db_->PutData(change.storage_key(), change.data()); |
break; |
case EntityChange::ACTION_UPDATE: |
- EXPECT_TRUE(db_.HasData(change.storage_key())); |
- db_.PutData(change.storage_key(), change.data()); |
+ EXPECT_TRUE(db_->HasData(change.storage_key())); |
+ db_->PutData(change.storage_key(), change.data()); |
break; |
case EntityChange::ACTION_DELETE: |
- EXPECT_TRUE(db_.HasData(change.storage_key())); |
- db_.RemoveData(change.storage_key()); |
+ EXPECT_TRUE(db_->HasData(change.storage_key())); |
+ db_->RemoveData(change.storage_key()); |
break; |
} |
} |
@@ -238,11 +239,11 @@ void FakeModelTypeService::ApplyMetadataChangeList( |
for (const auto& kv : metadata_changes) { |
switch (kv.second.type) { |
case SimpleMetadataChangeList::UPDATE: |
- db_.PutMetadata(kv.first, kv.second.metadata); |
+ db_->PutMetadata(kv.first, kv.second.metadata); |
break; |
case SimpleMetadataChangeList::CLEAR: |
- EXPECT_TRUE(db_.HasMetadata(kv.first)); |
- db_.RemoveMetadata(kv.first); |
+ EXPECT_TRUE(db_->HasMetadata(kv.first)); |
+ db_->RemoveMetadata(kv.first); |
break; |
} |
} |
@@ -251,10 +252,10 @@ void FakeModelTypeService::ApplyMetadataChangeList( |
changes->GetModelTypeStateChange(); |
switch (state_change.type) { |
case SimpleMetadataChangeList::UPDATE: |
- db_.set_model_type_state(state_change.state); |
+ db_->set_model_type_state(state_change.state); |
break; |
case SimpleMetadataChangeList::CLEAR: |
- db_.set_model_type_state(ModelTypeState()); |
+ db_->set_model_type_state(ModelTypeState()); |
break; |
} |
} |
@@ -268,8 +269,8 @@ void FakeModelTypeService::GetData(StorageKeyList keys, DataCallback callback) { |
} |
std::unique_ptr<DataBatchImpl> batch(new DataBatchImpl()); |
for (const std::string& key : keys) { |
- DCHECK(db_.HasData(key)) << "No data for " << key; |
- batch->Put(key, CopyEntityData(db_.GetData(key))); |
+ DCHECK(db_->HasData(key)) << "No data for " << key; |
+ batch->Put(key, CopyEntityData(db_->GetData(key))); |
} |
callback.Run(SyncError(), std::move(batch)); |
} |
@@ -281,7 +282,7 @@ void FakeModelTypeService::GetAllData(DataCallback callback) { |
return; |
} |
std::unique_ptr<DataBatchImpl> batch(new DataBatchImpl()); |
- for (const auto& kv : db_.all_data()) { |
+ for (const auto& kv : db_->all_data()) { |
batch->Put(kv.first, CopyEntityData(*kv.second)); |
} |
callback.Run(SyncError(), std::move(batch)); |
@@ -295,13 +296,6 @@ std::string FakeModelTypeService::GetStorageKey(const EntityData& entity_data) { |
return entity_data.specifics.preference().name(); |
} |
-void FakeModelTypeService::OnChangeProcessorSet() {} |
- |
-void FakeModelTypeService::SetServiceError(SyncError::ErrorType error_type) { |
- DCHECK(!service_error_.IsSet()); |
- service_error_ = SyncError(FROM_HERE, error_type, "TestError", PREFERENCES); |
-} |
- |
ConflictResolution FakeModelTypeService::ResolveConflict( |
const EntityData& local_data, |
const EntityData& remote_data) const { |
@@ -314,6 +308,11 @@ void FakeModelTypeService::SetConflictResolution( |
conflict_resolution_.reset(new ConflictResolution(std::move(resolution))); |
} |
+void FakeModelTypeService::SetServiceError(SyncError::ErrorType error_type) { |
+ DCHECK(!service_error_.IsSet()); |
+ service_error_ = SyncError(FROM_HERE, error_type, "TestError", PREFERENCES); |
+} |
+ |
void FakeModelTypeService::CheckPostConditions() { |
DCHECK(!service_error_.IsSet()); |
} |