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
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
|
// 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.
'use strict';
var resultQueue = new ResultQueue();
var pushSubscription = null;
// NIST P-256 public key made available to tests. Must be an uncompressed
// point in accordance with SEC1 2.3.3.
var applicationServerKey = new Uint8Array([
0x04, 0x55, 0x52, 0x6A, 0xA5, 0x6E, 0x8E, 0xAA, 0x47, 0x97, 0x36, 0x10, 0xC1,
0x66, 0x3C, 0x1E, 0x65, 0xBF, 0xA1, 0x7B, 0xEE, 0x48, 0xC9, 0xC6, 0xBB, 0xBF,
0x02, 0x18, 0x53, 0x72, 0x1D, 0x0C, 0x7B, 0xA9, 0xE3, 0x11, 0xB7, 0x03, 0x52,
0x21, 0xD3, 0x71, 0x90, 0x13, 0xA8, 0xC1, 0xCF, 0xED, 0x20, 0xF7, 0x1F, 0xD1,
0x7F, 0xF2, 0x76, 0xB6, 0x01, 0x20, 0xD8, 0x35, 0xA5, 0xD9, 0x3C, 0x43, 0xFD
]);
var pushSubscriptionOptions = {
userVisibleOnly: true
};
// Sends data back to the test. This must be in response to an earlier
// request, but it's ok to respond asynchronously. The request blocks until
// the response is sent.
function sendResultToTest(result) {
console.log('sendResultToTest: ' + result);
if (window.domAutomationController) {
domAutomationController.send('' + result);
}
}
function sendErrorToTest(error) {
sendResultToTest(error.name + ' - ' + error.message);
}
// Queue storing asynchronous results received from the Service Worker. Results
// are sent to the test when requested.
function ResultQueue() {
// Invariant: this.queue.length == 0 || this.pendingGets == 0
this.queue = [];
this.pendingGets = 0;
}
// Adds a data item to the queue. Will be sent to the test if there are
// pendingGets.
ResultQueue.prototype.push = function(data) {
if (this.pendingGets > 0) {
this.pendingGets--;
sendResultToTest(data);
} else {
this.queue.unshift(data);
}
};
// Called by native. Sends the next data item to the test if it is available.
// Otherwise increments pendingGets so it will be delivered when received.
ResultQueue.prototype.pop = function() {
if (this.queue.length) {
sendResultToTest(this.queue.pop());
} else {
this.pendingGets++;
}
};
// Called by native. Immediately sends the next data item to the test if it is
// available, otherwise sends null.
ResultQueue.prototype.popImmediately = function() {
sendResultToTest(this.queue.length ? this.queue.pop() : null);
};
// Notification permission has been coalesced with Push permission. After
// this is granted, Push API subscription can succeed.
function requestNotificationPermission() {
Notification.requestPermission(function(permission) {
sendResultToTest('permission status - ' + permission);
});
}
function registerServiceWorker() {
// The base dir used to resolve service_worker.js and the scope depends on
// whether this script is included from an html file in ./, subscope1/, or
// subscope2/.
navigator.serviceWorker.register('service_worker.js', {scope: './'}).then(
function(swRegistration) {
sendResultToTest('ok - service worker registered');
}, sendErrorToTest);
}
function unregisterServiceWorker() {
navigator.serviceWorker.getRegistration().then(function(swRegistration) {
swRegistration.unregister().then(function(result) {
sendResultToTest('service worker unregistration status: ' + result);
})
}).catch(sendErrorToTest);
}
function removeManifest() {
var element = document.querySelector('link[rel="manifest"]');
if (element) {
element.parentNode.removeChild(element);
sendResultToTest('manifest removed');
} else {
sendResultToTest('unable to find manifest element');
}
}
function swapManifestNoSenderId() {
var element = document.querySelector('link[rel="manifest"]');
if (element) {
element.href = 'manifest_no_sender_id.json';
sendResultToTest('sender id removed from manifest');
} else {
sendResultToTest('unable to find manifest element');
}
}
// This is the old style of push subscriptions which we are phasing away
// from, where the subscription used a sender ID instead of public key.
function subscribePushWithoutKey() {
navigator.serviceWorker.ready.then(function(swRegistration) {
return swRegistration.pushManager.subscribe(
pushSubscriptionOptions)
.then(function(subscription) {
pushSubscription = subscription;
sendResultToTest(subscription.endpoint);
});
}).catch(sendErrorToTest);
}
function subscribePush() {
navigator.serviceWorker.ready.then(function(swRegistration) {
pushSubscriptionOptions.applicationServerKey = applicationServerKey.buffer;
return swRegistration.pushManager.subscribe(pushSubscriptionOptions)
.then(function(subscription) {
pushSubscription = subscription;
sendResultToTest(subscription.endpoint);
});
}).catch(sendErrorToTest);
}
function subscribePushBadKey() {
navigator.serviceWorker.ready.then(function(swRegistration) {
var invalidApplicationServerKey = Uint8Array.from(applicationServerKey);
invalidApplicationServerKey[0] = 0x05;
pushSubscriptionOptions.applicationServerKey =
invalidApplicationServerKey.buffer;
return swRegistration.pushManager.subscribe(pushSubscriptionOptions)
.then(function(subscription) {
pushSubscription = subscription;
sendResultToTest(subscription.endpoint);
});
}).catch(sendErrorToTest);
}
function GetP256dh() {
navigator.serviceWorker.ready.then(function(swRegistration) {
return swRegistration.pushManager.getSubscription()
.then(function(subscription) {
sendResultToTest(btoa(String.fromCharCode.apply(null,
new Uint8Array(subscription.getKey('p256dh')))));
});
}).catch(sendErrorToTest);
}
function permissionState() {
navigator.serviceWorker.ready.then(function(swRegistration) {
return swRegistration.pushManager.permissionState(pushSubscriptionOptions)
.then(function(permission) {
sendResultToTest('permission status - ' + permission);
});
}).catch(sendErrorToTest);
}
function isControlled() {
if (navigator.serviceWorker.controller) {
sendResultToTest('true - is controlled');
} else {
sendResultToTest('false - is not controlled');
}
}
function unsubscribePush() {
if (!pushSubscription) {
sendResultToTest('unsubscribe error: no subscription');
return;
}
pushSubscription.unsubscribe().then(function(result) {
sendResultToTest('unsubscribe result: ' + result);
}, function(error) {
sendResultToTest('unsubscribe error: ' + error.name + ': ' + error.message);
});
}
function hasSubscription() {
navigator.serviceWorker.ready.then(function(swRegistration) {
return swRegistration.pushManager.getSubscription();
}).then(function(subscription) {
sendResultToTest(subscription ? 'true - subscribed'
: 'false - not subscribed');
}).catch(sendErrorToTest);
}
navigator.serviceWorker.addEventListener('message', function(event) {
var message = JSON.parse(event.data);
if (message.type == 'push')
resultQueue.push(message.data);
}, false);
|
