blob: cb15b3ff113fbc0790aed7a16632ec611c9aa359 (
plain)
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
|
// We store an empty response for each fetch event request we see
// in this Cache object so we can get the list of urls in the
// message event.
var cacheName = 'urls-' + self.registration.scope;
var waitUntilPromiseList = [];
self.addEventListener('message', function(event) {
var urls;
event.waitUntil(Promise.all(waitUntilPromiseList).then(function() {
waitUntilPromiseList = [];
return caches.open(cacheName);
}).then(function(cache) {
return cache.keys();
}).then(function(requestList) {
urls = requestList.map(function(request) { return request.url; });
return caches.delete(cacheName);
}).then(function() {
event.data.port.postMessage({urls: urls});
}));
});
function get_query_params(url) {
var search = (new URL(url)).search;
if (!search) {
return {};
}
var ret = {};
var params = search.substring(1).split('&');
params.forEach(function(param) {
var element = param.split('=');
ret[decodeURIComponent(element[0])] = decodeURIComponent(element[1]);
});
return ret;
}
self.addEventListener('fetch', function(event) {
var waitUntilPromise = caches.open(cacheName).then(function(cache) {
return cache.put(event.request, new Response());
});
event.waitUntil(waitUntilPromise);
var params = get_query_params(event.request.url);
if (!params['sw']) {
// To avoid races, add the waitUntil() promise to our global list.
// If we get a message event before we finish here, it will wait
// these promises to complete before proceeding to read from the
// cache.
waitUntilPromiseList.push(waitUntilPromise);
return;
}
event.respondWith(waitUntilPromise.then(function() {
if (params['sw'] == 'gen') {
return Response.redirect(params['url']);
} else if (params['sw'] == 'fetch') {
return fetch(event.request);
} else if (params['sw'] == 'opaque') {
return fetch(new Request(event.request.url, {redirect: 'manual'}));
} else if (params['sw'] == 'opaqueThroughCache') {
var url = event.request.url;
var cache;
return caches.delete(url)
.then(function() { return self.caches.open(url); })
.then(function(c) {
cache = c;
return fetch(new Request(url, {redirect: 'manual'}));
})
.then(function(res) { return cache.put(event.request, res); })
.then(function() { return cache.match(url); });
}
// unexpected... trigger an interception failure
}));
});
|
