Deploy OpenClaw PR API

src/slop_farmer/app/pr_search.py

@@ -41,17 +41,16 @@ def format_pr_search_status(result: Mapping[str, Any]) -> str:
 
 
 def format_pr_search_similar(result: Mapping[str, Any]) -> str:
+    query = result.get("query") or {}
+    mode_used = str(query.get("mode_used") or "indexed")
+    source = str(query.get("source") or "active_index")
     lines = [
         f"PR #{result['pr']['pr_number']}: {result['pr']['title']}",
         "",
         f"Active snapshot: {result['snapshot_id']}",
+        f"Lookup: {mode_used} via {source}",
         "",
     ]
-    query = result.get("query") or {}
-    if query.get("mode_used") == "live":
-        source = query.get("source") or "live"
-        lines.insert(3, f"Lookup mode: live via {source}")
-        lines.insert(4, "")
     if not result["similar_prs"]:
         lines.append("No similar PRs found in the active run.")
         return "\n".join(lines)
@@ -96,16 +95,17 @@ def format_pr_search_candidate_clusters(result: Mapping[str, Any]) -> str:
 
 
 def format_pr_search_clusters(result: Mapping[str, Any]) -> str:
+    query = result.get("query") or {}
+    mode_used = str(query.get("mode_used") or "indexed")
+    source = str(query.get("source") or "active_index")
     lines = [
         f"PR #{result['pr']['pr_number']}: cluster context",
         "",
+        f"Lookup: {mode_used} via {source}",
+        "",
+        "Assigned clusters:",
     ]
-    query = result.get("query") or {}
-    if query.get("mode_used") == "live":
-        source = query.get("source") or "live"
-        lines.extend([f"Lookup mode: live via {source}", ""])
     assigned_clusters = result.get("assigned_clusters") or []
-    lines.append("Assigned clusters:")
     if not assigned_clusters:
         lines.append("- none")
     else:

src/slop_farmer/reports/pr_search_service.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import json
-from collections.abc import Iterable
+from collections.abc import Iterable, Mapping
 from contextlib import suppress
 from pathlib import Path
 from typing import Any, Protocol
@@ -195,7 +195,8 @@ def get_pr_search_status(db_path: Path, *, repo: str | None = None) -> dict[str,
     try:
         active_run = resolve_active_run(connection, repo=repo)
         return {
-            **active_run,
+            **_without_json_fields(active_run),
+            "settings": _json_dict(active_run.get("settings_json")),
             "row_counts": get_run_counts(connection, run_id=str(active_run["id"])),
         }
     finally:
@@ -226,7 +227,7 @@ def get_pr_search_similar(
         for row in similar_rows:
             results.append(
                 {
-                    **row,
+                    **_without_json_fields(row),
                     "neighbor_title": _require_document(
                         connection,
                         run_id=run_id,
@@ -268,7 +269,7 @@ def get_pr_search_candidate_clusters(
             evidence = _json_dict(row.get("evidence_json"))
             candidates.append(
                 {
-                    **row,
+                    **_without_json_fields(row),
                     "shared_filenames": _json_list(row.get("shared_filenames_json")),
                     "shared_directories": _json_list(row.get("shared_directories_json")),
                     "evidence": evidence,
@@ -407,11 +408,7 @@ def get_pr_search_cluster(
             "repo": active_run["repo"],
             "snapshot_id": active_run["snapshot_id"],
             "run_id": run_id,
-            "cluster": {
-                **cluster,
-                "shared_filenames": _json_list(cluster.get("shared_filenames_json")),
-                "shared_directories": _json_list(cluster.get("shared_directories_json")),
-            },
+            "cluster": _cluster_summary(cluster),
             "members": members,
         }
     finally:
@@ -758,7 +755,7 @@ def _get_pr_search_clusters_indexed(
             evidence = _json_dict(row.get("evidence_json"))
             candidates.append(
                 {
-                    **row,
+                    **_without_json_fields(row),
                     "shared_filenames": _json_list(row.get("shared_filenames_json")),
                     "shared_directories": _json_list(row.get("shared_directories_json")),
                     "evidence": evidence,
@@ -819,12 +816,16 @@ def _json_float_dict(raw: Any) -> dict[str, float]:
 
 def _cluster_summary(cluster: dict[str, Any]) -> dict[str, Any]:
     return {
-        **cluster,
+        **_without_json_fields(cluster),
         "shared_filenames": _json_list(cluster.get("shared_filenames_json")),
         "shared_directories": _json_list(cluster.get("shared_directories_json")),
     }
 
 
+def _without_json_fields(row: Mapping[str, Any]) -> dict[str, Any]:
+    return {str(key): value for key, value in row.items() if not str(key).endswith("_json")}
+
+
 def _normalize_lookup_mode(mode: str) -> str:
     normalized = mode.strip().lower()
     if normalized not in {"auto", "indexed", "live"}: