const db = require('./db')

// Get all blacklist rows from the DB "blacklist" table that were manually inserted by the operator
const getBlacklist = () => {
  return db.any(`SELECT * FROM blacklist WHERE created_by_operator = 't'`).then(res =>
    res.map(item => ({
      cryptoCode: item.crypto_code,
      address: item.address,
      createdByOperator: item.created_by_operator
    }))
  )
}

// Delete row from blacklist table by crypto code and address
const deleteFromBlacklist = (cryptoCode, address) => {
  return db.none(
    `DELETE FROM blacklist WHERE created_by_operator = 't' AND crypto_code = $1 AND address = $2`,
    [cryptoCode, address]
  )
}

const insertIntoBlacklist = (cryptoCode, address) => {
  return db
    .none(
      'insert into blacklist(crypto_code, address, created_by_operator) values($1, $2, $3);',
      [cryptoCode, address, true]
    )
}

function blocked(address, cryptoCode) {
  const sql = `select * from blacklist where address = $1 and crypto_code = $2`
  return db.any(sql, [address, cryptoCode])
}

function addToUsedAddresses(address, cryptoCode) {
  // ETH reuses addresses
  if (cryptoCode === 'ETH') return Promise.resolve()

  const sql = `insert into blacklist(crypto_code, address, created_by_operator) values ($1, $2, 'f')`
  return db.oneOrNone(sql, [cryptoCode, address])
}

module.exports = {
  blocked,
  addToUsedAddresses,
  getBlacklist,
  deleteFromBlacklist,
  insertIntoBlacklist
}