From 67a18ba3ddf0aaecb20a7fd045f265987c6620d2 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Wed, 19 Feb 2025 00:30:56 +0100 Subject: [PATCH] Update --- src/modules/stream_notifications/messages_proc.py | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/src/modules/stream_notifications/messages_proc.py b/src/modules/stream_notifications/messages_proc.py index 9edd969..0fd7d5c 100644 --- a/src/modules/stream_notifications/messages_proc.py +++ b/src/modules/stream_notifications/messages_proc.py @@ -154,14 +154,7 @@ class MessagesProc: def get_message_history_with_thread(cls, message_id: str) -> list[dict]: logger.info(f"HISTORY: {cls.MESSAGE_HISTORY}") - message = next((message for message in cls.MESSAGE_HISTORY if message["id"] == message_id), None) - if message is None: - return [] - - return ( - [m for m in cls.MESSAGE_HISTORY if m["thread_id"] == message_id] - + [m for m in cls.MESSAGE_HISTORY if m["id"] == message_id] - ) + return [m for m in cls.MESSAGE_HISTORY if m["thread_id"] == message_id or m["id"] == message_id] @classmethod async def on_message(cls, event: MessageEvent):