anonflow/anonflow/bot/middlewares/user/not_registered.py

from aiogram import BaseMiddleware
from aiogram.enums import ChatType
from aiogram.types import Message

from anonflow.bot.transport.types import RequestContext
from anonflow.interfaces import UserResponsesPort


class UserNotRegisteredMiddleware(BaseMiddleware):
    def __init__(self, responses_port: UserResponsesPort):
        super().__init__()

        self._responses_port = responses_port

    async def __call__(self, handler, event, data):
        message = getattr(event, "message", None)
        if isinstance(message, Message) and message.chat.type == ChatType.PRIVATE:
            text = message.text or message.caption or ""

            is_user_exists = data.get("user") is not None
            if not is_user_exists and not text.startswith("/start"):
                await self._responses_port.user_not_registered(
                    RequestContext(message.chat.id, data["user_language"])
                )
                return

        return await handler(event, data)