Index: components/browser_sync/browser/profile_sync_service_bookmark_unittest.cc |
diff --git a/components/browser_sync/browser/profile_sync_service_bookmark_unittest.cc b/components/browser_sync/browser/profile_sync_service_bookmark_unittest.cc |
deleted file mode 100644 |
index 545ab04b594623e683afe3e87c949b8a1544a38d..0000000000000000000000000000000000000000 |
--- a/components/browser_sync/browser/profile_sync_service_bookmark_unittest.cc |
+++ /dev/null |
@@ -1,2601 +0,0 @@ |
-// Copyright (c) 2012 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. |
- |
-// TODO(akalin): This file is basically just a unit test for |
-// BookmarkChangeProcessor. Write unit tests for |
-// BookmarkModelAssociator separately. |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include <map> |
-#include <memory> |
-#include <queue> |
-#include <stack> |
-#include <utility> |
- |
-#include "base/bind.h" |
-#include "base/bind_helpers.h" |
-#include "base/files/file_util.h" |
-#include "base/location.h" |
-#include "base/macros.h" |
-#include "base/memory/ptr_util.h" |
-#include "base/run_loop.h" |
-#include "base/strings/string16.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "base/strings/string_util.h" |
-#include "base/strings/stringprintf.h" |
-#include "base/strings/utf_string_conversions.h" |
-#include "base/test/test_message_loop.h" |
-#include "base/time/time.h" |
-#include "build/build_config.h" |
-#include "components/bookmarks/browser/base_bookmark_model_observer.h" |
-#include "components/bookmarks/browser/bookmark_model.h" |
-#include "components/bookmarks/browser/bookmark_utils.h" |
-#include "components/bookmarks/managed/managed_bookmark_service.h" |
-#include "components/bookmarks/test/bookmark_test_helpers.h" |
-#include "components/bookmarks/test/test_bookmark_client.h" |
-#include "components/browser_sync/browser/profile_sync_test_util.h" |
-#include "components/sync/api/data_type_error_handler.h" |
-#include "components/sync/api/data_type_error_handler_mock.h" |
-#include "components/sync/api/sync_error.h" |
-#include "components/sync/api/sync_merge_result.h" |
-#include "components/sync/core/change_record.h" |
-#include "components/sync/core/read_node.h" |
-#include "components/sync/core/read_transaction.h" |
-#include "components/sync/core/test/test_user_share.h" |
-#include "components/sync/core/write_node.h" |
-#include "components/sync/core/write_transaction.h" |
-#include "components/sync/core_impl/syncapi_internal.h" |
-#include "components/sync/driver/fake_sync_client.h" |
-#include "components/sync/syncable/mutable_entry.h" |
-#include "components/sync/syncable/syncable_id.h" |
-#include "components/sync/syncable/syncable_util.h" |
-#include "components/sync/syncable/syncable_write_transaction.h" |
-#include "components/sync_bookmarks/bookmark_change_processor.h" |
-#include "components/sync_bookmarks/bookmark_model_associator.h" |
-#include "testing/gmock/include/gmock/gmock.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-using bookmarks::BookmarkModel; |
-using bookmarks::BookmarkNode; |
-using sync_bookmarks::BookmarkChangeProcessor; |
-using sync_bookmarks::BookmarkModelAssociator; |
-using syncer::BaseNode; |
-using testing::_; |
-using testing::Return; |
-using testing::StrictMock; |
- |
-namespace browser_sync { |
- |
-namespace { |
- |
-#if defined(OS_ANDROID) || defined(OS_IOS) |
-static const bool kExpectMobileBookmarks = true; |
-#else |
-static const bool kExpectMobileBookmarks = false; |
-#endif // defined(OS_ANDROID) || defined(OS_IOS) |
- |
-std::string ReturnEmptyString() { |
- return std::string(); |
-} |
- |
-void MakeServerUpdate(syncer::WriteTransaction* trans, |
- syncer::WriteNode* node) { |
- syncer::syncable::ChangeEntryIDAndUpdateChildren( |
- trans->GetWrappedWriteTrans(), node->GetMutableEntryForTest(), |
- syncer::syncable::Id::CreateFromServerId( |
- base::Int64ToString(node->GetId()))); |
- node->GetMutableEntryForTest()->PutBaseVersion(10); |
- node->GetMutableEntryForTest()->PutIsUnappliedUpdate(true); |
-} |
- |
-void MakeServerUpdate(syncer::WriteTransaction* trans, int64_t id) { |
- syncer::WriteNode node(trans); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- MakeServerUpdate(trans, &node); |
-} |
- |
-// FakeServerChange constructs a list of syncer::ChangeRecords while modifying |
-// the sync model, and can pass the ChangeRecord list to a |
-// syncer::SyncObserver (i.e., the ProfileSyncService) to test the client |
-// change-application behavior. |
-// Tests using FakeServerChange should be careful to avoid back-references, |
-// since FakeServerChange will send the edits in the order specified. |
-class FakeServerChange { |
- public: |
- explicit FakeServerChange(syncer::WriteTransaction* trans) : trans_(trans) {} |
- |
- // Pretend that the server told the syncer to add a bookmark object. |
- int64_t AddWithMetaInfo(const std::string& title, |
- const std::string& url, |
- const BookmarkNode::MetaInfoMap* meta_info_map, |
- bool is_folder, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- syncer::ReadNode parent(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, parent.InitByIdLookup(parent_id)); |
- syncer::WriteNode node(trans_); |
- if (predecessor_id == 0) { |
- EXPECT_TRUE(node.InitBookmarkByCreation(parent, NULL)); |
- } else { |
- syncer::ReadNode predecessor(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, predecessor.InitByIdLookup(predecessor_id)); |
- EXPECT_EQ(predecessor.GetParentId(), parent.GetId()); |
- EXPECT_TRUE(node.InitBookmarkByCreation(parent, &predecessor)); |
- } |
- EXPECT_EQ(node.GetPredecessorId(), predecessor_id); |
- EXPECT_EQ(node.GetParentId(), parent_id); |
- node.SetIsFolder(is_folder); |
- node.SetTitle(title); |
- |
- sync_pb::BookmarkSpecifics specifics(node.GetBookmarkSpecifics()); |
- const base::Time creation_time(base::Time::Now()); |
- specifics.set_creation_time_us(creation_time.ToInternalValue()); |
- if (!is_folder) |
- specifics.set_url(url); |
- if (meta_info_map) |
- SetNodeMetaInfo(*meta_info_map, &specifics); |
- node.SetBookmarkSpecifics(specifics); |
- |
- syncer::ChangeRecord record; |
- record.action = syncer::ChangeRecord::ACTION_ADD; |
- record.id = node.GetId(); |
- changes_.push_back(record); |
- return node.GetId(); |
- } |
- |
- int64_t Add(const std::string& title, |
- const std::string& url, |
- bool is_folder, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- return AddWithMetaInfo(title, url, NULL, is_folder, parent_id, |
- predecessor_id); |
- } |
- |
- // Add a bookmark folder. |
- int64_t AddFolder(const std::string& title, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- return Add(title, std::string(), true, parent_id, predecessor_id); |
- } |
- int64_t AddFolderWithMetaInfo(const std::string& title, |
- const BookmarkNode::MetaInfoMap* meta_info_map, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- return AddWithMetaInfo(title, std::string(), meta_info_map, true, parent_id, |
- predecessor_id); |
- } |
- |
- // Add a bookmark. |
- int64_t AddURL(const std::string& title, |
- const std::string& url, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- return Add(title, url, false, parent_id, predecessor_id); |
- } |
- int64_t AddURLWithMetaInfo(const std::string& title, |
- const std::string& url, |
- const BookmarkNode::MetaInfoMap* meta_info_map, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- return AddWithMetaInfo(title, url, meta_info_map, false, parent_id, |
- predecessor_id); |
- } |
- |
- // Pretend that the server told the syncer to delete an object. |
- void Delete(int64_t id) { |
- { |
- // Delete the sync node. |
- syncer::WriteNode node(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- if (node.GetIsFolder()) |
- EXPECT_FALSE(node.GetFirstChildId()); |
- node.GetMutableEntryForTest()->PutServerIsDel(true); |
- node.Tombstone(); |
- } |
- { |
- // Verify the deletion. |
- syncer::ReadNode node(trans_); |
- EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_IS_DEL, node.InitByIdLookup(id)); |
- } |
- |
- syncer::ChangeRecord record; |
- record.action = syncer::ChangeRecord::ACTION_DELETE; |
- record.id = id; |
- // Deletions are always first in the changelist, but we can't actually do |
- // WriteNode::Remove() on the node until its children are moved. So, as |
- // a practical matter, users of FakeServerChange must move or delete |
- // children before parents. Thus, we must insert the deletion record |
- // at the front of the vector. |
- changes_.insert(changes_.begin(), record); |
- } |
- |
- // Set a new title value, and return the old value. |
- std::string ModifyTitle(int64_t id, const std::string& new_title) { |
- syncer::WriteNode node(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- std::string old_title = node.GetTitle(); |
- node.SetTitle(new_title); |
- SetModified(id); |
- return old_title; |
- } |
- |
- // Set a new parent and predecessor value. Return the old parent id. |
- // We could return the old predecessor id, but it turns out not to be |
- // very useful for assertions. |
- int64_t ModifyPosition(int64_t id, |
- int64_t parent_id, |
- int64_t predecessor_id) { |
- syncer::ReadNode parent(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, parent.InitByIdLookup(parent_id)); |
- syncer::WriteNode node(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- int64_t old_parent_id = node.GetParentId(); |
- if (predecessor_id == 0) { |
- EXPECT_TRUE(node.SetPosition(parent, NULL)); |
- } else { |
- syncer::ReadNode predecessor(trans_); |
- EXPECT_EQ(BaseNode::INIT_OK, predecessor.InitByIdLookup(predecessor_id)); |
- EXPECT_EQ(predecessor.GetParentId(), parent.GetId()); |
- EXPECT_TRUE(node.SetPosition(parent, &predecessor)); |
- } |
- SetModified(id); |
- return old_parent_id; |
- } |
- |
- void ModifyCreationTime(int64_t id, int64_t creation_time_us) { |
- syncer::WriteNode node(trans_); |
- ASSERT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- sync_pb::BookmarkSpecifics specifics = node.GetBookmarkSpecifics(); |
- specifics.set_creation_time_us(creation_time_us); |
- node.SetBookmarkSpecifics(specifics); |
- SetModified(id); |
- } |
- |
- void ModifyMetaInfo(int64_t id, |
- const BookmarkNode::MetaInfoMap& meta_info_map) { |
- syncer::WriteNode node(trans_); |
- ASSERT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- sync_pb::BookmarkSpecifics specifics = node.GetBookmarkSpecifics(); |
- SetNodeMetaInfo(meta_info_map, &specifics); |
- node.SetBookmarkSpecifics(specifics); |
- SetModified(id); |
- } |
- |
- // Pass the fake change list to |service|. |
- void ApplyPendingChanges(sync_driver::ChangeProcessor* processor) { |
- processor->ApplyChangesFromSyncModel( |
- trans_, 0, syncer::ImmutableChangeRecordList(&changes_)); |
- } |
- |
- const syncer::ChangeRecordList& changes() { return changes_; } |
- |
- private: |
- // Helper function to push an ACTION_UPDATE record onto the back |
- // of the changelist. |
- void SetModified(int64_t id) { |
- // Coalesce multi-property edits. |
- if (!changes_.empty() && changes_.back().id == id && |
- changes_.back().action == syncer::ChangeRecord::ACTION_UPDATE) |
- return; |
- syncer::ChangeRecord record; |
- record.action = syncer::ChangeRecord::ACTION_UPDATE; |
- record.id = id; |
- changes_.push_back(record); |
- } |
- |
- void SetNodeMetaInfo(const BookmarkNode::MetaInfoMap& meta_info_map, |
- sync_pb::BookmarkSpecifics* specifics) { |
- specifics->clear_meta_info(); |
- // Deliberatly set MetaInfoMap entries in opposite order (compared |
- // to the implementation in BookmarkChangeProcessor) to ensure that |
- // (a) the implementation isn't sensitive to the order and |
- // (b) the original meta info isn't blindly overwritten by |
- // BookmarkChangeProcessor unless there is a real change. |
- BookmarkNode::MetaInfoMap::const_iterator it = meta_info_map.end(); |
- while (it != meta_info_map.begin()) { |
- --it; |
- sync_pb::MetaInfo* meta_info = specifics->add_meta_info(); |
- meta_info->set_key(it->first); |
- meta_info->set_value(it->second); |
- } |
- } |
- |
- // The transaction on which everything happens. |
- syncer::WriteTransaction* trans_; |
- |
- // The change list we construct. |
- syncer::ChangeRecordList changes_; |
- DISALLOW_COPY_AND_ASSIGN(FakeServerChange); |
-}; |
- |
-class ExtensiveChangesBookmarkModelObserver |
- : public bookmarks::BaseBookmarkModelObserver { |
- public: |
- ExtensiveChangesBookmarkModelObserver() |
- : started_count_(0), |
- completed_count_at_started_(0), |
- completed_count_(0) {} |
- |
- void ExtensiveBookmarkChangesBeginning(BookmarkModel* model) override { |
- ++started_count_; |
- completed_count_at_started_ = completed_count_; |
- } |
- |
- void ExtensiveBookmarkChangesEnded(BookmarkModel* model) override { |
- ++completed_count_; |
- } |
- |
- void BookmarkModelChanged() override {} |
- |
- int get_started() const { return started_count_; } |
- |
- int get_completed_count_at_started() const { |
- return completed_count_at_started_; |
- } |
- |
- int get_completed() const { return completed_count_; } |
- |
- private: |
- int started_count_; |
- int completed_count_at_started_; |
- int completed_count_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ExtensiveChangesBookmarkModelObserver); |
-}; |
- |
-class ProfileSyncServiceBookmarkTest : public testing::Test { |
- protected: |
- enum LoadOption { LOAD_FROM_STORAGE, DELETE_EXISTING_STORAGE }; |
- enum SaveOption { SAVE_TO_STORAGE, DONT_SAVE_TO_STORAGE }; |
- |
- ProfileSyncServiceBookmarkTest() |
- : managed_bookmark_service_(new bookmarks::ManagedBookmarkService( |
- profile_sync_service_bundle_.pref_service(), |
- base::Bind(ReturnEmptyString))), |
- local_merge_result_(syncer::BOOKMARKS), |
- syncer_merge_result_(syncer::BOOKMARKS) { |
- CHECK(data_dir_.CreateUniqueTempDir()); |
- browser_sync::ProfileSyncServiceBundle::SyncClientBuilder builder( |
- &profile_sync_service_bundle_); |
- builder.SetBookmarkModelCallback(base::Bind( |
- &ProfileSyncServiceBookmarkTest::model, base::Unretained(this))); |
- sync_client_ = builder.Build(); |
- bookmarks::RegisterProfilePrefs( |
- profile_sync_service_bundle_.pref_service()->registry()); |
- } |
- |
- ~ProfileSyncServiceBookmarkTest() override { |
- static_cast<KeyedService*>(managed_bookmark_service_.get())->Shutdown(); |
- StopSync(); |
- } |
- |
- void SetUp() override { test_user_share_.SetUp(); } |
- |
- void TearDown() override { test_user_share_.TearDown(); } |
- |
- bool CanSyncNode(const BookmarkNode* node) { |
- return model_->client()->CanSyncNode(node); |
- } |
- |
- // Inserts a folder directly to the share. |
- // Do not use this after model association is complete. |
- // |
- // This function differs from the AddFolder() function declared elsewhere in |
- // this file in that it only affects the sync model. It would be invalid to |
- // change the sync model directly after ModelAssociation. This function can |
- // be invoked prior to model association to set up first-time sync model |
- // association scenarios. |
- int64_t AddFolderToShare(syncer::WriteTransaction* trans, |
- const std::string& title) { |
- EXPECT_FALSE(model_associator_); |
- |
- // Be sure to call CreatePermanentBookmarkNodes(), otherwise this will fail. |
- syncer::ReadNode bookmark_bar(trans); |
- EXPECT_EQ(BaseNode::INIT_OK, |
- bookmark_bar.InitByTagLookupForBookmarks("bookmark_bar")); |
- |
- syncer::WriteNode node(trans); |
- EXPECT_TRUE(node.InitBookmarkByCreation(bookmark_bar, NULL)); |
- node.SetIsFolder(true); |
- node.SetTitle(title); |
- |
- return node.GetId(); |
- } |
- |
- // Inserts a bookmark directly to the share. |
- // Do not use this after model association is complete. |
- // |
- // This function differs from the AddURL() function declared elsewhere in this |
- // file in that it only affects the sync model. It would be invalid to change |
- // the sync model directly after ModelAssociation. This function can be |
- // invoked prior to model association to set up first-time sync model |
- // association scenarios. |
- int64_t AddBookmarkToShare(syncer::WriteTransaction* trans, |
- int64_t parent_id, |
- const std::string& title, |
- const std::string& url) { |
- EXPECT_FALSE(model_associator_); |
- |
- syncer::ReadNode parent(trans); |
- EXPECT_EQ(BaseNode::INIT_OK, parent.InitByIdLookup(parent_id)); |
- |
- sync_pb::BookmarkSpecifics specifics; |
- specifics.set_url(url); |
- specifics.set_title(title); |
- |
- syncer::WriteNode node(trans); |
- EXPECT_TRUE(node.InitBookmarkByCreation(parent, NULL)); |
- node.SetIsFolder(false); |
- node.SetTitle(title); |
- node.SetBookmarkSpecifics(specifics); |
- |
- return node.GetId(); |
- } |
- |
- // Create a BookmarkModel. If |delete_bookmarks| is true, the bookmarks file |
- // will be deleted before starting up the BookmarkModel. |
- std::unique_ptr<BookmarkModel> CreateBookmarkModel(bool delete_bookmarks) { |
- const base::FilePath& data_path = data_dir_.GetPath(); |
- auto model = base::MakeUnique<BookmarkModel>( |
- base::WrapUnique(new bookmarks::TestBookmarkClient())); |
- managed_bookmark_service_->BookmarkModelCreated(model.get()); |
- int64_t next_id = 0; |
- static_cast<bookmarks::TestBookmarkClient*>(model->client()) |
- ->SetExtraNodesToLoad( |
- managed_bookmark_service_->GetLoadExtraNodesCallback().Run( |
- &next_id)); |
- if (delete_bookmarks) { |
- base::DeleteFile(data_path.Append(FILE_PATH_LITERAL("dummy_bookmarks")), |
- false); |
- } |
- |
- model->Load(profile_sync_service_bundle_.pref_service(), data_path, |
- base::ThreadTaskRunnerHandle::Get(), |
- base::ThreadTaskRunnerHandle::Get()); |
- bookmarks::test::WaitForBookmarkModelToLoad(model.get()); |
- return model; |
- } |
- |
- // Load (or re-load) the bookmark model. |load| controls use of the |
- // bookmarks file on disk. |save| controls whether the newly loaded |
- // bookmark model will write out a bookmark file as it goes. |
- void LoadBookmarkModel(LoadOption load, SaveOption save) { |
- bool delete_bookmarks = load == DELETE_EXISTING_STORAGE; |
- model_.reset(); |
- model_ = CreateBookmarkModel(delete_bookmarks); |
- // This noticeably speeds up the unit tests that request it. |
- if (save == DONT_SAVE_TO_STORAGE) |
- model_->ClearStore(); |
- base::RunLoop().RunUntilIdle(); |
- } |
- |
- int GetSyncBookmarkCount() { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
- syncer::ReadNode node(&trans); |
- if (node.InitTypeRoot(syncer::BOOKMARKS) != BaseNode::INIT_OK) |
- return 0; |
- return node.GetTotalNodeCount(); |
- } |
- |
- // Creates the bookmark root node and the permanent nodes if they don't |
- // already exist. |
- bool CreatePermanentBookmarkNodes() { |
- bool root_exists = false; |
- syncer::ModelType type = syncer::BOOKMARKS; |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
- syncer::ReadNode uber_root(&trans); |
- uber_root.InitByRootLookup(); |
- |
- syncer::ReadNode root(&trans); |
- root_exists = (root.InitTypeRoot(type) == BaseNode::INIT_OK); |
- } |
- |
- if (!root_exists) { |
- if (!syncer::TestUserShare::CreateRoot(type, |
- test_user_share_.user_share())) |
- return false; |
- } |
- |
- const int kNumPermanentNodes = 3; |
- const std::string permanent_tags[kNumPermanentNodes] = { |
- "bookmark_bar", "other_bookmarks", "synced_bookmarks", |
- }; |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
- syncer::ReadNode root(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, root.InitTypeRoot(type)); |
- |
- // Loop through creating permanent nodes as necessary. |
- int64_t last_child_id = syncer::kInvalidId; |
- for (int i = 0; i < kNumPermanentNodes; ++i) { |
- // First check if the node already exists. This is for tests that involve |
- // persistence and set up sync more than once. |
- syncer::ReadNode lookup(&trans); |
- if (lookup.InitByTagLookupForBookmarks(permanent_tags[i]) == |
- syncer::ReadNode::INIT_OK) { |
- last_child_id = lookup.GetId(); |
- continue; |
- } |
- |
- // If it doesn't exist, create the permanent node at the end of the |
- // ordering. |
- syncer::ReadNode predecessor_node(&trans); |
- syncer::ReadNode* predecessor = NULL; |
- if (last_child_id != syncer::kInvalidId) { |
- EXPECT_EQ(BaseNode::INIT_OK, |
- predecessor_node.InitByIdLookup(last_child_id)); |
- predecessor = &predecessor_node; |
- } |
- syncer::WriteNode node(&trans); |
- if (!node.InitBookmarkByCreation(root, predecessor)) |
- return false; |
- node.SetIsFolder(true); |
- node.GetMutableEntryForTest()->PutUniqueServerTag(permanent_tags[i]); |
- node.SetTitle(permanent_tags[i]); |
- node.SetExternalId(0); |
- last_child_id = node.GetId(); |
- } |
- return true; |
- } |
- |
- bool AssociateModels() { |
- DCHECK(!model_associator_); |
- |
- // Set up model associator. |
- model_associator_.reset(new BookmarkModelAssociator( |
- model_.get(), sync_client_.get(), test_user_share_.user_share(), |
- base::MakeUnique<syncer::DataTypeErrorHandlerMock>(), |
- kExpectMobileBookmarks)); |
- |
- local_merge_result_ = syncer::SyncMergeResult(syncer::BOOKMARKS); |
- syncer_merge_result_ = syncer::SyncMergeResult(syncer::BOOKMARKS); |
- int local_count_before = model_->root_node()->GetTotalNodeCount(); |
- int syncer_count_before = GetSyncBookmarkCount(); |
- |
- syncer::SyncError error = model_associator_->AssociateModels( |
- &local_merge_result_, &syncer_merge_result_); |
- if (error.IsSet()) |
- return false; |
- |
- base::RunLoop().RunUntilIdle(); |
- |
- // Verify the merge results were calculated properly. |
- EXPECT_EQ(local_count_before, |
- local_merge_result_.num_items_before_association()); |
- EXPECT_EQ(syncer_count_before, |
- syncer_merge_result_.num_items_before_association()); |
- EXPECT_EQ(local_merge_result_.num_items_after_association(), |
- local_merge_result_.num_items_before_association() + |
- local_merge_result_.num_items_added() - |
- local_merge_result_.num_items_deleted()); |
- EXPECT_EQ(syncer_merge_result_.num_items_after_association(), |
- syncer_merge_result_.num_items_before_association() + |
- syncer_merge_result_.num_items_added() - |
- syncer_merge_result_.num_items_deleted()); |
- EXPECT_EQ(model_->root_node()->GetTotalNodeCount(), |
- local_merge_result_.num_items_after_association()); |
- EXPECT_EQ(GetSyncBookmarkCount(), |
- syncer_merge_result_.num_items_after_association()); |
- return true; |
- } |
- |
- void StartSync() { |
- test_user_share_.Reload(); |
- |
- ASSERT_TRUE(CreatePermanentBookmarkNodes()); |
- ASSERT_TRUE(AssociateModels()); |
- |
- // Set up change processor. |
- ResetChangeProcessor(); |
- change_processor_->Start(test_user_share_.user_share()); |
- } |
- |
- void StopSync() { |
- change_processor_.reset(); |
- if (model_associator_) { |
- syncer::SyncError error = model_associator_->DisassociateModels(); |
- EXPECT_FALSE(error.IsSet()); |
- } |
- model_associator_.reset(); |
- |
- base::RunLoop().RunUntilIdle(); |
- |
- // TODO(akalin): Actually close the database and flush it to disk |
- // (and make StartSync reload from disk). This would require |
- // refactoring TestUserShare. |
- } |
- |
- bool InitSyncNodeFromChromeNode(const BookmarkNode* bnode, |
- BaseNode* sync_node) { |
- return model_associator_->InitSyncNodeFromChromeId(bnode->id(), sync_node); |
- } |
- |
- void ExpectSyncerNodeMatching(syncer::BaseTransaction* trans, |
- const BookmarkNode* bnode) { |
- std::string truncated_title = base::UTF16ToUTF8(bnode->GetTitle()); |
- syncer::SyncAPINameToServerName(truncated_title, &truncated_title); |
- base::TruncateUTF8ToByteSize(truncated_title, 255, &truncated_title); |
- syncer::ServerNameToSyncAPIName(truncated_title, &truncated_title); |
- |
- syncer::ReadNode gnode(trans); |
- ASSERT_TRUE(InitSyncNodeFromChromeNode(bnode, &gnode)); |
- // Non-root node titles and parents must match. |
- if (!model_->is_permanent_node(bnode)) { |
- EXPECT_EQ(truncated_title, gnode.GetTitle()); |
- EXPECT_EQ(model_associator_->GetChromeNodeFromSyncId(gnode.GetParentId()), |
- bnode->parent()); |
- } |
- EXPECT_EQ(bnode->is_folder(), gnode.GetIsFolder()); |
- if (bnode->is_url()) |
- EXPECT_EQ(bnode->url(), GURL(gnode.GetBookmarkSpecifics().url())); |
- |
- // Check that meta info matches. |
- const BookmarkNode::MetaInfoMap* meta_info_map = bnode->GetMetaInfoMap(); |
- sync_pb::BookmarkSpecifics specifics = gnode.GetBookmarkSpecifics(); |
- if (!meta_info_map) { |
- EXPECT_EQ(0, specifics.meta_info_size()); |
- } else { |
- EXPECT_EQ(meta_info_map->size(), |
- static_cast<size_t>(specifics.meta_info_size())); |
- for (int i = 0; i < specifics.meta_info_size(); i++) { |
- BookmarkNode::MetaInfoMap::const_iterator it = |
- meta_info_map->find(specifics.meta_info(i).key()); |
- EXPECT_TRUE(it != meta_info_map->end()); |
- EXPECT_EQ(it->second, specifics.meta_info(i).value()); |
- } |
- } |
- |
- // Check for position matches. |
- int browser_index = bnode->parent()->GetIndexOf(bnode); |
- if (browser_index == 0) { |
- EXPECT_EQ(gnode.GetPredecessorId(), 0); |
- } else { |
- const BookmarkNode* bprev = bnode->parent()->GetChild(browser_index - 1); |
- syncer::ReadNode gprev(trans); |
- ASSERT_TRUE(InitSyncNodeFromChromeNode(bprev, &gprev)); |
- EXPECT_EQ(gnode.GetPredecessorId(), gprev.GetId()); |
- EXPECT_EQ(gnode.GetParentId(), gprev.GetParentId()); |
- } |
- // Note: the managed node is the last child of the root_node but isn't |
- // synced; if CanSyncNode() is false then there is no next node to sync. |
- const BookmarkNode* bnext = NULL; |
- if (browser_index + 1 < bnode->parent()->child_count()) |
- bnext = bnode->parent()->GetChild(browser_index + 1); |
- if (!bnext || !CanSyncNode(bnext)) { |
- EXPECT_EQ(gnode.GetSuccessorId(), 0); |
- } else { |
- syncer::ReadNode gnext(trans); |
- ASSERT_TRUE(InitSyncNodeFromChromeNode(bnext, &gnext)); |
- EXPECT_EQ(gnode.GetSuccessorId(), gnext.GetId()); |
- EXPECT_EQ(gnode.GetParentId(), gnext.GetParentId()); |
- } |
- if (!bnode->empty()) |
- EXPECT_TRUE(gnode.GetFirstChildId()); |
- } |
- |
- void ExpectSyncerNodeMatching(const BookmarkNode* bnode) { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
- ExpectSyncerNodeMatching(&trans, bnode); |
- } |
- |
- void ExpectBrowserNodeMatching(syncer::BaseTransaction* trans, |
- int64_t sync_id) { |
- EXPECT_TRUE(sync_id); |
- const BookmarkNode* bnode = |
- model_associator_->GetChromeNodeFromSyncId(sync_id); |
- ASSERT_TRUE(bnode); |
- ASSERT_TRUE(CanSyncNode(bnode)); |
- |
- int64_t id = model_associator_->GetSyncIdFromChromeId(bnode->id()); |
- EXPECT_EQ(id, sync_id); |
- ExpectSyncerNodeMatching(trans, bnode); |
- } |
- |
- void ExpectBrowserNodeUnknown(int64_t sync_id) { |
- EXPECT_FALSE(model_associator_->GetChromeNodeFromSyncId(sync_id)); |
- } |
- |
- void ExpectBrowserNodeKnown(int64_t sync_id) { |
- EXPECT_TRUE(model_associator_->GetChromeNodeFromSyncId(sync_id)); |
- } |
- |
- void ExpectSyncerNodeKnown(const BookmarkNode* node) { |
- int64_t sync_id = model_associator_->GetSyncIdFromChromeId(node->id()); |
- EXPECT_NE(sync_id, syncer::kInvalidId); |
- } |
- |
- void ExpectSyncerNodeUnknown(const BookmarkNode* node) { |
- int64_t sync_id = model_associator_->GetSyncIdFromChromeId(node->id()); |
- EXPECT_EQ(sync_id, syncer::kInvalidId); |
- } |
- |
- void ExpectBrowserNodeTitle(int64_t sync_id, const std::string& title) { |
- const BookmarkNode* bnode = |
- model_associator_->GetChromeNodeFromSyncId(sync_id); |
- ASSERT_TRUE(bnode); |
- EXPECT_EQ(bnode->GetTitle(), base::UTF8ToUTF16(title)); |
- } |
- |
- void ExpectBrowserNodeURL(int64_t sync_id, const std::string& url) { |
- const BookmarkNode* bnode = |
- model_associator_->GetChromeNodeFromSyncId(sync_id); |
- ASSERT_TRUE(bnode); |
- EXPECT_EQ(GURL(url), bnode->url()); |
- } |
- |
- void ExpectBrowserNodeParent(int64_t sync_id, int64_t parent_sync_id) { |
- const BookmarkNode* node = |
- model_associator_->GetChromeNodeFromSyncId(sync_id); |
- ASSERT_TRUE(node); |
- const BookmarkNode* parent = |
- model_associator_->GetChromeNodeFromSyncId(parent_sync_id); |
- EXPECT_TRUE(parent); |
- EXPECT_EQ(node->parent(), parent); |
- } |
- |
- void ExpectModelMatch(syncer::BaseTransaction* trans) { |
- const BookmarkNode* root = model_->root_node(); |
- EXPECT_EQ(root->GetIndexOf(model_->bookmark_bar_node()), 0); |
- EXPECT_EQ(root->GetIndexOf(model_->other_node()), 1); |
- EXPECT_EQ(root->GetIndexOf(model_->mobile_node()), 2); |
- |
- std::stack<int64_t> stack; |
- stack.push(bookmark_bar_id()); |
- while (!stack.empty()) { |
- int64_t id = stack.top(); |
- stack.pop(); |
- if (!id) |
- continue; |
- |
- ExpectBrowserNodeMatching(trans, id); |
- |
- syncer::ReadNode gnode(trans); |
- ASSERT_EQ(BaseNode::INIT_OK, gnode.InitByIdLookup(id)); |
- stack.push(gnode.GetSuccessorId()); |
- if (gnode.GetIsFolder()) |
- stack.push(gnode.GetFirstChildId()); |
- } |
- } |
- |
- void ExpectModelMatch() { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
- ExpectModelMatch(&trans); |
- } |
- |
- int64_t mobile_bookmarks_id() { |
- return model_associator_->GetSyncIdFromChromeId( |
- model_->mobile_node()->id()); |
- } |
- |
- int64_t other_bookmarks_id() { |
- return model_associator_->GetSyncIdFromChromeId(model_->other_node()->id()); |
- } |
- |
- int64_t bookmark_bar_id() { |
- return model_associator_->GetSyncIdFromChromeId( |
- model_->bookmark_bar_node()->id()); |
- } |
- |
- BookmarkModel* model() { return model_.get(); } |
- |
- syncer::TestUserShare* test_user_share() { return &test_user_share_; } |
- |
- BookmarkChangeProcessor* change_processor() { |
- return change_processor_.get(); |
- } |
- |
- void delete_change_processor() { change_processor_.reset(); } |
- |
- void ResetChangeProcessor() { |
- std::unique_ptr<syncer::DataTypeErrorHandlerMock> error_handler = |
- base::MakeUnique<syncer::DataTypeErrorHandlerMock>(); |
- mock_error_handler_ = error_handler.get(); |
- change_processor_ = base::MakeUnique<BookmarkChangeProcessor>( |
- sync_client_.get(), model_associator_.get(), std::move(error_handler)); |
- } |
- |
- syncer::DataTypeErrorHandlerMock* mock_error_handler() { |
- return mock_error_handler_; |
- } |
- |
- void delete_model_associator() { model_associator_.reset(); } |
- |
- BookmarkModelAssociator* model_associator() { |
- return model_associator_.get(); |
- } |
- |
- bookmarks::ManagedBookmarkService* managed_bookmark_service() { |
- return managed_bookmark_service_.get(); |
- } |
- |
- private: |
- base::TestMessageLoop message_loop_; |
- base::ScopedTempDir data_dir_; |
- browser_sync::ProfileSyncServiceBundle profile_sync_service_bundle_; |
- |
- std::unique_ptr<sync_driver::FakeSyncClient> sync_client_; |
- std::unique_ptr<BookmarkModel> model_; |
- syncer::TestUserShare test_user_share_; |
- std::unique_ptr<BookmarkChangeProcessor> change_processor_; |
- syncer::DataTypeErrorHandlerMock* mock_error_handler_; |
- std::unique_ptr<BookmarkModelAssociator> model_associator_; |
- std::unique_ptr<bookmarks::ManagedBookmarkService> managed_bookmark_service_; |
- |
- syncer::SyncMergeResult local_merge_result_; |
- syncer::SyncMergeResult syncer_merge_result_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ProfileSyncServiceBookmarkTest); |
-}; |
- |
-TEST_F(ProfileSyncServiceBookmarkTest, InitialState) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- EXPECT_TRUE(other_bookmarks_id()); |
- EXPECT_TRUE(bookmark_bar_id()); |
- EXPECT_TRUE(mobile_bookmarks_id()); |
- |
- ExpectModelMatch(); |
-} |
- |
-// Populate the sync database then start model association. Sync's bookmarks |
-// should end up being copied into the native model, resulting in a successful |
-// "ExpectModelMatch()". |
-// |
-// This code has some use for verifying correctness. It's also a very useful |
-// for profiling bookmark ModelAssociation, an important part of some first-time |
-// sync scenarios. Simply increase the kNumFolders and kNumBookmarksPerFolder |
-// as desired, then run the test under a profiler to find hot spots in the model |
-// association code. |
-TEST_F(ProfileSyncServiceBookmarkTest, InitialModelAssociate) { |
- const int kNumBookmarksPerFolder = 10; |
- const int kNumFolders = 10; |
- |
- CreatePermanentBookmarkNodes(); |
- |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- for (int i = 0; i < kNumFolders; ++i) { |
- int64_t folder_id = |
- AddFolderToShare(&trans, base::StringPrintf("folder%05d", i)); |
- for (int j = 0; j < kNumBookmarksPerFolder; ++j) { |
- AddBookmarkToShare( |
- &trans, folder_id, base::StringPrintf("bookmark%05d", j), |
- base::StringPrintf("http://www.google.com/search?q=%05d", j)); |
- } |
- } |
- } |
- |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- ExpectModelMatch(); |
-} |
- |
-// Tests bookmark association when nodes exists in the native model only. |
-// These entries should be copied to Sync directory during association process. |
-TEST_F(ProfileSyncServiceBookmarkTest, |
- InitialModelAssociateWithBookmarkModelNodes) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- const BookmarkNode* folder = model()->AddFolder(model()->other_node(), 0, |
- base::ASCIIToUTF16("foobar")); |
- model()->AddFolder(folder, 0, base::ASCIIToUTF16("nested")); |
- model()->AddURL(folder, 0, base::ASCIIToUTF16("Internets #1 Pies Site"), |
- GURL("http://www.easypie.com/")); |
- model()->AddURL(folder, 1, base::ASCIIToUTF16("Airplanes"), |
- GURL("http://www.easyjet.com/")); |
- |
- StartSync(); |
- ExpectModelMatch(); |
-} |
- |
-// Tests bookmark association case when there is an entry in the delete journal |
-// that matches one of native bookmarks. |
-TEST_F(ProfileSyncServiceBookmarkTest, InitialModelAssociateWithDeleteJournal) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- const BookmarkNode* folder = model()->AddFolder( |
- model()->bookmark_bar_node(), 0, base::ASCIIToUTF16("foobar")); |
- const BookmarkNode* bookmark = |
- model()->AddURL(folder, 0, base::ASCIIToUTF16("Airplanes"), |
- GURL("http://www.easyjet.com/")); |
- |
- CreatePermanentBookmarkNodes(); |
- |
- // Create entries matching the folder and the bookmark above. |
- int64_t folder_id, bookmark_id; |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- folder_id = AddFolderToShare(&trans, "foobar"); |
- bookmark_id = AddBookmarkToShare(&trans, folder_id, "Airplanes", |
- "http://www.easyjet.com/"); |
- } |
- |
- // Associate the bookmark sync node with the native model one and make |
- // it look like it was deleted by a server update. |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- syncer::WriteNode node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(bookmark_id)); |
- |
- node.GetMutableEntryForTest()->PutLocalExternalId(bookmark->id()); |
- |
- MakeServerUpdate(&trans, &node); |
- node.GetMutableEntryForTest()->PutServerIsDel(true); |
- node.GetMutableEntryForTest()->PutIsDel(true); |
- } |
- |
- ASSERT_TRUE(AssociateModels()); |
- ExpectModelMatch(); |
- |
- // The bookmark node should be deleted. |
- EXPECT_EQ(0, folder->child_count()); |
-} |
- |
-// Tests that the external ID is used to match the right folder amoung |
-// multiple folders with the same name during the native model traversal. |
-// Also tests that the external ID is used to match the right bookmark |
-// among multiple identical bookmarks when dealing with the delete journal. |
-TEST_F(ProfileSyncServiceBookmarkTest, |
- InitialModelAssociateVerifyExternalIdMatch) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- const int kNumFolders = 10; |
- const int kNumBookmarks = 10; |
- const int kFolderToIncludeBookmarks = 7; |
- const int kBookmarkToDelete = 4; |
- |
- int64_t folder_ids[kNumFolders]; |
- int64_t bookmark_ids[kNumBookmarks]; |
- |
- // Create native folders and bookmarks with identical names. Only |
- // one of the folders contains bookmarks and others are empty. Here is the |
- // expected tree shape: |
- // Bookmarks bar |
- // +- folder (#0) |
- // +- folder (#1) |
- // ... |
- // +- folder (#7) <-- Only this folder contains bookmarks. |
- // +- bookmark (#0) |
- // +- bookmark (#1) |
- // ... |
- // +- bookmark (#4) <-- Only this one bookmark should be removed later. |
- // ... |
- // +- bookmark (#9) |
- // ... |
- // +- folder (#9) |
- |
- const BookmarkNode* parent_folder = nullptr; |
- for (int i = 0; i < kNumFolders; i++) { |
- const BookmarkNode* folder = model()->AddFolder( |
- model()->bookmark_bar_node(), i, base::ASCIIToUTF16("folder")); |
- folder_ids[i] = folder->id(); |
- if (i == kFolderToIncludeBookmarks) { |
- parent_folder = folder; |
- } |
- } |
- |
- for (int i = 0; i < kNumBookmarks; i++) { |
- const BookmarkNode* bookmark = |
- model()->AddURL(parent_folder, i, base::ASCIIToUTF16("bookmark"), |
- GURL("http://www.google.com/")); |
- bookmark_ids[i] = bookmark->id(); |
- } |
- |
- // Number of nodes in bookmark bar before association. |
- int total_node_count = model()->bookmark_bar_node()->GetTotalNodeCount(); |
- |
- CreatePermanentBookmarkNodes(); |
- |
- int64_t sync_bookmark_id_to_delete = 0; |
- { |
- // Create sync folders matching native folders above. |
- int64_t parent_id = 0; |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- // Create in reverse order because AddFolderToShare passes NULL for |
- // |predecessor| argument. |
- for (int i = kNumFolders - 1; i >= 0; i--) { |
- int64_t id = AddFolderToShare(&trans, "folder"); |
- |
- // Pre-map sync folders to native folders by setting |
- // external ID. This will verify that the association algorithm picks |
- // the right ones despite all of them having identical names. |
- // More specifically this will help to avoid cloning bookmarks from |
- // a wrong folder. |
- syncer::WriteNode node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- node.GetMutableEntryForTest()->PutLocalExternalId(folder_ids[i]); |
- |
- if (i == kFolderToIncludeBookmarks) { |
- parent_id = id; |
- } |
- } |
- |
- // Create sync bookmark matching native bookmarks above in reverse order |
- // because AddBookmarkToShare passes NULL for |predecessor| argument. |
- for (int i = kNumBookmarks - 1; i >= 0; i--) { |
- int id = AddBookmarkToShare(&trans, parent_id, "bookmark", |
- "http://www.google.com/"); |
- |
- // Pre-map sync bookmarks to native bookmarks by setting |
- // external ID. This will verify that the association algorithm picks |
- // the right ones despite all of them having identical names and URLs. |
- syncer::WriteNode node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(id)); |
- node.GetMutableEntryForTest()->PutLocalExternalId(bookmark_ids[i]); |
- |
- if (i == kBookmarkToDelete) { |
- sync_bookmark_id_to_delete = id; |
- } |
- } |
- } |
- |
- // Make one bookmark deleted. |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- syncer::WriteNode node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, |
- node.InitByIdLookup(sync_bookmark_id_to_delete)); |
- |
- MakeServerUpdate(&trans, &node); |
- node.GetMutableEntryForTest()->PutServerIsDel(true); |
- node.GetMutableEntryForTest()->PutIsDel(true); |
- } |
- |
- // Perform association. |
- ASSERT_TRUE(AssociateModels()); |
- ExpectModelMatch(); |
- |
- // Only one native node should have been deleted and no nodes cloned due to |
- // matching folder names. |
- EXPECT_EQ(kNumFolders, model()->bookmark_bar_node()->child_count()); |
- EXPECT_EQ(kNumBookmarks - 1, parent_folder->child_count()); |
- EXPECT_EQ(total_node_count - 1, |
- model()->bookmark_bar_node()->GetTotalNodeCount()); |
- |
- // Verify that the right bookmark got deleted and no bookmarks reordered. |
- for (int i = 0; i < parent_folder->child_count(); i++) { |
- int index_in_bookmark_ids = (i < kBookmarkToDelete) ? i : i + 1; |
- EXPECT_EQ(bookmark_ids[index_in_bookmark_ids], |
- parent_folder->GetChild(i)->id()); |
- } |
-} |
- |
-// Verifies that the bookmark association skips sync nodes with invalid URLs. |
-TEST_F(ProfileSyncServiceBookmarkTest, InitialModelAssociateWithInvalidUrl) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- // On the local side create a folder and two nodes. |
- const BookmarkNode* folder = model()->AddFolder( |
- model()->bookmark_bar_node(), 0, base::ASCIIToUTF16("folder")); |
- model()->AddURL(folder, 0, base::ASCIIToUTF16("node1"), |
- GURL("http://www.node1.com/")); |
- model()->AddURL(folder, 1, base::ASCIIToUTF16("node2"), |
- GURL("http://www.node2.com/")); |
- |
- // On the sync side create a matching folder, one matching node, one |
- // unmatching node, and one node with an invalid URL. |
- CreatePermanentBookmarkNodes(); |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- int64_t folder_id = AddFolderToShare(&trans, "folder"); |
- // Please note that each AddBookmarkToShare inserts the node at the front |
- // so the actual order of children in the directory will be opposite. |
- AddBookmarkToShare(&trans, folder_id, "node2", "http://www.node2.com/"); |
- AddBookmarkToShare(&trans, folder_id, "node3", ""); |
- AddBookmarkToShare(&trans, folder_id, "node4", "http://www.node4.com/"); |
- } |
- |
- // Perform association. |
- StartSync(); |
- |
- // Concatenate resulting titles of native nodes. |
- std::string native_titles; |
- for (int i = 0; i < folder->child_count(); i++) { |
- if (!native_titles.empty()) |
- native_titles += ","; |
- const BookmarkNode* child = folder->GetChild(i); |
- native_titles += base::UTF16ToUTF8(child->GetTitle()); |
- } |
- |
- // Expect the order of nodes to follow the sync order (see note above), the |
- // node with the invalid URL to be skipped, and the extra native node to be |
- // at the end. |
- EXPECT_EQ("node4,node2,node1", native_titles); |
-} |
- |
-TEST_F(ProfileSyncServiceBookmarkTest, BookmarkModelOperations) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // Test addition. |
- const BookmarkNode* folder = model()->AddFolder(model()->other_node(), 0, |
- base::ASCIIToUTF16("foobar")); |
- ExpectSyncerNodeMatching(folder); |
- ExpectModelMatch(); |
- const BookmarkNode* folder2 = |
- model()->AddFolder(folder, 0, base::ASCIIToUTF16("nested")); |
- ExpectSyncerNodeMatching(folder2); |
- ExpectModelMatch(); |
- const BookmarkNode* url1 = |
- model()->AddURL(folder, 0, base::ASCIIToUTF16("Internets #1 Pies Site"), |
- GURL("http://www.easypie.com/")); |
- ExpectSyncerNodeMatching(url1); |
- ExpectModelMatch(); |
- const BookmarkNode* url2 = |
- model()->AddURL(folder, 1, base::ASCIIToUTF16("Airplanes"), |
- GURL("http://www.easyjet.com/")); |
- ExpectSyncerNodeMatching(url2); |
- ExpectModelMatch(); |
- // Test addition. |
- const BookmarkNode* mobile_folder = |
- model()->AddFolder(model()->mobile_node(), 0, base::ASCIIToUTF16("pie")); |
- ExpectSyncerNodeMatching(mobile_folder); |
- ExpectModelMatch(); |
- |
- // Test modification. |
- model()->SetTitle(url2, base::ASCIIToUTF16("EasyJet")); |
- ExpectModelMatch(); |
- model()->Move(url1, folder2, 0); |
- ExpectModelMatch(); |
- model()->Move(folder2, model()->bookmark_bar_node(), 0); |
- ExpectModelMatch(); |
- model()->SetTitle(folder2, base::ASCIIToUTF16("Not Nested")); |
- ExpectModelMatch(); |
- model()->Move(folder, folder2, 0); |
- ExpectModelMatch(); |
- model()->SetTitle(folder, base::ASCIIToUTF16("who's nested now?")); |
- ExpectModelMatch(); |
- model()->Copy(url2, model()->bookmark_bar_node(), 0); |
- ExpectModelMatch(); |
- model()->SetTitle(mobile_folder, base::ASCIIToUTF16("strawberry")); |
- ExpectModelMatch(); |
- |
- // Test deletion. |
- // Delete a single item. |
- model()->Remove(url2); |
- ExpectModelMatch(); |
- // Delete an item with several children. |
- model()->Remove(folder2); |
- ExpectModelMatch(); |
- model()->Remove(model()->mobile_node()->GetChild(0)); |
- ExpectModelMatch(); |
-} |
- |
-TEST_F(ProfileSyncServiceBookmarkTest, ServerChangeProcessing) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- |
- FakeServerChange adds(&trans); |
- int64_t f1 = adds.AddFolder("Server Folder B", bookmark_bar_id(), 0); |
- int64_t f2 = adds.AddFolder("Server Folder A", bookmark_bar_id(), f1); |
- int64_t u1 = adds.AddURL("Some old site", "ftp://nifty.andrew.cmu.edu/", |
- bookmark_bar_id(), f2); |
- int64_t u2 = adds.AddURL("Nifty", "ftp://nifty.andrew.cmu.edu/", f1, 0); |
- // u3 is a duplicate URL |
- int64_t u3 = adds.AddURL("Nifty2", "ftp://nifty.andrew.cmu.edu/", f1, u2); |
- // u4 is a duplicate title, different URL. |
- adds.AddURL("Some old site", "http://slog.thestranger.com/", |
- bookmark_bar_id(), u1); |
- // u5 tests an empty-string title. |
- std::string javascript_url( |
- "javascript:(function(){var w=window.open(" |
- "'about:blank','gnotesWin','location=0,menubar=0," |
- "scrollbars=0,status=0,toolbar=0,width=300," |
- "height=300,resizable');});"); |
- adds.AddURL(std::string(), javascript_url, other_bookmarks_id(), 0); |
- int64_t u6 = adds.AddURL("Sync1", "http://www.syncable.edu/", |
- mobile_bookmarks_id(), 0); |
- |
- syncer::ChangeRecordList::const_iterator it; |
- // The bookmark model shouldn't yet have seen any of the nodes of |adds|. |
- for (it = adds.changes().begin(); it != adds.changes().end(); ++it) |
- ExpectBrowserNodeUnknown(it->id); |
- |
- adds.ApplyPendingChanges(change_processor()); |
- |
- // Make sure the bookmark model received all of the nodes in |adds|. |
- for (it = adds.changes().begin(); it != adds.changes().end(); ++it) |
- ExpectBrowserNodeMatching(&trans, it->id); |
- ExpectModelMatch(&trans); |
- |
- // Part two: test modifications. |
- FakeServerChange mods(&trans); |
- // Mess with u2, and move it into empty folder f2 |
- // TODO(ncarter): Determine if we allow ModifyURL ops or not. |
- /* std::string u2_old_url = mods.ModifyURL(u2, "http://www.google.com"); */ |
- std::string u2_old_title = mods.ModifyTitle(u2, "The Google"); |
- int64_t u2_old_parent = mods.ModifyPosition(u2, f2, 0); |
- |
- // Now move f1 after u2. |
- std::string f1_old_title = mods.ModifyTitle(f1, "Server Folder C"); |
- int64_t f1_old_parent = mods.ModifyPosition(f1, f2, u2); |
- |
- // Then add u3 after f1. |
- int64_t u3_old_parent = mods.ModifyPosition(u3, f2, f1); |
- |
- std::string u6_old_title = mods.ModifyTitle(u6, "Mobile Folder A"); |
- |
- // Test that the property changes have not yet taken effect. |
- ExpectBrowserNodeTitle(u2, u2_old_title); |
- /* ExpectBrowserNodeURL(u2, u2_old_url); */ |
- ExpectBrowserNodeParent(u2, u2_old_parent); |
- |
- ExpectBrowserNodeTitle(f1, f1_old_title); |
- ExpectBrowserNodeParent(f1, f1_old_parent); |
- |
- ExpectBrowserNodeParent(u3, u3_old_parent); |
- |
- ExpectBrowserNodeTitle(u6, u6_old_title); |
- |
- // Apply the changes. |
- mods.ApplyPendingChanges(change_processor()); |
- |
- // Check for successful application. |
- for (it = mods.changes().begin(); it != mods.changes().end(); ++it) |
- ExpectBrowserNodeMatching(&trans, it->id); |
- ExpectModelMatch(&trans); |
- |
- // Part 3: Test URL deletion. |
- FakeServerChange dels(&trans); |
- dels.Delete(u2); |
- dels.Delete(u3); |
- dels.Delete(u6); |
- |
- ExpectBrowserNodeKnown(u2); |
- ExpectBrowserNodeKnown(u3); |
- |
- dels.ApplyPendingChanges(change_processor()); |
- |
- ExpectBrowserNodeUnknown(u2); |
- ExpectBrowserNodeUnknown(u3); |
- ExpectBrowserNodeUnknown(u6); |
- ExpectModelMatch(&trans); |
-} |
- |
-// Tests a specific case in ApplyModelChanges where we move the |
-// children out from under a parent, and then delete the parent |
-// in the same changelist. The delete shows up first in the changelist, |
-// requiring the children to be moved to a temporary location. |
-TEST_F(ProfileSyncServiceBookmarkTest, ServerChangeRequiringFosterParent) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- |
- // Stress the immediate children of other_node because that's where |
- // ApplyModelChanges puts a temporary foster parent node. |
- std::string url("http://dev.chromium.org/"); |
- FakeServerChange adds(&trans); |
- int64_t f0 = other_bookmarks_id(); // + other_node |
- int64_t f1 = adds.AddFolder("f1", f0, 0); // + f1 |
- int64_t f2 = adds.AddFolder("f2", f1, 0); // + f2 |
- int64_t u3 = adds.AddURL("u3", url, f2, 0); // + u3 NOLINT |
- int64_t u4 = adds.AddURL("u4", url, f2, u3); // + u4 NOLINT |
- int64_t u5 = adds.AddURL("u5", url, f1, f2); // + u5 NOLINT |
- int64_t f6 = adds.AddFolder("f6", f1, u5); // + f6 |
- int64_t u7 = adds.AddURL("u7", url, f0, f1); // + u7 NOLINT |
- |
- syncer::ChangeRecordList::const_iterator it; |
- // The bookmark model shouldn't yet have seen any of the nodes of |adds|. |
- for (it = adds.changes().begin(); it != adds.changes().end(); ++it) |
- ExpectBrowserNodeUnknown(it->id); |
- |
- adds.ApplyPendingChanges(change_processor()); |
- |
- // Make sure the bookmark model received all of the nodes in |adds|. |
- for (it = adds.changes().begin(); it != adds.changes().end(); ++it) |
- ExpectBrowserNodeMatching(&trans, it->id); |
- ExpectModelMatch(&trans); |
- |
- // We have to do the moves before the deletions, but FakeServerChange will |
- // put the deletion at the front of the changelist. |
- FakeServerChange ops(&trans); |
- ops.ModifyPosition(f6, other_bookmarks_id(), 0); |
- ops.ModifyPosition(u3, other_bookmarks_id(), f1); // Prev == f1 is OK here. |
- ops.ModifyPosition(f2, other_bookmarks_id(), u7); |
- ops.ModifyPosition(u7, f2, 0); |
- ops.ModifyPosition(u4, other_bookmarks_id(), f2); |
- ops.ModifyPosition(u5, f6, 0); |
- ops.Delete(f1); |
- |
- ops.ApplyPendingChanges(change_processor()); |
- |
- ExpectModelMatch(&trans); |
-} |
- |
-// Simulate a server change record containing a valid but non-canonical URL. |
-TEST_F(ProfileSyncServiceBookmarkTest, ServerChangeWithNonCanonicalURL) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- |
- FakeServerChange adds(&trans); |
- std::string url("http://dev.chromium.org"); |
- EXPECT_NE(GURL(url).spec(), url); |
- adds.AddURL("u1", url, other_bookmarks_id(), 0); |
- |
- adds.ApplyPendingChanges(change_processor()); |
- |
- EXPECT_EQ(1, model()->other_node()->child_count()); |
- ExpectModelMatch(&trans); |
- } |
- |
- // Now reboot the sync service, forcing a merge step. |
- StopSync(); |
- LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // There should still be just the one bookmark. |
- EXPECT_EQ(1, model()->other_node()->child_count()); |
- ExpectModelMatch(); |
-} |
- |
-// Simulate a server change record containing an invalid URL (per GURL). |
-// TODO(ncarter): Disabled due to crashes. Fix bug 1677563. |
-TEST_F(ProfileSyncServiceBookmarkTest, DISABLED_ServerChangeWithInvalidURL) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- int child_count = 0; |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- |
- FakeServerChange adds(&trans); |
- std::string url("x"); |
- EXPECT_FALSE(GURL(url).is_valid()); |
- adds.AddURL("u1", url, other_bookmarks_id(), 0); |
- |
- adds.ApplyPendingChanges(change_processor()); |
- |
- // We're lenient about what should happen -- the model could wind up with |
- // the node or without it; but things should be consistent, and we |
- // shouldn't crash. |
- child_count = model()->other_node()->child_count(); |
- EXPECT_TRUE(child_count == 0 || child_count == 1); |
- ExpectModelMatch(&trans); |
- } |
- |
- // Now reboot the sync service, forcing a merge step. |
- StopSync(); |
- LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // Things ought not to have changed. |
- EXPECT_EQ(model()->other_node()->child_count(), child_count); |
- ExpectModelMatch(); |
-} |
- |
-// Test strings that might pose a problem if the titles ever became used as |
-// file names in the sync backend. |
-TEST_F(ProfileSyncServiceBookmarkTest, CornerCaseNames) { |
- // TODO(ncarter): Bug 1570238 explains the failure of this test. |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- const char* names[] = { |
- // The empty string. |
- "", |
- // Illegal Windows filenames. |
- "CON", "PRN", "AUX", "NUL", "COM1", "COM2", "COM3", "COM4", "COM5", |
- "COM6", "COM7", "COM8", "COM9", "LPT1", "LPT2", "LPT3", "LPT4", "LPT5", |
- "LPT6", "LPT7", "LPT8", "LPT9", |
- // Current/parent directory markers. |
- ".", "..", "...", |
- // Files created automatically by the Windows shell. |
- "Thumbs.db", ".DS_Store", |
- // Names including Win32-illegal characters, and path separators. |
- "foo/bar", "foo\\bar", "foo?bar", "foo:bar", "foo|bar", "foo\"bar", |
- "foo'bar", "foo<bar", "foo>bar", "foo%bar", "foo*bar", "foo]bar", |
- "foo[bar", |
- // A name with title > 255 characters |
- "012345678901234567890123456789012345678901234567890123456789012345678901" |
- "234567890123456789012345678901234567890123456789012345678901234567890123" |
- "456789012345678901234567890123456789012345678901234567890123456789012345" |
- "678901234567890123456789012345678901234567890123456789012345678901234567" |
- "890123456789"}; |
- // Create both folders and bookmarks using each name. |
- GURL url("http://www.doublemint.com"); |
- for (size_t i = 0; i < arraysize(names); ++i) { |
- model()->AddFolder(model()->other_node(), 0, base::ASCIIToUTF16(names[i])); |
- model()->AddURL(model()->other_node(), 0, base::ASCIIToUTF16(names[i]), |
- url); |
- } |
- |
- // Verify that the browser model matches the sync model. |
- EXPECT_EQ(static_cast<size_t>(model()->other_node()->child_count()), |
- 2 * arraysize(names)); |
- ExpectModelMatch(); |
- |
- // Restart and re-associate. Verify things still match. |
- StopSync(); |
- LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- EXPECT_EQ(static_cast<size_t>(model()->other_node()->child_count()), |
- 2 * arraysize(names)); |
- ExpectModelMatch(); |
-} |
- |
-// Stress the internal representation of position by sparse numbers. We want |
-// to repeatedly bisect the range of available positions, to force the |
-// syncer code to renumber its ranges. Pick a number big enough so that it |
-// would exhaust 32bits of room between items a couple of times. |
-TEST_F(ProfileSyncServiceBookmarkTest, RepeatedMiddleInsertion) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- static const int kTimesToInsert = 256; |
- |
- // Create two book-end nodes to insert between. |
- model()->AddFolder(model()->other_node(), 0, base::ASCIIToUTF16("Alpha")); |
- model()->AddFolder(model()->other_node(), 1, base::ASCIIToUTF16("Omega")); |
- int count = 2; |
- |
- // Test insertion in first half of range by repeatedly inserting in second |
- // position. |
- for (int i = 0; i < kTimesToInsert; ++i) { |
- base::string16 title = |
- base::ASCIIToUTF16("Pre-insertion ") + base::IntToString16(i); |
- model()->AddFolder(model()->other_node(), 1, title); |
- count++; |
- } |
- |
- // Test insertion in second half of range by repeatedly inserting in |
- // second-to-last position. |
- for (int i = 0; i < kTimesToInsert; ++i) { |
- base::string16 title = |
- base::ASCIIToUTF16("Post-insertion ") + base::IntToString16(i); |
- model()->AddFolder(model()->other_node(), count - 1, title); |
- count++; |
- } |
- |
- // Verify that the browser model matches the sync model. |
- EXPECT_EQ(model()->other_node()->child_count(), count); |
- ExpectModelMatch(); |
-} |
- |
-// Introduce a consistency violation into the model, and see that it |
-// puts itself into a lame, error state. |
-TEST_F(ProfileSyncServiceBookmarkTest, UnrecoverableErrorSuspendsService) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // Add a node which will be the target of the consistency violation. |
- const BookmarkNode* node = |
- model()->AddFolder(model()->other_node(), 0, base::ASCIIToUTF16("node")); |
- ExpectSyncerNodeMatching(node); |
- |
- // Now destroy the syncer node as if we were the ProfileSyncService without |
- // updating the ProfileSyncService state. This should introduce |
- // inconsistency between the two models. |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- syncer::WriteNode sync_node(&trans); |
- ASSERT_TRUE(InitSyncNodeFromChromeNode(node, &sync_node)); |
- sync_node.Tombstone(); |
- } |
- // The models don't match at this point, but the ProfileSyncService |
- // doesn't know it yet. |
- ExpectSyncerNodeKnown(node); |
- |
- mock_error_handler()->ExpectError(syncer::SyncError::DATATYPE_ERROR); |
- |
- // Add a child to the inconsistent node. This should cause detection of the |
- // problem and the syncer should stop processing changes. |
- model()->AddFolder(node, 0, base::ASCIIToUTF16("nested")); |
-} |
- |
-// See what happens if we run model association when there are two exact URL |
-// duplicate bookmarks. The BookmarkModelAssociator should not fall over when |
-// this happens. |
-TEST_F(ProfileSyncServiceBookmarkTest, MergeDuplicates) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- model()->AddURL(model()->other_node(), 0, base::ASCIIToUTF16("Dup"), |
- GURL("http://dup.com/")); |
- model()->AddURL(model()->other_node(), 0, base::ASCIIToUTF16("Dup"), |
- GURL("http://dup.com/")); |
- |
- EXPECT_EQ(2, model()->other_node()->child_count()); |
- |
- // Restart the sync service to trigger model association. |
- StopSync(); |
- StartSync(); |
- |
- EXPECT_EQ(2, model()->other_node()->child_count()); |
- ExpectModelMatch(); |
-} |
- |
-TEST_F(ProfileSyncServiceBookmarkTest, ApplySyncDeletesFromJournal) { |
- // Initialize sync model and bookmark model as: |
- // URL 0 |
- // Folder 1 |
- // |-- URL 1 |
- // +-- Folder 2 |
- // +-- URL 2 |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- int64_t u0 = 0; |
- int64_t f1 = 0; |
- int64_t u1 = 0; |
- int64_t f2 = 0; |
- int64_t u2 = 0; |
- StartSync(); |
- int fixed_sync_bk_count = GetSyncBookmarkCount(); |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- FakeServerChange adds(&trans); |
- u0 = adds.AddURL("URL 0", "http://plus.google.com/", bookmark_bar_id(), 0); |
- f1 = adds.AddFolder("Folder 1", bookmark_bar_id(), u0); |
- u1 = adds.AddURL("URL 1", "http://www.google.com/", f1, 0); |
- f2 = adds.AddFolder("Folder 2", f1, u1); |
- u2 = adds.AddURL("URL 2", "http://mail.google.com/", f2, 0); |
- adds.ApplyPendingChanges(change_processor()); |
- } |
- StopSync(); |
- |
- // Reload bookmark model and disable model saving to make sync changes not |
- // persisted. |
- LoadBookmarkModel(LOAD_FROM_STORAGE, DONT_SAVE_TO_STORAGE); |
- EXPECT_EQ(6, model()->bookmark_bar_node()->GetTotalNodeCount()); |
- EXPECT_EQ(fixed_sync_bk_count + 5, GetSyncBookmarkCount()); |
- StartSync(); |
- { |
- // Remove all folders/bookmarks except u3 added above. |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- MakeServerUpdate(&trans, f1); |
- MakeServerUpdate(&trans, u1); |
- MakeServerUpdate(&trans, f2); |
- MakeServerUpdate(&trans, u2); |
- FakeServerChange dels(&trans); |
- dels.Delete(u2); |
- dels.Delete(f2); |
- dels.Delete(u1); |
- dels.Delete(f1); |
- dels.ApplyPendingChanges(change_processor()); |
- } |
- StopSync(); |
- // Bookmark bar itself and u0 remain. |
- EXPECT_EQ(2, model()->bookmark_bar_node()->GetTotalNodeCount()); |
- |
- // Reload bookmarks including ones deleted in sync model from storage. |
- LoadBookmarkModel(LOAD_FROM_STORAGE, DONT_SAVE_TO_STORAGE); |
- EXPECT_EQ(6, model()->bookmark_bar_node()->GetTotalNodeCount()); |
- // Add a bookmark under f1 when sync is off so that f1 will not be |
- // deleted even when f1 matches delete journal because it's not empty. |
- model()->AddURL(model()->bookmark_bar_node()->GetChild(1), 0, |
- base::UTF8ToUTF16("local"), GURL("http://www.youtube.com")); |
- // Sync model has fixed bookmarks nodes and u3. |
- EXPECT_EQ(fixed_sync_bk_count + 1, GetSyncBookmarkCount()); |
- StartSync(); |
- // Expect 4 bookmarks after model association because u2, f2, u1 are removed |
- // by delete journal, f1 is not removed by delete journal because it's |
- // not empty due to www.youtube.com added above. |
- EXPECT_EQ(4, model()->bookmark_bar_node()->GetTotalNodeCount()); |
- EXPECT_EQ(base::UTF8ToUTF16("URL 0"), |
- model()->bookmark_bar_node()->GetChild(0)->GetTitle()); |
- EXPECT_EQ(base::UTF8ToUTF16("Folder 1"), |
- model()->bookmark_bar_node()->GetChild(1)->GetTitle()); |
- EXPECT_EQ(base::UTF8ToUTF16("local"), |
- model()->bookmark_bar_node()->GetChild(1)->GetChild(0)->GetTitle()); |
- StopSync(); |
- |
- // Verify purging of delete journals. |
- // Delete journals for u2, f2, u1 remains because they are used in last |
- // association. |
- EXPECT_EQ(3u, test_user_share()->GetDeleteJournalSize()); |
- StartSync(); |
- StopSync(); |
- // Reload again and all delete journals should be gone because none is used |
- // in last association. |
- ASSERT_TRUE(test_user_share()->Reload()); |
- EXPECT_EQ(0u, test_user_share()->GetDeleteJournalSize()); |
-} |
- |
-struct TestData { |
- const char* title; |
- const char* url; |
-}; |
- |
-// Map from bookmark node ID to its version. |
-typedef std::map<int64_t, int64_t> BookmarkNodeVersionMap; |
- |
-// TODO(ncarter): Integrate the existing TestNode/PopulateNodeFromString code |
-// in the bookmark model unittest, to make it simpler to set up test data |
-// here (and reduce the amount of duplication among tests), and to reduce the |
-// duplication. |
-class ProfileSyncServiceBookmarkTestWithData |
- : public ProfileSyncServiceBookmarkTest { |
- public: |
- ProfileSyncServiceBookmarkTestWithData(); |
- |
- protected: |
- // Populates or compares children of the given bookmark node from/with the |
- // given test data array with the given size. |running_count| is updated as |
- // urls are added. It is used to set the creation date (or test the creation |
- // date for CompareWithTestData()). |
- void PopulateFromTestData(const BookmarkNode* node, |
- const TestData* data, |
- int size, |
- int* running_count); |
- void CompareWithTestData(const BookmarkNode* node, |
- const TestData* data, |
- int size, |
- int* running_count); |
- |
- void ExpectBookmarkModelMatchesTestData(); |
- void WriteTestDataToBookmarkModel(); |
- |
- // Output transaction versions of |node| and nodes under it to |
- // |node_versions|. |
- void GetTransactionVersions(const BookmarkNode* root, |
- BookmarkNodeVersionMap* node_versions); |
- |
- // Verify transaction versions of bookmark nodes and sync nodes are equal |
- // recursively. If node is in |version_expected|, versions should match |
- // there, too. |
- void ExpectTransactionVersionMatch( |
- const BookmarkNode* node, |
- const BookmarkNodeVersionMap& version_expected); |
- |
- private: |
- const base::Time start_time_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ProfileSyncServiceBookmarkTestWithData); |
-}; |
- |
-namespace { |
- |
-// Constants for bookmark model that looks like: |
-// |-- Bookmark bar |
-// | |-- u2, http://www.u2.com/ |
-// | |-- f1 |
-// | | |-- f1u4, http://www.f1u4.com/ |
-// | | |-- f1u2, http://www.f1u2.com/ |
-// | | |-- f1u3, http://www.f1u3.com/ |
-// | | +-- f1u1, http://www.f1u1.com/ |
-// | |-- u1, http://www.u1.com/ |
-// | +-- f2 |
-// | |-- f2u2, http://www.f2u2.com/ |
-// | |-- f2u4, http://www.f2u4.com/ |
-// | |-- f2u3, http://www.f2u3.com/ |
-// | +-- f2u1, http://www.f2u1.com/ |
-// +-- Other bookmarks |
-// | |-- f3 |
-// | | |-- f3u4, http://www.f3u4.com/ |
-// | | |-- f3u2, http://www.f3u2.com/ |
-// | | |-- f3u3, http://www.f3u3.com/ |
-// | | +-- f3u1, http://www.f3u1.com/ |
-// | |-- u4, http://www.u4.com/ |
-// | |-- u3, http://www.u3.com/ |
-// | --- f4 |
-// | | |-- f4u1, http://www.f4u1.com/ |
-// | | |-- f4u2, http://www.f4u2.com/ |
-// | | |-- f4u3, http://www.f4u3.com/ |
-// | | +-- f4u4, http://www.f4u4.com/ |
-// | |-- dup |
-// | | +-- dupu1, http://www.dupu1.com/ |
-// | +-- dup |
-// | | +-- dupu2, http://www.dupu1.com/ |
-// | +-- ls , http://www.ls.com/ |
-// | |
-// +-- Mobile bookmarks |
-// |-- f5 |
-// | |-- f5u1, http://www.f5u1.com/ |
-// |-- f6 |
-// | |-- f6u1, http://www.f6u1.com/ |
-// | |-- f6u2, http://www.f6u2.com/ |
-// +-- u5, http://www.u5.com/ |
- |
-static TestData kBookmarkBarChildren[] = { |
- {"u2", "http://www.u2.com/"}, |
- {"f1", NULL}, |
- {"u1", "http://www.u1.com/"}, |
- {"f2", NULL}, |
-}; |
-static TestData kF1Children[] = { |
- {"f1u4", "http://www.f1u4.com/"}, |
- {"f1u2", "http://www.f1u2.com/"}, |
- {"f1u3", "http://www.f1u3.com/"}, |
- {"f1u1", "http://www.f1u1.com/"}, |
-}; |
-static TestData kF2Children[] = { |
- {"f2u2", "http://www.f2u2.com/"}, |
- {"f2u4", "http://www.f2u4.com/"}, |
- {"f2u3", "http://www.f2u3.com/"}, |
- {"f2u1", "http://www.f2u1.com/"}, |
-}; |
- |
-static TestData kOtherBookmarkChildren[] = {{"f3", NULL}, |
- {"u4", "http://www.u4.com/"}, |
- {"u3", "http://www.u3.com/"}, |
- {"f4", NULL}, |
- {"dup", NULL}, |
- {"dup", NULL}, |
- {" ls ", "http://www.ls.com/"}}; |
-static TestData kF3Children[] = { |
- {"f3u4", "http://www.f3u4.com/"}, |
- {"f3u2", "http://www.f3u2.com/"}, |
- {"f3u3", "http://www.f3u3.com/"}, |
- {"f3u1", "http://www.f3u1.com/"}, |
-}; |
-static TestData kF4Children[] = { |
- {"f4u1", "http://www.f4u1.com/"}, |
- {"f4u2", "http://www.f4u2.com/"}, |
- {"f4u3", "http://www.f4u3.com/"}, |
- {"f4u4", "http://www.f4u4.com/"}, |
-}; |
-static TestData kDup1Children[] = { |
- {"dupu1", "http://www.dupu1.com/"}, |
-}; |
-static TestData kDup2Children[] = { |
- {"dupu2", "http://www.dupu2.com/"}, |
-}; |
- |
-static TestData kMobileBookmarkChildren[] = { |
- {"f5", NULL}, |
- {"f6", NULL}, |
- {"u5", "http://www.u5.com/"}, |
-}; |
-static TestData kF5Children[] = { |
- {"f5u1", "http://www.f5u1.com/"}, |
- {"f5u2", "http://www.f5u2.com/"}, |
-}; |
-static TestData kF6Children[] = { |
- {"f6u1", "http://www.f6u1.com/"}, |
- {"f6u2", "http://www.f6u2.com/"}, |
-}; |
- |
-} // anonymous namespace. |
- |
-ProfileSyncServiceBookmarkTestWithData::ProfileSyncServiceBookmarkTestWithData() |
- : start_time_(base::Time::Now()) {} |
- |
-void ProfileSyncServiceBookmarkTestWithData::PopulateFromTestData( |
- const BookmarkNode* node, |
- const TestData* data, |
- int size, |
- int* running_count) { |
- DCHECK(node); |
- DCHECK(data); |
- DCHECK(node->is_folder()); |
- for (int i = 0; i < size; ++i) { |
- const TestData& item = data[i]; |
- if (item.url) { |
- const base::Time add_time = |
- start_time_ + base::TimeDelta::FromMinutes(*running_count); |
- model()->AddURLWithCreationTimeAndMetaInfo( |
- node, i, base::UTF8ToUTF16(item.title), GURL(item.url), add_time, |
- NULL); |
- } else { |
- model()->AddFolder(node, i, base::UTF8ToUTF16(item.title)); |
- } |
- (*running_count)++; |
- } |
-} |
- |
-void ProfileSyncServiceBookmarkTestWithData::CompareWithTestData( |
- const BookmarkNode* node, |
- const TestData* data, |
- int size, |
- int* running_count) { |
- DCHECK(node); |
- DCHECK(data); |
- DCHECK(node->is_folder()); |
- ASSERT_EQ(size, node->child_count()); |
- for (int i = 0; i < size; ++i) { |
- const BookmarkNode* child_node = node->GetChild(i); |
- const TestData& item = data[i]; |
- GURL url = GURL(item.url == NULL ? "" : item.url); |
- BookmarkNode test_node(url); |
- test_node.SetTitle(base::UTF8ToUTF16(item.title)); |
- EXPECT_EQ(child_node->GetTitle(), test_node.GetTitle()); |
- if (item.url) { |
- EXPECT_FALSE(child_node->is_folder()); |
- EXPECT_TRUE(child_node->is_url()); |
- EXPECT_EQ(child_node->url(), test_node.url()); |
- const base::Time expected_time = |
- start_time_ + base::TimeDelta::FromMinutes(*running_count); |
- EXPECT_EQ(expected_time.ToInternalValue(), |
- child_node->date_added().ToInternalValue()); |
- } else { |
- EXPECT_TRUE(child_node->is_folder()); |
- EXPECT_FALSE(child_node->is_url()); |
- } |
- (*running_count)++; |
- } |
-} |
- |
-// TODO(munjal): We should implement some way of generating random data and can |
-// use the same seed to generate the same sequence. |
-void ProfileSyncServiceBookmarkTestWithData::WriteTestDataToBookmarkModel() { |
- const BookmarkNode* bookmarks_bar_node = model()->bookmark_bar_node(); |
- int count = 0; |
- PopulateFromTestData(bookmarks_bar_node, kBookmarkBarChildren, |
- arraysize(kBookmarkBarChildren), &count); |
- |
- ASSERT_GE(bookmarks_bar_node->child_count(), 4); |
- const BookmarkNode* f1_node = bookmarks_bar_node->GetChild(1); |
- PopulateFromTestData(f1_node, kF1Children, arraysize(kF1Children), &count); |
- const BookmarkNode* f2_node = bookmarks_bar_node->GetChild(3); |
- PopulateFromTestData(f2_node, kF2Children, arraysize(kF2Children), &count); |
- |
- const BookmarkNode* other_bookmarks_node = model()->other_node(); |
- PopulateFromTestData(other_bookmarks_node, kOtherBookmarkChildren, |
- arraysize(kOtherBookmarkChildren), &count); |
- |
- ASSERT_GE(other_bookmarks_node->child_count(), 6); |
- const BookmarkNode* f3_node = other_bookmarks_node->GetChild(0); |
- PopulateFromTestData(f3_node, kF3Children, arraysize(kF3Children), &count); |
- const BookmarkNode* f4_node = other_bookmarks_node->GetChild(3); |
- PopulateFromTestData(f4_node, kF4Children, arraysize(kF4Children), &count); |
- const BookmarkNode* dup_node = other_bookmarks_node->GetChild(4); |
- PopulateFromTestData(dup_node, kDup1Children, arraysize(kDup1Children), |
- &count); |
- dup_node = other_bookmarks_node->GetChild(5); |
- PopulateFromTestData(dup_node, kDup2Children, arraysize(kDup2Children), |
- &count); |
- |
- const BookmarkNode* mobile_bookmarks_node = model()->mobile_node(); |
- PopulateFromTestData(mobile_bookmarks_node, kMobileBookmarkChildren, |
- arraysize(kMobileBookmarkChildren), &count); |
- |
- ASSERT_GE(mobile_bookmarks_node->child_count(), 3); |
- const BookmarkNode* f5_node = mobile_bookmarks_node->GetChild(0); |
- PopulateFromTestData(f5_node, kF5Children, arraysize(kF5Children), &count); |
- const BookmarkNode* f6_node = mobile_bookmarks_node->GetChild(1); |
- PopulateFromTestData(f6_node, kF6Children, arraysize(kF6Children), &count); |
- |
- ExpectBookmarkModelMatchesTestData(); |
-} |
- |
-void ProfileSyncServiceBookmarkTestWithData:: |
- ExpectBookmarkModelMatchesTestData() { |
- const BookmarkNode* bookmark_bar_node = model()->bookmark_bar_node(); |
- int count = 0; |
- CompareWithTestData(bookmark_bar_node, kBookmarkBarChildren, |
- arraysize(kBookmarkBarChildren), &count); |
- |
- ASSERT_GE(bookmark_bar_node->child_count(), 4); |
- const BookmarkNode* f1_node = bookmark_bar_node->GetChild(1); |
- CompareWithTestData(f1_node, kF1Children, arraysize(kF1Children), &count); |
- const BookmarkNode* f2_node = bookmark_bar_node->GetChild(3); |
- CompareWithTestData(f2_node, kF2Children, arraysize(kF2Children), &count); |
- |
- const BookmarkNode* other_bookmarks_node = model()->other_node(); |
- CompareWithTestData(other_bookmarks_node, kOtherBookmarkChildren, |
- arraysize(kOtherBookmarkChildren), &count); |
- |
- ASSERT_GE(other_bookmarks_node->child_count(), 6); |
- const BookmarkNode* f3_node = other_bookmarks_node->GetChild(0); |
- CompareWithTestData(f3_node, kF3Children, arraysize(kF3Children), &count); |
- const BookmarkNode* f4_node = other_bookmarks_node->GetChild(3); |
- CompareWithTestData(f4_node, kF4Children, arraysize(kF4Children), &count); |
- const BookmarkNode* dup_node = other_bookmarks_node->GetChild(4); |
- CompareWithTestData(dup_node, kDup1Children, arraysize(kDup1Children), |
- &count); |
- dup_node = other_bookmarks_node->GetChild(5); |
- CompareWithTestData(dup_node, kDup2Children, arraysize(kDup2Children), |
- &count); |
- |
- const BookmarkNode* mobile_bookmarks_node = model()->mobile_node(); |
- CompareWithTestData(mobile_bookmarks_node, kMobileBookmarkChildren, |
- arraysize(kMobileBookmarkChildren), &count); |
- |
- ASSERT_GE(mobile_bookmarks_node->child_count(), 3); |
- const BookmarkNode* f5_node = mobile_bookmarks_node->GetChild(0); |
- CompareWithTestData(f5_node, kF5Children, arraysize(kF5Children), &count); |
- const BookmarkNode* f6_node = mobile_bookmarks_node->GetChild(1); |
- CompareWithTestData(f6_node, kF6Children, arraysize(kF6Children), &count); |
-} |
- |
-// Tests persistence of the profile sync service by unloading the |
-// database and then reloading it from disk. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, Persistence) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- WriteTestDataToBookmarkModel(); |
- |
- ExpectModelMatch(); |
- |
- // Force both models to discard their data and reload from disk. This |
- // simulates what would happen if the browser were to shutdown normally, |
- // and then relaunch. |
- StopSync(); |
- LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- ExpectBookmarkModelMatchesTestData(); |
- |
- // With the BookmarkModel contents verified, ExpectModelMatch will |
- // verify the contents of the sync model. |
- ExpectModelMatch(); |
-} |
- |
-// Tests the merge case when the BookmarkModel is non-empty but the |
-// sync model is empty. This corresponds to uploading browser |
-// bookmarks to an initially empty, new account. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, MergeWithEmptySyncModel) { |
- // Don't start the sync service until we've populated the bookmark model. |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- |
- WriteTestDataToBookmarkModel(); |
- |
- // Restart sync. This should trigger a merge step during |
- // initialization -- we expect the browser bookmarks to be written |
- // to the sync service during this call. |
- StartSync(); |
- |
- // Verify that the bookmark model hasn't changed, and that the sync model |
- // matches it exactly. |
- ExpectBookmarkModelMatchesTestData(); |
- ExpectModelMatch(); |
-} |
- |
-// Tests the merge case when the BookmarkModel is empty but the sync model is |
-// non-empty. This corresponds (somewhat) to a clean install of the browser, |
-// with no bookmarks, connecting to a sync account that has some bookmarks. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, MergeWithEmptyBookmarkModel) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- WriteTestDataToBookmarkModel(); |
- |
- ExpectModelMatch(); |
- |
- // Force the databse to unload and write itself to disk. |
- StopSync(); |
- |
- // Blow away the bookmark model -- it should be empty afterwards. |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- EXPECT_EQ(model()->bookmark_bar_node()->child_count(), 0); |
- EXPECT_EQ(model()->other_node()->child_count(), 0); |
- EXPECT_EQ(model()->mobile_node()->child_count(), 0); |
- |
- // Now restart the sync service. Starting it should populate the bookmark |
- // model -- test for consistency. |
- StartSync(); |
- ExpectBookmarkModelMatchesTestData(); |
- ExpectModelMatch(); |
-} |
- |
-// Tests the merge cases when both the models are expected to be identical |
-// after the merge. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, MergeExpectedIdenticalModels) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- WriteTestDataToBookmarkModel(); |
- ExpectModelMatch(); |
- StopSync(); |
- |
- // At this point both the bookmark model and the server should have the |
- // exact same data and it should match the test data. |
- LoadBookmarkModel(LOAD_FROM_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- ExpectBookmarkModelMatchesTestData(); |
- ExpectModelMatch(); |
- StopSync(); |
- |
- // Now reorder some bookmarks in the bookmark model and then merge. Make |
- // sure we get the order of the server after merge. |
- LoadBookmarkModel(LOAD_FROM_STORAGE, DONT_SAVE_TO_STORAGE); |
- ExpectBookmarkModelMatchesTestData(); |
- const BookmarkNode* bookmark_bar = model()->bookmark_bar_node(); |
- ASSERT_TRUE(bookmark_bar); |
- ASSERT_GT(bookmark_bar->child_count(), 1); |
- model()->Move(bookmark_bar->GetChild(0), bookmark_bar, 1); |
- StartSync(); |
- ExpectModelMatch(); |
- ExpectBookmarkModelMatchesTestData(); |
-} |
- |
-// Tests the merge cases when both the models are expected to be identical |
-// after the merge. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, MergeModelsWithSomeExtras) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- ExpectBookmarkModelMatchesTestData(); |
- |
- // Remove some nodes and reorder some nodes. |
- const BookmarkNode* bookmark_bar_node = model()->bookmark_bar_node(); |
- int remove_index = 2; |
- ASSERT_GT(bookmark_bar_node->child_count(), remove_index); |
- const BookmarkNode* child_node = bookmark_bar_node->GetChild(remove_index); |
- ASSERT_TRUE(child_node); |
- ASSERT_TRUE(child_node->is_url()); |
- model()->Remove(bookmark_bar_node->GetChild(remove_index)); |
- ASSERT_GT(bookmark_bar_node->child_count(), remove_index); |
- child_node = bookmark_bar_node->GetChild(remove_index); |
- ASSERT_TRUE(child_node); |
- ASSERT_TRUE(child_node->is_folder()); |
- model()->Remove(bookmark_bar_node->GetChild(remove_index)); |
- |
- const BookmarkNode* other_node = model()->other_node(); |
- ASSERT_GE(other_node->child_count(), 1); |
- const BookmarkNode* f3_node = other_node->GetChild(0); |
- ASSERT_TRUE(f3_node); |
- ASSERT_TRUE(f3_node->is_folder()); |
- remove_index = 2; |
- ASSERT_GT(f3_node->child_count(), remove_index); |
- model()->Remove(f3_node->GetChild(remove_index)); |
- ASSERT_GT(f3_node->child_count(), remove_index); |
- model()->Remove(f3_node->GetChild(remove_index)); |
- |
- StartSync(); |
- ExpectModelMatch(); |
- StopSync(); |
- |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- ExpectBookmarkModelMatchesTestData(); |
- |
- // Remove some nodes and reorder some nodes. |
- bookmark_bar_node = model()->bookmark_bar_node(); |
- remove_index = 0; |
- ASSERT_GT(bookmark_bar_node->child_count(), remove_index); |
- child_node = bookmark_bar_node->GetChild(remove_index); |
- ASSERT_TRUE(child_node); |
- ASSERT_TRUE(child_node->is_url()); |
- model()->Remove(bookmark_bar_node->GetChild(remove_index)); |
- ASSERT_GT(bookmark_bar_node->child_count(), remove_index); |
- child_node = bookmark_bar_node->GetChild(remove_index); |
- ASSERT_TRUE(child_node); |
- ASSERT_TRUE(child_node->is_folder()); |
- model()->Remove(bookmark_bar_node->GetChild(remove_index)); |
- |
- ASSERT_GE(bookmark_bar_node->child_count(), 2); |
- model()->Move(bookmark_bar_node->GetChild(0), bookmark_bar_node, 1); |
- |
- other_node = model()->other_node(); |
- ASSERT_GE(other_node->child_count(), 1); |
- f3_node = other_node->GetChild(0); |
- ASSERT_TRUE(f3_node); |
- ASSERT_TRUE(f3_node->is_folder()); |
- remove_index = 0; |
- ASSERT_GT(f3_node->child_count(), remove_index); |
- model()->Remove(f3_node->GetChild(remove_index)); |
- ASSERT_GT(f3_node->child_count(), remove_index); |
- model()->Remove(f3_node->GetChild(remove_index)); |
- |
- ASSERT_GE(other_node->child_count(), 4); |
- model()->Move(other_node->GetChild(0), other_node, 1); |
- model()->Move(other_node->GetChild(2), other_node, 3); |
- |
- StartSync(); |
- ExpectModelMatch(); |
- |
- // After the merge, the model should match the test data. |
- ExpectBookmarkModelMatchesTestData(); |
-} |
- |
-// Tests that when persisted model associations are used, things work fine. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, ModelAssociationPersistence) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- StartSync(); |
- ExpectModelMatch(); |
- // Force sync to shut down and write itself to disk. |
- StopSync(); |
- // Now restart sync. This time it should use the persistent |
- // associations. |
- StartSync(); |
- ExpectModelMatch(); |
-} |
- |
-// Tests that when persisted model associations are used, things work fine. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, |
- ModelAssociationInvalidPersistence) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- StartSync(); |
- ExpectModelMatch(); |
- // Force sync to shut down and write itself to disk. |
- StopSync(); |
- // Change the bookmark model before restarting sync service to simulate |
- // the situation where bookmark model is different from sync model and |
- // make sure model associator correctly rebuilds associations. |
- const BookmarkNode* bookmark_bar_node = model()->bookmark_bar_node(); |
- model()->AddURL(bookmark_bar_node, 0, base::ASCIIToUTF16("xtra"), |
- GURL("http://www.xtra.com")); |
- // Now restart sync. This time it will try to use the persistent |
- // associations and realize that they are invalid and hence will rebuild |
- // associations. |
- StartSync(); |
- ExpectModelMatch(); |
-} |
- |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, SortChildren) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // Write test data to bookmark model and verify that the models match. |
- WriteTestDataToBookmarkModel(); |
- const BookmarkNode* folder_added = model()->other_node()->GetChild(0); |
- ASSERT_TRUE(folder_added); |
- ASSERT_TRUE(folder_added->is_folder()); |
- |
- ExpectModelMatch(); |
- |
- // Sort the other-bookmarks children and expect that the models match. |
- model()->SortChildren(folder_added); |
- ExpectModelMatch(); |
-} |
- |
-// See what happens if we enable sync but then delete the "Sync Data" |
-// folder. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, |
- RecoverAfterDeletingSyncDataDirectory) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE); |
- StartSync(); |
- |
- WriteTestDataToBookmarkModel(); |
- |
- StopSync(); |
- |
- // Nuke the sync DB and reload. |
- TearDown(); |
- SetUp(); |
- |
- // First attempt fails due to a persistence error. |
- EXPECT_TRUE(CreatePermanentBookmarkNodes()); |
- EXPECT_FALSE(AssociateModels()); |
- |
- // Second attempt succeeds due to the previous error resetting the native |
- // transaction version. |
- delete_model_associator(); |
- EXPECT_TRUE(CreatePermanentBookmarkNodes()); |
- EXPECT_TRUE(AssociateModels()); |
- |
- // Make sure we're back in sync. In real life, the user would need |
- // to reauthenticate before this happens, but in the test, authentication |
- // is sidestepped. |
- ExpectBookmarkModelMatchesTestData(); |
- ExpectModelMatch(); |
-} |
- |
-// Verify that the bookmark model is updated about whether the |
-// associator is currently running. |
-TEST_F(ProfileSyncServiceBookmarkTest, AssociationState) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- |
- ExtensiveChangesBookmarkModelObserver observer; |
- model()->AddObserver(&observer); |
- |
- StartSync(); |
- |
- EXPECT_EQ(1, observer.get_started()); |
- EXPECT_EQ(0, observer.get_completed_count_at_started()); |
- EXPECT_EQ(1, observer.get_completed()); |
- |
- model()->RemoveObserver(&observer); |
-} |
- |
-// Verify that the creation_time_us changes are applied in the local model at |
-// association time and update time. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, UpdateDateAdded) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- |
- // Start and stop sync in order to create bookmark nodes in the sync db. |
- StartSync(); |
- StopSync(); |
- |
- // Modify the date_added field of a bookmark so it doesn't match with |
- // the sync data. |
- const BookmarkNode* bookmark_bar_node = model()->bookmark_bar_node(); |
- int modified_index = 2; |
- ASSERT_GT(bookmark_bar_node->child_count(), modified_index); |
- const BookmarkNode* child_node = bookmark_bar_node->GetChild(modified_index); |
- ASSERT_TRUE(child_node); |
- EXPECT_TRUE(child_node->is_url()); |
- model()->SetDateAdded(child_node, base::Time::FromInternalValue(10)); |
- |
- StartSync(); |
- StopSync(); |
- |
- // Verify that transaction versions are in sync between the native model |
- // and Sync. |
- { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- int64_t sync_version = trans.GetModelVersion(syncer::BOOKMARKS); |
- int64_t native_version = model()->root_node()->sync_transaction_version(); |
- EXPECT_EQ(native_version, sync_version); |
- } |
- |
- // Since the version is in sync the association above should have skipped |
- // updating the native node above. That is expected optimization (see |
- // crbug/464907. |
- EXPECT_EQ(child_node->date_added(), base::Time::FromInternalValue(10)); |
- |
- // Reset transaction version on the native model to trigger updating data |
- // for all bookmark nodes. |
- model()->SetNodeSyncTransactionVersion( |
- model()->root_node(), syncer::syncable::kInvalidTransactionVersion); |
- |
- StartSync(); |
- |
- // Everything should be back in sync after model association. |
- ExpectBookmarkModelMatchesTestData(); |
- ExpectModelMatch(); |
- |
- // Now trigger a change while syncing. We add a new bookmark, sync it, then |
- // updates it's creation time. |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- FakeServerChange adds(&trans); |
- const std::string kTitle = "Some site"; |
- const std::string kUrl = "http://www.whatwhat.yeah/"; |
- const int kCreationTime = 30; |
- int64_t id = adds.AddURL(kTitle, kUrl, bookmark_bar_id(), 0); |
- adds.ApplyPendingChanges(change_processor()); |
- FakeServerChange updates(&trans); |
- updates.ModifyCreationTime(id, kCreationTime); |
- updates.ApplyPendingChanges(change_processor()); |
- |
- const BookmarkNode* node = model()->bookmark_bar_node()->GetChild(0); |
- ASSERT_TRUE(node); |
- EXPECT_TRUE(node->is_url()); |
- EXPECT_EQ(base::UTF8ToUTF16(kTitle), node->GetTitle()); |
- EXPECT_EQ(kUrl, node->url().possibly_invalid_spec()); |
- EXPECT_EQ(node->date_added(), base::Time::FromInternalValue(30)); |
-} |
- |
-// Verifies that the transaction version in the native bookmark model gets |
-// updated and synced with the sync transaction version even when the |
-// association doesn't modify any sync nodes. This is necessary to ensure |
-// that the native transaction doesn't get stuck at "unset" version and skips |
-// any further consistency checks. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, |
- NativeTransactionVersionUpdated) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- |
- // Start sync in order to create bookmark nodes in the sync db. |
- StartSync(); |
- StopSync(); |
- |
- // Reset transaction version on the native mode to "unset". |
- model()->SetNodeSyncTransactionVersion( |
- model()->root_node(), syncer::syncable::kInvalidTransactionVersion); |
- |
- // Restart sync. |
- StartSync(); |
- StopSync(); |
- |
- // Verify that the native transaction version has been updated and is now |
- // in sync with the sync version. |
- { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- int64_t sync_version = trans.GetModelVersion(syncer::BOOKMARKS); |
- int64_t native_version = model()->root_node()->sync_transaction_version(); |
- EXPECT_EQ(native_version, sync_version); |
- } |
-} |
- |
-// Tests that changes to the sync nodes meta info gets reflected in the local |
-// bookmark model. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, UpdateMetaInfoFromSync) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- StartSync(); |
- |
- // Create bookmark nodes containing meta info. |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- FakeServerChange adds(&trans); |
- BookmarkNode::MetaInfoMap folder_meta_info; |
- folder_meta_info["folder"] = "foldervalue"; |
- int64_t folder_id = adds.AddFolderWithMetaInfo( |
- "folder title", &folder_meta_info, bookmark_bar_id(), 0); |
- BookmarkNode::MetaInfoMap node_meta_info; |
- node_meta_info["node"] = "nodevalue"; |
- node_meta_info["other"] = "othervalue"; |
- int64_t id = adds.AddURLWithMetaInfo("node title", "http://www.foo.com", |
- &node_meta_info, folder_id, 0); |
- adds.ApplyPendingChanges(change_processor()); |
- |
- // Verify that the nodes are created with the correct meta info. |
- ASSERT_LT(0, model()->bookmark_bar_node()->child_count()); |
- const BookmarkNode* folder_node = model()->bookmark_bar_node()->GetChild(0); |
- ASSERT_TRUE(folder_node->GetMetaInfoMap()); |
- EXPECT_EQ(folder_meta_info, *folder_node->GetMetaInfoMap()); |
- ASSERT_LT(0, folder_node->child_count()); |
- const BookmarkNode* node = folder_node->GetChild(0); |
- ASSERT_TRUE(node->GetMetaInfoMap()); |
- EXPECT_EQ(node_meta_info, *node->GetMetaInfoMap()); |
- |
- // Update meta info on nodes on server |
- FakeServerChange updates(&trans); |
- folder_meta_info.erase("folder"); |
- updates.ModifyMetaInfo(folder_id, folder_meta_info); |
- node_meta_info["node"] = "changednodevalue"; |
- node_meta_info.erase("other"); |
- node_meta_info["newkey"] = "newkeyvalue"; |
- updates.ModifyMetaInfo(id, node_meta_info); |
- updates.ApplyPendingChanges(change_processor()); |
- |
- // Confirm that the updated values are reflected in the bookmark nodes. |
- EXPECT_FALSE(folder_node->GetMetaInfoMap()); |
- ASSERT_TRUE(node->GetMetaInfoMap()); |
- EXPECT_EQ(node_meta_info, *node->GetMetaInfoMap()); |
-} |
- |
-// Tests that changes to the local bookmark nodes meta info gets reflected in |
-// the sync nodes. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, UpdateMetaInfoFromModel) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- StartSync(); |
- ExpectBookmarkModelMatchesTestData(); |
- |
- const BookmarkNode* folder_node = model()->AddFolder( |
- model()->bookmark_bar_node(), 0, base::ASCIIToUTF16("folder title")); |
- const BookmarkNode* node = |
- model()->AddURL(folder_node, 0, base::ASCIIToUTF16("node title"), |
- GURL("http://www.foo.com")); |
- ExpectModelMatch(); |
- |
- // Add some meta info and verify sync model matches the changes. |
- model()->SetNodeMetaInfo(folder_node, "folder", "foldervalue"); |
- model()->SetNodeMetaInfo(node, "node", "nodevalue"); |
- model()->SetNodeMetaInfo(node, "other", "othervalue"); |
- ExpectModelMatch(); |
- |
- // Change/delete existing meta info and verify. |
- model()->DeleteNodeMetaInfo(folder_node, "folder"); |
- model()->SetNodeMetaInfo(node, "node", "changednodevalue"); |
- model()->DeleteNodeMetaInfo(node, "other"); |
- model()->SetNodeMetaInfo(node, "newkey", "newkeyvalue"); |
- ExpectModelMatch(); |
-} |
- |
-// Tests that node's specifics doesn't get unnecessarily overwritten (causing |
-// a subsequent commit) when BookmarkChangeProcessor handles a notification |
-// (such as BookmarkMetaInfoChanged) without an actual data change. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, MetaInfoPreservedOnNonChange) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- WriteTestDataToBookmarkModel(); |
- StartSync(); |
- |
- std::string orig_specifics; |
- int64_t sync_id; |
- const BookmarkNode* bookmark; |
- |
- // Create bookmark folder node containing meta info. |
- { |
- syncer::WriteTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- FakeServerChange adds(&trans); |
- |
- int64_t folder_id = adds.AddFolder("folder title", bookmark_bar_id(), 0); |
- |
- BookmarkNode::MetaInfoMap node_meta_info; |
- node_meta_info["one"] = "1"; |
- node_meta_info["two"] = "2"; |
- node_meta_info["three"] = "3"; |
- |
- sync_id = adds.AddURLWithMetaInfo("node title", "http://www.foo.com/", |
- &node_meta_info, folder_id, 0); |
- |
- // Verify that the node propagates to the bookmark model |
- adds.ApplyPendingChanges(change_processor()); |
- |
- bookmark = model()->bookmark_bar_node()->GetChild(0)->GetChild(0); |
- EXPECT_EQ(node_meta_info, *bookmark->GetMetaInfoMap()); |
- |
- syncer::ReadNode sync_node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, sync_node.InitByIdLookup(sync_id)); |
- orig_specifics = sync_node.GetBookmarkSpecifics().SerializeAsString(); |
- } |
- |
- // Force change processor to update the sync node. |
- change_processor()->BookmarkMetaInfoChanged(model(), bookmark); |
- |
- // Read bookmark specifics again and verify that there is no change. |
- { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- syncer::ReadNode sync_node(&trans); |
- EXPECT_EQ(BaseNode::INIT_OK, sync_node.InitByIdLookup(sync_id)); |
- std::string new_specifics = |
- sync_node.GetBookmarkSpecifics().SerializeAsString(); |
- ASSERT_EQ(orig_specifics, new_specifics); |
- } |
-} |
- |
-void ProfileSyncServiceBookmarkTestWithData::GetTransactionVersions( |
- const BookmarkNode* root, |
- BookmarkNodeVersionMap* node_versions) { |
- node_versions->clear(); |
- std::queue<const BookmarkNode*> nodes; |
- nodes.push(root); |
- while (!nodes.empty()) { |
- const BookmarkNode* n = nodes.front(); |
- nodes.pop(); |
- |
- int64_t version = n->sync_transaction_version(); |
- EXPECT_NE(BookmarkNode::kInvalidSyncTransactionVersion, version); |
- |
- (*node_versions)[n->id()] = version; |
- for (int i = 0; i < n->child_count(); ++i) { |
- if (!CanSyncNode(n->GetChild(i))) |
- continue; |
- nodes.push(n->GetChild(i)); |
- } |
- } |
-} |
- |
-void ProfileSyncServiceBookmarkTestWithData::ExpectTransactionVersionMatch( |
- const BookmarkNode* node, |
- const BookmarkNodeVersionMap& version_expected) { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- |
- BookmarkNodeVersionMap bnodes_versions; |
- GetTransactionVersions(node, &bnodes_versions); |
- for (BookmarkNodeVersionMap::const_iterator it = bnodes_versions.begin(); |
- it != bnodes_versions.end(); ++it) { |
- syncer::ReadNode sync_node(&trans); |
- ASSERT_TRUE( |
- model_associator()->InitSyncNodeFromChromeId(it->first, &sync_node)); |
- EXPECT_EQ(sync_node.GetTransactionVersion(), it->second); |
- BookmarkNodeVersionMap::const_iterator expected_ver_it = |
- version_expected.find(it->first); |
- if (expected_ver_it != version_expected.end()) |
- EXPECT_EQ(expected_ver_it->second, it->second); |
- } |
-} |
- |
-// Test transaction versions of model and nodes are incremented after changes |
-// are applied. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, UpdateTransactionVersion) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- WriteTestDataToBookmarkModel(); |
- base::RunLoop().RunUntilIdle(); |
- |
- BookmarkNodeVersionMap initial_versions; |
- |
- // Verify transaction versions in sync model and bookmark model (saved as |
- // transaction version of root node) are equal after |
- // WriteTestDataToBookmarkModel() created bookmarks. |
- { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- EXPECT_GT(trans.GetModelVersion(syncer::BOOKMARKS), 0); |
- GetTransactionVersions(model()->root_node(), &initial_versions); |
- EXPECT_EQ(trans.GetModelVersion(syncer::BOOKMARKS), |
- initial_versions[model()->root_node()->id()]); |
- } |
- ExpectTransactionVersionMatch(model()->bookmark_bar_node(), |
- BookmarkNodeVersionMap()); |
- ExpectTransactionVersionMatch(model()->other_node(), |
- BookmarkNodeVersionMap()); |
- ExpectTransactionVersionMatch(model()->mobile_node(), |
- BookmarkNodeVersionMap()); |
- |
- // Verify model version is incremented and bookmark node versions remain |
- // the same. |
- const BookmarkNode* bookmark_bar = model()->bookmark_bar_node(); |
- model()->Remove(bookmark_bar->GetChild(0)); |
- base::RunLoop().RunUntilIdle(); |
- BookmarkNodeVersionMap new_versions; |
- GetTransactionVersions(model()->root_node(), &new_versions); |
- EXPECT_EQ(initial_versions[model()->root_node()->id()] + 1, |
- new_versions[model()->root_node()->id()]); |
- ExpectTransactionVersionMatch(model()->bookmark_bar_node(), initial_versions); |
- ExpectTransactionVersionMatch(model()->other_node(), initial_versions); |
- ExpectTransactionVersionMatch(model()->mobile_node(), initial_versions); |
- |
- // Verify model version and version of changed bookmark are incremented and |
- // versions of others remain same. |
- const BookmarkNode* changed_bookmark = |
- model()->bookmark_bar_node()->GetChild(0); |
- model()->SetTitle(changed_bookmark, base::ASCIIToUTF16("test")); |
- base::RunLoop().RunUntilIdle(); |
- GetTransactionVersions(model()->root_node(), &new_versions); |
- EXPECT_EQ(initial_versions[model()->root_node()->id()] + 2, |
- new_versions[model()->root_node()->id()]); |
- EXPECT_LT(initial_versions[changed_bookmark->id()], |
- new_versions[changed_bookmark->id()]); |
- initial_versions.erase(changed_bookmark->id()); |
- ExpectTransactionVersionMatch(model()->bookmark_bar_node(), initial_versions); |
- ExpectTransactionVersionMatch(model()->other_node(), initial_versions); |
- ExpectTransactionVersionMatch(model()->mobile_node(), initial_versions); |
-} |
- |
-// Test that sync persistence errors are detected and trigger a failed |
-// association. |
-TEST_F(ProfileSyncServiceBookmarkTestWithData, PersistenceError) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- WriteTestDataToBookmarkModel(); |
- base::RunLoop().RunUntilIdle(); |
- |
- BookmarkNodeVersionMap initial_versions; |
- |
- // Verify transaction versions in sync model and bookmark model (saved as |
- // transaction version of root node) are equal after |
- // WriteTestDataToBookmarkModel() created bookmarks. |
- { |
- syncer::ReadTransaction trans(FROM_HERE, test_user_share()->user_share()); |
- EXPECT_GT(trans.GetModelVersion(syncer::BOOKMARKS), 0); |
- GetTransactionVersions(model()->root_node(), &initial_versions); |
- EXPECT_EQ(trans.GetModelVersion(syncer::BOOKMARKS), |
- initial_versions[model()->root_node()->id()]); |
- } |
- ExpectTransactionVersionMatch(model()->bookmark_bar_node(), |
- BookmarkNodeVersionMap()); |
- ExpectTransactionVersionMatch(model()->other_node(), |
- BookmarkNodeVersionMap()); |
- ExpectTransactionVersionMatch(model()->mobile_node(), |
- BookmarkNodeVersionMap()); |
- |
- // Now shut down sync and artificially increment the native model's version. |
- StopSync(); |
- int64_t root_version = initial_versions[model()->root_node()->id()]; |
- model()->SetNodeSyncTransactionVersion(model()->root_node(), |
- root_version + 1); |
- |
- // Upon association, bookmarks should fail to associate. |
- EXPECT_FALSE(AssociateModels()); |
-} |
- |
-// It's possible for update/add calls from the bookmark model to be out of |
-// order, or asynchronous. Handle that without triggering an error. |
-TEST_F(ProfileSyncServiceBookmarkTest, UpdateThenAdd) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- EXPECT_TRUE(other_bookmarks_id()); |
- EXPECT_TRUE(bookmark_bar_id()); |
- EXPECT_TRUE(mobile_bookmarks_id()); |
- |
- ExpectModelMatch(); |
- |
- // Now destroy the change processor then add a bookmark, to simulate |
- // missing the Update call. |
- delete_change_processor(); |
- const BookmarkNode* node = |
- model()->AddURL(model()->bookmark_bar_node(), 0, |
- base::ASCIIToUTF16("title"), GURL("http://www.url.com")); |
- |
- // Recreate the change processor then update that bookmark. Sync should |
- // receive the update call and gracefully treat that as if it were an add. |
- ResetChangeProcessor(); |
- change_processor()->Start(test_user_share()->user_share()); |
- model()->SetTitle(node, base::ASCIIToUTF16("title2")); |
- ExpectModelMatch(); |
- |
- // Then simulate the add call arriving late. |
- change_processor()->BookmarkNodeAdded(model(), model()->bookmark_bar_node(), |
- 0); |
- ExpectModelMatch(); |
-} |
- |
-// Verify operations on native nodes that shouldn't be propagated to Sync. |
-TEST_F(ProfileSyncServiceBookmarkTest, TestUnsupportedNodes) { |
- LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE); |
- StartSync(); |
- |
- // Initial number of bookmarks on the sync side. |
- int sync_bookmark_count = GetSyncBookmarkCount(); |
- |
- // Create a bookmark under managed_node() permanent folder. |
- const BookmarkNode* folder = managed_bookmark_service()->managed_node(); |
- const BookmarkNode* node = model()->AddURL( |
- folder, 0, base::ASCIIToUTF16("node"), GURL("http://www.node.com/")); |
- |
- // Verify that these changes are ignored by Sync. |
- EXPECT_EQ(sync_bookmark_count, GetSyncBookmarkCount()); |
- int64_t sync_id = model_associator()->GetSyncIdFromChromeId(node->id()); |
- EXPECT_EQ(syncer::kInvalidId, sync_id); |
- |
- // Verify that Sync ignores deleting this node. |
- model()->Remove(node); |
- EXPECT_EQ(sync_bookmark_count, GetSyncBookmarkCount()); |
-} |
- |
-} // namespace |
- |
-} // namespace browser_sync |