further simplification - now using better-sqlite3 native transaction API

This commit is contained in:
zadam 2020-06-21 13:33:56 +02:00
parent f0acfaf147
commit c34a9b96e4

View File

@ -211,29 +211,11 @@ function wrap(query, func) {
} }
function transactional(func) { function transactional(func) {
if (dbConnection.inTransaction) { const ret = dbConnection.transaction(func).deferred();
return func();
}
try { require('./ws.js').sendPingToAllClients();
beginTransaction();
const ret = func(); return ret;
commit();
// note that sync rows sent from this action will be sent again by scheduled periodic ping
require('./ws.js').sendPingToAllClients();
return ret;
}
catch (e) {
if (dbConnection.inTransaction) {
rollback();
}
throw e;
}
} }
module.exports = { module.exports = {