diff --git a/tests/test_new_serve_stack.py b/tests/test_new_serve_stack.py index 140a8a3..c14f2b0 100644 --- a/tests/test_new_serve_stack.py +++ b/tests/test_new_serve_stack.py @@ -49,6 +49,14 @@ def tracker(self): def test_empty_ingest_returns_empty(self, tracker): assert tracker.ingest({"type": "unknown"}) == [{"type": "unknown"}] + @pytest.mark.parametrize("event_type", [ + "plugin.added", + "connector.updated", + "reference.updated", + ]) + def test_bootstrap_lifecycle_events_silently_dropped(self, tracker, event_type): + assert tracker.ingest({"type": event_type, "properties": {"id": "test"}}) == [] + def test_delta_accumulates_text(self, tracker): tracker.ingest({ "type": "message.part.delta", diff --git a/tools/events/state_tracker.py b/tools/events/state_tracker.py index c083fb9..7eae384 100644 --- a/tools/events/state_tracker.py +++ b/tools/events/state_tracker.py @@ -112,7 +112,9 @@ def ingest(self, event: dict[str, Any]) -> list[dict[str, Any]]: mapped = self._map_session_diff(event) return [mapped] if mapped else [] - if event_type == "session.updated": + if event_type in ("session.updated", + "plugin.added", "connector.updated", + "reference.updated"): return [] # Pass-through events that don't need accumulation.