fix bug where empty channels failed
This commit is contained in:
parent
80fb5e1e21
commit
d576fdc886
@ -41,7 +41,9 @@ var insert = function (db, channelName, content, cb) {
|
|||||||
var getMessages = function (db, channelName, msgHandler, cb) {
|
var getMessages = function (db, channelName, msgHandler, 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;
|
||||||
|
}));
|
||||||
}).nThen(function (waitFor) {
|
}).nThen(function (waitFor) {
|
||||||
var again = function (i) {
|
var again = function (i) {
|
||||||
db.get(channelName + '=>' + i, waitFor(function (e, out) {
|
db.get(channelName + '=>' + i, waitFor(function (e, out) {
|
||||||
@ -52,6 +54,7 @@ var getMessages = function (db, channelName, msgHandler, cb) {
|
|||||||
}));
|
}));
|
||||||
};
|
};
|
||||||
if (index > -1) { again(0); }
|
if (index > -1) { again(0); }
|
||||||
|
else if (cb) { cb(); }
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user