Public/automatic
1
0
Fork 0
mirror of https://github.com/vladmandic/automatic synced 2026-09-19 09:14:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove need for timeout failsafe

Browse Source 
All the failure routes should either:
- Get far enough along to not leave checked values unable to reach the finished state...
- or all be tied into the same AbortController so everything aborts together.

... I think...
This commit is contained in:
awsr
2025-12-02 16:28:19 -08:00
parent d3a2f6c7ed
commit 2c288b651a
2 changed files with 48 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files
javascript/indexdb.js
+12 -11
View File
@@ -90,6 +90,8 @@ async function idbGetAllKeys(index = null, query = null) {
try {
let request;
const transaction = db.transaction('thumbs', 'readonly');
transaction.onabort = (e) => reject(e);
const store = transaction.objectStore('thumbs');
if (index) {
request = store.index(index).getAllKeys(query);
@@ -98,7 +100,6 @@ async function idbGetAllKeys(index = null, query = null) {
}
request.onsuccess = () => resolve(request.result);
request.onerror = (e) => reject(e);
transaction.onabort = (e) => reject(e);
} catch (err) {
reject(err);
}
@@ -117,6 +118,8 @@ async function idbCount(folder = null) {
try {
let request;
const transaction = db.transaction('thumbs', 'readonly');
transaction.onabort = (e) => reject(e);
const store = transaction.objectStore('thumbs');
if (folder) {
request = store.index('folder').count(folder);
@@ -125,7 +128,6 @@ async function idbCount(folder = null) {
}
request.onsuccess = () => resolve(request.result);
request.onerror = (e) => reject(e);
transaction.onabort = (e) => reject(e);
} catch (err) {
reject(err);
}
@@ -161,15 +163,6 @@ async function idbFolderCleanup(keepSet, folder, signal) {
transaction.abort();
}
signal.addEventListener('abort', abortTransaction);
try {
const store = transaction.objectStore('thumbs');
removals.forEach((entry) => { store.delete(entry); });
} catch (err) {
error(err);
abortTransaction();
}
transaction.onabort = () => {
signal.removeEventListener('abort', abortTransaction);
reject(`Aborting. ${signal.reason}`); // eslint-disable-line prefer-promise-reject-errors
@@ -182,6 +175,14 @@ async function idbFolderCleanup(keepSet, folder, signal) {
signal.removeEventListener('abort', abortTransaction);
resolve(totalRemovals);
};
try {
const store = transaction.objectStore('thumbs');
removals.forEach((entry) => { store.delete(entry); });
} catch (err) {
error(err);
abortTransaction();
}
});
}