main.py

import asyncio
import logging

from app.client import client
from app.instruments_config.parser import instruments_config
from app.strategies.strategy_fabric import resolve_strategy

logging.basicConfig(
    level=logging.DEBUG,
    format="[%(levelname)-5s] %(asctime)-19s %(name)s: %(message)s",
)


async def init():
    await client.ainit()
    for instrument_config in instruments_config.instruments:
        strategy = resolve_strategy(
            strategy_name=instrument_config.strategy.name,
            figi=instrument_config.figi,
            **instrument_config.strategy.parameters
        )
        asyncio.create_task(strategy.start())


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.create_task(init())
    loop.run_forever()