Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(28)

Side by Side Diff: chrome/browser/profiles/profile_downloader.cc

Issue 265563002: Revert of Use new people.get api instead of oauth2/v1/userinfo. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 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 "chrome/browser/profiles/profile_downloader.h" 5 #include "chrome/browser/profiles/profile_downloader.h"
6 6
7 #include <string> 7 #include <string>
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/json/json_reader.h" 10 #include "base/json/json_reader.h"
(...skipping 20 matching lines...) Expand all
31 #include "url/gurl.h" 31 #include "url/gurl.h"
32 32
33 using content::BrowserThread; 33 using content::BrowserThread;
34 34
35 namespace { 35 namespace {
36 36
37 // Template for optional authorization header when using an OAuth access token. 37 // Template for optional authorization header when using an OAuth access token.
38 const char kAuthorizationHeader[] = 38 const char kAuthorizationHeader[] =
39 "Authorization: Bearer %s"; 39 "Authorization: Bearer %s";
40 40
41 // URL requesting user info.
42 const char kUserEntryURL[] =
43 "https://www.googleapis.com/oauth2/v1/userinfo?alt=json";
44
45 // OAuth scope for the user info API.
46 // For more info, see https://developers.google.com/accounts/docs/OAuth2LoginV1.
47 const char kAPIScope[] = "https://www.googleapis.com/auth/userinfo.profile";
48
41 // Path in JSON dictionary to user's photo thumbnail URL. 49 // Path in JSON dictionary to user's photo thumbnail URL.
42 const char kPhotoThumbnailURLPath[] = "image.url"; 50 const char kPhotoThumbnailURLPath[] = "picture";
43 51
44 // From the user info API, this field corresponds to the full name of the user. 52 // From the user info API, this field corresponds to the full name of the user.
45 const char kFullNamePath[] = "displayName"; 53 const char kFullNamePath[] = "name";
46 54
47 const char kGivenNamePath[] = "name.givenName"; 55 const char kGivenNamePath[] = "given_name";
48 56
49 // Path in JSON dictionary to user's preferred locale. 57 // Path in JSON dictionary to user's preferred locale.
50 const char kLocalePath[] = "language"; 58 const char kLocalePath[] = "locale";
51 59
52 // Path format for specifying thumbnail's size. 60 // Path format for specifying thumbnail's size.
53 const char kThumbnailSizeFormat[] = "s%d-c"; 61 const char kThumbnailSizeFormat[] = "s%d-c";
54 // Default thumbnail size. 62 // Default thumbnail size.
55 const int kDefaultThumbnailSize = 64; 63 const int kDefaultThumbnailSize = 64;
56 64
57 // Separator of URL path components. 65 // Separator of URL path components.
58 const char kURLPathSeparator = '/'; 66 const char kURLPathSeparator = '/';
59 67
60 // Photo ID of the Picasa Web Albums profile picture (base64 of 0). 68 // Photo ID of the Picasa Web Albums profile picture (base64 of 0).
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after
118 // We can't set the image size, just use the default size. 126 // We can't set the image size, just use the default size.
119 *new_url = old_url; 127 *new_url = old_url;
120 return true; 128 return true;
121 } 129 }
122 130
123 } // namespace 131 } // namespace
124 132
125 // Parses the entry response and gets the name and profile image URL. 133 // Parses the entry response and gets the name and profile image URL.
126 // |data| should be the JSON formatted data return by the response. 134 // |data| should be the JSON formatted data return by the response.
127 // Returns false to indicate a parsing error. 135 // Returns false to indicate a parsing error.
128 bool ProfileDownloader::ParseProfileJSON(base::DictionaryValue* root_dictionary, 136 bool ProfileDownloader::ParseProfileJSON(const std::string& data,
129 base::string16* full_name, 137 base::string16* full_name,
130 base::string16* given_name, 138 base::string16* given_name,
131 std::string* url, 139 std::string* url,
132 int image_size, 140 int image_size,
133 std::string* profile_locale) { 141 std::string* profile_locale) {
134 DCHECK(full_name); 142 DCHECK(full_name);
135 DCHECK(given_name); 143 DCHECK(given_name);
136 DCHECK(url); 144 DCHECK(url);
137 DCHECK(profile_locale); 145 DCHECK(profile_locale);
138 146
139 *full_name = base::string16(); 147 *full_name = base::string16();
140 *given_name = base::string16(); 148 *given_name = base::string16();
141 *url = std::string(); 149 *url = std::string();
142 *profile_locale = std::string(); 150 *profile_locale = std::string();
143 151
152 int error_code = -1;
153 std::string error_message;
154 scoped_ptr<base::Value> root_value(base::JSONReader::ReadAndReturnError(
155 data, base::JSON_PARSE_RFC, &error_code, &error_message));
156 if (!root_value) {
157 LOG(ERROR) << "Error while parsing user entry response: "
158 << error_message;
159 return false;
160 }
161 if (!root_value->IsType(base::Value::TYPE_DICTIONARY)) {
162 LOG(ERROR) << "JSON root is not a dictionary: "
163 << root_value->GetType();
164 return false;
165 }
166 base::DictionaryValue* root_dictionary =
167 static_cast<base::DictionaryValue*>(root_value.get());
168
144 root_dictionary->GetString(kFullNamePath, full_name); 169 root_dictionary->GetString(kFullNamePath, full_name);
145 root_dictionary->GetString(kGivenNamePath, given_name); 170 root_dictionary->GetString(kGivenNamePath, given_name);
146 root_dictionary->GetString(kLocalePath, profile_locale); 171 root_dictionary->GetString(kLocalePath, profile_locale);
147 172
148 std::string url_string; 173 std::string url_string;
149 if (root_dictionary->GetString(kPhotoThumbnailURLPath, &url_string)) { 174 if (root_dictionary->GetString(kPhotoThumbnailURLPath, &url_string)) {
150 GURL new_url; 175 GURL new_url;
151 if (!GetImageURLWithSize(GURL(url_string), image_size, &new_url)) { 176 if (!GetImageURLWithSize(GURL(url_string), image_size, &new_url)) {
152 LOG(ERROR) << "GetImageURLWithSize failed for url: " << url_string; 177 LOG(ERROR) << "GetImageURLWithSize failed for url: " << url_string;
153 return false; 178 return false;
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
241 ProfileDownloader::PictureStatus ProfileDownloader::GetProfilePictureStatus() 266 ProfileDownloader::PictureStatus ProfileDownloader::GetProfilePictureStatus()
242 const { 267 const {
243 return picture_status_; 268 return picture_status_;
244 } 269 }
245 270
246 std::string ProfileDownloader::GetProfilePictureURL() const { 271 std::string ProfileDownloader::GetProfilePictureURL() const {
247 return picture_url_; 272 return picture_url_;
248 } 273 }
249 274
250 void ProfileDownloader::StartFetchingImage() { 275 void ProfileDownloader::StartFetchingImage() {
251 DCHECK(!auth_token_.empty());
252 VLOG(1) << "Fetching user entry with token: " << auth_token_; 276 VLOG(1) << "Fetching user entry with token: " << auth_token_;
253 gaia_client_.reset(new gaia::GaiaOAuthClient( 277 user_entry_fetcher_.reset(net::URLFetcher::Create(
254 delegate_->GetBrowserProfile()->GetRequestContext())); 278 GURL(kUserEntryURL), net::URLFetcher::GET, this));
255 gaia_client_->GetUserInfo(auth_token_, 0, this); 279 user_entry_fetcher_->SetRequestContext(
280 delegate_->GetBrowserProfile()->GetRequestContext());
281 user_entry_fetcher_->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES |
282 net::LOAD_DO_NOT_SAVE_COOKIES);
283 if (!auth_token_.empty()) {
284 user_entry_fetcher_->SetExtraRequestHeaders(
285 base::StringPrintf(kAuthorizationHeader, auth_token_.c_str()));
286 }
287 user_entry_fetcher_->Start();
256 } 288 }
257 289
258 void ProfileDownloader::StartFetchingOAuth2AccessToken() { 290 void ProfileDownloader::StartFetchingOAuth2AccessToken() {
259 Profile* profile = delegate_->GetBrowserProfile(); 291 Profile* profile = delegate_->GetBrowserProfile();
260 OAuth2TokenService::ScopeSet scopes; 292 OAuth2TokenService::ScopeSet scopes;
261 scopes.insert(GaiaConstants::kGoogleUserInfoProfile); 293 scopes.insert(kAPIScope);
262 ProfileOAuth2TokenService* token_service = 294 ProfileOAuth2TokenService* token_service =
263 ProfileOAuth2TokenServiceFactory::GetForProfile(profile); 295 ProfileOAuth2TokenServiceFactory::GetForProfile(profile);
264 oauth2_access_token_request_ = token_service->StartRequest( 296 oauth2_access_token_request_ = token_service->StartRequest(
265 account_id_, scopes, this); 297 account_id_, scopes, this);
266 } 298 }
267 299
268 ProfileDownloader::~ProfileDownloader() { 300 ProfileDownloader::~ProfileDownloader() {
269 // Ensures PO2TS observation is cleared when ProfileDownloader is destructed 301 // Ensures PO2TS observation is cleared when ProfileDownloader is destructed
270 // before refresh token is available. 302 // before refresh token is available.
271 ProfileOAuth2TokenService* service = 303 ProfileOAuth2TokenService* service =
272 ProfileOAuth2TokenServiceFactory::GetForProfile( 304 ProfileOAuth2TokenServiceFactory::GetForProfile(
273 delegate_->GetBrowserProfile()); 305 delegate_->GetBrowserProfile());
274 if (service) 306 if (service)
275 service->RemoveObserver(this); 307 service->RemoveObserver(this);
276 } 308 }
277 309
278 void ProfileDownloader::OnGetUserInfoResponse(
279 scoped_ptr<base::DictionaryValue> user_info) {
280 std::string image_url;
281 if (!ParseProfileJSON(user_info.get(),
282 &profile_full_name_,
283 &profile_given_name_,
284 &image_url,
285 delegate_->GetDesiredImageSideLength(),
286 &profile_locale_)) {
287 delegate_->OnProfileDownloadFailure(
288 this, ProfileDownloaderDelegate::SERVICE_ERROR);
289 return;
290 }
291 if (!delegate_->NeedsProfilePicture()) {
292 VLOG(1) << "Skipping profile picture download";
293 delegate_->OnProfileDownloadSuccess(this);
294 return;
295 }
296 if (IsDefaultProfileImageURL(image_url)) {
297 VLOG(1) << "User has default profile picture";
298 picture_status_ = PICTURE_DEFAULT;
299 delegate_->OnProfileDownloadSuccess(this);
300 return;
301 }
302 if (!image_url.empty() && image_url == delegate_->GetCachedPictureURL()) {
303 VLOG(1) << "Picture URL matches cached picture URL";
304 picture_status_ = PICTURE_CACHED;
305 delegate_->OnProfileDownloadSuccess(this);
306 return;
307 }
308 VLOG(1) << "Fetching profile image from " << image_url;
309 picture_url_ = image_url;
310 profile_image_fetcher_.reset(net::URLFetcher::Create(
311 GURL(image_url), net::URLFetcher::GET, this));
312 profile_image_fetcher_->SetRequestContext(
313 delegate_->GetBrowserProfile()->GetRequestContext());
314 profile_image_fetcher_->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES |
315 net::LOAD_DO_NOT_SAVE_COOKIES);
316 if (!auth_token_.empty()) {
317 profile_image_fetcher_->SetExtraRequestHeaders(
318 base::StringPrintf(kAuthorizationHeader, auth_token_.c_str()));
319 }
320 profile_image_fetcher_->Start();
321 }
322
323 void ProfileDownloader::OnOAuthError() {
324 LOG(WARNING) << "OnOAuthError: Fetching profile data failed";
325 delegate_->OnProfileDownloadFailure(
326 this, ProfileDownloaderDelegate::SERVICE_ERROR);
327 }
328
329 void ProfileDownloader::OnNetworkError(int response_code) {
330 LOG(WARNING) << "OnNetworkError: Fetching profile data failed";
331 DVLOG(1) << " Response code: " << response_code;
332 delegate_->OnProfileDownloadFailure(
333 this, ProfileDownloaderDelegate::NETWORK_ERROR);
334 }
335
336 void ProfileDownloader::OnURLFetchComplete(const net::URLFetcher* source) { 310 void ProfileDownloader::OnURLFetchComplete(const net::URLFetcher* source) {
337 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 311 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
338 std::string data; 312 std::string data;
339 source->GetResponseAsString(&data); 313 source->GetResponseAsString(&data);
340 bool network_error = 314 bool network_error =
341 source->GetStatus().status() != net::URLRequestStatus::SUCCESS; 315 source->GetStatus().status() != net::URLRequestStatus::SUCCESS;
342 if (network_error || source->GetResponseCode() != 200) { 316 if (network_error || source->GetResponseCode() != 200) {
343 LOG(WARNING) << "Fetching profile data failed"; 317 LOG(WARNING) << "Fetching profile data failed";
344 DVLOG(1) << " Status: " << source->GetStatus().status(); 318 DVLOG(1) << " Status: " << source->GetStatus().status();
345 DVLOG(1) << " Error: " << source->GetStatus().error(); 319 DVLOG(1) << " Error: " << source->GetStatus().error();
346 DVLOG(1) << " Response code: " << source->GetResponseCode(); 320 DVLOG(1) << " Response code: " << source->GetResponseCode();
347 DVLOG(1) << " Url: " << source->GetURL().spec(); 321 DVLOG(1) << " Url: " << source->GetURL().spec();
348 delegate_->OnProfileDownloadFailure(this, network_error ? 322 delegate_->OnProfileDownloadFailure(this, network_error ?
349 ProfileDownloaderDelegate::NETWORK_ERROR : 323 ProfileDownloaderDelegate::NETWORK_ERROR :
350 ProfileDownloaderDelegate::SERVICE_ERROR); 324 ProfileDownloaderDelegate::SERVICE_ERROR);
351 return; 325 return;
352 } 326 }
353 327
354 VLOG(1) << "Decoding the image..."; 328 if (source == user_entry_fetcher_.get()) {
355 scoped_refptr<ImageDecoder> image_decoder = new ImageDecoder( 329 std::string image_url;
356 this, data, ImageDecoder::DEFAULT_CODEC); 330 if (!ParseProfileJSON(data,
357 scoped_refptr<base::MessageLoopProxy> task_runner = 331 &profile_full_name_,
358 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI); 332 &profile_given_name_,
359 image_decoder->Start(task_runner); 333 &image_url,
334 delegate_->GetDesiredImageSideLength(),
335 &profile_locale_)) {
336 delegate_->OnProfileDownloadFailure(
337 this, ProfileDownloaderDelegate::SERVICE_ERROR);
338 return;
339 }
340 if (!delegate_->NeedsProfilePicture()) {
341 VLOG(1) << "Skipping profile picture download";
342 delegate_->OnProfileDownloadSuccess(this);
343 return;
344 }
345 if (IsDefaultProfileImageURL(image_url)) {
346 VLOG(1) << "User has default profile picture";
347 picture_status_ = PICTURE_DEFAULT;
348 delegate_->OnProfileDownloadSuccess(this);
349 return;
350 }
351 if (!image_url.empty() && image_url == delegate_->GetCachedPictureURL()) {
352 VLOG(1) << "Picture URL matches cached picture URL";
353 picture_status_ = PICTURE_CACHED;
354 delegate_->OnProfileDownloadSuccess(this);
355 return;
356 }
357 VLOG(1) << "Fetching profile image from " << image_url;
358 picture_url_ = image_url;
359 profile_image_fetcher_.reset(net::URLFetcher::Create(
360 GURL(image_url), net::URLFetcher::GET, this));
361 profile_image_fetcher_->SetRequestContext(
362 delegate_->GetBrowserProfile()->GetRequestContext());
363 profile_image_fetcher_->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES |
364 net::LOAD_DO_NOT_SAVE_COOKIES);
365 if (!auth_token_.empty()) {
366 profile_image_fetcher_->SetExtraRequestHeaders(
367 base::StringPrintf(kAuthorizationHeader, auth_token_.c_str()));
368 }
369 profile_image_fetcher_->Start();
370 } else if (source == profile_image_fetcher_.get()) {
371 VLOG(1) << "Decoding the image...";
372 scoped_refptr<ImageDecoder> image_decoder = new ImageDecoder(
373 this, data, ImageDecoder::DEFAULT_CODEC);
374 scoped_refptr<base::MessageLoopProxy> task_runner =
375 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
376 image_decoder->Start(task_runner);
377 }
360 } 378 }
361 379
362 void ProfileDownloader::OnImageDecoded(const ImageDecoder* decoder, 380 void ProfileDownloader::OnImageDecoded(const ImageDecoder* decoder,
363 const SkBitmap& decoded_image) { 381 const SkBitmap& decoded_image) {
364 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 382 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
365 int image_size = delegate_->GetDesiredImageSideLength(); 383 int image_size = delegate_->GetDesiredImageSideLength();
366 profile_picture_ = skia::ImageOperations::Resize( 384 profile_picture_ = skia::ImageOperations::Resize(
367 decoded_image, 385 decoded_image,
368 skia::ImageOperations::RESIZE_BEST, 386 skia::ImageOperations::RESIZE_BEST,
369 image_size, 387 image_size,
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
405 void ProfileDownloader::OnGetTokenFailure( 423 void ProfileDownloader::OnGetTokenFailure(
406 const OAuth2TokenService::Request* request, 424 const OAuth2TokenService::Request* request,
407 const GoogleServiceAuthError& error) { 425 const GoogleServiceAuthError& error) {
408 DCHECK_EQ(request, oauth2_access_token_request_.get()); 426 DCHECK_EQ(request, oauth2_access_token_request_.get());
409 oauth2_access_token_request_.reset(); 427 oauth2_access_token_request_.reset();
410 LOG(WARNING) << "ProfileDownloader: token request using refresh token failed:" 428 LOG(WARNING) << "ProfileDownloader: token request using refresh token failed:"
411 << error.ToString(); 429 << error.ToString();
412 delegate_->OnProfileDownloadFailure( 430 delegate_->OnProfileDownloadFailure(
413 this, ProfileDownloaderDelegate::TOKEN_ERROR); 431 this, ProfileDownloaderDelegate::TOKEN_ERROR);
414 } 432 }
OLDNEW
« no previous file with comments | « chrome/browser/profiles/profile_downloader.h ('k') | chrome/browser/profiles/profile_downloader_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698