rho-coding-agent 1.17.0

//! Claude stream-json NDJSON line bound and re-export of the shared decoder.
//!
//! Decoding lives in `rho_providers::provider_backend::line_decoder`. This
//! module only owns the Claude-specific 4 MiB anti-runaway budget and a thin
//! constructor so session call sites stay self-documenting.

use rho_providers::provider_backend::line_decoder::LineDecoder as SharedLineDecoder;

/// Maximum accepted bytes in one NDJSON line, including an incomplete tail.
///
/// # Why 4 MiB (not 1 MiB, not 32 MiB)
///
/// Claude stream-json lines are usually small. With
/// `--include-partial-messages`, tool inputs arrive as short
/// `input_json_delta` chunks. Live fixtures stay under 2 KiB per line.
///
/// The complete `assistant` envelope and `user`/`tool_result` frames still
/// carry full tool input/result JSON on a single NDJSON line. Agents may
/// declare `Write` / `Read` / `Bash`, so a legitimate supported message can
/// hold hundreds of KiB to a few MiB of file or command output. A 1 MiB
/// decoder cap would reject those complete frames before the mapper can
/// apply its softer presentation bounds (tool payload display 16 KiB,
/// terminal result 64 KiB, text/reasoning delta 32 KiB).
///
/// 4 MiB is therefore the anti-runaway line budget: large enough for
/// ordinary multi-megabyte tool envelopes, far below a 16–32 MiB "accept
/// anything" ceiling. Peak retained memory is one incomplete line of this
/// size; oversize input sets a pending error, drops only that tail, and
/// the session fails the run with a clear diagnostic rather than truncating
/// mid-JSON and corrupting later lines.
pub(crate) const MAX_NDJSON_LINE_BYTES: usize = 4 * 1024 * 1024;

pub(crate) use rho_providers::provider_backend::line_decoder::LineDecodeError;

/// Build the Claude stream-json decoder with the 4 MiB anti-runaway budget.
pub(crate) fn claude_ndjson_line_decoder() -> SharedLineDecoder {
    SharedLineDecoder::with_max_line_bytes(MAX_NDJSON_LINE_BYTES)
}

#[cfg(test)]
#[path = "line_decoder_tests.rs"]
mod tests;