Function read_message

src/diagnostics/lsp/client.rs:382–425

(
    reader: &mut BufReader<tokio::process::ChildStdout>,
)

}

async fn read_message(
    reader: &mut BufReader<tokio::process::ChildStdout>,
) -> Result<Option<JsonRpcMessage>> {
    let mut content_length = None;
    loop {
        let mut line = String::new();
        let bytes = reader
            .read_line(&mut line)
            .await
            .map_err(|e| TraceDecayError::Config {
                message: format!("failed to read LSP header: {e}"),
            })?;
        if bytes == 0 {
            return Ok(None);
        }
        let trimmed = line.trim_end_matches(['\r', '\n']);
        if trimmed.is_empty() {
            break;
        }
        let Some((name, value)) = trimmed.split_once(':') else {
            continue;
        };
        if name.eq_ignore_ascii_case("content-length") {
            content_length = value.trim().parse::<usize>().ok();
        }
    }
    let Some(length) = content_length else {
        return Err(TraceDecayError::Config {
            message: "LSP message missing Content-Length header".to_string(),
        });
    };
    let mut body = vec![0_u8; length];
    reader
        .read_exact(&mut body)
        .await
        .map_err(|e| TraceDecayError::Config {
            message: format!("failed to read LSP body: {e}"),
        })?;
    serde_json::from_slice(&body)
        .map(Some)
        .map_err(|e| TraceDecayError::Config {
            message: format!("failed to parse LSP message: {e}"),
        })
}

async fn read_message_until(
    reader: &mut BufReader<tokio::process::ChildStdout>,