import { Pool } from 'pg';
import 'dotenv/config';

const poolCreds = {
  host: process.env.POSTGRES_HOST,
  database: process.env.POSTGRES_DB_PARAMYXRX,
  port: process.env.POSTGRES_PORT,
  user: process.env.POSTGRES_USER,
  password: process.env.POSTGRES_PASSWORD
};

const pool = new Pool(poolCreds);

export const paramyxRunQuery = async (query, params = []) => {
  const client = await pool.connect();

  try {
    const pgQueryResponse = await client.query(query, params);
    return pgQueryResponse?.rows || [];
  } finally {
    client.release();
  }
}