text: 
  // 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
  