From aec5c9aefca828aae5860f027ab9651c76a42472 Mon Sep 17 00:00:00 2001 From: Wojtek Kosior Date: Sat, 18 Jun 2022 12:30:21 +0200 Subject: automatically change repo url to point to api v2 endpoint --- common/indexeddb.js | 43 ++++++++++++++++++++++++++++++++----------- 1 file changed, 32 insertions(+), 11 deletions(-) (limited to 'common') diff --git a/common/indexeddb.js b/common/indexeddb.js index bd87399..d83e605 100644 --- a/common/indexeddb.js +++ b/common/indexeddb.js @@ -53,11 +53,13 @@ let initial_data = ( ); /* Update when changes are made to database schema. Must have 3 elements */ -const db_version = [1, 0, 0]; +const db_version = [1, 0, 1]; const nr_reductor = ([i, s], num) => [i - 1, s + num * 1024 ** i]; const version_nr = ver => ver.slice(0, 3).reduce(nr_reductor, [2, 0])[1]; +let db_version_nr = version_nr(db_version); + const stores = [ ["file", {keyPath: "sha256"}], ["file_uses", {keyPath: "sha256"}], @@ -100,19 +102,38 @@ async function idb_del(transaction, store_name, key) } async function perform_upgrade(event) { + if (event.oldVersion > db_version_nr) + throw "bad db version: " + event.oldVersion; + const opened_db = event.target.result; + const transaction = event.target.transaction; - /* When we move to a new database schema, we will add upgrade logic here. */ - if (event.oldVersion > 0) - throw "bad db version: " + event.oldVersion; + if (event.oldVersion == 0) { + for (const [store_name, key_mode] of stores) + opened_db.createObjectStore(store_name, key_mode); + } - let store; - for (const [store_name, key_mode] of stores) - store = opened_db.createObjectStore(store_name, key_mode); + if (event.oldVersion > 0 && event.oldVersion < db_version_nr) { + const v1_url = "https://hydrilla.koszko.org/api_v1/"; + const v1_entry = await idb_get(transaction, "repo", v1_url); - const ctx = make_context(store.transaction, initial_data.file); - await _save_items(initial_data.resource, initial_data.mapping, - initial_data.repo || [], ctx); + if (v1_entry) { + const v2_url = "https://hydrilla.koszko.org/api_v2/"; + + await idb_del(transaction, "repo", v1_url); + await idb_put(transaction, "repo", {url: v2_url}); + } + } + + if (event.oldVersion == 0) { + const ctx = make_context(transaction, initial_data.file); + await _save_items(initial_data.resource, initial_data.mapping, + initial_data.repo || [], ctx); + } else { + await new Promise( + (...cbs) => [transaction.onsuccess, transaction.onerror] = cbs + ); + } return opened_db; } @@ -125,7 +146,7 @@ async function get_db() { let resolve, reject; const waiter = new Promise((...cbs) => [resolve, reject] = cbs); - const request = indexedDB.open("haketilo", version_nr(db_version)); + const request = indexedDB.open("haketilo", db_version_nr); request.onsuccess = ev => resolve(ev.target.result); request.onerror = ev => reject("db error: " + ev.target.errorCode); request.onupgradeneeded = ev => perform_upgrade(ev).then(resolve, reject); -- cgit v1.2.3