Coverage for docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py: 0%

1import asyncio 

2 

3from aiogram import Bot, Dispatcher 

4from aiogram.types import Message 

5 

6from faststream.nats import NatsBroker 

7 

8bot = Bot("") 

9dispatcher = Dispatcher() 

10broker = NatsBroker() 

11 

12@broker.subscriber("echo") 

13async def echo_faststream_handler(data: dict[str, str]) -> None: 

14 await bot.copy_message(**data) 

15 

16 

17@dispatcher.message() 

18async def echo_aiogram_handler(event: Message) -> None: 

19 await broker.publish( 

20 subject="echo", 

21 message={ 

22 "chat_id": event.chat.id, 

23 "message_id": event.message_id, 

24 "from_chat_id": event.chat.id, 

25 }, 

26 ) 

27 

28 

29async def main() -> None: 

30 async with broker: 

31 await broker.start() 

32 await dispatcher.start_polling(bot) 

33 

34asyncio.run(main())