diff --git a/routers/tg_send.py b/routers/tg_send.py index dcb37e7..2635b48 100644 --- a/routers/tg_send.py +++ b/routers/tg_send.py @@ -4,7 +4,7 @@ import logging as log from schemas import TelegramMessageToDashboard from auth import verify_token_admin from telegram import send_message_to_dashboard, del_message_from_dashboard -from redis_db import set_value +from redis_db import set_value, pop_value router = APIRouter() @@ -15,7 +15,9 @@ async def send_message( token: str = Depends(verify_token_admin), ): if message.text.startswith("Problem has been resolved"): - await del_message_from_dashboard(message_id=message.problem_id) + msg_id = await pop_value(message.problem_id) + msg_id = int(msg_id.decode("utf-8")) + await del_message_from_dashboard(message_id=msg_id) return result = await send_message_to_dashboard(text=message.text)