Index: sync/internal_api/sync_manager_impl_unittest.cc |
diff --git a/sync/internal_api/sync_manager_impl_unittest.cc b/sync/internal_api/sync_manager_impl_unittest.cc |
index 20b768529b11a03044b63152fd2ab3363b306f04..a5c0c81001d94974ae23b68f2105faacdb902c9c 100644 |
--- a/sync/internal_api/sync_manager_impl_unittest.cc |
+++ b/sync/internal_api/sync_manager_impl_unittest.cc |
@@ -210,94 +210,22 @@ |
} |
protected: |
- // Create an entry with the given |model_type|, |client_tag| and |
- // |attachment_metadata|. |
- void CreateEntryWithAttachmentMetadata( |
- const ModelType& model_type, |
- const std::string& client_tag, |
- const sync_pb::AttachmentMetadata& attachment_metadata); |
- |
- // Attempts to load the entry specified by |model_type| and |client_tag| and |
- // returns the lookup result code. |
- BaseNode::InitByLookupResult LookupEntryByClientTag( |
- const ModelType& model_type, |
- const std::string& client_tag); |
- |
- // Replace the entry specified by |model_type| and |client_tag| with a |
- // tombstone. |
- void ReplaceWithTombstone(const ModelType& model_type, |
- const std::string& client_tag); |
- |
- // Save changes to the Directory, destroy it then reload it. |
- bool ReloadDir(); |
- |
- UserShare* user_share(); |
- syncable::Directory* dir(); |
- SyncEncryptionHandler* encryption_handler(); |
- |
- private: |
base::MessageLoop message_loop_; |
TestUserShare test_user_share_; |
}; |
-UserShare* SyncApiTest::user_share() { |
- return test_user_share_.user_share(); |
-} |
- |
-syncable::Directory* SyncApiTest::dir() { |
- return test_user_share_.user_share()->directory.get(); |
-} |
- |
-SyncEncryptionHandler* SyncApiTest::encryption_handler() { |
- return test_user_share_.encryption_handler(); |
-} |
- |
-bool SyncApiTest::ReloadDir() { |
- return test_user_share_.Reload(); |
-} |
- |
-void SyncApiTest::CreateEntryWithAttachmentMetadata( |
- const ModelType& model_type, |
- const std::string& client_tag, |
- const sync_pb::AttachmentMetadata& attachment_metadata) { |
- syncer::WriteTransaction trans(FROM_HERE, user_share()); |
- syncer::ReadNode root_node(&trans); |
- root_node.InitByRootLookup(); |
- syncer::WriteNode node(&trans); |
- ASSERT_EQ(node.InitUniqueByCreation(model_type, root_node, client_tag), |
- syncer::WriteNode::INIT_SUCCESS); |
- node.SetAttachmentMetadata(attachment_metadata); |
-} |
- |
-BaseNode::InitByLookupResult SyncApiTest::LookupEntryByClientTag( |
- const ModelType& model_type, |
- const std::string& client_tag) { |
- syncer::ReadTransaction trans(FROM_HERE, user_share()); |
- syncer::ReadNode node(&trans); |
- return node.InitByClientTagLookup(model_type, client_tag); |
-} |
- |
-void SyncApiTest::ReplaceWithTombstone(const ModelType& model_type, |
- const std::string& client_tag) { |
- syncer::WriteTransaction trans(FROM_HERE, user_share()); |
- syncer::WriteNode node(&trans); |
- ASSERT_EQ(node.InitByClientTagLookup(model_type, client_tag), |
- syncer::WriteNode::INIT_OK); |
- node.Tombstone(); |
-} |
- |
TEST_F(SyncApiTest, SanityCheckTest) { |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
EXPECT_TRUE(trans.GetWrappedTrans()); |
} |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
EXPECT_TRUE(trans.GetWrappedTrans()); |
} |
{ |
// No entries but root should exist |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode node(&trans); |
// Metahandle 1 can be root, sanity check 2 |
EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, node.InitByIdLookup(2)); |
@@ -306,16 +234,17 @@ |
TEST_F(SyncApiTest, BasicTagWrite) { |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
EXPECT_EQ(root_node.GetFirstChildId(), 0); |
} |
- ignore_result(MakeNode(user_share(), BOOKMARKS, "testtag")); |
- |
- { |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ignore_result(MakeNode(test_user_share_.user_share(), |
+ BOOKMARKS, "testtag")); |
+ |
+ { |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
node.InitByClientTagLookup(BOOKMARKS, "testtag")); |
@@ -329,18 +258,21 @@ |
TEST_F(SyncApiTest, ModelTypesSiloed) { |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
EXPECT_EQ(root_node.GetFirstChildId(), 0); |
} |
- ignore_result(MakeNode(user_share(), BOOKMARKS, "collideme")); |
- ignore_result(MakeNode(user_share(), PREFERENCES, "collideme")); |
- ignore_result(MakeNode(user_share(), AUTOFILL, "collideme")); |
- |
- { |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ignore_result(MakeNode(test_user_share_.user_share(), |
+ BOOKMARKS, "collideme")); |
+ ignore_result(MakeNode(test_user_share_.user_share(), |
+ PREFERENCES, "collideme")); |
+ ignore_result(MakeNode(test_user_share_.user_share(), |
+ AUTOFILL, "collideme")); |
+ |
+ { |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode bookmarknode(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
@@ -365,14 +297,14 @@ |
TEST_F(SyncApiTest, ReadMissingTagsFails) { |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, |
node.InitByClientTagLookup(BOOKMARKS, |
"testtag")); |
} |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
WriteNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, |
node.InitByClientTagLookup(BOOKMARKS, |
@@ -388,7 +320,7 @@ |
std::string test_title("test1"); |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
@@ -409,7 +341,7 @@ |
// Ensure we can delete something with a tag. |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
WriteNode wnode(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
wnode.InitByClientTagLookup(BOOKMARKS, |
@@ -423,7 +355,7 @@ |
// Lookup of a node which was deleted should return failure, |
// but have found some data about the node. |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_IS_DEL, |
node.InitByClientTagLookup(BOOKMARKS, |
@@ -434,7 +366,7 @@ |
} |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode folder_node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, folder_node.InitByIdLookup(folder_id)); |
@@ -452,7 +384,7 @@ |
// Now look up should work. |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
node.InitByClientTagLookup(BOOKMARKS, |
@@ -465,11 +397,11 @@ |
TEST_F(SyncApiTest, WriteAndReadPassword) { |
KeyParams params = {"localhost", "username", "passphrase"}; |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
trans.GetCryptographer()->AddKey(params); |
} |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
@@ -483,7 +415,7 @@ |
password_node.SetPasswordSpecifics(data); |
} |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
@@ -499,13 +431,13 @@ |
TEST_F(SyncApiTest, WriteEncryptedTitle) { |
KeyParams params = {"localhost", "username", "passphrase"}; |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
trans.GetCryptographer()->AddKey(params); |
} |
- encryption_handler()->EnableEncryptEverything(); |
+ test_user_share_.encryption_handler()->EnableEncryptEverything(); |
int bookmark_id; |
{ |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
@@ -521,7 +453,7 @@ |
pref_node.SetTitle("bar"); |
} |
{ |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
@@ -540,8 +472,9 @@ |
} |
TEST_F(SyncApiTest, BaseNodeSetSpecifics) { |
- int64 child_id = MakeNode(user_share(), BOOKMARKS, "testtag"); |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ int64 child_id = MakeNode(test_user_share_.user_share(), |
+ BOOKMARKS, "testtag"); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
WriteNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); |
@@ -556,8 +489,9 @@ |
} |
TEST_F(SyncApiTest, BaseNodeSetSpecificsPreservesUnknownFields) { |
- int64 child_id = MakeNode(user_share(), BOOKMARKS, "testtag"); |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ int64 child_id = MakeNode(test_user_share_.user_share(), |
+ BOOKMARKS, "testtag"); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
WriteNode node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); |
EXPECT_TRUE(node.GetEntitySpecifics().unknown_fields().empty()); |
@@ -574,7 +508,7 @@ |
} |
TEST_F(SyncApiTest, EmptyTags) { |
- WriteTransaction trans(FROM_HERE, user_share()); |
+ WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode root_node(&trans); |
root_node.InitByRootLookup(); |
WriteNode node(&trans); |
@@ -588,9 +522,10 @@ |
// Test counting nodes when the type's root node has no children. |
TEST_F(SyncApiTest, GetTotalNodeCountEmpty) { |
- int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); |
- { |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
+ BOOKMARKS); |
+ { |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode type_root_node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
type_root_node.InitByIdLookup(type_root)); |
@@ -600,10 +535,14 @@ |
// Test counting nodes when there is one child beneath the type's root. |
TEST_F(SyncApiTest, GetTotalNodeCountOneChild) { |
- int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); |
- int64 parent = MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL); |
- { |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
+ BOOKMARKS); |
+ int64 parent = MakeFolderWithParent(test_user_share_.user_share(), |
+ BOOKMARKS, |
+ type_root, |
+ NULL); |
+ { |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode type_root_node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
type_root_node.InitByIdLookup(type_root)); |
@@ -618,15 +557,32 @@ |
// Test counting nodes when there are multiple children beneath the type root, |
// and one of those children has children of its own. |
TEST_F(SyncApiTest, GetTotalNodeCountMultipleChildren) { |
- int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); |
- int64 parent = MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL); |
- ignore_result(MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL)); |
- int64 child1 = MakeFolderWithParent(user_share(), BOOKMARKS, parent, NULL); |
- ignore_result(MakeBookmarkWithParent(user_share(), parent, NULL)); |
- ignore_result(MakeBookmarkWithParent(user_share(), child1, NULL)); |
- |
- { |
- ReadTransaction trans(FROM_HERE, user_share()); |
+ int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
+ BOOKMARKS); |
+ int64 parent = MakeFolderWithParent(test_user_share_.user_share(), |
+ BOOKMARKS, |
+ type_root, |
+ NULL); |
+ ignore_result(MakeFolderWithParent(test_user_share_.user_share(), |
+ BOOKMARKS, |
+ type_root, |
+ NULL)); |
+ int64 child1 = MakeFolderWithParent( |
+ test_user_share_.user_share(), |
+ BOOKMARKS, |
+ parent, |
+ NULL); |
+ ignore_result(MakeBookmarkWithParent( |
+ test_user_share_.user_share(), |
+ parent, |
+ NULL)); |
+ ignore_result(MakeBookmarkWithParent( |
+ test_user_share_.user_share(), |
+ child1, |
+ NULL)); |
+ |
+ { |
+ ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
ReadNode type_root_node(&trans); |
EXPECT_EQ(BaseNode::INIT_OK, |
type_root_node.InitByIdLookup(type_root)); |
@@ -636,57 +592,6 @@ |
node.InitByIdLookup(parent)); |
EXPECT_EQ(4, node.GetTotalNodeCount()); |
} |
-} |
- |
-// Verify that Directory keeps track of which attachments are referenced by |
-// which entries. |
-TEST_F(SyncApiTest, AttachmentLinking) { |
- // Add an entry with an attachment. |
- std::string tag1("some tag"); |
- syncer::AttachmentId attachment_id(syncer::AttachmentId::Create()); |
- sync_pb::AttachmentMetadata attachment_metadata; |
- sync_pb::AttachmentMetadataRecord* record = attachment_metadata.add_record(); |
- *record->mutable_id() = attachment_id.GetProto(); |
- ASSERT_FALSE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- CreateEntryWithAttachmentMetadata(PREFERENCES, tag1, attachment_metadata); |
- |
- // See that the directory knows it's linked. |
- ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- |
- // Add a second entry referencing the same attachment. |
- std::string tag2("some other tag"); |
- CreateEntryWithAttachmentMetadata(PREFERENCES, tag2, attachment_metadata); |
- |
- // See that the directory knows it's still linked. |
- ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- |
- // Tombstone the first entry. |
- ReplaceWithTombstone(syncer::PREFERENCES, tag1); |
- |
- // See that the attachment is still considered linked because the entry hasn't |
- // been purged from the Directory. |
- ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- |
- // Save changes and see that the entry is truly gone. |
- ASSERT_TRUE(dir()->SaveChanges()); |
- ASSERT_EQ(LookupEntryByClientTag(PREFERENCES, tag1), |
- syncer::WriteNode::INIT_FAILED_ENTRY_NOT_GOOD); |
- |
- // However, the attachment is still linked. |
- ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- |
- // Save, destroy, and recreate the directory. See that it's still linked. |
- ASSERT_TRUE(ReloadDir()); |
- ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
- |
- // Tombstone the second entry, save changes, see that it's truly gone. |
- ReplaceWithTombstone(syncer::PREFERENCES, tag2); |
- ASSERT_TRUE(dir()->SaveChanges()); |
- ASSERT_EQ(LookupEntryByClientTag(PREFERENCES, tag2), |
- syncer::WriteNode::INIT_FAILED_ENTRY_NOT_GOOD); |
- |
- // Finally, the attachment is no longer linked. |
- ASSERT_FALSE(dir()->IsAttachmentLinked(attachment_id.GetProto())); |
} |
namespace { |