1 files changed, 82 insertions, 0 deletions
diff --git a/node_modules/workbox-background-sync/models/QueueStore.mjs b/node_modules/workbox-background-sync/models/QueueStore.mjs
new file mode 100644
index 00000000..6f880d88
--- /dev/null
+++ b/node_modules/workbox-background-sync/models/QueueStore.mjs
@@ -0,0 +1,82 @@
+/*
+ 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.
+*/
+
+import {DBWrapper} from 'workbox-core/_private/DBWrapper.mjs';
+import StorableRequest from './StorableRequest.mjs';
+import {DB_NAME, OBJECT_STORE_NAME, INDEXED_PROP} from '../utils/constants.mjs';
+import '../_version.mjs';
+
+/**
+ * A class to manage storing requests from a Queue in IndexedbDB,
+ * indexed by their queue name for easier access.
+ *
+ * @private
+ */
+export 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(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
+   */
+  async addEntry(storableRequest) {
+    await 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
+   */
+  async getAndRemoveOldestEntry() {
+    const [entry] = await this._db.getAllMatching(OBJECT_STORE_NAME, {
+      index: INDEXED_PROP,
+      query: IDBKeyRange.only(this._queue.name),
+      count: 1,
+      includeKeys: true,
+    });
+
+    if (entry) {
+      await this._db.delete(OBJECT_STORE_NAME, entry.primaryKey);
+      return new StorableRequest(entry.value.storableRequest);
+    }
+  }
+}