Run metrics filter on fetch only

lidofinance · Dec 16, 2024 · b2bf8e7 · b2bf8e7
1 parent f16d2f6
commit b2bf8e7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/transport/msg_storage.py b/src/transport/msg_storage.py
@@ -46,8 +46,9 @@ def get_messages_and_actualize(self, actualize_filter: Callable[[BotMessage], bo
         """
         messages = self.messages
         for transport in self._transports:
-            messages.extend(transport.get_messages())
-        self.messages = list(filter(lambda x: self._filter(x) and actualize_filter(x), messages))
+            filtered_messages = list(filter(lambda x: self._filter(x), transport.get_messages()))
+            messages.extend(filtered_messages)
+        self.messages = list(filter(lambda x: actualize_filter(x), messages))
         return self.messages
 
     def clear(self):