Index: sync/test/engine/single_type_mock_server.cc |
diff --git a/sync/test/engine/single_type_mock_server.cc b/sync/test/engine/single_type_mock_server.cc |
deleted file mode 100644 |
index 6c0b5cdb34fbdf8e2ea7e5fe6d10fbe04022f24d..0000000000000000000000000000000000000000 |
--- a/sync/test/engine/single_type_mock_server.cc |
+++ /dev/null |
@@ -1,182 +0,0 @@ |
-// 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/test/engine/single_type_mock_server.h" |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include "sync/util/time.h" |
- |
-using google::protobuf::RepeatedPtrField; |
- |
-namespace syncer { |
- |
-SingleTypeMockServer::SingleTypeMockServer(syncer::ModelType type) |
- : type_(type), type_root_id_(ModelTypeToRootTag(type)) { |
-} |
- |
-SingleTypeMockServer::~SingleTypeMockServer() { |
-} |
- |
-sync_pb::SyncEntity SingleTypeMockServer::TypeRootUpdate() { |
- sync_pb::SyncEntity entity; |
- |
- entity.set_id_string(type_root_id_); |
- entity.set_parent_id_string("r"); |
- entity.set_version(1000); |
- entity.set_ctime(TimeToProtoTime(base::Time::UnixEpoch())); |
- entity.set_mtime(TimeToProtoTime(base::Time::UnixEpoch())); |
- entity.set_server_defined_unique_tag(ModelTypeToRootTag(type_)); |
- entity.set_deleted(false); |
- AddDefaultFieldValue(type_, entity.mutable_specifics()); |
- |
- return entity; |
-} |
- |
-sync_pb::SyncEntity SingleTypeMockServer::UpdateFromServer( |
- int64_t version_offset, |
- const std::string& tag_hash, |
- const sync_pb::EntitySpecifics& specifics) { |
- int64_t old_version = GetServerVersion(tag_hash); |
- int64_t version = old_version + version_offset; |
- if (version > old_version) { |
- SetServerVersion(tag_hash, version); |
- } |
- |
- sync_pb::SyncEntity entity; |
- |
- entity.set_id_string(GenerateId(tag_hash)); |
- entity.set_parent_id_string(type_root_id_); |
- entity.set_version(version); |
- entity.set_client_defined_unique_tag(tag_hash); |
- entity.set_deleted(false); |
- entity.mutable_specifics()->CopyFrom(specifics); |
- |
- // Unimportant fields, set for completeness only. |
- base::Time ctime = base::Time::UnixEpoch() + base::TimeDelta::FromDays(1); |
- base::Time mtime = ctime + base::TimeDelta::FromSeconds(version); |
- entity.set_ctime(TimeToProtoTime(ctime)); |
- entity.set_mtime(TimeToProtoTime(mtime)); |
- entity.set_name("Name: " + tag_hash); |
- |
- return entity; |
-} |
- |
-sync_pb::SyncEntity SingleTypeMockServer::TombstoneFromServer( |
- int64_t version_offset, |
- const std::string& tag_hash) { |
- int64_t old_version = GetServerVersion(tag_hash); |
- int64_t version = old_version + version_offset; |
- if (version > old_version) { |
- SetServerVersion(tag_hash, version); |
- } |
- |
- sync_pb::SyncEntity entity; |
- |
- entity.set_id_string(GenerateId(tag_hash)); |
- entity.set_parent_id_string(type_root_id_); |
- entity.set_version(version); |
- entity.set_client_defined_unique_tag(tag_hash); |
- entity.set_deleted(false); |
- AddDefaultFieldValue(type_, entity.mutable_specifics()); |
- |
- // Unimportant fields, set for completeness only. |
- base::Time ctime = base::Time::UnixEpoch() + base::TimeDelta::FromDays(1); |
- base::Time mtime = ctime + base::TimeDelta::FromSeconds(version); |
- entity.set_ctime(TimeToProtoTime(ctime)); |
- entity.set_mtime(TimeToProtoTime(mtime)); |
- entity.set_name("Tombstone"); |
- |
- return entity; |
-} |
- |
-sync_pb::ClientToServerResponse SingleTypeMockServer::DoSuccessfulCommit( |
- const sync_pb::ClientToServerMessage& message) { |
- commit_messages_.push_back(message); |
- |
- sync_pb::ClientToServerResponse response; |
- sync_pb::CommitResponse* commit_response = response.mutable_commit(); |
- |
- const RepeatedPtrField<sync_pb::SyncEntity>& entries = |
- message.commit().entries(); |
- for (RepeatedPtrField<sync_pb::SyncEntity>::const_iterator it = |
- entries.begin(); |
- it != entries.end(); |
- ++it) { |
- const std::string tag_hash = it->client_defined_unique_tag(); |
- |
- committed_items_[tag_hash] = *it; |
- |
- // Every commit increments the version number. |
- int64_t version = GetServerVersion(tag_hash); |
- version++; |
- SetServerVersion(tag_hash, version); |
- |
- sync_pb::CommitResponse_EntryResponse* entryresponse = |
- commit_response->add_entryresponse(); |
- entryresponse->set_response_type(sync_pb::CommitResponse::SUCCESS); |
- entryresponse->set_id_string(GenerateId(tag_hash)); |
- entryresponse->set_parent_id_string(it->parent_id_string()); |
- entryresponse->set_version(version); |
- entryresponse->set_name(it->name()); |
- entryresponse->set_mtime(it->mtime()); |
- } |
- |
- return response; |
-} |
- |
-size_t SingleTypeMockServer::GetNumCommitMessages() const { |
- return commit_messages_.size(); |
-} |
- |
-sync_pb::ClientToServerMessage SingleTypeMockServer::GetNthCommitMessage( |
- size_t n) const { |
- DCHECK_LT(n, GetNumCommitMessages()); |
- return commit_messages_[n]; |
-} |
- |
-bool SingleTypeMockServer::HasCommitEntity(const std::string& tag_hash) const { |
- return committed_items_.find(tag_hash) != committed_items_.end(); |
-} |
- |
-sync_pb::SyncEntity SingleTypeMockServer::GetLastCommittedEntity( |
- const std::string& tag_hash) const { |
- DCHECK(HasCommitEntity(tag_hash)); |
- return committed_items_.find(tag_hash)->second; |
-} |
- |
-sync_pb::DataTypeProgressMarker SingleTypeMockServer::GetProgress() const { |
- sync_pb::DataTypeProgressMarker progress; |
- progress.set_data_type_id(type_); |
- progress.set_token("non_null_progress_token"); |
- return progress; |
-} |
- |
-sync_pb::DataTypeContext SingleTypeMockServer::GetContext() const { |
- return sync_pb::DataTypeContext(); |
-} |
- |
-std::string SingleTypeMockServer::GenerateId(const std::string& tag_hash) { |
- return "FakeId:" + tag_hash; |
-} |
- |
-int64_t SingleTypeMockServer::GetServerVersion( |
- const std::string& tag_hash) const { |
- std::map<const std::string, int64_t>::const_iterator it; |
- it = server_versions_.find(tag_hash); |
- // Server versions do not necessarily start at 1 or 0. |
- if (it == server_versions_.end()) { |
- return 2048; |
- } else { |
- return it->second; |
- } |
-} |
- |
-void SingleTypeMockServer::SetServerVersion(const std::string& tag_hash, |
- int64_t version) { |
- server_versions_[tag_hash] = version; |
-} |
- |
-} // namespace syncer |