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 |