1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
// 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 CHROME_BROWSER_PUSH_MESSAGING_PUSH_MESSAGING_SERVICE_IMPL_H_
#define CHROME_BROWSER_PUSH_MESSAGING_PUSH_MESSAGING_SERVICE_IMPL_H_
#include "base/callback.h"
#include "base/compiler_specific.h"
#include "base/memory/weak_ptr.h"
#include "components/content_settings/core/browser/content_settings_observer.h"
#include "components/content_settings/core/common/content_settings.h"
#include "components/gcm_driver/gcm_app_handler.h"
#include "components/gcm_driver/gcm_client.h"
#include "components/keyed_service/core/keyed_service.h"
#include "content/public/browser/push_messaging_service.h"
#include "content/public/common/push_messaging_status.h"
#include "third_party/WebKit/public/platform/modules/push_messaging/WebPushPermissionStatus.h"
class Profile;
class PushMessagingApplicationId;
namespace user_prefs {
class PrefRegistrySyncable;
}
namespace gcm {
class GCMDriver;
class GCMProfileService;
}
class PushMessagingServiceImpl : public content::PushMessagingService,
public gcm::GCMAppHandler,
public content_settings::Observer,
public KeyedService {
public:
// Register profile-specific prefs for GCM.
static void RegisterProfilePrefs(user_prefs::PrefRegistrySyncable* registry);
// If any Service Workers are using push, starts GCM and adds an app handler.
static void InitializeForProfile(Profile* profile);
explicit PushMessagingServiceImpl(Profile* profile);
~PushMessagingServiceImpl() override;
// gcm::GCMAppHandler implementation.
void ShutdownHandler() override;
void OnMessage(const std::string& app_id,
const gcm::GCMClient::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;
// content::PushMessagingService implementation:
GURL GetPushEndpoint() override;
void RegisterFromDocument(
const GURL& requesting_origin,
int64 service_worker_registration_id,
const std::string& sender_id,
int renderer_id,
int render_frame_id,
bool user_visible,
const content::PushMessagingService::RegisterCallback& callback) override;
void RegisterFromWorker(
const GURL& requesting_origin,
int64 service_worker_registration_id,
const std::string& sender_id,
bool user_visible,
const content::PushMessagingService::RegisterCallback& callback) override;
void Unregister(
const GURL& requesting_origin,
int64 service_worker_registration_id,
const std::string& sender_id,
const content::PushMessagingService::UnregisterCallback&) override;
blink::WebPushPermissionStatus GetPermissionStatus(
const GURL& requesting_origin,
const GURL& embedding_origin,
bool user_visible) override;
// content_settings::Observer implementation.
void OnContentSettingChanged(const ContentSettingsPattern& primary_pattern,
const ContentSettingsPattern& secondary_pattern,
ContentSettingsType content_type,
std::string resource_identifier) override;
// KeyedService implementation.
void Shutdown() override;
void SetContentSettingChangedCallbackForTesting(
const base::Closure& callback);
private:
// A registration is pending until it has succeeded or failed.
void IncreasePushRegistrationCount(int add, bool is_pending);
void DecreasePushRegistrationCount(int subtract, bool was_pending);
// OnMessage methods ---------------------------------------------------------
void DeliverMessageCallback(const std::string& app_id_guid,
const GURL& requesting_origin,
int64 service_worker_registration_id,
const gcm::GCMClient::IncomingMessage& message,
content::PushDeliveryStatus status);
// Developers are required to display a Web Notification in response to an
// incoming push message in order to clarify to the user that something has
// happened in the background. When they forget to do so, display a default
// notification on their behalf.
void RequireUserVisibleUX(const GURL& requesting_origin,
int64 service_worker_registration_id);
void DidGetNotificationsShown(
const GURL& requesting_origin,
int64 service_worker_registration_id,
bool notification_shown,
bool notification_needed,
const std::string& data,
bool success,
bool not_found);
// Register methods ----------------------------------------------------------
void RegisterEnd(
const content::PushMessagingService::RegisterCallback& callback,
const std::string& registration_id,
content::PushRegistrationStatus status);
void DidRegister(
const PushMessagingApplicationId& application_id,
const content::PushMessagingService::RegisterCallback& callback,
const std::string& registration_id,
gcm::GCMClient::Result result);
void DidRequestPermission(
const PushMessagingApplicationId& application_id,
const std::string& sender_id,
const content::PushMessagingService::RegisterCallback& callback,
ContentSetting content_setting);
// Unregister methods --------------------------------------------------------
void Unregister(const std::string& app_id_guid,
const std::string& sender_id,
const content::PushMessagingService::UnregisterCallback&);
void DidUnregister(bool was_registered,
const content::PushMessagingService::UnregisterCallback&,
gcm::GCMClient::Result result);
// OnContentSettingChanged methods -------------------------------------------
void UnregisterBecausePermissionRevoked(const PushMessagingApplicationId& id,
const base::Closure& closure,
const std::string& sender_id,
bool success, bool not_found);
// Helper methods ------------------------------------------------------------
// Checks if a given origin is allowed to use Push.
bool HasPermission(const GURL& origin);
gcm::GCMDriver* GetGCMDriver() const;
Profile* profile_;
int push_registration_count_;
int pending_push_registration_count_;
base::Closure content_setting_changed_callback_for_testing_;
base::WeakPtrFactory<PushMessagingServiceImpl> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(PushMessagingServiceImpl);
};
#endif // CHROME_BROWSER_PUSH_MESSAGING_PUSH_MESSAGING_SERVICE_IMPL_H_
|
