Function async_refresh_task

opensuse-proxy-cache/src/main.rs:365–423

(
    client: reqwest::Client,
    prefetch_tx: Sender<PrefetchReq>,
    fetch_url: Url,
    submit_tx: Sender<CacheMeta>,
    tmp_file: NamedTempFile,
    obj: CacheObj<PathBuf, Status>,
    prefetch

#[instrument(skip_all)]
async fn async_refresh_task(
    client: reqwest::Client,
    prefetch_tx: Sender<PrefetchReq>,
    fetch_url: Url,
    submit_tx: Sender<CacheMeta>,
    tmp_file: NamedTempFile,
    obj: CacheObj<PathBuf, Status>,
    prefetch_paths: Option<Vec<PrefetchItem>>,
) {
    info!(
        "🥺  start async refresh {}",
        obj.userdata.cache_key.display()
    );

    if !refresh(&client, fetch_url.clone(), &obj).await {
        info!(
            "🥰  async prefetch, content still valid {}",
            obj.userdata.cache_key.display()
        );
        let etime = time::OffsetDateTime::now_utc();
        // If we can't submit, we are probably shutting down so just finish up cleanly.
        // That's why we ignore these errors.
        //
        // If this item is valid we can update all the related prefetch items.
        let _ = submit_tx
            .send(CacheMeta {
                cache_key: obj.userdata.cache_key.clone(),
                etime,
                action: Action::Update,
            })
            .await;
        return;
    }

    info!(
        "😵  async refresh, need to refresh {}",
        obj.userdata.cache_key.display()
    );

    prefetch(prefetch_tx.clone(), &submit_tx, prefetch_paths);

    // Fetch our actual file too

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