Function http_request

packages/server/src/main/http.rs:11–62

(
    server_url: &str,
    method: &str,
    path: &str,
    body: Option<&Value>,
)

}

fn http_request(
    server_url: &str,
    method: &str,
    path: &str,
    body: Option<&Value>,
) -> anyhow::Result<Vec<u8>> {
    let endpoint = HttpEndpoint::parse(server_url)?;
    let mut stream = std::net::TcpStream::connect((endpoint.host.as_str(), endpoint.port))
        .with_context(|| format!("connect to SimDeck service at {server_url}"))?;
    stream.set_read_timeout(Some(Duration::from_secs(180)))?;
    stream.set_write_timeout(Some(Duration::from_secs(5)))?;
    let body = body.map(serde_json::to_vec).transpose()?;
    let request = if let Some(body) = body.as_ref() {
        format!(
            "{method} {path} HTTP/1.1\r\nHost: {}\r\nOrigin: {}\r\nAccept: application/json\r\nContent-Type: application/json\r\nContent-Length: {}\r\nConnection: close\r\n\r\n",
            endpoint.host_header(),
            endpoint.origin(),
            body.len(),
        )
    } else {
        format!(
            "{method} {path} HTTP/1.1\r\nHost: {}\r\nOrigin: {}\r\nAccept: application/json\r\nConnection: close\r\n\r\n",
            endpoint.host_header(),
            endpoint.origin(),
        )
    };
    stream.write_all(request.as_bytes())?;
    if let Some(body) = body.as_ref() {
        stream.write_all(body)?;
    }

    let mut response = Vec::new();
    stream.read_to_end(&mut response)?;
    let (status, headers, body) = parse_http_response(&response)?;
    let body = if response_is_chunked(&headers) {
        decode_chunked_body(body)?
    } else {
        body.to_vec()
    };
    if !(200..300).contains(&status) {
        let message = String::from_utf8_lossy(&body).trim().to_owned();
        anyhow::bail!(
            "SimDeck service returned HTTP {status}{}",
            if message.is_empty() {
                String::new()
            } else {
                format!(": {message}")
            }
        );
    }
    Ok(body)
}

struct HttpEndpoint {
    host: String,