| Index: chrome/common/net/gaia/oauth2_mint_token_fetcher.cc
|
| diff --git a/chrome/common/net/gaia/oauth2_mint_token_fetcher.cc b/chrome/common/net/gaia/oauth2_mint_token_fetcher.cc
|
| deleted file mode 100644
|
| index e46b3077b3afb3972dc905d989d077f05a2afb9c..0000000000000000000000000000000000000000
|
| --- a/chrome/common/net/gaia/oauth2_mint_token_fetcher.cc
|
| +++ /dev/null
|
| @@ -1,190 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "chrome/common/net/gaia/oauth2_mint_token_fetcher.h"
|
| -
|
| -#include <algorithm>
|
| -#include <string>
|
| -
|
| -#include "base/json/json_reader.h"
|
| -#include "base/string_util.h"
|
| -#include "base/stringprintf.h"
|
| -#include "base/values.h"
|
| -#include "chrome/common/net/gaia/gaia_urls.h"
|
| -#include "chrome/common/net/gaia/google_service_auth_error.h"
|
| -#include "net/base/escape.h"
|
| -#include "net/base/load_flags.h"
|
| -#include "net/http/http_status_code.h"
|
| -#include "net/url_request/url_fetcher.h"
|
| -#include "net/url_request/url_request_context_getter.h"
|
| -#include "net/url_request/url_request_status.h"
|
| -
|
| -using net::URLFetcher;
|
| -using net::URLFetcherDelegate;
|
| -using net::ResponseCookies;
|
| -using net::URLRequestContextGetter;
|
| -using net::URLRequestStatus;
|
| -
|
| -namespace {
|
| -static const char kAuthorizationHeaderFormat[] =
|
| - "Authorization: Bearer %s";
|
| -static const char kOAuth2IssueTokenBodyFormat[] =
|
| - "force=true"
|
| - "&response_type=token"
|
| - "&scope=%s"
|
| - "&client_id=%s"
|
| - "&origin=%s";
|
| -static const char kAccessTokenKey[] = "token";
|
| -
|
| -static GoogleServiceAuthError CreateAuthError(URLRequestStatus status) {
|
| - CHECK(!status.is_success());
|
| - if (status.status() == URLRequestStatus::CANCELED) {
|
| - return GoogleServiceAuthError(GoogleServiceAuthError::REQUEST_CANCELED);
|
| - } else {
|
| - DLOG(WARNING) << "Could not reach Google Accounts servers: errno "
|
| - << status.error();
|
| - return GoogleServiceAuthError::FromConnectionError(status.error());
|
| - }
|
| -}
|
| -
|
| -static URLFetcher* CreateFetcher(URLRequestContextGetter* getter,
|
| - const GURL& url,
|
| - const std::string& headers,
|
| - const std::string& body,
|
| - URLFetcherDelegate* delegate) {
|
| - bool empty_body = body.empty();
|
| - URLFetcher* result = net::URLFetcher::Create(
|
| - 0, url,
|
| - empty_body ? URLFetcher::GET : URLFetcher::POST,
|
| - delegate);
|
| -
|
| - result->SetRequestContext(getter);
|
| - result->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES |
|
| - net::LOAD_DO_NOT_SAVE_COOKIES);
|
| -
|
| - if (!empty_body)
|
| - result->SetUploadData("application/x-www-form-urlencoded", body);
|
| - if (!headers.empty())
|
| - result->SetExtraRequestHeaders(headers);
|
| -
|
| - return result;
|
| -}
|
| -} // namespace
|
| -
|
| -OAuth2MintTokenFetcher::OAuth2MintTokenFetcher(
|
| - OAuth2MintTokenConsumer* consumer,
|
| - URLRequestContextGetter* getter,
|
| - const std::string& source)
|
| - : consumer_(consumer),
|
| - getter_(getter),
|
| - source_(source),
|
| - state_(INITIAL) { }
|
| -
|
| -OAuth2MintTokenFetcher::~OAuth2MintTokenFetcher() { }
|
| -
|
| -void OAuth2MintTokenFetcher::CancelRequest() {
|
| - fetcher_.reset();
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::Start(const std::string& oauth_login_access_token,
|
| - const std::string& client_id,
|
| - const std::vector<std::string>& scopes,
|
| - const std::string& origin) {
|
| - oauth_login_access_token_ = oauth_login_access_token;
|
| - client_id_ = client_id;
|
| - scopes_ = scopes;
|
| - origin_ = origin;
|
| - StartMintToken();
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::StartMintToken() {
|
| - CHECK_EQ(INITIAL, state_);
|
| - state_ = MINT_TOKEN_STARTED;
|
| - fetcher_.reset(CreateFetcher(
|
| - getter_,
|
| - MakeMintTokenUrl(),
|
| - MakeMintTokenHeader(oauth_login_access_token_),
|
| - MakeMintTokenBody(client_id_, scopes_, origin_),
|
| - this));
|
| - fetcher_->Start(); // OnURLFetchComplete will be called.
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::EndMintToken(const net::URLFetcher* source) {
|
| - CHECK_EQ(MINT_TOKEN_STARTED, state_);
|
| - state_ = MINT_TOKEN_DONE;
|
| -
|
| - URLRequestStatus status = source->GetStatus();
|
| - if (!status.is_success()) {
|
| - OnMintTokenFailure(CreateAuthError(status));
|
| - return;
|
| - }
|
| -
|
| - if (source->GetResponseCode() != net::HTTP_OK) {
|
| - OnMintTokenFailure(GoogleServiceAuthError(
|
| - GoogleServiceAuthError::INVALID_GAIA_CREDENTIALS));
|
| - return;
|
| - }
|
| -
|
| - // The request was successfully fetched and it returned OK.
|
| - // Parse out the access token.
|
| - std::string access_token;
|
| - ParseMintTokenResponse(source, &access_token);
|
| - OnMintTokenSuccess(access_token);
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::OnMintTokenSuccess(
|
| - const std::string& access_token) {
|
| - consumer_->OnMintTokenSuccess(access_token);
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::OnMintTokenFailure(
|
| - const GoogleServiceAuthError& error) {
|
| - state_ = ERROR_STATE;
|
| - consumer_->OnMintTokenFailure(error);
|
| -}
|
| -
|
| -void OAuth2MintTokenFetcher::OnURLFetchComplete(const net::URLFetcher* source) {
|
| - CHECK(source);
|
| - CHECK_EQ(MINT_TOKEN_STARTED, state_);
|
| - EndMintToken(source);
|
| -}
|
| -
|
| -// static
|
| -GURL OAuth2MintTokenFetcher::MakeMintTokenUrl() {
|
| - return GURL(GaiaUrls::GetInstance()->oauth2_issue_token_url());
|
| -}
|
| -
|
| -// static
|
| -std::string OAuth2MintTokenFetcher::MakeMintTokenHeader(
|
| - const std::string& access_token) {
|
| - return StringPrintf(kAuthorizationHeaderFormat, access_token.c_str());
|
| -}
|
| -
|
| -// static
|
| -std::string OAuth2MintTokenFetcher::MakeMintTokenBody(
|
| - const std::string& client_id,
|
| - const std::vector<std::string>& scopes,
|
| - const std::string& origin) {
|
| - return StringPrintf(
|
| - kOAuth2IssueTokenBodyFormat,
|
| - net::EscapeUrlEncodedData(JoinString(scopes, ','), true).c_str(),
|
| - net::EscapeUrlEncodedData(client_id, true).c_str(),
|
| - net::EscapeUrlEncodedData(origin, true).c_str());
|
| -}
|
| -
|
| -// static
|
| -bool OAuth2MintTokenFetcher::ParseMintTokenResponse(
|
| - const net::URLFetcher* source,
|
| - std::string* access_token) {
|
| - CHECK(source);
|
| - CHECK(access_token);
|
| - std::string data;
|
| - source->GetResponseAsString(&data);
|
| - scoped_ptr<base::Value> value(base::JSONReader::Read(data));
|
| - if (!value.get() || value->GetType() != base::Value::TYPE_DICTIONARY)
|
| - return false;
|
| -
|
| - DictionaryValue* dict = static_cast<DictionaryValue*>(value.get());
|
| - return dict->GetString(kAccessTokenKey, access_token);
|
| -}
|
|
|