fix(cli): fix project context set JSON/YAML output structure (#6319)

Implemented spec-compliant JSON, YAML, plain, and rich outputs for `agents project context set`. Added BDD coverage verifying the new output structure across formats.\n\nISSUES CLOSED: #6319

docs/specification.md

@@ -3904,7 +3904,9 @@ Set the context policy for a project and (optionally) a specific view.
       "timing": {
         "duration_ms": 42
       },
-      "messages": ["Context policy updated"]
+      "messages": [
+        {"level": "ok", "text": "Context policy updated"}
+      ]
     }
     ```
 
@@ -3939,7 +3941,8 @@ Set the context policy for a project and (optionally) a specific view.
     timing:
       duration_ms: 42
     messages:
-      - Context policy updated
+      - level: ok
+        text: Context policy updated
     ```
 
 ###### agents project context show
@@ -4064,7 +4067,9 @@ Show the active context policy for a project.
       "timing": {
         "duration_ms": 38
       },
-      "messages": ["Context policy loaded"]
+      "messages": [
+        {"level": "ok", "text": "Context policy loaded"}
+      ]
     }
     ```
 
@@ -4103,7 +4108,8 @@ Show the active context policy for a project.
     timing:
       duration_ms: 38
     messages:
-      - Context policy loaded
+      - level: ok
+        text: Context policy loaded
     ```
 
 ###### agents project context inspect
@@ -4252,7 +4258,9 @@ Inspect the current state of the ACMS context assembly for a project. Shows the
       "timing": {
         "duration_ms": 185
       },
-      "messages": ["Context inspection complete"]
+      "messages": [
+        {"level": "ok", "text": "Context inspection complete"}
+      ]
     }
     ```
 
@@ -4319,7 +4327,8 @@ Inspect the current state of the ACMS context assembly for a project. Shows the
     timing:
       duration_ms: 185
     messages:
-      - Context inspection complete
+      - level: ok
+        text: Context inspection complete
     ```
 
 ###### agents project context simulate
@@ -4483,7 +4492,12 @@ Simulate a context assembly run without invoking an actor. Produces a dry-run re
       "timing": {
         "duration_ms": 310
       },
-      "messages": ["Simulation complete (dry run -- no context was assembled)"]
+      "messages": [
+        {
+          "level": "ok",
+          "text": "Simulation complete (dry run -- no context was assembled)"
+        }
+      ]
     }
     ```
 
@@ -4551,7 +4565,8 @@ Simulate a context assembly run without invoking an actor. Produces a dry-run re
     timing:
       duration_ms: 310
     messages:
-      - "Simulation complete (dry run -- no context was assembled)"
+      - level: ok
+        text: Simulation complete (dry run -- no context was assembled)
     ```
 
 #### agents actor

features/project_context_cli.feature

@@ -112,3 +112,18 @@ Feature: Project context CLI commands (B2.cli)
     When I run context show on "local/ctx-app" with format "json"
     Then the context show command should succeed
     And the context output should be valid JSON
+
+  Scenario: Context set JSON output matches spec structure
+    When I run context set spec example on "local/ctx-app" with format "json"
+    Then the context set command should succeed
+    And the context set JSON output should match the spec envelope
+
+  Scenario: Context set YAML output matches spec structure
+    When I run context set spec example on "local/ctx-app" with format "yaml"
+    Then the context set command should succeed
+    And the context set YAML output should match the spec envelope
+
+  Scenario: Context set rich output matches spec presentation
+    When I run context set spec example on "local/ctx-app" with format "rich"
+    Then the context set command should succeed
+    And the context set rich output should include spec panels

features/steps/project_context_cli_steps.py

@@ -7,6 +7,7 @@ CLI commands using an in-memory SQLite database.
 from __future__ import annotations
 
 import json
+import yaml
 from io import StringIO
 from typing import Any
 from unittest.mock import MagicMock, patch
@@ -139,7 +140,7 @@ def _run_with_container(context: Any, func: Any, *args: Any, **kwargs: Any) -> N
         soft_wrap=True,
     )
 
-    def _test_format_output(data, format_type):
+    def _test_format_output(data, format_type, *args, **kwargs):
         import sys as _sys
         from io import StringIO as _SIO
 
