Function apply_extra_headers

src/commands/pages.rs:12–48

Apply extra HTTP headers to a page session via Network.setExtraHTTPHeaders.

(
    client: &mut CdpClient,
    session_id: &str,
    extra_headers: Option<&str>,
)

/// Apply extra HTTP headers to a page session via Network.setExtraHTTPHeaders.
pub async fn apply_extra_headers(
    client: &mut CdpClient,
    session_id: &str,
    extra_headers: Option<&str>,
) -> Result<()> {
    if let Some(headers_json) = extra_headers {
        let headers: serde_json::Value = serde_json::from_str(headers_json)
            .map_err(|e| anyhow::anyhow!("Invalid --extra-headers JSON: {e}"))?;
        let headers_obj = headers
            .as_object()
            .ok_or_else(|| anyhow::anyhow!("--extra-headers must be a JSON object"))?;
        let mut converted_headers = serde_json::Map::new();
        for (k, v) in headers_obj {
            let val_str = match v {
                serde_json::Value::String(s) => s.clone(),
                serde_json::Value::Number(n) => n.to_string(),
                serde_json::Value::Bool(b) => b.to_string(),
                _ => anyhow::bail!(
                    "Header value for '{}' must be a primitive scalar (string, number, or boolean)",
                    k
                ),
            };
            converted_headers.insert(k.clone(), serde_json::Value::String(val_str));
        }
        client
            .send_to_target(session_id, "Network.enable", json!({}))
            .await?;
        client
            .send_to_target(
                session_id,
                "Network.setExtraHTTPHeaders",
                json!({"headers": converted_headers}),
            )
            .await?;
    }
    Ok(())
}

/// Clear extra HTTP headers for a page session.
pub async fn clear_extra_headers(client: &mut CdpClient, session_id: &str) -> Result<()> {