Method write_import_recorded

atomic-repository/src/repository/insert.rs:726–916

Assemble, save, and apply a freshly imported Git commit without going through the normal `insert_change()` load/check path. This preserves the normal graph writer and CRDT table application, but avoids reloading the just-saved change and avoids the `has_change_in_graph` probe. The write transaction is opened before assembly, so globalization and application share one consistent transaction view.

(
        &self,
        header: ChangeHeader,
        recorded_files: &[atomic_core::record::workflow::RecordedFile],
        unhashed: serde_json::Value,
        deleted_paths: &[String],
        pr

    /// graph-only so importing into a foreign view cannot rewrite the active
    /// view's global TREE mappings.
    pub fn write_import_recorded(
        &self,
        header: ChangeHeader,
        recorded_files: &[atomic_core::record::workflow::RecordedFile],
        unhashed: serde_json::Value,
        deleted_paths: &[String],
        preserve_existing_tree_paths: bool,
        options: InsertOptions,
    ) -> Result<ImportWriteOutcome, RepositoryError> {
        use atomic_core::record::workflow::assemble_change;
        use atomic_core::record::workflow::assembly::AssemblyOptions;

        let mut timings = ImportWriteTimings::default();
        let view_name = options.view.as_deref().unwrap_or(&self.current_view);

        let mut txn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        let assemble_start = std::time::Instant::now();
        let mut change = if recorded_files.is_empty() {
            Change::empty(header)
        } else {
            match assemble_change(
                &txn,
                recorded_files,
                header.clone(),
                &AssemblyOptions::default(),
            ) {
                Ok(result) => result.into_change(),
                Err(e) => {
                    let err_msg = e.to_string();
                    if err_msg.contains("empty") || err_msg.contains("AllEmpty") {
                        Change::empty(header)
                    } else {
                        return Err(RepositoryError::Apply(e.to_string()));
                    }
                }
            }
        };
        timings.assemble_ms = assemble_start.elapsed().as_millis();

        change.unhashed = Some(unhashed);

        let mut v3_bytes = Vec::new();
        let hash = change
            .serialize(&mut v3_bytes)
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        let (final_change, verified_hash) = Change::deserialize(&mut v3_bytes.as_slice())
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        debug_assert_eq!(hash, verified_hash);

        let save_start = std::time::Instant::now();
        self.save_change_bytes(&hash, &v3_bytes, &final_change)?;
        timings.save_ms = save_start.elapsed().as_millis();

        let change_id = txn