diff --git a/src/packager/cache.js b/src/packager/cache.js index 16f2385..2c02867 100644 --- a/src/packager/cache.js +++ b/src/packager/cache.js @@ -68,22 +68,7 @@ const set = async (asset, content) => { }); }; -const resetAll = async () => { - const {transaction, store} = await db.createTransaction('readwrite'); - return new Promise((resolve, reject) => { - Database.setTransactionErrorHandler(transaction, reject); - const request = store.openCursor(); - request.onsuccess = e => { - const cursor = e.target.result; - if (cursor) { - cursor.delete(); - cursor.continue(); - } else { - resolve(); - } - }; - }); -}; +const resetAll = () => db.deleteEverything(); export default { get, diff --git a/src/packager/lib/idb.js b/src/packager/lib/idb.js index 2878af9..63bf8ce 100644 --- a/src/packager/lib/idb.js +++ b/src/packager/lib/idb.js @@ -67,7 +67,24 @@ class Database { }; } - onopen () { + async deleteEverything () { + const {transaction, store} = await this.createTransaction('readwrite'); + return new Promise((resolve, reject) => { + Database.setTransactionErrorHandler(transaction, reject); + const request = store.openCursor(); + request.onsuccess = e => { + const cursor = e.target.result; + if (cursor) { + cursor.delete(); + cursor.continue(); + } else { + resolve(); + } + }; + }); + } + + onopen () { return Promise.resolve(); } }