Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code

Unified Diff: lib/adblockplus.js

Issue 29355962: Issue 4023 - Use localforage (IndexedDB) instead of localStorage (Closed)
Patch Set: Don't call both successCallback and errorCallback Created Oct. 11, 2016, 1:50 p.m.
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « background.html ('k') | qunit/index.html » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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;
« no previous file with comments | « background.html ('k') | qunit/index.html » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld