In case there is an error parsing one of the messages in a file, catch rather than blowing up

pull/1/head
Caleb James DeLisle 7 years ago
parent ee605183e5
commit f3167964f4

@ -257,24 +257,23 @@ var getMessages = function (env, chanName, handler, cb) {
return;
}
var errorState = false;
try {
readMessages(chan.path, function (msg) {
if (!msg || errorState) { return; }
//console.log(msg);
readMessages(chan.path, function (msg) {
if (!msg || errorState) { return; }
//console.log(msg);
try {
handler(msg);
}, function (err) {
if (err) {
errorState = true;
return void cb(err);
}
chan.atime = +new Date();
cb();
});
} catch (err2) {
console.error(err2);
cb(err2);
return;
}
} catch (e) {
errorState = true;
return void cb(err);
}
}, function (err) {
if (err) {
errorState = true;
return void cb(err);
}
chan.atime = +new Date();
cb();
});
});
};

Loading…
Cancel
Save