automatic build

1 files changed, 594 insertions, 0 deletions

diff --git a/dist/workbox-v3.2.0/workbox-background-sync.dev.js b/dist/workbox-v3.2.0/workbox-background-sync.dev.js
new file mode 100644
index 0000000..fcb3e01
--- /dev/null
+++ b/dist/workbox-v3.2.0/workbox-background-sync.dev.js
@@ -0,0 +1,594 @@
+this.workbox = this.workbox || {};
+this.workbox.backgroundSync = (function (DBWrapper_mjs,WorkboxError_mjs,logger_mjs,assert_mjs,getFriendlyURL_mjs) {
+'use strict';
+
+try {
+  self.workbox.v['workbox:background-sync:3.2.0'] = 1;
+} catch (e) {} // eslint-disable-line
+
+/*
+ Copyright 2017 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.
+*/
+
+const serializableProperties = ['method', 'referrer', 'referrerPolicy', 'mode', 'credentials', 'cache', 'redirect', 'integrity', 'keepalive'];
+
+/**
+ * A class to make it easier to serialize and de-serialize requests so they
+ * can be stored in IndexedDB.
+ *
+ * @private
+ */
+class StorableRequest {
+  /**
+   * Converts a Request object to a plain object that can be structured
+   * cloned or JSON-stringified.
+   *
+   * @param {Request} request
+   * @return {Promise<StorableRequest>}
+   *
+   * @private
+   */
+  static fromRequest(request) {
+    return babelHelpers.asyncToGenerator(function* () {
+      const requestInit = { headers: {} };
+
+      // Set the body if present.
+      if (request.method !== 'GET') {
+        // Use blob to support non-text request bodies,
+        // and clone first in case the caller still needs the request.
+        requestInit.body = yield request.clone().blob();
+      }
+
+      // Convert the headers from an iterable to an object.
+      for (const [key, value] of request.headers.entries()) {
+        requestInit.headers[key] = value;
+      }
+
+      // Add all other serializable request properties
+      for (const prop of serializableProperties) {
+        if (request[prop] !== undefined) {
+          requestInit[prop] = request[prop];
+        }
+      }
+
+      return new StorableRequest({ url: request.url, requestInit });
+    })();
+  }
+
+  /**
+   * Accepts a URL and RequestInit dictionary that can be used to create a
+   * new Request object. A timestamp is also generated so consumers can
+   * reference when the object was created.
+   *
+   * @param {Object} param1
+   * @param {string} param1.url
+   * @param {Object} param1.requestInit
+   *     See: https://fetch.spec.whatwg.org/#requestinit
+   * @param {number} param1.timestamp The time the request was created,
+   *     defaulting to the current time if not specified.
+   *
+   * @private
+   */
+  constructor({ url, requestInit, timestamp = Date.now() }) {
+    this.url = url;
+    this.requestInit = requestInit;
+
+    // "Private"
+    this._timestamp = timestamp;
+  }
+
+  /**
+   * Gets the private _timestamp property.
+   *
+   * @return {number}
+   *
+   * @private
+   */
+  get timestamp() {
+    return this._timestamp;
+  }
+
+  /**
+   * Coverts this instance to a plain Object.
+   *
+   * @return {Object}
+   *
+   * @private
+   */
+  toObject() {
+    return {
+      url: this.url,
+      timestamp: this.timestamp,
+      requestInit: this.requestInit
+    };
+  }
+
+  /**
+   * Converts this instance to a Request.
+   *
+   * @return {Request}
+   *
+   * @private
+   */
+  toRequest() {
+    return new Request(this.url, this.requestInit);
+  }
+
+  /**
+   * Creates and returns a deep clone of the instance.
+   *
+   * @return {StorableRequest}
+   *
+   * @private
+   */
+  clone() {
+    const requestInit = Object.assign({}, this.requestInit);
+    requestInit.headers = Object.assign({}, this.requestInit.headers);
+    if (this.requestInit.body) {
+      requestInit.body = this.requestInit.body.slice();
+    }
+
+    return new StorableRequest({
+      url: this.url,
+      timestamp: this.timestamp,
+      requestInit
+    });
+  }
+}
+
+/*
+ Copyright 2017 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.
+*/
+
+const DB_NAME = 'workbox-background-sync';
+const OBJECT_STORE_NAME = 'requests';
+const INDEXED_PROP = 'queueName';
+const TAG_PREFIX = 'workbox-background-sync';
+const MAX_RETENTION_TIME = 60 * 24 * 7; // 7 days in minutes
+
+/*
+ Copyright 2017 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.
+*/
+
+/**
+ * A class to manage storing requests from a Queue in IndexedbDB,
+ * indexed by their queue name for easier access.
+ *
+ * @private
+ */
+class QueueStore {
+  /**
+   * Associates this instance with a Queue instance, so entries added can be
+   * identified by their queue name.
+   *
+   * @param {Queue} queue
+   *
+   * @private
+   */
+  constructor(queue) {
+    this._queue = queue;
+    this._db = new DBWrapper_mjs.DBWrapper(DB_NAME, 1, {
+      onupgradeneeded: evt => evt.target.result.createObjectStore(OBJECT_STORE_NAME, { autoIncrement: true }).createIndex(INDEXED_PROP, INDEXED_PROP, { unique: false })
+    });
+  }
+
+  /**
+   * Takes a StorableRequest instance, converts it to an object and adds it
+   * as an entry in the object store.
+   *
+   * @param {StorableRequest} storableRequest
+   *
+   * @private
+   */
+  addEntry(storableRequest) {
+    var _this = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      yield _this._db.add(OBJECT_STORE_NAME, {
+        queueName: _this._queue.name,
+        storableRequest: storableRequest.toObject()
+      });
+    })();
+  }
+
+  /**
+   * Gets the oldest entry in the object store, removes it, and returns the
+   * value as a StorableRequest instance. If no entry exists, it returns
+   * undefined.
+   *
+   * @return {StorableRequest|undefined}
+   *
+   * @private
+   */
+  getAndRemoveOldestEntry() {
+    var _this2 = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      const [entry] = yield _this2._db.getAllMatching(OBJECT_STORE_NAME, {
+        index: INDEXED_PROP,
+        query: IDBKeyRange.only(_this2._queue.name),
+        count: 1,
+        includeKeys: true
+      });
+
+      if (entry) {
+        yield _this2._db.delete(OBJECT_STORE_NAME, entry.primaryKey);
+        return new StorableRequest(entry.value.storableRequest);
+      }
+    })();
+  }
+}
+
+/*
+ Copyright 2017 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.
+*/
+
+const queueNames = new Set();
+
+/**
+ * A class to manage storing failed requests in IndexedDB and retrying them
+ * later. All parts of the storing and replaying process are observable via
+ * callbacks.
+ *
+ * @memberof workbox.backgroundSync
+ */
+class Queue {
+  /**
+   * Creates an instance of Queue with the given options
+   *
+   * @param {string} name The unique name for this queue. This name must be
+   *     unique as it's used to register sync events and store requests
+   *     in IndexedDB specific to this instance. An error will be thrown if
+   *     a duplicate name is detected.
+   * @param {Object} [options]
+   * @param {Object} [options.callbacks] Callbacks to observe the lifecycle of
+   *     queued requests. Use these to respond to or modify the requests
+   *     during the replay process.
+   * @param {function(StorableRequest):undefined}
+   *     [options.callbacks.requestWillEnqueue]
+   *     Invoked immediately before the request is stored to IndexedDB. Use
+   *     this callback to modify request data at store time.
+   * @param {function(StorableRequest):undefined}
+   *     [options.callbacks.requestWillReplay]
+   *     Invoked immediately before the request is re-fetched. Use this
+   *     callback to modify request data at fetch time.
+   * @param {function(Array<StorableRequest>):undefined}
+   *     [options.callbacks.queueDidReplay]
+   *     Invoked after all requests in the queue have successfully replayed.
+   * @param {number} [options.maxRetentionTime = 7 days] The amount of time (in
+   *     minutes) a request may be retried. After this amount of time has
+   *     passed, the request will be deleted from the queue.
+   */
+  constructor(name, {
+    callbacks = {},
+    maxRetentionTime = MAX_RETENTION_TIME
+  } = {}) {
+    // Ensure the store name is not already being used
+    if (queueNames.has(name)) {
+      throw new WorkboxError_mjs.WorkboxError('duplicate-queue-name', { name });
+    } else {
+      queueNames.add(name);
+    }
+
+    this._name = name;
+    this._callbacks = callbacks;
+    this._maxRetentionTime = maxRetentionTime;
+    this._queueStore = new QueueStore(this);
+
+    this._addSyncListener();
+  }
+
+  /**
+   * @return {string}
+   */
+  get name() {
+    return this._name;
+  }
+
+  /**
+   * Stores the passed request into IndexedDB. The database used is
+   * `workbox-background-sync` and the object store name is the same as
+   * the name this instance was created with (to guarantee it's unique).
+   *
+   * @param {Request} request The request object to store.
+   */
+  addRequest(request) {
+    var _this = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      {
+        assert_mjs.assert.isInstance(request, Request, {
+          moduleName: 'workbox-background-sync',
+          className: 'Queue',
+          funcName: 'addRequest',
+          paramName: 'request'
+        });
+      }
+
+      const storableRequest = yield StorableRequest.fromRequest(request.clone());
+      yield _this._runCallback('requestWillEnqueue', storableRequest);
+      yield _this._queueStore.addEntry(storableRequest);
+      yield _this._registerSync();
+      {
+        logger_mjs.logger.log(`Request for '${getFriendlyURL_mjs.getFriendlyURL(storableRequest.url)}' has been
+          added to background sync queue '${_this._name}'.`);
+      }
+    })();
+  }
+
+  /**
+   * Retrieves all stored requests in IndexedDB and retries them. If the
+   * queue contained requests that were successfully replayed, the
+   * `queueDidReplay` callback is invoked (which implies the queue is
+   * now empty). If any of the requests fail, a new sync registration is
+   * created to retry again later.
+   */
+  replayRequests() {
+    var _this2 = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      const now = Date.now();
+      const replayedRequests = [];
+      const failedRequests = [];
+
+      let storableRequest;
+      while (storableRequest = yield _this2._queueStore.getAndRemoveOldestEntry()) {
+        // Make a copy so the unmodified request can be stored
+        // in the event of a replay failure.
+        const storableRequestClone = storableRequest.clone();
+
+        // Ignore requests older than maxRetentionTime.
+        const maxRetentionTimeInMs = _this2._maxRetentionTime * 60 * 1000;
+        if (now - storableRequest.timestamp > maxRetentionTimeInMs) {
+          continue;
+        }
+
+        yield _this2._runCallback('requestWillReplay', storableRequest);
+
+        const replay = { request: storableRequest.toRequest() };
+
+        try {
+          // Clone the request before fetching so callbacks get an unused one.
+          replay.response = yield fetch(replay.request.clone());
+          {
+            logger_mjs.logger.log(`Request for '${getFriendlyURL_mjs.getFriendlyURL(storableRequest.url)}'
+             has been replayed`);
+          }
+        } catch (err) {
+          {
+            logger_mjs.logger.log(`Request for '${getFriendlyURL_mjs.getFriendlyURL(storableRequest.url)}'
+             failed to replay`);
+          }
+          replay.error = err;
+          failedRequests.push(storableRequestClone);
+        }
+
+        replayedRequests.push(replay);
+      }
+
+      yield _this2._runCallback('queueDidReplay', replayedRequests);
+
+      // If any requests failed, put the failed requests back in the queue
+      // and rethrow the failed requests count.
+      if (failedRequests.length) {
+        yield Promise.all(failedRequests.map(function (storableRequest) {
+          return _this2._queueStore.addEntry(storableRequest);
+        }));
+
+        throw new WorkboxError_mjs.WorkboxError('queue-replay-failed', { name: _this2._name, count: failedRequests.length });
+      }
+    })();
+  }
+
+  /**
+   * Runs the passed callback if it exists.
+   *
+   * @private
+   * @param {string} name The name of the callback on this._callbacks.
+   * @param {...*} args The arguments to invoke the callback with.
+   */
+  _runCallback(name, ...args) {
+    var _this3 = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      if (typeof _this3._callbacks[name] === 'function') {
+        yield _this3._callbacks[name].apply(null, args);
+      }
+    })();
+  }
+
+  /**
+   * In sync-supporting browsers, this adds a listener for the sync event.
+   * In non-sync-supporting browsers, this will retry the queue on service
+   * worker startup.
+   *
+   * @private
+   */
+  _addSyncListener() {
+    if ('sync' in registration) {
+      self.addEventListener('sync', event => {
+        if (event.tag === `${TAG_PREFIX}:${this._name}`) {
+          {
+            logger_mjs.logger.log(`Background sync for tag '${event.tag}'
+                has been received, starting replay now`);
+          }
+          event.waitUntil(this.replayRequests());
+        }
+      });
+    } else {
+      {
+        logger_mjs.logger.log(`Background sync replaying without background sync event`);
+      }
+      // If the browser doesn't support background sync, retry
+      // every time the service worker starts up as a fallback.
+      this.replayRequests();
+    }
+  }
+
+  /**
+   * Registers a sync event with a tag unique to this instance.
+   *
+   * @private
+   */
+  _registerSync() {
+    var _this4 = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      if ('sync' in registration) {
+        try {
+          yield registration.sync.register(`${TAG_PREFIX}:${_this4._name}`);
+        } catch (err) {
+          // This means the registration failed for some reason, possibly due to
+          // the user disabling it.
+          {
+            logger_mjs.logger.warn(`Unable to register sync event for '${_this4._name}'.`, err);
+          }
+        }
+      }
+    })();
+  }
+
+  /**
+   * Returns the set of queue names. This is primarily used to reset the list
+   * of queue names in tests.
+   *
+   * @return {Set}
+   *
+   * @private
+   */
+  static get _queueNames() {
+    return queueNames;
+  }
+}
+
+/*
+ Copyright 2017 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.
+*/
+
+/**
+ * A class implementing the `fetchDidFail` lifecycle callback. This makes it
+ * easier to add failed requests to a background sync Queue.
+ *
+ * @memberof workbox.backgroundSync
+ */
+class Plugin {
+  /**
+   * @param {...*} queueArgs Args to forward to the composed Queue instance.
+   *    See the [Queue]{@link workbox.backgroundSync.Queue} documentation for
+   *    parameter details.
+   */
+  constructor(...queueArgs) {
+    this._queue = new Queue(...queueArgs);
+    this.fetchDidFail = this.fetchDidFail.bind(this);
+  }
+
+  /**
+   * @param {Object} options
+   * @param {Request} options.request
+   * @private
+   */
+  fetchDidFail({ request }) {
+    var _this = this;
+
+    return babelHelpers.asyncToGenerator(function* () {
+      yield _this._queue.addRequest(request);
+    })();
+  }
+}
+
+/*
+ Copyright 2017 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.
+*/
+
+
+var publicAPI = Object.freeze({
+	Queue: Queue,
+	Plugin: Plugin
+});
+
+/*
+ Copyright 2017 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.
+*/
+
+return publicAPI;
+
+}(workbox.core._private,workbox.core._private,workbox.core._private,workbox.core._private,workbox.core._private));
+
+//# sourceMappingURL=workbox-background-sync.dev.js.map