Moving oauth code from host to base to allow code sharing between host and client.

remoting/host/oauth_token_getter_impl.cc

Index: remoting/host/oauth_token_getter_impl.cc
diff --git a/remoting/host/oauth_token_getter_impl.cc b/remoting/host/oauth_token_getter_impl.cc
deleted file mode 100644
index 83404d8ef8de22c1db2a8b076a7ae9b033669317..0000000000000000000000000000000000000000
--- a/remoting/host/oauth_token_getter_impl.cc
+++ /dev/null
@@ -1,181 +0,0 @@
-// Copyright 2014 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 "remoting/host/oauth_token_getter_impl.h"
-
-#include <utility>
-
-#include "base/bind.h"
-#include "base/callback.h"
-#include "base/strings/string_util.h"
-#include "google_apis/google_api_keys.h"
-#include "net/url_request/url_request_context_getter.h"
-#include "remoting/base/logging.h"
-
-namespace remoting {
-
-namespace {
-
-// Maximum number of retries on network/500 errors.
-const int kMaxRetries = 3;
-
-// Time when we we try to update OAuth token before its expiration.
-const int kTokenUpdateTimeBeforeExpirySeconds = 60;
-
-}  // namespace
-
-OAuthTokenGetterImpl::OAuthTokenGetterImpl(
-    std::unique_ptr<OAuthCredentials> oauth_credentials,
-    const scoped_refptr<net::URLRequestContextGetter>&
-        url_request_context_getter,
-    bool auto_refresh)
-    : oauth_credentials_(std::move(oauth_credentials)),
-      gaia_oauth_client_(
-          new gaia::GaiaOAuthClient(url_request_context_getter.get())),
-      url_request_context_getter_(url_request_context_getter) {
-  if (auto_refresh) {
-    refresh_timer_.reset(new base::OneShotTimer());
-  }
-}
-
-OAuthTokenGetterImpl::~OAuthTokenGetterImpl() {}
-
-void OAuthTokenGetterImpl::OnGetTokensResponse(const std::string& user_email,
-                                               const std::string& access_token,
-                                               int expires_seconds) {
-  NOTREACHED();
-}
-
-void OAuthTokenGetterImpl::OnRefreshTokenResponse(
-    const std::string& access_token,
-    int expires_seconds) {
-  DCHECK(CalledOnValidThread());
-  DCHECK(oauth_credentials_.get());
-  HOST_LOG << "Received OAuth token.";
-
-  oauth_access_token_ = access_token;
-  base::TimeDelta token_expiration =
-      base::TimeDelta::FromSeconds(expires_seconds) -
-      base::TimeDelta::FromSeconds(kTokenUpdateTimeBeforeExpirySeconds);
-  auth_token_expiry_time_ = base::Time::Now() + token_expiration;
-
-  if (refresh_timer_) {
-    refresh_timer_->Stop();
-    refresh_timer_->Start(FROM_HERE, token_expiration, this,
-                          &OAuthTokenGetterImpl::RefreshOAuthToken);
-  }
-
-  if (!oauth_credentials_->is_service_account && !email_verified_) {
-    gaia_oauth_client_->GetUserEmail(access_token, kMaxRetries, this);
-  } else {
-    refreshing_oauth_token_ = false;
-    NotifyCallbacks(OAuthTokenGetterImpl::SUCCESS, oauth_credentials_->login,
-                    oauth_access_token_);
-  }
-}
-
-void OAuthTokenGetterImpl::OnGetUserEmailResponse(
-    const std::string& user_email) {
-  DCHECK(CalledOnValidThread());
-  DCHECK(oauth_credentials_.get());
-  HOST_LOG << "Received user info.";
-
-  if (user_email != oauth_credentials_->login) {
-    LOG(ERROR) << "OAuth token and email address do not refer to "
-                  "the same account.";
-    OnOAuthError();
-    return;
-  }
-
-  email_verified_ = true;
-  refreshing_oauth_token_ = false;
-
-  // Now that we've refreshed the token and verified that it's for the correct
-  // user account, try to connect using the new token.
-  NotifyCallbacks(OAuthTokenGetterImpl::SUCCESS, user_email,
-                  oauth_access_token_);
-}
-
-void OAuthTokenGetterImpl::NotifyCallbacks(Status status,
-                                           const std::string& user_email,
-                                           const std::string& access_token) {
-  std::queue<TokenCallback> callbacks(pending_callbacks_);
-  pending_callbacks_ = std::queue<TokenCallback>();
-
-  while (!callbacks.empty()) {
-    callbacks.front().Run(status, user_email, access_token);
-    callbacks.pop();
-  }
-}
-
-void OAuthTokenGetterImpl::OnOAuthError() {
-  DCHECK(CalledOnValidThread());
-  LOG(ERROR) << "OAuth: invalid credentials.";
-  refreshing_oauth_token_ = false;
-
-  // Throw away invalid credentials and force a refresh.
-  oauth_access_token_.clear();
-  auth_token_expiry_time_ = base::Time();
-  email_verified_ = false;
-
-  NotifyCallbacks(OAuthTokenGetterImpl::AUTH_ERROR, std::string(),
-                  std::string());
-}
-
-void OAuthTokenGetterImpl::OnNetworkError(int response_code) {
-  DCHECK(CalledOnValidThread());
-  LOG(ERROR) << "Network error when trying to update OAuth token: "
-             << response_code;
-  refreshing_oauth_token_ = false;
-  NotifyCallbacks(OAuthTokenGetterImpl::NETWORK_ERROR, std::string(),
-                  std::string());
-}
-
-void OAuthTokenGetterImpl::CallWithToken(const TokenCallback& on_access_token) {
-  DCHECK(CalledOnValidThread());
-  bool need_new_auth_token = auth_token_expiry_time_.is_null() ||
-                             base::Time::Now() >= auth_token_expiry_time_ ||
-                             (!oauth_credentials_->is_service_account &&
-                              !email_verified_);
-
-  if (need_new_auth_token) {
-    pending_callbacks_.push(on_access_token);
-    if (!refreshing_oauth_token_)
-      RefreshOAuthToken();
-  } else {
-    on_access_token.Run(SUCCESS, oauth_credentials_->login,
-                        oauth_access_token_);
-  }
-}
-
-void OAuthTokenGetterImpl::InvalidateCache() {
-  DCHECK(CalledOnValidThread());
-  auth_token_expiry_time_ = base::Time();
-}
-
-void OAuthTokenGetterImpl::RefreshOAuthToken() {
-  DCHECK(CalledOnValidThread());
-  HOST_LOG << "Refreshing OAuth token.";
-  DCHECK(!refreshing_oauth_token_);
-
-  // Service accounts use different API keys, as they use the client app flow.
-  google_apis::OAuth2Client oauth2_client =
-      oauth_credentials_->is_service_account ? google_apis::CLIENT_REMOTING_HOST
-                                             : google_apis::CLIENT_REMOTING;
-
-  gaia::OAuthClientInfo client_info = {
-      google_apis::GetOAuth2ClientID(oauth2_client),
-      google_apis::GetOAuth2ClientSecret(oauth2_client),
-      // Redirect URL is only used when getting tokens from auth code. It
-      // is not required when getting access tokens.
-      ""};
-
-  refreshing_oauth_token_ = true;
-  std::vector<std::string> empty_scope_list;  // Use scope from refresh token.
-  gaia_oauth_client_->RefreshToken(client_info,
-                                   oauth_credentials_->refresh_token,
-                                   empty_scope_list, kMaxRetries, this);
-}
-
-}  // namespace remoting