'use strict';

const db = require('../src/infra/db');

async function hasColumn(table, column) {
  const rows = await db.query(
    `SELECT 1 FROM information_schema.columns
      WHERE table_schema = DATABASE() AND table_name = ? AND column_name = ? LIMIT 1`,
    [table, column],
  );
  return rows.length > 0;
}

async function main() {
  if (await hasColumn('performance_assessments', 'reward_amount')) {
    console.log('reward_amount already exists');
    return;
  }
  await db.execute(
    `ALTER TABLE performance_assessments
       ADD COLUMN reward_amount DECIMAL(12,2) NULL AFTER performance_points`,
  );
  console.log('added performance_assessments.reward_amount');
}

main()
  .then(() => process.exit(0))
  .catch((error) => {
    console.error(error);
    process.exit(1);
  });