1 files changed, 57 insertions, 0 deletions
diff --git a/test/wpt/tests/storage/buckets/resources/util.js b/test/wpt/tests/storage/buckets/resources/util.js
new file mode 100644
index 0000000..425303c
--- /dev/null
+++ b/test/wpt/tests/storage/buckets/resources/util.js
@@ -0,0 +1,57 @@
+'use strict';
+
+// Makes sure initial bucket state is as expected and to clean up after the test
+// is over (whether it passes or fails).
+async function prepareForBucketTest(test) {
+  // Verify initial state.
+  assert_equals('', (await navigator.storageBuckets.keys()).join());
+  // Clean up after test.
+  test.add_cleanup(async function() {
+    const keys = await navigator.storageBuckets.keys();
+    for (const key of keys) {
+      await navigator.storageBuckets.delete(key);
+    }
+  });
+}
+
+function indexedDbOpenRequest(t, idb, dbname, upgrade_func) {
+  return new Promise((resolve, reject) => {
+    const openRequest = idb.open(dbname);
+    t.add_cleanup(() => {
+      indexedDbDeleteRequest(idb, dbname);
+    });
+
+    openRequest.onerror = () => {
+      reject(openRequest.error);
+    };
+    openRequest.onsuccess = () => {
+      resolve(openRequest.result);
+    };
+    openRequest.onupgradeneeded = event => {
+      upgrade_func(openRequest.result);
+    };
+  });
+}
+
+function indexedDbDeleteRequest(idb, name) {
+  return new Promise((resolve, reject) => {
+    const deleteRequest = idb.deleteDatabase(name);
+    deleteRequest.onerror = () => {
+      reject(deleteRequest.error);
+    };
+    deleteRequest.onsuccess = () => {
+      resolve();
+    };
+  });
+}
+
+function transactionPromise(txn) {
+  return new Promise((resolve, reject) => {
+    txn.onabort = () => {
+      reject(txn.error);
+    };
+    txn.oncomplete = () => {
+      resolve();
+    };
+  });
+}