contacts: Add ContactStoreFactory and FakeContactStore.

chrome/browser/chromeos/contacts/google_contact_store.cc

 // 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/browser/chromeos/contacts/google_contact_store.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/file_path.h"
@@ skipping 67 matching lines @@
     : profile_(profile),
       contacts_deleter_(&contacts_),
       db_(new ContactDatabase),
       update_delay_on_next_failure_(
           base::TimeDelta::FromSeconds(kUpdateFailureInitialRetrySec)),
       ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 }
 
 GoogleContactStore::~GoogleContactStore() {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  // This should also be running on the UI thread but we can't check it; the
+  // message loop is typically already getting torn down at this point.

[Daniel Erat, 2012/08/03 20:00:23]

[9076:9076:952949823645:FATAL:google_contact_store.cc(88)] Check failed:
BrowserThread::CurrentlyOn(BrowserThread::UI). 
Backtrace:
        base::debug::StackTrace::StackTrace() [0x7f16a33714f2]
        logging::LogMessage::~LogMessage() [0x7f16a33a5097]
        contacts::GoogleContactStore::~GoogleContactStore() [0x7f16a5c7002f]
        STLDeleteValues<>() [0x7f16a5c6bccd]
        STLValueDeleter<>::~STLValueDeleter() [0x7f16a5c6b07b]
        contacts::ContactManager::~ContactManager() [0x7f16a5c69560]
        scoped_ptr<>::~scoped_ptr() [0x7f16a5c67d89]
        ChromeBrowserMainPartsChromeos::~ChromeBrowserMainPartsChromeos()
[0x7f16a5c6559b]
        scoped_ptr<>::~scoped_ptr() [0x7f16992a0e07]
        content::BrowserMainLoop::~BrowserMainLoop() [0x7f169929f0dc]
        scoped_ptr<>::reset() [0x7f16992a2902]
        (anonymous namespace)::BrowserMainRunnerImpl::Shutdown()
[0x7f16992a2698]
        BrowserMain() [0x7f169929dbae]
        content::RunNamedProcessTypeMain() [0x7f169927a682]
        content::ContentMainRunnerImpl::Run() [0x7f169927b4c8]
        content::ContentMain() [0x7f1699279ce9]
        ChromeMain [0x7f16a5ab3cc1]
        main [0x7f16a5ab3c8c]
        0x7f16936efc4d
        0x7f16a5ab3b99

[satorux1, 2012/08/03 20:08:14]

wow this is subtle...

On 2012/08/03 20:00:23, Daniel Erat wrote:

   weak_ptr_factory_.InvalidateWeakPtrs();
   DestroyDatabase();
 }
 
 void GoogleContactStore::Init() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   FilePath db_path = profile_->GetPath().Append(kDatabaseDirectoryName);
   VLOG(1) << "Initializing contact database \"" << db_path.value() << "\" for "
           << profile_->GetProfileName();
   db_->Init(db_path,
@@ skipping 155 matching lines @@
               gdata::util::FormatTimeAsString(last_contact_update_time_));
 }
 
 void GoogleContactStore::OnDownloadSuccess(
     bool is_full_update,
     const base::Time& update_start_time,
     scoped_ptr<ScopedVector<Contact> > updated_contacts) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   VLOG(1) << "Got " << updated_contacts->size() << " contact(s) for "
           << profile_->GetProfileName();
-  size_t num_updated_contacts = updated_contacts->size();
+
+  // Copy the pointers so we can update just these contacts in the database.
+  scoped_ptr<ContactPointers> contacts_to_save_to_db(new ContactPointers);
+  if (db_) {
+    for (size_t i = 0; i < updated_contacts->size(); ++i)
+      contacts_to_save_to_db->push_back((*updated_contacts)[i]);
+  }
+  bool got_updates = !updated_contacts->empty();
+
   MergeContacts(is_full_update, updated_contacts.Pass());
   last_successful_update_start_time_ = update_start_time;
 
-  if (is_full_update || num_updated_contacts > 0) {
+  if (is_full_update || got_updates > 0) {
     FOR_EACH_OBSERVER(ContactStoreObserver,
                       observers_,
                       OnContactsUpdated(this));
   }
 
   if (db_) {
-    scoped_ptr<ContactPointers> contacts_to_save(new ContactPointers);
-    for (ContactMap::const_iterator it = contacts_.begin();
-         it != contacts_.end(); ++it) {
-      contacts_to_save->push_back(it->second);
-    }
+    VLOG(1) << "Saving " << contacts_to_save_to_db->size() << " contact(s) to "
+            << "database as " << (is_full_update ? "full" : "partial")
+            << " update";
     scoped_ptr<UpdateMetadata> metadata(new UpdateMetadata);
     metadata->set_last_update_start_time(update_start_time.ToInternalValue());
-
     db_->SaveContacts(
-        contacts_to_save.Pass(),
+        contacts_to_save_to_db.Pass(),
         metadata.Pass(),
         is_full_update,
         base::Bind(&GoogleContactStore::OnDatabaseContactsSaved,
                    weak_ptr_factory_.GetWeakPtr()));
 
     // We'll schedule an update from OnDatabaseContactsSaved() after we're done
     // writing to the database -- we don't want to modify the contacts while
     // they're being used by the database.
   } else {
     ScheduleUpdate(true);
@@ skipping 48 matching lines @@
 void GoogleContactStore::OnDatabaseContactsSaved(bool success) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   if (!success)
     LOG(WARNING) << "Failed to save contacts to database";
 
   // We only update the database when we've successfully downloaded contacts, so
   // report success to ScheduleUpdate() even if the database update failed.
   ScheduleUpdate(true);
 }
 
+GoogleContactStoreFactory::GoogleContactStoreFactory() {
+}
+
+GoogleContactStoreFactory::~GoogleContactStoreFactory() {
+}
+
+bool GoogleContactStoreFactory::CanCreateContactStoreForProfile(
+    Profile* profile) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  DCHECK(profile);
+  return gdata::util::IsGDataAvailable(profile);
+}
+
+ContactStore* GoogleContactStoreFactory::CreateContactStore(Profile* profile) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  DCHECK(CanCreateContactStoreForProfile(profile));
+  return new GoogleContactStore(profile);
+}
+
 }  // namespace contacts