| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/policy/core/common/cloud/cloud_policy_client_registration_h
elper.h" | 5 #include "components/policy/core/common/cloud/cloud_policy_client_registration_h
elper.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 148 } | 148 } |
| 149 | 149 |
| 150 #endif | 150 #endif |
| 151 | 151 |
| 152 CloudPolicyClientRegistrationHelper::CloudPolicyClientRegistrationHelper( | 152 CloudPolicyClientRegistrationHelper::CloudPolicyClientRegistrationHelper( |
| 153 CloudPolicyClient* client, | 153 CloudPolicyClient* client, |
| 154 enterprise_management::DeviceRegisterRequest::Type registration_type) | 154 enterprise_management::DeviceRegisterRequest::Type registration_type) |
| 155 : context_(client->GetRequestContext()), | 155 : context_(client->GetRequestContext()), |
| 156 client_(client), | 156 client_(client), |
| 157 registration_type_(registration_type) { | 157 registration_type_(registration_type) { |
| 158 DCHECK(context_); | 158 DCHECK(context_.get()); |
| 159 DCHECK(client_); | 159 DCHECK(client_); |
| 160 } | 160 } |
| 161 | 161 |
| 162 CloudPolicyClientRegistrationHelper::~CloudPolicyClientRegistrationHelper() { | 162 CloudPolicyClientRegistrationHelper::~CloudPolicyClientRegistrationHelper() { |
| 163 // Clean up any pending observers in case the browser is shutdown while | 163 // Clean up any pending observers in case the browser is shutdown while |
| 164 // trying to register for policy. | 164 // trying to register for policy. |
| 165 if (client_) | 165 if (client_) |
| 166 client_->RemoveObserver(this); | 166 client_->RemoveObserver(this); |
| 167 } | 167 } |
| 168 | 168 |
| (...skipping 21 matching lines...) Expand all Loading... |
| 190 const base::Closure& callback) { | 190 const base::Closure& callback) { |
| 191 DVLOG(1) << "Starting registration process with login token"; | 191 DVLOG(1) << "Starting registration process with login token"; |
| 192 DCHECK(!client_->is_registered()); | 192 DCHECK(!client_->is_registered()); |
| 193 callback_ = callback; | 193 callback_ = callback; |
| 194 client_->AddObserver(this); | 194 client_->AddObserver(this); |
| 195 | 195 |
| 196 login_token_helper_.reset( | 196 login_token_helper_.reset( |
| 197 new CloudPolicyClientRegistrationHelper::LoginTokenHelper()); | 197 new CloudPolicyClientRegistrationHelper::LoginTokenHelper()); |
| 198 login_token_helper_->FetchAccessToken( | 198 login_token_helper_->FetchAccessToken( |
| 199 login_refresh_token, | 199 login_refresh_token, |
| 200 context_, | 200 context_.get(), |
| 201 base::Bind(&CloudPolicyClientRegistrationHelper::OnTokenFetched, | 201 base::Bind(&CloudPolicyClientRegistrationHelper::OnTokenFetched, |
| 202 base::Unretained(this))); | 202 base::Unretained(this))); |
| 203 } | 203 } |
| 204 | 204 |
| 205 void CloudPolicyClientRegistrationHelper::StartRegistrationWithAccessToken( | 205 void CloudPolicyClientRegistrationHelper::StartRegistrationWithAccessToken( |
| 206 const std::string& access_token, | 206 const std::string& access_token, |
| 207 const base::Closure& callback) { | 207 const base::Closure& callback) { |
| 208 DCHECK(!client_->is_registered()); | 208 DCHECK(!client_->is_registered()); |
| 209 callback_ = callback; | 209 callback_ = callback; |
| 210 client_->AddObserver(this); | 210 client_->AddObserver(this); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 233 << GaiaConstants::kDeviceManagementServiceOAuth; | 233 << GaiaConstants::kDeviceManagementServiceOAuth; |
| 234 RequestCompleted(); | 234 RequestCompleted(); |
| 235 return; | 235 return; |
| 236 } | 236 } |
| 237 | 237 |
| 238 // Cache the access token to be used after the GetUserInfo call. | 238 // Cache the access token to be used after the GetUserInfo call. |
| 239 oauth_access_token_ = access_token; | 239 oauth_access_token_ = access_token; |
| 240 DVLOG(1) << "Fetched new scoped OAuth token:" << oauth_access_token_; | 240 DVLOG(1) << "Fetched new scoped OAuth token:" << oauth_access_token_; |
| 241 // Now we've gotten our access token - contact GAIA to see if this is a | 241 // Now we've gotten our access token - contact GAIA to see if this is a |
| 242 // hosted domain. | 242 // hosted domain. |
| 243 user_info_fetcher_.reset(new UserInfoFetcher(this, context_)); | 243 user_info_fetcher_.reset(new UserInfoFetcher(this, context_.get())); |
| 244 user_info_fetcher_->Start(oauth_access_token_); | 244 user_info_fetcher_->Start(oauth_access_token_); |
| 245 } | 245 } |
| 246 | 246 |
| 247 void CloudPolicyClientRegistrationHelper::OnGetUserInfoFailure( | 247 void CloudPolicyClientRegistrationHelper::OnGetUserInfoFailure( |
| 248 const GoogleServiceAuthError& error) { | 248 const GoogleServiceAuthError& error) { |
| 249 DVLOG(1) << "Failed to fetch user info from GAIA: " << error.state(); | 249 DVLOG(1) << "Failed to fetch user info from GAIA: " << error.state(); |
| 250 user_info_fetcher_.reset(); | 250 user_info_fetcher_.reset(); |
| 251 RequestCompleted(); | 251 RequestCompleted(); |
| 252 } | 252 } |
| 253 | 253 |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 298 void CloudPolicyClientRegistrationHelper::RequestCompleted() { | 298 void CloudPolicyClientRegistrationHelper::RequestCompleted() { |
| 299 if (client_) { | 299 if (client_) { |
| 300 client_->RemoveObserver(this); | 300 client_->RemoveObserver(this); |
| 301 // |client_| may be freed by the callback so clear it now. | 301 // |client_| may be freed by the callback so clear it now. |
| 302 client_ = NULL; | 302 client_ = NULL; |
| 303 callback_.Run(); | 303 callback_.Run(); |
| 304 } | 304 } |
| 305 } | 305 } |
| 306 | 306 |
| 307 } // namespace policy | 307 } // namespace policy |
| OLD | NEW |