#!/usr/bin/env tsx
/**
 * Verification script for J2 deliverables
 * Creates a temporary test database, runs migrations and seed, then cleans up
 */

import { Pool } from 'pg';
import { drizzle } from 'drizzle-orm/node-postgres';
import { migrate } from 'drizzle-orm/node-postgres/migrator';
import { agents, rooms, roomMembers } from '../src/db/schema.js';

const POSTGRES_PORT = Number(process.env.POSTGRES_PORT) || 54329;
const POSTGRES_USER = process.env.POSTGRES_USER || 'alexandre'; // embedded-postgres uses system user
const POSTGRES_PASSWORD = process.env.POSTGRES_PASSWORD || ''; // embedded-postgres no password
const TEST_DB = 'agenthub_test';

async function main() {
  console.log('[verify-j2] Starting J2 verification...\n');
  console.log(`[verify-j2] Using Postgres on port ${POSTGRES_PORT} (user: ${POSTGRES_USER})\n`);

  // Step 1: Connect to default postgres DB to create test database
  const adminPool = new Pool({
    host: 'localhost',
    port: POSTGRES_PORT,
    user: POSTGRES_USER,
    password: POSTGRES_PASSWORD,
    database: 'postgres',
  });

  try {
    console.log(`[verify-j2] Creating test database "${TEST_DB}"...`);

    // Drop if exists, then create
    await adminPool.query(`DROP DATABASE IF EXISTS ${TEST_DB}`);
    await adminPool.query(`CREATE DATABASE ${TEST_DB}`);

    console.log('[verify-j2] ✓ Test database created\n');
  } catch (error) {
    console.error('[verify-j2] ✗ Failed to create test database:', error);
    process.exit(1);
  } finally {
    await adminPool.end();
  }

  // Step 2: Connect to test database and run migrations
  const testPool = new Pool({
    host: 'localhost',
    port: POSTGRES_PORT,
    user: POSTGRES_USER,
    password: POSTGRES_PASSWORD,
    database: TEST_DB,
  });

  testPool.on('connect', (client) => {
    client.query("SET TIME ZONE 'UTC'");
  });

  const db = drizzle(testPool);

  try {
    console.log('[verify-j2] Running migrations...');
    await migrate(db, { migrationsFolder: './drizzle' });
    console.log('[verify-j2] ✓ Migrations applied\n');

    // Step 3: Run seed
    console.log('[verify-j2] Running seed...');

    const { v7: uuidv7 } = await import('uuid');

    const aliceId = uuidv7();
    const bobId = uuidv7();
    const cliId = uuidv7();

    await db.insert(agents).values([
      {
        id: aliceId,
        name: 'alice',
        displayName: 'Alice (Admin)',
        role: 'admin',
      },
      {
        id: bobId,
        name: 'bob',
        displayName: 'Bob (Agent)',
        role: 'agent',
      },
      {
        id: cliId,
        name: 'cli',
        displayName: 'CLI Bot',
        role: 'agent',
      },
    ]);

    const generalId = uuidv7();
    const incidentsId = uuidv7();

    await db.insert(rooms).values([
      {
        id: generalId,
        slug: 'general',
        name: 'General Discussion',
        createdBy: aliceId,
      },
      {
        id: incidentsId,
        slug: 'incidents',
        name: 'Incident Response',
        createdBy: aliceId,
      },
    ]);

    await db.insert(roomMembers).values([
      { roomId: generalId, agentId: aliceId },
      { roomId: generalId, agentId: bobId },
      { roomId: generalId, agentId: cliId },
      { roomId: incidentsId, agentId: aliceId },
      { roomId: incidentsId, agentId: bobId },
    ]);

    console.log('[verify-j2] ✓ Seed completed\n');

    // Step 4: Verify data
    console.log('[verify-j2] Verifying seeded data...');

    const agentCount = await db.select().from(agents);
    const roomCount = await db.select().from(rooms);
    const memberCount = await db.select().from(roomMembers);

    console.log(`[verify-j2]   - Agents: ${agentCount.length} (expected 3)`);
    console.log(`[verify-j2]   - Rooms: ${roomCount.length} (expected 2)`);
    console.log(`[verify-j2]   - Room members: ${memberCount.length} (expected 5)`);

    if (agentCount.length === 3 && roomCount.length === 2 && memberCount.length === 5) {
      console.log('[verify-j2] ✓ Data verification passed\n');
    } else {
      throw new Error('Data verification failed: counts do not match expected values');
    }

  } catch (error) {
    console.error('[verify-j2] ✗ Verification failed:', error);
    await testPool.end();

    // Cleanup on failure
    const cleanupPool = new Pool({
      host: 'localhost',
      port: POSTGRES_PORT,
      user: POSTGRES_USER,
      password: POSTGRES_PASSWORD,
      database: 'postgres',
    });

    try {
      await cleanupPool.query(`DROP DATABASE IF EXISTS ${TEST_DB}`);
      console.log('[verify-j2] ✓ Test database cleaned up');
    } finally {
      await cleanupPool.end();
    }

    process.exit(1);
  }

  await testPool.end();

  // Step 5: Cleanup
  const cleanupPool = new Pool({
    host: 'localhost',
    port: POSTGRES_PORT,
    user: POSTGRES_USER,
    password: POSTGRES_PASSWORD,
    database: 'postgres',
  });

  try {
    console.log(`[verify-j2] Cleaning up test database...`);
    await cleanupPool.query(`DROP DATABASE IF EXISTS ${TEST_DB}`);
    console.log('[verify-j2] ✓ Test database cleaned up\n');
  } catch (error) {
    console.error('[verify-j2] ⚠ Cleanup warning:', error);
  } finally {
    await cleanupPool.end();
  }

  console.log('╔════════════════════════════════════════════════════════╗');
  console.log('║  ✅ J2 Verification PASSED                            ║');
  console.log('║                                                        ║');
  console.log('║  All deliverables verified:                           ║');
  console.log('║  - Postgres schema (6 tables)                         ║');
  console.log('║  - Drizzle migrations                                 ║');
  console.log('║  - Seed script (3 agents + 2 rooms)                   ║');
  console.log('╚════════════════════════════════════════════════════════╝');
}

main();