Introduce CloudPolicyClient

chrome/browser/policy/device_token_fetcher_unittest.cc

 // Copyright (c) 2012 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 "chrome/browser/policy/device_token_fetcher.h"
 
 #include "base/message_loop.h"
 #include "base/scoped_temp_dir.h"
 #include "chrome/browser/policy/cloud_policy_data_store.h"
 #include "chrome/browser/policy/logging_work_scheduler.h"
@@ skipping 10 matching lines @@
 namespace policy {
 
 const char kTestToken[] = "device_token_fetcher_test_auth_token";
 
 using content::BrowserThread;
 using testing::AnyNumber;
 using testing::Mock;
 using testing::_;
 
 ACTION_P(VerifyRegisterRequest, known_machine_id) {
-  ASSERT_TRUE(arg0);
-  ASSERT_TRUE(arg0->GetRequest());
-  ASSERT_TRUE(arg0->GetRequest()->has_register_request());
-  const em::DeviceRegisterRequest& request =
-      arg0->GetRequest()->register_request();
+  ASSERT_TRUE(arg6.has_register_request());
+  const em::DeviceRegisterRequest& request = arg6.register_request();
   if (known_machine_id) {
     EXPECT_TRUE(request.has_auto_enrolled());
     EXPECT_TRUE(request.auto_enrolled());
   } else {
     EXPECT_FALSE(request.has_auto_enrolled());
   }
 }
 
 class DeviceTokenFetcherTest : public testing::Test {
  protected:
   DeviceTokenFetcherTest()
       : ui_thread_(BrowserThread::UI, &loop_),
         file_thread_(BrowserThread::FILE, &loop_) {
     EXPECT_TRUE(temp_user_data_dir_.CreateUniqueTempDir());
     successful_registration_response_.mutable_register_response()->
         set_device_management_token("fake_token");
     successful_registration_response_.mutable_register_response()->
         set_enrollment_type(em::DeviceRegisterResponse::ENTERPRISE);
   }
 
   virtual void SetUp() {
     cache_.reset(new UserPolicyCache(
         temp_user_data_dir_.path().AppendASCII("DeviceTokenFetcherTest"),
         false  /* wait_for_policy_fetch */));
-    EXPECT_CALL(service_, StartJob(_)).Times(AnyNumber());
+    EXPECT_CALL(service_, StartJob(_, _, _, _, _, _, _)).Times(AnyNumber());
     data_store_.reset(CloudPolicyDataStore::CreateForUserPolicies());
     data_store_->AddObserver(&observer_);
   }
 
   virtual void TearDown() {
     loop_.RunAllPending();
     data_store_->RemoveObserver(&observer_);
   }
 
   void FetchToken(DeviceTokenFetcher* fetcher, CloudPolicyDataStore* store) {
@@ skipping 11 matching lines @@
     cache_->Load();
     loop_.RunAllPending();
     ASSERT_TRUE(cache_->last_policy_refresh_time().is_null());
     ASSERT_FALSE(cache_->IsReady());
   }
 
   void SetUpSuccessfulRegistrationExpectation(bool known_machine_id) {
     EXPECT_CALL(service_,
                 CreateJob(DeviceManagementRequestJob::TYPE_REGISTRATION))
         .WillOnce(service_.SucceedJob(successful_registration_response_));
-    EXPECT_CALL(service_, StartJob(_))
+    EXPECT_CALL(service_, StartJob(_, _, _, _, _, _, _))
         .WillOnce(VerifyRegisterRequest(known_machine_id));
   }
 
   MessageLoop loop_;
   MockDeviceManagementService service_;
   scoped_ptr<CloudPolicyCacheBase> cache_;
   scoped_ptr<CloudPolicyDataStore> data_store_;
   MockCloudPolicyDataStoreObserver observer_;
   PolicyNotifier notifier_;
   ScopedTempDir temp_user_data_dir_;
@@ skipping 157 matching lines @@
   data_store_->set_known_machine_id(true);
   FetchToken(&fetcher, data_store_.get());
   loop_.RunAllPending();
 
   Mock::VerifyAndClearExpectations(&observer_);
   std::string token = data_store_->device_token();
   EXPECT_NE("", token);
 }
 
 }  // namespace policy