Deploy OpenClaw PR API

src/slop_farmer/app/pr_search.py

@@ -11,6 +11,7 @@ get_pr_search_similar = pr_search_service.get_pr_search_similar
 get_pr_search_similar_lookup = pr_search_service.get_pr_search_similar_lookup
 get_pr_search_candidate_clusters = pr_search_service.get_pr_search_candidate_clusters
 get_pr_search_clusters = pr_search_service.get_pr_search_clusters
+list_pr_search_clusters = pr_search_service.list_pr_search_clusters
 get_pr_search_cluster = pr_search_service.get_pr_search_cluster
 explain_pr_search_pair = pr_search_service.explain_pr_search_pair
 probe_pr_search_live = pr_search_service.probe_pr_search_live
@@ -151,6 +152,29 @@ def format_pr_search_cluster(result: Mapping[str, Any]) -> str:
     return "\n".join(lines)
 
 
+def format_pr_search_cluster_list(result: Mapping[str, Any]) -> str:
+    lines = [
+        f"Repo: {result['repo']}",
+        f"Active snapshot: {result['snapshot_id']}",
+        "",
+        "Clusters:",
+    ]
+    clusters = result.get("clusters") or []
+    if not clusters:
+        lines.append("- none")
+        return "\n".join(lines)
+    for index, cluster in enumerate(clusters, start=1):
+        lines.append(
+            f"{index}. {cluster['cluster_id']}  representative=PR #{cluster['representative_pr_number']}  "
+            f"size={cluster['cluster_size']} avg={cluster['average_similarity']:.2f}"
+        )
+        if cluster.get("representative_title"):
+            lines.append(f"   {cluster['representative_title']}")
+        if cluster.get("summary"):
+            lines.append(f"   {cluster['summary']}")
+    return "\n".join(lines)
+
+
 def format_pr_search_pair(result: Mapping[str, Any]) -> str:
     pair = result["pair"]
     lines = [

src/slop_farmer/app/pr_search_api.py

@@ -16,6 +16,7 @@ from slop_farmer.reports.pr_search_service import (
     get_pr_search_clusters,
     get_pr_search_similar_lookup,
     get_pr_search_status,
+    list_pr_search_clusters,
     run_pr_search_refresh,
 )
 
@@ -40,6 +41,8 @@ class PrSearchApiSettings:
     similar_limit_max: int = 50
     candidate_limit_default: int = 5
     candidate_limit_max: int = 20
+    cluster_list_limit_default: int = 50
+    cluster_list_limit_max: int = 200
     probe_limit_default: int = 10
     probe_limit_max: int = 25
 
@@ -70,6 +73,8 @@ class PrSearchApiSettings:
             similar_limit_max=_env_int("SIMILAR_LIMIT_MAX", 50),
             candidate_limit_default=_env_int("CANDIDATE_LIMIT_DEFAULT", 5),
             candidate_limit_max=_env_int("CANDIDATE_LIMIT_MAX", 20),
+            cluster_list_limit_default=_env_int("CLUSTER_LIST_LIMIT_DEFAULT", 50),
+            cluster_list_limit_max=_env_int("CLUSTER_LIST_LIMIT_MAX", 200),
             probe_limit_default=_env_int("PROBE_LIMIT_DEFAULT", 10),
             probe_limit_max=_env_int("PROBE_LIMIT_MAX", 25),
         )
@@ -180,6 +185,25 @@ def create_app(settings: PrSearchApiSettings | None = None) -> FastAPI:
         repo_slug = _repo_slug(settings, owner, repo)
         return get_pr_search_cluster(settings.index_path, repo=repo_slug, cluster_id=cluster_id)
 
+    @app.get("/v1/repos/{owner}/{repo}/clusters")
+    async def cluster_list(
+        owner: str,
+        repo: str,
+        request: Request,
+        limit: int | None = None,
+    ) -> dict[str, Any]:
+        settings = request.app.state.settings
+        repo_slug = _repo_slug(settings, owner, repo)
+        return list_pr_search_clusters(
+            settings.index_path,
+            repo=repo_slug,
+            limit=_limit(
+                limit,
+                default=settings.cluster_list_limit_default,
+                maximum=settings.cluster_list_limit_max,
+            ),
+        )
+
     return app
 
 

src/slop_farmer/app/pr_search_client.py

@@ -11,6 +11,7 @@ from typing import Any
 
 from slop_farmer.app.pr_search import (
     format_pr_search_cluster,
+    format_pr_search_cluster_list,
     format_pr_search_clusters,
     format_pr_search_similar,
     format_pr_search_status,
@@ -27,9 +28,10 @@ def build_parser() -> argparse.ArgumentParser:
         epilog=(
             "Examples:\n"
             "  pr-search repo status\n"
-            "  pr-search pr similar 67096\n"
-            "  pr-search pr clusters 67096\n"
-            "  pr-search --json pr similar 67096 --mode live\n"
+            "  pr-search similar 67096\n"
+            "  pr-search clusters 67096\n"
+            "  pr-search cluster list --limit 20\n"
+            "  pr-search --json similar 67096 --mode live\n"
             "  pr-search cluster view pr-scope-123-4\n"
             "  pr-search -R openclaw/openclaw repo status"
         ),
@@ -70,14 +72,7 @@ def build_parser() -> argparse.ArgumentParser:
         description="Show the active indexed snapshot and row counts.",
     )
 
