stateset_embedded/
transfer_orders.rs

1//! Transfer order operations (inter-warehouse stock movement).
2
3use rust_decimal::Decimal;
4use stateset_core::{
5    CreateTransferOrder, Result, TransferOrder, TransferOrderFilter, TransferOrderId,
6    TransferOrderItemId,
7};
8use stateset_db::{Database, DatabaseCapability};
9use std::sync::Arc;
10
11/// Transfer order operations.
12pub struct TransferOrders {
13    db: Arc<dyn Database>,
14}
15
16impl std::fmt::Debug for TransferOrders {
17    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
18        f.debug_struct("TransferOrders").finish_non_exhaustive()
19    }
20}
21
22impl TransferOrders {
23    pub(crate) fn new(db: Arc<dyn Database>) -> Self {
24        Self { db }
25    }
26
27    /// Whether transfer orders are supported by the active backend.
28    #[must_use]
29    pub fn is_supported(&self) -> bool {
30        self.db.supports_capability(DatabaseCapability::TransferOrders)
31    }
32
33    fn ensure(&self) -> Result<()> {
34        self.db.ensure_capability(DatabaseCapability::TransferOrders)
35    }
36
37    /// Create a new transfer order.
38    pub fn create(&self, input: CreateTransferOrder) -> Result<TransferOrder> {
39        self.ensure()?;
40        self.db.transfer_orders().create(input)
41    }
42
43    /// Get a transfer order by ID.
44    pub fn get(&self, id: TransferOrderId) -> Result<Option<TransferOrder>> {
45        self.ensure()?;
46        self.db.transfer_orders().get(id)
47    }
48
49    /// List transfer orders with optional filtering.
50    pub fn list(&self, filter: TransferOrderFilter) -> Result<Vec<TransferOrder>> {
51        self.ensure()?;
52        self.db.transfer_orders().list(filter)
53    }
54
55    /// Mark a transfer order as shipped from the source.
56    pub fn ship(&self, id: TransferOrderId) -> Result<TransferOrder> {
57        self.ensure()?;
58        self.db.transfer_orders().ship(id)
59    }
60
61    /// Receive a quantity against a single line at the destination.
62    pub fn receive_line(
63        &self,
64        id: TransferOrderId,
65        item_id: TransferOrderItemId,
66        quantity: Decimal,
67    ) -> Result<TransferOrder> {
68        self.ensure()?;
69        self.db.transfer_orders().receive_line(id, item_id, quantity)
70    }
71
72    /// Cancel a transfer order.
73    pub fn cancel(&self, id: TransferOrderId) -> Result<TransferOrder> {
74        self.ensure()?;
75        self.db.transfer_orders().cancel(id)
76    }
77}
stateset_embedded/transfer_orders.rs

stateset_embedded/
transfer_orders.rs
