async_stream_acc.py

import aiohttp
import requests
import time
import json
import datetime
import asyncio
import os

TG_BOT_TOKEN = os.getenv('TG_BOT_TOKEN')
TG_ChatID = os.getenv('TG_ChatID')

def tg_sendMsg(
    msg: str | list = "no message",
    TOKEN=TG_BOT_TOKEN,
    chat_id=TG_ChatID,
    ps = "",
    *,
    sep_msg: bool = False,
) -> str:

    """send message via telegram api(url)\n
    url = (
        f"https://api.telegram.org/bot{TOKEN}/sendMessage?chat_id={chat_id}&text={msg}"
    )"""
    # TOKEN = TOKEN
    # chat_id = chat_id
    _ps = ps
    isStr = type(msg) is str
    if isStr:
        msg = msg + _ps
    elif sep_msg and type(msg) == list:
        for m in msg:
            url = f"https://api.telegram.org/bot{TOKEN}/sendMessage?chat_id={chat_id}&text={m + _ps}"
            requests.get(url).json()
        return True
    elif not sep_msg and type(msg) != str:
        msg = " \n".join([m for m in msg]) + _ps
    url = (
        f"https://api.telegram.org/bot{TOKEN}/sendMessage?chat_id={chat_id}&text={msg}"
    )
    requests.get(url).json()
async def main():
    headers = {
        "accept": "*/*",
        "accept-language": "ru-RU,ru;q=0.9,en-US;q=0.8,en;q=0.7,uk;q=0.6",
        "authorization": "Bearer AFPJTKEBPOX3AIYAAAAKA2HWOTRNJP5MUCV5DMDCZAAOCPSAYEYS3CILNQVLF2HWKED6USY",
        "content-type": "application/json",
        "sec-ch-ua": "\"Chromium\";v=\"122\", \"Not(A:Brand\";v=\"24\", \"Google Chrome\";v=\"122\"",
        "sec-ch-ua-mobile": "?0",
        "sec-ch-ua-platform": "\"Windows\"",
        "sec-fetch-dest": "empty",
        "sec-fetch-mode": "cors",
        "sec-fetch-site": "cross-site"
    }


    url = "https://tonapi.io/v2/sse/accounts/traces?accounts=EQAIFunALREOeQ99syMbO6sSzM_Fa1RsPD5TBoS0qVeKQ-AR&token=AFPJTKEBPOX3AIYAAAAKA2HWOTRNJP5MUCV5DMDCZAAOCPSAYEYS3CILNQVLF2HWKED6USY"
    #stream accounts  https://tonviewer.com/EQAIFunALREOeQ99syMbO6sSzM_Fa1RsPD5TBoS0qVeKQ-AR
    response = requests.get(url, stream=True)

    for line in response.iter_lines():
        if line.startswith(b'data:'):
            # Если строка начинается с 'data:', это строка данных
            # Извлеките данные и разберите их как JSON
            data_json = line.split(b':', 1)[1].strip()
            if data_json:
                event_data = json.loads(data_json)
                # print(event_data['accounts'])
                st = time.time()
                async with aiohttp.ClientSession() as session:
                    for i in event_data['accounts']:
                        Sale_addr = i
                        #NFT SALE CONTRACT info with price
                        async with session.get(f'https://tonapi.io/v2/blockchain/accounts/{Sale_addr}/methods/get_sale_data', headers=headers) as res:
                            if res.status == 200:
                                response = await res.json()
                                try:
                                    if response['decoded']['royalty_address'] == '0:ed53bc999e5a4af69a3f9c3de5376f7d90c487e1528f331e716dbe85903d5112':
                                        created_at = response['decoded']['created_at']
                                        price = int(response['decoded']['full_price'])/1e9
                                        # if created_at < int(time.time()) + 10 and price < 7:
                                        if price < 8:
                                            nft_addr = response['decoded']['nft']
                                            is_complete = response['decoded']['is_complete']
                                            dt = str(datetime.datetime.fromtimestamp(created_at))
                                            timeNow = str(datetime.datetime.now())[:-7]
                                            # print(f'Price: {price}', f'\nCreated at: {dt:>16}\n  Found at: {timeNow:>16}', f'\nNFT ADD: {nft_addr}\nIs_complete: {is_complete}')
                                        # print(response)
                                            #NFT INFO
                                            async with session.get(f'https://tonapi.io/v2/nfts/{nft_addr}', headers=headers) as res1:
                                                nft_res = await res1.json()
                                                if 'sale' in nft_res:
                                                    print(f'Price: {price}', f'\nCreated at: {dt:>16}\n  Found at: {timeNow:>16}', f'\nNFT ADD: {nft_addr}\nIs_complete: {is_complete}')
                                                    msg = f'Price: {price}\nCreated at: {dt:>16}\n   Found at: {timeNow:>16}\nNFT ADD: {nft_addr}\nIs_complete: {is_complete}'
                                                    # tg_sendMsg(msg, ps='\n\nstream_acc.py')
                                except Exception as e:
                                    # print("Exception: ", e)
                                    pass
                            
                            else:
                                print('Status code: ',res.status)
                end = time.time() - st
                print(end)
if __name__ == "__main__":
    asyncio.run(main())