Move sync test code out of chrome/test

chrome/test/sync/engine/syncer_command_test.h

-// Copyright (c) 2011 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 CHROME_TEST_SYNC_ENGINE_SYNCER_COMMAND_TEST_H_
-#define CHROME_TEST_SYNC_ENGINE_SYNCER_COMMAND_TEST_H_
-#pragma once
-
-#include <algorithm>
-#include <string>
-#include <vector>
-
-#include "base/compiler_specific.h"
-#include "chrome/browser/sync/engine/model_safe_worker.h"
-#include "chrome/browser/sync/sessions/sync_session.h"
-#include "chrome/browser/sync/sessions/sync_session_context.h"
-#include "chrome/test/sync/engine/mock_connection_manager.h"
-#include "chrome/test/sync/engine/test_directory_setter_upper.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace browser_sync {
-
-// A test fixture that simplifies writing unit tests for individual
-// SyncerCommands, providing convenient access to a test directory
-// and a syncer session.
-template<typename T>
-class SyncerCommandTestWithParam : public testing::TestWithParam<T>,
-                                   public sessions::SyncSession::Delegate,
-                                   public ModelSafeWorkerRegistrar {
- public:
-  enum UseMockDirectory {
-    USE_MOCK_DIRECTORY
-  };
-
-  // SyncSession::Delegate implementation.
-  virtual void OnSilencedUntil(
-      const base::TimeTicks& silenced_until) OVERRIDE {
-    FAIL() << "Should not get silenced.";
-  }
-  virtual bool IsSyncingCurrentlySilenced() OVERRIDE {
-    ADD_FAILURE() << "No requests for silenced state should be made.";
-    return false;
-  }
-  virtual void OnReceivedLongPollIntervalUpdate(
-      const base::TimeDelta& new_interval) OVERRIDE {
-    FAIL() << "Should not get poll interval update.";
-  }
-  virtual void OnReceivedShortPollIntervalUpdate(
-      const base::TimeDelta& new_interval) OVERRIDE {
-    FAIL() << "Should not get poll interval update.";
-  }
-  virtual void OnReceivedSessionsCommitDelay(
-      const base::TimeDelta& new_delay) OVERRIDE {
-    FAIL() << "Should not get sessions commit delay.";
-  }
-  virtual void OnShouldStopSyncingPermanently() OVERRIDE {
-    FAIL() << "Shouldn't be called.";
-  }
-  virtual void OnSyncProtocolError(
-      const sessions::SyncSessionSnapshot& session) OVERRIDE {
-    FAIL() << "Shouldn't be called.";
-  }
-
-  // ModelSafeWorkerRegistrar implementation.
-  virtual void GetWorkers(std::vector<ModelSafeWorker*>* out) OVERRIDE {
-    std::vector<scoped_refptr<ModelSafeWorker> >::iterator it;
-    for (it = workers_.begin(); it != workers_.end(); ++it)
-      out->push_back(*it);
-  }
-  virtual void GetModelSafeRoutingInfo(ModelSafeRoutingInfo* out) OVERRIDE {
-    ModelSafeRoutingInfo copy(routing_info_);
-    out->swap(copy);
-  }
-
- protected:
-  SyncerCommandTestWithParam() : syncdb_(new TestDirectorySetterUpper()) {}
-
-  explicit SyncerCommandTestWithParam(UseMockDirectory use_mock)
-      : syncdb_(new MockDirectorySetterUpper()) {}
-
-  virtual ~SyncerCommandTestWithParam() {}
-  virtual void SetUp() {
-    syncdb_->SetUp();
-    ResetContext();
-  }
-  virtual void TearDown() {
-    syncdb_->TearDown();
-  }
-
-  TestDirectorySetterUpper* syncdb() { return syncdb_.get(); }
-  sessions::SyncSessionContext* context() const { return context_.get(); }
-  sessions::SyncSession::Delegate* delegate() { return this; }
-  ModelSafeWorkerRegistrar* registrar() { return this; }
-
-  // Lazily create a session requesting all datatypes with no payload.
-  sessions::SyncSession* session() {
-    syncable::ModelTypePayloadMap types =
-        syncable::ModelTypePayloadMapFromRoutingInfo(routing_info_,
-                                                     std::string());
-    return session(sessions::SyncSourceInfo(types));
-  }
-
-  // Create a session with the provided source.
-  sessions::SyncSession* session(const sessions::SyncSourceInfo& source) {
-    if (!session_.get()) {
-      std::vector<ModelSafeWorker*> workers;
-      GetWorkers(&workers);
-      session_.reset(new sessions::SyncSession(context(), delegate(), source,
-                     routing_info_, workers));
-    }
-    return session_.get();
-  }
-
-  void ClearSession() {
-    session_.reset();
-  }
-
-  void ResetContext() {
-    context_.reset(new sessions::SyncSessionContext(
-        mock_server_.get(), syncdb_->manager(), registrar(),
-        std::vector<SyncEngineEventListener*>()));
-    context_->set_account_name(syncdb_->name());
-    ClearSession();
-  }
-
-  // Install a MockServerConnection.  Resets the context.  By default,
-  // the context does not have a MockServerConnection attached.
-  void ConfigureMockServerConnection() {
-    mock_server_.reset(
-        new MockConnectionManager(syncdb_->manager(), syncdb_->name()));
-    ResetContext();
-  }
-
-  std::vector<scoped_refptr<ModelSafeWorker> >* workers() {
-    return &workers_;
-  }
-
-  const ModelSafeRoutingInfo& routing_info() { return routing_info_; }
-  ModelSafeRoutingInfo* mutable_routing_info() { return &routing_info_; }
-
-  MockConnectionManager* mock_server() {
-    return mock_server_.get();
-  }
-
- private:
-  scoped_ptr<TestDirectorySetterUpper> syncdb_;
-  scoped_ptr<sessions::SyncSessionContext> context_;
-  scoped_ptr<MockConnectionManager> mock_server_;
-  scoped_ptr<sessions::SyncSession> session_;
-  std::vector<scoped_refptr<ModelSafeWorker> > workers_;
-  ModelSafeRoutingInfo routing_info_;
-  DISALLOW_COPY_AND_ASSIGN(SyncerCommandTestWithParam);
-};
-
-class SyncerCommandTest : public SyncerCommandTestWithParam<void*> {};
-
-class MockDirectorySyncerCommandTest
-    : public SyncerCommandTestWithParam<void*> {
- public:
-  MockDirectorySyncerCommandTest()
-      : SyncerCommandTestWithParam<void*>(
-          SyncerCommandTestWithParam<void*>::USE_MOCK_DIRECTORY) {}
-  MockDirectorySetterUpper::MockDirectory* mock_directory() {
-    return static_cast<MockDirectorySetterUpper*>(syncdb())->directory();
-  }
-};
-
-}  // namespace browser_sync
-
-#endif  // CHROME_TEST_SYNC_ENGINE_SYNCER_COMMAND_TEST_H_