from datetime import datetime
from unittest.mock import patch

import pytest

from aiogram.dispatcher.middlewares.user_context import (
    EventContext,
    UserContextMiddleware,
)
from aiogram.types import (
    Chat,
    ChatBoost,
    ChatBoostSourceGiftCode,
    ChatBoostSourceGiveaway,
    ChatBoostSourcePremium,
    ChatBoostUpdated,
    Update,
    User,
)


async def next_handler(*args, **kwargs):
    pass


class TestUserContextMiddleware:
    async def test_unexpected_event_type(self):
        with pytest.raises(RuntimeError):
            await UserContextMiddleware()(next_handler, object(), {})

    async def test_call(self):
        middleware = UserContextMiddleware()
        data = {}

        chat = Chat(id=1, type="private", title="Test")
        user = User(id=2, first_name="Test", is_bot=False)
        thread_id = 3

        with patch.object(
            UserContextMiddleware,
            "resolve_event_context",
            return_value=EventContext(user=user, chat=chat, thread_id=3),
        ):
            await middleware(next_handler, Update(update_id=42), data)

        event_context = data["event_context"]
        assert isinstance(event_context, EventContext)
        assert event_context.chat is chat
        assert event_context.user is user
        assert event_context.thread_id == thread_id
        assert data["event_chat"] is chat
        assert data["event_from_user"] is user
        assert data["event_thread_id"] == thread_id

    @pytest.mark.parametrize(
        "source, expected_user",
        [
            (
                ChatBoostSourcePremium(user=User(id=2, first_name="Test", is_bot=False)),
                User(id=2, first_name="Test", is_bot=False),
            ),
            (ChatBoostSourceGiftCode(user=User(id=2, first_name="Test", is_bot=False)), None),
            (
                ChatBoostSourceGiveaway(
                    giveaway_message_id=1, user=User(id=2, first_name="Test", is_bot=False)
                ),
                None,
            ),
        ],
    )
    async def test_resolve_event_context(self, source, expected_user):
        middleware = UserContextMiddleware()
        data = {}

        chat = Chat(id=1, type="private", title="Test")
        add_date = datetime.now()
        expiration_date = datetime.now()

        boost = ChatBoost(
            boost_id="Test", add_date=add_date, expiration_date=expiration_date, source=source
        )
        update = Update(update_id=42, chat_boost=ChatBoostUpdated(chat=chat, boost=boost))

        await middleware(next_handler, update, data)

        event_context = data["event_context"]
        assert isinstance(event_context, EventContext)
        assert event_context.user == expected_user