summaryrefslogtreecommitdiffstats
path: root/chrome/browser/sync/profile_sync_service_unittest.cc
diff options
context:
space:
mode:
Diffstat (limited to 'chrome/browser/sync/profile_sync_service_unittest.cc')
-rw-r--r--chrome/browser/sync/profile_sync_service_unittest.cc1273
1 files changed, 1273 insertions, 0 deletions
diff --git a/chrome/browser/sync/profile_sync_service_unittest.cc b/chrome/browser/sync/profile_sync_service_unittest.cc
new file mode 100644
index 0000000..a4d1421
--- /dev/null
+++ b/chrome/browser/sync/profile_sync_service_unittest.cc
@@ -0,0 +1,1273 @@
+// Copyright (c) 2006-2008 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.
+
+#ifdef CHROME_PERSONALIZATION
+
+#include <stack>
+#include <vector>
+
+#include "testing/gtest/include/gtest/gtest.h"
+
+#include "base/command_line.h"
+#include "base/string_util.h"
+#include "base/string16.h"
+#include "chrome/browser/bookmarks/bookmark_model.h"
+#include "chrome/browser/profile.h"
+#include "chrome/browser/sync/engine/syncapi.h"
+#include "chrome/browser/sync/glue/model_associator.h"
+#include "chrome/browser/sync/profile_sync_service.h"
+#include "chrome/common/pref_service.h"
+#include "chrome/test/testing_profile.h"
+
+using std::vector;
+using browser_sync::ModelAssociator;
+using browser_sync::SyncBackendHost;
+
+class TestModelAssociator : public ModelAssociator {
+ public:
+ explicit TestModelAssociator(ProfileSyncService* service)
+ : ModelAssociator(service) {
+ }
+
+ virtual bool GetSyncIdForTaggedNode(const string16& tag, int64* sync_id) {
+ sync_api::WriteTransaction trans(
+ sync_service()->backend()->GetUserShareHandle());
+ sync_api::ReadNode root(&trans);
+ root.InitByRootLookup();
+
+ // First, try to find a node with the title among the root's children.
+ // This will be the case if we are testing model persistence, and
+ // are reloading a sync repository created earlier in the test.
+ for (int64 id = root.GetFirstChildId(); id != sync_api::kInvalidId; /***/) {
+ sync_api::ReadNode child(&trans);
+ if (!child.InitByIdLookup(id)) {
+ NOTREACHED();
+ break;
+ }
+ if (tag == child.GetTitle()) {
+ *sync_id = id;
+ return true;
+ }
+ id = child.GetSuccessorId();
+ }
+
+ sync_api::WriteNode node(&trans);
+ if (!node.InitByCreation(root, NULL))
+ return false;
+ node.SetIsFolder(true);
+ node.SetTitle(tag.c_str());
+ node.SetExternalId(0);
+ *sync_id = node.GetId();
+ return true;
+ }
+};
+
+class TestProfileSyncService : public ProfileSyncService {
+ public:
+ explicit TestProfileSyncService(Profile* profile)
+ : ProfileSyncService(profile) {
+ PrefService* pref_service = profile->GetPrefs();
+ if (pref_service->IsPrefRegistered(prefs::kSyncUserName))
+ return;
+ pref_service->RegisterStringPref(prefs::kSyncUserName, string16());
+ pref_service->RegisterStringPref(prefs::kSyncLastSyncedTime, string16());
+ pref_service->RegisterBooleanPref(prefs::kSyncHasSetupCompleted, true);
+ }
+ virtual ~TestProfileSyncService() {
+ }
+
+ virtual void InitializeBackend() {
+ set_model_associator(new TestModelAssociator(this));
+ backend()->InitializeForTestMode(L"testuser");
+ // The SyncBackend posts a task to the current loop when initialization
+ // completes.
+ MessageLoop::current()->Run();
+ // Initialization is synchronous for test mode, so we should be good to go.
+ DCHECK(sync_initialized());
+ }
+
+ virtual void OnBackendInitialized() {
+ ProfileSyncService::OnBackendInitialized();
+ MessageLoop::current()->Quit();
+ }
+
+ virtual bool MergeAndSyncAcceptanceNeeded() {
+ // Never show the dialog.
+ return false;
+ }
+};
+
+// FakeServerChange constructs a list of sync_api::ChangeRecords while modifying
+// the sync model, and can pass the ChangeRecord list to a
+// sync_api::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(sync_api::WriteTransaction* trans) : trans_(trans) {
+ }
+
+ // Pretend that the server told the syncer to add a bookmark object.
+ int64 Add(const string16& title,
+ const string16& url,
+ bool is_folder,
+ int64 parent_id,
+ int64 predecessor_id) {
+ sync_api::ReadNode parent(trans_);
+ EXPECT_TRUE(parent.InitByIdLookup(parent_id));
+ sync_api::WriteNode node(trans_);
+ if (predecessor_id == 0) {
+ EXPECT_TRUE(node.InitByCreation(parent, NULL));
+ } else {
+ sync_api::ReadNode predecessor(trans_);
+ EXPECT_TRUE(predecessor.InitByIdLookup(predecessor_id));
+ EXPECT_EQ(predecessor.GetParentId(), parent.GetId());
+ EXPECT_TRUE(node.InitByCreation(parent, &predecessor));
+ }
+ EXPECT_EQ(node.GetPredecessorId(), predecessor_id);
+ EXPECT_EQ(node.GetParentId(), parent_id);
+ node.SetIsFolder(is_folder);
+ node.SetTitle(title.c_str());
+ if (!is_folder) {
+ GURL gurl(url);
+ node.SetURL(url.c_str());
+ }
+ sync_api::SyncManager::ChangeRecord record;
+ record.action = sync_api::SyncManager::ChangeRecord::ACTION_ADD;
+ record.id = node.GetId();
+ changes_.push_back(record);
+ return node.GetId();
+ }
+
+ // Add a bookmark folder.
+ int64 AddFolder(const string16& title,
+ int64 parent_id,
+ int64 predecessor_id) {
+ return Add(title, string16(), true, parent_id, predecessor_id);
+ }
+
+ // Add a bookmark.
+ int64 AddURL(const string16& title,
+ const string16& url,
+ int64 parent_id,
+ int64 predecessor_id) {
+ return Add(title, url, false, parent_id, predecessor_id);
+ }
+
+ // Pretend that the server told the syncer to delete an object.
+ void Delete(int64 id) {
+ {
+ // Delete the sync node.
+ sync_api::WriteNode node(trans_);
+ EXPECT_TRUE(node.InitByIdLookup(id));
+ EXPECT_FALSE(node.GetFirstChildId());
+ node.Remove();
+ }
+ {
+ // Verify the deletion.
+ sync_api::ReadNode node(trans_);
+ EXPECT_FALSE(node.InitByIdLookup(id));
+ }
+
+ sync_api::SyncManager::ChangeRecord record;
+ record.action = sync_api::SyncManager::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.
+ string16 ModifyTitle(int64 id, const string16& new_title) {
+ sync_api::WriteNode node(trans_);
+ EXPECT_TRUE(node.InitByIdLookup(id));
+ string16 old_title = node.GetTitle();
+ node.SetTitle(new_title.c_str());
+ SetModified(id);
+ return old_title;
+ }
+
+ // Set a new URL value, and return the old value.
+ // TODO(ncarter): Determine if URL modifications are even legal.
+ string16 ModifyURL(int64 id, const string16& new_url) {
+ sync_api::WriteNode node(trans_);
+ EXPECT_TRUE(node.InitByIdLookup(id));
+ EXPECT_FALSE(node.GetIsFolder());
+ string16 old_url = node.GetURL();
+ node.SetURL(new_url.c_str());
+ SetModified(id);
+ return old_url;
+ }
+
+ // 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 ModifyPosition(int64 id, int64 parent_id, int64 predecessor_id) {
+ sync_api::ReadNode parent(trans_);
+ EXPECT_TRUE(parent.InitByIdLookup(parent_id));
+ sync_api::WriteNode node(trans_);
+ EXPECT_TRUE(node.InitByIdLookup(id));
+ int64 old_parent_id = node.GetParentId();
+ if (predecessor_id == 0) {
+ EXPECT_TRUE(node.SetPosition(parent, NULL));
+ } else {
+ sync_api::ReadNode predecessor(trans_);
+ EXPECT_TRUE(predecessor.InitByIdLookup(predecessor_id));
+ EXPECT_EQ(predecessor.GetParentId(), parent.GetId());
+ EXPECT_TRUE(node.SetPosition(parent, &predecessor));
+ }
+ SetModified(id);
+ return old_parent_id;
+ }
+
+ // Pass the fake change list to |service|.
+ void ApplyPendingChanges(ProfileSyncService* service) {
+ service->ApplyModelChanges(trans_, changes_.size() ? &changes_[0] : NULL,
+ changes_.size());
+ }
+
+ const vector<sync_api::SyncManager::ChangeRecord>& changes() {
+ return changes_;
+ }
+
+ private:
+ // Helper function to push an ACTION_UPDATE record onto the back
+ // of the changelist.
+ void SetModified(int64 id) {
+ // Coalesce multi-property edits.
+ if (changes_.size() > 0 && changes_.back().id == id &&
+ changes_.back().action ==
+ sync_api::SyncManager::ChangeRecord::ACTION_UPDATE)
+ return;
+ sync_api::SyncManager::ChangeRecord record;
+ record.action = sync_api::SyncManager::ChangeRecord::ACTION_UPDATE;
+ record.id = id;
+ changes_.push_back(record);
+ }
+
+ // The transaction on which everything happens.
+ sync_api::WriteTransaction *trans_;
+
+ // The change list we construct.
+ vector<sync_api::SyncManager::ChangeRecord> changes_;
+};
+
+class ProfileSyncServiceTest : public testing::Test {
+ protected:
+ enum LoadOption { LOAD_FROM_STORAGE, DELETE_EXISTING_STORAGE };
+ enum SaveOption { SAVE_TO_STORAGE, DONT_SAVE_TO_STORAGE };
+ ProfileSyncServiceTest() : model_(NULL) {
+ profile_.reset(new TestingProfile());
+ profile_->set_has_history_service(true);
+ }
+ virtual ~ProfileSyncServiceTest() {
+ // Kill the service before the profile.
+ service_.reset();
+ profile_.reset();
+ }
+
+ ModelAssociator* associator() {
+ DCHECK(service_.get());
+ return service_->model_associator_;
+ }
+
+ void StartSyncService() {
+ if (!service_.get()) {
+ service_.reset(new TestProfileSyncService(profile_.get()));
+ service_->Initialize();
+ }
+ // The service may have already started sync automatically if it's already
+ // enabled by user once.
+ if (!service_->IsSyncEnabledByUser())
+ service_->EnableForUser();
+ }
+ void StopSyncService(SaveOption save) {
+ if (save == DONT_SAVE_TO_STORAGE)
+ service_->DisableForUser();
+ service_.reset();
+ }
+
+ // 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;
+ profile_->CreateBookmarkModel(delete_bookmarks);
+ model_ = profile_->GetBookmarkModel();
+ // Wait for the bookmarks model to load.
+ profile_->BlockUntilBookmarkModelLoaded();
+ // This noticeably speeds up the unit tests that request it.
+ if (save == DONT_SAVE_TO_STORAGE)
+ model_->ClearStore();
+ }
+
+ void ExpectSyncerNodeMatching(sync_api::BaseTransaction* trans,
+ const BookmarkNode* bnode) {
+ sync_api::ReadNode gnode(trans);
+ EXPECT_TRUE(associator()->InitSyncNodeFromBookmarkId(bnode->id(), &gnode));
+ // Non-root node titles and parents must match.
+ if (bnode != model_->GetBookmarkBarNode() &&
+ bnode != model_->other_node()) {
+ EXPECT_EQ(bnode->GetTitle(), gnode.GetTitle());
+ EXPECT_EQ(associator()->GetBookmarkNodeFromSyncId(gnode.GetParentId()),
+ bnode->GetParent());
+ }
+ EXPECT_EQ(bnode->is_folder(), gnode.GetIsFolder());
+ if (bnode->is_url())
+ EXPECT_EQ(bnode->GetURL(), GURL(gnode.GetURL()));
+
+ // Check for position matches.
+ int browser_index = bnode->GetParent()->IndexOfChild(bnode);
+ if (browser_index == 0) {
+ EXPECT_EQ(gnode.GetPredecessorId(), 0);
+ } else {
+ const BookmarkNode* bprev =
+ bnode->GetParent()->GetChild(browser_index - 1);
+ sync_api::ReadNode gprev(trans);
+ ASSERT_TRUE(associator()->InitSyncNodeFromBookmarkId(bprev->id(),
+ &gprev));
+ EXPECT_EQ(gnode.GetPredecessorId(), gprev.GetId());
+ EXPECT_EQ(gnode.GetParentId(), gprev.GetParentId());
+ }
+ if (browser_index == bnode->GetParent()->GetChildCount() - 1) {
+ EXPECT_EQ(gnode.GetSuccessorId(), 0);
+ } else {
+ const BookmarkNode* bnext =
+ bnode->GetParent()->GetChild(browser_index + 1);
+ sync_api::ReadNode gnext(trans);
+ ASSERT_TRUE(associator()->InitSyncNodeFromBookmarkId(bnext->id(),
+ &gnext));
+ EXPECT_EQ(gnode.GetSuccessorId(), gnext.GetId());
+ EXPECT_EQ(gnode.GetParentId(), gnext.GetParentId());
+ }
+ if (bnode->GetChildCount()) {
+ EXPECT_TRUE(gnode.GetFirstChildId());
+ }
+ }
+
+ void ExpectSyncerNodeMatching(const BookmarkNode* bnode) {
+ sync_api::ReadTransaction trans(service_->backend_->GetUserShareHandle());
+ ExpectSyncerNodeMatching(&trans, bnode);
+ }
+
+ void ExpectBrowserNodeMatching(sync_api::BaseTransaction* trans,
+ int64 sync_id) {
+ EXPECT_TRUE(sync_id);
+ const BookmarkNode* bnode =
+ associator()->GetBookmarkNodeFromSyncId(sync_id);
+ ASSERT_TRUE(bnode);
+ int64 id = associator()->GetSyncIdFromBookmarkId(bnode->id());
+ EXPECT_EQ(id, sync_id);
+ ExpectSyncerNodeMatching(trans, bnode);
+ }
+
+ void ExpectBrowserNodeUnknown(int64 sync_id) {
+ EXPECT_FALSE(associator()->GetBookmarkNodeFromSyncId(sync_id));
+ }
+
+ void ExpectBrowserNodeKnown(int64 sync_id) {
+ EXPECT_TRUE(associator()->GetBookmarkNodeFromSyncId(sync_id));
+ }
+
+ void ExpectSyncerNodeKnown(const BookmarkNode* node) {
+ int64 sync_id = associator()->GetSyncIdFromBookmarkId(node->id());
+ EXPECT_NE(sync_id, sync_api::kInvalidId);
+ }
+
+ void ExpectSyncerNodeUnknown(const BookmarkNode* node) {
+ int64 sync_id = associator()->GetSyncIdFromBookmarkId(node->id());
+ EXPECT_EQ(sync_id, sync_api::kInvalidId);
+ }
+
+ void ExpectBrowserNodeTitle(int64 sync_id, const string16& title) {
+ const BookmarkNode* bnode =
+ associator()->GetBookmarkNodeFromSyncId(sync_id);
+ ASSERT_TRUE(bnode);
+ EXPECT_EQ(bnode->GetTitle(), title);
+ }
+
+ void ExpectBrowserNodeURL(int64 sync_id, const string16& url) {
+ const BookmarkNode* bnode =
+ associator()->GetBookmarkNodeFromSyncId(sync_id);
+ ASSERT_TRUE(bnode);
+ GURL url2(url);
+ EXPECT_EQ(url2, bnode->GetURL());
+ }
+
+ void ExpectBrowserNodeParent(int64 sync_id, int64 parent_sync_id) {
+ const BookmarkNode* node = associator()->GetBookmarkNodeFromSyncId(sync_id);
+ ASSERT_TRUE(node);
+ const BookmarkNode* parent =
+ associator()->GetBookmarkNodeFromSyncId(parent_sync_id);
+ EXPECT_TRUE(parent);
+ EXPECT_EQ(node->GetParent(), parent);
+ }
+
+ void ExpectModelMatch(sync_api::BaseTransaction* trans) {
+ const BookmarkNode* root = model_->root_node();
+ EXPECT_EQ(root->IndexOfChild(model_->GetBookmarkBarNode()), 0);
+ EXPECT_EQ(root->IndexOfChild(model_->other_node()), 1);
+
+ std::stack<int64> stack;
+ stack.push(bookmark_bar_id());
+ while (!stack.empty()) {
+ int64 id = stack.top();
+ stack.pop();
+ if (!id) continue;
+
+ ExpectBrowserNodeMatching(trans, id);
+
+ sync_api::ReadNode gnode(trans);
+ ASSERT_TRUE(gnode.InitByIdLookup(id));
+ stack.push(gnode.GetFirstChildId());
+ stack.push(gnode.GetSuccessorId());
+ }
+ }
+
+ void ExpectModelMatch() {
+ sync_api::ReadTransaction trans(service_->backend_->GetUserShareHandle());
+ ExpectModelMatch(&trans);
+ }
+
+ int64 other_bookmarks_id() {
+ return associator()->GetSyncIdFromBookmarkId(model_->other_node()->id());
+ }
+
+ int64 bookmark_bar_id() {
+ return associator()->GetSyncIdFromBookmarkId(
+ model_->GetBookmarkBarNode()->id());
+ }
+
+ SyncBackendHost* backend() { return service_->backend_.get(); }
+
+ // This serves as the "UI loop" on which the ProfileSyncService lives and
+ // operates. It is needed because the SyncBackend can post tasks back to
+ // the service, meaning it can't be null. It doesn't have to be running,
+ // though -- OnInitializationCompleted is the only example (so far) in this
+ // test where we need to Run the loop to swallow a task and then quit, to
+ // avoid leaking the ProfileSyncService (the PostTask will retain the callee
+ // and caller until the task is run).
+ MessageLoop message_loop_;
+
+ scoped_ptr<ProfileSyncService> service_;
+ scoped_ptr<TestingProfile> profile_;
+ BookmarkModel* model_;
+};
+
+TEST_F(ProfileSyncServiceTest, InitialState) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ EXPECT_TRUE(other_bookmarks_id());
+ EXPECT_TRUE(bookmark_bar_id());
+
+ ExpectModelMatch();
+}
+
+TEST_F(ProfileSyncServiceTest, BookmarkModelOperations) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ // Test addition.
+ const BookmarkNode* folder =
+ model_->AddGroup(model_->other_node(), 0, L"foobar");
+ ExpectSyncerNodeMatching(folder);
+ ExpectModelMatch();
+ const BookmarkNode* folder2 = model_->AddGroup(folder, 0, L"nested");
+ ExpectSyncerNodeMatching(folder2);
+ ExpectModelMatch();
+ const BookmarkNode* url1 = model_->AddURL(
+ folder, 0, L"Internets #1 Pies Site", GURL(L"http://www.easypie.com/"));
+ ExpectSyncerNodeMatching(url1);
+ ExpectModelMatch();
+ const BookmarkNode* url2 = model_->AddURL(
+ folder, 1, L"Airplanes", GURL(L"http://www.easyjet.com/"));
+ ExpectSyncerNodeMatching(url2);
+ ExpectModelMatch();
+
+ // Test modification.
+ model_->SetTitle(url2, L"EasyJet");
+ ExpectModelMatch();
+ model_->Move(url1, folder2, 0);
+ ExpectModelMatch();
+ model_->Move(folder2, model_->GetBookmarkBarNode(), 0);
+ ExpectModelMatch();
+ model_->SetTitle(folder2, L"Not Nested");
+ ExpectModelMatch();
+ model_->Move(folder, folder2, 0);
+ ExpectModelMatch();
+ model_->SetTitle(folder, L"who's nested now?");
+ ExpectModelMatch();
+
+ // Test deletion.
+ // Delete a single item.
+ model_->Remove(url2->GetParent(), url2->GetParent()->IndexOfChild(url2));
+ ExpectModelMatch();
+ // Delete an item with several children.
+ model_->Remove(folder2->GetParent(),
+ folder2->GetParent()->IndexOfChild(folder2));
+ ExpectModelMatch();
+}
+
+TEST_F(ProfileSyncServiceTest, ServerChangeProcessing) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ sync_api::WriteTransaction trans(backend()->GetUserShareHandle());
+
+ FakeServerChange adds(&trans);
+ int64 f1 = adds.AddFolder(L"Server Folder B", bookmark_bar_id(), 0);
+ int64 f2 = adds.AddFolder(L"Server Folder A", bookmark_bar_id(), f1);
+ int64 u1 = adds.AddURL(L"Some old site", L"ftp://nifty.andrew.cmu.edu/",
+ bookmark_bar_id(), f2);
+ int64 u2 = adds.AddURL(L"Nifty", L"ftp://nifty.andrew.cmu.edu/", f1, 0);
+ // u3 is a duplicate URL
+ int64 u3 = adds.AddURL(L"Nifty2", L"ftp://nifty.andrew.cmu.edu/", f1, u2);
+ // u4 is a duplicate title, different URL.
+ int64 u4 = adds.AddURL(L"Some old site", L"http://slog.thestranger.com/",
+ bookmark_bar_id(), u1);
+ // u5 tests an empty-string title.
+ string16 javascript_url(L"javascript:(function(){var w=window.open(" \
+ L"'about:blank','gnotesWin','location=0,menubar=0," \
+ L"scrollbars=0,status=0,toolbar=0,width=300," \
+ L"height=300,resizable');});");
+ int64 u5 = adds.AddURL(L"", javascript_url, other_bookmarks_id(), 0);
+
+ vector<sync_api::SyncManager::ChangeRecord>::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(service_.get());
+
+ // 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.
+ /* string16 u2_old_url = mods.ModifyURL(u2, L"http://www.google.com"); */
+ string16 u2_old_title = mods.ModifyTitle(u2, L"The Google");
+ int64 u2_old_parent = mods.ModifyPosition(u2, f2, 0);
+
+ // Now move f1 after u2.
+ string16 f1_old_title = mods.ModifyTitle(f1, L"Server Folder C");
+ int64 f1_old_parent = mods.ModifyPosition(f1, f2, u2);
+
+ // Then add u3 after f1.
+ int64 u3_old_parent = mods.ModifyPosition(u3, f2, f1);
+
+ // 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);
+
+ // Apply the changes.
+ mods.ApplyPendingChanges(service_.get());
+
+ // 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);
+
+ ExpectBrowserNodeKnown(u2);
+ ExpectBrowserNodeKnown(u3);
+
+ dels.ApplyPendingChanges(service_.get());
+
+ ExpectBrowserNodeUnknown(u2);
+ ExpectBrowserNodeUnknown(u3);
+ 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(ProfileSyncServiceTest, ServerChangeRequiringFosterParent) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ sync_api::WriteTransaction trans(backend()->GetUserShareHandle());
+
+ // Stress the immediate children of other_node because that's where
+ // ApplyModelChanges puts a temporary foster parent node.
+ string16 url(L"http://dev.chromium.org/");
+ FakeServerChange adds(&trans);
+ int64 f0 = other_bookmarks_id(); // + other_node
+ int64 f1 = adds.AddFolder(L"f1", f0, 0); // + f1
+ int64 f2 = adds.AddFolder(L"f2", f1, 0); // + f2
+ int64 u3 = adds.AddURL( L"u3", url, f2, 0); // + u3
+ int64 u4 = adds.AddURL( L"u4", url, f2, u3); // + u4
+ int64 u5 = adds.AddURL( L"u5", url, f1, f2); // + u5
+ int64 f6 = adds.AddFolder(L"f6", f1, u5); // + f6
+ int64 u7 = adds.AddURL( L"u7", url, f0, f1); // + u7
+
+ vector<sync_api::SyncManager::ChangeRecord>::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(service_.get());
+
+ // 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(service_.get());
+
+ ExpectModelMatch(&trans);
+}
+
+// Simulate a server change record containing a valid but non-canonical URL.
+TEST_F(ProfileSyncServiceTest, ServerChangeWithNonCanonicalURL) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ {
+ sync_api::WriteTransaction trans(backend()->GetUserShareHandle());
+
+ FakeServerChange adds(&trans);
+ std::string url("http://dev.chromium.org");
+ EXPECT_NE(GURL(url).spec(), url);
+ int64 u1 = adds.AddURL(L"u1", UTF8ToWide(url), other_bookmarks_id(), 0);
+
+ adds.ApplyPendingChanges(service_.get());
+
+ EXPECT_TRUE(model_->other_node()->GetChildCount() == 1);
+ ExpectModelMatch(&trans);
+ }
+
+ // Now reboot the sync service, forcing a merge step.
+ StopSyncService(SAVE_TO_STORAGE);
+ LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ // There should still be just the one bookmark.
+ EXPECT_TRUE(model_->other_node()->GetChildCount() == 1);
+ ExpectModelMatch();
+}
+
+// Simulate a server change record containing an invalid URL (per GURL).
+// TODO(ncarter): Disabled due to crashes. Fix bug 1677563.
+TEST_F(ProfileSyncServiceTest, DISABLED_ServerChangeWithInvalidURL) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ int child_count = 0;
+ {
+ sync_api::WriteTransaction trans(backend()->GetUserShareHandle());
+
+ FakeServerChange adds(&trans);
+ EXPECT_FALSE(GURL("x").is_valid());
+ int64 u1 = adds.AddURL(L"u1", L"x", other_bookmarks_id(), 0);
+
+ adds.ApplyPendingChanges(service_.get());
+
+ // 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()->GetChildCount();
+ EXPECT_TRUE(child_count == 0 || child_count == 1);
+ ExpectModelMatch(&trans);
+ }
+
+ // Now reboot the sync service, forcing a merge step.
+ StopSyncService(SAVE_TO_STORAGE);
+ LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ // Things ought not to have changed.
+ EXPECT_EQ(model_->other_node()->GetChildCount(), 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(ProfileSyncServiceTest, CornerCaseNames) {
+ // TODO(ncarter): Bug 1570238 explains the failure of this test.
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ char16* names[] = {
+ // The empty string.
+ L"",
+ // Illegal Windows filenames.
+ L"CON", L"PRN", L"AUX", L"NUL", L"COM1", L"COM2", L"COM3", L"COM4",
+ L"COM5", L"COM6", L"COM7", L"COM8", L"COM9", L"LPT1", L"LPT2", L"LPT3",
+ L"LPT4", L"LPT5", L"LPT6", L"LPT7", L"LPT8", L"LPT9",
+ // Current/parent directory markers.
+ L".", L"..", L"...",
+ // Files created automatically by the Windows shell.
+ L"Thumbs.db", L".DS_Store",
+ // Names including Win32-illegal characters, and path separators.
+ L"foo/bar", L"foo\\bar", L"foo?bar", L"foo:bar", L"foo|bar", L"foo\"bar",
+ L"foo'bar", L"foo<bar", L"foo>bar", L"foo%bar", L"foo*bar", L"foo]bar",
+ L"foo[bar",
+ };
+ // Create both folders and bookmarks using each name.
+ GURL url("http://www.doublemint.com");
+ for (int i = 0; i < arraysize(names); ++i) {
+ model_->AddGroup(model_->other_node(), 0, names[i]);
+ model_->AddURL(model_->other_node(), 0, names[i], url);
+ }
+
+ // Verify that the browser model matches the sync model.
+ EXPECT_EQ(model_->other_node()->GetChildCount(), 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(ProfileSyncServiceTest, RepeatedMiddleInsertion) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ static const int kTimesToInsert = 256;
+
+ // Create two book-end nodes to insert between.
+ model_->AddGroup(model_->other_node(), 0, L"Alpha");
+ model_->AddGroup(model_->other_node(), 1, L"Omega");
+ int count = 2;
+
+ // Test insertion in first half of range by repeatedly inserting in second
+ // position.
+ for (int i = 0; i < kTimesToInsert; ++i) {
+ string16 title = string16(L"Pre-insertion ") + IntToWString(i);
+ model_->AddGroup(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) {
+ string16 title = string16(L"Post-insertion ") + IntToWString(i);
+ model_->AddGroup(model_->other_node(), count - 1, title);
+ count++;
+ }
+
+ // Verify that the browser model matches the sync model.
+ EXPECT_EQ(model_->other_node()->GetChildCount(), count);
+ ExpectModelMatch();
+}
+
+// Introduce a consistency violation into the model, and see that it
+// puts itself into a lame, error state.
+TEST_F(ProfileSyncServiceTest, UnrecoverableErrorSuspendsService) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ // Synchronization should be up and running at this point.
+ EXPECT_TRUE(service_->ShouldPushChanges());
+
+ // Add a node which will be the target of the consistency violation.
+ const BookmarkNode* node =
+ model_->AddGroup(model_->other_node(), 0, L"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.
+ {
+ sync_api::WriteTransaction trans(service_->backend_->GetUserShareHandle());
+ sync_api::WriteNode sync_node(&trans);
+ EXPECT_TRUE(associator()->InitSyncNodeFromBookmarkId(node->id(),
+ &sync_node));
+ sync_node.Remove();
+ }
+ // The models don't match at this point, but the ProfileSyncService
+ // doesn't know it yet.
+ ExpectSyncerNodeKnown(node);
+ EXPECT_TRUE(service_->ShouldPushChanges());
+
+ // Add a child to the inconsistent node. This should cause detection of the
+ // problem.
+ const BookmarkNode* nested = model_->AddGroup(node, 0, L"nested");
+ EXPECT_FALSE(service_->ShouldPushChanges());
+ ExpectSyncerNodeUnknown(nested);
+
+ // Try to add a node under a totally different parent. This should also
+ // fail -- the ProfileSyncService should stop processing changes after
+ // encountering a consistency violation.
+ const BookmarkNode* unrelated = model_->AddGroup(
+ model_->GetBookmarkBarNode(), 0, L"unrelated");
+ EXPECT_FALSE(service_->ShouldPushChanges());
+ ExpectSyncerNodeUnknown(unrelated);
+
+ // TODO(ncarter): We ought to test the ProfileSyncService state machine
+ // directly here once that's formalized and exposed.
+}
+
+struct TestData {
+ const char16* title;
+ const char16* url;
+};
+
+// 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 ProfileSyncServiceTestWithData : public ProfileSyncServiceTest {
+ protected:
+ // Populates or compares children of the given bookmark node from/with the
+ // given test data array with the given size.
+ void PopulateFromTestData(const BookmarkNode* node,
+ const TestData* data,
+ int size);
+ void CompareWithTestData(const BookmarkNode* node,
+ const TestData* data,
+ int size);
+
+ void ExpectBookmarkModelMatchesTestData();
+ void WriteTestDataToBookmarkModel();
+};
+
+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/
+//
+static TestData kBookmarkBarChildren[] = {
+ { L"u2", L"http://www.u2.com/" },
+ { L"f1", NULL },
+ { L"u1", L"http://www.u1.com/" },
+ { L"f2", NULL },
+};
+static TestData kF1Children[] = {
+ { L"f1u4", L"http://www.f1u4.com/" },
+ { L"f1u2", L"http://www.f1u2.com/" },
+ { L"f1u3", L"http://www.f1u3.com/" },
+ { L"f1u1", L"http://www.f1u1.com/" },
+};
+static TestData kF2Children[] = {
+ { L"f2u2", L"http://www.f2u2.com/" },
+ { L"f2u4", L"http://www.f2u4.com/" },
+ { L"f2u3", L"http://www.f2u3.com/" },
+ { L"f2u1", L"http://www.f2u1.com/" },
+};
+
+static TestData kOtherBookmarksChildren[] = {
+ { L"f3", NULL },
+ { L"u4", L"http://www.u4.com/" },
+ { L"u3", L"http://www.u3.com/" },
+ { L"f4", NULL },
+ { L"dup", NULL },
+ { L"dup", NULL },
+};
+static TestData kF3Children[] = {
+ { L"f3u4", L"http://www.f3u4.com/" },
+ { L"f3u2", L"http://www.f3u2.com/" },
+ { L"f3u3", L"http://www.f3u3.com/" },
+ { L"f3u1", L"http://www.f3u1.com/" },
+};
+static TestData kF4Children[] = {
+ { L"f4u1", L"http://www.f4u1.com/" },
+ { L"f4u2", L"http://www.f4u2.com/" },
+ { L"f4u3", L"http://www.f4u3.com/" },
+ { L"f4u4", L"http://www.f4u4.com/" },
+};
+static TestData kDup1Children[] = {
+ { L"dupu1", L"http://www.dupu1.com/" },
+};
+static TestData kDup2Children[] = {
+ { L"dupu2", L"http://www.dupu2.com/" },
+};
+
+} // anonymous namespace.
+
+void ProfileSyncServiceTestWithData::PopulateFromTestData(
+ const BookmarkNode* node, const TestData* data, int size) {
+ DCHECK(node);
+ DCHECK(data);
+ DCHECK(node->is_folder());
+ for (int i = 0; i < size; ++i) {
+ const TestData& item = data[i];
+ if (item.url) {
+ model_->AddURL(node, i, item.title, GURL(item.url));
+ } else {
+ model_->AddGroup(node, i, item.title);
+ }
+ }
+}
+
+void ProfileSyncServiceTestWithData::CompareWithTestData(
+ const BookmarkNode* node, const TestData* data, int size) {
+ DCHECK(node);
+ DCHECK(data);
+ DCHECK(node->is_folder());
+ for (int i = 0; i < size; ++i) {
+ const BookmarkNode* child_node = node->GetChild(i);
+ const TestData& item = data[i];
+ EXPECT_TRUE(child_node->GetTitle() == item.title);
+ if (item.url) {
+ EXPECT_FALSE(child_node->is_folder());
+ EXPECT_TRUE(child_node->is_url());
+ EXPECT_TRUE(child_node->GetURL() == GURL(item.url));
+ } else {
+ EXPECT_TRUE(child_node->is_folder());
+ EXPECT_FALSE(child_node->is_url());
+ }
+ }
+}
+
+// TODO(munjal): We should implement some way of generating random data and can
+// use the same seed to generate the same sequence.
+void ProfileSyncServiceTestWithData::WriteTestDataToBookmarkModel() {
+ const BookmarkNode* bookmarks_bar_node = model_->GetBookmarkBarNode();
+ PopulateFromTestData(bookmarks_bar_node,
+ kBookmarkBarChildren,
+ arraysize(kBookmarkBarChildren));
+
+ ASSERT_GE(bookmarks_bar_node->GetChildCount(), 4);
+ const BookmarkNode* f1_node = bookmarks_bar_node->GetChild(1);
+ PopulateFromTestData(f1_node, kF1Children, arraysize(kF1Children));
+ const BookmarkNode* f2_node = bookmarks_bar_node->GetChild(3);
+ PopulateFromTestData(f2_node, kF2Children, arraysize(kF2Children));
+
+ const BookmarkNode* other_bookmarks_node = model_->other_node();
+ PopulateFromTestData(other_bookmarks_node,
+ kOtherBookmarksChildren,
+ arraysize(kOtherBookmarksChildren));
+
+ ASSERT_GE(other_bookmarks_node->GetChildCount(), 6);
+ const BookmarkNode* f3_node = other_bookmarks_node->GetChild(0);
+ PopulateFromTestData(f3_node, kF3Children, arraysize(kF3Children));
+ const BookmarkNode* f4_node = other_bookmarks_node->GetChild(3);
+ PopulateFromTestData(f4_node, kF4Children, arraysize(kF4Children));
+ const BookmarkNode* dup_node = other_bookmarks_node->GetChild(4);
+ PopulateFromTestData(dup_node, kDup1Children, arraysize(kDup1Children));
+ dup_node = other_bookmarks_node->GetChild(5);
+ PopulateFromTestData(dup_node, kDup2Children, arraysize(kDup2Children));
+
+ ExpectBookmarkModelMatchesTestData();
+}
+
+void ProfileSyncServiceTestWithData::ExpectBookmarkModelMatchesTestData() {
+ const BookmarkNode* bookmark_bar_node = model_->GetBookmarkBarNode();
+ CompareWithTestData(bookmark_bar_node,
+ kBookmarkBarChildren,
+ arraysize(kBookmarkBarChildren));
+
+ ASSERT_GE(bookmark_bar_node->GetChildCount(), 4);
+ const BookmarkNode* f1_node = bookmark_bar_node->GetChild(1);
+ CompareWithTestData(f1_node, kF1Children, arraysize(kF1Children));
+ const BookmarkNode* f2_node = bookmark_bar_node->GetChild(3);
+ CompareWithTestData(f2_node, kF2Children, arraysize(kF2Children));
+
+ const BookmarkNode* other_bookmarks_node = model_->other_node();
+ CompareWithTestData(other_bookmarks_node,
+ kOtherBookmarksChildren,
+ arraysize(kOtherBookmarksChildren));
+
+ ASSERT_GE(other_bookmarks_node->GetChildCount(), 6);
+ const BookmarkNode* f3_node = other_bookmarks_node->GetChild(0);
+ CompareWithTestData(f3_node, kF3Children, arraysize(kF3Children));
+ const BookmarkNode* f4_node = other_bookmarks_node->GetChild(3);
+ CompareWithTestData(f4_node, kF4Children, arraysize(kF4Children));
+ const BookmarkNode* dup_node = other_bookmarks_node->GetChild(4);
+ CompareWithTestData(dup_node, kDup1Children, arraysize(kDup1Children));
+ dup_node = other_bookmarks_node->GetChild(5);
+ CompareWithTestData(dup_node, kDup2Children, arraysize(kDup2Children));
+}
+
+// Tests persistence of the profile sync service by destroying the
+// profile sync service and then reloading it from disk.
+TEST_F(ProfileSyncServiceTestWithData, Persistence) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ 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.
+ StopSyncService(SAVE_TO_STORAGE);
+ LoadBookmarkModel(LOAD_FROM_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ 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(ProfileSyncServiceTestWithData, MergeWithEmptySyncModel) {
+ // Don't start the sync service until we've populated the bookmark model.
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+
+ WriteTestDataToBookmarkModel();
+
+ // Restart the profile sync service. This should trigger a merge step
+ // during initialization -- we expect the browser bookmarks to be written
+ // to the sync service during this call.
+ StartSyncService();
+
+ // 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(ProfileSyncServiceTestWithData, MergeWithEmptyBookmarkModel) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ WriteTestDataToBookmarkModel();
+
+ ExpectModelMatch();
+
+ // Force the sync service to shut down and write itself to disk.
+ StopSyncService(SAVE_TO_STORAGE);
+
+ // Blow away the bookmark model -- it should be empty afterwards.
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ EXPECT_EQ(model_->GetBookmarkBarNode()->GetChildCount(), 0);
+ EXPECT_EQ(model_->other_node()->GetChildCount(), 0);
+
+ // Now restart the sync service. Starting it should populate the bookmark
+ // model -- test for consistency.
+ StartSyncService();
+ ExpectBookmarkModelMatchesTestData();
+ ExpectModelMatch();
+}
+
+// Tests the merge cases when both the models are expected to be identical
+// after the merge.
+TEST_F(ProfileSyncServiceTestWithData, MergeExpectedIdenticalModels) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+ WriteTestDataToBookmarkModel();
+ ExpectModelMatch();
+ StopSyncService(SAVE_TO_STORAGE);
+
+ // 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);
+ StartSyncService();
+ ExpectBookmarkModelMatchesTestData();
+ ExpectModelMatch();
+ StopSyncService(SAVE_TO_STORAGE);
+
+ // 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_->GetBookmarkBarNode();
+ ASSERT_TRUE(bookmark_bar);
+ ASSERT_GT(bookmark_bar->GetChildCount(), 1);
+ model_->Move(bookmark_bar->GetChild(0), bookmark_bar, 1);
+ StartSyncService();
+ ExpectModelMatch();
+ ExpectBookmarkModelMatchesTestData();
+}
+
+// Tests the merge cases when both the models are expected to be identical
+// after the merge.
+TEST_F(ProfileSyncServiceTestWithData, MergeModelsWithSomeExtras) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ WriteTestDataToBookmarkModel();
+ ExpectBookmarkModelMatchesTestData();
+
+ // Remove some nodes and reorder some nodes.
+ const BookmarkNode* bookmark_bar_node = model_->GetBookmarkBarNode();
+ int remove_index = 2;
+ ASSERT_GT(bookmark_bar_node->GetChildCount(), 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, remove_index);
+ ASSERT_GT(bookmark_bar_node->GetChildCount(), 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, remove_index);
+
+ const BookmarkNode* other_node = model_->other_node();
+ ASSERT_GE(other_node->GetChildCount(), 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->GetChildCount(), remove_index);
+ model_->Remove(f3_node, remove_index);
+ ASSERT_GT(f3_node->GetChildCount(), remove_index);
+ model_->Remove(f3_node, remove_index);
+
+ StartSyncService();
+ ExpectModelMatch();
+ StopSyncService(SAVE_TO_STORAGE);
+
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ WriteTestDataToBookmarkModel();
+ ExpectBookmarkModelMatchesTestData();
+
+ // Remove some nodes and reorder some nodes.
+ bookmark_bar_node = model_->GetBookmarkBarNode();
+ remove_index = 0;
+ ASSERT_GT(bookmark_bar_node->GetChildCount(), 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, remove_index);
+ ASSERT_GT(bookmark_bar_node->GetChildCount(), 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, remove_index);
+
+ ASSERT_GE(bookmark_bar_node->GetChildCount(), 2);
+ model_->Move(bookmark_bar_node->GetChild(0), bookmark_bar_node, 1);
+
+ other_node = model_->other_node();
+ ASSERT_GE(other_node->GetChildCount(), 1);
+ f3_node = other_node->GetChild(0);
+ ASSERT_TRUE(f3_node);
+ ASSERT_TRUE(f3_node->is_folder());
+ remove_index = 0;
+ ASSERT_GT(f3_node->GetChildCount(), remove_index);
+ model_->Remove(f3_node, remove_index);
+ ASSERT_GT(f3_node->GetChildCount(), remove_index);
+ model_->Remove(f3_node, remove_index);
+
+ ASSERT_GE(other_node->GetChildCount(), 4);
+ model_->Move(other_node->GetChild(0), other_node, 1);
+ model_->Move(other_node->GetChild(2), other_node, 3);
+
+ StartSyncService();
+ ExpectModelMatch();
+
+ // After the merge, the model should match the test data.
+ ExpectBookmarkModelMatchesTestData();
+}
+
+// Tests that when persisted model assocations are used, things work fine.
+TEST_F(ProfileSyncServiceTestWithData, ModelAssociationPersistence) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ WriteTestDataToBookmarkModel();
+ StartSyncService();
+ ExpectModelMatch();
+ // Force the sync service to shut down and write itself to disk.
+ StopSyncService(SAVE_TO_STORAGE);
+ // Now restart the sync service. This time it should use the persistent
+ // assocations.
+ StartSyncService();
+ ExpectModelMatch();
+}
+
+TEST_F(ProfileSyncServiceTestWithData, SortChildren) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, DONT_SAVE_TO_STORAGE);
+ StartSyncService();
+
+ // 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 hte models match.
+ model_->SortChildren(folder_added);
+ ExpectModelMatch();
+}
+
+// See what happens if we enable sync but then delete the "Sync Data"
+// folder.
+TEST_F(ProfileSyncServiceTestWithData, RecoverAfterDeletingSyncDataDirectory) {
+ LoadBookmarkModel(DELETE_EXISTING_STORAGE, SAVE_TO_STORAGE);
+ StartSyncService();
+
+ WriteTestDataToBookmarkModel();
+
+ // While the service is running.
+ FilePath sync_data_directory = backend()->sync_data_folder_path();
+
+ // Simulate a normal shutdown for the sync service (don't disable it for
+ // the user, which would reset the preferences and delete the sync data
+ // directory).
+ StopSyncService(SAVE_TO_STORAGE);
+
+ // Now pretend that the user has deleted this directory from the disk.
+ file_util::Delete(sync_data_directory, true);
+
+ // Restart the sync service.
+ StartSyncService();
+
+ // 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();
+}
+
+#endif // CHROME_PERSONALIZATION