import asyncio
import os
from datetime import datetime
import asyncpg

DB_HOST = os.getenv('DB_HOST', 'localhost')
DB_PORT = int(os.getenv('DB_PORT', 5432))
DB_NAME = os.getenv('DB_NAME', 'btc_data')
DB_USER = os.getenv('DB_USER', 'btc_bot')
DB_PASSWORD = os.getenv('DB_PASSWORD', '')

async def check_data():
    conn = await asyncpg.connect(
        host=DB_HOST,
        port=DB_PORT,
        database=DB_NAME,
        user=DB_USER,
        password=DB_PASSWORD
    )
    
    try:
        print("Checking candle counts...")
        rows = await conn.fetch("""
            SELECT interval, COUNT(*), MIN(time), MAX(time)
            FROM candles
            GROUP BY interval
            ORDER BY interval
        """)
        
        for row in rows:
            print(f"Interval: {row['interval']}")
            print(f"  Count: {row['count']}")
            print(f"  Min Time: {row['min']}")
            print(f"  Max Time: {row['max']}")
            print("-" * 20)
            
    finally:
        await conn.close()

if __name__ == "__main__":
    asyncio.run(check_data())