application.py

from composition_root import CompositionRoot
from database.models import UserDb
import asyncio


class Application:
    def __init__(self, composition_root: CompositionRoot):
        self._composition_root = composition_root

    async def run(self):
        # Create a new user
        new_user = UserDb(name="John Doe", email="john.doe@example.com")
        await self._composition_root._user_repository_async.create(new_user)

        # Fetch all users
        users = await self._composition_root._user_repository_async.get_all(limit=10)
        for user in users:
            print(f"User ID: {user.id}, Name: {user.name}, Email: {user.email}")

        # get user by id
        user = await self._composition_root._user_repository_async.get_by_id(
            new_user.id
        )
        if user:
            print(f"Fetched User ID: {user.id}, Name: {user.name}, Email: {user.email}")

        # Update user
        if user:
            user.name = "Jane Doe"
            await self._composition_root._user_repository_async.update(user)

            # get updated user
            updated_user = (
                await self._composition_root._user_repository_async.get_by_id(user.id)
            )
            if updated_user:
                print(
                    f"Updated User ID: {updated_user.id}, Name: {updated_user.name}, Email: {updated_user.email}"
                )

        # Delete user
        if user:
            await self._composition_root._user_repository_async.delete(user)
            print(f"Deleted User ID: {user.id}")

        # Verify deletion
        deleted_user = await self._composition_root._user_repository_async.get_by_id(
            new_user.id
        )
        if not deleted_user:
            print(f"User ID: {new_user.id} successfully deleted.")

        # Close the async engine
        await self._composition_root._db_context_async.close()

    def start(self):
        asyncio.run(self.run())