| Index: sync/test/engine/mock_model_type_worker.h
|
| diff --git a/sync/test/engine/mock_model_type_worker.h b/sync/test/engine/mock_model_type_worker.h
|
| deleted file mode 100644
|
| index b8499cf07ecec3b4dcdf8e392ef34ed7b3b99423..0000000000000000000000000000000000000000
|
| --- a/sync/test/engine/mock_model_type_worker.h
|
| +++ /dev/null
|
| @@ -1,123 +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.
|
| -
|
| -#ifndef SYNC_TEST_ENGINE_MOCK_MODEL_TYPE_WORKER_H_
|
| -#define SYNC_TEST_ENGINE_MOCK_MODEL_TYPE_WORKER_H_
|
| -
|
| -#include <stddef.h>
|
| -#include <stdint.h>
|
| -
|
| -#include <deque>
|
| -#include <map>
|
| -#include <string>
|
| -#include <vector>
|
| -
|
| -#include "base/macros.h"
|
| -#include "sync/engine/commit_queue.h"
|
| -#include "sync/internal_api/public/model_type_processor.h"
|
| -#include "sync/internal_api/public/non_blocking_sync_common.h"
|
| -#include "sync/protocol/data_type_state.pb.h"
|
| -
|
| -namespace syncer_v2 {
|
| -
|
| -// Receives and records commit requests sent through the ModelTypeWorker.
|
| -//
|
| -// This class also includes features intended to help mock out server behavior.
|
| -// It has some basic functionality to keep track of server state and generate
|
| -// plausible UpdateResponseData and CommitResponseData messages.
|
| -class MockModelTypeWorker : public CommitQueue {
|
| - public:
|
| - MockModelTypeWorker(const sync_pb::DataTypeState& data_type_state,
|
| - ModelTypeProcessor* processor);
|
| - ~MockModelTypeWorker() override;
|
| -
|
| - // Implementation of ModelTypeWorker.
|
| - void EnqueueForCommit(const CommitRequestDataList& list) override;
|
| -
|
| - // Getters to inspect the requests sent to this object.
|
| - size_t GetNumPendingCommits() const;
|
| - CommitRequestDataList GetNthPendingCommit(size_t n) const;
|
| - bool HasPendingCommitForTag(const std::string& tag) const;
|
| - CommitRequestData GetLatestPendingCommitForTag(const std::string& tag) const;
|
| -
|
| - // Expect that the |n|th commit request list has one commit request for |tag|
|
| - // with |value| set.
|
| - void ExpectNthPendingCommit(size_t n,
|
| - const std::string& tag,
|
| - const std::string& value);
|
| -
|
| - // For each tag in |tags|, expect a corresponding request list of length one.
|
| - void ExpectPendingCommits(const std::vector<std::string>& tags);
|
| -
|
| - // Trigger an update from the server containing a single entity. See
|
| - // GenerateUpdateData for parameter descriptions. |version_offset| defaults to
|
| - // 1 and |ekn| defaults to the current encryption key name the worker has.
|
| - void UpdateFromServer(const std::string& tag, const std::string& value);
|
| - void UpdateFromServer(const std::string& tag,
|
| - const std::string& value,
|
| - int64_t version_offset);
|
| - void UpdateFromServer(const std::string& tag,
|
| - const std::string& value,
|
| - int64_t version_offset,
|
| - const std::string& ekn);
|
| -
|
| - // Returns an UpdateResponseData representing an update received from
|
| - // the server. Updates server state accordingly. |tag| is used to generate the
|
| - // tag hash and the specifics along with |value|.
|
| - //
|
| - // The |version_offset| field can be used to emulate stale data (ie. versions
|
| - // going backwards), reflections and redeliveries (ie. several instances of
|
| - // the same version) or new updates.
|
| - //
|
| - // |ekn| is the encryption key name this item will fake having.
|
| - UpdateResponseData GenerateUpdateData(const std::string& tag,
|
| - const std::string& value,
|
| - int64_t version_offset,
|
| - const std::string& ekn);
|
| -
|
| - // Triggers a server-side deletion of the entity with |tag|; updates server
|
| - // state accordingly.
|
| - void TombstoneFromServer(const std::string& tag);
|
| -
|
| - // Pops one pending commit from the front of the queue and send a commit
|
| - // response to the processor for it.
|
| - void AckOnePendingCommit();
|
| -
|
| - // Set the encryption key to |ekn| and inform the processor with an update
|
| - // containing the data in |update|, which defaults to an empty list.
|
| - void UpdateWithEncryptionKey(const std::string& ekn);
|
| - void UpdateWithEncryptionKey(const std::string& ekn,
|
| - const UpdateResponseDataList& update);
|
| -
|
| - private:
|
| - // Generate an ID string.
|
| - static std::string GenerateId(const std::string& tag_hash);
|
| -
|
| - // Returns a commit response that indicates a successful commit of the
|
| - // given |request_data|. Updates server state accordingly.
|
| - CommitResponseData SuccessfulCommitResponse(
|
| - const CommitRequestData& request_data);
|
| -
|
| - // Retrieve or set the server version.
|
| - int64_t GetServerVersion(const std::string& tag_hash);
|
| - void SetServerVersion(const std::string& tag_hash, int64_t version);
|
| -
|
| - sync_pb::DataTypeState data_type_state_;
|
| -
|
| - // A pointer to the processor for this mock worker.
|
| - ModelTypeProcessor* processor_;
|
| -
|
| - // A record of past commits requests.
|
| - std::deque<CommitRequestDataList> pending_commits_;
|
| -
|
| - // Map of versions by client tag.
|
| - // This is an essential part of the mocked server state.
|
| - std::map<const std::string, int64_t> server_versions_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(MockModelTypeWorker);
|
| -};
|
| -
|
| -} // namespace syncer_v2
|
| -
|
| -#endif // SYNC_TEST_ENGINE_MOCK_MODEL_TYPE_WORKER_H_
|
|
|