import requests
import settings
from datetime import datetime, timedelta
import time
import tg
import traceback
import logging



def strategy_run():
    # 获取上一分钟的timestamp
    last_min = datetime.now() - timedelta(minutes=settings.whaleAlert_minutes)
    ts = time.mktime(last_min.timetuple())

    url = f'https://api.whale-alert.io/v1/transactions?api_key={settings.whaleAlert_apikey}&start={int(ts)}'
    resp = requests.get(url).json()
    print(resp)
    try:
        if 'transactions' in resp:
            data = resp['transactions']

            for ts in data:
                usd = int(ts['amount_usd'])
                if ts['to']['owner_type'] == 'exchange' and usd > settings.whaleAlert_max_limit:
                    from_text = 'unknown wallet'
                    content = f"🚨 {ts['amount']} #{ts['symbol']} ({ts['amount_usd']} USD) 从 {from_text} 转入 #{ts['to']['owner']}"

                    print(content)
                    tg.send_message(settings.chat_id, content)
    except Exception as e:
        logging.error(traceback.format_exc())
        tg.send_message(settings.chat_id, traceback.format_exc())