remove temporary event bus recording code

Author: pedjaradenkovic

plain2code.py

@@ -339,48 +339,6 @@ def main():  # noqa: C901
 
     run_state = RunState(spec_filename=args.filename, replay_with=args.replay_with)
 
-    # === TEMP: event bus recording (do not commit) ===
-    import dataclasses as _dc
-    import datetime as _dt
-    import enum as _enum
-    import time as _time
-
-    event_bus._recorded_events = []  # type: ignore[attr-defined]
-    event_bus._recording_started_monotonic = _time.monotonic()  # type: ignore[attr-defined]
-    event_bus._recording_started_wall = _dt.datetime.now().isoformat()  # type: ignore[attr-defined]
-    _orig_publish = event_bus.publish
-
-    def _recording_serialize(o):
-        if _dc.is_dataclass(o) and not isinstance(o, type):
-            return {f.name: _recording_serialize(getattr(o, f.name)) for f in _dc.fields(o)}
-        if isinstance(o, dict):
-            return {str(k): _recording_serialize(v) for k, v in o.items()}
-        if isinstance(o, (list, tuple, set, frozenset)):
-            return [_recording_serialize(v) for v in o]
-        if isinstance(o, _enum.Enum):
-            return o.name
-        if isinstance(o, (str, int, float, bool)) or o is None:
-            return o
-        if hasattr(o, "__dict__"):
-            return {k: _recording_serialize(v) for k, v in vars(o).items() if not k.startswith("_")}
-        return repr(o)
-
-    def _recording_publish(evt, _orig=_orig_publish):
-        now = _time.monotonic()
-        event_bus._recorded_events.append(  # type: ignore[attr-defined]
-            {
-                "wall_clock": _dt.datetime.now().isoformat(),
-                "seconds_since_recording_start": round(now - event_bus._recording_started_monotonic, 4),
-                "seconds_since_render_start": round(now - run_state.last_render_start_timestamp, 4),
-                "event_type": type(evt).__name__,
-                "data": _recording_serialize(evt),
-            }
-        )
-        return _orig(evt)
-
-    event_bus.publish = _recording_publish  # type: ignore[method-assign]
-    # === END TEMP ===
-
     if args.headless:
         # Suppress Rich console output.
         console.quiet = True
@@ -410,27 +368,6 @@ def _recording_publish(evt, _orig=_orig_publish):
             if not isinstance(e, EXPECTED_EXCEPTIONS):
                 exc_info = sys.exc_info()
     finally:
-        # === TEMP: dump event bus recording (do not commit) ===
-        try:
-            import json as _json
-
-            _recording_path = Path(args.filename).parent / f"event_bus_recording_{run_state.render_id}.json"
-            with open(_recording_path, "w") as _rf:
-                _json.dump(
-                    {
-                        "render_id": run_state.render_id,
-                        "spec_filename": args.filename,
-                        "recording_started_wall": getattr(event_bus, "_recording_started_wall", None),
-                        "events": getattr(event_bus, "_recorded_events", []),
-                    },
-                    _rf,
-                    indent=2,
-                    default=str,
-                )
-            console.info(f"Event bus recording saved to {_recording_path}")
-        except Exception as _rec_err:
-            console.error(f"Failed to save event bus recording: {_rec_err}")
-        # === END TEMP ===
         if exc_info:
             dump_crash_logs(args, run_state)
             capture_crash(exc_info, run_state, args)