Function parse_bedrock_stream

crates/opencode-provider/src/bedrock.rs:495–516

(text: &str)

}

fn parse_bedrock_stream(text: &str) -> Result<StreamEvent, ProviderError> {
    if text.contains("\"contentBlockDelta\"") {
        if let Some(start) = text.find("\"text\":") {
            let rest = &text[start + 8..];
            if let Some(end) = rest.find("\"") {
                let text_content = &rest[..end];
                if let Ok(decoded) =
                    serde_json::from_str::<String>(&format!("\"{}\"", text_content))
                {
                    return Ok(StreamEvent::TextDelta(decoded));
                }
                return Ok(StreamEvent::TextDelta(text_content.to_string()));
            }
        }
    }

    if text.contains("\"messageStop\"") {
        return Ok(StreamEvent::Done);
    }

    Ok(StreamEvent::TextDelta(String::new()))
}