db

class DB:
    """
    DB class
    """

    @classmethod
    def engine_async(cls) -> AsyncEngine:
        try:
            return cls._engine_async
        except AttributeError:
            cls.set_async_db()
            return cls._engine_async

    @classmethod
    def engine_sync(cls) -> Engine:
        try:
            return cls._engine_sync
        except AttributeError:
            cls.set_sync_db()
            return cls._engine_sync

    @classmethod
    def set_async_db(cls) -> None:
        cls._engine_async = create_async_engine(**_get_engine_atrs())
        cls._async_session_maker = async_sessionmaker(
            cls._engine_async,
            class_=AsyncSession,
            expire_on_commit=False,
        )

    @classmethod
    def set_sync_db(cls) -> None:
        cls._engine_sync = create_engine(**_get_engine_atrs())
        cls._sync_session_maker = sessionmaker(cls._engine_sync)

    @classmethod
    async def get_async_db(cls) -> AsyncGenerator[AsyncSession, None]:
        """
        Get async database session
        """
        try:
            session_maker = cls._async_session_maker()
        except AttributeError:
            cls.set_async_db()
            session_maker = cls._async_session_maker()
        async with session_maker as async_session:
            yield async_session

    @classmethod
    def get_sync_db(cls) -> Generator[DBSyncSession, None, None]:
        """
        Get sync database session
        """
        try:
            session_maker = cls._sync_session_maker()
        except AttributeError:
            cls.set_sync_db()
            session_maker = cls._sync_session_maker()
        with session_maker as sync_session:
            yield sync_session