use crate::api::MmexContext;
use crate::domain::stocks::{Stock, StockError, StockId, StockUpdate};
use crate::MmexError;
use std::sync::{Arc, Mutex};
#[derive(uniffi::Object)]
pub struct StockManager {
pub(crate) context: Arc<Mutex<MmexContext>>,
}
#[uniffi::export]
impl StockManager {
pub fn get_all(&self) -> Result<Vec<Stock>, StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
Ok(ctx.stocks().get_all_stocks()?)
}
pub fn get_by_id(&self, id: i64) -> Result<Option<Stock>, StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
Ok(ctx.stocks().get_stock_by_id(StockId { v1: id })?)
}
pub fn create(&self, stock: Stock) -> Result<Stock, StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
Ok(ctx.stocks().create_stock(&stock)?)
}
pub fn update(&self, stock: Stock) -> Result<(), StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
ctx.stocks().update_stock(&stock)?;
Ok(())
}
pub fn update_partial(&self, id: i64, update: StockUpdate) -> Result<(), StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
ctx.stocks()
.update_stock_partial(StockId { v1: id }, update)?;
Ok(())
}
pub fn delete(&self, id: i64) -> Result<(), StockError> {
let ctx = self
.context
.lock()
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))?;
ctx.stocks().delete_stock(StockId { v1: id })?;
Ok(())
}
pub fn get_all_json(&self) -> Result<String, StockError> {
let stocks = self.get_all()?;
serde_json::to_string(&stocks)
.map_err(|e| StockError::Common(MmexError::Internal(e.to_string())))
}
}