/**
 * @file
 * Configures the database connection
 */

const { Pool, Client } = require('pg');
const url = require('url');
const logger = require('./logger');
//const connectionString = 'postgresql://wrenchboard:wrenchboard@10.10.10.23:5432/wrenchboard';
const connectionString = process.env.POSTGRE_URL.replace(/'/g, '');
const params = url.parse(connectionString);
const auth = params.auth.split(':');
const config = {
          user: auth[0],
          password: auth[1],
          host: params.hostname,
          port: params.port,
          database: params.pathname.split('/')[1],
          ssl: false
};

const postgres = new Pool(config);

postgres.on('connect', client => {
  logger.info('Connected to Database');
});

postgres.on('acquire', client => {
  logger.info('Client is checked out from the DB connection pool');
});

postgres.on('remove', client => {
  logger.info('Client is closed & removed from the DB connection pool');
});

postgres.on('error', (err, client) => {
  logger.error(err);
});

// Connect to PostgreSQL
postgres.connect((err, client, release) => {
  logger.info(connectionString);
  if (err) {
    logger.error('Error acquiring client', err.stack);
    return null;
  }
  client.query('SELECT NOW()', (err, result) => {
    release();
    if (err) {
      logger.error('Error executing query', err.stack);
      return nul;
    }
    logger.info(result.rows);
  });
});

module.exports = postgres;