/* eslint-disable */
const { Pool } = require('pg');

const pool = new Pool({
  connectionString: 'postgresql://jumpa_admin:JumpaS3cur3%21%40%23@localhost:5432/jumpadb'
});

async function runPatch() {
  try {
    console.log('Adding is_locked column to chat_statuses...');
    await pool.query(`ALTER TABLE chat_statuses ADD COLUMN IF NOT EXISTS is_locked boolean DEFAULT false NOT NULL`);
    console.log('chat_statuses patched.');

    console.log('Adding is_locked column to chat_broadcasts...');
    await pool.query(`ALTER TABLE chat_broadcasts ADD COLUMN IF NOT EXISTS is_locked boolean DEFAULT false NOT NULL`);
    console.log('chat_broadcasts patched.');

  } catch (error) {
    console.error('Error patching db:', error);
  } finally {
    await pool.end();
  }
}

runPatch();