From c34a9b96e4e1c43b9b041c68a7312a3770292141 Mon Sep 17 00:00:00 2001
From: zadam <adam.zivner@gmail.com>
Date: Sun, 21 Jun 2020 13:33:56 +0200
Subject: [PATCH] further simplification - now using better-sqlite3 native
 transaction API

---
 src/services/sql.js | 24 +++---------------------
 1 file changed, 3 insertions(+), 21 deletions(-)

diff --git a/src/services/sql.js b/src/services/sql.js
index cdd1a2955..1b997ab7c 100644
--- a/src/services/sql.js
+++ b/src/services/sql.js
@@ -211,29 +211,11 @@ function wrap(query, func) {
 }
 
 function transactional(func) {
-    if (dbConnection.inTransaction) {
-        return func();
-    }
+    const ret = dbConnection.transaction(func).deferred();
 
-    try {
-        beginTransaction();
+    require('./ws.js').sendPingToAllClients();
 
-        const ret = func();
-
-        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;
-    }
+    return ret;
 }
 
 module.exports = {