OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/net/gaia/gaia_oauth_fetcher.h" | 5 #include "chrome/browser/net/gaia/gaia_oauth_fetcher.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
47 "https://www.google.com/accounts/OAuthLogin"; | 47 "https://www.google.com/accounts/OAuthLogin"; |
48 | 48 |
49 static const char kUserInfoUrl[] = | 49 static const char kUserInfoUrl[] = |
50 "https://www.googleapis.com/oauth2/v1/userinfo"; | 50 "https://www.googleapis.com/oauth2/v1/userinfo"; |
51 | 51 |
52 static const char kOAuthTokenCookie[] = "oauth_token"; | 52 static const char kOAuthTokenCookie[] = "oauth_token"; |
53 | 53 |
54 GaiaOAuthFetcher::GaiaOAuthFetcher(GaiaOAuthConsumer* consumer, | 54 GaiaOAuthFetcher::GaiaOAuthFetcher(GaiaOAuthConsumer* consumer, |
55 net::URLRequestContextGetter* getter, | 55 net::URLRequestContextGetter* getter, |
56 Profile* profile, | 56 Profile* profile, |
57 const std::string& service_name, | |
58 const std::string& service_scope) | 57 const std::string& service_scope) |
59 : consumer_(consumer), | 58 : consumer_(consumer), |
60 getter_(getter), | 59 getter_(getter), |
61 profile_(profile), | 60 profile_(profile), |
62 popup_(NULL), | 61 popup_(NULL), |
63 service_name_(service_name), | |
64 service_scope_(service_scope), | 62 service_scope_(service_scope), |
65 fetch_pending_(false), | 63 fetch_pending_(false), |
66 auto_fetch_limit_(ALL_OAUTH_STEPS) {} | 64 auto_fetch_limit_(ALL_OAUTH_STEPS) {} |
67 | 65 |
68 GaiaOAuthFetcher::~GaiaOAuthFetcher() {} | 66 GaiaOAuthFetcher::~GaiaOAuthFetcher() {} |
69 | 67 |
70 bool GaiaOAuthFetcher::HasPendingFetch() { | 68 bool GaiaOAuthFetcher::HasPendingFetch() { |
71 return fetch_pending_; | 69 return fetch_pending_; |
72 } | 70 } |
73 | 71 |
(...skipping 327 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
401 false, | 399 false, |
402 this)); | 400 this)); |
403 fetch_pending_ = true; | 401 fetch_pending_ = true; |
404 fetcher_->Start(); | 402 fetcher_->Start(); |
405 } | 403 } |
406 | 404 |
407 void GaiaOAuthFetcher::StartOAuthWrapBridge( | 405 void GaiaOAuthFetcher::StartOAuthWrapBridge( |
408 const std::string& oauth1_access_token, | 406 const std::string& oauth1_access_token, |
409 const std::string& oauth1_access_token_secret, | 407 const std::string& oauth1_access_token_secret, |
410 const std::string& wrap_token_duration, | 408 const std::string& wrap_token_duration, |
411 const std::string& service_name, | |
412 const std::string& service_scope) { | 409 const std::string& service_scope) { |
413 DCHECK(!fetch_pending_) << "Tried to fetch two things at once!"; | 410 DCHECK(!fetch_pending_) << "Tried to fetch two things at once!"; |
414 | 411 |
415 VLOG(1) << "Starting OAuthWrapBridge for: " << service_name; | 412 VLOG(1) << "Starting OAuthWrapBridge for: " << service_scope; |
416 std::string combined_scope = service_scope + " " + | 413 std::string combined_scope = service_scope + " " + |
417 kOAuthWrapBridgeUserInfoScope; | 414 kOAuthWrapBridgeUserInfoScope; |
418 service_name_ = service_name; | 415 service_scope_ = service_scope; |
419 | 416 |
420 // Must outlive fetcher_. | 417 // Must outlive fetcher_. |
421 request_body_ = MakeOAuthWrapBridgeBody( | 418 request_body_ = MakeOAuthWrapBridgeBody( |
422 oauth1_access_token, | 419 oauth1_access_token, |
423 oauth1_access_token_secret, | 420 oauth1_access_token_secret, |
424 wrap_token_duration, | 421 wrap_token_duration, |
425 combined_scope); | 422 combined_scope); |
426 | 423 |
427 request_headers_ = ""; | 424 request_headers_ = ""; |
428 fetcher_.reset(CreateGaiaFetcher(getter_, | 425 fetcher_.reset(CreateGaiaFetcher(getter_, |
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
588 const net::URLRequestStatus& status, | 585 const net::URLRequestStatus& status, |
589 int response_code) { | 586 int response_code) { |
590 if (status.is_success() && response_code == RC_REQUEST_OK) { | 587 if (status.is_success() && response_code == RC_REQUEST_OK) { |
591 VLOG(1) << "OAuth1 access token fetched."; | 588 VLOG(1) << "OAuth1 access token fetched."; |
592 std::string secret; | 589 std::string secret; |
593 std::string token; | 590 std::string token; |
594 ParseOAuthGetAccessTokenResponse(data, &token, &secret); | 591 ParseOAuthGetAccessTokenResponse(data, &token, &secret); |
595 consumer_->OnOAuthGetAccessTokenSuccess(token, secret); | 592 consumer_->OnOAuthGetAccessTokenSuccess(token, secret); |
596 if (ShouldAutoFetch(OAUTH2_SERVICE_ACCESS_TOKEN)) | 593 if (ShouldAutoFetch(OAUTH2_SERVICE_ACCESS_TOKEN)) |
597 StartOAuthWrapBridge( | 594 StartOAuthWrapBridge( |
598 token, secret, "3600", service_name_, service_scope_); | 595 token, secret, GaiaConstants::kGaiaOAuthDuration, service_scope_); |
599 } else { | 596 } else { |
600 consumer_->OnOAuthGetAccessTokenFailure(GenerateAuthError(data, status)); | 597 consumer_->OnOAuthGetAccessTokenFailure(GenerateAuthError(data, status)); |
601 } | 598 } |
602 } | 599 } |
603 | 600 |
604 void GaiaOAuthFetcher::OnOAuthWrapBridgeFetched( | 601 void GaiaOAuthFetcher::OnOAuthWrapBridgeFetched( |
605 const std::string& data, | 602 const std::string& data, |
606 const net::URLRequestStatus& status, | 603 const net::URLRequestStatus& status, |
607 int response_code) { | 604 int response_code) { |
608 if (status.is_success() && response_code == RC_REQUEST_OK) { | 605 if (status.is_success() && response_code == RC_REQUEST_OK) { |
609 VLOG(1) << "OAuth2 access token fetched."; | 606 VLOG(1) << "OAuth2 access token fetched."; |
610 std::string token; | 607 std::string token; |
611 std::string expires_in; | 608 std::string expires_in; |
612 ParseOAuthWrapBridgeResponse(data, &token, &expires_in); | 609 ParseOAuthWrapBridgeResponse(data, &token, &expires_in); |
613 consumer_->OnOAuthWrapBridgeSuccess(service_name_, token, expires_in); | 610 consumer_->OnOAuthWrapBridgeSuccess(service_scope_, token, expires_in); |
614 if (ShouldAutoFetch(USER_INFO)) | 611 if (ShouldAutoFetch(USER_INFO)) |
615 StartUserInfo(token); | 612 StartUserInfo(token); |
616 } else { | 613 } else { |
617 consumer_->OnOAuthWrapBridgeFailure(GenerateAuthError(data, status)); | 614 consumer_->OnOAuthWrapBridgeFailure(service_scope_, |
| 615 GenerateAuthError(data, status)); |
618 } | 616 } |
619 } | 617 } |
620 | 618 |
621 void GaiaOAuthFetcher::OnUserInfoFetched( | 619 void GaiaOAuthFetcher::OnUserInfoFetched( |
622 const std::string& data, | 620 const std::string& data, |
623 const net::URLRequestStatus& status, | 621 const net::URLRequestStatus& status, |
624 int response_code) { | 622 int response_code) { |
625 if (status.is_success() && response_code == RC_REQUEST_OK) { | 623 if (status.is_success() && response_code == RC_REQUEST_OK) { |
626 std::string email; | 624 std::string email; |
627 ParseUserInfoResponse(data, &email); | 625 ParseUserInfoResponse(data, &email); |
(...skipping 24 matching lines...) Expand all Loading... |
652 } else if (url.spec() == kUserInfoUrl) { | 650 } else if (url.spec() == kUserInfoUrl) { |
653 OnUserInfoFetched(data, status, response_code); | 651 OnUserInfoFetched(data, status, response_code); |
654 } else { | 652 } else { |
655 NOTREACHED(); | 653 NOTREACHED(); |
656 } | 654 } |
657 } | 655 } |
658 | 656 |
659 bool GaiaOAuthFetcher::ShouldAutoFetch(AutoFetchLimit fetch_step) { | 657 bool GaiaOAuthFetcher::ShouldAutoFetch(AutoFetchLimit fetch_step) { |
660 return fetch_step <= auto_fetch_limit_; | 658 return fetch_step <= auto_fetch_limit_; |
661 } | 659 } |
OLD | NEW |