more tracelogging

1 files changed, 1 insertions, 0 deletions

diff --git a/backend/node/src/clipperz.js b/backend/node/src/clipperz.js
index b8b4d3e..04b054a 100644
--- a/backend/node/src/clipperz.js
+++ b/backend/node/src/clipperz.js
@@ -47,64 +47,65 @@ function clipperz_store(PG) {
 
 var srp_g = BIGNUM(2);
 var srp_n = BIGNUM("115b8b692e0e045692cf280b436735c77a5a9e8a9e7ed56c965f87db5b2a2ece3",16);
 var n123 = '112233445566778899aabbccddeeff00112233445566778899aabbccddeeff00';
 
 
 var CLIPPERZ = module.exports = function(CONFIG) {
 
  var LOGGER = CONFIG.logger||{trace:function(){}};
 
  var PG = {
   url: CONFIG.psql,
   PG: require('pg').native,
   Q: function(q,a,cb) {
    if('function'===typeof a) cb=a,a=[];
    LOGGER.trace({query:q,args:a},'SQL: %s',q);
    PG.PG.connect(PG.url,function(e,C,D) {
         if(e) return cb(e);
         var t0=new Date();
         C.query(q,a,function(e,r) {
          var t1=new Date(), dt=t1-t0;
          D();
          LOGGER.trace({query:q,args:a,ms:dt,rows:r&&r.rowCount,err:e},"SQL query '%s' took %dms",q,dt);
          cb(e,r);
         });
    });
   },
   T: function(cb) {
    PG.PG.connect(PG.url,function(e,C,D) {
         if(e) return cb(e);
         C.query('BEGIN',function(e){
          if(e) return D(),cb(e);
+         LOGGER.trace('SQL: transaction begun');
          cb(null,{
           Q: function(q,a,cb) {
            LOGGER.trace({query:q,args:a},'SQL: %s',q);
            if(this.over) return cb(new Error('game over'));
            if('function'===typeof a) cb=a,a=[];
            var t0=new Date();
            C.query(q,a,function(e,r) {
                 var t1=new Date(), dt=t1-t0;
                 LOGGER.trace({query:q,args:a,ms:dt,rows:r&&r.rowCount,err:e},"SQL query '%s' took %dms",q,dt);
                 cb(e,r);
            });
           },
           commit: function(cb) {
            LOGGER.trace('SQL: commit');
            if(this.over) return cb(new Error('game over'));
            return (this.over=true),C.query('COMMIT',function(e){D();cb&&cb(e)});
           },
           rollback: function(cb) {
            LOGGER.trace('SQL: rollback');
            if(this.over) return cb(new Error('game over'));
            return (this.over=true),C.query('ROLLBACK',function(e){D();cb&&cb(e)});
           },
           end: function(e,cb) {
            if(e) return LOGGER.trace(e,"rolling back transaction due to an error"),this.rollback(cb);
            this.commit(cb);
           }
          });
         });
    });
   }
  };