diff --git a/src/handlers/chat_handlers.py b/src/handlers/chat_handlers.py index 472e548..1675c58 100644 --- a/src/handlers/chat_handlers.py +++ b/src/handlers/chat_handlers.py @@ -486,52 +486,19 @@ async def handle_sticker_message(message: Message): @router.message(F.voice) async def handle_voice_message(message: Message): - """Обработчик голосовых сообщений""" - async with async_session_maker() as session: - can_send, reason = await ChatPermissionService.can_send_message( - session, - message.from_user.id, - is_admin=is_admin(message.from_user.id) - ) - - if not can_send: - await message.answer(f"❌ {reason}") - return - - settings = await ChatSettingsService.get_or_create_settings(session) - user = await UserService.get_user_by_telegram_id(session, message.from_user.id) - - if not user: - return - - if settings.mode == 'broadcast': - # НЕ исключаем отправителя - админ должен видеть все сообщения - forwarded_ids, success, fail = await broadcast_message_with_scheduler(message, exclude_user_id=None) - - await ChatMessageService.save_message( - session, - user_id=user.id, - telegram_message_id=message.message_id, - message_type='voice', - file_id=message.voice.file_id, - forwarded_ids=forwarded_ids - ) - - # Показываем статистику только админам - if is_admin(message.from_user.id): - await message.answer(f"✅ Голосовое сообщение разослано: {success} получателей") - - elif settings.mode == 'forward': - if settings.forward_chat_id: - success, channel_msg_id = await forward_to_channel(message, settings.forward_chat_id) - - if success: - await ChatMessageService.save_message( - session, - user_id=user.id, - telegram_message_id=message.message_id, - message_type='voice', - file_id=message.voice.file_id, - forwarded_ids={'channel': channel_msg_id} if channel_msg_id else None - ) - await message.answer("✅ Голосовое сообщение переслано в канал") + """Обработчик голосовых сообщений - ЗАБЛОКИРОВАНО""" + await message.answer( + "🚫 Голосовые сообщения запрещены.\n\n" + "Пожалуйста, используйте текстовые сообщения или изображения." + ) + return + + +@router.message(F.audio) +async def handle_audio_message(message: Message): + """Обработчик аудиофайлов (музыка, аудиозаписи) - ЗАБЛОКИРОВАНО""" + await message.answer( + "🚫 Аудиофайлы запрещены.\n\n" + "Пожалуйста, используйте текстовые сообщения или изображения." + ) + return