kopia lustrzana https://gitlab.com/rysiekpl/libresilient
95 wiersze
3.8 KiB
JavaScript
95 wiersze
3.8 KiB
JavaScript
/* ========================================================================= *\
|
|
|* === Testing plugin === *|
|
|
\* ========================================================================= */
|
|
|
|
/**
|
|
* this plugin does not implement any push method
|
|
*/
|
|
|
|
// no polluting of the global namespace please
|
|
(function(LRPC){
|
|
// this never changes
|
|
const pluginName = "test-plugin"
|
|
LRPC.set(pluginName, (LR, init={})=>{
|
|
|
|
/*
|
|
* plugin config settings
|
|
*/
|
|
|
|
// sane defaults
|
|
let defaultConfig = {}
|
|
|
|
// merge the defaults with settings from init
|
|
let config = {...defaultConfig, ...init}
|
|
/**
|
|
* getting content using regular HTTP(S) fetch()
|
|
*/
|
|
let fetchContent = (url, init={}) => {
|
|
LR.log(pluginName, `regular fetch: ${url}`)
|
|
// we really want to make fetch happen, Regina!
|
|
// TODO: this change should *probably* be handled on the Service Worker level
|
|
init.cache = 'reload'
|
|
// run built-in regular fetch()
|
|
return fetch(url, init)
|
|
.then(async (response) => {
|
|
|
|
// we got something, it seems
|
|
// it might be a 2xx; it might be a 3xx redirect
|
|
// it might also be a 4xx or a 5xx error
|
|
// the service worker will know how to deal with those
|
|
LR.log(pluginName, `fetched successfully: ${response.url}`);
|
|
|
|
// we need to create a new Response object
|
|
// with all the headers added explicitly,
|
|
// since response.headers is immutable
|
|
var responseInit = {
|
|
status: response.status,
|
|
statusText: response.statusText,
|
|
headers: {},
|
|
url: response.url
|
|
};
|
|
response.headers.forEach(function(val, header){
|
|
responseInit.headers[header] = val;
|
|
});
|
|
|
|
// add the X-LibResilient-* headers to the mix
|
|
responseInit.headers['X-LibResilient-Method'] = pluginName
|
|
responseInit.headers['X-LibResilient-ETag'] = response.headers.get('ETag')
|
|
|
|
let ab = await response.clone()
|
|
.blob()
|
|
.then(blob=>{
|
|
return blob.arrayBuffer()
|
|
})
|
|
|
|
// let's guess the content type
|
|
let contentType = await LR.guessMimeType(
|
|
url.split('.').pop().toLowerCase(),
|
|
ab
|
|
)
|
|
LR.log(pluginName, '*** guessed content type:', contentType)
|
|
|
|
// return the new response, using the Blob from the original one
|
|
return response
|
|
.blob()
|
|
.then((blob) => {
|
|
return new Response(
|
|
blob,
|
|
responseInit
|
|
)
|
|
})
|
|
})
|
|
}
|
|
|
|
// return the plugin
|
|
return {
|
|
name: pluginName,
|
|
description: 'Just a regular HTTP(S) fetch()',
|
|
version: 'COMMIT_UNKNOWN',
|
|
fetch: fetchContent
|
|
}
|
|
|
|
})
|
|
// done with not polluting the global namespace
|
|
})(LibResilientPluginConstructors)
|