fix: connection

Author: Elin Angelow

lib/postgres/index.js

@@ -6,22 +6,29 @@ const SqlWe = (() => (class Sql extends WError {}))();
 
 const predefinedSql = require('./sqls/index.js')();
 
-const conn = (() => {
-    let connection;
+const connectionPool = (log) => {
+    let pool;
     return async(config) => {
-        if (connection === undefined) {
-            connection = new Pool(config);
-            return connection;
+        if (pool === undefined) {
+            pool = new Pool(config);
+            pool.on('error', (e) => log('error', 'expose.sql.methods', e));
+            return pool;
         }
-        return connection;
+        return pool;
     };
-})();
+};
 
 
-module.exports = async(config) => {
+module.exports = async(
+    config,
+    {log = () => {}}
+) => {
     const {link: {gluePrefix = '.', schemas: sc} = {}} = config;
     const schemas = sc instanceof Array ? sc : [sc];
-    const link = await conn(config.connection);
+    const link = await connectionPool(log)(
+        config.connection,
+        {log}
+    );
     const txMap = new Map();
     let txId = 0;