import asyncio
import os

import pytest

from redbot.core import drivers, data_manager


@pytest.fixture(scope="session")
def event_loop(request):
    """Create an instance of the default event loop for entire session."""
    loop = asyncio.get_event_loop_policy().new_event_loop()
    yield loop
    loop.close()


def _get_backend_type():
    if os.getenv("RED_STORAGE_TYPE") == "postgres":
        return drivers.BackendType.POSTGRES
    elif os.getenv("RED_STORAGE_TYPE") == "mongo":
        return drivers.BackendType.MONGO
    else:
        return drivers.BackendType.JSON


@pytest.fixture(scope="session", autouse=True)
async def _setup_driver():
    backend_type = _get_backend_type()
    if backend_type == drivers.BackendType.MONGO:
        storage_details = {
            "URI": os.getenv("RED_MONGO_URI", "mongodb"),
            "HOST": os.getenv("RED_MONGO_HOST", "localhost"),
            "PORT": int(os.getenv("RED_MONGO_PORT", "27017")),
            "USERNAME": os.getenv("RED_MONGO_USER", "red"),
            "PASSWORD": os.getenv("RED_MONGO_PASSWORD", "red"),
            "DB_NAME": os.getenv("RED_MONGO_DATABASE", "red_db"),
        }
    else:
        storage_details = {}
    data_manager.storage_type = lambda: backend_type.value
    data_manager.storage_details = lambda: storage_details
    driver_cls = drivers.get_driver_class(backend_type)
    await driver_cls.initialize(**storage_details)
    yield
    await driver_cls.teardown()