| OLD | NEW |
| (Empty) |
| 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/policy/cloud/user_info_fetcher.h" | |
| 6 | |
| 7 #include "base/json/json_reader.h" | |
| 8 #include "base/logging.h" | |
| 9 #include "base/strings/stringprintf.h" | |
| 10 #include "base/values.h" | |
| 11 #include "google_apis/gaia/gaia_urls.h" | |
| 12 #include "google_apis/gaia/google_service_auth_error.h" | |
| 13 #include "net/base/load_flags.h" | |
| 14 #include "net/http/http_status_code.h" | |
| 15 #include "net/url_request/url_fetcher.h" | |
| 16 #include "net/url_request/url_request_status.h" | |
| 17 #include "url/gurl.h" | |
| 18 | |
| 19 namespace { | |
| 20 | |
| 21 static const char kAuthorizationHeaderFormat[] = | |
| 22 "Authorization: Bearer %s"; | |
| 23 | |
| 24 static std::string MakeAuthorizationHeader(const std::string& auth_token) { | |
| 25 return base::StringPrintf(kAuthorizationHeaderFormat, auth_token.c_str()); | |
| 26 } | |
| 27 | |
| 28 } // namespace | |
| 29 | |
| 30 namespace policy { | |
| 31 | |
| 32 UserInfoFetcher::UserInfoFetcher(Delegate* delegate, | |
| 33 net::URLRequestContextGetter* context) | |
| 34 : delegate_(delegate), | |
| 35 context_(context) { | |
| 36 DCHECK(delegate); | |
| 37 } | |
| 38 | |
| 39 UserInfoFetcher::~UserInfoFetcher() { | |
| 40 } | |
| 41 | |
| 42 void UserInfoFetcher::Start(const std::string& access_token) { | |
| 43 // Create a URLFetcher and start it. | |
| 44 url_fetcher_.reset(net::URLFetcher::Create( | |
| 45 0, GaiaUrls::GetInstance()->oauth_user_info_url(), | |
| 46 net::URLFetcher::GET, this)); | |
| 47 url_fetcher_->SetRequestContext(context_); | |
| 48 url_fetcher_->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES | | |
| 49 net::LOAD_DO_NOT_SAVE_COOKIES); | |
| 50 url_fetcher_->AddExtraRequestHeader(MakeAuthorizationHeader(access_token)); | |
| 51 url_fetcher_->Start(); // Results in a call to OnURLFetchComplete(). | |
| 52 } | |
| 53 | |
| 54 void UserInfoFetcher::OnURLFetchComplete(const net::URLFetcher* source) { | |
| 55 net::URLRequestStatus status = source->GetStatus(); | |
| 56 GoogleServiceAuthError error = GoogleServiceAuthError::AuthErrorNone(); | |
| 57 if (!status.is_success()) { | |
| 58 if (status.status() == net::URLRequestStatus::CANCELED) | |
| 59 error = GoogleServiceAuthError(GoogleServiceAuthError::REQUEST_CANCELED); | |
| 60 else | |
| 61 error = GoogleServiceAuthError::FromConnectionError(status.error()); | |
| 62 } else if (source->GetResponseCode() != net::HTTP_OK) { | |
| 63 DLOG(WARNING) << "UserInfo request failed with HTTP code: " | |
| 64 << source->GetResponseCode(); | |
| 65 error = GoogleServiceAuthError( | |
| 66 GoogleServiceAuthError::CONNECTION_FAILED); | |
| 67 } | |
| 68 if (error.state() != GoogleServiceAuthError::NONE) { | |
| 69 delegate_->OnGetUserInfoFailure(error); | |
| 70 return; | |
| 71 } | |
| 72 | |
| 73 // Successfully fetched userinfo from the server - parse it and hand it off | |
| 74 // to the delegate. | |
| 75 std::string unparsed_data; | |
| 76 source->GetResponseAsString(&unparsed_data); | |
| 77 DVLOG(1) << "Received UserInfo response: " << unparsed_data; | |
| 78 scoped_ptr<base::Value> parsed_value(base::JSONReader::Read(unparsed_data)); | |
| 79 base::DictionaryValue* dict; | |
| 80 if (parsed_value.get() && parsed_value->GetAsDictionary(&dict)) { | |
| 81 delegate_->OnGetUserInfoSuccess(dict); | |
| 82 } else { | |
| 83 NOTREACHED() << "Could not parse userinfo response from server"; | |
| 84 delegate_->OnGetUserInfoFailure(GoogleServiceAuthError( | |
| 85 GoogleServiceAuthError::CONNECTION_FAILED)); | |
| 86 } | |
| 87 } | |
| 88 | |
| 89 }; // namespace policy | |
| OLD | NEW |