Function miss

opensuse-proxy-cache/src/main.rs:529–659

(
    state: Arc<AppState>,
    fetch_url: Url,
    cache_key: PathBuf,
    tmp_file: NamedTempFile,
    submit_tx: Sender<CacheMeta>,
    cls: Classification,
    range: Option<(u64, Option<u64>)>,
 

#[instrument(skip_all)]
async fn miss(
    state: Arc<AppState>,
    fetch_url: Url,
    cache_key: PathBuf,
    tmp_file: NamedTempFile,
    submit_tx: Sender<CacheMeta>,
    cls: Classification,
    range: Option<(u64, Option<u64>)>,
    client_ip_addr: IpAddr,
) -> Response {
    info!("❄️   start miss ");
    debug!("range -> {:?}", range);

    if range.is_some() {
        info!("Range request, submitting bg dl with rangestream");

        if state
            .prefetch_tx
            .send(PrefetchReq {
                cache_key,
                fetch_url: fetch_url.clone(),
                submit_tx,
                tmp_file,
                cls,
            })
            .await
            .is_err()
        {
            error!("Prefetch task may have died!");
        }

        // Stream. metadata=false because we want the body.
        return stream(state, fetch_url, false, range, client_ip_addr).await;
    }

    // Not a range, go on.
    info!("Not a range request, as you were.");

    // Start the dl.
    let send_headers = send_headers(None);
    let client_response = state
        .client
        .get(fetch_url)
        .headers(send_headers)
        .send()
        .await;

    let client_response = match client_response {
        Ok(cr) => cr,
        Err(e) => {
            error!(?e, "Error handling client response");
            return (StatusCode::INTERNAL_SERVER_ERROR).into_response();
        }
    };

    let headers = filter_headers(client_response.headers(), false);

    // Since it's not a range request, the content-length is the full file size we are about