import {

  type Sql,

} from "https://deno.land/x/windmill@v1.88.1/mod.ts";

import { Client } from "https://deno.land/x/postgres@v0.17.0/mod.ts"

type Postgresql = {

  host: string;

  port: number;

  user: string;

  dbname: string;

  sslmode: string;

  password: string;

};

export async function main(db: Postgresql, query: Sql = "SELECT * FROM demo;") {

  if (!query) {

    throw Error("Query must not be empty.");

  }

  const { rows } = await pgClient(db).queryObject(query);

  return rows;

}

export function pgClient(db: any) {    

  let db2 = {

    ...db,

    hostname: db.host,

    database: db.dbname,

    tls: {

        enabled: false,

    },

  }

  return new Client(db2)

}