phi_agent/render/
mod.rs

1pub mod json_stream;
2pub mod null;
3pub mod terminal;
4
5pub use json_stream::JsonStreamRenderer;
6pub use null::NullRenderer;
7pub use terminal::TerminalRenderer;
8
9use std::io::{self, Write};
10
11use agent_base::{AgentResult, RuntimeEvent};
12
13/// Event renderer: converts RuntimeEvents into a specific output format.
14///
15/// Each renderer is a pure consumer — it only reads events and produces
16/// output, without modifying Agent state.
17pub trait EventRenderer: Send {
18    /// Process one runtime event.
19    fn render(&mut self, event: RuntimeEvent) -> AgentResult<()>;
20
21    /// End of current turn — renderer may flush / output summary.
22    fn finish_turn(&mut self) -> AgentResult<()>;
23
24    /// End of entire session.
25    fn finish_session(&mut self) -> AgentResult<()> {
26        Ok(())
27    }
28}
29
30/// Output format
31#[derive(Clone, Debug)]
32pub enum OutputFormat {
33    /// Rich terminal output (with colors and emoji)
34    Terminal {
35        show_thinking: bool,
36        show_tool_args: bool,
37        color: bool,
38    },
39    /// One JSON object per line
40    Json,
41    /// No output
42    Quiet,
43}
44
45/// Create the corresponding renderer for a given output format.
46///
47/// `writer` defaults to stdout (CLI scenario). Web consumers can pass a
48/// custom writer (e.g. a WebSocket sink).
49pub fn create_renderer(format: &OutputFormat, writer: Option<Box<dyn Write + Send>>) -> Box<dyn EventRenderer> {
50    match format {
51        OutputFormat::Terminal { show_thinking, show_tool_args, color } => {
52            let w = writer.unwrap_or_else(|| Box::new(io::stdout()));
53            Box::new(TerminalRenderer::new(*show_thinking, *show_tool_args, *color, w))
54        }
55        OutputFormat::Json => {
56            let w = writer.unwrap_or_else(|| Box::new(io::stdout()));
57            Box::new(JsonStreamRenderer::new(w))
58        }
59        OutputFormat::Quiet => Box::new(NullRenderer),
60    }
61}
62
63/// Create a renderer using stdout (backward-compatible).
64pub fn create_stdout_renderer(format: &OutputFormat) -> Box<dyn EventRenderer> {
65    create_renderer(format, None)
66}
phi_agent/render/mod.rs

phi_agent/render/
mod.rs
