From f2b8a5d541389e3b7ffc41176615623c64c62a8b Mon Sep 17 00:00:00 2001 From: kshitijk4poor <82637225+kshitijk4poor@users.noreply.github.com> Date: Thu, 2 Jul 2026 12:44:07 +0530 Subject: [PATCH] test(gateway): assert _record_gateway_session_peer fires only on the persisted split MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The fake _SessionStore tracked peer_records but no test read it, leaving #55300's peer-record behavior unasserted. Add a positive assertion on the persist path and negative (== []) assertions on the two stale/moved-binding skip paths, so the peer-record side effect is bound. Mutation-verified: removing the production _record_gateway_session_peer call makes the positive assertion fail. Co-authored-by: João Vitor Cunha --- tests/gateway/test_compression_failure_session_sync.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/tests/gateway/test_compression_failure_session_sync.py b/tests/gateway/test_compression_failure_session_sync.py index d24021a0f03..0cfd4f076f1 100644 --- a/tests/gateway/test_compression_failure_session_sync.py +++ b/tests/gateway/test_compression_failure_session_sync.py @@ -170,6 +170,10 @@ def test_failed_turn_still_syncs_compression_session_split(monkeypatch): assert result["history_offset"] == 0 assert session_store.entry.session_id == "session-after-compression" assert session_store.save_calls == 1 + # #55300: the child's gateway peer metadata is recorded on the persist path. + assert session_store.peer_records == [ + ("session-after-compression", SESSION_KEY, source) + ] runner._sync_telegram_topic_binding.assert_called_once_with( source, session_store.entry, reason="agent-run-compression" ) @@ -197,6 +201,7 @@ def test_stale_run_does_not_overwrite_new_session_after_compression(monkeypatch) assert result["history_offset"] == 0 assert session_store.entry.session_id == "session-before-compression" assert session_store.save_calls == 0 + assert session_store.peer_records == [] assert getattr(runner._sync_telegram_topic_binding, "call_count") == 0 @@ -222,4 +227,5 @@ def test_session_split_sync_skips_when_binding_already_moved(monkeypatch): assert result["history_offset"] == 0 assert session_store.entry.session_id == "fresh-session-after-new" assert session_store.save_calls == 0 + assert session_store.peer_records == [] assert getattr(runner._sync_telegram_topic_binding, "call_count") == 0