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
|
// 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 "modules/push_messaging/PushManager.h"
#include "bindings/core/v8/ScriptPromise.h"
#include "bindings/core/v8/ScriptPromiseResolver.h"
#include "bindings/core/v8/ScriptState.h"
#include "core/dom/DOMException.h"
#include "core/dom/Document.h"
#include "core/dom/ExceptionCode.h"
#include "core/dom/ExecutionContext.h"
#include "modules/push_messaging/PushController.h"
#include "modules/push_messaging/PushError.h"
#include "modules/push_messaging/PushPermissionStatusCallbacks.h"
#include "modules/push_messaging/PushSubscription.h"
#include "modules/push_messaging/PushSubscriptionCallbacks.h"
#include "modules/push_messaging/PushSubscriptionOptions.h"
#include "modules/serviceworkers/ServiceWorkerRegistration.h"
#include "public/platform/Platform.h"
#include "public/platform/modules/push_messaging/WebPushClient.h"
#include "public/platform/modules/push_messaging/WebPushProvider.h"
#include "public/platform/modules/push_messaging/WebPushSubscriptionOptions.h"
#include "wtf/RefPtr.h"
namespace blink {
namespace {
WebPushProvider* pushProvider()
{
WebPushProvider* webPushProvider = Platform::current()->pushProvider();
ASSERT(webPushProvider);
return webPushProvider;
}
String bufferSourceToString(const ArrayBufferOrArrayBufferView& applicationServerKey, ExceptionState& exceptionState)
{
// Check the validity of the sender info. It must be a 65 byte unencrypted key,
// which has the byte 0x04 as the first byte as a marker.
char* input;
int length;
if (applicationServerKey.isArrayBuffer()) {
input = static_cast<char*>(
applicationServerKey.getAsArrayBuffer()->data());
length = applicationServerKey.getAsArrayBuffer()->byteLength();
} else if (applicationServerKey.isArrayBufferView()) {
input = static_cast<char*>(
applicationServerKey.getAsArrayBufferView()->buffer()->data());
length = applicationServerKey.getAsArrayBufferView()->buffer()->byteLength();
} else {
ASSERT_NOT_REACHED();
return String();
}
if (length == 65 && input[0] == 0x04)
return WebString::fromUTF8(input, length);
exceptionState.throwDOMException(InvalidAccessError, "The provided applicationServerKey is not valid.");
return String();
}
} // namespace
PushManager::PushManager(ServiceWorkerRegistration* registration)
: m_registration(registration)
{
ASSERT(registration);
}
WebPushSubscriptionOptions PushManager::toWebPushSubscriptionOptions(const PushSubscriptionOptions& options, ExceptionState& exceptionState)
{
WebPushSubscriptionOptions webOptions;
webOptions.userVisibleOnly = options.userVisibleOnly();
if (options.hasApplicationServerKey()) {
webOptions.applicationServerKey = bufferSourceToString(options.applicationServerKey(),
exceptionState);
}
return webOptions;
}
ScriptPromise PushManager::subscribe(ScriptState* scriptState, const PushSubscriptionOptions& options, ExceptionState& exceptionState)
{
if (!m_registration->active())
return ScriptPromise::rejectWithDOMException(scriptState, DOMException::create(AbortError, "Subscription failed - no active Service Worker"));
const WebPushSubscriptionOptions& webOptions = toWebPushSubscriptionOptions(options, exceptionState);
if (exceptionState.hadException())
return ScriptPromise();
ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
ScriptPromise promise = resolver->promise();
// The document context is the only reasonable context from which to ask the user for permission
// to use the Push API. The embedder should persist the permission so that later calls in
// different contexts can succeed.
if (scriptState->getExecutionContext()->isDocument()) {
Document* document = toDocument(scriptState->getExecutionContext());
if (!document->domWindow() || !document->frame())
return ScriptPromise::rejectWithDOMException(scriptState, DOMException::create(InvalidStateError, "Document is detached from window."));
PushController::clientFrom(document->frame()).subscribe(m_registration->webRegistration(), webOptions, new PushSubscriptionCallbacks(resolver, m_registration));
} else {
pushProvider()->subscribe(m_registration->webRegistration(), webOptions, new PushSubscriptionCallbacks(resolver, m_registration));
}
return promise;
}
ScriptPromise PushManager::getSubscription(ScriptState* scriptState)
{
ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
ScriptPromise promise = resolver->promise();
pushProvider()->getSubscription(m_registration->webRegistration(), new PushSubscriptionCallbacks(resolver, m_registration));
return promise;
}
ScriptPromise PushManager::permissionState(ScriptState* scriptState, const PushSubscriptionOptions& options, ExceptionState& exceptionState)
{
if (scriptState->getExecutionContext()->isDocument()) {
Document* document = toDocument(scriptState->getExecutionContext());
if (!document->domWindow() || !document->frame())
return ScriptPromise::rejectWithDOMException(scriptState, DOMException::create(InvalidStateError, "Document is detached from window."));
}
ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
ScriptPromise promise = resolver->promise();
pushProvider()->getPermissionStatus(m_registration->webRegistration(), toWebPushSubscriptionOptions(options, exceptionState), new PushPermissionStatusCallbacks(resolver));
return promise;
}
DEFINE_TRACE(PushManager)
{
visitor->trace(m_registration);
}
} // namespace blink
|
