'use strict';

const { Pool } = require('pg');

module.exports = {
  verifyDatabase: verifyDatabase
};

async function verifyDatabase (db) {
  const pool = new Pool({
    user: 'postgres',
    host: '127.0.0.1',
    database: 'postgres',
    password: 'postgres',
    port: '5432'
  });

  const { rows } = await pool.query(`SELECT count(*) > 0 as exist FROM pg_catalog.pg_database WHERE datname = '${db}'`);

  if (!rows[0].exist) {
    await pool.query(`CREATE DATABASE "${db}"`);
    pool.end();
  } else {
    pool.end();
  }
}