@@ -149,7 +150,7 @@ def _run_with_container(context: Any, func: Any, *args: Any, **kwargs: Any) -> N
         _old = _sys.stdout
         _sys.stdout = _b
         try:
-            _r = _fo(data, format_type)
+            _r = _fo(data, format_type, *args, **kwargs)
         finally:
             _sys.stdout = _old
         return _r or _b.getvalue().rstrip("\n")
@@ -255,6 +256,31 @@ def step_ctx_set_exclude_path(context: Any, project: str, view: str, path: str)
     )
 
 
+@when('I run context set spec example on "{project}" with format "{fmt}"')
+def step_ctx_set_spec_example(context: Any, project: str, fmt: str) -> None:
+    from cleveragents.cli.commands.project_context import (
+        context_set,
+    )
+
+    _run_with_container(
+        context,
+        context_set,
+        project=project,
+        view="strategize",
+        include_resource=["repo"],
+        exclude_path=["**/node_modules/**"],
+        hot_max_tokens=12_000,
+        warm_max_decisions=50,
+        cold_max_decisions=200,
+        query_limit=20,
+        max_file_size=1_048_576,
+        max_total_size=50 * 1_048_576,
+        summarize=True,
+        summary_max_tokens=800,
+        output_format=fmt,
+    )
+
+
 @when('I run context set on "{project}" with view "{view}" and max-file-size {size:d}')
 def step_ctx_set_max_file_size(
     context: Any, project: str, view: str, size: int
@@ -462,6 +488,114 @@ def step_ctx_set_fail(context: Any) -> None:
     )
 
 
