RunKlinesNotifications.py

from Network.WebSocketKlines import start_web_socket
from loguru import logger
from BlackBoxScripts.Processor_BinanceAllKlinesToNotification import Processor_BinanceAllKlinesToNotification
from BlackBoxScripts.Processor_BinanceAllKlinesDisplay import Processor_BinanceAllKlinesDisplay
from Network.BinanceClient import BinanceClient
# from binanceHelper.SamBinanceClient import AsyncClient



if __name__ == "__main__":
    # https://binance-docs.github.io/apidocs/spot/en/#kline-candlestick-streams
    
    run_config = {
        "vol_increase_x": 15,
        "not_increase_x": 15,
        "back_off_after_notification_secs": 3600,
        "max_minute_kline_memory_storage_count": 360,
        "ta_average_length": 60
    }

    stable_coin = "usdt"


    logger.add("LOG_run_klines_notifications.log", format="{time:YYYY-MM-DDTHH:mm:ss} {level} {message}", level="INFO",  rotation="500 MB")
    testNet = False
    b_client = BinanceClient(testNet)
    # processData = Processor_BinanceAllKlinesToNotification(stable_coin, b_client, run_config)
    processData = Processor_BinanceAllKlinesDisplay(stable_coin)


    start_web_socket(stable_coin, processData)