chrome/browser/signin/signin_names_io_thread.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/signin/signin_names_io_thread.h"
   6
   7 #include "base/logging.h"
   8 #include "base/strings/utf_string_conversions.h"
   9 #include "chrome/browser/browser_process.h"
  10 #include "chrome/browser/chrome_notification_types.h"
  11 #include "chrome/browser/profiles/profile_info_cache.h"
  12 #include "chrome/browser/profiles/profile_manager.h"
  13 #include "chrome/browser/signin/signin_manager.h"
  14 #include "content/public/browser/browser_thread.h"
  15 #include "content/public/browser/notification_service.h"
  16
  17 SigninNamesOnIOThread::SigninNamesOnIOThread() {
  18   CheckOnUIThread();
  19
  20   // We want to register for all profiles, not just for the current profile.
  21   registrar_.reset(new content::NotificationRegistrar);
  22   registrar_->Add(this, chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL,
  23                   content::NotificationService::AllSources());
  24   registrar_->Add(this, chrome::NOTIFICATION_GOOGLE_SIGNED_OUT,
  25                   content::NotificationService::AllSources());
  26
  27   // Get list of profiles and record the email addresses of any connected
  28   // accounts.
  29   if (g_browser_process) {
  30     ProfileManager* manager = g_browser_process->profile_manager();
  31     if (manager) {
  32       const ProfileInfoCache& cache = manager->GetProfileInfoCache();
  33       for (size_t i = 0; i < cache.GetNumberOfProfiles(); ++i) {
  34         base::string16 email = cache.GetUserNameOfProfileAtIndex(i);
  35         if (!email.empty())
  36           emails_.insert(email);
  37       }
  38     }
  39   }
  40 }
  41
  42 SigninNamesOnIOThread::~SigninNamesOnIOThread() {
  43   CheckOnIOThread();
  44   DCHECK(!registrar_) << "Must call ReleaseResourcesOnUIThread() first";
  45 }
  46
  47 const SigninNamesOnIOThread::EmailSet&
  48     SigninNamesOnIOThread::GetEmails() const {
  49   CheckOnIOThread();
  50   return emails_;
  51 }
  52
  53 void SigninNamesOnIOThread::ReleaseResourcesOnUIThread() {
  54   CheckOnUIThread();
  55   registrar_.reset();
  56 }
  57
  58 void SigninNamesOnIOThread::Observe(
  59     int type,
  60     const content::NotificationSource& source,
  61     const content::NotificationDetails& details) {
  62   CheckOnUIThread();
  63
  64   switch (type) {
  65     case chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL: {
  66       const GoogleServiceSigninSuccessDetails* signin_details =
  67           content::Details<GoogleServiceSigninSuccessDetails>(details).ptr();
  68       PostTaskToIOThread(type, base::UTF8ToUTF16(signin_details->username));
  69       break;
  70     }
  71     case chrome::NOTIFICATION_GOOGLE_SIGNED_OUT: {
  72       const GoogleServiceSignoutDetails* signout_details =
  73           content::Details<GoogleServiceSignoutDetails>(details).ptr();
  74       PostTaskToIOThread(type, base::UTF8ToUTF16(signout_details->username));
  75       break;
  76     }
  77     default:
  78       NOTREACHED() << "Unexpected type=" << type;
  79   }
  80 }
  81
  82 void SigninNamesOnIOThread::CheckOnIOThread() const {
  83   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
  84 }
  85
  86 void SigninNamesOnIOThread::CheckOnUIThread() const {
  87   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
  88 }
  89
  90 void SigninNamesOnIOThread::PostTaskToIOThread(
  91     int type,
  92     const base::string16& email) {
  93   if (content::BrowserThread::CurrentlyOn(content::BrowserThread::IO)) {
  94     UpdateOnIOThread(type, email);
  95   } else {
  96     bool may_run = content::BrowserThread::PostTask(
  97             content::BrowserThread::IO,
  98             FROM_HERE,
  99             base::Bind(&SigninNamesOnIOThread::UpdateOnIOThread,
 100                        base::Unretained(this), type, email));
 101     DCHECK(may_run);
 102   }
 103 }
 104
 105 void SigninNamesOnIOThread::UpdateOnIOThread(
 106     int type,
 107     const base::string16& email) {
 108   CheckOnIOThread();
 109   if (type == chrome::NOTIFICATION_GOOGLE_SIGNIN_SUCCESSFUL) {
 110     emails_.insert(email);
 111   } else {
 112     emails_.erase(email);
 113   }
 114 }