diff options
Diffstat (limited to 'sync/engine/sync_thread_sync_entity_unittest.cc')
| -rw-r--r-- | sync/engine/sync_thread_sync_entity_unittest.cc | 164 |
1 files changed, 164 insertions, 0 deletions
diff --git a/sync/engine/sync_thread_sync_entity_unittest.cc b/sync/engine/sync_thread_sync_entity_unittest.cc new file mode 100644 index 0000000..be2604b --- /dev/null +++ b/sync/engine/sync_thread_sync_entity_unittest.cc @@ -0,0 +1,164 @@ + +// Copyright 2014 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. + +#include "sync/engine/sync_thread_sync_entity.h" + +#include "base/memory/scoped_ptr.h" +#include "base/time/time.h" +#include "sync/internal_api/public/base/model_type.h" +#include "sync/syncable/syncable_util.h" +#include "sync/util/time.h" +#include "testing/gtest/include/gtest/gtest.h" + +namespace syncer { + +// Some simple tests for the SyncThreadSyncEntity. +// +// The SyncThreadSyncEntity is an implementation detail of the +// NonBlockingTypeProcessorCore. As such, it doesn't make much sense to test +// it exhaustively, since it already gets a lot of test coverage from the +// NonBlockingTypeProcessorCore unit tests. +// +// These tests are intended as a basic sanity check. Anything more complicated +// would be redundant. +class SyncThreadSyncEntityTest : public ::testing::Test { + public: + SyncThreadSyncEntityTest() + : kServerId("ServerID"), + kClientTag("some.sample.tag"), + kClientTagHash(syncable::GenerateSyncableHash(PREFERENCES, kClientTag)), + kCtime(base::Time::UnixEpoch() + base::TimeDelta::FromDays(10)), + kMtime(base::Time::UnixEpoch() + base::TimeDelta::FromDays(20)) { + specifics.mutable_preference()->set_name(kClientTag); + specifics.mutable_preference()->set_value("pref.value"); + } + + virtual ~SyncThreadSyncEntityTest() {} + + const std::string kServerId; + const std::string kClientTag; + const std::string kClientTagHash; + const base::Time kCtime; + const base::Time kMtime; + sync_pb::EntitySpecifics specifics; +}; + +// Construct a new entity from a server update. Then receive another update. +TEST_F(SyncThreadSyncEntityTest, FromServerUpdate) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromServerUpdate(kServerId, kClientTagHash, 10)); + EXPECT_FALSE(entity->IsCommitPending()); + + entity->ReceiveUpdate(20); + EXPECT_FALSE(entity->IsCommitPending()); +} + +// Construct a new entity from a commit request. Then serialize it. +TEST_F(SyncThreadSyncEntityTest, FromCommitRequest) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromCommitRequest(kServerId, + kClientTagHash, + 22, + 33, + kCtime, + kMtime, + kClientTag, + false, + specifics)); + + ASSERT_TRUE(entity->IsCommitPending()); + sync_pb::SyncEntity pb_entity; + int64 sequence_number = 0; + entity->PrepareCommitProto(&pb_entity, &sequence_number); + EXPECT_EQ(22, sequence_number); + EXPECT_EQ(kServerId, pb_entity.id_string()); + EXPECT_EQ(kClientTagHash, pb_entity.client_defined_unique_tag()); + EXPECT_EQ(33, pb_entity.version()); + EXPECT_EQ(kCtime, ProtoTimeToTime(pb_entity.ctime())); + EXPECT_EQ(kMtime, ProtoTimeToTime(pb_entity.mtime())); + EXPECT_FALSE(pb_entity.deleted()); + EXPECT_EQ(specifics.preference().name(), + pb_entity.specifics().preference().name()); + EXPECT_EQ(specifics.preference().value(), + pb_entity.specifics().preference().value()); +} + +// Start with a server initiated entity. Commit over top of it. +TEST_F(SyncThreadSyncEntityTest, RequestCommit) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromServerUpdate(kServerId, kClientTagHash, 10)); + + entity->RequestCommit(kServerId, + kClientTagHash, + 1, + 10, + kCtime, + kMtime, + kClientTag, + false, + specifics); + + EXPECT_TRUE(entity->IsCommitPending()); +} + +// Start with a server initiated entity. Fail to request a commit because of +// an out of date base version. +TEST_F(SyncThreadSyncEntityTest, RequestCommitFailure) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromServerUpdate(kServerId, kClientTagHash, 10)); + EXPECT_FALSE(entity->IsCommitPending()); + + entity->RequestCommit(kServerId, + kClientTagHash, + 23, + 5, // Version 5 < 10 + kCtime, + kMtime, + kClientTag, + false, + specifics); + EXPECT_FALSE(entity->IsCommitPending()); +} + +// Start with a pending commit. Clobber it with an incoming update. +TEST_F(SyncThreadSyncEntityTest, UpdateClobbersCommit) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromCommitRequest(kServerId, + kClientTagHash, + 22, + 33, + kCtime, + kMtime, + kClientTag, + false, + specifics)); + + EXPECT_TRUE(entity->IsCommitPending()); + + entity->ReceiveUpdate(400); // Version 400 > 33. + EXPECT_FALSE(entity->IsCommitPending()); +} + +// Start with a pending commit. Send it a reflected update that +// will not override the in-progress commit. +TEST_F(SyncThreadSyncEntityTest, ReflectedUpdateDoesntClobberCommit) { + scoped_ptr<SyncThreadSyncEntity> entity( + SyncThreadSyncEntity::FromCommitRequest(kServerId, + kClientTagHash, + 22, + 33, + kCtime, + kMtime, + kClientTag, + false, + specifics)); + + EXPECT_TRUE(entity->IsCommitPending()); + + entity->ReceiveUpdate(33); // Version 33 == 33. + EXPECT_TRUE(entity->IsCommitPending()); +} + +} // namespace syncer |