Method clone_additional_views

atomic-cli/src/commands/clone/command.rs:602–709

Clone every remote view not already applied by the primary chain. Each view arrives as a manifest and is applied with the same primitive as the primary view, so scope and parent are preserved. Manifests are ordered parents-before-children; changes are content-addressed and deduplicated against everything already downloaded. Returns the number of additional views cloned.

(
        &self,
        repo: &mut Repository,
        remote: &HttpRemote,
        stats: &mut CloneStats,
        applied: &mut HashSet<String>,
    )

    /// content-addressed and deduplicated against everything already
    /// downloaded. Returns the number of additional views cloned.
    async fn clone_additional_views(
        &self,
        repo: &mut Repository,
        remote: &HttpRemote,
        stats: &mut CloneStats,
        applied: &mut HashSet<String>,
    ) -> CliResult<usize> {
        // The user explicitly asked for every view, so a missing inventory
        // is a hard error, not a silent single-view clone.
        let remote_views = remote
            .list_views()
            .await
            .map_err(|e| CliError::RemoteError {
                message: format!(
                    "--all-views requires the view inventory (?views), but the request failed: {}",
                    e
                ),
                url: Some(self.url.clone()),
            })?;

        let names: Vec<String> = remote_views.into_iter().map(|v| v.name).collect();
        let others = match classify_inventory(&names, applied) {
            InventoryOutcome::Views(others) => others,
            InventoryOutcome::NothingNew => return Ok(0),
            InventoryOutcome::Unsupported => {
                return Err(CliError::RemoteError {
                    message: "--all-views requires the view inventory (?views), but this \
                              server does not support it (empty inventory). Upgrade the \
                              server, or clone a single view without --all-views."
                        .to_string(),
                    url: Some(self.url.clone()),
                })
            }
        };

        print_blank();
        println!(
            "Cloning {} additional {}:",
            others.len(),
            if others.len() == 1 { "view" } else { "views" }
        );

        // Fetch manifests for every remaining view.
        let mut manifests: Vec<ViewManifest> = Vec::with_capacity(others.len());
        for name in &others {
            match self.fetch_view_manifest(remote, name).await {
                Ok(Some(m)) => manifests.push(m),
                Ok(None) => {
                    print_warning(&format!(
                        "View '{}' vanished from the remote — skipped",
                        name
                    ));
                }
                Err(e) => {
                    print_warning(&format!(
                        "Failed to fetch manifest for view '{}': {}",
                        name, e
                    ));