const { Client } = require("pg")

const DATASOURCE_CONFIG = {
  host: {
    type: "string",
    default: "localhost",
    required: true,
  },
  port: {
    type: "number",
    required: true,
    default: 5432,
  },
  database: {
    type: "string",
    default: "postgres",
    required: true,
  },
  username: {
    type: "string",
    default: "root",
    required: true,
  },
  password: {
    type: "password",
    default: "root",
    required: true,
  },
}

const QUERY_CONFIG = {
  sql: {
    type: "sql",
  },
  gui: {
    type: "config",
    fields: {
      something: "",
      other: "",
    },
  },
}

class PostgresIntegration {
  constructor(config, query) {
    this.config = config
    this.queryString = this.buildQuery(query)
    this.client = new Client(config)
    this.connect()
  }

  buildQuery(query) {
    // TODO: account for different types
    return query
  }

  async connect() {
    return this.client.connect()
  }

  async query() {
    const response = await this.client.query(this.queryString)
    return response.rows
  }
}

module.exports = {
  schema: {
    datasource: DATASOURCE_CONFIG,
    query: QUERY_CONFIG,
  },
  integration: PostgresIntegration,
}