| """ |
| `dw review` command. |
| Interactive Human Review Wizard for knowledge proposals. |
| """ |
| from __future__ import annotations |
|
|
| from typing import Optional |
| import typer |
| from rich.prompt import Prompt |
| from rich.panel import Panel |
|
|
| from diffweave.cli.config import get_active_workspace |
| from diffweave.cli.output import print_success, print_error, print_info, console |
| from diffweave.mcp.client import DiffWeaveMCPClient |
|
|
|
|
| def review_command( |
| proposal_id: Optional[str] = typer.Option(None, "--proposal", "-p", help="Target specific proposal UUID"), |
| action: Optional[str] = typer.Option(None, "--action", "-a", help="Direct action: approve, reject, archive"), |
| comments: Optional[str] = typer.Option(None, "--comments", "-m", help="Review comments / commit note"), |
| workspace_id: Optional[str] = typer.Option(None, "--workspace", "-w", help="Workspace UUID override"), |
| interactive: bool = typer.Option(True, "--interactive/--no-interactive", help="Enable interactive wizard"), |
| ): |
| """ |
| Review pending knowledge proposals (Approve into truth, Reject, or Stash). |
| """ |
| try: |
| active_ws_id = get_active_workspace(workspace_id) |
| except Exception as e: |
| print_error(str(e)) |
| raise typer.Exit(code=1) |
|
|
| client = DiffWeaveMCPClient() |
|
|
| |
| if proposal_id and action: |
| act = action.strip().lower() |
| try: |
| if act == "approve": |
| res = client.call_tool_sync("approve_proposal", {"proposal_id": proposal_id, "comments": comments}) |
| print_success(f"Proposal [bold]{proposal_id}[/bold] APPROVED. Commit ID: [cyan]{res.get('commit_id')}[/cyan]") |
| elif act == "reject": |
| res = client.call_tool_sync("reject_proposal", {"proposal_id": proposal_id, "comments": comments}) |
| print_info(f"Proposal [bold]{proposal_id}[/bold] REJECTED. (No commit created)") |
| elif act in ("archive", "stash"): |
| res = client.call_tool_sync("archive_proposal", {"proposal_id": proposal_id, "comments": comments}) |
| print_info(f"Proposal [bold]{proposal_id}[/bold] ARCHIVED / STASHED for later review.") |
| else: |
| print_error(f"Unknown action '{action}'. Use approve, reject, or archive.") |
| raise typer.Exit(code=1) |
| return |
| except Exception as e: |
| print_error(f"Review action failed: {e}") |
| raise typer.Exit(code=1) |
|
|
| |
| try: |
| pending = client.call_tool_sync("list_pending_proposals", {"workspace_id": active_ws_id}) |
| except Exception as e: |
| print_error(f"Failed to fetch proposals: {e}") |
| raise typer.Exit(code=1) |
|
|
| if proposal_id: |
| pending = [p for p in pending if str(p.get("proposal_id", "")).startswith(proposal_id.strip())] |
|
|
| if not pending: |
| print_success("Review queue is clean! No pending proposals awaiting review.") |
| return |
|
|
| console.print(f"[bold cyan]DiffWeave Review Wizard[/bold cyan] ({len(pending)} pending proposals)\n") |
|
|
| for idx, p in enumerate(pending, 1): |
| pid = p.get("proposal_id") |
| pc = p.get("proposed_changes", {}) |
| evidence_list = pc.get("evidence", []) |
| evidence_quote = evidence_list[0].get("quote", "None cited") if evidence_list else "None cited" |
| page = evidence_list[0].get("page_number", "N/A") if evidence_list else "N/A" |
| prop_val = pc.get("value") or pc.get("proposed", {}).get("value", "N/A") |
|
|
| body = ( |
| f"[bold white]Summary:[/bold white] {p.get('summary')}\n" |
| f"[bold white]Type:[/bold white] [cyan]{p.get('proposal_type')}[/cyan] | " |
| f"[bold white]Confidence:[/bold white] {pc.get('confidence') or pc.get('proposed', {}).get('confidence', 1.0)}\n" |
| f"[bold white]Proposed Value:[/bold white] \"{prop_val}\"\n" |
| f"[bold white]Verbatim Evidence (Page {page}):[/bold white]\n" |
| f" [italic cyan]\"{evidence_quote}\"[/italic cyan]" |
| ) |
| console.print(Panel(body, title=f"Review [{idx}/{len(pending)}] — PR {pid[:8]}", border_style="cyan")) |
|
|
| choice = Prompt.ask( |
| "Decision", |
| choices=["a", "r", "s", "q", "skip"], |
| default="a", |
| show_choices=False, |
| show_default=False, |
| ) |
|
|
| if choice in ("q", "quit"): |
| console.print("[dim]Review session stopped.[/dim]") |
| break |
| elif choice in ("skip", "s"): |
| if choice == "s": |
| client.call_tool_sync("archive_proposal", {"proposal_id": pid}) |
| print_info(f"PR {pid[:8]} stashed/archived.") |
| continue |
| elif choice == "a": |
| note = Prompt.ask("Commit message / comment (optional)", default="") |
| try: |
| res = client.call_tool_sync("approve_proposal", {"proposal_id": pid, "comments": note or None}) |
| print_success(f"PR {pid[:8]} APPROVED. Commit ID: [cyan]{res.get('commit_id')}[/cyan]\n") |
| except Exception as e: |
| print_error(f"Approval failed: {e}\n") |
| elif choice == "r": |
| reason = Prompt.ask("Rejection reason (optional)", default="") |
| try: |
| client.call_tool_sync("reject_proposal", {"proposal_id": pid, "comments": reason or None}) |
| print_info(f"PR {pid[:8]} REJECTED.\n") |
| except Exception as e: |
| print_error(f"Rejection failed: {e}\n") |
|
|
