vitalif
/
likeopera-backend
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Pass catched exceptions, fix error in addMessage

master
Vitaliy Filippov 2016-07-25 16:13:23 +03:00
parent fda15026d6
commit 4b52453e47
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
operetta.js
View File

@ -148,7 +148,7 @@ Syncer.runFetch = function*(what, params, boxId, processor)
var cb, wait; var cb, wait;
f.on('message', function(msg, seqnum) f.on('message', function(msg, seqnum)
{ {
gen.run(self.onMessage(msg, seqnum, boxId, processor), checkFinish, checkFinish); gen.run(self.onMessage(msg, seqnum, boxId, processor), checkFinish, function(e) { checkFinish(); throw e; });
}); });
cb = gen.cb(); cb = gen.cb();
@ -158,7 +158,7 @@ Syncer.runFetch = function*(what, params, boxId, processor)
if (self.parsed <= 0) if (self.parsed <= 0)
cb(); cb();
else if (self.pending.length > 0) else if (self.pending.length > 0)
gen.run(self[processor](self.pending, boxId), saveLast, saveLast); gen.run(self[processor](self.pending, boxId), saveLast, function(e) { saveLast(); throw e; });
}); });
function saveLast() function saveLast()
@ -280,6 +280,7 @@ Syncer.saveMessages = function*(messages, boxId)
Syncer.addMessage = function*(msgrow, attrs) Syncer.addMessage = function*(msgrow, attrs)
{ {
var self = this;
var pgtx, end_transaction; var pgtx, end_transaction;
try try
{ {