Fringg
909a4039c4
- LoggingMiddleware: logger.error → logger.exception to include exc_info so TelegramNotifierProcessor can extract traceback for admin chat - ConsoleRenderer: pad_event_to=0 to remove excessive whitespace in short event names (timeline markers like ┃, ┗)
44 lines
1.7 KiB
Python
44 lines
1.7 KiB
Python
from collections.abc import Awaitable, Callable
|
|
from time import monotonic
|
|
from typing import Any
|
|
|
|
import structlog
|
|
from aiogram import BaseMiddleware
|
|
from aiogram.types import CallbackQuery, Message, TelegramObject
|
|
|
|
|
|
logger = structlog.get_logger(__name__)
|
|
|
|
|
|
class LoggingMiddleware(BaseMiddleware):
|
|
async def __call__(
|
|
self,
|
|
handler: Callable[[TelegramObject, dict[str, Any]], Awaitable[Any]],
|
|
event: TelegramObject,
|
|
data: dict[str, Any],
|
|
) -> Any:
|
|
start_time = monotonic()
|
|
|
|
try:
|
|
if isinstance(event, Message) and event.from_user:
|
|
user_info = f'@{event.from_user.username}' if event.from_user.username else f'ID:{event.from_user.id}'
|
|
text = event.text or event.caption or '[медиа]'
|
|
logger.info('📩 Сообщение от', user_info=user_info, text=text)
|
|
|
|
elif isinstance(event, CallbackQuery) and event.from_user:
|
|
user_info = f'@{event.from_user.username}' if event.from_user.username else f'ID:{event.from_user.id}'
|
|
logger.info('🔘 Callback от', user_info=user_info, event_data=event.data)
|
|
|
|
result = await handler(event, data)
|
|
|
|
execution_time = monotonic() - start_time
|
|
if execution_time > 1.0:
|
|
logger.warning('⏱️ Медленная операция', execution_time=round(execution_time, 2))
|
|
|
|
return result
|
|
|
|
except Exception as e:
|
|
execution_time = monotonic() - start_time
|
|
logger.exception('❌ Ошибка при обработке события за', execution_time=round(execution_time, 2), error=e)
|
|
raise
|