Index: components/sync/driver/generic_change_processor_unittest.cc |
diff --git a/components/sync/driver/generic_change_processor_unittest.cc b/components/sync/driver/generic_change_processor_unittest.cc |
index 953f50727360ad57131770b0d1c75016cab1e35f..446700cd61c45fcfcbcb7d265b15886d2f513895 100644 |
--- a/components/sync/driver/generic_change_processor_unittest.cc |
+++ b/components/sync/driver/generic_change_processor_unittest.cc |
@@ -37,45 +37,42 @@ |
#include "testing/gmock/include/gmock/gmock.h" |
#include "testing/gtest/include/gtest/gtest.h" |
-namespace sync_driver { |
+namespace syncer { |
namespace { |
// A mock that keeps track of attachments passed to UploadAttachments. |
-class MockAttachmentService : public syncer::AttachmentServiceImpl { |
+class MockAttachmentService : public AttachmentServiceImpl { |
public: |
MockAttachmentService( |
- std::unique_ptr<syncer::AttachmentStoreForSync> attachment_store); |
+ std::unique_ptr<AttachmentStoreForSync> attachment_store); |
~MockAttachmentService() override; |
- void UploadAttachments( |
- const syncer::AttachmentIdList& attachment_ids) override; |
- std::vector<syncer::AttachmentIdList>* attachment_id_lists(); |
+ void UploadAttachments(const AttachmentIdList& attachment_ids) override; |
+ std::vector<AttachmentIdList>* attachment_id_lists(); |
private: |
- std::vector<syncer::AttachmentIdList> attachment_id_lists_; |
+ std::vector<AttachmentIdList> attachment_id_lists_; |
}; |
MockAttachmentService::MockAttachmentService( |
- std::unique_ptr<syncer::AttachmentStoreForSync> attachment_store) |
- : AttachmentServiceImpl(std::move(attachment_store), |
- std::unique_ptr<syncer::AttachmentUploader>( |
- new syncer::FakeAttachmentUploader), |
- std::unique_ptr<syncer::AttachmentDownloader>( |
- new syncer::FakeAttachmentDownloader), |
- NULL, |
- base::TimeDelta(), |
- base::TimeDelta()) {} |
+ std::unique_ptr<AttachmentStoreForSync> attachment_store) |
+ : AttachmentServiceImpl( |
+ std::move(attachment_store), |
+ std::unique_ptr<AttachmentUploader>(new FakeAttachmentUploader), |
+ std::unique_ptr<AttachmentDownloader>(new FakeAttachmentDownloader), |
+ NULL, |
+ base::TimeDelta(), |
+ base::TimeDelta()) {} |
MockAttachmentService::~MockAttachmentService() {} |
void MockAttachmentService::UploadAttachments( |
- const syncer::AttachmentIdList& attachment_ids) { |
+ const AttachmentIdList& attachment_ids) { |
attachment_id_lists_.push_back(attachment_ids); |
AttachmentServiceImpl::UploadAttachments(attachment_ids); |
} |
-std::vector<syncer::AttachmentIdList>* |
-MockAttachmentService::attachment_id_lists() { |
+std::vector<AttachmentIdList>* MockAttachmentService::attachment_id_lists() { |
return &attachment_id_lists_; |
} |
@@ -87,40 +84,39 @@ class MockSyncApiComponentFactory : public SyncApiComponentFactory { |
// SyncApiComponentFactory implementation. |
void RegisterDataTypes( |
- sync_driver::SyncService* sync_service, |
+ SyncService* sync_service, |
const RegisterDataTypesMethod& register_platform_types_method) override {} |
- sync_driver::DataTypeManager* CreateDataTypeManager( |
- const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>& |
- debug_info_listener, |
- const sync_driver::DataTypeController::TypeMap* controllers, |
- const sync_driver::DataTypeEncryptionHandler* encryption_handler, |
- browser_sync::SyncBackendHost* backend, |
- sync_driver::DataTypeManagerObserver* observer) override { |
+ DataTypeManager* CreateDataTypeManager( |
+ const WeakHandle<DataTypeDebugInfoListener>& debug_info_listener, |
+ const DataTypeController::TypeMap* controllers, |
+ const DataTypeEncryptionHandler* encryption_handler, |
+ SyncBackendHost* backend, |
+ DataTypeManagerObserver* observer) override { |
return nullptr; |
}; |
- browser_sync::SyncBackendHost* CreateSyncBackendHost( |
+ SyncBackendHost* CreateSyncBackendHost( |
const std::string& name, |
invalidation::InvalidationService* invalidator, |
- const base::WeakPtr<sync_driver::SyncPrefs>& sync_prefs, |
+ const base::WeakPtr<SyncPrefs>& sync_prefs, |
const base::FilePath& sync_folder) override { |
return nullptr; |
} |
- std::unique_ptr<sync_driver::LocalDeviceInfoProvider> |
- CreateLocalDeviceInfoProvider() override { |
+ std::unique_ptr<LocalDeviceInfoProvider> CreateLocalDeviceInfoProvider() |
+ override { |
return nullptr; |
} |
SyncComponents CreateBookmarkSyncComponents( |
- sync_driver::SyncService* sync_service, |
- std::unique_ptr<syncer::DataTypeErrorHandler> error_handler) override { |
+ SyncService* sync_service, |
+ std::unique_ptr<DataTypeErrorHandler> error_handler) override { |
return SyncComponents(nullptr, nullptr); |
} |
- std::unique_ptr<syncer::AttachmentService> CreateAttachmentService( |
- std::unique_ptr<syncer::AttachmentStoreForSync> attachment_store, |
- const syncer::UserShare& user_share, |
+ std::unique_ptr<AttachmentService> CreateAttachmentService( |
+ std::unique_ptr<AttachmentStoreForSync> attachment_store, |
+ const UserShare& user_share, |
const std::string& store_birthday, |
- syncer::ModelType model_type, |
- syncer::AttachmentService::Delegate* delegate) override { |
+ ModelType model_type, |
+ AttachmentService::Delegate* delegate) override { |
std::unique_ptr<MockAttachmentService> attachment_service( |
new MockAttachmentService(std::move(attachment_store))); |
// GenericChangeProcessor takes ownership of the AttachmentService, but we |
@@ -143,7 +139,7 @@ class SyncGenericChangeProcessorTest : public testing::Test { |
public: |
// Most test cases will use this type. For those that need a |
// GenericChangeProcessor for a different type, use |InitializeForType|. |
- static const syncer::ModelType kType = syncer::PREFERENCES; |
+ static const ModelType kType = PREFERENCES; |
SyncGenericChangeProcessorTest() |
: syncable_service_ptr_factory_(&fake_syncable_service_), |
@@ -166,47 +162,44 @@ class SyncGenericChangeProcessorTest : public testing::Test { |
// Initialize GenericChangeProcessor and related classes for testing with |
// model type |type|. |
- void InitializeForType(syncer::ModelType type) { |
+ void InitializeForType(ModelType type) { |
TearDown(); |
- test_user_share_.reset(new syncer::TestUserShare); |
+ test_user_share_.reset(new TestUserShare); |
test_user_share_->SetUp(); |
- sync_merge_result_.reset(new syncer::SyncMergeResult(type)); |
+ sync_merge_result_.reset(new SyncMergeResult(type)); |
merge_result_ptr_factory_.reset( |
- new base::WeakPtrFactory<syncer::SyncMergeResult>( |
- sync_merge_result_.get())); |
- |
- syncer::ModelTypeSet types = syncer::ProtocolTypes(); |
- for (syncer::ModelTypeSet::Iterator iter = types.First(); iter.Good(); |
- iter.Inc()) { |
- syncer::TestUserShare::CreateRoot(iter.Get(), |
- test_user_share_->user_share()); |
+ new base::WeakPtrFactory<SyncMergeResult>(sync_merge_result_.get())); |
+ |
+ ModelTypeSet types = ProtocolTypes(); |
+ for (ModelTypeSet::Iterator iter = types.First(); iter.Good(); iter.Inc()) { |
+ TestUserShare::CreateRoot(iter.Get(), test_user_share_->user_share()); |
} |
test_user_share_->encryption_handler()->Init(); |
ConstructGenericChangeProcessor(type); |
} |
- void ConstructGenericChangeProcessor(syncer::ModelType type) { |
- std::unique_ptr<syncer::AttachmentStore> attachment_store = |
- syncer::AttachmentStore::CreateInMemoryStore(); |
+ void ConstructGenericChangeProcessor(ModelType type) { |
+ std::unique_ptr<AttachmentStore> attachment_store = |
+ AttachmentStore::CreateInMemoryStore(); |
change_processor_.reset(new GenericChangeProcessor( |
- type, base::MakeUnique<syncer::DataTypeErrorHandlerMock>(), |
+ type, base::MakeUnique<DataTypeErrorHandlerMock>(), |
syncable_service_ptr_factory_.GetWeakPtr(), |
merge_result_ptr_factory_->GetWeakPtr(), test_user_share_->user_share(), |
&sync_client_, attachment_store->CreateAttachmentStoreForSync())); |
mock_attachment_service_ = sync_factory_.GetMockAttachmentService(); |
} |
- void BuildChildNodes(syncer::ModelType type, int n) { |
- syncer::WriteTransaction trans(FROM_HERE, user_share()); |
+ void BuildChildNodes(ModelType type, int n) { |
+ WriteTransaction trans(FROM_HERE, user_share()); |
for (int i = 0; i < n; ++i) { |
- syncer::WriteNode node(&trans); |
+ WriteNode node(&trans); |
node.InitUniqueByCreation(type, base::StringPrintf("node%05d", i)); |
} |
} |
GenericChangeProcessor* change_processor() { return change_processor_.get(); } |
- syncer::UserShare* user_share() { return test_user_share_->user_share(); } |
+ UserShare* user_share() { return test_user_share_->user_share(); } |
MockAttachmentService* mock_attachment_service() { |
return mock_attachment_service_; |
@@ -220,15 +213,14 @@ class SyncGenericChangeProcessorTest : public testing::Test { |
private: |
base::MessageLoopForUI loop_; |
- std::unique_ptr<syncer::SyncMergeResult> sync_merge_result_; |
- std::unique_ptr<base::WeakPtrFactory<syncer::SyncMergeResult>> |
+ std::unique_ptr<SyncMergeResult> sync_merge_result_; |
+ std::unique_ptr<base::WeakPtrFactory<SyncMergeResult>> |
merge_result_ptr_factory_; |
- syncer::FakeSyncableService fake_syncable_service_; |
- base::WeakPtrFactory<syncer::FakeSyncableService> |
- syncable_service_ptr_factory_; |
+ FakeSyncableService fake_syncable_service_; |
+ base::WeakPtrFactory<FakeSyncableService> syncable_service_ptr_factory_; |
- std::unique_ptr<syncer::TestUserShare> test_user_share_; |
+ std::unique_ptr<TestUserShare> test_user_share_; |
MockAttachmentService* mock_attachment_service_; |
FakeSyncClient sync_client_; |
MockSyncApiComponentFactory sync_factory_; |
@@ -245,7 +237,7 @@ TEST_F(SyncGenericChangeProcessorTest, StressGetAllSyncData) { |
ASSERT_NO_FATAL_FAILURE(BuildChildNodes(kType, kNumChildNodes)); |
for (int i = 0; i < kRepeatCount; ++i) { |
- syncer::SyncDataList sync_data = change_processor()->GetAllSyncData(kType); |
+ SyncDataList sync_data = change_processor()->GetAllSyncData(kType); |
// Start with a simple test. We can add more in-depth testing later. |
EXPECT_EQ(static_cast<size_t>(kNumChildNodes), sync_data.size()); |
@@ -253,31 +245,30 @@ TEST_F(SyncGenericChangeProcessorTest, StressGetAllSyncData) { |
} |
TEST_F(SyncGenericChangeProcessorTest, SetGetPasswords) { |
- InitializeForType(syncer::PASSWORDS); |
+ InitializeForType(PASSWORDS); |
const int kNumPasswords = 10; |
sync_pb::PasswordSpecificsData password_data; |
password_data.set_username_value("user"); |
sync_pb::EntitySpecifics password_holder; |
- syncer::SyncChangeList change_list; |
+ SyncChangeList change_list; |
for (int i = 0; i < kNumPasswords; ++i) { |
password_data.set_password_value(base::StringPrintf("password%i", i)); |
password_holder.mutable_password() |
->mutable_client_only_encrypted_data() |
->CopyFrom(password_data); |
- change_list.push_back(syncer::SyncChange( |
- FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
- base::StringPrintf("title%i", i), |
- password_holder))); |
+ change_list.push_back( |
+ SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
+ base::StringPrintf("title%i", i), |
+ password_holder))); |
} |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet()); |
- syncer::SyncDataList password_list( |
- change_processor()->GetAllSyncData(syncer::PASSWORDS)); |
+ SyncDataList password_list(change_processor()->GetAllSyncData(PASSWORDS)); |
ASSERT_EQ(password_list.size(), change_list.size()); |
for (int i = 0; i < kNumPasswords; ++i) { |
@@ -300,11 +291,11 @@ TEST_F(SyncGenericChangeProcessorTest, SetGetPasswords) { |
ASSERT_EQ(sync_password.username_value(), change_password.username_value()); |
// Verify the raw sync data was stored securely. |
- syncer::ReadTransaction read_transaction(FROM_HERE, user_share()); |
- syncer::ReadNode node(&read_transaction); |
- ASSERT_EQ(node.InitByClientTagLookup(syncer::PASSWORDS, |
- base::StringPrintf("tag%i", i)), |
- syncer::BaseNode::INIT_OK); |
+ ReadTransaction read_transaction(FROM_HERE, user_share()); |
+ ReadNode node(&read_transaction); |
+ ASSERT_EQ( |
+ node.InitByClientTagLookup(PASSWORDS, base::StringPrintf("tag%i", i)), |
+ BaseNode::INIT_OK); |
ASSERT_EQ(node.GetTitle(), "encrypted"); |
const sync_pb::EntitySpecifics& raw_specifics = node.GetEntitySpecifics(); |
ASSERT_TRUE(raw_specifics.has_password()); |
@@ -314,34 +305,34 @@ TEST_F(SyncGenericChangeProcessorTest, SetGetPasswords) { |
} |
TEST_F(SyncGenericChangeProcessorTest, UpdatePasswords) { |
- InitializeForType(syncer::PASSWORDS); |
+ InitializeForType(PASSWORDS); |
const int kNumPasswords = 10; |
sync_pb::PasswordSpecificsData password_data; |
password_data.set_username_value("user"); |
sync_pb::EntitySpecifics password_holder; |
- syncer::SyncChangeList change_list; |
- syncer::SyncChangeList change_list2; |
+ SyncChangeList change_list; |
+ SyncChangeList change_list2; |
for (int i = 0; i < kNumPasswords; ++i) { |
password_data.set_password_value(base::StringPrintf("password%i", i)); |
password_holder.mutable_password() |
->mutable_client_only_encrypted_data() |
->CopyFrom(password_data); |
- change_list.push_back(syncer::SyncChange( |
- FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
- base::StringPrintf("title%i", i), |
- password_holder))); |
+ change_list.push_back( |
+ SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
+ base::StringPrintf("title%i", i), |
+ password_holder))); |
password_data.set_password_value(base::StringPrintf("password_m%i", i)); |
password_holder.mutable_password() |
->mutable_client_only_encrypted_data() |
->CopyFrom(password_data); |
- change_list2.push_back(syncer::SyncChange( |
- FROM_HERE, syncer::SyncChange::ACTION_UPDATE, |
- syncer::SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
- base::StringPrintf("title_m%i", i), |
- password_holder))); |
+ change_list2.push_back( |
+ SyncChange(FROM_HERE, SyncChange::ACTION_UPDATE, |
+ SyncData::CreateLocalData(base::StringPrintf("tag%i", i), |
+ base::StringPrintf("title_m%i", i), |
+ password_holder))); |
} |
ASSERT_FALSE( |
@@ -349,8 +340,7 @@ TEST_F(SyncGenericChangeProcessorTest, UpdatePasswords) { |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, change_list2).IsSet()); |
- syncer::SyncDataList password_list( |
- change_processor()->GetAllSyncData(syncer::PASSWORDS)); |
+ SyncDataList password_list(change_processor()->GetAllSyncData(PASSWORDS)); |
ASSERT_EQ(password_list.size(), change_list2.size()); |
for (int i = 0; i < kNumPasswords; ++i) { |
@@ -373,11 +363,11 @@ TEST_F(SyncGenericChangeProcessorTest, UpdatePasswords) { |
ASSERT_EQ(sync_password.username_value(), change_password.username_value()); |
// Verify the raw sync data was stored securely. |
- syncer::ReadTransaction read_transaction(FROM_HERE, user_share()); |
- syncer::ReadNode node(&read_transaction); |
- ASSERT_EQ(node.InitByClientTagLookup(syncer::PASSWORDS, |
- base::StringPrintf("tag%i", i)), |
- syncer::BaseNode::INIT_OK); |
+ ReadTransaction read_transaction(FROM_HERE, user_share()); |
+ ReadNode node(&read_transaction); |
+ ASSERT_EQ( |
+ node.InitByClientTagLookup(PASSWORDS, base::StringPrintf("tag%i", i)), |
+ BaseNode::INIT_OK); |
ASSERT_EQ(node.GetTitle(), "encrypted"); |
const sync_pb::EntitySpecifics& raw_specifics = node.GetEntitySpecifics(); |
ASSERT_TRUE(raw_specifics.has_password()); |
@@ -396,43 +386,42 @@ TEST_F(SyncGenericChangeProcessorTest, |
sync_pb::PreferenceSpecifics* pref_specifics = specifics.mutable_preference(); |
pref_specifics->set_name("test"); |
- syncer::AttachmentIdList attachment_ids; |
- attachment_ids.push_back(syncer::AttachmentId::Create(0, 0)); |
- attachment_ids.push_back(syncer::AttachmentId::Create(0, 0)); |
+ AttachmentIdList attachment_ids; |
+ attachment_ids.push_back(AttachmentId::Create(0, 0)); |
+ attachment_ids.push_back(AttachmentId::Create(0, 0)); |
// Add a SyncData with two attachments. |
- syncer::SyncChangeList change_list; |
- change_list.push_back( |
- syncer::SyncChange(FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalDataWithAttachments( |
- tag, title, specifics, attachment_ids))); |
+ SyncChangeList change_list; |
+ change_list.push_back(SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalDataWithAttachments( |
+ tag, title, specifics, attachment_ids))); |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet()); |
RunLoop(); |
// Check that the AttachmentService received the new attachments. |
ASSERT_EQ(mock_attachment_service()->attachment_id_lists()->size(), 1U); |
- const syncer::AttachmentIdList& attachments_added = |
+ const AttachmentIdList& attachments_added = |
mock_attachment_service()->attachment_id_lists()->front(); |
ASSERT_THAT(attachments_added, testing::UnorderedElementsAre( |
attachment_ids[0], attachment_ids[1])); |
// Update the SyncData, replacing its two attachments with one new attachment. |
- syncer::AttachmentIdList new_attachment_ids; |
- new_attachment_ids.push_back(syncer::AttachmentId::Create(0, 0)); |
+ AttachmentIdList new_attachment_ids; |
+ new_attachment_ids.push_back(AttachmentId::Create(0, 0)); |
mock_attachment_service()->attachment_id_lists()->clear(); |
change_list.clear(); |
change_list.push_back( |
- syncer::SyncChange(FROM_HERE, syncer::SyncChange::ACTION_UPDATE, |
- syncer::SyncData::CreateLocalDataWithAttachments( |
- tag, title, specifics, new_attachment_ids))); |
+ SyncChange(FROM_HERE, SyncChange::ACTION_UPDATE, |
+ SyncData::CreateLocalDataWithAttachments(tag, title, specifics, |
+ new_attachment_ids))); |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet()); |
RunLoop(); |
// Check that the AttachmentService received it. |
ASSERT_EQ(mock_attachment_service()->attachment_id_lists()->size(), 1U); |
- const syncer::AttachmentIdList& new_attachments_added = |
+ const AttachmentIdList& new_attachments_added = |
mock_attachment_service()->attachment_id_lists()->front(); |
ASSERT_THAT(new_attachments_added, |
testing::UnorderedElementsAre(new_attachment_ids[0])); |
@@ -447,26 +436,25 @@ TEST_F(SyncGenericChangeProcessorTest, AttachmentUploaded) { |
sync_pb::PreferenceSpecifics* pref_specifics = specifics.mutable_preference(); |
pref_specifics->set_name("test"); |
- syncer::AttachmentIdList attachment_ids; |
- attachment_ids.push_back(syncer::AttachmentId::Create(0, 0)); |
+ AttachmentIdList attachment_ids; |
+ attachment_ids.push_back(AttachmentId::Create(0, 0)); |
// Add a SyncData with two attachments. |
- syncer::SyncChangeList change_list; |
- change_list.push_back( |
- syncer::SyncChange(FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalDataWithAttachments( |
- tag, title, specifics, attachment_ids))); |
+ SyncChangeList change_list; |
+ change_list.push_back(SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalDataWithAttachments( |
+ tag, title, specifics, attachment_ids))); |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet()); |
sync_pb::AttachmentIdProto attachment_id_proto = attachment_ids[0].GetProto(); |
- syncer::AttachmentId attachment_id = |
- syncer::AttachmentId::CreateFromProto(attachment_id_proto); |
+ AttachmentId attachment_id = |
+ AttachmentId::CreateFromProto(attachment_id_proto); |
change_processor()->OnAttachmentUploaded(attachment_id); |
- syncer::ReadTransaction read_transaction(FROM_HERE, user_share()); |
- syncer::ReadNode node(&read_transaction); |
- ASSERT_EQ(node.InitByClientTagLookup(kType, tag), syncer::BaseNode::INIT_OK); |
+ ReadTransaction read_transaction(FROM_HERE, user_share()); |
+ ReadNode node(&read_transaction); |
+ ASSERT_EQ(node.InitByClientTagLookup(kType, tag), BaseNode::INIT_OK); |
attachment_ids = node.GetAttachmentIds(); |
EXPECT_EQ(1U, attachment_ids.size()); |
} |
@@ -475,14 +463,14 @@ TEST_F(SyncGenericChangeProcessorTest, AttachmentUploaded) { |
// scheduled for upload. |
TEST_F(SyncGenericChangeProcessorTest, UploadAllAttachmentsNotOnServer) { |
// Create two attachment ids. id2 will be marked as "on server". |
- syncer::AttachmentId id1 = syncer::AttachmentId::Create(0, 0); |
- syncer::AttachmentId id2 = syncer::AttachmentId::Create(0, 0); |
+ AttachmentId id1 = AttachmentId::Create(0, 0); |
+ AttachmentId id2 = AttachmentId::Create(0, 0); |
{ |
// Write an entry containing these two attachment ids. |
- syncer::WriteTransaction trans(FROM_HERE, user_share()); |
- syncer::ReadNode root(&trans); |
- ASSERT_EQ(syncer::BaseNode::INIT_OK, root.InitTypeRoot(kType)); |
- syncer::WriteNode node(&trans); |
+ WriteTransaction trans(FROM_HERE, user_share()); |
+ ReadNode root(&trans); |
+ ASSERT_EQ(BaseNode::INIT_OK, root.InitTypeRoot(kType)); |
+ WriteNode node(&trans); |
node.InitUniqueByCreation(kType, root, "some node"); |
sync_pb::AttachmentMetadata metadata; |
sync_pb::AttachmentMetadataRecord* record1 = metadata.add_record(); |
@@ -503,40 +491,38 @@ TEST_F(SyncGenericChangeProcessorTest, UploadAllAttachmentsNotOnServer) { |
// Test that attempting to add an entry that already exists still works. |
TEST_F(SyncGenericChangeProcessorTest, AddExistingEntry) { |
- InitializeForType(syncer::SESSIONS); |
+ InitializeForType(SESSIONS); |
sync_pb::EntitySpecifics sessions_specifics; |
sessions_specifics.mutable_session()->set_session_tag("session tag"); |
- syncer::SyncChangeList changes; |
+ SyncChangeList changes; |
// First add it normally. |
- changes.push_back(syncer::SyncChange( |
- FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalData(base::StringPrintf("tag"), |
- base::StringPrintf("title"), |
- sessions_specifics))); |
+ changes.push_back( |
+ SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalData(base::StringPrintf("tag"), |
+ base::StringPrintf("title"), |
+ sessions_specifics))); |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, changes).IsSet()); |
// Now attempt to add it again, but with different specifics. Should not |
// result in an error and should still update the specifics. |
sessions_specifics.mutable_session()->set_session_tag("session tag 2"); |
- changes[0] = |
- syncer::SyncChange(FROM_HERE, syncer::SyncChange::ACTION_ADD, |
- syncer::SyncData::CreateLocalData( |
- base::StringPrintf("tag"), |
- base::StringPrintf("title"), sessions_specifics)); |
+ changes[0] = SyncChange(FROM_HERE, SyncChange::ACTION_ADD, |
+ SyncData::CreateLocalData(base::StringPrintf("tag"), |
+ base::StringPrintf("title"), |
+ sessions_specifics)); |
ASSERT_FALSE( |
change_processor()->ProcessSyncChanges(FROM_HERE, changes).IsSet()); |
// Verify the data was updated properly. |
- syncer::SyncDataList sync_data = |
- change_processor()->GetAllSyncData(syncer::SESSIONS); |
+ SyncDataList sync_data = change_processor()->GetAllSyncData(SESSIONS); |
ASSERT_EQ(sync_data.size(), 1U); |
ASSERT_EQ("session tag 2", |
sync_data[0].GetSpecifics().session().session_tag()); |
- EXPECT_FALSE(syncer::SyncDataRemote(sync_data[0]).GetClientTagHash().empty()); |
+ EXPECT_FALSE(SyncDataRemote(sync_data[0]).GetClientTagHash().empty()); |
} |
} // namespace |
-} // namespace sync_driver |
+} // namespace syncer |