from app.common.repository.admin_user_repository import AdminUserRepository
from app.exception.err_exception import ErrException
from app.lib.response.admin_return import AdminReturn
from app.service.admin.base_admin_service import BaseAdminService


class CurrentUserService(BaseAdminService):
    def __init__(
        self,
        user_repository: AdminUserRepository,
        admin_return: AdminReturn,
    ) -> None:
        super().__init__(admin_return)
        self.user_repository = user_repository

    async def handle(self) -> dict:
        admin_user = await self.user_repository.find_by_id(self.admin_id)
        if admin_user is None:
            raise ErrException("账户不存在")
        return self.admin_return.success("success", admin_user.to_public_dict())