| Index: chrome/browser/services/gcm/gcm_service_unittest.cc
|
| diff --git a/chrome/browser/services/gcm/gcm_service_unittest.cc b/chrome/browser/services/gcm/gcm_service_unittest.cc
|
| deleted file mode 100644
|
| index 575e11c93a908e7eee7416d28a8cc29459b4836a..0000000000000000000000000000000000000000
|
| --- a/chrome/browser/services/gcm/gcm_service_unittest.cc
|
| +++ /dev/null
|
| @@ -1,1322 +0,0 @@
|
| -// 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 "chrome/browser/services/gcm/gcm_service.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/bind_helpers.h"
|
| -#include "base/files/scoped_temp_dir.h"
|
| -#include "base/location.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/run_loop.h"
|
| -#include "base/strings/string_util.h"
|
| -#include "chrome/browser/services/gcm/fake_gcm_client_factory.h"
|
| -#include "chrome/browser/services/gcm/gcm_client_mock.h"
|
| -#include "components/gcm_driver/gcm_app_handler.h"
|
| -#include "components/gcm_driver/gcm_client_factory.h"
|
| -#include "content/public/browser/browser_thread.h"
|
| -#include "content/public/test/test_browser_thread_bundle.h"
|
| -#include "google_apis/gaia/fake_identity_provider.h"
|
| -#include "google_apis/gaia/fake_oauth2_token_service.h"
|
| -#include "google_apis/gcm/base/fake_encryptor.h"
|
| -#include "net/url_request/url_request_context_getter.h"
|
| -#include "net/url_request/url_request_test_util.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace gcm {
|
| -
|
| -namespace {
|
| -
|
| -const char kTestAccountID1[] = "user1@example.com";
|
| -const char kTestAccountID2[] = "user2@example.com";
|
| -const char kTestAccountID3[] = "user3@example.com";
|
| -const char kTestAppID1[] = "TestApp1";
|
| -const char kTestAppID2[] = "TestApp2";
|
| -const char kUserID1[] = "user1";
|
| -const char kUserID2[] = "user2";
|
| -
|
| -void PumpCurrentLoop() {
|
| - base::MessageLoop::ScopedNestableTaskAllower
|
| - nestable_task_allower(base::MessageLoop::current());
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -void PumpUILoop() {
|
| - PumpCurrentLoop();
|
| -}
|
| -
|
| -void PumpIOLoop() {
|
| - base::RunLoop run_loop;
|
| - content::BrowserThread::PostTaskAndReply(content::BrowserThread::IO,
|
| - FROM_HERE,
|
| - base::Bind(&PumpCurrentLoop),
|
| - run_loop.QuitClosure());
|
| - run_loop.Run();
|
| -}
|
| -
|
| -std::vector<std::string> ToSenderList(const std::string& sender_ids) {
|
| - std::vector<std::string> senders;
|
| - Tokenize(sender_ids, ",", &senders);
|
| - return senders;
|
| -}
|
| -
|
| -class FakeGCMAppHandler : public GCMAppHandler {
|
| - public:
|
| - enum Event {
|
| - NO_EVENT,
|
| - MESSAGE_EVENT,
|
| - MESSAGES_DELETED_EVENT,
|
| - SEND_ERROR_EVENT
|
| - };
|
| -
|
| - FakeGCMAppHandler();
|
| - virtual ~FakeGCMAppHandler();
|
| -
|
| - const Event& received_event() const { return received_event_; }
|
| - const std::string& app_id() const { return app_id_; }
|
| - const GCMClient::IncomingMessage& message() const { return message_; }
|
| - const GCMClient::SendErrorDetails& send_error_details() const {
|
| - return send_error_details_;
|
| - }
|
| -
|
| - void WaitForNotification();
|
| -
|
| - // GCMAppHandler:
|
| - virtual void ShutdownHandler() OVERRIDE;
|
| - virtual void OnMessage(const std::string& app_id,
|
| - const GCMClient::IncomingMessage& message) OVERRIDE;
|
| - virtual void OnMessagesDeleted(const std::string& app_id) OVERRIDE;
|
| - virtual void OnSendError(
|
| - const std::string& app_id,
|
| - const GCMClient::SendErrorDetails& send_error_details) OVERRIDE;
|
| -
|
| - private:
|
| - void ClearResults();
|
| -
|
| - scoped_ptr<base::RunLoop> run_loop_;
|
| -
|
| - Event received_event_;
|
| - std::string app_id_;
|
| - GCMClient::IncomingMessage message_;
|
| - GCMClient::SendErrorDetails send_error_details_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(FakeGCMAppHandler);
|
| -};
|
| -
|
| -class TestGCMService : public GCMService {
|
| - public:
|
| - TestGCMService(
|
| - bool start_automatically,
|
| - scoped_ptr<IdentityProvider> identity_provider,
|
| - const scoped_refptr<net::URLRequestContextGetter>& request_context);
|
| - virtual ~TestGCMService();
|
| -
|
| - protected:
|
| - // GCMService:
|
| - virtual bool ShouldStartAutomatically() const OVERRIDE;
|
| - virtual base::FilePath GetStorePath() const OVERRIDE;
|
| - virtual scoped_refptr<net::URLRequestContextGetter>
|
| - GetURLRequestContextGetter() const OVERRIDE;
|
| -
|
| - private:
|
| - base::ScopedTempDir temp_dir_;
|
| - scoped_refptr<net::URLRequestContextGetter> request_context_;
|
| - const bool start_automatically_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(TestGCMService);
|
| -};
|
| -
|
| -FakeGCMAppHandler::FakeGCMAppHandler() : received_event_(NO_EVENT) {
|
| -}
|
| -
|
| -FakeGCMAppHandler::~FakeGCMAppHandler() {
|
| -}
|
| -
|
| -void FakeGCMAppHandler::WaitForNotification() {
|
| - run_loop_.reset(new base::RunLoop);
|
| - run_loop_->Run();
|
| - run_loop_.reset();
|
| -}
|
| -
|
| -void FakeGCMAppHandler::ShutdownHandler() {
|
| -}
|
| -
|
| -void FakeGCMAppHandler::OnMessage(const std::string& app_id,
|
| - const GCMClient::IncomingMessage& message) {
|
| - ClearResults();
|
| - received_event_ = MESSAGE_EVENT;
|
| - app_id_ = app_id;
|
| - message_ = message;
|
| - if (run_loop_)
|
| - run_loop_->Quit();
|
| -}
|
| -
|
| -void FakeGCMAppHandler::OnMessagesDeleted(const std::string& app_id) {
|
| - ClearResults();
|
| - received_event_ = MESSAGES_DELETED_EVENT;
|
| - app_id_ = app_id;
|
| - if (run_loop_)
|
| - run_loop_->Quit();
|
| -}
|
| -
|
| -void FakeGCMAppHandler::OnSendError(
|
| - const std::string& app_id,
|
| - const GCMClient::SendErrorDetails& send_error_details) {
|
| - ClearResults();
|
| - received_event_ = SEND_ERROR_EVENT;
|
| - app_id_ = app_id;
|
| - send_error_details_ = send_error_details;
|
| - if (run_loop_)
|
| - run_loop_->Quit();
|
| -}
|
| -
|
| -void FakeGCMAppHandler::ClearResults() {
|
| - received_event_ = NO_EVENT;
|
| - app_id_.clear();
|
| - message_ = GCMClient::IncomingMessage();
|
| - send_error_details_ = GCMClient::SendErrorDetails();
|
| -}
|
| -
|
| -TestGCMService::TestGCMService(
|
| - bool start_automatically,
|
| - scoped_ptr<IdentityProvider> identity_provider,
|
| - const scoped_refptr<net::URLRequestContextGetter>& request_context)
|
| - : GCMService(identity_provider.Pass()),
|
| - request_context_(request_context),
|
| - start_automatically_(start_automatically) {
|
| - if (!temp_dir_.CreateUniqueTempDir())
|
| - ADD_FAILURE();
|
| -}
|
| -
|
| -TestGCMService::~TestGCMService() {
|
| -}
|
| -
|
| -bool TestGCMService::ShouldStartAutomatically() const {
|
| - return start_automatically_;
|
| -}
|
| -
|
| -base::FilePath TestGCMService::GetStorePath() const {
|
| - return temp_dir_.path();
|
| -}
|
| -
|
| -scoped_refptr<net::URLRequestContextGetter>
|
| -TestGCMService::GetURLRequestContextGetter() const {
|
| - return request_context_;
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -class TestGCMServiceWrapper {
|
| - public:
|
| - enum WaitToFinish {
|
| - DO_NOT_WAIT,
|
| - WAIT
|
| - };
|
| -
|
| - explicit TestGCMServiceWrapper(
|
| - const scoped_refptr<net::URLRequestContextGetter>& request_context);
|
| - ~TestGCMServiceWrapper();
|
| -
|
| - TestGCMService* service() { return service_.get(); }
|
| - FakeGCMAppHandler* gcm_app_handler() { return gcm_app_handler_.get(); }
|
| - const std::string& registration_id() const { return registration_id_; }
|
| - GCMClient::Result registration_result() const { return registration_result_; }
|
| - const std::string& send_message_id() const { return send_message_id_; }
|
| - GCMClient::Result send_result() const { return send_result_; }
|
| - GCMClient::Result unregistration_result() const {
|
| - return unregistration_result_;
|
| - }
|
| -
|
| - void ClearRegistrationResult();
|
| - void ClearUnregistrationResult();
|
| -
|
| - bool ServiceHasAppHandlers() const;
|
| - GCMClientMock* GetGCMClient();
|
| -
|
| - void CreateService(bool start_automatically,
|
| - GCMClientMock::StartMode gcm_client_start_mode);
|
| -
|
| - void SignIn(const std::string& account_id);
|
| - void SignOut();
|
| -
|
| - void Register(const std::string& app_id,
|
| - const std::vector<std::string>& sender_ids,
|
| - WaitToFinish wait_to_finish);
|
| - void Send(const std::string& app_id,
|
| - const std::string& receiver_id,
|
| - const GCMClient::OutgoingMessage& message,
|
| - WaitToFinish wait_to_finish);
|
| - void Unregister(const std::string& app_id, WaitToFinish wait_to_finish);
|
| -
|
| - void WaitForAsyncOperation();
|
| -
|
| - private:
|
| - void RegisterCompleted(const std::string& registration_id,
|
| - GCMClient::Result result);
|
| - void SendCompleted(const std::string& message_id, GCMClient::Result result);
|
| - void UnregisterCompleted(GCMClient::Result result);
|
| -
|
| - scoped_refptr<net::URLRequestContextGetter> request_context_;
|
| - FakeOAuth2TokenService token_service_;
|
| - scoped_ptr<FakeIdentityProvider> identity_provider_owner_;
|
| - FakeIdentityProvider* identity_provider_;
|
| - scoped_ptr<TestGCMService> service_;
|
| - scoped_ptr<FakeGCMAppHandler> gcm_app_handler_;
|
| -
|
| - base::Closure async_operation_completed_callback_;
|
| -
|
| - std::string registration_id_;
|
| - GCMClient::Result registration_result_;
|
| - std::string send_message_id_;
|
| - GCMClient::Result send_result_;
|
| - GCMClient::Result unregistration_result_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(TestGCMServiceWrapper);
|
| -};
|
| -
|
| -TestGCMServiceWrapper::TestGCMServiceWrapper(
|
| - const scoped_refptr<net::URLRequestContextGetter>& request_context)
|
| - : request_context_(request_context),
|
| - identity_provider_(NULL),
|
| - registration_result_(GCMClient::UNKNOWN_ERROR),
|
| - send_result_(GCMClient::UNKNOWN_ERROR),
|
| - unregistration_result_(GCMClient::UNKNOWN_ERROR) {
|
| - identity_provider_owner_.reset(new FakeIdentityProvider(&token_service_));
|
| - identity_provider_ = identity_provider_owner_.get();
|
| -}
|
| -
|
| -TestGCMServiceWrapper::~TestGCMServiceWrapper() {
|
| - if (!service_)
|
| - return;
|
| -
|
| - service_->ShutdownService();
|
| - service_.reset();
|
| - PumpIOLoop();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::ClearRegistrationResult() {
|
| - registration_id_.clear();
|
| - registration_result_ = GCMClient::UNKNOWN_ERROR;
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::ClearUnregistrationResult() {
|
| - unregistration_result_ = GCMClient::UNKNOWN_ERROR;
|
| -}
|
| -
|
| -bool TestGCMServiceWrapper::ServiceHasAppHandlers() const {
|
| - return !service_->app_handlers_.empty();
|
| -}
|
| -
|
| -GCMClientMock* TestGCMServiceWrapper::GetGCMClient() {
|
| - return static_cast<GCMClientMock*>(service_->GetGCMClientForTesting());
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::CreateService(
|
| - bool start_automatically,
|
| - GCMClientMock::StartMode gcm_client_start_mode) {
|
| - service_.reset(new TestGCMService(
|
| - start_automatically,
|
| - identity_provider_owner_.PassAs<IdentityProvider>(),
|
| - request_context_));
|
| - service_->Initialize(scoped_ptr<GCMClientFactory>(
|
| - new FakeGCMClientFactory(gcm_client_start_mode)));
|
| -
|
| - gcm_app_handler_.reset(new FakeGCMAppHandler);
|
| - service_->AddAppHandler(kTestAppID1, gcm_app_handler_.get());
|
| - service_->AddAppHandler(kTestAppID2, gcm_app_handler_.get());
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::SignIn(const std::string& account_id) {
|
| - token_service_.AddAccount(account_id);
|
| - identity_provider_->LogIn(account_id);
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::SignOut() {
|
| - identity_provider_->LogOut();
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::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();
|
| - service_->Register(app_id,
|
| - sender_ids,
|
| - base::Bind(&TestGCMServiceWrapper::RegisterCompleted,
|
| - base::Unretained(this)));
|
| - if (wait_to_finish == WAIT)
|
| - run_loop.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::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();
|
| - service_->Send(app_id,
|
| - receiver_id,
|
| - message,
|
| - base::Bind(&TestGCMServiceWrapper::SendCompleted,
|
| - base::Unretained(this)));
|
| - if (wait_to_finish == WAIT)
|
| - run_loop.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::Unregister(const std::string& app_id,
|
| - WaitToFinish wait_to_finish) {
|
| - base::RunLoop run_loop;
|
| - async_operation_completed_callback_ = run_loop.QuitClosure();
|
| - service_->Unregister(app_id,
|
| - base::Bind(&TestGCMServiceWrapper::UnregisterCompleted,
|
| - base::Unretained(this)));
|
| - if (wait_to_finish == WAIT)
|
| - run_loop.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::WaitForAsyncOperation() {
|
| - base::RunLoop run_loop;
|
| - async_operation_completed_callback_ = run_loop.QuitClosure();
|
| - run_loop.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::RegisterCompleted(
|
| - const std::string& registration_id,
|
| - GCMClient::Result result) {
|
| - registration_id_ = registration_id;
|
| - registration_result_ = result;
|
| - if (!async_operation_completed_callback_.is_null())
|
| - async_operation_completed_callback_.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::SendCompleted(const std::string& message_id,
|
| - GCMClient::Result result) {
|
| - send_message_id_ = message_id;
|
| - send_result_ = result;
|
| - if (!async_operation_completed_callback_.is_null())
|
| - async_operation_completed_callback_.Run();
|
| -}
|
| -
|
| -void TestGCMServiceWrapper::UnregisterCompleted(GCMClient::Result result) {
|
| - unregistration_result_ = result;
|
| - if (!async_operation_completed_callback_.is_null())
|
| - async_operation_completed_callback_.Run();
|
| -}
|
| -
|
| -class GCMServiceTest : public testing::Test {
|
| - protected:
|
| - GCMServiceTest();
|
| - virtual ~GCMServiceTest();
|
| -
|
| - // testing::Test:
|
| - virtual void SetUp() OVERRIDE;
|
| - virtual void TearDown() OVERRIDE;
|
| -
|
| - scoped_ptr<content::TestBrowserThreadBundle> thread_bundle_;
|
| - scoped_refptr<net::URLRequestContextGetter> request_context_;
|
| - scoped_ptr<TestGCMServiceWrapper> wrapper_;
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(GCMServiceTest);
|
| -};
|
| -
|
| -GCMServiceTest::GCMServiceTest() {
|
| -}
|
| -
|
| -GCMServiceTest::~GCMServiceTest() {
|
| -}
|
| -
|
| -void GCMServiceTest::SetUp() {
|
| - thread_bundle_.reset(new content::TestBrowserThreadBundle(
|
| - content::TestBrowserThreadBundle::REAL_IO_THREAD));
|
| - request_context_ = new net::TestURLRequestContextGetter(
|
| - content::BrowserThread::GetMessageLoopProxyForThread(
|
| - content::BrowserThread::IO));
|
| - wrapper_.reset(new TestGCMServiceWrapper(request_context_));
|
| -}
|
| -
|
| -void GCMServiceTest::TearDown() {
|
| - wrapper_.reset();
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, CreateGCMServiceBeforeSignIn) {
|
| - // Create CreateGMCService first.
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - EXPECT_FALSE(wrapper_->service()->IsStarted());
|
| -
|
| - // Sign in. This will kick off the check-in.
|
| - wrapper_->SignIn(kTestAccountID1);
|
| - EXPECT_TRUE(wrapper_->service()->IsStarted());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, CreateGCMServiceAfterSignIn) {
|
| - // Sign in. This will not initiate the check-in.
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // Create GCMeService after sign-in.
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - EXPECT_TRUE(wrapper_->service()->IsStarted());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, Shutdown) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - EXPECT_TRUE(wrapper_->ServiceHasAppHandlers());
|
| -
|
| - wrapper_->service()->ShutdownService();
|
| - EXPECT_FALSE(wrapper_->ServiceHasAppHandlers());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, SignInAndSignOutUnderPositiveChannelSignal) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should be loaded.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - wrapper_->SignOut();
|
| -
|
| - // GCMClient should be checked out.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::CHECKED_OUT, wrapper_->GetGCMClient()->status());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, SignInAndSignOutUnderNonPositiveChannelSignal) {
|
| - // Non-positive channel signal will prevent GCMClient from checking in during
|
| - // sign-in.
|
| - wrapper_->CreateService(false, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should not be loaded.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::UNINITIALIZED, wrapper_->GetGCMClient()->status());
|
| -
|
| - wrapper_->SignOut();
|
| -
|
| - // Check-out should still be performed.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::CHECKED_OUT, wrapper_->GetGCMClient()->status());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, SignOutAndThenSignIn) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should be loaded.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - wrapper_->SignOut();
|
| -
|
| - // GCMClient should be checked out.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::CHECKED_OUT, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Sign-in with a different account.
|
| - wrapper_->SignIn(kTestAccountID2);
|
| -
|
| - // GCMClient should be loaded again.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, StopAndRestartGCM) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should be loaded.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Stops the GCM.
|
| - wrapper_->service()->Stop();
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -
|
| - // GCMClient should be stopped.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STOPPED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Restarts the GCM.
|
| - wrapper_->service()->Start();
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -
|
| - // GCMClient should be loaded.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Stops the GCM.
|
| - wrapper_->service()->Stop();
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -
|
| - // GCMClient should be stopped.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STOPPED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Sign out.
|
| - wrapper_->SignOut();
|
| -
|
| - // GCMClient should be checked out.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::CHECKED_OUT, wrapper_->GetGCMClient()->status());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, RegisterWhenNotSignedIn) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| -
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_TRUE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, RegisterUnderNonPositiveChannelSignal) {
|
| - // Non-positive channel signal will prevent GCMClient from checking in during
|
| - // sign-in.
|
| - wrapper_->CreateService(false, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should not be checked in.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::UNINITIALIZED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Invoking register will make GCMClient checked in.
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // GCMClient should be checked in.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Registration should succeed.
|
| - const std::string expected_registration_id =
|
| - GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids);
|
| - EXPECT_EQ(expected_registration_id, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, SendWhenNotSignedIn) {
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| -
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_TRUE(wrapper_->send_message_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->send_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceTest, SendUnderNonPositiveChannelSignal) {
|
| - // Non-positive channel signal will prevent GCMClient from checking in during
|
| - // sign-in.
|
| - wrapper_->CreateService(false, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // GCMClient should not be checked in.
|
| - EXPECT_FALSE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::UNINITIALIZED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Invoking send will make GCMClient checked in.
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // GCMClient should be checked in.
|
| - EXPECT_TRUE(wrapper_->service()->IsGCMClientReady());
|
| - EXPECT_EQ(GCMClientMock::STARTED, wrapper_->GetGCMClient()->status());
|
| -
|
| - // Sending should succeed.
|
| - EXPECT_EQ(message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -}
|
| -
|
| -// Tests a single instance of GCMService.
|
| -class GCMServiceSingleInstanceTest : public GCMServiceTest {
|
| - public:
|
| - GCMServiceSingleInstanceTest();
|
| - virtual ~GCMServiceSingleInstanceTest();
|
| -
|
| - // GCMServiceTest:
|
| - virtual void SetUp() OVERRIDE;
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(GCMServiceSingleInstanceTest);
|
| -};
|
| -
|
| -GCMServiceSingleInstanceTest::GCMServiceSingleInstanceTest() {
|
| -}
|
| -
|
| -GCMServiceSingleInstanceTest::~GCMServiceSingleInstanceTest() {
|
| -}
|
| -
|
| -void GCMServiceSingleInstanceTest::SetUp() {
|
| - GCMServiceTest::SetUp();
|
| -
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, Register) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - const std::string expected_registration_id =
|
| - GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids);
|
| -
|
| - EXPECT_EQ(expected_registration_id, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, RegisterError) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1@error");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_TRUE(wrapper_->registration_id().empty());
|
| - EXPECT_NE(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, RegisterAgainWithSameSenderIDs) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - sender_ids.push_back("sender2");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - const std::string expected_registration_id =
|
| - GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids);
|
| -
|
| - EXPECT_EQ(expected_registration_id, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - // Clears the results the would be set by the Register callback in preparation
|
| - // to call register 2nd time.
|
| - wrapper_->ClearRegistrationResult();
|
| -
|
| - // Calling register 2nd time with the same set of sender IDs but different
|
| - // ordering will get back the same registration ID.
|
| - std::vector<std::string> another_sender_ids;
|
| - another_sender_ids.push_back("sender2");
|
| - another_sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1,
|
| - another_sender_ids,
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(expected_registration_id, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, RegisterAgainWithDifferentSenderIDs) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - const std::string expected_registration_id =
|
| - GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids);
|
| -
|
| - EXPECT_EQ(expected_registration_id, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - // Make sender IDs different.
|
| - sender_ids.push_back("sender2");
|
| - const std::string expected_registration_id2 =
|
| - GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids);
|
| -
|
| - // Calling register 2nd time with the different sender IDs will get back a new
|
| - // registration ID.
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(expected_registration_id2, wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, GCMClientNotReadyBeforeRegistration) {
|
| - // Make GCMClient not ready initially.
|
| - wrapper_.reset(new TestGCMServiceWrapper(request_context_));
|
| - wrapper_->CreateService(true, GCMClientMock::DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // The registration is on hold until GCMClient is ready.
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1,
|
| - sender_ids,
|
| - TestGCMServiceWrapper::DO_NOT_WAIT);
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| - EXPECT_TRUE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::UNKNOWN_ERROR, wrapper_->registration_result());
|
| -
|
| - // Register operation will be invoked after GCMClient becomes ready.
|
| - wrapper_->GetGCMClient()->PerformDelayedLoading();
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_FALSE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, RegisterAfterSignOut) {
|
| - // This will trigger check-out.
|
| - wrapper_->SignOut();
|
| -
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_TRUE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, UnregisterExplicitly) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_FALSE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - wrapper_->Unregister(kTestAppID1, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->unregistration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, UnregisterWhenAsyncOperationPending) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - // First start registration without waiting for it to complete.
|
| - wrapper_->Register(kTestAppID1,
|
| - sender_ids,
|
| - TestGCMServiceWrapper::DO_NOT_WAIT);
|
| -
|
| - // Test that unregistration fails with async operation pending when there is a
|
| - // registration already in progress.
|
| - wrapper_->Unregister(kTestAppID1, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(GCMClient::ASYNC_OPERATION_PENDING,
|
| - wrapper_->unregistration_result());
|
| -
|
| - // Complete the unregistration.
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - // Start unregistration without waiting for it to complete. This time no async
|
| - // operation is pending.
|
| - wrapper_->Unregister(kTestAppID1, TestGCMServiceWrapper::DO_NOT_WAIT);
|
| -
|
| - // Test that unregistration fails with async operation pending when there is
|
| - // an unregistration already in progress.
|
| - wrapper_->Unregister(kTestAppID1, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(GCMClient::ASYNC_OPERATION_PENDING,
|
| - wrapper_->unregistration_result());
|
| - wrapper_->ClearUnregistrationResult();
|
| -
|
| - // Complete unregistration.
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->unregistration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, RegisterWhenAsyncOperationPending) {
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - // First start registration without waiting for it to complete.
|
| - wrapper_->Register(kTestAppID1,
|
| - sender_ids,
|
| - TestGCMServiceWrapper::DO_NOT_WAIT);
|
| -
|
| - // Test that registration fails with async operation pending when there is a
|
| - // registration already in progress.
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(GCMClient::ASYNC_OPERATION_PENDING,
|
| - wrapper_->registration_result());
|
| - wrapper_->ClearRegistrationResult();
|
| -
|
| - // Complete the registration.
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - // Start unregistration without waiting for it to complete. This time no async
|
| - // operation is pending.
|
| - wrapper_->Unregister(kTestAppID1, TestGCMServiceWrapper::DO_NOT_WAIT);
|
| -
|
| - // Test that registration fails with async operation pending when there is an
|
| - // unregistration already in progress.
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(GCMClient::ASYNC_OPERATION_PENDING,
|
| - wrapper_->registration_result());
|
| -
|
| - // Complete the first unregistration expecting success.
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->unregistration_result());
|
| -
|
| - // Test that it is ok to register again after unregistration.
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, Send) {
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, GCMClientNotReadyBeforeSending) {
|
| - // Make GCMClient not ready initially.
|
| - wrapper_.reset(new TestGCMServiceWrapper(request_context_));
|
| - wrapper_->CreateService(true, GCMClientMock::DELAY_START);
|
| - wrapper_->SignIn(kTestAccountID1);
|
| -
|
| - // The sending is on hold until GCMClient is ready.
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - wrapper_->Send(kTestAppID1,
|
| - kUserID1,
|
| - message,
|
| - TestGCMServiceWrapper::DO_NOT_WAIT);
|
| - PumpIOLoop();
|
| - PumpUILoop();
|
| -
|
| - EXPECT_TRUE(wrapper_->send_message_id().empty());
|
| - EXPECT_EQ(GCMClient::UNKNOWN_ERROR, wrapper_->send_result());
|
| -
|
| - // Send operation will be invoked after GCMClient becomes ready.
|
| - wrapper_->GetGCMClient()->PerformDelayedLoading();
|
| - wrapper_->WaitForAsyncOperation();
|
| - EXPECT_EQ(message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, SendAfterSignOut) {
|
| - // This will trigger check-out.
|
| - wrapper_->SignOut();
|
| -
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_TRUE(wrapper_->send_message_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->send_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, SendError) {
|
| - GCMClient::OutgoingMessage message;
|
| - // Embedding error in id will tell the mock to simulate the send error.
|
| - message.id = "1@error";
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -
|
| - // Wait for the send error.
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| - EXPECT_EQ(FakeGCMAppHandler::SEND_ERROR_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message.id,
|
| - wrapper_->gcm_app_handler()->send_error_details().message_id);
|
| - EXPECT_NE(GCMClient::SUCCESS,
|
| - wrapper_->gcm_app_handler()->send_error_details().result);
|
| - EXPECT_EQ(message.data,
|
| - wrapper_->gcm_app_handler()->send_error_details().additional_data);
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, MessageReceived) {
|
| - wrapper_->Register(kTestAppID1,
|
| - ToSenderList("sender"),
|
| - TestGCMServiceWrapper::WAIT);
|
| - GCMClient::IncomingMessage message;
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - message.sender_id = "sender";
|
| - wrapper_->GetGCMClient()->ReceiveMessage(kTestAppID1, message);
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message.data, wrapper_->gcm_app_handler()->message().data);
|
| - EXPECT_TRUE(wrapper_->gcm_app_handler()->message().collapse_key.empty());
|
| - EXPECT_EQ(message.sender_id,
|
| - wrapper_->gcm_app_handler()->message().sender_id);
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, MessageWithCollapseKeyReceived) {
|
| - wrapper_->Register(kTestAppID1,
|
| - ToSenderList("sender"),
|
| - TestGCMServiceWrapper::WAIT);
|
| - GCMClient::IncomingMessage message;
|
| - message.data["key1"] = "value1";
|
| - message.collapse_key = "collapse_key_value";
|
| - message.sender_id = "sender";
|
| - wrapper_->GetGCMClient()->ReceiveMessage(kTestAppID1, message);
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message.data, wrapper_->gcm_app_handler()->message().data);
|
| - EXPECT_EQ(message.collapse_key,
|
| - wrapper_->gcm_app_handler()->message().collapse_key);
|
| -}
|
| -
|
| -TEST_F(GCMServiceSingleInstanceTest, MessagesDeleted) {
|
| - wrapper_->GetGCMClient()->DeleteMessages(kTestAppID1);
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGES_DELETED_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| -}
|
| -
|
| -// Tests to make sure that concurrent GCMService instances work correctly
|
| -// regardless how GCMClient is created.
|
| -class GCMServiceMultipleInstanceTest : public GCMServiceTest {
|
| - protected:
|
| - GCMServiceMultipleInstanceTest();
|
| - virtual ~GCMServiceMultipleInstanceTest();
|
| -
|
| - // GCMServiceTest:
|
| - virtual void SetUp() OVERRIDE;
|
| - virtual void TearDown() OVERRIDE;
|
| -
|
| - scoped_ptr<TestGCMServiceWrapper> wrapper2_;
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(GCMServiceMultipleInstanceTest);
|
| -};
|
| -
|
| -GCMServiceMultipleInstanceTest::GCMServiceMultipleInstanceTest() {
|
| -}
|
| -
|
| -GCMServiceMultipleInstanceTest::~GCMServiceMultipleInstanceTest() {
|
| -}
|
| -
|
| -void GCMServiceMultipleInstanceTest::SetUp() {
|
| - GCMServiceTest::SetUp();
|
| -
|
| - wrapper2_.reset(new TestGCMServiceWrapper(request_context_));
|
| -
|
| - wrapper_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| - wrapper2_->CreateService(true, GCMClientMock::NO_DELAY_START);
|
| -
|
| - // Initiate check-in for each instance.
|
| - wrapper_->SignIn(kTestAccountID1);
|
| - wrapper2_->SignIn(kTestAccountID2);
|
| -}
|
| -
|
| -void GCMServiceMultipleInstanceTest::TearDown() {
|
| - wrapper2_.reset();
|
| -}
|
| -
|
| -TEST_F(GCMServiceMultipleInstanceTest, Register) {
|
| - // Register an app.
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Register the same app in a different instance.
|
| - std::vector<std::string> sender_ids2;
|
| - sender_ids2.push_back("foo");
|
| - sender_ids2.push_back("bar");
|
| - wrapper2_->Register(kTestAppID1, sender_ids2, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids),
|
| - wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - EXPECT_EQ(GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids2),
|
| - wrapper2_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->registration_result());
|
| -
|
| - // Register a different app in a different instance.
|
| - std::vector<std::string> sender_ids3;
|
| - sender_ids3.push_back("sender1");
|
| - sender_ids3.push_back("sender2");
|
| - sender_ids3.push_back("sender3");
|
| - wrapper2_->Register(kTestAppID2, sender_ids3, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids3),
|
| - wrapper2_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->registration_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceMultipleInstanceTest, Send) {
|
| - // Send a message from one app in one instance.
|
| - GCMClient::OutgoingMessage message;
|
| - message.id = "1";
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - wrapper_->Send(kTestAppID1, kUserID1, message, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Send a message from same app in another instance.
|
| - GCMClient::OutgoingMessage message2;
|
| - message2.id = "2";
|
| - message2.data["foo"] = "bar";
|
| - wrapper2_->Send(kTestAppID1, kUserID2, message2, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -
|
| - EXPECT_EQ(message2.id, wrapper2_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->send_result());
|
| -
|
| - // Send another message from different app in another instance.
|
| - GCMClient::OutgoingMessage message3;
|
| - message3.id = "3";
|
| - message3.data["hello"] = "world";
|
| - wrapper2_->Send(kTestAppID2, kUserID1, message3, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(message3.id, wrapper2_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->send_result());
|
| -}
|
| -
|
| -TEST_F(GCMServiceMultipleInstanceTest, MessageReceived) {
|
| - wrapper_->Register(kTestAppID1,
|
| - ToSenderList("sender"),
|
| - TestGCMServiceWrapper::WAIT);
|
| - wrapper2_->Register(kTestAppID1,
|
| - ToSenderList("sender"),
|
| - TestGCMServiceWrapper::WAIT);
|
| - wrapper2_->Register(kTestAppID2,
|
| - ToSenderList("sender2"),
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Trigger an incoming message for an app in one instance.
|
| - GCMClient::IncomingMessage message;
|
| - message.data["key1"] = "value1";
|
| - message.data["key2"] = "value2";
|
| - message.sender_id = "sender";
|
| - wrapper_->GetGCMClient()->ReceiveMessage(kTestAppID1, message);
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - // Trigger an incoming message for the same app in another instance.
|
| - GCMClient::IncomingMessage message2;
|
| - message2.data["foo"] = "bar";
|
| - message2.sender_id = "sender";
|
| - wrapper2_->GetGCMClient()->ReceiveMessage(kTestAppID1, message2);
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message.data, wrapper_->gcm_app_handler()->message().data);
|
| - EXPECT_EQ("sender", wrapper_->gcm_app_handler()->message().sender_id);
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper2_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message2.data, wrapper2_->gcm_app_handler()->message().data);
|
| - EXPECT_EQ("sender", wrapper2_->gcm_app_handler()->message().sender_id);
|
| -
|
| - // Trigger another incoming message for a different app in another instance.
|
| - GCMClient::IncomingMessage message3;
|
| - message3.data["bar1"] = "foo1";
|
| - message3.data["bar2"] = "foo2";
|
| - message3.sender_id = "sender2";
|
| - wrapper2_->GetGCMClient()->ReceiveMessage(kTestAppID2, message3);
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID2, wrapper2_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(message3.data, wrapper2_->gcm_app_handler()->message().data);
|
| - EXPECT_EQ("sender2", wrapper2_->gcm_app_handler()->message().sender_id);
|
| -}
|
| -
|
| -// Test a set of GCM operations on multiple instances.
|
| -// 1) Register 1 app in instance 1 and register 2 apps in instance 2;
|
| -// 2) Send a message from instance 1;
|
| -// 3) Receive a message to an app in instance 1 and receive a message for each
|
| -// of the two apps in instance 2;
|
| -// 4) Send a message for each of the two apps in instance 2;
|
| -// 5) Sign out of instance 1.
|
| -// 6) Register/send stops working for instance 1;
|
| -// 7) The app in instance 2 can still receive these events;
|
| -// 8) Sign into instance 1 with a different account.
|
| -// 9) The message to the newly signed-in account will be routed.
|
| -TEST_F(GCMServiceMultipleInstanceTest, Combined) {
|
| - // Register an app.
|
| - std::vector<std::string> sender_ids;
|
| - sender_ids.push_back("sender1");
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Register the same app in a different instance.
|
| - std::vector<std::string> sender_ids2;
|
| - sender_ids2.push_back("foo");
|
| - sender_ids2.push_back("bar");
|
| - wrapper2_->Register(kTestAppID1, sender_ids2, TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Register a different app in a different instance.
|
| - std::vector<std::string> sender_ids3;
|
| - sender_ids3.push_back("sender1");
|
| - sender_ids3.push_back("sender2");
|
| - sender_ids3.push_back("sender3");
|
| - wrapper2_->Register(kTestAppID2, sender_ids3, TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids),
|
| - wrapper_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->registration_result());
|
| -
|
| - EXPECT_EQ(GCMClientMock::GetRegistrationIdFromSenderIds(sender_ids3),
|
| - wrapper2_->registration_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->registration_result());
|
| -
|
| - // Send a message from one instance.
|
| - GCMClient::OutgoingMessage out_message;
|
| - out_message.id = "1";
|
| - out_message.data["out1"] = "out_data1";
|
| - out_message.data["out1_2"] = "out_data1_2";
|
| - wrapper_->Send(kTestAppID1,
|
| - kUserID1,
|
| - out_message,
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(out_message.id, wrapper_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper_->send_result());
|
| -
|
| - // Trigger an incoming message for an app in one instance.
|
| - GCMClient::IncomingMessage in_message;
|
| - in_message.data["in1"] = "in_data1";
|
| - in_message.data["in1_2"] = "in_data1_2";
|
| - in_message.sender_id = "sender1";
|
| - wrapper_->GetGCMClient()->ReceiveMessage(kTestAppID1, in_message);
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(in_message.data, wrapper_->gcm_app_handler()->message().data);
|
| -
|
| - // Trigger 2 incoming messages, one for each app respectively, in another
|
| - // instance.
|
| - GCMClient::IncomingMessage in_message2;
|
| - in_message2.data["in2"] = "in_data2";
|
| - in_message2.sender_id = "sender3";
|
| - wrapper2_->GetGCMClient()->ReceiveMessage(kTestAppID2, in_message2);
|
| -
|
| - GCMClient::IncomingMessage in_message3;
|
| - in_message3.data["in3"] = "in_data3";
|
| - in_message3.data["in3_2"] = "in_data3_2";
|
| - in_message3.sender_id = "foo";
|
| - wrapper2_->GetGCMClient()->ReceiveMessage(kTestAppID1, in_message3);
|
| -
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID2, wrapper2_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(in_message2.data, wrapper2_->gcm_app_handler()->message().data);
|
| -
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper2_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(in_message3.data, wrapper2_->gcm_app_handler()->message().data);
|
| -
|
| - // Send two messages, one for each app respectively, from another instance.
|
| - GCMClient::OutgoingMessage out_message2;
|
| - out_message2.id = "2";
|
| - out_message2.data["out2"] = "out_data2";
|
| - wrapper2_->Send(kTestAppID1,
|
| - kUserID2,
|
| - out_message2,
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - GCMClient::OutgoingMessage out_message3;
|
| - out_message3.id = "3";
|
| - out_message3.data["out3"] = "out_data3";
|
| - wrapper2_->Send(kTestAppID2,
|
| - kUserID2,
|
| - out_message3,
|
| - TestGCMServiceWrapper::DO_NOT_WAIT);
|
| -
|
| - EXPECT_EQ(out_message2.id, wrapper2_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->send_result());
|
| -
|
| - wrapper2_->WaitForAsyncOperation();
|
| -
|
| - EXPECT_EQ(out_message3.id, wrapper2_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->send_result());
|
| -
|
| - // Sign out of one instance.
|
| - wrapper_->SignOut();
|
| -
|
| - // Register/send stops working for signed-out instance.
|
| - wrapper_->Register(kTestAppID1, sender_ids, TestGCMServiceWrapper::WAIT);
|
| - EXPECT_TRUE(wrapper_->registration_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->registration_result());
|
| -
|
| - wrapper_->Send(kTestAppID2,
|
| - kUserID2,
|
| - out_message3,
|
| - TestGCMServiceWrapper::WAIT);
|
| - EXPECT_TRUE(wrapper_->send_message_id().empty());
|
| - EXPECT_EQ(GCMClient::NOT_SIGNED_IN, wrapper_->send_result());
|
| -
|
| - // Deleted messages event will go through for another signed-in instance.
|
| - wrapper2_->GetGCMClient()->DeleteMessages(kTestAppID2);
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGES_DELETED_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID2, wrapper2_->gcm_app_handler()->app_id());
|
| -
|
| - // Send error event will go through for another signed-in instance.
|
| - GCMClient::OutgoingMessage out_message4;
|
| - out_message4.id = "1@error";
|
| - out_message4.data["out4"] = "out_data4";
|
| - wrapper2_->Send(kTestAppID1,
|
| - kUserID1,
|
| - out_message4,
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - EXPECT_EQ(out_message4.id, wrapper2_->send_message_id());
|
| - EXPECT_EQ(GCMClient::SUCCESS, wrapper2_->send_result());
|
| -
|
| - wrapper2_->gcm_app_handler()->WaitForNotification();
|
| - EXPECT_EQ(FakeGCMAppHandler::SEND_ERROR_EVENT,
|
| - wrapper2_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(kTestAppID1, wrapper2_->gcm_app_handler()->app_id());
|
| - EXPECT_EQ(out_message4.id,
|
| - wrapper2_->gcm_app_handler()->send_error_details().message_id);
|
| - EXPECT_NE(GCMClient::SUCCESS,
|
| - wrapper2_->gcm_app_handler()->send_error_details().result);
|
| - EXPECT_EQ(out_message4.data,
|
| - wrapper2_->gcm_app_handler()->send_error_details().additional_data);
|
| -
|
| - // Sign in with a different account.
|
| - wrapper_->SignIn(kTestAccountID3);
|
| -
|
| - // Signing out cleared all registrations, so we need to register again.
|
| - wrapper_->Register(kTestAppID1,
|
| - ToSenderList("sender1"),
|
| - TestGCMServiceWrapper::WAIT);
|
| -
|
| - // Incoming message will go through for the new signed-in account.
|
| - GCMClient::IncomingMessage in_message5;
|
| - in_message5.data["in5"] = "in_data5";
|
| - in_message5.sender_id = "sender1";
|
| - wrapper_->GetGCMClient()->ReceiveMessage(kTestAppID1, in_message5);
|
| -
|
| - wrapper_->gcm_app_handler()->WaitForNotification();
|
| -
|
| - EXPECT_EQ(FakeGCMAppHandler::MESSAGE_EVENT,
|
| - wrapper_->gcm_app_handler()->received_event());
|
| - EXPECT_EQ(in_message5.data, wrapper_->gcm_app_handler()->message().data);
|
| -}
|
| -
|
| -} // namespace gcm
|
|
|