Index: lib/adblockplus.js |
=================================================================== |
--- a/lib/adblockplus.js |
+++ b/lib/adblockplus.js |
@@ -357,60 +357,45 @@ |
return keyPrefix + (file instanceof FakeFile ? file.path : file.spec); |
} |
- function loadFile(file) |
- { |
- return new Promise(function(resolve, reject) |
- { |
- var key = fileToKey(file); |
- ext.storage.get([key], function(items) |
- { |
- var entry = items[key]; |
- if (!entry) |
- { |
- try |
- { |
- entry = JSON.parse(window.localStorage.getItem(key)); |
- } |
- catch (err) |
- {} |
- } |
- if (entry) |
- { |
- resolve(entry); |
- } |
- else |
- { |
- reject(new Error("File doesn't exist")); |
- } |
- }); |
- }.bind(this)); |
+ function loadFile(file, successCallback, errorCallback) |
+ { |
+ var key = fileToKey(file); |
+ // Make sure we do not have subscriptions in localStorage from older versions first |
+ var entry = localStorage.getItem(key); |
+ if (typeof entry == "string") |
+ { |
+ try |
+ { |
+ entry = JSON.parse(entry); |
+ } |
+ catch(err) |
+ { |
+ setTimeout(errorCallback(new Error("File is corrupted"))); |
+ return; |
+ } |
+ setTimeout(successCallback(entry)); |
+ return; |
+ } |
+ // Now try to read from IndexedDB |
+ localforage.getItem(key, function(err, value) |
+ { |
+ if (err || !value) |
+ errorCallback(new Error("File doesn't exist")); |
+ else |
+ successCallback(value); |
+ }); |
} |
+ |
function saveFile(file, data, callback) |
{ |
- var entry = {}; |
var key = fileToKey(file); |
+ var entry = { |
+ lastModified: Date.now(), |
+ content: data |
+ }; |
- if (typeof browser == "undefined") |
- { |
- entry[key] = { |
- lastModified: Date.now(), |
- content: data |
- }; |
- ext.storage.set(entry, callback); |
- } |
- else |
- { |
- var processedData = LZString.compressToUTF16(JSON.stringify(data)); |
- ext.storage.remove(key); |
- entry[key] = { |
- lastModified: Date.now(), |
- content: processedData, |
- compressed: true |
- }; |
- window.localStorage.setItem(key, JSON.stringify(entry[key])); |
- setTimeout(callback, 0); |
- } |
- callback(); |
+ localStorage.removeItem(key); |
+ localforage.setItem(key, entry, callback); |
} |
exports.IO = { |
resolveFilePath: function(path) |
@@ -423,10 +408,6 @@ |
{ |
if ("content" in entry) |
{ |
- if (entry["compressed"]) |
- { |
- entry.content = JSON.parse(LZString.decompressFromUTF16(entry.content)); |
- } |
for (var _loopIndex15 = 0; _loopIndex15 < entry.content.length; ++_loopIndex15) |
{ |
var line = entry.content[_loopIndex15]; |
@@ -435,7 +416,7 @@ |
} |
callback(null); |
} |
- loadFile(file).then(onLoaded, callback); |
+ loadFile(file, onLoaded, callback); |
}, |
writeToFile: function(file, data, callback) |
{ |
@@ -447,7 +428,7 @@ |
{ |
saveFile(toFile, entry.content, callback); |
} |
- loadFile(file).then(onLoaded, callback); |
+ loadFile(file, onLoaded, callback); |
}, |
renameFile: function(fromFile, newName, callback) |
{ |
@@ -458,7 +439,7 @@ |
ext.storage.set(keyPrefix + newName, entry, callback); |
}); |
} |
- loadFile(file).then(onLoaded, callback); |
+ loadFile(file, onLoaded, callback); |
}, |
removeFile: function(file, callback) |
{ |
@@ -474,7 +455,7 @@ |
lastModified: entry.lastModified |
}); |
} |
- loadFile(file).then(onLoaded, callback); |
+ loadFile(file, onLoaded, callback); |
} |
}; |
return exports; |