Provide a mechanism for the GCM driver to send message receipts to GCM.

components/gcm_driver/fake_gcm_client.cc

 // Copyright 2014 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 "components/gcm_driver/fake_gcm_client.h"
 
 #include <stddef.h>
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/sequenced_task_runner.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/sys_byteorder.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
+#include "components/sync/base/bind_to_task_runner.h"
 #include "google_apis/gcm/base/encryptor.h"
 #include "google_apis/gcm/engine/account_mapping.h"
 #include "net/base/ip_endpoint.h"
 
 namespace gcm {
 
 // static
 std::string FakeGCMClient::GenerateGCMRegistrationID(
     const std::vector<std::string>& sender_ids) {
   // GCMService normalizes the sender IDs by making them sorted.
@@ skipping 200 matching lines @@
 
 void FakeGCMClient::PerformDelayedStart() {
   DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
   io_thread_->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::DoStart, weak_ptr_factory_.GetWeakPtr()));
 }
 
 void FakeGCMClient::ReceiveMessage(const std::string& app_id,
+                                   const std::string& message_id,
                                    const IncomingMessage& message) {
   DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
   io_thread_->PostTask(
-      FROM_HERE,
-      base::Bind(&FakeGCMClient::MessageReceived,
-                 weak_ptr_factory_.GetWeakPtr(),
-                 app_id,
-                 message));
+      FROM_HERE, base::Bind(&FakeGCMClient::MessageReceived,
+                            weak_ptr_factory_.GetWeakPtr(), app_id, message,
+                            base::Bind(&FakeGCMClient::SendMessageReceipt,
+                                       weak_ptr_factory_.GetWeakPtr(),
+                                       message_id, app_id)));
+}
+
+void FakeGCMClient::SendMessageReceipt(const std::string& message_id,
+                                       const std::string& app_id,
+                                       GCMMessageStatus status) {
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
+
+  receipt_message_id_ = message_id;
+  receipt_app_id_ = app_id;
+  receipt_status_ = status;
 }
 
 void FakeGCMClient::DeleteMessages(const std::string& app_id) {
   DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
   io_thread_->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::MessagesDeleted,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id));
@@ skipping 35 matching lines @@
         base::TimeDelta::FromMilliseconds(200));
   } else if(message.id.find("ack") != std::string::npos) {
     base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
         FROM_HERE,
         base::Bind(&FakeGCMClient::SendAcknowledgement,
                    weak_ptr_factory_.GetWeakPtr(), app_id, message.id),
         base::TimeDelta::FromMilliseconds(200));
   }
 }
 
-void FakeGCMClient::MessageReceived(const std::string& app_id,
-                                    const IncomingMessage& message) {
+void FakeGCMClient::MessageReceived(
+    const std::string& app_id,
+    const IncomingMessage& message,
+    const GCMClient::MessageReceiptCallback& callback) {
   if (delegate_)
-    delegate_->OnMessageReceived(app_id, message);
+    delegate_->OnMessageReceived(app_id, message,
+                                 syncer::BindToCurrentThread(callback));
 }
 
 void FakeGCMClient::MessagesDeleted(const std::string& app_id) {
   if (delegate_)
     delegate_->OnMessagesDeleted(app_id);
 }
 
 void FakeGCMClient::MessageSendError(
     const std::string& app_id,
     const GCMClient::SendErrorDetails& send_error_details) {
   if (delegate_)
     delegate_->OnMessageSendError(app_id, send_error_details);
 }
 
 void FakeGCMClient::SendAcknowledgement(const std::string& app_id,
                                         const std::string& message_id) {
   if (delegate_)
     delegate_->OnSendAcknowledged(app_id, message_id);
 }
 
 }  // namespace gcm