Index: chrome/browser/extensions/api/identity/account_tracker.cc |
diff --git a/chrome/browser/extensions/api/identity/account_tracker.cc b/chrome/browser/extensions/api/identity/account_tracker.cc |
deleted file mode 100644 |
index a93f505034a040ea673be1debff96b0d005881c4..0000000000000000000000000000000000000000 |
--- a/chrome/browser/extensions/api/identity/account_tracker.cc |
+++ /dev/null |
@@ -1,342 +0,0 @@ |
-// Copyright 2013 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/browser/extensions/api/identity/account_tracker.h" |
- |
-#include "base/logging.h" |
-#include "base/stl_util.h" |
-#include "chrome/browser/browser_process.h" |
-#include "chrome/browser/chrome_notification_types.h" |
-#include "chrome/browser/profiles/profile.h" |
-#include "chrome/browser/signin/profile_oauth2_token_service_factory.h" |
-#include "chrome/browser/signin/signin_manager_factory.h" |
-#include "components/signin/core/browser/profile_oauth2_token_service.h" |
-#include "components/signin/core/browser/signin_manager.h" |
-#include "content/public/browser/notification_details.h" |
-#include "extensions/browser/extension_system.h" |
- |
-namespace extensions { |
- |
-AccountTracker::AccountTracker(Profile* profile) : profile_(profile) { |
- ProfileOAuth2TokenService* service = |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_); |
- service->AddObserver(this); |
- service->signin_error_controller()->AddProvider(this); |
- SigninManagerFactory::GetForProfile(profile_)->AddObserver(this); |
-} |
- |
-AccountTracker::~AccountTracker() {} |
- |
-void AccountTracker::ReportAuthError(const std::string& account_id, |
- const GoogleServiceAuthError& error) { |
- account_errors_.insert(make_pair(account_id, error)); |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_)-> |
- signin_error_controller()->AuthStatusChanged(); |
- UpdateSignInState(account_id, false); |
-} |
- |
-void AccountTracker::Shutdown() { |
- STLDeleteValues(&user_info_requests_); |
- SigninManagerFactory::GetForProfile(profile_)->RemoveObserver(this); |
- ProfileOAuth2TokenService* service = |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_); |
- service->signin_error_controller()->RemoveProvider(this); |
- service->RemoveObserver(this); |
-} |
- |
-void AccountTracker::AddObserver(Observer* observer) { |
- observer_list_.AddObserver(observer); |
-} |
- |
-void AccountTracker::RemoveObserver(Observer* observer) { |
- observer_list_.RemoveObserver(observer); |
-} |
- |
-std::vector<AccountIds> AccountTracker::GetAccounts() const { |
- const std::string primary_account_id = signin_manager_account_id(); |
- std::vector<AccountIds> accounts; |
- |
- for (std::map<std::string, AccountState>::const_iterator it = |
- accounts_.begin(); |
- it != accounts_.end(); |
- ++it) { |
- const AccountState& state = it->second; |
- bool is_visible = state.is_signed_in && !state.ids.gaia.empty(); |
- |
- if (it->first == primary_account_id) { |
- if (is_visible) |
- accounts.insert(accounts.begin(), state.ids); |
- else |
- return std::vector<AccountIds>(); |
- |
- } else if (is_visible) { |
- accounts.push_back(state.ids); |
- } |
- } |
- return accounts; |
-} |
- |
-std::string AccountTracker::FindAccountKeyByGaiaId(const std::string& gaia_id) { |
- for (std::map<std::string, AccountState>::const_iterator it = |
- accounts_.begin(); |
- it != accounts_.end(); |
- ++it) { |
- const AccountState& state = it->second; |
- if (state.ids.gaia == gaia_id) { |
- return state.ids.account_key; |
- } |
- } |
- |
- return std::string(); |
-} |
- |
-void AccountTracker::OnRefreshTokenAvailable(const std::string& account_id) { |
- // Ignore refresh tokens if there is no primary account ID at all. |
- if (signin_manager_account_id().empty()) |
- return; |
- |
- DVLOG(1) << "AVAILABLE " << account_id; |
- ClearAuthError(account_id); |
- UpdateSignInState(account_id, true); |
-} |
- |
-void AccountTracker::OnRefreshTokenRevoked(const std::string& account_id) { |
- DVLOG(1) << "REVOKED " << account_id; |
- UpdateSignInState(account_id, false); |
-} |
- |
-void AccountTracker::GoogleSigninSucceeded(const std::string& username, |
- const std::string& password) { |
- std::vector<std::string> accounts = |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_)->GetAccounts(); |
- |
- for (std::vector<std::string>::const_iterator it = accounts.begin(); |
- it != accounts.end(); |
- ++it) { |
- OnRefreshTokenAvailable(*it); |
- } |
-} |
- |
-void AccountTracker::GoogleSignedOut(const std::string& username) { |
- if (username == signin_manager_account_id() || |
- signin_manager_account_id().empty()) { |
- StopTrackingAllAccounts(); |
- } else { |
- StopTrackingAccount(username); |
- } |
-} |
- |
-void AccountTracker::SetAccountStateForTest(AccountIds ids, bool is_signed_in) { |
- accounts_[ids.account_key].ids = ids; |
- accounts_[ids.account_key].is_signed_in = is_signed_in; |
- |
- DVLOG(1) << "SetAccountStateForTest " << ids.account_key << ":" |
- << is_signed_in; |
- |
- if (VLOG_IS_ON(1)) { |
- for (std::map<std::string, AccountState>::const_iterator it = |
- accounts_.begin(); |
- it != accounts_.end(); |
- ++it) { |
- DVLOG(1) << it->first << ":" << it->second.is_signed_in; |
- } |
- } |
-} |
- |
-const std::string AccountTracker::signin_manager_account_id() const { |
- return SigninManagerFactory::GetForProfile(profile_) |
- ->GetAuthenticatedAccountId(); |
-} |
- |
-void AccountTracker::NotifyAccountAdded(const AccountState& account) { |
- DCHECK(!account.ids.gaia.empty()); |
- FOR_EACH_OBSERVER( |
- Observer, observer_list_, OnAccountAdded(account.ids)); |
-} |
- |
-void AccountTracker::NotifyAccountRemoved(const AccountState& account) { |
- DCHECK(!account.ids.gaia.empty()); |
- FOR_EACH_OBSERVER( |
- Observer, observer_list_, OnAccountRemoved(account.ids)); |
-} |
- |
-void AccountTracker::NotifySignInChanged(const AccountState& account) { |
- DCHECK(!account.ids.gaia.empty()); |
- FOR_EACH_OBSERVER(Observer, |
- observer_list_, |
- OnAccountSignInChanged(account.ids, account.is_signed_in)); |
-} |
- |
-void AccountTracker::ClearAuthError(const std::string& account_key) { |
- account_errors_.erase(account_key); |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_)-> |
- signin_error_controller()->AuthStatusChanged(); |
-} |
- |
-void AccountTracker::UpdateSignInState(const std::string& account_key, |
- bool is_signed_in) { |
- StartTrackingAccount(account_key); |
- AccountState& account = accounts_[account_key]; |
- bool needs_gaia_id = account.ids.gaia.empty(); |
- bool was_signed_in = account.is_signed_in; |
- account.is_signed_in = is_signed_in; |
- |
- if (needs_gaia_id && is_signed_in) |
- StartFetchingUserInfo(account_key); |
- |
- if (!needs_gaia_id && (was_signed_in != is_signed_in)) |
- NotifySignInChanged(account); |
-} |
- |
-void AccountTracker::StartTrackingAccount(const std::string& account_key) { |
- if (!ContainsKey(accounts_, account_key)) { |
- DVLOG(1) << "StartTracking " << account_key; |
- AccountState account_state; |
- account_state.ids.account_key = account_key; |
- account_state.ids.email = account_key; |
- account_state.is_signed_in = false; |
- accounts_.insert(make_pair(account_key, account_state)); |
- } |
-} |
- |
-void AccountTracker::StopTrackingAccount(const std::string& account_key) { |
- if (ContainsKey(accounts_, account_key)) { |
- AccountState& account = accounts_[account_key]; |
- if (!account.ids.gaia.empty()) { |
- UpdateSignInState(account_key, false); |
- NotifyAccountRemoved(account); |
- } |
- accounts_.erase(account_key); |
- } |
- |
- ClearAuthError(account_key); |
- |
- if (ContainsKey(user_info_requests_, account_key)) |
- DeleteFetcher(user_info_requests_[account_key]); |
-} |
- |
-void AccountTracker::StopTrackingAllAccounts() { |
- while (!accounts_.empty()) |
- StopTrackingAccount(accounts_.begin()->first); |
-} |
- |
-void AccountTracker::StartFetchingUserInfo(const std::string& account_key) { |
- if (ContainsKey(user_info_requests_, account_key)) |
- DeleteFetcher(user_info_requests_[account_key]); |
- |
- DVLOG(1) << "StartFetching " << account_key; |
- AccountIdFetcher* fetcher = |
- new AccountIdFetcher(profile_, this, account_key); |
- user_info_requests_[account_key] = fetcher; |
- fetcher->Start(); |
-} |
- |
-void AccountTracker::OnUserInfoFetchSuccess(AccountIdFetcher* fetcher, |
- const std::string& gaia_id) { |
- const std::string& account_key = fetcher->account_key(); |
- DCHECK(ContainsKey(accounts_, account_key)); |
- AccountState& account = accounts_[account_key]; |
- |
- account.ids.gaia = gaia_id; |
- NotifyAccountAdded(account); |
- |
- if (account.is_signed_in) |
- NotifySignInChanged(account); |
- |
- DeleteFetcher(fetcher); |
-} |
- |
-void AccountTracker::OnUserInfoFetchFailure(AccountIdFetcher* fetcher) { |
- LOG(WARNING) << "Failed to get UserInfo for " << fetcher->account_key(); |
- std::string key = fetcher->account_key(); |
- DeleteFetcher(fetcher); |
- StopTrackingAccount(key); |
-} |
- |
-std::string AccountTracker::GetAccountId() const { |
- if (account_errors_.size() == 0) |
- return std::string(); |
- else |
- return account_errors_.begin()->first; |
-} |
- |
-std::string AccountTracker::GetUsername() const { |
- std::string id = GetAccountId(); |
- if (!id.empty()) { |
- std::map<std::string, AccountState>::const_iterator it = |
- accounts_.find(id); |
- if (it != accounts_.end()) |
- return it->second.ids.email; |
- } |
- return std::string(); |
-} |
- |
-GoogleServiceAuthError AccountTracker::GetAuthStatus() const { |
- if (account_errors_.size() == 0) |
- return GoogleServiceAuthError::AuthErrorNone(); |
- else |
- return account_errors_.begin()->second; |
-} |
- |
-void AccountTracker::DeleteFetcher(AccountIdFetcher* fetcher) { |
- const std::string& account_key = fetcher->account_key(); |
- DCHECK(ContainsKey(user_info_requests_, account_key)); |
- DCHECK_EQ(fetcher, user_info_requests_[account_key]); |
- user_info_requests_.erase(account_key); |
- delete fetcher; |
-} |
- |
-AccountIdFetcher::AccountIdFetcher(Profile* profile, |
- AccountTracker* tracker, |
- const std::string& account_key) |
- : OAuth2TokenService::Consumer("extensions_account_tracker"), |
- profile_(profile), |
- tracker_(tracker), |
- account_key_(account_key) {} |
- |
-AccountIdFetcher::~AccountIdFetcher() {} |
- |
-void AccountIdFetcher::Start() { |
- ProfileOAuth2TokenService* service = |
- ProfileOAuth2TokenServiceFactory::GetForProfile(profile_); |
- login_token_request_ = service->StartRequest( |
- account_key_, OAuth2TokenService::ScopeSet(), this); |
-} |
- |
-void AccountIdFetcher::OnGetTokenSuccess( |
- const OAuth2TokenService::Request* request, |
- const std::string& access_token, |
- const base::Time& expiration_time) { |
- DCHECK_EQ(request, login_token_request_.get()); |
- |
- gaia_oauth_client_.reset(new gaia::GaiaOAuthClient( |
- g_browser_process->system_request_context())); |
- |
- const int kMaxGetUserIdRetries = 3; |
- gaia_oauth_client_->GetUserId(access_token, kMaxGetUserIdRetries, this); |
-} |
- |
-void AccountIdFetcher::OnGetTokenFailure( |
- const OAuth2TokenService::Request* request, |
- const GoogleServiceAuthError& error) { |
- LOG(ERROR) << "OnGetTokenFailure: " << error.ToString(); |
- DCHECK_EQ(request, login_token_request_.get()); |
- tracker_->OnUserInfoFetchFailure(this); |
-} |
- |
-void AccountIdFetcher::OnGetUserIdResponse(const std::string& gaia_id) { |
- tracker_->OnUserInfoFetchSuccess(this, gaia_id); |
-} |
- |
-void AccountIdFetcher::OnOAuthError() { |
- LOG(ERROR) << "OnOAuthError"; |
- tracker_->OnUserInfoFetchFailure(this); |
-} |
- |
-void AccountIdFetcher::OnNetworkError(int response_code) { |
- LOG(ERROR) << "OnNetworkError " << response_code; |
- tracker_->OnUserInfoFetchFailure(this); |
-} |
- |
-} // namespace extensions |