Method clone_one_view

atomic-cli/src/commands/clone/command.rs:364–424

Create one view locally and populate it from its remote changelist. Returns the number of changes inserted into the view.

(
        &self,
        repo: &mut Repository,
        remote: &HttpRemote,
        view_name: &str,
        stats: &mut CloneStats,
    )

    ///
    /// Returns the number of changes inserted into the view.
    async fn clone_one_view(
        &self,
        repo: &mut Repository,
        remote: &HttpRemote,
        view_name: &str,
        stats: &mut CloneStats,
    ) -> CliResult<usize> {
        if !repo.view_exists(view_name).map_err(CliError::Repository)? {
            repo.create_shared_view(view_name)
                .map_err(CliError::Repository)?;
        }

        let entries = remote
            .get_changelist(view_name, 0)
            .await
            .map_err(|e| convert_remote_error(e, &self.url))?;

        let mut applied = 0usize;
        for entry in &entries {
            let Some(hash) = atomic_core::types::Hash::from_base32(entry.hash.as_bytes()) else {
                continue;
            };

            // Reuse content already present locally; fetch only what's missing.
            if !repo.has_change(&hash) {
                let data = remote
                    .download_change(&entry.hash)
                    .await
                    .map_err(|e| convert_remote_error(e, &self.url))?;
                let len = data.len() as u64;
                save_downloaded_change(&*repo, &hash, data).map_err(|e| {
                    CliError::Internal(anyhow::anyhow!("save change {}: {}", entry.hash, e))
                })?;
                stats.record_change_downloaded(len);
            }

            // Insert the change (and its dependency closure) into this view.
            // Changes arrive in dependency order, so deps are already present.
            let opts = atomic_repository::InsertOptions::default()
                .apply_deps(true)
                .view(view_name);
            match repo.insert_change_rec(&hash, opts) {
                Ok(_) => applied += 1,
                Err(e) => {
                    let msg = e.to_string();
                    if msg.contains("already applied") || msg.contains("AlreadyApplied") {
                        applied += 1;
                    } else {
                        return Err(CliError::Internal(anyhow::anyhow!(
                            "insert {} into '{}': {}",
                            entry.hash,
                            view_name,
                            e
                        )));
                    }
                }
            }
        }