import { GeneralService } from '../../share/generalservice.js'

export class BdgmstInterface {

  constructor() {
    this.general = new GeneralService()
    this.table = 'bdgmst'
    this.pk = ['bdgseq']
  }

  async saveInterface(database, data) {
    const method = data.methods.toLowerCase()
    const payload = { ...data }
    delete payload.method

    if (method === 'put') return this.update(database, payload)
    if (method === 'post') return this.insert(database, payload)
    if (method === 'delete') return this.remove(database, payload)

    throw new Error(`Unknown method: ${method}`)
  }

  async insert(database, payload) {
    const cols = Object.keys(payload)
    const vals = Object.values(payload)
    const placeholders = cols.map((_, i) => `$${i + 1}`).join(', ')

    const sql = `
      INSERT INTO ${database}.${this.table} (${cols.join(', ')})
      VALUES (${placeholders})
      RETURNING *
    `
    return await this.general.executeQueryParam(database, sql, vals)
  }

  async update(database, payload) {
    const where = {}
    const update = {}

    for (const col in payload) {
      if (this.pk.includes(col)) where[col] = payload[col]
      else update[col] = payload[col]
    }

    const setCols = Object.keys(update)
      .map((col, i) => `${col} = $${i + 1}`)
      .join(', ')

    const whereCols = Object.keys(where)
      .map((col, i) => `${col} = $${i + 1 + Object.keys(update).length}`)
      .join(' AND ')

    const params = [...Object.values(update), ...Object.values(where)]

    const sql = `
      UPDATE ${database}.${this.table}
      SET ${setCols}
      WHERE ${whereCols}
      RETURNING *
    `

    return await this.general.executeQueryParam(database, sql, params)
  }

  async remove(database, payload) {
    const where = {}
    this.pk.forEach(pk => {
      if (!payload[pk]) throw new Error(`Missing PK: ${pk}`)
      where[pk] = payload[pk]
    })

    const whereCols = Object.keys(where)
      .map((col, i) => `${col} = $${i + 1}`)
      .join(' AND ')

    const params = Object.values(where)

    const sql = `
      DELETE FROM ${database}.${this.table}
      WHERE ${whereCols}
      RETURNING *
    `

    return await this.general.executeQueryParam(database, sql, params)
  }
}