import { Pool } from 'pg';
import 'dotenv/config';

if (!process.env.DB_URL) throw new Error('DB_URL is required');

const pool = new Pool({
  connectionString: process.env.DB_URL,
  ssl: { rejectUnauthorized: false },
});

try {
  // เปลี่ยน otp_code จาก VARCHAR(6) เป็น TEXT เพื่อเก็บ token จาก ThaiBulkSMS
  await pool.query(`ALTER TABLE simo_otps ALTER COLUMN otp_code TYPE TEXT`);
  console.log('✅ Migration v4: simo_otps.otp_code เปลี่ยนเป็น TEXT สำหรับ ThaiBulkSMS token');
} catch (e) {
  console.error('❌ Migration v4 failed:', e);
  process.exit(1);
} finally {
  await pool.end();
}