+@then("the context set JSON output should match the spec envelope")
+def step_ctx_set_json_spec(context: Any) -> None:
+    output = context.ctx_output.strip()
+    assert output, "No CLI output captured"
+    payload = json.loads(output)
+
+    assert payload.get("command") == "project context set"
+    assert payload.get("status") == "ok"
+    assert payload.get("exit_code") == 0
+
+    timing = payload.get("timing", {})
+    assert isinstance(timing.get("duration_ms"), int)
+
+    messages = payload.get("messages", [])
+    assert messages and messages[0].get("text") == "Context policy updated"
+
+    data = payload.get("data", {})
+
+    context_policy = data.get("context_policy", {})
+    assert context_policy.get("project") == "local/ctx-app"
+    assert context_policy.get("view") == "strategize"
+    assert context_policy.get("include_resources") == ["repo"]
+    assert context_policy.get("exclude_paths") == ["**/node_modules/**"]
+
+    limits = data.get("limits", {})
+    assert limits.get("hot_max_tokens") == 12_000
+    assert limits.get("warm_max_decisions") == 50
+    assert limits.get("cold_max_decisions") == 200
+    assert limits.get("query_limit") == 20
+    assert limits.get("max_file_size") == "1 MB"
+    assert limits.get("max_total_size") == "50 MB"
+
+    summarization = data.get("summarization", {})
+    assert summarization.get("enabled") is True
+    assert summarization.get("max_tokens") == 800
+
+    other_views = data.get("other_views", {})
+    assert other_views.get("default") == "(unset)"
+    assert other_views.get("execute") == "(default)"
+    assert other_views.get("apply") == "(default)"
+
+
+@then("the context set YAML output should match the spec envelope")
+def step_ctx_set_yaml_spec(context: Any) -> None:
+    output = context.ctx_output.strip()
+    assert output, "No CLI output captured"
+    payload = yaml.safe_load(output)
+
+    assert payload.get("command") == "project context set"
+    assert payload.get("status") == "ok"
+    assert payload.get("exit_code") == 0
+
+    timing = payload.get("timing", {})
+    assert isinstance(timing.get("duration_ms"), int)
+
+    messages = payload.get("messages", [])
+    assert messages and messages[0].get("text") == "Context policy updated"
+
+    data = payload.get("data", {})
+    context_policy = data.get("context_policy", {})
+    assert context_policy.get("project") == "local/ctx-app"
+    assert context_policy.get("view") == "strategize"
+    assert context_policy.get("include_resources") == ["repo"]
+    assert context_policy.get("exclude_paths") == ["**/node_modules/**"]
+
+    limits = data.get("limits", {})
+    assert limits.get("hot_max_tokens") == 12_000
+    assert limits.get("warm_max_decisions") == 50
+    assert limits.get("cold_max_decisions") == 200
+    assert limits.get("query_limit") == 20
+    assert limits.get("max_file_size") == "1 MB"
+    assert limits.get("max_total_size") == "50 MB"
+
+    summarization = data.get("summarization", {})
+    assert summarization.get("enabled") is True
+    assert summarization.get("max_tokens") == 800
+
+    other_views = data.get("other_views", {})
+    assert other_views.get("default") == "(unset)"
+    assert other_views.get("execute") == "(default)"
+    assert other_views.get("apply") == "(default)"
+
+
+@then("the context set rich output should include spec panels")
+def step_ctx_set_rich_spec(context: Any) -> None:
+    output = context.ctx_output
+    assert "Context Policy" in output
+    assert "Limits" in output
+    assert "Summarization" in output
+    assert "Other Views" in output
+    assert "Project: local/ctx-app" in output
+    assert "View: strategize" in output
+    assert "Include: repo" in output
+    assert "Exclude: **/node_modules/**" in output
+    assert "Hot Tokens: 12000 (soft cap)" in output
+    assert "Warm Decisions: 50" in output
+    assert "Cold Decisions: 200" in output
+    assert "Query Limit: 20" in output
+    assert "Max File Size: 1 MB" in output
+    assert "Max Total Size: 50 MB" in output
+    assert "Enabled: yes" in output
+    assert "Max Tokens: 800" in output
+    assert "default: (unset)" in output
+    assert "execute: (default)" in output
+    assert "apply: (default)" in output
+    assert "✓ Context policy updated" in output
+
+
 @then("the context show command should succeed")
 def step_ctx_show_ok(context: Any) -> None:
     assert context.ctx_exit_code == 0, (

src/cleveragents/cli/commands/project_context.py

@@ -23,7 +23,7 @@ from __future__ import annotations
 import contextlib
 import hashlib
 import json as _json
-from typing import Annotated, Any
+from typing import Annotated, Any, cast
 
 import typer
 from rich.console import Console
@@ -34,6 +34,11 @@ from cleveragents.application.services.context_phase_analysis import (
     analyze_phase_summaries,
 )
 from cleveragents.cli.formatting import OutputFormat, format_output
+from cleveragents.cli.rendering.project_context_set import (
+    build_context_set_payload,
+    render_context_set_plain,
+    render_context_set_rich,
+)
 from cleveragents.domain.models.acms.crp import (
     AssembledContext,
     ContextFragment,
@@ -108,7 +113,7 @@ def _load_policy_json(
         ).fetchone()
         if row is None or row[0] is None:
             return None
-        return _json.loads(row[0])  # type: ignore[no-any-return]
+        return cast(dict[str, Any], _json.loads(row[0]))
     finally:
         session.close()
 
@@ -742,20 +747,41 @@ def context_set(
             },
         )
 
-    data = _policy_to_dict(policy)
-    data["acms_config"] = acms
-    if output_format.lower() == OutputFormat.RICH:
-        console.print(
-            Panel(
-                f"[green]✓[/green] Context policy "
-                f"'{view}' view updated for "
-                f"project '{project}'.",
-                title="Context Policy Updated",
-                expand=False,
-            )
-        )
-    else:
-        console.print(format_output(data, output_format))
+    payload = build_context_set_payload(
+        project,
+        view,
+        policy,
+        acms,
+        default_limits={
+            "hot_max_tokens": _DEFAULT_HOT_MAX_TOKENS,
+            "warm_max_decisions": _DEFAULT_WARM_MAX_DECISIONS,
+            "cold_max_decisions": _DEFAULT_COLD_MAX_DECISIONS,
+            "query_limit": None,
+        },
+    )
+    fmt = output_format.lower()
+    message_text = "Context policy updated"
+
+    if fmt == OutputFormat.RICH.value:
+        for panel in render_context_set_rich(payload):
+            console.print(panel)
+        console.print(f"[green]✓[/green] {message_text}")
+        return
+
+    if fmt == OutputFormat.PLAIN.value:
+        console.print(render_context_set_plain(payload, message_text))
+        return
+
+    rendered = format_output(
+        payload,
+        output_format,
+        command="project context set",
+        status="ok",
+        exit_code=0,
+        messages=[{"level": "ok", "text": message_text}],
+    )
+    if rendered:
+        console.print(rendered)
 
 
 @app.command(name="show")

src/cleveragents/cli/rendering/__init__.py

@@ -0,0 +1,13 @@
+"""Rendering helpers for CLI commands."""
+
+from .project_context_set import (  # noqa: F401
+    build_context_set_payload,
+    render_context_set_plain,
+    render_context_set_rich,
+)
+
+__all__ = [
+    "build_context_set_payload",
+    "render_context_set_plain",
+    "render_context_set_rich",
+]

src/cleveragents/cli/rendering/project_context_set.py

@@ -0,0 +1,209 @@
+"""Rendering helpers for ``agents project context set`` output."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from rich.panel import Panel
+
+from cleveragents.domain.models.core.context_policy import (
+    ContextView,
+    ProjectContextPolicy,
+)
+
+
+__all__ = [
+    "build_context_set_payload",
+    "render_context_set_plain",
+    "render_context_set_rich",
+]
+
+
+def _format_size(value: int | None) -> str:
+    """Render byte sizes using binary units with whole numbers."""
+
+    if value is None:
+        return "(no limit)"
+
+    units = [
+        ("TB", 1024**4),
+        ("GB", 1024**3),
+        ("MB", 1024**2),
+        ("KB", 1024),
+    ]
+    for unit, factor in units:
+        if value % factor == 0:
+            return f"{value // factor} {unit}"
+    return f"{value} bytes"
+
+
+def _format_inline_list(values: list[str], empty_placeholder: str) -> str:
+    """Join a list into a comma-separated string with a placeholder for empty."""
+
+    return ", ".join(values) if values else empty_placeholder
+
+
+def _is_view_default(view: ContextView) -> bool:
+    """Determine whether a view matches the default configuration."""
+
+    default_view = ContextView()
+    return view.model_dump(mode="json") == default_view.model_dump(mode="json")
+
+
+def _view_status(policy: ProjectContextPolicy, phase: str) -> str:
+    """Summarise configuration state for a phase view."""
+
+    if phase == "default":
+        return "(unset)" if _is_view_default(policy.default_view) else "configured"
+
+    view_obj = getattr(policy, f"{phase}_view")
+    return "(default)" if view_obj is None else "configured"
+
+
+def build_context_set_payload(
+    project: str,
+    view: str,
+    policy: ProjectContextPolicy,
+    acms: dict[str, Any],
+    *,
+    default_limits: dict[str, int | None],
+) -> dict[str, Any]:
+    """Construct the structured payload for the context-set command."""
+
+    resolved_view = policy.resolve_view(view)
+    context_policy = {
+        "project": project,
+        "view": view,
+        "include_resources": resolved_view.include_resources,
+        "exclude_resources": resolved_view.exclude_resources,
+        "include_paths": resolved_view.include_paths,
+        "exclude_paths": resolved_view.exclude_paths,
+    }
+
+    limits = {
+        "hot_max_tokens": acms.get(
+            "hot_max_tokens", default_limits.get("hot_max_tokens")
+        ),
+        "warm_max_decisions": acms.get(
+            "warm_max_decisions", default_limits.get("warm_max_decisions")
+        ),
+        "cold_max_decisions": acms.get(
+            "cold_max_decisions", default_limits.get("cold_max_decisions")
+        ),
+        "query_limit": acms.get("query_limit", default_limits.get("query_limit")),
+        "max_file_size": _format_size(resolved_view.max_file_size),
+        "max_total_size": _format_size(resolved_view.max_total_size),
+    }
+
+    summarization = {
+        "enabled": bool(acms.get("summarize", True)),
+        "max_tokens": acms.get("summary_max_tokens"),
+    }
+
+    phase_order = ["default", "strategize", "execute", "apply"]
+    other_views = {
+        phase: _view_status(policy, phase) for phase in phase_order if phase != view
+    }
+
+    return {
+        "context_policy": context_policy,
+        "limits": limits,
+        "summarization": summarization,
+        "other_views": other_views,
+    }
+
+
+def render_context_set_plain(payload: dict[str, Any], message: str) -> str:
+    """Render the spec-aligned plain text output for context-set."""
+
+    context_policy = payload["context_policy"]
+    limits = payload["limits"]
+    summarization = payload["summarization"]
+    other_views = payload["other_views"]
+
+    sections: list[str] = []
+
+    cp_lines = [
+        "Context Policy",
+        f"  Project: {context_policy['project']}",
+        f"  View: {context_policy['view']}",
+        "  Include: "
+        f"{_format_inline_list(context_policy['include_resources'], '(all)')}",
+        f"  Exclude: {_format_inline_list(context_policy['exclude_paths'], '(none)')}",
+    ]
+    sections.append("\n".join(cp_lines))
+
+    limits_lines = [
+        "Limits",
+        f"  Hot Tokens: {limits['hot_max_tokens']} (soft cap)",
+        f"  Warm Decisions: {limits['warm_max_decisions']}",
+        f"  Cold Decisions: {limits['cold_max_decisions']}",
+    ]
+    query_limit = limits["query_limit"]
+    limits_lines.append(
+        f"  Query Limit: {query_limit if query_limit is not None else '(default)'}"
+    )
+    limits_lines.append(f"  Max File Size: {limits['max_file_size']}")
+    limits_lines.append(f"  Max Total Size: {limits['max_total_size']}")
+    sections.append("\n".join(limits_lines))
+
+    summarization_lines = [
+        "Summarization",
+        f"  Enabled: {'yes' if summarization['enabled'] else 'no'}",
+        "  Max Tokens: "
+        f"{summarization['max_tokens'] if summarization['max_tokens'] is not None else '(default)'}",
+    ]
+    sections.append("\n".join(summarization_lines))
+
+    other_view_lines = ["Other Views"]
+    for phase, status in other_views.items():
+        other_view_lines.append(f"  {phase}: {status}")
+    sections.append("\n".join(other_view_lines))
+
+    return "\n\n".join(sections) + f"\n\n[OK] {message}"
+
+
+def render_context_set_rich(payload: dict[str, Any]) -> list[Panel]:
+    """Build Rich panels matching the specification."""
+
+    context_policy = payload["context_policy"]
+    limits = payload["limits"]
+    summarization = payload["summarization"]
+    other_views = payload["other_views"]
+
+    cp_lines = [
+        f"[cyan bold]Project:[/cyan bold] {context_policy['project']}",
+        f"[blue bold]View:[/blue bold] {context_policy['view']}",
+        "[green bold]Include:[/green bold] "
+        f"{_format_inline_list(context_policy['include_resources'], '(all)')}",
+        "[yellow bold]Exclude:[/yellow bold] "
+        f"{_format_inline_list(context_policy['exclude_paths'], '(none)')}",
+    ]
+
+    limits_lines = [
+        f"[magenta bold]Hot Tokens:[/magenta bold] {limits['hot_max_tokens']} (soft cap)",
+        f"[magenta bold]Warm Decisions:[/magenta bold] {limits['warm_max_decisions']}",
+        f"[magenta bold]Cold Decisions:[/magenta bold] {limits['cold_max_decisions']}",
+        f"[blue bold]Query Limit:[/blue bold] "
+        f"{limits['query_limit'] if limits['query_limit'] is not None else '(default)'}",
+        f"[blue bold]Max File Size:[/blue bold] {limits['max_file_size']}",
+        f"[blue bold]Max Total Size:[/blue bold] {limits['max_total_size']}",
+    ]
+
+    summarization_lines = [
+        f"[green bold]Enabled:[/green bold] {'yes' if summarization['enabled'] else 'no'}",
+        f"[blue bold]Max Tokens:[/blue bold] "
+        f"{summarization['max_tokens'] if summarization['max_tokens'] is not None else '(default)'}",
+    ]
+
+    other_view_lines = [
+        f"[blue bold]{phase}:[/blue bold] {status}"
+        for phase, status in other_views.items()
+    ]
+
+    return [
+        Panel("\n".join(cp_lines), title="Context Policy", expand=False),
+        Panel("\n".join(limits_lines), title="Limits", expand=False),
+        Panel("\n".join(summarization_lines), title="Summarization", expand=False),
+        Panel("\n".join(other_view_lines), title="Other Views", expand=False),
+    ]