Cover 100%

tests/test_api/test_types/test_message_entity.py

@@ -1,5 +1,3 @@
-import pytest
-
 from aiogram.types import MessageEntity
 from tests.deprecated import check_deprecated
 

tests/test_dispatcher/test_dispatcher.py

@@ -9,6 +9,7 @@ import pytest
 from aiogram import Bot
 from aiogram.dispatcher.dispatcher import Dispatcher
 from aiogram.dispatcher.event.bases import UNHANDLED, SkipHandler
+from aiogram.dispatcher.fsm.strategy import FSMStrategy
 from aiogram.dispatcher.middlewares.user_context import UserContextMiddleware
 from aiogram.dispatcher.router import Router
 from aiogram.methods import GetMe, GetUpdates, SendMessage
@@ -78,8 +79,9 @@ class TestDispatcher:
         assert dp.parent_router is None
 
     @pytest.mark.asyncio
-    async def test_feed_update(self):
-        dp = Dispatcher()
+    @pytest.mark.parametrize("isolate_events", (True, False))
+    async def test_feed_update(self, isolate_events):
+        dp = Dispatcher(isolate_events=isolate_events)
         bot = Bot("42:TEST")
 
         @dp.message()
@@ -652,3 +654,20 @@ class TestDispatcher:
 
         log_records = [rec.message for rec in caplog.records]
         assert "Cause exception while process update" in log_records[0]
+
+    @pytest.mark.parametrize(
+        "strategy,case,expected",
+        [
+            [FSMStrategy.USER_IN_CHAT, (-42, 42), (-42, 42)],
+            [FSMStrategy.CHAT, (-42, 42), (-42, -42)],
+            [FSMStrategy.GLOBAL_USER, (-42, 42), (42, 42)],
+            [FSMStrategy.USER_IN_CHAT, (42, 42), (42, 42)],
+            [FSMStrategy.CHAT, (42, 42), (42, 42)],
+            [FSMStrategy.GLOBAL_USER, (42, 42), (42, 42)],
+        ],
+    )
+    def test_get_current_state_context(self, strategy, case, expected):
+        dp = Dispatcher(fsm_strategy=strategy)
+        chat_id, user_id = case
+        state = dp.current_state(chat_id=chat_id, user_id=user_id)
+        assert (state.chat_id, state.user_id) == expected

tests/test_dispatcher/test_fsm/storage/test_memory.py

@@ -32,3 +32,14 @@ class TestMemoryStorage:
         assert 42 in storage.storage[-42]
         assert isinstance(storage.storage[-42][42], MemoryStorageRecord)
         assert storage.storage[-42][42].data == {"foo": "bar"}
+
+    @pytest.mark.asyncio
+    async def test_update_data(self, storage: MemoryStorage):
+        assert await storage.get_data(chat_id=-42, user_id=42) == {}
+        assert await storage.update_data(chat_id=-42, user_id=42, data={"foo": "bar"}) == {
+            "foo": "bar"
+        }
+        assert await storage.update_data(chat_id=-42, user_id=42, data={"baz": "spam"}) == {
+            "foo": "bar",
+            "baz": "spam",
+        }

tests/test_dispatcher/test_fsm/test_context.py

