from aiohttp import web
import asyncio
from core.database.api import Database
from core.cache.api import Cache
from core.logic.api import Logic
from core import settings
import logging
from tasks.api import Tasks
import sys


if __name__ == "__main__":
    logger = logging.getLogger()
    logger.info("Tasks server is starting...")

    loop = asyncio.get_event_loop()

    database = Database(
        engine_type=settings.DATABASE_ENGINE,
        host=settings.DATABASE_HOST,
        name=settings.DATABASE_NAME,
        username=settings.DATABASE_USER,
        password=settings.DATABASE_PASSWORD,
        logger=logging.getLogger("database"),
    )
    Logic.set_database(database)
    cache = loop.run_until_complete(Cache.create(
        host=settings.CACHE_HOST,
        port=settings.CACHE_PORT,
        logger=logging.getLogger("cache"),
    ))
    Logic.set_cache(cache)

    for name in Tasks.BACK_TASKS:
        Tasks.add_task(name=name, loop=loop)

    logger.info("Back tasks started")

    args = dict()
    for arg in sys.argv[1:]:
        if arg[:7] == "--port=":
            args["port"] = int(arg[7:])

    app = web.Application()
    # from routes import routes
    # for path, method, view in routes:
    #     app.router.add_route(method, path, view)
    web.run_app(app, port=args["port"])