import asyncio
import aiohttp
import redis
import json
import logging
import time

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

# redis default port
redis_client = redis.Redis(host='localhost', port=6379, db=0)

URL = 'https://api.kraken.com/0/public/Ticker?pair=BTCUSD'
HEADERS = {'Accept': 'application/json'}

MAX_PRICES = 10
UPDATE_INTERVAL = 3  # seconds

async def fetch_btc_price(session):
    try:
        async with session.get(URL, headers=HEADERS, ssl=False) as response:
            data = await response.json()
            return float(data['result']['XXBTZUSD']['c'][0])
    except Exception as e:
        logger.error(f"error getting price: {e}")
        return None

async def update_price():
    async with aiohttp.ClientSession(connector=aiohttp.TCPConnector(ssl=False)) as session:
        while True:
            price = await fetch_btc_price(session)
            if price:
                timestamp = int(time.time())  # this is unix
                price_data = json.dumps({"price": price, "timestamp": timestamp})
                
                redis_client.lpush('btc_prices', price_data)
                
                redis_client.ltrim('btc_prices', 0, MAX_PRICES - 1)
                
                logger.info(f"updated btc price: ${price}")
                
                all_prices = redis_client.lrange('btc_prices', 0, -1)
                logger.info("prices:")
                for i, p in enumerate(all_prices, 1):
                    p_data = json.loads(p)
                    logger.info(f"{i}. ${p_data['price']} at {p_data['timestamp']}")
            
            await asyncio.sleep(UPDATE_INTERVAL)

async def main():
    logger.info("btc price update")
    await update_price()

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