From 82c64f2bb6e3d73f9f4e256c1cd5a67a20d655ac Mon Sep 17 00:00:00 2001 From: LoopX Agent <337587101+loopx-agent@users.noreply.github.com> Date: Sun, 18 Oct 2026 18:14:14 +0800 Subject: [PATCH] test(chat): wire session recovery into amendment HTTP fixtures Signed-off-by: LoopX Agent <337587101+loopx-agent@users.noreply.github.com> --- tests/control_plane/test_chat_goal_amendment.py | 8 ++++++++ tests/control_plane/test_chat_request_control.py | 4 +--- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/tests/control_plane/test_chat_goal_amendment.py b/tests/control_plane/test_chat_goal_amendment.py index b88650e8be..4c1a144571 100644 --- a/tests/control_plane/test_chat_goal_amendment.py +++ b/tests/control_plane/test_chat_goal_amendment.py @@ -10,7 +10,9 @@ import pytest from test_goal_amendment_authority import source_goal, _root # noqa: F401 +from loopx.chat_runtime import ChatRuntimeController from loopx.chat_server import ChatHTTPServer, ChatRequestHandler +from loopx.chat_store import ChatSessionStore from loopx.control_plane.effect_runtime import restart_effect_runtime @@ -20,6 +22,11 @@ def api(source_goal, tmp_path): # noqa: F811 - pytest fixture imported above. server.registry_path = source_goal["registry"] server.runtime_root = source_goal["runtime"] server.runtime_root_override = str(source_goal["runtime"]) + server.chat_store = ChatSessionStore(source_goal["runtime"]) + server.runtime_controller = ChatRuntimeController( + store=server.chat_store, codex_bin="unused-fixture-codex", + registry_path=source_goal["registry"], + ) server.selected_goal_id = source_goal["ref"]["goal_id"] server.verbose = False thread = threading.Thread(target=server.serve_forever, daemon=True) @@ -47,6 +54,7 @@ def call(body=None, *, query=None, path=None, origin=None): server.shutdown() thread.join(5) server.server_close() + server.runtime_controller.close() restart_effect_runtime() diff --git a/tests/control_plane/test_chat_request_control.py b/tests/control_plane/test_chat_request_control.py index abfeb00618..df7c9d8363 100644 --- a/tests/control_plane/test_chat_request_control.py +++ b/tests/control_plane/test_chat_request_control.py @@ -6,13 +6,11 @@ from test_goal_amendment_authority import source_goal as source_goal from test_request_amendment_recovery import BRIEF from loopx.capabilities.manager_context import deliver -from loopx.chat_store import ChatSessionStore def _source(api): call, f, server = api - store = ChatSessionStore(f["runtime"]) - server.chat_store = store + store = server.chat_store session = store.create_session(goal_id="loopx-manager", agent_id="codex", adapter_kind="codex_app_server", upstream_thread_id="request-control-fixture", channel_id="manager") turn, _ = store.create_turn(session["session_id"], client_turn_id="request-source", message="Check the current contract", origin="web")