-    pr_parser = subparsers.add_parser(
-        "pr",
-        help="Pull request operations.",
-        description="Pull request operations.",
-    )
-    pr_subparsers = pr_parser.add_subparsers(dest="pr_command", required=True, metavar="SUBCOMMAND")
-
-    similar = pr_subparsers.add_parser(
+    similar = subparsers.add_parser(
         "similar",
         help="Show similar PRs.",
         description="Find similar pull requests for one PR number.",
@@ -91,7 +86,7 @@ def build_parser() -> argparse.ArgumentParser:
         help="Lookup mode. Defaults to auto.",
     )
 
-    clusters = pr_subparsers.add_parser(
+    clusters = subparsers.add_parser(
         "clusters",
         help="Show cluster context for a PR.",
         description="Show assigned and candidate clusters for one PR number.",
@@ -113,6 +108,12 @@ def build_parser() -> argparse.ArgumentParser:
     cluster_subparsers = cluster_parser.add_subparsers(
         dest="cluster_command", required=True, metavar="SUBCOMMAND"
     )
+    cluster_list = cluster_subparsers.add_parser(
+        "list",
+        help="List clusters.",
+        description="List clusters in the active snapshot.",
+    )
+    cluster_list.add_argument("--limit", type=int, default=None, help="Maximum rows to return.")
     cluster_view = cluster_subparsers.add_parser(
         "view",
         help="Inspect one cluster.",
@@ -162,6 +163,13 @@ class PrSearchApiClient:
         owner, name = _split_repo(repo)
         return self._get_json(f"/v1/repos/{owner}/{name}/clusters/{cluster_id}")
 
+    def list_clusters(self, repo: str, *, limit: int | None) -> dict[str, Any]:
+        owner, name = _split_repo(repo)
+        return self._get_json(
+            f"/v1/repos/{owner}/{name}/clusters",
+            params=None if limit is None else {"limit": limit},
+        )
+
     def _get_json(
         self,
         path: str,
@@ -195,31 +203,36 @@ def main(argv: list[str] | None = None) -> None:
             _emit(result, args.json, format_pr_search_status)
             return
 
-        if args.command == "pr":
-            if args.pr_command == "similar":
-                result = client.get_similar(
-                    args.repo,
-                    number=args.number,
-                    limit=args.limit,
-                    mode=args.mode,
-                )
-                _emit(result, args.json, format_pr_search_similar)
-                return
-            if args.pr_command == "clusters":
-                result = client.get_clusters(
-                    args.repo,
-                    number=args.number,
-                    limit=args.limit,
-                    mode=args.mode,
-                )
-                _emit(result, args.json, format_pr_search_clusters)
-                return
+        if args.command == "similar":
+            result = client.get_similar(
+                args.repo,
+                number=args.number,
+                limit=args.limit,
+                mode=args.mode,
+            )
+            _emit(result, args.json, format_pr_search_similar)
+            return
 
-        if args.command == "cluster" and args.cluster_command == "view":
-            result = client.get_cluster(args.repo, cluster_id=args.cluster_id)
-            _emit(result, args.json, format_pr_search_cluster)
+        if args.command == "clusters":
+            result = client.get_clusters(
+                args.repo,
+                number=args.number,
+                limit=args.limit,
+                mode=args.mode,
+            )
+            _emit(result, args.json, format_pr_search_clusters)
             return
 
+        if args.command == "cluster":
+            if args.cluster_command == "list":
+                result = client.list_clusters(args.repo, limit=args.limit)
+                _emit(result, args.json, format_pr_search_cluster_list)
+                return
+            if args.cluster_command == "view":
+                result = client.get_cluster(args.repo, cluster_id=args.cluster_id)
+                _emit(result, args.json, format_pr_search_cluster)
+                return
+
         raise RuntimeError("unsupported command")
     except RuntimeError as exc:
         print(f"error: {exc}", file=sys.stderr)

src/slop_farmer/reports/pr_search_service.py

@@ -418,6 +418,44 @@ def get_pr_search_cluster(
         connection.close()
 
 
+def list_pr_search_clusters(
+    db_path: Path,
+    *,
+    repo: str | None = None,
+    limit: int = 50,
+) -> dict[str, Any]:
+    connection = connect_pr_search_db(db_path, read_only=True)
+    try:
+        active_run = resolve_active_run(connection, repo=repo)
+        run_id = str(active_run["id"])
+        rows = fetch_rows(
+            connection,
+            """
+            SELECT
+                cl.*,
+                d.title AS representative_title,
+                d.html_url AS representative_html_url,
+                d.state AS representative_state,
+                d.draft AS representative_draft
+            FROM pr_scope_clusters AS cl
+            LEFT JOIN pr_search_documents AS d
+              ON d.run_id = cl.run_id AND d.pr_number = cl.representative_pr_number
+            WHERE cl.run_id = ?
+            ORDER BY cl.cluster_size DESC, cl.average_similarity DESC, cl.cluster_id
+            LIMIT ?
+            """,
+            [run_id, limit],
+        )
+        return {
+            "repo": active_run["repo"],
+            "snapshot_id": active_run["snapshot_id"],
+            "run_id": run_id,
+            "clusters": [_cluster_summary(row) for row in rows],
+        }
+    finally:
+        connection.close()
+
+
 def explain_pr_search_pair(
     db_path: Path,
     *,