Function get_view

opensuse-proxy-cache/src/main.rs:199–344

(
    headers: HeaderMap,
    extract::Extension(client_ip_addr): extract::Extension<IpAddr>,
    extract::State(state): extract::State<Arc<AppState>>,
    extract::OriginalUri(req_uri): extract::Orig

#[instrument(skip_all)]
async fn get_view(
    headers: HeaderMap,
    extract::Extension(client_ip_addr): extract::Extension<IpAddr>,
    extract::State(state): extract::State<Arc<AppState>>,
    extract::OriginalUri(req_uri): extract::OriginalUri,
) -> Response {
    // let req_path = req_uri.path();

    let req_path = normalise_path(req_uri.path());

    trace!("{:?}", req_path);
    info!("request_headers -> {:?}", headers);

    let decision = state.cache.decision(&req_path, false);
    // Req path sometimes has dup //, so we replace them.

    // We have a hit, with our cache meta! Hooray!
    // Let's setup the response, and then stream from the file!
    let range = headers
        .get("range")
        .and_then(|hv| hv.to_str().ok())
        .and_then(|sr| {
            if sr.starts_with("bytes=") {
                sr.strip_prefix("bytes=")
                    .and_then(|v| v.split_once('-'))
                    .and_then(|(range_start, range_end)| {
                        let r_end = u64::from_str_radix(range_end, 10).ok();
                        u64::from_str_radix(range_start, 10)
                            .ok()
                            .map(|s| (s, r_end))
                    })
            } else {
                None
            }
        });

    // Based on the decision, take an appropriate path.
    match decision {
        CacheDecision::Stream(url) => stream(state, url, false, range, client_ip_addr).await,
        CacheDecision::NotFound => missing().await,
        CacheDecision::FoundObj(meta) => found(state, meta, false, range, client_ip_addr).await,
        CacheDecision::MissObj {
            fetch_url,
            cache_key,
            tmp_file,
            submit_tx,
            cls,
            prefetch_items,
        } => {
            // Submit all our BG prefetch reqs
            prefetch(state.prefetch_tx.clone(), &submit_tx, prefetch_items);

            miss(
                state,
                fetch_url,
                cache_key,
                tmp_file,
                submit_tx,