google_apis: Rename OperationRunner to RequestSender

chrome/browser/chromeos/contacts/gdata_contacts_service.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/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/string_util.h"
 #include "base/time.h"
 #include "base/timer.h"
 #include "base/values.h"
 #include "chrome/browser/chromeos/contacts/contact.pb.h"
+#include "chrome/browser/google_apis/gdata_contacts_operations.h"
 #include "chrome/browser/google_apis/gdata_errorcode.h"
-#include "chrome/browser/google_apis/gdata_contacts_operations.h"
-#include "chrome/browser/google_apis/operation_runner.h"
+#include "chrome/browser/google_apis/request_sender.h"
 #include "chrome/browser/google_apis/time_util.h"
 #include "content/public/browser/browser_thread.h"
 
 using content::BrowserThread;
 
 namespace contacts {
 
 namespace {
 
 // Download outcomes reported via the "Contacts.FullUpdateResult" and
@@ skipping 393 matching lines @@
 // Individual contacts::Contact objects are created using the data from the
 // feed.
 //
 // Finally, GetContactPhotoOperations 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::OperationRunner* runner,
+      google_apis::RequestSender* runner,
       net::URLRequestContextGetter* url_request_context_getter,
       SuccessCallback success_callback,
       FailureCallback failure_callback,
       const base::Time& min_update_time)
       : service_(service),
-        runner_(runner),
+        sender_(runner),
         url_request_context_getter_(url_request_context_getter),
         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(runner_);
+    DCHECK(sender_);
   }
 
   ~DownloadContactsRequest() {
     DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
     service_ = NULL;
-    runner_ = 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::GetContactGroupsOperation* operation =
           new google_apis::GetContactGroupsOperation(
-              runner_,
+              sender_,
               url_request_context_getter_,
               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_);
       }
-      runner_->StartOperationWithRetry(operation);
+      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();
@@ skipping 79 matching lines @@
       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::GetContactsOperation* operation =
         new google_apis::GetContactsOperation(
-            runner_,
+            sender_,
             url_request_context_getter_,
             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_);
     }
-    runner_->StartOperationWithRetry(operation);
+    sender_->StartRequestWithRetry(operation);
   }
 
   // Callback for GetContactsOperation 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;
@@ skipping 124 matching lines @@
     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();
-      runner_->StartOperationWithRetry(
+      sender_->StartRequestWithRetry(
           new google_apis::GetContactPhotoOperation(
-              runner_,
+              sender_,
               url_request_context_getter_,
               GURL(url),
               base::Bind(&DownloadContactsRequest::HandlePhotoData,
                          weak_ptr_factory_.GetWeakPtr(),
                          contact)));
       num_in_progress_photo_downloads_++;
     }
   }
 
   // Callback for GetContactPhotoOperation calls.  Updates the associated
@@ skipping 36 matching lines @@
     }
 
     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::OperationRunner* runner_;  // not owned
+  google_apis::RequestSender* sender_;  // not owned
   net::URLRequestContextGetter* url_request_context_getter_;  // 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.
@@ skipping 40 matching lines @@
 
 GDataContactsService::GDataContactsService(
     net::URLRequestContextGetter* url_request_context_getter,
     Profile* profile)
     : url_request_context_getter_(url_request_context_getter),
       max_photo_downloads_per_second_(kMaxPhotoDownloadsPerSecond),
       photo_download_timer_interval_(base::TimeDelta::FromSeconds(1)) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   std::vector<std::string> scopes;
   scopes.push_back(kContactsScope);
-  runner_.reset(new google_apis::OperationRunner(profile,
-                                                 url_request_context_getter_,
-                                                 scopes,
-                                                 "" /* custom_user_agent */));
+  sender_.reset(new google_apis::RequestSender(profile,
+                                               url_request_context_getter_,
+                                               scopes,
+                                               "" /* custom_user_agent */));
 }
 
 GDataContactsService::~GDataContactsService() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  runner_->CancelAll();
+  sender_->CancelAll();
   STLDeleteContainerPointers(requests_.begin(), requests_.end());
   requests_.clear();
 }
 
 google_apis::AuthService* GDataContactsService::auth_service_for_testing() {
-  return runner_->auth_service();
+  return sender_->auth_service();
 }
 
 void GDataContactsService::Initialize() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  runner_->Initialize();
+  sender_->Initialize();
 }
 
 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,
-                                  runner_.get(),
+                                  sender_.get(),
                                   url_request_context_getter_,
                                   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