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>
 
@@ skipping 220 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,

[Peter Beverloo, 2017/02/08 17:09:08]

nit: generally we have a mild preference of writing nested base::Bind()
callbacks to a local, because it significantly reduces nesting.

[harkness, 2017/02/09 16:27:29]

Done.

+                                       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 36 matching lines @@
   } 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) {
+                                    const IncomingMessage& message,
+                                    const MessageReceiptCallback& callback) {
   if (delegate_)
-    delegate_->OnMessageReceived(app_id, message);
+    delegate_->OnMessageReceived(app_id, message, 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