Function write_file

opensuse-proxy-cache/src/main.rs:949–1089

(
    cache_key: PathBuf,
    mut headers: HeaderMap,
    file: NamedTempFile,
    submit_tx: Sender<CacheMeta>,
    cls: Classification,
    mut reader: I,
)

#[instrument(skip_all)]
async fn write_file<I>(
    cache_key: PathBuf,
    mut headers: HeaderMap,
    file: NamedTempFile,
    submit_tx: Sender<CacheMeta>,
    cls: Classification,
    mut reader: I,
) where
    I: AsyncRead + Unpin,
{
    let cnt_amt = headers
        .remove("content-length")
        .and_then(|hk| hk.to_str().ok().and_then(|i| usize::from_str(i).ok()))
        .unwrap_or(0);

    debug!(etag = ?headers.get("etag"));

    let etag_nginix_len = headers
        .get("etag")
        .and_then(|hk| {
            hk.to_str().ok().and_then(|t| {
                ETAG_NGINIX_RE.captures(t).and_then(|caps| {
                    let etcap = caps.name("len");
                    etcap
                        .map(|s| s.as_str())
                        .and_then(|len_str| usize::from_str_radix(len_str, 16).ok())
                })
            })
        })
        .unwrap_or(0);

    let etag_apache_len = headers
        .get("etag")
        .and_then(|hk| {
            hk.to_str().ok().and_then(|t| {
                ETAG_APACHE_RE.captures(t).and_then(|caps| {
                    let etcap = caps.name("len");
                    etcap
                        .map(|s| s.as_str())
                        .and_then(|len_str| usize::from_str_radix(len_str, 16).ok())
                })
            })
        })
        .unwrap_or(0);

    // At least *one* etag length has to make sense ...
    // Does this length make sense? Can we get an etag length?

    if cnt_amt == 0 {
        info!("Ignoring 0 length content amount");
        return;
    } else if etag_nginix_len == 0 && etag_apache_len == 0 {
        info!("disregard 0 length etags");
    } else if (etag_nginix_len != 0 && cnt_amt == etag_nginix_len)
        || (etag_apache_len != 0 && cnt_amt == etag_apache_len)
    {
        info!(
            "content-length and etag agree - {} == a {} || n {}",