Function list_gateways_with_source

crates/openshell-bootstrap/src/metadata.rs:312–376

List all gateways that have stored metadata, along with the config layer that supplied each record.

()

/// List all gateways that have stored metadata, along with the config layer
/// that supplied each record.
pub fn list_gateways_with_source() -> Result<Vec<ListedGateway>> {
    let mut gateways = Vec::new();
    let mut seen: std::collections::HashSet<String> = std::collections::HashSet::new();

    let user_dir = user_gateways_dir()?;
    if user_dir.exists() {
        let entries = std::fs::read_dir(&user_dir)
            .into_diagnostic()
            .wrap_err_with(|| format!("failed to read directory {}", user_dir.display()))?;
        for entry in entries {
            let entry = entry.into_diagnostic()?;
            let path = entry.path();
            if !path.is_dir() {
                continue;
            }

            let metadata_path = path.join("metadata.json");
            if !user_entry_shadows_system(&metadata_path) {
                continue;
            }

            let name = entry.file_name().to_string_lossy().to_string();
            if !seen.insert(name) {
                continue;
            }

            if let Ok(metadata) = parse_gateway_metadata(&metadata_path) {
                gateways.push(ListedGateway {
                    metadata,
                    source: GatewayMetadataSource::User,
                });
            }
        }
    }

    let system_dir = system_gateways_dir();
    if system_dir.exists() {
        let entries = std::fs::read_dir(&system_dir)
            .into_diagnostic()
            .wrap_err_with(|| format!("failed to read directory {}", system_dir.display()))?;
        for entry in entries {
            let entry = entry.into_diagnostic()?;
            let path = entry.path();
            if !path.is_dir() {
                continue;
            }

            let name = entry.file_name().to_string_lossy().to_string();
            if seen.contains(&name) {
                continue;
            }

            let metadata_path = path.join("metadata.json");
            if let Ok(metadata) = parse_gateway_metadata(&metadata_path) {
                gateways.push(ListedGateway {
                    metadata,
                    source: GatewayMetadataSource::System,
                });