Function build_upstream_headers

src/proxy.rs:107–155

(
    original: &Headers,
    access_token: &str,
    allow_context_1m: bool,
)

}

fn build_upstream_headers(
    original: &Headers,
    access_token: &str,
    allow_context_1m: bool,
) -> Result<Headers> {
    let headers = Headers::new();
    let mut seen_user_agent = false;
    let mut seen_anthropic_version = false;
    let mut beta_values = Vec::new();

    for (name, value) in original.entries() {
        let lower = name.to_ascii_lowercase();
        if is_hop_by_hop(&lower)
            || matches!(
                lower.as_str(),
                "host" | "content-length" | "authorization" | "cookie" | "x-api-key"
            )
        {
            continue;
        }
        if lower == "anthropic-beta" {
            collect_beta_values(&value, &mut beta_values, allow_context_1m);
            continue;
        }
        if lower == "user-agent" {
            seen_user_agent = true;
        }
        if lower == "anthropic-version" {
            seen_anthropic_version = true;
        }
        headers.append(&name, &value)?;
    }

    collect_beta_values(DEFAULT_REQUIRED_BETA, &mut beta_values, allow_context_1m);
    if allow_context_1m {
        collect_beta_values(DEFAULT_CONTEXT_1M_BETA, &mut beta_values, allow_context_1m);
    }
    headers.set("authorization", &format!("Bearer {access_token}"))?;
    if !seen_user_agent {
        headers.set("user-agent", DEFAULT_USER_AGENT)?;
    }
    if !seen_anthropic_version {
        headers.set("anthropic-version", DEFAULT_ANTHROPIC_VERSION)?;
    }
    if !beta_values.is_empty() {
        headers.set("anthropic-beta", &beta_values.join(","))?;
    }
    Ok(headers)
}

async fn send_upstream_request(
    upstream_url: &str,