chrome/browser/sync/abstract_profile_sync_service_test.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/sync/abstract_profile_sync_service_test.h"
   6
   7 #include "base/bind.h"
   8 #include "base/bind_helpers.h"
   9 #include "base/location.h"
  10 #include "base/run_loop.h"
  11 #include "chrome/browser/sync/test_profile_sync_service.h"
  12 #include "content/public/test/test_utils.h"
  13 #include "sync/internal_api/public/test/test_user_share.h"
  14 #include "sync/internal_api/public/write_transaction.h"
  15 #include "sync/protocol/sync.pb.h"
  16 #include "sync/util/cryptographer.h"
  17
  18 using syncer::ModelType;
  19 using syncer::UserShare;
  20
  21 /* static */
  22 syncer::ImmutableChangeRecordList
  23     ProfileSyncServiceTestHelper::MakeSingletonChangeRecordList(
  24         int64 node_id, syncer::ChangeRecord::Action action) {
  25   syncer::ChangeRecord record;
  26   record.action = action;
  27   record.id = node_id;
  28   syncer::ChangeRecordList records(1, record);
  29   return syncer::ImmutableChangeRecordList(&records);
  30 }
  31
  32 /* static */
  33 syncer::ImmutableChangeRecordList
  34     ProfileSyncServiceTestHelper::MakeSingletonDeletionChangeRecordList(
  35         int64 node_id, const sync_pb::EntitySpecifics& specifics) {
  36   syncer::ChangeRecord record;
  37   record.action = syncer::ChangeRecord::ACTION_DELETE;
  38   record.id = node_id;
  39   record.specifics = specifics;
  40   syncer::ChangeRecordList records(1, record);
  41   return syncer::ImmutableChangeRecordList(&records);
  42 }
  43
  44 AbstractProfileSyncServiceTest::AbstractProfileSyncServiceTest()
  45     : thread_bundle_(content::TestBrowserThreadBundle::REAL_DB_THREAD |
  46                      content::TestBrowserThreadBundle::REAL_FILE_THREAD |
  47                      content::TestBrowserThreadBundle::REAL_IO_THREAD),
  48       sync_service_(NULL) {
  49 }
  50
  51 AbstractProfileSyncServiceTest::~AbstractProfileSyncServiceTest() {}
  52
  53 void AbstractProfileSyncServiceTest::SetUp() {
  54 }
  55
  56 void AbstractProfileSyncServiceTest::TearDown() {
  57   // Pump messages posted by the sync core thread (which may end up
  58   // posting on the IO thread).
  59   base::RunLoop().RunUntilIdle();
  60   content::RunAllPendingInMessageLoop(content::BrowserThread::IO);
  61   base::RunLoop().RunUntilIdle();
  62 }
  63
  64 bool AbstractProfileSyncServiceTest::CreateRoot(ModelType model_type) {
  65   return syncer::TestUserShare::CreateRoot(model_type,
  66                                            sync_service_->GetUserShare());
  67 }
  68
  69 CreateRootHelper::CreateRootHelper(AbstractProfileSyncServiceTest* test,
  70                                    ModelType model_type)
  71     : callback_(base::Bind(&CreateRootHelper::CreateRootCallback,
  72                            base::Unretained(this))),
  73       test_(test),
  74       model_type_(model_type),
  75       success_(false) {
  76 }
  77
  78 CreateRootHelper::~CreateRootHelper() {
  79 }
  80
  81 const base::Closure& CreateRootHelper::callback() const {
  82   return callback_;
  83 }
  84
  85 bool CreateRootHelper::success() {
  86   return success_;
  87 }
  88
  89 void CreateRootHelper::CreateRootCallback() {
  90   success_ = test_->CreateRoot(model_type_);
  91 }