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 #include "modules/push_messaging/PushSubscription.h" | 5 #include "modules/push_messaging/PushSubscription.h" |
6 | 6 |
7 #include "bindings/core/v8/CallbackPromiseAdapter.h" | 7 #include "bindings/core/v8/CallbackPromiseAdapter.h" |
8 #include "bindings/core/v8/ScriptPromiseResolver.h" | 8 #include "bindings/core/v8/ScriptPromiseResolver.h" |
9 #include "bindings/core/v8/V8ObjectBuilder.h" | 9 #include "bindings/core/v8/V8ObjectBuilder.h" |
10 #include "modules/push_messaging/PushError.h" | 10 #include "modules/push_messaging/PushError.h" |
| 11 #include "modules/push_messaging/PushSubscriptionOptions.h" |
11 #include "modules/serviceworkers/ServiceWorkerRegistration.h" | 12 #include "modules/serviceworkers/ServiceWorkerRegistration.h" |
12 #include "public/platform/Platform.h" | 13 #include "public/platform/Platform.h" |
13 #include "public/platform/modules/push_messaging/WebPushProvider.h" | 14 #include "public/platform/modules/push_messaging/WebPushProvider.h" |
14 #include "public/platform/modules/push_messaging/WebPushSubscription.h" | 15 #include "public/platform/modules/push_messaging/WebPushSubscription.h" |
15 #include "wtf/Assertions.h" | 16 #include "wtf/Assertions.h" |
16 #include "wtf/text/Base64.h" | 17 #include "wtf/text/Base64.h" |
17 #include <memory> | 18 #include <memory> |
18 | 19 |
19 namespace blink { | 20 namespace blink { |
20 | 21 |
21 PushSubscription* PushSubscription::take(ScriptPromiseResolver*, std::unique_ptr
<WebPushSubscription> pushSubscription, ServiceWorkerRegistration* serviceWorker
Registration) | 22 PushSubscription* PushSubscription::take(ScriptPromiseResolver*, std::unique_ptr
<WebPushSubscription> pushSubscription, ServiceWorkerRegistration* serviceWorker
Registration) |
22 { | 23 { |
23 if (!pushSubscription) | 24 if (!pushSubscription) |
24 return nullptr; | 25 return nullptr; |
25 return new PushSubscription(*pushSubscription, serviceWorkerRegistration); | 26 return new PushSubscription(*pushSubscription, serviceWorkerRegistration); |
26 } | 27 } |
27 | 28 |
28 void PushSubscription::dispose(WebPushSubscription* pushSubscription) | 29 void PushSubscription::dispose(WebPushSubscription* pushSubscription) |
29 { | 30 { |
30 if (pushSubscription) | 31 if (pushSubscription) |
31 delete pushSubscription; | 32 delete pushSubscription; |
32 } | 33 } |
33 | 34 |
34 PushSubscription::PushSubscription(const WebPushSubscription& subscription, Serv
iceWorkerRegistration* serviceWorkerRegistration) | 35 PushSubscription::PushSubscription(const WebPushSubscription& subscription, Serv
iceWorkerRegistration* serviceWorkerRegistration) |
35 : m_endpoint(subscription.endpoint) | 36 : m_endpoint(subscription.endpoint) |
| 37 , m_options(PushSubscriptionOptions::create(subscription.options)) |
36 , m_p256dh(DOMArrayBuffer::create(subscription.p256dh.data(), subscription.p
256dh.size())) | 38 , m_p256dh(DOMArrayBuffer::create(subscription.p256dh.data(), subscription.p
256dh.size())) |
37 , m_auth(DOMArrayBuffer::create(subscription.auth.data(), subscription.auth.
size())) | 39 , m_auth(DOMArrayBuffer::create(subscription.auth.data(), subscription.auth.
size())) |
38 , m_serviceWorkerRegistration(serviceWorkerRegistration) | 40 , m_serviceWorkerRegistration(serviceWorkerRegistration) |
39 { | 41 { |
40 } | 42 } |
41 | 43 |
42 PushSubscription::~PushSubscription() | 44 PushSubscription::~PushSubscription() |
43 { | 45 { |
44 } | 46 } |
45 | 47 |
46 KURL PushSubscription::endpoint() const | |
47 { | |
48 return m_endpoint; | |
49 } | |
50 | |
51 DOMArrayBuffer* PushSubscription::getKey(const AtomicString& name) const | 48 DOMArrayBuffer* PushSubscription::getKey(const AtomicString& name) const |
52 { | 49 { |
53 if (name == "p256dh") | 50 if (name == "p256dh") |
54 return m_p256dh; | 51 return m_p256dh; |
55 if (name == "auth") | 52 if (name == "auth") |
56 return m_auth; | 53 return m_auth; |
57 | 54 |
58 return nullptr; | 55 return nullptr; |
59 } | 56 } |
60 | 57 |
(...skipping 19 matching lines...) Expand all Loading... |
80 V8ObjectBuilder keys(scriptState); | 77 V8ObjectBuilder keys(scriptState); |
81 keys.add("p256dh", WTF::base64URLEncode(static_cast<const char*>(m_p256dh->d
ata()), m_p256dh->byteLength())); | 78 keys.add("p256dh", WTF::base64URLEncode(static_cast<const char*>(m_p256dh->d
ata()), m_p256dh->byteLength())); |
82 keys.add("auth", WTF::base64URLEncode(static_cast<const char*>(m_auth->data(
)), m_auth->byteLength())); | 79 keys.add("auth", WTF::base64URLEncode(static_cast<const char*>(m_auth->data(
)), m_auth->byteLength())); |
83 result.add("keys", keys); | 80 result.add("keys", keys); |
84 | 81 |
85 return result.scriptValue(); | 82 return result.scriptValue(); |
86 } | 83 } |
87 | 84 |
88 DEFINE_TRACE(PushSubscription) | 85 DEFINE_TRACE(PushSubscription) |
89 { | 86 { |
| 87 visitor->trace(m_options); |
90 visitor->trace(m_p256dh); | 88 visitor->trace(m_p256dh); |
91 visitor->trace(m_auth); | 89 visitor->trace(m_auth); |
92 visitor->trace(m_serviceWorkerRegistration); | 90 visitor->trace(m_serviceWorkerRegistration); |
93 } | 91 } |
94 | 92 |
95 } // namespace blink | 93 } // namespace blink |
OLD | NEW |