Add debugging for agent conversation in /tmp/conversation.log

Signed-off-by: Swarup Ghosh <swghosh@redhat.com>

Author: swghosh

server/server.py

@@ -9,12 +9,12 @@
     GET /api-implement?ep_url=<enhancement-pr-url>&cwd=<operator-repo-path>
 """
 
+import json
+import logging
 import os
 import re
-import json
+import traceback
 from pathlib import Path
-
-import anyio
 from fastapi import FastAPI, HTTPException, Query
 from claude_agent_sdk import (
     query,
@@ -46,6 +46,14 @@
 PLUGIN_DIR = str(Path(__file__).resolve().parent.parent / "plugins" / "oape")
 print(PLUGIN_DIR)
 
+CONVERSATION_LOG = Path("/tmp/conversation.log")
+
+conv_logger = logging.getLogger("conversation")
+conv_logger.setLevel(logging.INFO)
+_handler = logging.FileHandler(CONVERSATION_LOG)
+_handler.setFormatter(logging.Formatter("%(message)s"))
+conv_logger.addHandler(_handler)
+
 
 @app.get("/api-implement")
 async def api_implement(
@@ -94,27 +102,42 @@ async def api_implement(
 
     # --- Run the agent ---
     output_parts: list[str] = []
+    conversation: list[dict] = []
     cost_usd = 0.0
 
+    def _log(role: str, content, **extra):
+        entry = {"role": role, "content": content, **extra}
+        conversation.append(entry)
+        conv_logger.info(f"[{role}] {content}")
+
+    conv_logger.info(f"\n{'=' * 60}\n[request] ep_url={ep_url}  cwd={working_dir}\n{'=' * 60}")
+
     try:
         async for message in query(
             prompt=f"/oape:api-implement {ep_url}",
-            # prompt="explain the enhancement proposal to me like I'm 5 in 10 sentences, {ep_url}",
             options=options,
         ):
             if isinstance(message, AssistantMessage):
                 for block in message.content:
                     if isinstance(block, TextBlock):
                         output_parts.append(block.text)
+                        _log("assistant", block.text)
+                    else:
+                        _log(f"assistant:{type(block).__name__}",
+                             json.dumps(getattr(block, "__dict__", str(block)), default=str))
             elif isinstance(message, ResultMessage):
                 cost_usd = message.total_cost_usd
                 if message.result:
                     output_parts.append(message.result)
+                _log("result", message.result, cost_usd=cost_usd)
+            else:
+                _log(type(message).__name__,
+                     json.dumps(getattr(message, "__dict__", str(message)), default=str))
     except Exception as exc:
-        raise HTTPException(
-            status_code=500,
-            detail=f"Agent execution failed: {exc}",
-        )
+        conv_logger.info(f"[error] {traceback.format_exc()}")
+        raise HTTPException(status_code=500, detail=f"Agent execution failed: {exc}")
+
+    conv_logger.info(f"[done] cost=${cost_usd:.4f}  parts={len(output_parts)}\n")
 
     return {
         "status": "success",