revert: remove bridge.py rate limiter changes from drone PR

These changes (rate limiter + test) were incorrectly added by the
subagent in the drone modernization branch. They belong in a separate PR.

Author: spomichter

dimos/visualization/rerun/bridge.py

@@ -18,7 +18,6 @@
 
 from dataclasses import dataclass, field
 from functools import lru_cache
-import time
 from typing import (
     TYPE_CHECKING,
     Any,
@@ -163,14 +162,15 @@ def _resolve_viewer_mode() -> ViewerMode:
 class Config(ModuleConfig):
     """Configuration for RerunBridgeModule."""
 
-    pubsubs: list[SubscribeAllCapable[Any, Any]] = field(default_factory=lambda: [LCM()])
+    pubsubs: list[SubscribeAllCapable[Any, Any]] = field(
+        default_factory=lambda: [LCM(autoconf=True)]
+    )
 
     visual_override: dict[Glob | str, Callable[[Any], Archetype]] = field(default_factory=dict)
 
     # Static items logged once after start. Maps entity_path -> callable(rr) returning Archetype
     static: dict[str, Callable[[Any], Archetype]] = field(default_factory=dict)
 
-    min_interval_sec: float = 0.1  # Rate-limit per entity path (default: 10 Hz max)
     entity_prefix: str = "world"
     topic_to_entity: Callable[[Any], str] | None = None
     viewer_mode: ViewerMode = field(default_factory=_resolve_viewer_mode)
@@ -191,7 +191,7 @@ class RerunBridgeModule(Module):
     Example:
         from dimos.protocol.pubsub.impl.lcmpubsub import LCM
 
-        lcm = LCM()
+        lcm = LCM(autoconf=True)
         bridge = RerunBridgeModule(pubsubs=[lcm])
         bridge.start()
         # All messages with to_rerun() are now logged to Rerun
@@ -254,18 +254,6 @@ def _on_message(self, msg: Any, topic: Any) -> None:
         # convert a potentially complex topic object into an str rerun entity path
         entity_path: str = self._get_entity_path(topic)
 
-        # Rate-limit per entity path to prevent viewer memory exhaustion.
-        # High-bandwidth streams (e.g. 30fps camera) would otherwise flood
-        # the viewer with data faster than it can evict, causing OOM.
-        if self.config.min_interval_sec > 0:
-            now = time.monotonic()
-            if not hasattr(self, "_last_log"):
-                self._last_log: dict[str, float] = {}
-            last = self._last_log.get(entity_path, 0.0)
-            if now - last < self.config.min_interval_sec:
-                return
-            self._last_log[entity_path] = now
-
         # apply visual overrides (including final_convert which handles .to_rerun())
         rerun_data: RerunData | None = self._visual_override_for_entity_path(entity_path)(msg)
 
@@ -286,7 +274,6 @@ def start(self) -> None:
 
         super().start()
 
-        self._last_log.clear()
         logger.info("Rerun bridge starting", viewer_mode=self.config.viewer_mode)
 
         # Initialize and spawn Rerun viewer
@@ -357,16 +344,12 @@ def run_bridge(
     """Start a RerunBridgeModule with default LCM config and block until interrupted."""
     import signal
 
-    from dimos.protocol.service.lcmservice import autoconf
-
-    autoconf(check_only=True)
-
     bridge = RerunBridgeModule(
         viewer_mode=viewer_mode,
         memory_limit=memory_limit,
         # any pubsub that supports subscribe_all and topic that supports str(topic)
         # is acceptable here
-        pubsubs=[LCM()],
+        pubsubs=[LCM(autoconf=True)],
     )
 
     bridge.start()