korrat/beancount-importers - Change Y2R6OOYWSW6WUQMWWO4I2COCACW72VQ4EBFYJPCSGN7FSOMV5J5AC

Only archive files after successful import

Created by korrat on June 23, 2023

Y2R6OOYWSW6WUQMWWO4I2COCACW72VQ4EBFYJPCSGN7FSOMV5J5AC

Dependencies

In channels

main

Change contents

Replacement in framework/src/runner.rs at line 147 [3.41]

B:BD[3.3497] → [4.258:301]

    ) -> Result<Option<RelativePathBuf>> {

[3.3497]

[4.301]

        destination: RelativePathBuf,
    ) -> Result<()> {

Replacement in framework/src/runner.rs at line 150 [3.41]
B:BD[4.327] → [4.327:356]
```
            return Ok(None);
```
[4.327]
[3.3716]
```
            return Ok(());
```

Replacement in framework/src/runner.rs at line 153 [3.41]

B:BD[3.3727] → [4.357:519]

        let relative_destination = archive::file_name(importer, file)?;
        let destination = relative_destination.to_logical_path(&self.archive_directory);

[3.3727]

[4.519]

        let destination = destination.to_logical_path(&self.archive_directory);

Replacement in framework/src/runner.rs at line 170 [3.41]
B:BD[3.4017] → [4.1058:1097]
```
        Ok(Some(relative_destination))
```
[3.4017]
[3.4146]
```
        Ok(())
```
Deletion in framework/src/runner.rs at line 203 [3.41]
B:BD[3.5239] → [3.5239:5240]
B:BD[3.5240] → [4.1098:1138]
∅:D[4.1138] → [3.5264:5354]
B:BD[3.5264] → [3.5264:5354]
```
        let relative_destination = self
            .archive_file(importer, file)
            .wrap_err("while archiving file")?;
```

Replacement in framework/src/runner.rs at line 204 [3.41]

B:BD[4.1140] → [4.1140:1479]

        let destination = relative_destination.as_ref().map_or_else(
            || file.to_path_buf(),
            |relative_destination| {
                let destination = relative_destination.to_path(&self.archive_directory);
                Utf8PathBuf::from_path_buf(destination).expect("path to be UTF-8")
            },
        );

[4.1140]

[3.5437]

        let destination = archive::file_name(importer, file)?;

Replacement in framework/src/runner.rs at line 207 [3.41]

B:BD[3.5486] → [4.1480:1555]

            .extract(&destination, &[]) // TODO load existing transactions

[3.5486]

[3.5554]

            .extract(file, &[]) // TODO load existing transactions

Replacement in framework/src/runner.rs at line 210 [3.41]

B:BD[3.5639] → [4.1556:1664]

B:BD[4.1664] → [2.168:247]

∅:D[2.247] → [4.1738:1752]

B:BD[4.1738] → [4.1738:1752]

        if let Some(path) = relative_destination {
            for directive in &mut extracted_directives {
                directive.add_meta(common_keys::IMPORTED_FROM, path.as_str());
            }

[3.5639]

[4.1752]

        for directive in &mut extracted_directives {
            directive.add_meta(common_keys::IMPORTED_FROM, destination.as_str());

Insertion in framework/src/runner.rs at line 213 [3.41]

[4.1762]


        self.archive_file(importer, file, destination)
            .wrap_err("while archiving file")?;