@@ -0,0 +1,49 @@
+import pytest
+
+from aiogram.dispatcher.fsm.context import FSMContext
+from aiogram.dispatcher.fsm.storage.memory import MemoryStorage
+
+
+@pytest.fixture()
+def state():
+    storage = MemoryStorage()
+    ctx = storage.storage[-42][42]
+    ctx.state = "test"
+    ctx.data = {"foo": "bar"}
+    return FSMContext(storage=storage, user_id=-42, chat_id=42)
+
+
+class TestFSMContext:
+    @pytest.mark.asyncio
+    async def test_address_mapping(self):
+        storage = MemoryStorage()
+        ctx = storage.storage[-42][42]
+        ctx.state = "test"
+        ctx.data = {"foo": "bar"}
+        state = FSMContext(storage=storage, chat_id=-42, user_id=42)
+        state2 = FSMContext(storage=storage, chat_id=42, user_id=42)
+        state3 = FSMContext(storage=storage, chat_id=69, user_id=69)
+
+        assert await state.get_state() == "test"
+        assert await state2.get_state() is None
+        assert await state3.get_state() is None
+
+        assert await state.get_data() == {"foo": "bar"}
+        assert await state2.get_data() == {}
+        assert await state3.get_data() == {}
+
+        await state2.set_state("experiments")
+        assert await state.get_state() == "test"
+        assert await state3.get_state() is None
+
+        await state3.set_data({"key": "value"})
+        assert await state2.get_data() == {}
+
+        await state.update_data({"key": "value"})
+        assert await state.get_data() == {"foo": "bar", "key": "value"}
+
+        await state.clear()
+        assert await state.get_state() is None
+        assert await state.get_data() == {}
+
+        assert await state2.get_state() == "experiments"

tests/test_dispatcher/test_fsm/test_strategy.py

@@ -0,0 +1,20 @@
+import pytest
+
+from aiogram.dispatcher.fsm.strategy import FSMStrategy, apply_strategy
+
+
+class TestStrategy:
+    @pytest.mark.parametrize(
+        "strategy,case,expected",
+        [
+            [FSMStrategy.USER_IN_CHAT, (-42, 42), (-42, 42)],
+            [FSMStrategy.CHAT, (-42, 42), (-42, -42)],
+            [FSMStrategy.GLOBAL_USER, (-42, 42), (42, 42)],
+            [FSMStrategy.USER_IN_CHAT, (42, 42), (42, 42)],
+            [FSMStrategy.CHAT, (42, 42), (42, 42)],
+            [FSMStrategy.GLOBAL_USER, (42, 42), (42, 42)],
+        ],
+    )
+    def test_strategy(self, strategy, case, expected):
+        chat_id, user_id = case
+        assert apply_strategy(chat_id=chat_id, user_id=user_id, strategy=strategy) == expected

tests/test_dispatcher/test_handler/test_chat_member.py

@@ -0,0 +1,32 @@
+import datetime
+from typing import Any
+
+import pytest
+
+from aiogram.dispatcher.handler.chat_member import ChatMemberHandler
+from aiogram.types import Chat, ChatMember, ChatMemberUpdated, User
+
+
+class TestChatMemberUpdated:
+    @pytest.mark.asyncio
+    async def test_attributes_aliases(self):
+        event = ChatMemberUpdated(
+            chat=Chat(id=42, type="private"),
+            from_user=User(id=42, is_bot=False, first_name="Test"),
+            date=datetime.datetime.now(),
+            old_chat_member=ChatMember(
+                user=User(id=42, is_bot=False, first_name="Test"), status="restricted"
+            ),
+            new_chat_member=ChatMember(
+                user=User(id=42, is_bot=False, first_name="Test"), status="restricted"
+            ),
+        )
+
+        class MyHandler(ChatMemberHandler):
+            async def handle(self) -> Any:
+                assert self.event == event
+                assert self.from_user == self.event.from_user
+
+                return True
+
+        assert await MyHandler(event)

tests/test_dispatcher/test_router.py

@@ -1,26 +1,7 @@
-import datetime
-from typing import Any
-
 import pytest
 
-from aiogram.dispatcher.event.bases import UNHANDLED, SkipHandler, skip
-from aiogram.dispatcher.middlewares.user_context import UserContextMiddleware
+from aiogram.dispatcher.event.bases import SkipHandler, skip
 from aiogram.dispatcher.router import Router
-from aiogram.types import (
-    CallbackQuery,
-    Chat,
-    ChosenInlineResult,
-    InlineQuery,
-    Message,
-    Poll,
-    PollAnswer,
-    PollOption,
-    PreCheckoutQuery,
-    ShippingAddress,
-    ShippingQuery,
-    Update,
-    User,
-)
 from aiogram.utils.warnings import CodeHasNoEffect
 
 importable_router = Router()