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
|
// 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_SERVICES_GCM_PUSH_MESSAGING_SERVICE_IMPL_H_
#define CHROME_BROWSER_SERVICES_GCM_PUSH_MESSAGING_SERVICE_IMPL_H_
#include "base/compiler_specific.h"
#include "base/memory/weak_ptr.h"
#include "components/gcm_driver/gcm_app_handler.h"
#include "components/gcm_driver/gcm_client.h"
#include "content/public/browser/push_messaging_service.h"
#include "content/public/common/push_messaging_status.h"
#include "third_party/WebKit/public/platform/WebPushPermissionStatus.h"
class Profile;
namespace user_prefs {
class PrefRegistrySyncable;
}
namespace gcm {
class GCMProfileService;
struct PushMessagingApplicationId;
class PushMessagingServiceImpl : public content::PushMessagingService,
public GCMAppHandler {
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);
PushMessagingServiceImpl(GCMProfileService* gcm_profile_service,
Profile* profile);
~PushMessagingServiceImpl() override;
// GCMAppHandler implementation.
void ShutdownHandler() override;
void OnMessage(const std::string& app_id,
const GCMClient::IncomingMessage& message) override;
void OnMessagesDeleted(const std::string& app_id) override;
void OnSendError(
const std::string& app_id,
const 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_only,
const content::PushMessagingService::RegisterCallback& callback) override;
void RegisterFromWorker(
const GURL& requesting_origin,
int64 service_worker_registration_id,
const std::string& sender_id,
const content::PushMessagingService::RegisterCallback& callback) override;
void Unregister(
const GURL& requesting_origin,
int64 service_worker_registration_id,
const content::PushMessagingService::UnregisterCallback&) override;
blink::WebPushPermissionStatus GetPermissionStatus(
const GURL& requesting_origin,
const GURL& embedding_origin) override;
void SetProfileForTesting(Profile* profile);
private:
void IncreasePushRegistrationCount(int add);
void DecreasePushRegistrationCount(int subtract);
void DeliverMessageCallback(const PushMessagingApplicationId& application_id,
const 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 PushMessagingApplicationId& application_id);
void RegisterEnd(
const content::PushMessagingService::RegisterCallback& callback,
const std::string& registration_id,
content::PushRegistrationStatus status);
void DidRegister(
const content::PushMessagingService::RegisterCallback& callback,
const std::string& registration_id,
GCMClient::Result result);
void DidRequestPermission(
const PushMessagingApplicationId& application_id,
const std::string& sender_id,
const content::PushMessagingService::RegisterCallback& callback,
bool allow);
void Unregister(const PushMessagingApplicationId& application_id,
const content::PushMessagingService::UnregisterCallback&);
void DidUnregister(const content::PushMessagingService::UnregisterCallback&,
GCMClient::Result result);
// Helper method that checks if a given origin is allowed to use Push.
bool HasPermission(const GURL& origin);
// Adds this service as an app handler to the GCMDriver if it has not been
// added yet.
void AddAppHandlerIfNecessary();
GCMProfileService* gcm_profile_service_; // It owns us.
Profile* profile_; // It owns our owner.
int push_registration_count_;
base::WeakPtrFactory<PushMessagingServiceImpl> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(PushMessagingServiceImpl);
};
} // namespace gcm
#endif // CHROME_BROWSER_SERVICES_GCM_PUSH_MESSAGING_SERVICE_IMPL_H_
|
