Anki/rslib/src/import_export/insert.rs

// Copyright: Ankitects Pty Ltd and contributors
// License: GNU AGPL, version 3 or later; http://www.gnu.org/licenses/agpl.html

use super::gather::ExchangeData;
use crate::prelude::*;
use crate::revlog::RevlogEntry;

impl Collection {
    pub(super) fn insert_data(&mut self, data: &ExchangeData) -> Result<()> {
        self.transact_no_undo(|col| {
            col.insert_decks(&data.decks)?;
            col.insert_notes(&data.notes)?;
            col.insert_cards(&data.cards)?;
            col.insert_notetypes(&data.notetypes)?;
            col.insert_revlog(&data.revlog)?;
            col.insert_deck_configs(&data.deck_configs)
        })
    }

    fn insert_decks(&self, decks: &[Deck]) -> Result<()> {
        for deck in decks {
            self.storage.add_or_update_deck_with_existing_id(deck)?;
        }
        Ok(())
    }

    fn insert_notes(&self, notes: &[Note]) -> Result<()> {
        for note in notes {
            self.storage.add_or_update_note(note)?;
        }
        Ok(())
    }

    fn insert_cards(&self, cards: &[Card]) -> Result<()> {
        for card in cards {
            self.storage.add_or_update_card(card)?;
        }
        Ok(())
    }

    fn insert_notetypes(&self, notetypes: &[Notetype]) -> Result<()> {
        for notetype in notetypes {
            self.storage
                .add_or_update_notetype_with_existing_id(notetype)?;
        }
        Ok(())
    }

    fn insert_revlog(&self, revlog: &[RevlogEntry]) -> Result<()> {
        for entry in revlog {
            self.storage.add_revlog_entry(entry, false)?;
        }
        Ok(())
    }

    fn insert_deck_configs(&self, configs: &[DeckConfig]) -> Result<()> {
        for config in configs {
            self.storage
                .add_or_update_deck_config_with_existing_id(config)?;
        }
        Ok(())
    }
}