fix: logger

Author: Elin Angelow

lib/postgres/index.js

@@ -24,7 +24,7 @@ module.exports = async(
     {log = () => {}}
 ) => {
     const {link: {gluePrefix = '.', schemas: sc} = {}} = config;
-    const schemas = sc instanceof Array ? sc : [sc];
+    const schemas = Array.isArray(sc) ? sc : [sc];
     const link = await connectionPool(log)(
         config.connection,
         {log}
@@ -117,13 +117,13 @@ module.exports = async(
                     ...methods,
                     /**
                      * Description
-                     * @param {Object} arguments
+                     * @param {Object} args
                      * @param {number} txId
                      * @returns {any}
                      */
-                    [jsName]: async(arguments = {}, txId) => {
+                    [jsName]: async(args = {}, txId) => {
                         const dynArgs = args.input.map(({name}) => {
-                            if (arguments[name] === undefined) {
+                            if (args[name] === undefined) {
                                 if (oArgNames[name]!==undefined) {
                                     return oArgNames[name];
                                 }
@@ -132,7 +132,7 @@ module.exports = async(
                                     {fn: jsName, argument: name}
                                 );
                             }
-                            return arguments[name];
+                            return args[name];
                         });
                         try {
                             if (!txId) {
@@ -165,11 +165,16 @@ module.exports = async(
          * @returns {number}
          */
         async txBegin() {
-            const id = ++txId;
-            const client = await link.connect();
-            await client.query('BEGIN');
-            txMap.set(id, client);
-            return id;
+            try {
+                const id = ++txId;
+                const client = await link.connect();
+                await client.query('BEGIN');
+                txMap.set(id, client);
+                return id;
+            } catch (e) {
+                log('error', `TX Begin: id: ${id}`, e);
+                throw e;
+            }
         },
         /**
          * Description
@@ -178,10 +183,15 @@ module.exports = async(
          * @returns {void}
          */
         async txEnd(id, action) {
-            const client = txMap.get(id);
-            await client.query(action);
-            client.release();
-            txMap.delete(id);
+            try {
+                const client = txMap.get(id);
+                await client.query(action);
+                client.release();
+                txMap.delete(id);
+            } catch (e) {
+                log('error', `TX End: id: ${id}`, e);
+                throw e;
+            }
         }
     };
 };