[GCM] Adding the OnSendAcknowledgement event

components/gcm_driver/gcm_driver_desktop_unittest.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/gcm_driver_desktop.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/files/scoped_temp_dir.h"
 #include "base/location.h"
@@ skipping 211 matching lines @@
   PumpIOLoop();
   PumpUILoop();
 }
 
 void GCMDriverTest::Register(const std::string& app_id,
                              const std::vector<std::string>& sender_ids,
                              WaitToFinish wait_to_finish) {
   base::RunLoop run_loop;
   async_operation_completed_callback_ = run_loop.QuitClosure();
   driver_->Register(app_id,
-                     sender_ids,
-                     base::Bind(&GCMDriverTest::RegisterCompleted,
-                                base::Unretained(this)));
+                    sender_ids,
+                    base::Bind(&GCMDriverTest::RegisterCompleted,
+                               base::Unretained(this)));
   if (wait_to_finish == WAIT)
     run_loop.Run();
 }
 
 void GCMDriverTest::Send(const std::string& app_id,
                          const std::string& receiver_id,
                          const GCMClient::OutgoingMessage& message,
                          WaitToFinish wait_to_finish) {
   base::RunLoop run_loop;
   async_operation_completed_callback_ = run_loop.QuitClosure();
   driver_->Send(app_id,
-                 receiver_id,
-                 message,
-                 base::Bind(&GCMDriverTest::SendCompleted,
-                            base::Unretained(this)));
+                receiver_id,
+                message,
+                base::Bind(&GCMDriverTest::SendCompleted,
+                           base::Unretained(this)));
   if (wait_to_finish == WAIT)
     run_loop.Run();
 }
 
 void GCMDriverTest::Unregister(const std::string& app_id,
                                WaitToFinish wait_to_finish) {
   base::RunLoop run_loop;
   async_operation_completed_callback_ = run_loop.QuitClosure();
   driver_->Unregister(app_id,
                        base::Bind(&GCMDriverTest::UnregisterCompleted,
@@ skipping 530 matching lines @@
   WaitForAsyncOperation();
   EXPECT_EQ(GCMClient::SUCCESS, unregistration_result());
 
   // Test that it is ok to register again after unregistration.
   Register(kTestAppID1, sender_ids, GCMDriverTest::WAIT);
   EXPECT_EQ(GCMClient::SUCCESS, registration_result());
 }
 
 TEST_F(GCMDriverFunctionalTest, Send) {
   GCMClient::OutgoingMessage message;
-  message.id = "1";
+  message.id = "1@ack";
   message.data["key1"] = "value1";
   message.data["key2"] = "value2";
   Send(kTestAppID1, kUserID1, message, GCMDriverTest::WAIT);
 
   EXPECT_EQ(message.id, send_message_id());
   EXPECT_EQ(GCMClient::SUCCESS, send_result());
+
+  gcm_app_handler()->WaitForNotification();
+  EXPECT_EQ(message.id, gcm_app_handler()->acked_message_id());
+  EXPECT_EQ(kTestAppID1, gcm_app_handler()->app_id());
 }
 
 TEST_F(GCMDriverFunctionalTest, SendAfterSignOut) {
   // This will trigger check-out.
   SignOut();
 
   GCMClient::OutgoingMessage message;
   message.id = "1";
   message.data["key1"] = "value1";
   message.data["key2"] = "value2";
@@ skipping 61 matching lines @@
 
 TEST_F(GCMDriverFunctionalTest, MessagesDeleted) {
   GetGCMClient()->DeleteMessages(kTestAppID1);
   gcm_app_handler()->WaitForNotification();
   EXPECT_EQ(FakeGCMAppHandler::MESSAGES_DELETED_EVENT,
             gcm_app_handler()->received_event());
   EXPECT_EQ(kTestAppID1, gcm_app_handler()->app_id());
 }
 
 }  // namespace gcm