feat(cli): Add rich terminal output formatting

- Switched  to use  instead of JSON in TTY environments.
- Introduced  rules to break up pipeline execution phases (Plan, Iteration X, Intelligence Processing).
- Added  to vividly display AI deductive reasoning during cluster merges.

Author: vishnurajkv

.gitignore

@@ -3,6 +3,7 @@ venv/
 env/
 .venv/
 .env
+.sisyphus
 
 # Application results
 results/
@@ -24,3 +25,5 @@ htmlcov/
 .idea/
 .vscode/
 .cursor/
+test_output.txt
+all_tests.txt

pyproject.toml

@@ -19,6 +19,7 @@ dependencies = [
   "redis==5.0.8",
   "networkx==3.3",
   "asyncpg==0.30.0",
+  "rich>=14.3.3",
 ]
 
 [project.optional-dependencies]

src/secnodeapi/ai/validate.py

@@ -12,8 +12,11 @@
 
 from ..vulnerability_models import Finding, TestResult
 from .llm_client import call_llm
+from rich.console import Console
+from rich.panel import Panel
 
 logger = structlog.get_logger(__name__)
+console = Console()
 
 
 class AIValidationPayload(BaseModel):
@@ -263,6 +266,13 @@ async def deduplicate_findings_with_ai(findings: List[Finding]) -> List[Finding]
 
             if len(cluster_findings) > 1:
                 logger.info("AI Merge Decision", reasoning=cluster.reasoning, merged_count=len(cluster_findings), kept_id=cluster_findings[0].test_case_id)
+                console.print(
+                    Panel(
+                        f"[bold cyan]Rationale:[/]\n{cluster.reasoning}\n\n[bold green]Action:[/]\nMerged [bold]{len(cluster_findings)}[/bold] duplicate findings into root cause [bold]{cluster_findings[0].test_case_id}[/bold].",
+                        title="🧠 AI Vulnerability Deduplication",
+                        border_style="cyan"
+                    )
+                )
 
             # Keep the finding with the highest CVSS or confidence
             top_finding = sorted(

src/secnodeapi/cli.py

@@ -18,12 +18,26 @@
 except ImportError:
     pass
 
-structlog.configure(
-    processors=[
-        structlog.processors.TimeStamper(fmt="iso"),
-        structlog.processors.JSONRenderer(),
-    ]
-)
+import sys
+from rich.console import Console
+
+console = Console()
+
+if sys.stdout.isatty() and not os.environ.get("SECNODE_JSON_LOGS"):
+    structlog.configure(
+        processors=[
+            structlog.processors.TimeStamper(fmt="iso"),
+            structlog.dev.ConsoleRenderer(colors=True),
+        ]
+    )
+else:
+    structlog.configure(
+        processors=[
+            structlog.processors.TimeStamper(fmt="iso"),
+            structlog.processors.JSONRenderer(),
+        ]
+    )
+
 logger = structlog.get_logger(__name__)
 
 from .config import RuntimeConfig, has_supported_provider_key
@@ -293,21 +307,24 @@ async def _run_schema_only(args, runtime: RuntimeConfig) -> None:
 
 
 async def _run_dry_run(args, pipeline_input: PipelineInput) -> None:
+    console.rule("[bold cyan]SecNode Dry-Run Mode")
     _, tests = await build_pipeline_artifacts(pipeline_input)
     if not tests:
         logger.error("No tests generated. Aborting.")
         raise SystemExit(1)
-    print(f"Generated {len(tests)} test cases (dry-run).")
+    console.print(f"[bold green]Generated {len(tests)} test cases (dry-run).[/]")
     _write_dry_run_output(tests, args.dry_run_output)
     logger.info("Dry-run mode complete", generated_tests=len(tests))
 
 
 async def _run_full_pipeline(args, pipeline_input: PipelineInput) -> None:
+    console.rule("[bold magenta]SecNode Legacy Pipeline")
     api_structure, tests = await build_pipeline_artifacts(pipeline_input)
     if not tests:
         logger.error("No tests generated. Aborting.")
         raise SystemExit(1)
 
+    console.rule("[bold cyan]Executing Generated Tests")
     results = await execute_proactive_tests(
         test_cases=tests,
         base_url=api_structure.base_url,
@@ -316,6 +333,8 @@ async def _run_full_pipeline(args, pipeline_input: PipelineInput) -> None:
         proxy=pipeline_input.proxy,
         verify_ssl=pipeline_input.verify_ssl,
     )
+    
+    console.rule("[bold yellow]Validating Execution Results")
     findings = await validate_and_retest(
         results=results,
         base_url=api_structure.base_url,
@@ -329,11 +348,16 @@ async def _run_full_pipeline(args, pipeline_input: PipelineInput) -> None:
 
     report = build_report(api_structure.title, findings)
     output_dir = write_report(report, args.target)
+    
+    console.rule("[bold green]Scan Completed")
     logger.info("SecNode pipeline completed successfully", output_dir=output_dir)
 
 
 async def _run_agent_mode(args, pipeline_input: PipelineInput) -> None:
+    console.rule("[bold magenta]SecNode Autonomous Agent Mode")
     api_structure, confirmed, suspected, metrics = await run_agent_pipeline(pipeline_input)
+    
+    console.rule("[bold green]Scan Completed")
     report = build_report_with_context(
         api_structure.title,
         confirmed,

src/secnodeapi/services/pipeline.py

@@ -272,13 +272,18 @@ def _merge_unique_findings(existing: List[Finding], new_findings: List[Finding])
     return list(by_key.values())
 
 
+from rich.console import Console
+
+console = Console()
+
 async def run_agent_pipeline(
     pipeline_input: PipelineInput,
 ) -> Tuple[SchemaStructure, List[Finding], List[Finding], Dict[str, int]]:
     """
     Autonomous runtime loop:
     plan -> execute -> observe -> validate -> replan.
     """
+    console.rule("[bold cyan]Phase 1: Building Execution Plan")
     api_structure, seed_tests = await build_pipeline_artifacts(pipeline_input)
     identities = _resolve_identities(pipeline_input)
     queue = _deduplicate_test_cases(
@@ -294,12 +299,14 @@ async def run_agent_pipeline(
 
     while queue and remaining_budget > 0 and iteration < pipeline_input.max_iterations:
         iteration += 1
+        console.rule(f"[bold magenta]Phase 2: Agent Iteration {iteration}")
         batch, queue = _clip_for_budget(
             queue, remaining_budget, pipeline_input.per_endpoint_budget
         )
         if not batch:
             break
-
+        
+        console.print(f"[dim]Executing batch of {len(batch)} tests. {len(queue)} remaining in queue.[/]")
         results, stats = await execute_proactive_tests_detailed(
             test_cases=batch,
             base_url=api_structure.base_url,
@@ -328,6 +335,7 @@ async def run_agent_pipeline(
         queue = _deduplicate_test_cases(queue + chain_tests)
 
     # Run final AI deduplication
+    console.rule("[bold yellow]Phase 3: Final Intelligence Processing")
     confirmed = await deduplicate_findings_with_ai(confirmed)
 
     metrics = {