diff --git a/handlers/messages_routing.py b/handlers/messages_routing.py index b27bb6c..dc9c9ce 100644 --- a/handlers/messages_routing.py +++ b/handlers/messages_routing.py @@ -57,33 +57,36 @@ async def messages_routing(msg, state): if one_score: logger.debug(one_score) reply_text += f"{int(one_score)}% токсичности\n" + try: + # count average between all of messages + toxic_pattern = f"toxic:{cid}:{uid}:*" + toxic_score = await get_average_pattern(toxic_pattern) - # count average between all of messages - toxic_pattern = f"toxic:{cid}:{uid}:*" - toxic_score = await get_average_pattern(toxic_pattern) - - if toxic_score: - emoji = ( - "😳" - if toxic_score > 90 - else "😟" - if toxic_score > 80 - else "😏" - if toxic_score > 60 - else "🙂" - if toxic_score > 20 - else "😇" - ) - reply_text += ( - f"Средняя токсичность сообщений: {toxic_score}% {emoji}" - ) - if reply_text: - await telegram_api( - "sendMessage", - chat_id=cid, - reply_to_message_id=reply_to_msg_id, - text=reply_text, - ) + if toxic_score: + emoji = ( + "😳" + if toxic_score > 90 + else "😟" + if toxic_score > 80 + else "😏" + if toxic_score > 60 + else "🙂" + if toxic_score > 20 + else "😇" + ) + reply_text += ( + f"Средняя токсичность сообщений: {toxic_score}% {emoji}" + ) + except Exception: + pass + finally: + if reply_text: + await telegram_api( + "sendMessage", + chat_id=cid, + reply_to_message_id=reply_to_msg_id, + text=reply_text, + ) try: await telegram_api("deleteMessage", chat_id=cid, message_id=mid) except Exception: