idb-keyval.ts
2.23 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
export class Store {
readonly _dbp: Promise<IDBDatabase>;
constructor(dbName = 'keyval-store', readonly storeName = 'keyval') {
this._dbp = new Promise((resolve, reject) => {
const openreq = indexedDB.open(dbName, 1);
openreq.onerror = () => reject(openreq.error);
openreq.onsuccess = () => resolve(openreq.result);
// First time setup: create an empty object store
openreq.onupgradeneeded = () => {
openreq.result.createObjectStore(storeName);
};
});
}
_withIDBStore(type: IDBTransactionMode, callback: ((store: IDBObjectStore) => void)): Promise<void> {
return this._dbp.then(db => new Promise<void>((resolve, reject) => {
const transaction = db.transaction(this.storeName, type);
transaction.oncomplete = () => resolve();
transaction.onabort = transaction.onerror = () => reject(transaction.error);
callback(transaction.objectStore(this.storeName));
}));
}
}
let store: Store;
function getDefaultStore() {
if (!store) store = new Store();
return store;
}
export function get<Type>(key: IDBValidKey, store = getDefaultStore()): Promise<Type> {
let req: IDBRequest;
return store._withIDBStore('readonly', store => {
req = store.get(key);
}).then(() => req.result);
}
export function set(key: IDBValidKey, value: any, store = getDefaultStore()): Promise<void> {
return store._withIDBStore('readwrite', store => {
store.put(value, key);
});
}
export function del(key: IDBValidKey, store = getDefaultStore()): Promise<void> {
return store._withIDBStore('readwrite', store => {
store.delete(key);
});
}
export function clear(store = getDefaultStore()): Promise<void> {
return store._withIDBStore('readwrite', store => {
store.clear();
});
}
export function keys(store = getDefaultStore()): Promise<IDBValidKey[]> {
const keys: IDBValidKey[] = [];
return store._withIDBStore('readonly', store => {
// This would be store.getAllKeys(), but it isn't supported by Edge or Safari.
// And openKeyCursor isn't supported by Safari.
(store.openKeyCursor || store.openCursor).call(store).onsuccess = function() {
if (!this.result) return;
keys.push(this.result.key);
this.result.continue()
};
}).then(() => keys);
}