web/cryptpad
2
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

I'm an idiot - killer off-by-one ate the storage

Browse Source
This commit is contained in:
Caleb James DeLisle 2016-02-11 16:55:26 +01:00
parent 943a291903
commit 13360c335b
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
storage/lvl.js
View File

@ -3,19 +3,27 @@ var nThen = require('nthen');
var getIndex = function(db, cName, cb) { var getIndex = function(db, cName, cb) {
db.get(cName+'=>index', function(e, out){ db.get(cName+'=>index', function(e, out){
if (e && !e.notFound) { throw e; } if (e) {
cb(parseInt(out || 0)); if (e.notFound) {
cb(-1);
} else {
throw e;
}
return;
}
cb(parseInt(out));
}); });
}; };
var insert = function (db, channelName, content, cb) { var insert = function (db, channelName, content, cb) {
var index; var index;
nThen(function (waitFor) { nThen(function (waitFor) {
getIndex(db, channelName, waitFor(function (i) { index = i; })); getIndex(db, channelName, waitFor(function (i) { index = i+1; }));
}).nThen(function (waitFor) {
db.put(channelName+'=>index', ''+index, waitFor(function (e) { if (e) { throw e; } }));
}).nThen(function (waitFor) { }).nThen(function (waitFor) {
db.put(channelName+'=>'+index, content, waitFor(function (e) { if (e) { throw e; } })); db.put(channelName+'=>'+index, content, waitFor(function (e) { if (e) { throw e; } }));
}).nThen(function (waitFor) {
db.put(channelName+'=>index', ''+index, waitFor(function (e) { if (e) { throw e; } }));
console.log(index);
}).nThen(cb); }).nThen(cb);
}; };