Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(139)

Unified Diff: sync/test/engine/mock_model_type_worker.cc

Issue 2130453004: [Sync] Move //sync to //components/sync. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sync/test/engine/mock_model_type_worker.h ('k') | sync/test/engine/mock_nudge_handler.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/test/engine/mock_model_type_worker.cc
diff --git a/sync/test/engine/mock_model_type_worker.cc b/sync/test/engine/mock_model_type_worker.cc
deleted file mode 100644
index fd0866738d763b1c8516e682f304ae65ff2cd302..0000000000000000000000000000000000000000
--- a/sync/test/engine/mock_model_type_worker.cc
+++ /dev/null
@@ -1,251 +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/mock_model_type_worker.h"
-
-#include <stddef.h>
-#include <stdint.h>
-
-#include "base/logging.h"
-#include "sync/internal_api/public/base/model_type.h"
-#include "sync/syncable/syncable_util.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace syncer_v2 {
-
-namespace {
-
-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
-
-MockModelTypeWorker::MockModelTypeWorker(
- const sync_pb::DataTypeState& data_type_state,
- ModelTypeProcessor* processor)
- : data_type_state_(data_type_state), processor_(processor) {}
-
-MockModelTypeWorker::~MockModelTypeWorker() {}
-
-void MockModelTypeWorker::EnqueueForCommit(const CommitRequestDataList& list) {
- pending_commits_.push_back(list);
-}
-
-size_t MockModelTypeWorker::GetNumPendingCommits() const {
- return pending_commits_.size();
-}
-
-CommitRequestDataList MockModelTypeWorker::GetNthPendingCommit(size_t n) const {
- DCHECK_LT(n, GetNumPendingCommits());
- return pending_commits_[n];
-}
-
-bool MockModelTypeWorker::HasPendingCommitForTag(const std::string& tag) const {
- const std::string tag_hash = GenerateTagHash(tag);
- for (const CommitRequestDataList& commit : pending_commits_) {
- for (const CommitRequestData& data : commit) {
- if (data.entity->client_tag_hash == tag_hash) {
- return true;
- }
- }
- }
- return false;
-}
-
-CommitRequestData MockModelTypeWorker::GetLatestPendingCommitForTag(
- const std::string& tag) const {
- const std::string tag_hash = GenerateTagHash(tag);
- // Iterate backward through the sets of commit requests to find the most
- // recent one that applies to the specified tag_hash.
- for (auto rev_it = pending_commits_.rbegin();
- rev_it != pending_commits_.rend(); ++rev_it) {
- for (const CommitRequestData& data : *rev_it) {
- if (data.entity->client_tag_hash == tag_hash) {
- return data;
- }
- }
- }
- NOTREACHED() << "Could not find commit for tag hash " << tag_hash << ".";
- return CommitRequestData();
-}
-
-void MockModelTypeWorker::ExpectNthPendingCommit(size_t n,
- const std::string& tag,
- const std::string& value) {
- const CommitRequestDataList& list = GetNthPendingCommit(n);
- ASSERT_EQ(1U, list.size());
- const EntityData& data = list[0].entity.value();
- EXPECT_EQ(GenerateTagHash(tag), data.client_tag_hash);
- EXPECT_EQ(value, data.specifics.preference().value());
-}
-
-void MockModelTypeWorker::ExpectPendingCommits(
- const std::vector<std::string>& tags) {
- EXPECT_EQ(tags.size(), GetNumPendingCommits());
- for (size_t i = 0; i < tags.size(); i++) {
- const CommitRequestDataList& commits = GetNthPendingCommit(i);
- EXPECT_EQ(1U, commits.size());
- EXPECT_EQ(GenerateTagHash(tags[i]), commits[0].entity->client_tag_hash)
- << "Hash for tag " << tags[i] << " doesn't match.";
- }
-}
-
-void MockModelTypeWorker::UpdateFromServer(const std::string& tag,
- const std::string& value) {
- UpdateFromServer(tag, value, 1);
-}
-
-void MockModelTypeWorker::UpdateFromServer(const std::string& tag,
- const std::string& value,
- int64_t version_offset) {
- UpdateFromServer(tag, value, version_offset,
- data_type_state_.encryption_key_name());
-}
-
-void MockModelTypeWorker::UpdateFromServer(const std::string& tag,
- const std::string& value,
- int64_t version_offset,
- const std::string& ekn) {
- UpdateResponseDataList update;
- update.push_back(GenerateUpdateData(tag, value, version_offset, ekn));
- processor_->OnUpdateReceived(data_type_state_, update);
-}
-
-UpdateResponseData MockModelTypeWorker::GenerateUpdateData(
- const std::string& tag,
- const std::string& value,
- int64_t version_offset,
- const std::string& ekn) {
- const std::string tag_hash = GenerateTagHash(tag);
- // Overwrite the existing server version if this is the new highest version.
- int64_t old_version = GetServerVersion(tag_hash);
- int64_t version = old_version + version_offset;
- if (version > old_version) {
- SetServerVersion(tag_hash, version);
- }
-
- EntityData data;
- data.id = GenerateId(tag_hash);
- data.client_tag_hash = tag_hash;
- data.specifics = GenerateSpecifics(tag, value);
- // These elements should have no effect on behavior, but we set them anyway
- // so we can test they are properly copied around the system if we want to.
- data.creation_time = base::Time::UnixEpoch() + base::TimeDelta::FromDays(1);
- data.modification_time =
- data.creation_time + base::TimeDelta::FromSeconds(version);
- data.non_unique_name = data.specifics.preference().name();
-
- UpdateResponseData response_data;
- response_data.entity = data.PassToPtr();
- response_data.response_version = version;
- response_data.encryption_key_name = ekn;
-
- return response_data;
-}
-
-void MockModelTypeWorker::TombstoneFromServer(const std::string& tag) {
- const std::string tag_hash = GenerateTagHash(tag);
- int64_t old_version = GetServerVersion(tag_hash);
- int64_t version = old_version + 1;
- SetServerVersion(tag_hash, version);
-
- EntityData data;
- data.id = GenerateId(tag_hash);
- data.client_tag_hash = tag_hash;
- // These elements should have no effect on behavior, but we set them anyway
- // so we can test they are properly copied around the system if we want to.
- data.creation_time = base::Time::UnixEpoch() + base::TimeDelta::FromDays(1);
- data.modification_time =
- data.creation_time + base::TimeDelta::FromSeconds(version);
- data.non_unique_name = "Name Non Unique";
-
- UpdateResponseData response_data;
- response_data.entity = data.PassToPtr();
- response_data.response_version = version;
- response_data.encryption_key_name = data_type_state_.encryption_key_name();
-
- UpdateResponseDataList list;
- list.push_back(response_data);
- processor_->OnUpdateReceived(data_type_state_, list);
-}
-
-void MockModelTypeWorker::AckOnePendingCommit() {
- CommitResponseDataList list;
- for (const CommitRequestData& data : pending_commits_.front()) {
- list.push_back(SuccessfulCommitResponse(data));
- }
- pending_commits_.pop_front();
- processor_->OnCommitCompleted(data_type_state_, list);
-}
-
-CommitResponseData MockModelTypeWorker::SuccessfulCommitResponse(
- const CommitRequestData& request_data) {
- const EntityData& entity = request_data.entity.value();
- const std::string& client_tag_hash = entity.client_tag_hash;
-
- CommitResponseData response_data;
-
- if (request_data.base_version == 0) {
- // Server assigns new ID to newly committed items.
- DCHECK(entity.id.empty());
- response_data.id = entity.id;
- } else {
- // Otherwise we reuse the ID from the request.
- response_data.id = GenerateId(client_tag_hash);
- }
-
- response_data.client_tag_hash = client_tag_hash;
- response_data.sequence_number = request_data.sequence_number;
- response_data.specifics_hash = request_data.specifics_hash;
-
- // Increment the server version on successful commit.
- int64_t version = GetServerVersion(client_tag_hash);
- version++;
- SetServerVersion(client_tag_hash, version);
-
- response_data.response_version = version;
-
- return response_data;
-}
-
-void MockModelTypeWorker::UpdateWithEncryptionKey(const std::string& ekn) {
- UpdateWithEncryptionKey(ekn, UpdateResponseDataList());
-}
-
-void MockModelTypeWorker::UpdateWithEncryptionKey(
- const std::string& ekn,
- const UpdateResponseDataList& update) {
- data_type_state_.set_encryption_key_name(ekn);
- processor_->OnUpdateReceived(data_type_state_, update);
-}
-
-std::string MockModelTypeWorker::GenerateId(const std::string& tag_hash) {
- return "FakeId:" + tag_hash;
-}
-
-int64_t MockModelTypeWorker::GetServerVersion(const std::string& tag_hash) {
- std::map<const std::string, int64_t>::const_iterator it;
- it = server_versions_.find(tag_hash);
- if (it == server_versions_.end()) {
- return 0;
- } else {
- return it->second;
- }
-}
-
-void MockModelTypeWorker::SetServerVersion(const std::string& tag_hash,
- int64_t version) {
- server_versions_[tag_hash] = version;
-}
-
-} // namespace syncer_v2
« no previous file with comments | « sync/test/engine/mock_model_type_worker.h ('k') | sync/test/engine/mock_nudge_handler.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698