Add a flow class to abstract all the details of minting a token for an app.

chrome/common/net/gaia/oauth2_mint_token_flow.cc

Index: chrome/common/net/gaia/oauth2_mint_token_flow.cc
===================================================================
--- chrome/common/net/gaia/oauth2_mint_token_flow.cc	(revision 0)
+++ chrome/common/net/gaia/oauth2_mint_token_flow.cc	(revision 0)
@@ -0,0 +1,130 @@
+// 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_flow.h"
+
+#include <string>
+#include <vector>
+
+#include "base/basictypes.h"
+#include "chrome/common/net/gaia/gaia_urls.h"
+
+using net::URLRequestContextGetter;
+
+OAuth2MintTokenFlow::OAuth2MintTokenFlow(
+    URLRequestContextGetter* context,
+    Delegate* delegate)
+    : context_(context),
+      delegate_(delegate),
+      state_(INITIAL) {
+}
+
+OAuth2MintTokenFlow::~OAuth2MintTokenFlow() { }
+
+void OAuth2MintTokenFlow::Start(
+    const std::string& login_refresh_token,
+    const std::string& extension_id,
+    const std::string& client_id,
+    const std::vector<std::string>& scopes) {
+  login_refresh_token_ = login_refresh_token;
+  extension_id_ = extension_id;
+  client_id_ = client_id;
+  scopes_ = scopes;
+
+  BeginGetLoginAccessToken();
+}
+
+void OAuth2MintTokenFlow::OnGetTokenSuccess(
+    const std::string& access_token) {
+  login_access_token_ = access_token;
+  EndGetLoginAccessToken(NULL);
+}
+void OAuth2MintTokenFlow::OnGetTokenFailure(
+    const GoogleServiceAuthError& error) {
+  EndGetLoginAccessToken(&error);
+}
+
+void OAuth2MintTokenFlow::BeginGetLoginAccessToken() {
+  CHECK_EQ(INITIAL, state_);
+  state_ = FETCH_LOGIN_ACCESS_TOKEN_STARTED;
+
+  oauth2_access_token_fetcher_.reset(CreateAccessTokenFetcher());
+  oauth2_access_token_fetcher_->Start(
+      GaiaUrls::GetInstance()->oauth2_chrome_client_id(),
+      GaiaUrls::GetInstance()->oauth2_chrome_client_secret(),
+      login_refresh_token_,
+      std::vector<std::string>());
+}
+
+void OAuth2MintTokenFlow::EndGetLoginAccessToken(
+    const GoogleServiceAuthError* error) {
+  CHECK_EQ(FETCH_LOGIN_ACCESS_TOKEN_STARTED, state_);
+  if (!error) {
+    state_ = FETCH_LOGIN_ACCESS_TOKEN_DONE;
+    BeginMintAccessToken();
+  } else {
+    state_ = ERROR_STATE;
+    ReportFailure(*error);
+  }
+}
+
+void OAuth2MintTokenFlow::OnMintTokenSuccess(
+    const std::string& access_token) {
+  app_access_token_ = access_token;
+  EndMintAccessToken(NULL);
+}
+void OAuth2MintTokenFlow::OnMintTokenFailure(
+    const GoogleServiceAuthError& error) {
+  EndMintAccessToken(&error);
+}
+
+void OAuth2MintTokenFlow::BeginMintAccessToken() {
+  CHECK_EQ(FETCH_LOGIN_ACCESS_TOKEN_DONE, state_);
+  state_ = MINT_ACCESS_TOKEN_STARTED;
+
+  oauth2_mint_token_fetcher_.reset(CreateMintTokenFetcher());
+  oauth2_mint_token_fetcher_->Start(
+      login_access_token_,
+      client_id_,
+      scopes_,
+      extension_id_);
+}
+
+void OAuth2MintTokenFlow::EndMintAccessToken(
+    const GoogleServiceAuthError* error) {
+  CHECK_EQ(MINT_ACCESS_TOKEN_STARTED, state_);
+
+  if (!error) {
+    state_ = MINT_ACCESS_TOKEN_DONE;
+    ReportSuccess();
+  } else {
+    state_ = ERROR_STATE;
+    ReportFailure(*error);
+  }
+}
+
+void OAuth2MintTokenFlow::ReportSuccess() {
+  CHECK_EQ(MINT_ACCESS_TOKEN_DONE, state_);
+
+  if (delegate_) {
+    delegate_->OnMintTokenSuccess(app_access_token_);
+  }
+}
+
+void OAuth2MintTokenFlow::ReportFailure(
+    const GoogleServiceAuthError& error) {
+  CHECK_EQ(ERROR_STATE, state_);
+
+  if (delegate_) {
+    delegate_->OnMintTokenFailure(error);
+  }
+}
+
+OAuth2AccessTokenFetcher* OAuth2MintTokenFlow::CreateAccessTokenFetcher() {
+  return new OAuth2AccessTokenFetcher(this, context_);
+}
+
+OAuth2MintTokenFetcher* OAuth2MintTokenFlow::CreateMintTokenFetcher() {
+  return new OAuth2MintTokenFetcher(this, context_, "OAuth2MintTokenFlow");
+}