import { config } from '../src/config/config.js';
import dbManager from '../src/db/databaseManager.js';
import { logger } from '../src/utils/logger.js';

const verifyData = async () => {
  const client = await dbManager.pool.connect();
  try {
    console.log('Verifying data in database...');
    
    // Count total rows
    const countSql = `SELECT count(*) FROM ${config.db.schema}.${config.db.table}`;
    const countRes = await client.query(countSql);
    console.log(`Total rows in ${config.db.schema}.${config.db.table}: ${countRes.rows[0].count}`);

    // Check recent rows
    const recentSql = `
      SELECT * FROM ${config.db.schema}.${config.db.table}
      ORDER BY ts_ms DESC
      LIMIT 5
    `;
    const recentRes = await client.query(recentSql);
    console.log('Recent 5 rows:');
    recentRes.rows.forEach(row => {
      console.log(JSON.stringify(row));
    });

  } catch (err) {
    console.error('Error verifying data:', err);
  } finally {
    client.release();
    await dbManager.pool.end();
  }
};

verifyData();