|
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218 |
- /*
- Copyright 2018 Google Inc. All Rights Reserved.
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
-
- import {assert} from 'workbox-core/_private/assert.mjs';
- import {cacheNames} from 'workbox-core/_private/cacheNames.mjs';
- import {cacheWrapper} from 'workbox-core/_private/cacheWrapper.mjs';
- import {fetchWrapper} from 'workbox-core/_private/fetchWrapper.mjs';
- import {getFriendlyURL} from 'workbox-core/_private/getFriendlyURL.mjs';
- import {logger} from 'workbox-core/_private/logger.mjs';
-
- import messages from './utils/messages.mjs';
- import cacheOkAndOpaquePlugin from './plugins/cacheOkAndOpaquePlugin.mjs';
- import './_version.mjs';
-
- /**
- * An implementation of a
- * [stale-while-revalidate]{@link https://developers.google.com/web/fundamentals/instant-and-offline/offline-cookbook/#stale-while-revalidate}
- * request strategy.
- *
- * Resources are requested from both the cache and the network in parallel.
- * The strategy will respond with the cached version if available, otherwise
- * wait for the network response. The cache is updated with the network response
- * with each successful request.
- *
- * By default, this strategy will cache responses with a 200 status code as
- * well as [opaque responses]{@link https://developers.google.com/web/tools/workbox/guides/handle-third-party-requests}.
- * Opaque responses are are cross-origin requests where the response doesn't
- * support [CORS]{@link https://enable-cors.org/}.
- *
- * @memberof workbox.strategies
- */
- class StaleWhileRevalidate {
- /**
- * @param {Object} options
- * @param {string} options.cacheName Cache name to store and retrieve
- * requests. Defaults to cache names provided by
- * [workbox-core]{@link workbox.core.cacheNames}.
- * @param {Array<Object>} options.plugins [Plugins]{@link https://developers.google.com/web/tools/workbox/guides/using-plugins}
- * to use in conjunction with this caching strategy.
- * @param {Object} options.fetchOptions Values passed along to the
- * [`init`](https://developer.mozilla.org/en-US/docs/Web/API/WindowOrWorkerGlobalScope/fetch#Parameters)
- * of all fetch() requests made by this strategy.
- * @param {Object} options.matchOptions [`CacheQueryOptions`](https://w3c.github.io/ServiceWorker/#dictdef-cachequeryoptions)
- */
- constructor(options = {}) {
- this._cacheName = cacheNames.getRuntimeName(options.cacheName);
- this._plugins = options.plugins || [];
-
- if (options.plugins) {
- let isUsingCacheWillUpdate =
- options.plugins.some((plugin) => !!plugin.cacheWillUpdate);
- this._plugins = isUsingCacheWillUpdate ?
- options.plugins : [cacheOkAndOpaquePlugin, ...options.plugins];
- } else {
- // No plugins passed in, use the default plugin.
- this._plugins = [cacheOkAndOpaquePlugin];
- }
-
- this._fetchOptions = options.fetchOptions || null;
- this._matchOptions = options.matchOptions || null;
- }
-
- /**
- * This method will perform a request strategy and follows an API that
- * will work with the
- * [Workbox Router]{@link workbox.routing.Router}.
- *
- * @param {Object} options
- * @param {FetchEvent} options.event The fetch event to run this strategy
- * against.
- * @return {Promise<Response>}
- */
- async handle({event}) {
- if (process.env.NODE_ENV !== 'production') {
- assert.isInstance(event, FetchEvent, {
- moduleName: 'workbox-strategies',
- className: 'StaleWhileRevalidate',
- funcName: 'handle',
- paramName: 'event',
- });
- }
-
- return this.makeRequest({
- event,
- request: event.request,
- });
- }
-
- /**
- * This method can be used to perform a make a standalone request outside the
- * context of the [Workbox Router]{@link workbox.routing.Router}.
- *
- * See "[Advanced Recipes](https://developers.google.com/web/tools/workbox/guides/advanced-recipes#make-requests)"
- * for more usage information.
- *
- * @param {Object} options
- * @param {Request|string} options.request Either a
- * [`Request`]{@link https://developer.mozilla.org/en-US/docs/Web/API/Request}
- * object, or a string URL, corresponding to the request to be made.
- * @param {FetchEvent} [options.event] If provided, `event.waitUntil()` will
- * be called automatically to extend the service worker's lifetime.
- * @return {Promise<Response>}
- */
- async makeRequest({event, request}) {
- const logs = [];
-
- if (typeof request === 'string') {
- request = new Request(request);
- }
-
- if (process.env.NODE_ENV !== 'production') {
- assert.isInstance(request, Request, {
- moduleName: 'workbox-strategies',
- className: 'StaleWhileRevalidate',
- funcName: 'handle',
- paramName: 'request',
- });
- }
-
- const fetchAndCachePromise = this._getFromNetwork({request, event});
-
- let response = await cacheWrapper.match({
- cacheName: this._cacheName,
- request,
- event,
- matchOptions: this._matchOptions,
- plugins: this._plugins,
- });
-
- if (response) {
- if (process.env.NODE_ENV !== 'production') {
- logs.push(`Found a cached response in the '${this._cacheName}'` +
- ` cache. Will update with the network response in the background.`);
- }
-
- if (event) {
- try {
- event.waitUntil(fetchAndCachePromise);
- } catch (error) {
- if (process.env.NODE_ENV !== 'production') {
- logger.warn(`Unable to ensure service worker stays alive when ` +
- `updating cache for '${getFriendlyURL(event.request.url)}'.`);
- }
- }
- }
- } else {
- if (process.env.NODE_ENV !== 'production') {
- logs.push(`No response found in the '${this._cacheName}' cache. ` +
- `Will wait for the network response.`);
- }
- response = await fetchAndCachePromise;
- }
-
- if (process.env.NODE_ENV !== 'production') {
- logger.groupCollapsed(
- messages.strategyStart('StaleWhileRevalidate', request));
- for (let log of logs) {
- logger.log(log);
- }
- messages.printFinalResponse(response);
- logger.groupEnd();
- }
-
- return response;
- }
-
- /**
- * @param {Object} options
- * @param {Request} options.request
- * @param {Event} [options.event]
- * @return {Promise<Response>}
- *
- * @private
- */
- async _getFromNetwork({request, event}) {
- const response = await fetchWrapper.fetch({
- request,
- event,
- fetchOptions: this._fetchOptions,
- plugins: this._plugins,
- });
-
- const cachePutPromise = cacheWrapper.put({
- cacheName: this._cacheName,
- request,
- response: response.clone(),
- event,
- plugins: this._plugins,
- });
-
- if (event) {
- try {
- event.waitUntil(cachePutPromise);
- } catch (error) {
- if (process.env.NODE_ENV !== 'production') {
- logger.warn(`Unable to ensure service worker stays alive when ` +
- `updating cache for '${getFriendlyURL(event.request.url)}'.`);
- }
- }
- }
-
- return response;
- }
- }
-
- export {StaleWhileRevalidate};
|