| mergeInto(LibraryManager.library, { |
| $IDBFS__deps: ['$FS', '$MEMFS', '$PATH'], |
| $IDBFS: { |
| dbs: {}, |
| indexedDB: function() { |
| if (typeof indexedDB !== 'undefined') return indexedDB; |
| var ret = null; |
| if (typeof window === 'object') ret = window.indexedDB || window.mozIndexedDB || window.webkitIndexedDB || window.msIndexedDB; |
| assert(ret, 'IDBFS used, but indexedDB not supported'); |
| return ret; |
| }, |
| DB_VERSION: 21, |
| DB_STORE_NAME: 'FILE_DATA', |
| mount: function(mount) { |
| // reuse all of the core MEMFS functionality |
| return MEMFS.mount.apply(null, arguments); |
| }, |
| syncfs: function(mount, populate, callback) { |
| IDBFS.getLocalSet(mount, function(err, local) { |
| if (err) return callback(err); |
| |
| IDBFS.getRemoteSet(mount, function(err, remote) { |
| if (err) return callback(err); |
| |
| var src = populate ? remote : local; |
| var dst = populate ? local : remote; |
| |
| IDBFS.reconcile(src, dst, callback); |
| }); |
| }); |
| }, |
| getDB: function(name, callback) { |
| // check the cache first |
| var db = IDBFS.dbs[name]; |
| if (db) { |
| return callback(null, db); |
| } |
| |
| var req; |
| try { |
| req = IDBFS.indexedDB().open(name, IDBFS.DB_VERSION); |
| } catch (e) { |
| return callback(e); |
| } |
| if (!req) { |
| return callback("Unable to connect to IndexedDB"); |
| } |
| req.onupgradeneeded = function(e) { |
| var db = e.target.result; |
| var transaction = e.target.transaction; |
| |
| var fileStore; |
| |
| if (db.objectStoreNames.contains(IDBFS.DB_STORE_NAME)) { |
| fileStore = transaction.objectStore(IDBFS.DB_STORE_NAME); |
| } else { |
| fileStore = db.createObjectStore(IDBFS.DB_STORE_NAME); |
| } |
| |
| if (!fileStore.indexNames.contains('timestamp')) { |
| fileStore.createIndex('timestamp', 'timestamp', { unique: false }); |
| } |
| }; |
| req.onsuccess = function() { |
| db = req.result; |
| |
| // add to the cache |
| IDBFS.dbs[name] = db; |
| callback(null, db); |
| }; |
| req.onerror = function(e) { |
| callback(this.error); |
| e.preventDefault(); |
| }; |
| }, |
| getLocalSet: function(mount, callback) { |
| var entries = {}; |
| |
| function isRealDir(p) { |
| return p !== '.' && p !== '..'; |
| }; |
| function toAbsolute(root) { |
| return function(p) { |
| return PATH.join2(root, p); |
| } |
| }; |
| |
| var check = FS.readdir(mount.mountpoint).filter(isRealDir).map(toAbsolute(mount.mountpoint)); |
| |
| while (check.length) { |
| var path = check.pop(); |
| var stat; |
| |
| try { |
| stat = FS.stat(path); |
| } catch (e) { |
| return callback(e); |
| } |
| |
| if (FS.isDir(stat.mode)) { |
| check.push.apply(check, FS.readdir(path).filter(isRealDir).map(toAbsolute(path))); |
| } |
| |
| entries[path] = { timestamp: stat.mtime }; |
| } |
| |
| return callback(null, { type: 'local', entries: entries }); |
| }, |
| getRemoteSet: function(mount, callback) { |
| var entries = {}; |
| |
| IDBFS.getDB(mount.mountpoint, function(err, db) { |
| if (err) return callback(err); |
| |
| var transaction = db.transaction([IDBFS.DB_STORE_NAME], 'readonly'); |
| transaction.onerror = function(e) { |
| callback(this.error); |
| e.preventDefault(); |
| }; |
| |
| var store = transaction.objectStore(IDBFS.DB_STORE_NAME); |
| var index = store.index('timestamp'); |
| |
| index.openKeyCursor().onsuccess = function(event) { |
| var cursor = event.target.result; |
| |
| if (!cursor) { |
| return callback(null, { type: 'remote', db: db, entries: entries }); |
| } |
| |
| entries[cursor.primaryKey] = { timestamp: cursor.key }; |
| |
| cursor.continue(); |
| }; |
| }); |
| }, |
| loadLocalEntry: function(path, callback) { |
| var stat, node; |
| |
| try { |
| var lookup = FS.lookupPath(path); |
| node = lookup.node; |
| stat = FS.stat(path); |
| } catch (e) { |
| return callback(e); |
| } |
| |
| if (FS.isDir(stat.mode)) { |
| return callback(null, { timestamp: stat.mtime, mode: stat.mode }); |
| } else if (FS.isFile(stat.mode)) { |
| // Performance consideration: storing a normal JavaScript array to a IndexedDB is much slower than storing a typed array. |
| // Therefore always convert the file contents to a typed array first before writing the data to IndexedDB. |
| node.contents = MEMFS.getFileDataAsTypedArray(node); |
| return callback(null, { timestamp: stat.mtime, mode: stat.mode, contents: node.contents }); |
| } else { |
| return callback(new Error('node type not supported')); |
| } |
| }, |
| storeLocalEntry: function(path, entry, callback) { |
| try { |
| if (FS.isDir(entry.mode)) { |
| FS.mkdir(path, entry.mode); |
| } else if (FS.isFile(entry.mode)) { |
| FS.writeFile(path, entry.contents, { encoding: 'binary', canOwn: true }); |
| } else { |
| return callback(new Error('node type not supported')); |
| } |
| |
| FS.chmod(path, entry.mode); |
| FS.utime(path, entry.timestamp, entry.timestamp); |
| } catch (e) { |
| return callback(e); |
| } |
| |
| callback(null); |
| }, |
| removeLocalEntry: function(path, callback) { |
| try { |
| var lookup = FS.lookupPath(path); |
| var stat = FS.stat(path); |
| |
| if (FS.isDir(stat.mode)) { |
| FS.rmdir(path); |
| } else if (FS.isFile(stat.mode)) { |
| FS.unlink(path); |
| } |
| } catch (e) { |
| return callback(e); |
| } |
| |
| callback(null); |
| }, |
| loadRemoteEntry: function(store, path, callback) { |
| var req = store.get(path); |
| req.onsuccess = function(event) { callback(null, event.target.result); }; |
| req.onerror = function(e) { |
| callback(this.error); |
| e.preventDefault(); |
| }; |
| }, |
| storeRemoteEntry: function(store, path, entry, callback) { |
| var req = store.put(entry, path); |
| req.onsuccess = function() { callback(null); }; |
| req.onerror = function(e) { |
| callback(this.error); |
| e.preventDefault(); |
| }; |
| }, |
| removeRemoteEntry: function(store, path, callback) { |
| var req = store.delete(path); |
| req.onsuccess = function() { callback(null); }; |
| req.onerror = function(e) { |
| callback(this.error); |
| e.preventDefault(); |
| }; |
| }, |
| reconcile: function(src, dst, callback) { |
| var total = 0; |
| |
| var create = []; |
| Object.keys(src.entries).forEach(function (key) { |
| var e = src.entries[key]; |
| var e2 = dst.entries[key]; |
| if (!e2 || e.timestamp > e2.timestamp) { |
| create.push(key); |
| total++; |
| } |
| }); |
| |
| var remove = []; |
| Object.keys(dst.entries).forEach(function (key) { |
| var e = dst.entries[key]; |
| var e2 = src.entries[key]; |
| if (!e2) { |
| remove.push(key); |
| total++; |
| } |
| }); |
| |
| if (!total) { |
| return callback(null); |
| } |
| |
| var errored = false; |
| var completed = 0; |
| var db = src.type === 'remote' ? src.db : dst.db; |
| var transaction = db.transaction([IDBFS.DB_STORE_NAME], 'readwrite'); |
| var store = transaction.objectStore(IDBFS.DB_STORE_NAME); |
| |
| function done(err) { |
| if (err) { |
| if (!done.errored) { |
| done.errored = true; |
| return callback(err); |
| } |
| return; |
| } |
| if (++completed >= total) { |
| return callback(null); |
| } |
| }; |
| |
| transaction.onerror = function(e) { |
| done(this.error); |
| e.preventDefault(); |
| }; |
| |
| // sort paths in ascending order so directory entries are created |
| // before the files inside them |
| create.sort().forEach(function (path) { |
| if (dst.type === 'local') { |
| IDBFS.loadRemoteEntry(store, path, function (err, entry) { |
| if (err) return done(err); |
| IDBFS.storeLocalEntry(path, entry, done); |
| }); |
| } else { |
| IDBFS.loadLocalEntry(path, function (err, entry) { |
| if (err) return done(err); |
| IDBFS.storeRemoteEntry(store, path, entry, done); |
| }); |
| } |
| }); |
| |
| // sort paths in descending order so files are deleted before their |
| // parent directories |
| remove.sort().reverse().forEach(function(path) { |
| if (dst.type === 'local') { |
| IDBFS.removeLocalEntry(path, done); |
| } else { |
| IDBFS.removeRemoteEntry(store, path, done); |
| } |
| }); |
| } |
| } |
| }); |