forked from emscripten-core/emscripten
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathIDBStore.js
More file actions
111 lines (110 loc) · 3.32 KB
/
IDBStore.js
File metadata and controls
111 lines (110 loc) · 3.32 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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
/**
* @license
* Copyright 2015 The Emscripten Authors
* SPDX-License-Identifier: MIT
*/
var IDBStore = {
indexedDB() {
if (typeof indexedDB != 'undefined') return indexedDB;
var ret = null;
if (typeof window == 'object') ret = window.indexedDB || window.mozIndexedDB || window.webkitIndexedDB || window.msIndexedDB;
assert(ret, 'IDBStore used, but indexedDB not supported');
return ret;
},
DB_VERSION: 22,
DB_STORE_NAME: 'FILE_DATA',
dbs: {},
blobs: [0],
getDB(name, callback) {
// check the cache first
var db = IDBStore.dbs[name];
if (db) {
return callback(null, db);
}
var req;
try {
req = IDBStore.indexedDB().open(name, IDBStore.DB_VERSION);
} catch (e) {
return callback(e);
}
req.onupgradeneeded = (e) => {
var db = /** @type {IDBDatabase} */ (e.target.result);
var transaction = e.target.transaction;
var fileStore;
if (db.objectStoreNames.contains(IDBStore.DB_STORE_NAME)) {
fileStore = transaction.objectStore(IDBStore.DB_STORE_NAME);
} else {
fileStore = db.createObjectStore(IDBStore.DB_STORE_NAME);
}
};
req.onsuccess = () => {
db = /** @type {IDBDatabase} */ (req.result);
// add to the cache
IDBStore.dbs[name] = db;
callback(null, db);
};
req.onerror = function(event) {
callback(event.target.error || 'unknown error');
event.preventDefault();
};
},
getStore(dbName, type, callback) {
IDBStore.getDB(dbName, (error, db) => {
if (error) return callback(error);
var transaction = db.transaction([IDBStore.DB_STORE_NAME], type);
transaction.onerror = (event) => {
callback(event.target.error || 'unknown error');
event.preventDefault();
};
var store = transaction.objectStore(IDBStore.DB_STORE_NAME);
callback(null, store);
});
},
// External API
getFile(dbName, id, callback) {
IDBStore.getStore(dbName, 'readonly', (err, store) => {
if (err) return callback(err);
var req = store.get(id);
req.onsuccess = (event) => {
var result = event.target.result;
if (!result) {
return callback(`file ${id} not found`);
}
return callback(null, result);
};
req.onerror = callback;
});
},
setFile(dbName, id, data, callback) {
IDBStore.getStore(dbName, 'readwrite', (err, store) => {
if (err) return callback(err);
var req = store.put(data, id);
req.onsuccess = (event) => callback();
req.onerror = callback;
});
},
deleteFile(dbName, id, callback) {
IDBStore.getStore(dbName, 'readwrite', (err, store) => {
if (err) return callback(err);
var req = store.delete(id);
req.onsuccess = (event) => callback();
req.onerror = callback;
});
},
existsFile(dbName, id, callback) {
IDBStore.getStore(dbName, 'readonly', (err, store) => {
if (err) return callback(err);
var req = store.count(id);
req.onsuccess = (event) => callback(null, event.target.result > 0);
req.onerror = callback;
});
},
clearStore(dbName, callback) {
IDBStore.getStore(dbName, 'readwrite', (err, store) => {
if (err) return callback(err);
var req = store.clear();
req.onsuccess = (event) => callback();
req.onerror = callback;
});
},
};