| // 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. |
| |
| #ifndef COMPONENTS_COPRESENCE_HANDLERS_GCM_HANDLER_IMPL_H_ |
| #define COMPONENTS_COPRESENCE_HANDLERS_GCM_HANDLER_IMPL_H_ |
| |
| #include <string> |
| #include <vector> |
| |
| #include "base/callback_forward.h" |
| #include "base/cancelable_callback.h" |
| #include "base/macros.h" |
| #include "components/copresence/handlers/gcm_handler.h" |
| #include "components/copresence/public/copresence_constants.h" |
| #include "components/gcm_driver/gcm_app_handler.h" |
| #include "components/gcm_driver/gcm_client.h" |
| |
| namespace gcm { |
| class GCMDriver; |
| } |
| |
| namespace copresence { |
| |
| class DirectiveHandler; |
| |
| // This class handles GCM messages from the Copresence server. |
| class GCMHandlerImpl final : public GCMHandler, |
| public gcm::GCMAppHandler { |
| public: |
| // Callback to report that registration has completed. |
| // Returns an empty ID if registration failed. |
| using RegistrationCallback = base::Callback<void(const std::string&)>; |
| |
| static const char kCopresenceAppId[]; |
| static const char kCopresenceSenderId[]; |
| static const char kGcmMessageKey[]; |
| |
| // |gcm_driver| is required, but may disappear if we get a ShutdownHandler() |
| // call first. |directive_handler| must outlive us. The caller owns both. |
| GCMHandlerImpl(gcm::GCMDriver* gcm_driver, |
| DirectiveHandler* directive_handler, |
| const MessagesCallback& new_messages_callback); |
| ~GCMHandlerImpl() override; |
| |
| // GCMHandler override. |
| void GetGcmId(const RegistrationCallback& callback) override; |
| |
| private: |
| friend class GCMHandlerTest; |
| |
| // GCMAppHandler overrides |
| void ShutdownHandler() override; |
| void OnMessage(const std::string& app_id, |
| const gcm::IncomingMessage& message) override; |
| void OnMessagesDeleted(const std::string& app_id) override; |
| void OnSendError( |
| const std::string& /* app_id */, |
| const gcm::GCMClient::SendErrorDetails& /* send_error_details */) |
| override; |
| void OnSendAcknowledged(const std::string& /* app_id */, |
| const std::string& /* message_id */) override; |
| bool CanHandle(const std::string& app_id) const override; |
| |
| // GCM Registration has finished. Notify clients as appropriate. |
| void RegistrationComplete(const std::string& registration_id, |
| gcm::GCMClient::Result result); |
| |
| gcm::GCMDriver* driver_; |
| DirectiveHandler* const directive_handler_; |
| MessagesCallback new_messages_callback_; |
| |
| std::string gcm_id_; |
| std::vector<RegistrationCallback> pending_id_requests_; |
| |
| base::CancelableCallback<void(const std::string&, |
| gcm::GCMClient::Result)> registration_callback_; |
| |
| DISALLOW_COPY_AND_ASSIGN(GCMHandlerImpl); |
| }; |
| |
| } // namespace copresence |
| |
| #endif // COMPONENTS_COPRESENCE_HANDLERS_GCM_HANDLER_IMPL_H_ |