stateset_embedded/
price_levels.rs

1//! Price level operations (B2B pricing tiers).
2
3use rust_decimal::Decimal;
4use stateset_core::{
5    CreatePriceLevel, PriceLevel, PriceLevelEntry, PriceLevelFilter, PriceLevelId, ProductId,
6    Result, UpdatePriceLevel,
7};
8use stateset_db::{Database, DatabaseCapability};
9use std::sync::Arc;
10
11/// Price level operations.
12pub struct PriceLevels {
13    db: Arc<dyn Database>,
14}
15
16impl std::fmt::Debug for PriceLevels {
17    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
18        f.debug_struct("PriceLevels").finish_non_exhaustive()
19    }
20}
21
22impl PriceLevels {
23    pub(crate) fn new(db: Arc<dyn Database>) -> Self {
24        Self { db }
25    }
26
27    /// Whether price levels are supported by the active backend.
28    #[must_use]
29    pub fn is_supported(&self) -> bool {
30        self.db.supports_capability(DatabaseCapability::PriceLevels)
31    }
32
33    fn ensure(&self) -> Result<()> {
34        self.db.ensure_capability(DatabaseCapability::PriceLevels)
35    }
36
37    /// Create a new price level.
38    pub fn create(&self, input: CreatePriceLevel) -> Result<PriceLevel> {
39        self.ensure()?;
40        self.db.price_levels().create(input)
41    }
42
43    /// Get a price level by ID.
44    pub fn get(&self, id: PriceLevelId) -> Result<Option<PriceLevel>> {
45        self.ensure()?;
46        self.db.price_levels().get(id)
47    }
48
49    /// Update a price level.
50    pub fn update(&self, id: PriceLevelId, input: UpdatePriceLevel) -> Result<PriceLevel> {
51        self.ensure()?;
52        self.db.price_levels().update(id, input)
53    }
54
55    /// List price levels with optional filtering.
56    pub fn list(&self, filter: PriceLevelFilter) -> Result<Vec<PriceLevel>> {
57        self.ensure()?;
58        self.db.price_levels().list(filter)
59    }
60
61    /// Delete a price level and its entries.
62    pub fn delete(&self, id: PriceLevelId) -> Result<()> {
63        self.ensure()?;
64        self.db.price_levels().delete(id)
65    }
66
67    /// Upsert a per-product fixed price entry.
68    pub fn set_entry(
69        &self,
70        id: PriceLevelId,
71        product_id: ProductId,
72        price: Decimal,
73    ) -> Result<PriceLevelEntry> {
74        self.ensure()?;
75        self.db.price_levels().set_entry(id, product_id, price)
76    }
77
78    /// Remove a per-product entry.
79    pub fn delete_entry(&self, id: PriceLevelId, product_id: ProductId) -> Result<()> {
80        self.ensure()?;
81        self.db.price_levels().delete_entry(id, product_id)
82    }
83
84    /// List per-product entries for a level.
85    pub fn list_entries(&self, id: PriceLevelId) -> Result<Vec<PriceLevelEntry>> {
86        self.ensure()?;
87        self.db.price_levels().list_entries(id)
88    }
89}
stateset_embedded/price_levels.rs

stateset_embedded/
price_levels.rs
