pinafore/routes/_utils/database/databaseLifecycle.js

76 lines
2.2 KiB
JavaScript
Raw Normal View History

2018-01-23 17:03:31 +00:00
const openReqs = {}
const databaseCache = {}
2018-01-28 20:51:48 +00:00
const DB_VERSION = 2
2018-01-23 17:03:31 +00:00
import {
META_STORE,
TIMELINE_STORE,
2018-01-23 17:21:21 +00:00
STATUSES_STORE,
2018-01-28 20:51:48 +00:00
ACCOUNTS_STORE,
RELATIONSHIPS_STORE
2018-01-23 17:03:31 +00:00
} from './constants'
export function getDatabase(instanceName) {
2018-01-27 16:22:23 +00:00
if (!instanceName) {
2018-01-25 08:01:56 +00:00
throw new Error('instanceName is undefined in getDatabase()')
}
2018-01-23 17:03:31 +00:00
if (databaseCache[instanceName]) {
return Promise.resolve(databaseCache[instanceName])
}
databaseCache[instanceName] = new Promise((resolve, reject) => {
2018-01-28 20:51:48 +00:00
let req = indexedDB.open(instanceName, DB_VERSION)
2018-01-23 17:03:31 +00:00
openReqs[instanceName] = req
req.onerror = reject
req.onblocked = () => {
console.log('idb blocked')
}
2018-01-28 20:51:48 +00:00
req.onupgradeneeded = (e) => {
2018-01-23 17:03:31 +00:00
let db = req.result;
2018-01-28 20:51:48 +00:00
if (e.oldVersion < 1) {
db.createObjectStore(META_STORE, {keyPath: 'key'})
db.createObjectStore(STATUSES_STORE, {keyPath: 'id'})
db.createObjectStore(ACCOUNTS_STORE, {keyPath: 'id'})
let timelineStore = db.createObjectStore(TIMELINE_STORE, {keyPath: 'id'})
timelineStore.createIndex('statusId', 'statusId')
}
if (e.oldVersion < 2) {
db.createObjectStore(RELATIONSHIPS_STORE, {keyPath: 'id'})
}
2018-01-23 17:03:31 +00:00
}
req.onsuccess = () => resolve(req.result)
})
return databaseCache[instanceName]
}
export async function dbPromise(db, storeName, readOnlyOrReadWrite, cb) {
return await new Promise((resolve, reject) => {
const tx = db.transaction(storeName, readOnlyOrReadWrite)
let store = typeof storeName === 'string' ?
tx.objectStore(storeName) :
storeName.map(name => tx.objectStore(name))
let res
cb(store, (result) => {
res = result
})
tx.oncomplete = () => resolve(res)
tx.onerror = () => reject(tx.error.name + ' ' + tx.error.message)
})
}
export function deleteDatabase(instanceName) {
return new Promise((resolve, reject) => {
// close any open requests
let openReq = openReqs[instanceName];
if (openReq && openReq.result) {
openReq.result.close()
}
delete openReqs[instanceName]
delete databaseCache[instanceName]
let req = indexedDB.deleteDatabase(instanceName)
req.onsuccess = () => resolve()
req.onerror = () => reject(req.error.name + ' ' + req.error.message)
})
}