diff --git a/src/modules/stream_notifications/messages_proc.py b/src/modules/stream_notifications/messages_proc.py index f27425a..52facb6 100644 --- a/src/modules/stream_notifications/messages_proc.py +++ b/src/modules/stream_notifications/messages_proc.py @@ -154,7 +154,8 @@ class MessagesProc: def get_message_history_with_thread(cls, message_id: str, thread_id: str | None = None) -> list[dict]: logger.info(f"HISTORY: {cls.MESSAGE_HISTORY}") - return [m for m in cls.MESSAGE_HISTORY if m["thread_id"] == thread_id or m["id"] == message_id] + return [m for m in cls.MESSAGE_HISTORY if m["thread_id"] == thread_id] + \ + [m for m in cls.MESSAGE_HISTORY if m["id"] == message_id] @classmethod async def on_message(cls, event: MessageEvent):