Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(137)

Unified Diff: chrome/browser/chromeos/contacts/gdata_contacts_service.cc

Issue 190063004: chromeos: Delete old, unused contacts code. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: merge again Created 6 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: chrome/browser/chromeos/contacts/gdata_contacts_service.cc
diff --git a/chrome/browser/chromeos/contacts/gdata_contacts_service.cc b/chrome/browser/chromeos/contacts/gdata_contacts_service.cc
deleted file mode 100644
index 16ce208f557d065cd0a900aca988334c695d56db..0000000000000000000000000000000000000000
--- a/chrome/browser/chromeos/contacts/gdata_contacts_service.cc
+++ /dev/null
@@ -1,894 +0,0 @@
-// 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/gdata_contacts_service.h"
-
-#include <cstring>
-#include <map>
-#include <string>
-#include <utility>
-
-#include "base/json/json_value_converter.h"
-#include "base/json/json_writer.h"
-#include "base/logging.h"
-#include "base/memory/weak_ptr.h"
-#include "base/metrics/histogram.h"
-#include "base/stl_util.h"
-#include "base/strings/string_util.h"
-#include "base/threading/sequenced_worker_pool.h"
-#include "base/time/time.h"
-#include "base/timer/timer.h"
-#include "base/values.h"
-#include "chrome/browser/chromeos/contacts/contact.pb.h"
-#include "content/public/browser/browser_thread.h"
-#include "google_apis/drive/gdata_contacts_requests.h"
-#include "google_apis/drive/gdata_errorcode.h"
-#include "google_apis/drive/request_sender.h"
-#include "google_apis/drive/time_util.h"
-
-using content::BrowserThread;
-
-namespace contacts {
-
-namespace {
-
-// Download outcomes reported via the "Contacts.FullUpdateResult" and
-// "Contacts.IncrementalUpdateResult" histograms.
-enum HistogramResult {
- HISTOGRAM_RESULT_SUCCESS = 0,
- HISTOGRAM_RESULT_GROUPS_DOWNLOAD_FAILURE = 1,
- HISTOGRAM_RESULT_GROUPS_PARSE_FAILURE = 2,
- HISTOGRAM_RESULT_MY_CONTACTS_GROUP_NOT_FOUND = 3,
- HISTOGRAM_RESULT_CONTACTS_DOWNLOAD_FAILURE = 4,
- HISTOGRAM_RESULT_CONTACTS_PARSE_FAILURE = 5,
- HISTOGRAM_RESULT_PHOTO_DOWNLOAD_FAILURE = 6,
- HISTOGRAM_RESULT_MAX_VALUE = 7,
-};
-
-// Maximum number of profile photos that we'll download per second.
-// At values above 10, Google starts returning 503 errors.
-const int kMaxPhotoDownloadsPerSecond = 10;
-
-// Give up after seeing more than this many transient errors while trying to
-// download a photo for a single contact.
-const int kMaxTransientPhotoDownloadErrorsPerContact = 2;
-
-// Hardcoded system group ID for the "My Contacts" group, per
-// https://developers.google.com/google-apps/contacts/v3/#contact_group_entry.
-const char kMyContactsSystemGroupId[] = "Contacts";
-
-// Top-level field in a contact groups feed containing the list of entries.
-const char kGroupEntryField[] = "feed.entry";
-
-// Field in group entries containing the system group ID (e.g. ID "Contacts"
-// for the "My Contacts" system group). See
-// https://developers.google.com/google-apps/contacts/v3/#contact_group_entry
-// for more details.
-const char kSystemGroupIdField[] = "gContact$systemGroup.id";
-
-// Field in the top-level object containing the contacts feed.
-const char kFeedField[] = "feed";
-
-// Field in the contacts feed containing a list of category information, along
-// with fields within the dictionaries contained in the list and expected
-// values.
-const char kCategoryField[] = "category";
-const char kCategorySchemeField[] = "scheme";
-const char kCategorySchemeValue[] = "http://schemas.google.com/g/2005#kind";
-const char kCategoryTermField[] = "term";
-const char kCategoryTermValue[] =
- "http://schemas.google.com/contact/2008#contact";
-
-// Field in the contacts feed containing a list of contact entries.
-const char kEntryField[] = "entry";
-
-// Field in group and contact entries containing the item's ID.
-const char kIdField[] = "id.$t";
-
-// Top-level fields in contact entries.
-const char kDeletedField[] = "gd$deleted";
-const char kFullNameField[] = "gd$name.gd$fullName.$t";
-const char kGivenNameField[] = "gd$name.gd$givenName.$t";
-const char kAdditionalNameField[] = "gd$name.gd$additionalName.$t";
-const char kFamilyNameField[] = "gd$name.gd$familyName.$t";
-const char kNamePrefixField[] = "gd$name.gd$namePrefix.$t";
-const char kNameSuffixField[] = "gd$name.gd$nameSuffix.$t";
-const char kEmailField[] = "gd$email";
-const char kPhoneField[] = "gd$phoneNumber";
-const char kPostalAddressField[] = "gd$structuredPostalAddress";
-const char kInstantMessagingField[] = "gd$im";
-const char kLinkField[] = "link";
-const char kUpdatedField[] = "updated.$t";
-
-// Fields in entries in the |kEmailField| list.
-const char kEmailAddressField[] = "address";
-
-// Fields in entries in the |kPhoneField| list.
-const char kPhoneNumberField[] = "$t";
-
-// Fields in entries in the |kPostalAddressField| list.
-const char kPostalAddressFormattedField[] = "gd$formattedAddress.$t";
-
-// Fields in entries in the |kInstantMessagingField| list.
-const char kInstantMessagingAddressField[] = "address";
-const char kInstantMessagingProtocolField[] = "protocol";
-const char kInstantMessagingProtocolAimValue[] =
- "http://schemas.google.com/g/2005#AIM";
-const char kInstantMessagingProtocolMsnValue[] =
- "http://schemas.google.com/g/2005#MSN";
-const char kInstantMessagingProtocolYahooValue[] =
- "http://schemas.google.com/g/2005#YAHOO";
-const char kInstantMessagingProtocolSkypeValue[] =
- "http://schemas.google.com/g/2005#SKYPE";
-const char kInstantMessagingProtocolQqValue[] =
- "http://schemas.google.com/g/2005#QQ";
-const char kInstantMessagingProtocolGoogleTalkValue[] =
- "http://schemas.google.com/g/2005#GOOGLE_TALK";
-const char kInstantMessagingProtocolIcqValue[] =
- "http://schemas.google.com/g/2005#ICQ";
-const char kInstantMessagingProtocolJabberValue[] =
- "http://schemas.google.com/g/2005#JABBER";
-
-// Generic fields shared between address-like items (email, postal, etc.).
-const char kAddressPrimaryField[] = "primary";
-const char kAddressPrimaryTrueValue[] = "true";
-const char kAddressRelField[] = "rel";
-const char kAddressRelHomeValue[] = "http://schemas.google.com/g/2005#home";
-const char kAddressRelWorkValue[] = "http://schemas.google.com/g/2005#work";
-const char kAddressRelMobileValue[] = "http://schemas.google.com/g/2005#mobile";
-const char kAddressLabelField[] = "label";
-
-// Fields in entries in the |kLinkField| list.
-const char kLinkHrefField[] = "href";
-const char kLinkRelField[] = "rel";
-const char kLinkETagField[] = "gd$etag";
-const char kLinkRelPhotoValue[] =
- "http://schemas.google.com/contacts/2008/rel#photo";
-
-// Returns a string containing a pretty-printed JSON representation of |value|.
-std::string PrettyPrintValue(const base::Value& value) {
- std::string out;
- base::JSONWriter::WriteWithOptions(
- &value, base::JSONWriter::OPTIONS_PRETTY_PRINT, &out);
- return out;
-}
-
-// Assigns the value at |path| within |dict| to |out|, returning false if the
-// path wasn't present. Unicode byte order marks are removed from the string.
-bool GetCleanedString(const base::DictionaryValue& dict,
- const std::string& path,
- std::string* out) {
- if (!dict.GetString(path, out))
- return false;
-
- // The Unicode byte order mark, U+FEFF, is useless in UTF-8 strings (which are
- // interpreted one byte at a time).
- ReplaceSubstringsAfterOffset(out, 0, "\xEF\xBB\xBF", "");
- return true;
-}
-
-// Returns whether an address is primary, given a dictionary representing a
-// single address.
-bool IsAddressPrimary(const base::DictionaryValue& address_dict) {
- std::string primary;
- address_dict.GetString(kAddressPrimaryField, &primary);
- return primary == kAddressPrimaryTrueValue;
-}
-
-// Initializes an AddressType message given a dictionary representing a single
-// address.
-void InitAddressType(const base::DictionaryValue& address_dict,
- Contact_AddressType* type) {
- DCHECK(type);
- type->Clear();
-
- std::string rel;
- address_dict.GetString(kAddressRelField, &rel);
- if (rel == kAddressRelHomeValue)
- type->set_relation(Contact_AddressType_Relation_HOME);
- else if (rel == kAddressRelWorkValue)
- type->set_relation(Contact_AddressType_Relation_WORK);
- else if (rel == kAddressRelMobileValue)
- type->set_relation(Contact_AddressType_Relation_MOBILE);
- else
- type->set_relation(Contact_AddressType_Relation_OTHER);
-
- GetCleanedString(address_dict, kAddressLabelField, type->mutable_label());
-}
-
-// Maps the protocol from a dictionary representing a contact's IM address to a
-// contacts::Contact_InstantMessagingAddress_Protocol value.
-contacts::Contact_InstantMessagingAddress_Protocol
-GetInstantMessagingProtocol(const base::DictionaryValue& im_dict) {
- std::string protocol;
- im_dict.GetString(kInstantMessagingProtocolField, &protocol);
- if (protocol == kInstantMessagingProtocolAimValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_AIM;
- else if (protocol == kInstantMessagingProtocolMsnValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_MSN;
- else if (protocol == kInstantMessagingProtocolYahooValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_YAHOO;
- else if (protocol == kInstantMessagingProtocolSkypeValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_SKYPE;
- else if (protocol == kInstantMessagingProtocolQqValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_QQ;
- else if (protocol == kInstantMessagingProtocolGoogleTalkValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_GOOGLE_TALK;
- else if (protocol == kInstantMessagingProtocolIcqValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_ICQ;
- else if (protocol == kInstantMessagingProtocolJabberValue)
- return contacts::Contact_InstantMessagingAddress_Protocol_JABBER;
- else
- return contacts::Contact_InstantMessagingAddress_Protocol_OTHER;
-}
-
-// Gets the photo URL from a contact's dictionary (within the "entry" list).
-// Returns an empty string if no photo was found.
-std::string GetPhotoUrl(const base::DictionaryValue& dict) {
- const base::ListValue* link_list = NULL;
- if (!dict.GetList(kLinkField, &link_list))
- return std::string();
-
- for (size_t i = 0; i < link_list->GetSize(); ++i) {
- const base::DictionaryValue* link_dict = NULL;
- if (!link_list->GetDictionary(i, &link_dict))
- continue;
-
- std::string rel;
- if (!link_dict->GetString(kLinkRelField, &rel))
- continue;
- if (rel != kLinkRelPhotoValue)
- continue;
-
- // From https://goo.gl/7T6Od: "If a contact does not have a photo, then the
- // photo link element has no gd:etag attribute."
- std::string etag;
- if (!link_dict->GetString(kLinkETagField, &etag))
- continue;
-
- std::string url;
- if (link_dict->GetString(kLinkHrefField, &url))
- return url;
- }
- return std::string();
-}
-
-// Fills a Contact's fields using an entry from a GData feed.
-bool FillContactFromDictionary(const base::DictionaryValue& dict,
- contacts::Contact* contact) {
- DCHECK(contact);
- contact->Clear();
-
- if (!dict.GetString(kIdField, contact->mutable_contact_id()))
- return false;
-
- std::string updated;
- if (dict.GetString(kUpdatedField, &updated)) {
- base::Time update_time;
- if (!google_apis::util::GetTimeFromString(updated, &update_time)) {
- LOG(WARNING) << "Unable to parse time \"" << updated << "\"";
- return false;
- }
- contact->set_update_time(update_time.ToInternalValue());
- }
-
- const base::Value* deleted_value = NULL;
- contact->set_deleted(dict.Get(kDeletedField, &deleted_value));
- if (contact->deleted())
- return true;
-
- GetCleanedString(dict, kFullNameField, contact->mutable_full_name());
- GetCleanedString(dict, kGivenNameField, contact->mutable_given_name());
- GetCleanedString(
- dict, kAdditionalNameField, contact->mutable_additional_name());
- GetCleanedString(dict, kFamilyNameField, contact->mutable_family_name());
- GetCleanedString(dict, kNamePrefixField, contact->mutable_name_prefix());
- GetCleanedString(dict, kNameSuffixField, contact->mutable_name_suffix());
-
- const base::ListValue* email_list = NULL;
- if (dict.GetList(kEmailField, &email_list)) {
- for (size_t i = 0; i < email_list->GetSize(); ++i) {
- const base::DictionaryValue* email_dict = NULL;
- if (!email_list->GetDictionary(i, &email_dict))
- return false;
-
- contacts::Contact_EmailAddress* email = contact->add_email_addresses();
- if (!GetCleanedString(*email_dict,
- kEmailAddressField,
- email->mutable_address())) {
- return false;
- }
- email->set_primary(IsAddressPrimary(*email_dict));
- InitAddressType(*email_dict, email->mutable_type());
- }
- }
-
- const base::ListValue* phone_list = NULL;
- if (dict.GetList(kPhoneField, &phone_list)) {
- for (size_t i = 0; i < phone_list->GetSize(); ++i) {
- const base::DictionaryValue* phone_dict = NULL;
- if (!phone_list->GetDictionary(i, &phone_dict))
- return false;
-
- contacts::Contact_PhoneNumber* phone = contact->add_phone_numbers();
- if (!GetCleanedString(*phone_dict,
- kPhoneNumberField,
- phone->mutable_number())) {
- return false;
- }
- phone->set_primary(IsAddressPrimary(*phone_dict));
- InitAddressType(*phone_dict, phone->mutable_type());
- }
- }
-
- const base::ListValue* address_list = NULL;
- if (dict.GetList(kPostalAddressField, &address_list)) {
- for (size_t i = 0; i < address_list->GetSize(); ++i) {
- const base::DictionaryValue* address_dict = NULL;
- if (!address_list->GetDictionary(i, &address_dict))
- return false;
-
- contacts::Contact_PostalAddress* address =
- contact->add_postal_addresses();
- if (!GetCleanedString(*address_dict,
- kPostalAddressFormattedField,
- address->mutable_address())) {
- return false;
- }
- address->set_primary(IsAddressPrimary(*address_dict));
- InitAddressType(*address_dict, address->mutable_type());
- }
- }
-
- const base::ListValue* im_list = NULL;
- if (dict.GetList(kInstantMessagingField, &im_list)) {
- for (size_t i = 0; i < im_list->GetSize(); ++i) {
- const base::DictionaryValue* im_dict = NULL;
- if (!im_list->GetDictionary(i, &im_dict))
- return false;
-
- contacts::Contact_InstantMessagingAddress* im =
- contact->add_instant_messaging_addresses();
- if (!GetCleanedString(*im_dict,
- kInstantMessagingAddressField,
- im->mutable_address())) {
- return false;
- }
- im->set_primary(IsAddressPrimary(*im_dict));
- InitAddressType(*im_dict, im->mutable_type());
- im->set_protocol(GetInstantMessagingProtocol(*im_dict));
- }
- }
-
- return true;
-}
-
-// Structure into which we parse the contact groups feed using
-// JSONValueConverter.
-struct ContactGroups {
- struct ContactGroup {
- // Group ID, e.g.
- // "http://www.google.com/m8/feeds/groups/user%40gmail.com/base/6".
- std::string group_id;
-
- // System group ID (e.g. "Contacts" for the "My Contacts" system group) if
- // this is a system group, and empty otherwise. See http://goo.gl/oWVnN
- // for more details.
- std::string system_group_id;
- };
-
- // Given a system group ID, returns the corresponding group ID or an empty
- // string if the requested system group wasn't present.
- std::string GetGroupIdForSystemGroup(const std::string& system_group_id) {
- for (size_t i = 0; i < groups.size(); ++i) {
- const ContactGroup& group = *groups[i];
- if (group.system_group_id == system_group_id)
- return group.group_id;
- }
- return std::string();
- }
-
- // Given |value| corresponding to a dictionary in a contact group feed's
- // "entry" list, fills |result| with information about the group.
- static bool GetContactGroup(const base::Value* value, ContactGroup* result) {
- DCHECK(value);
- DCHECK(result);
- const base::DictionaryValue* dict = NULL;
- if (!value->GetAsDictionary(&dict))
- return false;
-
- dict->GetString(kIdField, &result->group_id);
- dict->GetString(kSystemGroupIdField, &result->system_group_id);
- return true;
- }
-
- static void RegisterJSONConverter(
- base::JSONValueConverter<ContactGroups>* converter) {
- DCHECK(converter);
- converter->RegisterRepeatedCustomValue<ContactGroup>(
- kGroupEntryField, &ContactGroups::groups, &GetContactGroup);
- }
-
- ScopedVector<ContactGroup> groups;
-};
-
-} // namespace
-
-// This class handles a single request to download all of a user's contacts.
-//
-// First, the feed containing the user's contact groups is downloaded via
-// GetContactGroupsRequest and examined to find the ID for the "My Contacts"
-// group (by default, the contacts API also returns suggested contacts). The
-// group ID is cached in GDataContactsService so that this step can be skipped
-// by later DownloadContactRequests.
-//
-// Next, the contacts feed is downloaded via GetContactsRequest and parsed.
-// Individual contacts::Contact objects are created using the data from the
-// feed.
-//
-// Finally, GetContactPhotoRequests are created and used to start downloading
-// contacts' photos in parallel. When all photos have been downloaded, the
-// contacts are passed to the passed-in callback.
-class GDataContactsService::DownloadContactsRequest {
- public:
- DownloadContactsRequest(
- GDataContactsService* service,
- google_apis::RequestSender* sender,
- SuccessCallback success_callback,
- FailureCallback failure_callback,
- const base::Time& min_update_time)
- : service_(service),
- sender_(sender),
- success_callback_(success_callback),
- failure_callback_(failure_callback),
- min_update_time_(min_update_time),
- contacts_(new ScopedVector<contacts::Contact>),
- my_contacts_group_id_(service->cached_my_contacts_group_id_),
- num_in_progress_photo_downloads_(0),
- photo_download_failed_(false),
- num_photo_download_404_errors_(0),
- total_photo_bytes_(0),
- weak_ptr_factory_(this) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK(service_);
- DCHECK(sender_);
- }
-
- ~DownloadContactsRequest() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- service_ = NULL;
- sender_ = NULL;
- }
-
- const std::string my_contacts_group_id() const {
- return my_contacts_group_id_;
- }
-
- // Begins the contacts-downloading process. If the ID for the "My Contacts"
- // group has previously been cached, then the contacts download is started.
- // Otherwise, the contact groups download is started.
- void Run() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- download_start_time_ = base::TimeTicks::Now();
- if (!my_contacts_group_id_.empty()) {
- StartContactsDownload();
- } else {
- google_apis::GetContactGroupsRequest* operation =
- new google_apis::GetContactGroupsRequest(
- sender_,
- base::Bind(&DownloadContactsRequest::HandleGroupsFeedData,
- weak_ptr_factory_.GetWeakPtr()));
- if (!service_->groups_feed_url_for_testing_.is_empty()) {
- operation->set_feed_url_for_testing(
- service_->groups_feed_url_for_testing_);
- }
- sender_->StartRequestWithRetry(operation);
- }
- }
-
- private:
- // Invokes the failure callback and notifies GDataContactsService that the
- // request is done.
- void ReportFailure(HistogramResult histogram_result) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- SendHistograms(histogram_result);
- failure_callback_.Run();
- service_->OnRequestComplete(this);
- }
-
- // Reports UMA stats after the request has completed.
- void SendHistograms(HistogramResult result) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK_GE(result, 0);
- DCHECK_LT(result, HISTOGRAM_RESULT_MAX_VALUE);
-
- bool success = (result == HISTOGRAM_RESULT_SUCCESS);
- base::TimeDelta elapsed_time =
- base::TimeTicks::Now() - download_start_time_;
- int photo_error_percent = static_cast<int>(
- 100.0 * transient_photo_download_errors_per_contact_.size() /
- contact_photo_urls_.size() + 0.5);
-
- if (min_update_time_.is_null()) {
- UMA_HISTOGRAM_ENUMERATION("Contacts.FullUpdateResult",
- result, HISTOGRAM_RESULT_MAX_VALUE);
- if (success) {
- UMA_HISTOGRAM_MEDIUM_TIMES("Contacts.FullUpdateDuration",
- elapsed_time);
- UMA_HISTOGRAM_COUNTS_10000("Contacts.FullUpdateContacts",
- contacts_->size());
- UMA_HISTOGRAM_COUNTS_10000("Contacts.FullUpdatePhotos",
- contact_photo_urls_.size());
- UMA_HISTOGRAM_MEMORY_KB("Contacts.FullUpdatePhotoBytes",
- total_photo_bytes_);
- UMA_HISTOGRAM_COUNTS_10000("Contacts.FullUpdatePhoto404Errors",
- num_photo_download_404_errors_);
- UMA_HISTOGRAM_PERCENTAGE("Contacts.FullUpdatePhotoErrorPercent",
- photo_error_percent);
- }
- } else {
- UMA_HISTOGRAM_ENUMERATION("Contacts.IncrementalUpdateResult",
- result, HISTOGRAM_RESULT_MAX_VALUE);
- if (success) {
- UMA_HISTOGRAM_MEDIUM_TIMES("Contacts.IncrementalUpdateDuration",
- elapsed_time);
- UMA_HISTOGRAM_COUNTS_10000("Contacts.IncrementalUpdateContacts",
- contacts_->size());
- UMA_HISTOGRAM_COUNTS_10000("Contacts.IncrementalUpdatePhotos",
- contact_photo_urls_.size());
- UMA_HISTOGRAM_MEMORY_KB("Contacts.IncrementalUpdatePhotoBytes",
- total_photo_bytes_);
- UMA_HISTOGRAM_COUNTS_10000("Contacts.IncrementalUpdatePhoto404Errors",
- num_photo_download_404_errors_);
- UMA_HISTOGRAM_PERCENTAGE("Contacts.IncrementalUpdatePhotoErrorPercent",
- photo_error_percent);
- }
- }
- }
-
- // Callback for GetContactGroupsRequest calls. Starts downloading the
- // actual contacts after finding the "My Contacts" group ID.
- void HandleGroupsFeedData(google_apis::GDataErrorCode error,
- scoped_ptr<base::Value> feed_data) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- if (error != google_apis::HTTP_SUCCESS) {
- LOG(WARNING) << "Got error " << error << " while downloading groups";
- ReportFailure(HISTOGRAM_RESULT_GROUPS_DOWNLOAD_FAILURE);
- return;
- }
-
- VLOG(2) << "Got groups feed data:\n"
- << PrettyPrintValue(*(feed_data.get()));
- ContactGroups groups;
- base::JSONValueConverter<ContactGroups> converter;
- if (!converter.Convert(*feed_data, &groups)) {
- LOG(WARNING) << "Unable to parse groups feed";
- ReportFailure(HISTOGRAM_RESULT_GROUPS_PARSE_FAILURE);
- return;
- }
-
- my_contacts_group_id_ =
- groups.GetGroupIdForSystemGroup(kMyContactsSystemGroupId);
- if (!my_contacts_group_id_.empty()) {
- StartContactsDownload();
- } else {
- LOG(WARNING) << "Unable to find ID for \"My Contacts\" group";
- ReportFailure(HISTOGRAM_RESULT_MY_CONTACTS_GROUP_NOT_FOUND);
- }
- }
-
- // Starts a download of the contacts from the "My Contacts" group.
- void StartContactsDownload() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- google_apis::GetContactsRequest* operation =
- new google_apis::GetContactsRequest(
- sender_,
- my_contacts_group_id_,
- min_update_time_,
- base::Bind(&DownloadContactsRequest::HandleContactsFeedData,
- weak_ptr_factory_.GetWeakPtr()));
- if (!service_->contacts_feed_url_for_testing_.is_empty()) {
- operation->set_feed_url_for_testing(
- service_->contacts_feed_url_for_testing_);
- }
- sender_->StartRequestWithRetry(operation);
- }
-
- // Callback for GetContactsRequest calls.
- void HandleContactsFeedData(google_apis::GDataErrorCode error,
- scoped_ptr<base::Value> feed_data) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- if (error != google_apis::HTTP_SUCCESS) {
- LOG(WARNING) << "Got error " << error << " while downloading contacts";
- ReportFailure(HISTOGRAM_RESULT_CONTACTS_DOWNLOAD_FAILURE);
- return;
- }
-
- VLOG(2) << "Got contacts feed data:\n"
- << PrettyPrintValue(*(feed_data.get()));
- if (!ProcessContactsFeedData(*feed_data.get())) {
- LOG(WARNING) << "Unable to process contacts feed data";
- ReportFailure(HISTOGRAM_RESULT_CONTACTS_PARSE_FAILURE);
- return;
- }
-
- StartPhotoDownloads();
- photo_download_timer_.Start(
- FROM_HERE, service_->photo_download_timer_interval_,
- this, &DownloadContactsRequest::StartPhotoDownloads);
- CheckCompletion();
- }
-
- // Processes the raw contacts feed from |feed_data| and fills |contacts_|.
- // Returns true on success.
- bool ProcessContactsFeedData(const base::Value& feed_data) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- const base::DictionaryValue* toplevel_dict = NULL;
- if (!feed_data.GetAsDictionary(&toplevel_dict)) {
- LOG(WARNING) << "Top-level object is not a dictionary";
- return false;
- }
-
- const base::DictionaryValue* feed_dict = NULL;
- if (!toplevel_dict->GetDictionary(kFeedField, &feed_dict)) {
- LOG(WARNING) << "Feed dictionary missing";
- return false;
- }
-
- // Check the category field to confirm that this is actually a contact feed.
- const base::ListValue* category_list = NULL;
- if (!feed_dict->GetList(kCategoryField, &category_list)) {
- LOG(WARNING) << "Category list missing";
- return false;
- }
- const base::DictionaryValue* category_dict = NULL;
- if (category_list->GetSize() != 1 ||
- !category_list->GetDictionary(0, &category_dict)) {
- LOG(WARNING) << "Unable to get dictionary from category list of size "
- << category_list->GetSize();
- return false;
- }
- std::string category_scheme, category_term;
- if (!category_dict->GetString(kCategorySchemeField, &category_scheme) ||
- !category_dict->GetString(kCategoryTermField, &category_term) ||
- category_scheme != kCategorySchemeValue ||
- category_term != kCategoryTermValue) {
- LOG(WARNING) << "Unexpected category (scheme was \"" << category_scheme
- << "\", term was \"" << category_term << "\")";
- return false;
- }
-
- // A missing entry list means no entries (maybe we're doing an incremental
- // update and nothing has changed).
- const base::ListValue* entry_list = NULL;
- if (!feed_dict->GetList(kEntryField, &entry_list))
- return true;
-
- contacts_needing_photo_downloads_.reserve(entry_list->GetSize());
-
- for (base::ListValue::const_iterator entry_it = entry_list->begin();
- entry_it != entry_list->end(); ++entry_it) {
- const size_t index = (entry_it - entry_list->begin());
- const base::DictionaryValue* contact_dict = NULL;
- if (!(*entry_it)->GetAsDictionary(&contact_dict)) {
- LOG(WARNING) << "Entry " << index << " isn't a dictionary";
- return false;
- }
-
- scoped_ptr<contacts::Contact> contact(new contacts::Contact);
- if (!FillContactFromDictionary(*contact_dict, contact.get())) {
- LOG(WARNING) << "Unable to fill entry " << index;
- return false;
- }
-
- VLOG(1) << "Got contact " << index << ":"
- << " id=" << contact->contact_id()
- << " full_name=\"" << contact->full_name() << "\""
- << " update_time=" << contact->update_time();
-
- std::string photo_url = GetPhotoUrl(*contact_dict);
- if (!photo_url.empty()) {
- if (!service_->rewrite_photo_url_callback_for_testing_.is_null()) {
- photo_url =
- service_->rewrite_photo_url_callback_for_testing_.Run(photo_url);
- }
- contact_photo_urls_[contact.get()] = photo_url;
- contacts_needing_photo_downloads_.push_back(contact.get());
- }
-
- contacts_->push_back(contact.release());
- }
-
- return true;
- }
-
- // If we're done downloading photos, invokes a callback and deletes |this|.
- // Otherwise, starts one or more downloads of URLs from
- // |contacts_needing_photo_downloads_|.
- void CheckCompletion() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- if (contacts_needing_photo_downloads_.empty() &&
- num_in_progress_photo_downloads_ == 0) {
- VLOG(1) << "Done downloading photos; invoking callback";
- photo_download_timer_.Stop();
- if (photo_download_failed_) {
- ReportFailure(HISTOGRAM_RESULT_PHOTO_DOWNLOAD_FAILURE );
- } else {
- SendHistograms(HISTOGRAM_RESULT_SUCCESS);
- success_callback_.Run(contacts_.Pass());
- service_->OnRequestComplete(this);
- }
- return;
- }
- }
-
- // Starts photo downloads for contacts in |contacts_needing_photo_downloads_|.
- // Should be invoked only once per second.
- void StartPhotoDownloads() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- while (!contacts_needing_photo_downloads_.empty() &&
- (num_in_progress_photo_downloads_ <
- service_->max_photo_downloads_per_second_)) {
- contacts::Contact* contact = contacts_needing_photo_downloads_.back();
- contacts_needing_photo_downloads_.pop_back();
- DCHECK(contact_photo_urls_.count(contact));
- std::string url = contact_photo_urls_[contact];
-
- VLOG(1) << "Starting download of photo " << url << " for "
- << contact->contact_id();
- sender_->StartRequestWithRetry(
- new google_apis::GetContactPhotoRequest(
- sender_,
- GURL(url),
- base::Bind(&DownloadContactsRequest::HandlePhotoData,
- weak_ptr_factory_.GetWeakPtr(),
- contact)));
- num_in_progress_photo_downloads_++;
- }
- }
-
- // Callback for GetContactPhotoRequest calls. Updates the associated
- // Contact and checks for completion.
- void HandlePhotoData(contacts::Contact* contact,
- google_apis::GDataErrorCode error,
- scoped_ptr<std::string> download_data) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- VLOG(1) << "Got photo data for " << contact->contact_id()
- << " (error=" << error << " size=" << download_data->size() << ")";
- num_in_progress_photo_downloads_--;
-
- if (error == google_apis::HTTP_INTERNAL_SERVER_ERROR ||
- error == google_apis::HTTP_SERVICE_UNAVAILABLE) {
- int num_errors = ++transient_photo_download_errors_per_contact_[contact];
- if (num_errors <= kMaxTransientPhotoDownloadErrorsPerContact) {
- LOG(WARNING) << "Got error " << error << " while downloading photo "
- << "for " << contact->contact_id() << "; retrying";
- contacts_needing_photo_downloads_.push_back(contact);
- return;
- }
- }
-
- if (error == google_apis::HTTP_NOT_FOUND) {
- LOG(WARNING) << "Got error " << error << " while downloading photo "
- << "for " << contact->contact_id() << "; skipping";
- num_photo_download_404_errors_++;
- CheckCompletion();
- return;
- }
-
- if (error != google_apis::HTTP_SUCCESS) {
- LOG(WARNING) << "Got error " << error << " while downloading photo "
- << "for " << contact->contact_id() << "; giving up";
- photo_download_failed_ = true;
- // Make sure we don't start any more downloads.
- contacts_needing_photo_downloads_.clear();
- CheckCompletion();
- return;
- }
-
- total_photo_bytes_ += download_data->size();
- contact->set_raw_untrusted_photo(*download_data);
- CheckCompletion();
- }
-
- typedef std::map<contacts::Contact*, std::string> ContactPhotoUrls;
-
- GDataContactsService* service_; // not owned
- google_apis::RequestSender* sender_; // not owned
-
- SuccessCallback success_callback_;
- FailureCallback failure_callback_;
-
- base::Time min_update_time_;
-
- scoped_ptr<ScopedVector<contacts::Contact> > contacts_;
-
- // ID of the "My Contacts" contacts group.
- std::string my_contacts_group_id_;
-
- // Map from a contact to the URL at which its photo is located.
- // Contacts without photos do not appear in this map.
- ContactPhotoUrls contact_photo_urls_;
-
- // Invokes StartPhotoDownloads() once per second.
- base::RepeatingTimer<DownloadContactsRequest> photo_download_timer_;
-
- // Contacts that have photos that we still need to start downloading.
- // When we start a download, the contact is removed from this list.
- std::vector<contacts::Contact*> contacts_needing_photo_downloads_;
-
- // Number of in-progress photo downloads.
- int num_in_progress_photo_downloads_;
-
- // Map from a contact to the number of transient errors that we've encountered
- // while trying to download its photo. Contacts for which no errors have been
- // encountered aren't represented in the map.
- std::map<contacts::Contact*, int>
- transient_photo_download_errors_per_contact_;
-
- // Did we encounter a fatal error while downloading a photo?
- bool photo_download_failed_;
-
- // How many photos did we skip due to 404 errors?
- int num_photo_download_404_errors_;
-
- // Total size of all photos that were downloaded.
- size_t total_photo_bytes_;
-
- // Time at which Run() was called.
- base::TimeTicks download_start_time_;
-
- // Note: This should remain the last member so it'll be destroyed and
- // invalidate its weak pointers before any other members are destroyed.
- base::WeakPtrFactory<DownloadContactsRequest> weak_ptr_factory_;
-
- DISALLOW_COPY_AND_ASSIGN(DownloadContactsRequest);
-};
-
-GDataContactsService::GDataContactsService(
- net::URLRequestContextGetter* url_request_context_getter,
- google_apis::AuthServiceInterface* auth_service)
- : max_photo_downloads_per_second_(kMaxPhotoDownloadsPerSecond),
- photo_download_timer_interval_(base::TimeDelta::FromSeconds(1)) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- sender_.reset(new google_apis::RequestSender(
- auth_service,
- url_request_context_getter,
- BrowserThread::GetBlockingPool()->GetSequencedTaskRunner(
- BrowserThread::GetBlockingPool()->GetSequenceToken()).get(),
- "" /* custom_user_agent */));
-}
-
-GDataContactsService::~GDataContactsService() {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- STLDeleteContainerPointers(requests_.begin(), requests_.end());
- requests_.clear();
-}
-
-void GDataContactsService::DownloadContacts(SuccessCallback success_callback,
- FailureCallback failure_callback,
- const base::Time& min_update_time) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DownloadContactsRequest* request =
- new DownloadContactsRequest(this,
- sender_.get(),
- success_callback,
- failure_callback,
- min_update_time);
- VLOG(1) << "Starting contacts download with request " << request;
- requests_.insert(request);
- request->Run();
-}
-
-void GDataContactsService::OnRequestComplete(DownloadContactsRequest* request) {
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
- DCHECK(request);
- VLOG(1) << "Download request " << request << " complete";
- if (!request->my_contacts_group_id().empty())
- cached_my_contacts_group_id_ = request->my_contacts_group_id();
- requests_.erase(request);
- delete request;
-}
-
-} // namespace contacts

Powered by Google App Engine
This is Rietveld 408576698