Function head_view

opensuse-proxy-cache/src/main.rs:131–194

(
    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 head_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 = format!("/{}", req_path.replace("//", "/"));

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

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

    let decision = state.cache.decision(&req_path, true);
    // Based on the decision, take an appropriate path. Generally with head reqs
    // we try to stream this if we don't have it, and we prefetch in the BG.
    match decision {
        CacheDecision::Stream(url) => stream(state, url, true, None, client_ip_addr).await,
        CacheDecision::NotFound => missing().await,
        CacheDecision::FoundObj(meta) => found(state, meta, true, None, client_ip_addr).await,
        CacheDecision::Refresh {
            fetch_url,
            submit_tx,
            prefetch_items,
            ..
        }
        | CacheDecision::MissObj {
            fetch_url,
            submit_tx,
            prefetch_items,
            ..
        } => {
            // Submit all our BG prefetch reqs
            prefetch(state.prefetch_tx.clone(), &submit_tx, prefetch_items);
            // Now we just stream.
            stream(state, fetch_url, true, None, client_ip_addr).await
        }
        CacheDecision::AsyncRefresh {
            fetch_url,
            _cache_key: _,
            tmp_file,
            submit_tx,
            meta,
            prefetch_items,
        } => {
            // Submit all our BG prefetch reqs
            async_refresh(
                state.client.clone(),
                state.prefetch_tx.clone(),
                &fetch_url,
                &submit_tx,
                tmp_file,
                &meta,
                prefetch_items,
            );
            // Send our current head data.
            found(state, meta, true, None, client_ip_addr).await