Function scan_cake_cache

cake-core/src/utils/models.rs:293–323

Scan the Cake cluster cache for worker-received models.

(cake_cache: &Path, models: &mut Vec<LocalModel>)

/// Scan the Cake cluster cache for worker-received models.
fn scan_cake_cache(cake_cache: &Path, models: &mut Vec<LocalModel>) -> Result<()> {
    let entries = match std::fs::read_dir(cake_cache) {
        Ok(e) => e,
        Err(_) => return Ok(()),
    };

    for entry in entries.flatten() {
        let dir = entry.path();
        if !dir.is_dir() {
            continue;
        }

        let cluster_hash = entry.file_name().to_string_lossy().to_string();

        if let Some((status, size_bytes)) = check_model_dir(&dir) {
            // Try to extract a model name from config.json
            let name = read_model_name_from_config(&dir)
                .unwrap_or_else(|| format!("cluster:{}", &cluster_hash));

            models.push(LocalModel {
                name,
                path: dir,
                source: ModelSource::ClusterCache { cluster_hash },
                status,
                size_bytes,
            });
        }
    }

    Ok(())
}

/// Try to read a model name from config.json (e.g. _name_or_path field).
fn read_model_name_from_config(dir: &Path) -> Option<String> {