| OLD | NEW |
|---|
| (Empty) |
| 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/chromeos/contacts/contact_manager.h" | |
| 6 | |
| 7 #include "base/logging.h" | |
| 8 #include "chrome/browser/browser_process.h" | |
| 9 #include "chrome/browser/chrome_notification_types.h" | |
| 10 #include "chrome/browser/chromeos/contacts/contact.pb.h" | |
| 11 #include "chrome/browser/chromeos/contacts/contact_manager_observer.h" | |
| 12 #include "chrome/browser/chromeos/contacts/contact_store.h" | |
| 13 #include "chrome/browser/chromeos/contacts/google_contact_store.h" | |
| 14 #include "chrome/browser/profiles/profile.h" | |
| 15 #include "chrome/browser/profiles/profile_manager.h" | |
| 16 #include "content/public/browser/browser_thread.h" | |
| 17 #include "content/public/browser/notification_service.h" | |
| 18 | |
| 19 using content::BrowserThread; | |
| 20 | |
| 21 namespace contacts { | |
| 22 | |
| 23 namespace { | |
| 24 | |
| 25 // Singleton instance. | |
| 26 ContactManager* g_instance = NULL; | |
| 27 | |
| 28 } // namespace | |
| 29 | |
| 30 // static | |
| 31 ContactManager* ContactManager::GetInstance() { | |
| 32 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 33 DCHECK(g_instance); | |
| 34 return g_instance; | |
| 35 } | |
| 36 | |
| 37 ContactManager::ContactManager() | |
| 38 : profile_observers_deleter_(&profile_observers_), | |
| 39 contact_store_factory_(new GoogleContactStoreFactory), | |
| 40 contact_stores_deleter_(&contact_stores_), | |
| 41 weak_ptr_factory_(this) { | |
| 42 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 43 DCHECK(!g_instance); | |
| 44 g_instance = this; | |
| 45 } | |
| 46 | |
| 47 ContactManager::~ContactManager() { | |
| 48 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 49 DCHECK_EQ(g_instance, this); | |
| 50 weak_ptr_factory_.InvalidateWeakPtrs(); | |
| 51 g_instance = NULL; | |
| 52 for (ContactStoreMap::const_iterator it = contact_stores_.begin(); | |
| 53 it != contact_stores_.end(); ++it) { | |
| 54 it->second->RemoveObserver(this); | |
| 55 } | |
| 56 } | |
| 57 | |
| 58 void ContactManager::SetContactStoreForTesting( | |
| 59 scoped_ptr<ContactStoreFactory> factory) { | |
| 60 DCHECK(contact_stores_.empty()); | |
| 61 contact_store_factory_.swap(factory); | |
| 62 } | |
| 63 | |
| 64 void ContactManager::Init() { | |
| 65 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 66 registrar_.Add( | |
| 67 this, | |
| 68 chrome::NOTIFICATION_PROFILE_CREATED, | |
| 69 content::NotificationService::AllSources()); | |
| 70 registrar_.Add( | |
| 71 this, | |
| 72 chrome::NOTIFICATION_PROFILE_DESTROYED, | |
| 73 content::NotificationService::AllSources()); | |
| 74 | |
| 75 // Notify about any already-existing profiles. | |
| 76 std::vector<Profile*> profiles( | |
| 77 g_browser_process->profile_manager()->GetLoadedProfiles()); | |
| 78 for (size_t i = 0; i < profiles.size(); ++i) | |
| 79 HandleProfileCreated(profiles[i]); | |
| 80 } | |
| 81 | |
| 82 base::WeakPtr<ContactManagerInterface> ContactManager::GetWeakPtr() { | |
| 83 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 84 return weak_ptr_factory_.GetWeakPtr(); | |
| 85 } | |
| 86 | |
| 87 void ContactManager::AddObserver(ContactManagerObserver* observer, | |
| 88 Profile* profile) { | |
| 89 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 90 DCHECK(observer); | |
| 91 DCHECK(profile); | |
| 92 Observers* observers = GetObserversForProfile(profile, true); | |
| 93 observers->AddObserver(observer); | |
| 94 } | |
| 95 | |
| 96 void ContactManager::RemoveObserver(ContactManagerObserver* observer, | |
| 97 Profile* profile) { | |
| 98 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 99 DCHECK(observer); | |
| 100 DCHECK(profile); | |
| 101 Observers* observers = GetObserversForProfile(profile, false); | |
| 102 if (observers) | |
| 103 observers->RemoveObserver(observer); | |
| 104 } | |
| 105 | |
| 106 scoped_ptr<ContactPointers> ContactManager::GetAllContacts(Profile* profile) { | |
| 107 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 108 DCHECK(profile); | |
| 109 scoped_ptr<ContactPointers> contacts(new ContactPointers); | |
| 110 ContactStoreMap::const_iterator it = contact_stores_.find(profile); | |
| 111 if (it != contact_stores_.end()) | |
| 112 it->second->AppendContacts(contacts.get()); | |
| 113 return contacts.Pass(); | |
| 114 } | |
| 115 | |
| 116 const Contact* ContactManager::GetContactById(Profile* profile, | |
| 117 const std::string& contact_id) { | |
| 118 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 119 DCHECK(profile); | |
| 120 ContactStoreMap::const_iterator it = contact_stores_.find(profile); | |
| 121 return it != contact_stores_.end() ? | |
| 122 it->second->GetContactById(contact_id) : | |
| 123 NULL; | |
| 124 } | |
| 125 | |
| 126 void ContactManager::OnContactsUpdated(ContactStore* store) { | |
| 127 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 128 for (ContactStoreMap::const_iterator it = contact_stores_.begin(); | |
| 129 it != contact_stores_.end(); ++it) { | |
| 130 if (it->second == store) { | |
| 131 Profile* profile = it->first; | |
| 132 Observers* observers = GetObserversForProfile(profile, false); | |
| 133 if (observers) { | |
| 134 FOR_EACH_OBSERVER(ContactManagerObserver, | |
| 135 *observers, | |
| 136 OnContactsUpdated(profile)); | |
| 137 } | |
| 138 return; | |
| 139 } | |
| 140 } | |
| 141 NOTREACHED() << "Got update from unknown contact store " << store; | |
| 142 } | |
| 143 | |
| 144 void ContactManager::Observe(int type, | |
| 145 const content::NotificationSource& source, | |
| 146 const content::NotificationDetails& details) { | |
| 147 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 148 switch (type) { | |
| 149 case chrome::NOTIFICATION_PROFILE_CREATED: | |
| 150 HandleProfileCreated(content::Source<Profile>(source).ptr()); | |
| 151 break; | |
| 152 case chrome::NOTIFICATION_PROFILE_DESTROYED: { | |
| 153 Profile* profile = content::Details<Profile>(details).ptr(); | |
| 154 if (profile) | |
| 155 HandleProfileDestroyed(profile); | |
| 156 break; | |
| 157 } | |
| 158 default: | |
| 159 NOTREACHED() << "Unexpected notification " << type; | |
| 160 } | |
| 161 } | |
| 162 | |
| 163 ContactManager::Observers* ContactManager::GetObserversForProfile( | |
| 164 Profile* profile, | |
| 165 bool create) { | |
| 166 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 167 ProfileObserversMap::const_iterator it = profile_observers_.find(profile); | |
| 168 if (it != profile_observers_.end()) | |
| 169 return it->second; | |
| 170 if (!create) | |
| 171 return NULL; | |
| 172 | |
| 173 Observers* observers = new Observers; | |
| 174 profile_observers_[profile] = observers; | |
| 175 return observers; | |
| 176 } | |
| 177 | |
| 178 void ContactManager::HandleProfileCreated(Profile* profile) { | |
| 179 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 180 DCHECK(profile); | |
| 181 | |
| 182 ContactStoreMap::iterator it = contact_stores_.find(profile); | |
| 183 if (it != contact_stores_.end()) | |
| 184 return; | |
| 185 | |
| 186 if (!contact_store_factory_->CanCreateContactStoreForProfile(profile)) | |
| 187 return; | |
| 188 | |
| 189 VLOG(1) << "Adding profile " << profile->GetProfileName(); | |
| 190 ContactStore* store = contact_store_factory_->CreateContactStore(profile); | |
| 191 DCHECK(store); | |
| 192 store->AddObserver(this); | |
| 193 store->Init(); | |
| 194 DCHECK_EQ(contact_stores_.count(profile), static_cast<size_t>(0)); | |
| 195 contact_stores_[profile] = store; | |
| 196 } | |
| 197 | |
| 198 void ContactManager::HandleProfileDestroyed(Profile* profile) { | |
| 199 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
| 200 DCHECK(profile); | |
| 201 | |
| 202 ContactStoreMap::iterator store_it = contact_stores_.find(profile); | |
| 203 if (store_it != contact_stores_.end()) { | |
| 204 store_it->second->RemoveObserver(this); | |
| 205 delete store_it->second; | |
| 206 contact_stores_.erase(store_it); | |
| 207 } | |
| 208 | |
| 209 ProfileObserversMap::iterator observer_it = profile_observers_.find(profile); | |
| 210 if (observer_it != profile_observers_.end()) { | |
| 211 delete observer_it->second; | |
| 212 profile_observers_.erase(observer_it); | |
| 213 } | |
| 214 } | |
| 215 | |
| 216 } // namespace contacts | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 190063004:
chromeos: Delete old, unused contacts code. (Closed)
Base URL: svn://svn.chromium.org/chrome/trunk/src