mmex_lib 0.1.0-beta.2

use crate::domain::currencies::{Currency, CurrencyError, CurrencyId, CurrencyRepository};
use crate::infrastructure::currencies_repository::SqlCurrencyRepository;
use rusqlite::Connection;

pub struct CurrencyService<'a> {
    conn: &'a Connection,
}

impl<'a> CurrencyService<'a> {
    pub fn new(conn: &'a Connection) -> Self {
        Self { conn }
    }

    pub fn get_all_currencies(&self) -> Result<Vec<Currency>, CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.find_all()
    }

    pub fn get_currency_by_id(&self, id: CurrencyId) -> Result<Option<Currency>, CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.find_by_id(id)
    }

    pub fn get_currency_by_symbol(&self, symbol: &str) -> Result<Option<Currency>, CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.find_by_symbol(symbol)
    }

    pub fn create_currency(&self, currency: &Currency) -> Result<Currency, CurrencyError> {
        if currency.name.trim().is_empty() || currency.symbol.trim().is_empty() {
            return Err(CurrencyError::NameRequired);
        }
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.insert(currency)
    }

    pub fn update_currency(&self, currency: &Currency) -> Result<(), CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.update(currency)
    }

    pub fn update_currency_partial(
        &self,
        id: CurrencyId,
        update: crate::domain::currencies::CurrencyUpdate,
    ) -> Result<(), CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.update_partial(id, update)
    }

    pub fn delete_currency(&self, id: CurrencyId) -> Result<(), CurrencyError> {
        let repo = SqlCurrencyRepository::new(self.conn);
        repo.delete(id)
    }
}