Index: sync/internal_api/processor_entity_tracker_unittest.cc |
diff --git a/sync/internal_api/processor_entity_tracker_unittest.cc b/sync/internal_api/processor_entity_tracker_unittest.cc |
index 9b8c5e29f575612e21639399baf04b7f2a1b9a23..5265c90e7ace654b228feead119af0b8819780e4 100644 |
--- a/sync/internal_api/processor_entity_tracker_unittest.cc |
+++ b/sync/internal_api/processor_entity_tracker_unittest.cc |
@@ -19,6 +19,29 @@ |
namespace syncer_v2 { |
+namespace { |
+ |
+const std::string kTag1 = "tag1"; |
+const std::string kTag2 = "tag2"; |
+const std::string kTag3 = "tag3"; |
+const std::string kValue1 = "value1"; |
+const std::string kValue2 = "value2"; |
+const std::string kValue3 = "value3"; |
+ |
+std::string GenerateTagHash(const std::string& tag) { |
+ return syncer::syncable::GenerateSyncableHash(syncer::PREFERENCES, tag); |
+} |
+ |
+sync_pb::EntitySpecifics GenerateSpecifics(const std::string& tag, |
+ const std::string& value) { |
+ sync_pb::EntitySpecifics specifics; |
+ specifics.mutable_preference()->set_name(tag); |
+ specifics.mutable_preference()->set_value(value); |
+ return specifics; |
+} |
+ |
+} // namespace |
+ |
// Some simple sanity tests for the ProcessorEntityTracker. |
// |
// A lot of the more complicated sync logic is implemented in the |
@@ -33,22 +56,14 @@ class ProcessorEntityTrackerTest : public ::testing::Test { |
ProcessorEntityTrackerTest() |
: kServerId("ServerID"), |
kClientTag("sample.pref.name"), |
- kClientTagHash(GetSyncableHash(kClientTag)), |
+ kClientTagHash(GenerateTagHash(kClientTag)), |
kCtime(base::Time::UnixEpoch() + base::TimeDelta::FromDays(10)), |
- kMtime(base::Time::UnixEpoch() + base::TimeDelta::FromDays(20)) { |
- sync_pb::PreferenceSpecifics* pref_specifics = |
- specifics.mutable_preference(); |
- pref_specifics->set_name(kClientTag); |
- pref_specifics->set_value("pref.value"); |
- } |
- |
- static std::string GetSyncableHash(const std::string& tag) { |
- return syncer::syncable::GenerateSyncableHash(syncer::PREFERENCES, tag); |
- } |
+ kMtime(base::Time::UnixEpoch() + base::TimeDelta::FromDays(20)), |
+ specifics(GenerateSpecifics(kClientTag, kValue1)) {} |
std::unique_ptr<ProcessorEntityTracker> NewLocalItem(const std::string& tag) { |
return std::unique_ptr<ProcessorEntityTracker>( |
- ProcessorEntityTracker::CreateNew(tag, GetSyncableHash(tag), "", |
+ ProcessorEntityTracker::CreateNew(tag, GenerateTagHash(tag), "", |
kCtime)); |
} |
@@ -125,7 +140,7 @@ TEST_F(ProcessorEntityTrackerTest, NewItem) { |
std::unique_ptr<ProcessorEntityTracker> entity(NewLocalItem("asdf")); |
EXPECT_EQ(entity->client_tag(), "asdf"); |
- EXPECT_EQ(entity->metadata().client_tag_hash(), GetSyncableHash("asdf")); |
+ EXPECT_EQ(entity->metadata().client_tag_hash(), GenerateTagHash("asdf")); |
EXPECT_FALSE(entity->HasCommitData()); |
EXPECT_FALSE(HasSpecificsHash(entity)); |
@@ -146,13 +161,20 @@ TEST_F(ProcessorEntityTrackerTest, NewLocalItem) { |
EXPECT_TRUE(entity->IsUnsynced()); |
EXPECT_FALSE(entity->UpdateIsReflection(1)); |
- entity->ReceiveCommitResponse("id", 1, 1); |
+ CommitResponseData data; |
+ data.id = "id"; |
+ data.client_tag_hash = entity->metadata().client_tag_hash(); |
+ data.sequence_number = 1; |
+ data.response_version = 1; |
+ data.specifics_hash = entity->metadata().specifics_hash(); |
+ entity->ReceiveCommitResponse(data); |
EXPECT_EQ(1, entity->metadata().sequence_number()); |
EXPECT_EQ(1, entity->metadata().acked_sequence_number()); |
EXPECT_EQ(1, entity->metadata().server_version()); |
EXPECT_FALSE(entity->HasCommitData()); |
EXPECT_TRUE(HasSpecificsHash(entity)); |
+ EXPECT_TRUE(entity->metadata().base_specifics_hash().empty()); |
EXPECT_FALSE(entity->IsUnsynced()); |
EXPECT_TRUE(entity->UpdateIsReflection(1)); |
} |