| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ | 5 #ifndef CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ |
| 6 #define CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ | 6 #define CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| 11 | 11 |
| 12 #include "base/basictypes.h" | 12 #include "base/basictypes.h" |
| 13 #include "base/callback.h" | 13 #include "base/callback.h" |
| 14 #include "base/compiler_specific.h" | 14 #include "base/compiler_specific.h" |
| 15 #include "base/files/file_path.h" | 15 #include "base/files/file_path.h" |
| 16 #include "base/memory/ref_counted.h" | 16 #include "base/memory/ref_counted.h" |
| 17 #include "base/memory/scoped_ptr.h" | 17 #include "base/memory/scoped_ptr.h" |
| 18 #include "base/memory/weak_ptr.h" | 18 #include "base/memory/weak_ptr.h" |
| 19 #include "chrome/browser/services/gcm/default_gcm_app_handler.h" | 19 #include "chrome/browser/services/gcm/default_gcm_app_handler.h" |
| 20 #include "google_apis/gaia/identity_provider.h" | 20 #include "google_apis/gaia/identity_provider.h" |
| 21 #include "google_apis/gcm/gcm_client.h" | 21 #include "google_apis/gcm/gcm_client.h" |
| 22 #include "google_apis/gcm/public/gcm_types.h" |
| 22 | 23 |
| 23 namespace extensions { | 24 namespace extensions { |
| 24 class ExtensionGCMAppHandlerTest; | 25 class ExtensionGCMAppHandlerTest; |
| 25 } | 26 } |
| 26 | 27 |
| 27 namespace net { | 28 namespace net { |
| 28 class URLRequestContextGetter; | 29 class URLRequestContextGetter; |
| 29 } | 30 } |
| 30 | 31 |
| 31 namespace gcm { | 32 namespace gcm { |
| 32 | 33 |
| 33 class GCMAppHandler; | 34 class GCMAppHandler; |
| 34 class GCMClientFactory; | 35 class GCMClientFactory; |
| 35 | 36 |
| 36 // A bridge between the GCM users in Chrome and the GCMClient layer. | 37 // A bridge between the GCM users in Chrome and the GCMClient layer. |
| 37 class GCMService : public IdentityProvider::Observer { | 38 class GCMService : public IdentityProvider::Observer { |
| 38 public: | 39 public: |
| 39 typedef base::Callback<void(const std::string& registration_id, | 40 typedef base::Callback<void(const std::string& registration_id, |
| 40 GCMClient::Result result)> RegisterCallback; | 41 Result result)> RegisterCallback; |
| 41 typedef base::Callback<void(const std::string& message_id, | 42 typedef base::Callback<void(const std::string& message_id, |
| 42 GCMClient::Result result)> SendCallback; | 43 Result result)> SendCallback; |
| 43 typedef base::Callback<void(GCMClient::Result result)> UnregisterCallback; | 44 typedef base::Callback<void(Result result)> UnregisterCallback; |
| 44 typedef base::Callback<void(const GCMClient::GCMStatistics& stats)> | 45 typedef base::Callback<void(const GCMClient::GCMStatistics& stats)> |
| 45 GetGCMStatisticsCallback; | 46 GetGCMStatisticsCallback; |
| 46 | 47 |
| 47 explicit GCMService(scoped_ptr<IdentityProvider> identity_provider); | 48 explicit GCMService(scoped_ptr<IdentityProvider> identity_provider); |
| 48 virtual ~GCMService(); | 49 virtual ~GCMService(); |
| 49 | 50 |
| 50 void Initialize(scoped_ptr<GCMClientFactory> gcm_client_factory); | 51 void Initialize(scoped_ptr<GCMClientFactory> gcm_client_factory); |
| 51 | 52 |
| 52 void Start(); | 53 void Start(); |
| 53 | 54 |
| (...skipping 26 matching lines...) Expand all Loading... |
| 80 virtual void Unregister(const std::string& app_id, | 81 virtual void Unregister(const std::string& app_id, |
| 81 UnregisterCallback callback); | 82 UnregisterCallback callback); |
| 82 | 83 |
| 83 // Sends a message to a given receiver. | 84 // Sends a message to a given receiver. |
| 84 // |app_id|: application ID. | 85 // |app_id|: application ID. |
| 85 // |receiver_id|: registration ID of the receiver party. | 86 // |receiver_id|: registration ID of the receiver party. |
| 86 // |message|: message to be sent. | 87 // |message|: message to be sent. |
| 87 // |callback|: to be called once the asynchronous operation is done. | 88 // |callback|: to be called once the asynchronous operation is done. |
| 88 virtual void Send(const std::string& app_id, | 89 virtual void Send(const std::string& app_id, |
| 89 const std::string& receiver_id, | 90 const std::string& receiver_id, |
| 90 const GCMClient::OutgoingMessage& message, | 91 const OutgoingMessage& message, |
| 91 SendCallback callback); | 92 SendCallback callback); |
| 92 | 93 |
| 93 // For testing purpose. | 94 // For testing purpose. |
| 94 GCMClient* GetGCMClientForTesting() const; | 95 GCMClient* GetGCMClientForTesting() const; |
| 95 | 96 |
| 96 // Returns true if the service was started. | 97 // Returns true if the service was started. |
| 97 bool IsStarted() const; | 98 bool IsStarted() const; |
| 98 | 99 |
| 99 // Returns true if the gcm client is ready. | 100 // Returns true if the gcm client is ready. |
| 100 bool IsGCMClientReady() const; | 101 bool IsGCMClientReady() const; |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 134 // |identity_provider_| is able to supply an account ID. | 135 // |identity_provider_| is able to supply an account ID. |
| 135 void EnsureLoaded(); | 136 void EnsureLoaded(); |
| 136 | 137 |
| 137 // Remove cached data when GCM service is stopped. | 138 // Remove cached data when GCM service is stopped. |
| 138 void RemoveCachedData(); | 139 void RemoveCachedData(); |
| 139 | 140 |
| 140 // Checks out of GCM and erases any cached and persisted data. | 141 // Checks out of GCM and erases any cached and persisted data. |
| 141 void CheckOut(); | 142 void CheckOut(); |
| 142 | 143 |
| 143 // Ensures that the app is ready for GCM functions and events. | 144 // Ensures that the app is ready for GCM functions and events. |
| 144 GCMClient::Result EnsureAppReady(const std::string& app_id); | 145 Result EnsureAppReady(const std::string& app_id); |
| 145 | 146 |
| 146 // Should be called when an app with |app_id| is trying to un/register. | 147 // Should be called when an app with |app_id| is trying to un/register. |
| 147 // Checks whether another un/registration is in progress. | 148 // Checks whether another un/registration is in progress. |
| 148 bool IsAsyncOperationPending(const std::string& app_id) const; | 149 bool IsAsyncOperationPending(const std::string& app_id) const; |
| 149 | 150 |
| 150 void DoRegister(const std::string& app_id, | 151 void DoRegister(const std::string& app_id, |
| 151 const std::vector<std::string>& sender_ids); | 152 const std::vector<std::string>& sender_ids); |
| 152 void DoUnregister(const std::string& app_id); | 153 void DoUnregister(const std::string& app_id); |
| 153 void DoSend(const std::string& app_id, | 154 void DoSend(const std::string& app_id, |
| 154 const std::string& receiver_id, | 155 const std::string& receiver_id, |
| 155 const GCMClient::OutgoingMessage& message); | 156 const OutgoingMessage& message); |
| 156 | 157 |
| 157 // Callbacks posted from IO thread to UI thread. | 158 // Callbacks posted from IO thread to UI thread. |
| 158 void RegisterFinished(const std::string& app_id, | 159 void RegisterFinished(const std::string& app_id, |
| 159 const std::string& registration_id, | 160 const std::string& registration_id, |
| 160 GCMClient::Result result); | 161 Result result); |
| 161 void UnregisterFinished(const std::string& app_id, GCMClient::Result result); | 162 void UnregisterFinished(const std::string& app_id, Result result); |
| 162 void SendFinished(const std::string& app_id, | 163 void SendFinished(const std::string& app_id, |
| 163 const std::string& message_id, | 164 const std::string& message_id, |
| 164 GCMClient::Result result); | 165 Result result); |
| 165 void MessageReceived(const std::string& app_id, | 166 void MessageReceived(const std::string& app_id, |
| 166 GCMClient::IncomingMessage message); | 167 IncomingMessage message); |
| 167 void MessagesDeleted(const std::string& app_id); | 168 void MessagesDeleted(const std::string& app_id); |
| 168 void MessageSendError(const std::string& app_id, | 169 void MessageSendError(const std::string& app_id, |
| 169 const GCMClient::SendErrorDetails& send_error_details); | 170 const SendErrorDetails& send_error_details); |
| 170 void GCMClientReady(); | 171 void GCMClientReady(); |
| 171 | 172 |
| 172 // Returns the handler for the given app. | 173 // Returns the handler for the given app. |
| 173 GCMAppHandler* GetAppHandler(const std::string& app_id); | 174 GCMAppHandler* GetAppHandler(const std::string& app_id); |
| 174 | 175 |
| 175 void GetGCMStatisticsFinished(GCMClient::GCMStatistics stats); | 176 void GetGCMStatisticsFinished(GCMClient::GCMStatistics stats); |
| 176 | 177 |
| 177 // Flag to indicate if GCMClient is ready. | 178 // Flag to indicate if GCMClient is ready. |
| 178 bool gcm_client_ready_; | 179 bool gcm_client_ready_; |
| 179 | 180 |
| (...skipping 28 matching lines...) Expand all Loading... |
| 208 | 209 |
| 209 // Used to pass a weak pointer to the IO worker. | 210 // Used to pass a weak pointer to the IO worker. |
| 210 base::WeakPtrFactory<GCMService> weak_ptr_factory_; | 211 base::WeakPtrFactory<GCMService> weak_ptr_factory_; |
| 211 | 212 |
| 212 DISALLOW_COPY_AND_ASSIGN(GCMService); | 213 DISALLOW_COPY_AND_ASSIGN(GCMService); |
| 213 }; | 214 }; |
| 214 | 215 |
| 215 } // namespace gcm | 216 } // namespace gcm |
| 216 | 217 |
| 217 #endif // CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ | 218 #endif // CHROME_BROWSER_SERVICES_GCM_GCM_SERVICE_H_ |
| OLD | NEW |