| 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; |