From c7c8b89b4e895be3b51fe3443769e5b45b308ad9 Mon Sep 17 00:00:00 2001
From: Ed_ <edwardgz@gmail.com>
Date: Mon, 23 Feb 2026 12:56:57 -0500
Subject: [PATCH] test(conductor): Add integration test for ApiHookClient usage
 in phase completion

---
 tests/test_conductor_api_hook_integration.py | 78 ++++++++++++++++++++
 1 file changed, 78 insertions(+)
 create mode 100644 tests/test_conductor_api_hook_integration.py

diff --git a/tests/test_conductor_api_hook_integration.py b/tests/test_conductor_api_hook_integration.py
new file mode 100644
index 0000000..8b8cace
--- /dev/null
+++ b/tests/test_conductor_api_hook_integration.py
@@ -0,0 +1,78 @@
+import pytest
+from unittest.mock import MagicMock, patch
+import os
+import threading
+import time
+import json
+
+from api_hooks import HookServer
+from api_hook_client import ApiHookClient
+
+@pytest.fixture(scope="module")
+def hook_server_fixture_for_integration():
+    # Mock the 'app' object that HookServer expects
+    mock_app = MagicMock()
+    mock_app.test_hooks_enabled = True # Essential for the server to start
+    mock_app.project = {'name': 'test_project'}
+    mock_app.disc_entries = [{'role': 'user', 'content': 'hello'}]
+    mock_app._pending_gui_tasks = []
+    mock_app._pending_gui_tasks_lock = threading.Lock()
+
+    # Use an ephemeral port (0) to avoid conflicts
+    server = HookServer(mock_app, port=0)
+    server.start()
+
+    time.sleep(0.1) # Wait a moment for the server thread to start and bind
+
+    actual_port = server.server.server_address[1]
+    client_base_url = f"http://127.0.0.1:{actual_port}"
+
+    yield client_base_url, mock_app
+
+    server.stop()
+
+
+def simulate_conductor_phase_completion(client_base_url: str, mock_app: MagicMock, plan_content: str):
+    """
+    Simulates the Conductor agent's logic for phase completion.
+    This function, in the *actual* implementation, will be *my* (the agent's) code.
+    """
+    print(f"Simulating Conductor phase completion. Client base URL: {client_base_url}")
+    # In the actual Conductor implementation, the agent would instantiate ApiHookClient
+    # and call its verification methods.
+    client = ApiHookClient(base_url=client_base_url)
+    
+    # Perform a verification call, for example, get_status
+    try:
+        status = client.get_status()
+        print(f"API Hook Client status response: {status}")
+        if status.get('status') == 'ok':
+            mock_app.verification_successful = True # Simulate success flag
+        else:
+            mock_app.verification_successful = False
+    except Exception as e:
+        print(f"API Hook Client verification failed: {e}")
+        mock_app.verification_successful = False
+
+def test_conductor_integrates_api_hook_client_for_verification(hook_server_fixture_for_integration):
+    """
+    Verify that Conductor's simulated phase completion logic properly integrates
+    and uses the ApiHookClient for verification. This test *should* pass (Green Phase)
+    if the integration in `simulate_conductor_phase_completion` is correct.
+    """
+    client_base_url, mock_app = hook_server_fixture_for_integration
+
+    dummy_plan_content = """
+# Implementation Plan: Test Track
+
+## Phase 1: Initial Setup [checkpoint: abcdefg]
+- [x] Task: Dummy Task 1 [1234567]
+- [ ] Task: Conductor - User Manual Verification 'Phase 1: Initial Setup' (Protocol in workflow.md)
+"""
+    # Reset mock_app's success flag for this test run
+    mock_app.verification_successful = False
+
+    simulate_conductor_phase_completion(client_base_url, mock_app, dummy_plan_content)
+
+    # Assert that the verification was considered successful by the simulated Conductor
+    assert mock_app.verification_successful is True