In MessageBus, keep history for entities not referenced in chains

15532th · Dec 14, 2024 · 4a51f46 · 4a51f46
1 parent 088c0b4
commit 4a51f46
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/avtdl/core/interfaces.py b/avtdl/core/interfaces.py
@@ -149,6 +149,9 @@ def pub(self, topic: str, message: Record):
 
             generic_topic = self._generic_topic(specific_topic)
             self.add_to_history(generic_topic, targeted_message)
+        if not matching_callbacks:
+            # topic has no subscribers, meaning entity is not referenced in chains
+            self.add_to_history(self._generic_topic(topic), message)
 
     def add_to_history(self, topic: str, message: Record):
         self.history[topic].append(message)