Function flatten_system_text_before_cache_control

src/proxy.rs:687–730

(body: &mut Value)

}

fn flatten_system_text_before_cache_control(body: &mut Value) {
    canonicalize_claude_body(body);
    let Some(blocks) = body.get_mut("system").and_then(Value::as_array_mut) else {
        return;
    };

    let mut merge_ranges = Vec::new();
    let mut run_start = None;
    let mut run_text = String::new();

    for (index, block) in blocks.iter().enumerate() {
        if is_claudecode_billing_header_block(block) {
            run_start = None;
            run_text.clear();
            continue;
        }

        if block_has_cache_control(block) {
            if let Some(start) = run_start.take()
                && index.saturating_sub(start) > 1
            {
                merge_ranges.push((start, index, std::mem::take(&mut run_text)));
            } else {
                run_text.clear();
            }
            continue;
        }

        if let Some(text) = block_text(block) {
            if run_start.is_none() {
                run_start = Some(index);
            }
            run_text.push_str(text);
            continue;
        }

        run_start = None;
        run_text.clear();
    }

    for (start, end, text) in merge_ranges.into_iter().rev() {
        blocks.splice(start..end, [json_text_block(text.as_str())]);
    }
}

fn build_claudecode_billing_header_text(body: &Value, version: &str) -> String {
    let user_text = first_claudecode_user_text(body);