| 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
|
|
|