import { createPostgresPool } from './src/lib/postgres.mjs';

async function main() {
  const pool = createPostgresPool({ connectionString: process.env.POSTGRES_URL });
  const inventoryRows = await pool.query(`
    SELECT event_id as inventory_id, observed_at, payload
    FROM intent_inventory_snapshots
    ORDER BY COALESCE(observed_at, ingested_at) DESC
    LIMIT 1
  `);
  console.log("Most recent snapshot:", inventoryRows.rows[0].observed_at);
  process.exit(0);
}
main().catch(console.error);