Function cache_mgr

opensuse-proxy-cache/src/cache.rs:699–764

(mut submit_rx: Receiver<CacheMeta>, pri_cache: ArcDiskCache<PathBuf, Status>)

}

fn cache_mgr(mut submit_rx: Receiver<CacheMeta>, pri_cache: ArcDiskCache<PathBuf, Status>) {
    // Wait on the channel, and when we get something proceed from there.
    while let Some(meta) = submit_rx.blocking_recv() {
        info!(
            "✨ Cache Manager Got -> {:?} {} {:?}",
            meta.cache_key, meta.etime, meta.action
        );

        let CacheMeta {
            cache_key,
            etime,
            action,
        } = meta;

        // Req path sometimes has dup //, so we replace them.
        // let req_path = req_path.replace("//", "/");

        match action {
            Action::Submit { file, headers, cls } => {
                let expiry = cls.expiry(etime);
                let key = cache_key.clone();

                pri_cache.insert(
                    key,
                    Status {
                        cache_key,
                        headers,
                        expiry,
                        cls,
                        nxtime: None,
                    },
                    file,
                )
            }
            Action::Update => pri_cache.update_userdata(&cache_key, |d: &mut Status| {
                d.expiry = d.cls.expiry(etime);
                if let Some(exp) = d.expiry.as_ref() {
                    debug!("⏰  expiry updated to soft {} hard {}", exp.0, exp.1);
                }
            }),
            Action::NotFound { cls } => {
                match pri_cache.new_tempfile() {
                    Some(file) => {
                        let key = cache_key.clone();

                        pri_cache.insert(
                            key,
                            Status {
                                cache_key,
                                headers: BTreeMap::default(),
                                expiry: None,
                                cls,
                                nxtime: Some(etime + time::Duration::minutes(1)),
                            },
                            file,
                        )
                    }
                    None => {