Struct StockAdjustmentRepository 

pub struct StockAdjustmentRepository;

The quant staging/apply SQL. Stateless; every method takes the caller’s connection.

Implementations

impl StockAdjustmentRepository

pub fn new() -> Self

pub async fn lock_quant( &self, conn: &mut PgConnection, selector: QuantSelector, ) -> Result<Option<QuantCountRow>, Error>

Lock the addressed quant FOR UPDATE (the reservation-apex row — every count stage/apply serializes here). None when no quant matches; the service then either errors (apply) or initializes one (stage).

pub async fn init_quant( &self, conn: &mut PgConnection, item_id: Uuid, location_id: Uuid, ) -> Result<Uuid, Error>

Initialize the zeroed quant for (item, location) — the count surface exists even before any stock does. Returns its id; the caller has already verified the location is internal (R13).

pub async fn stage_count( &self, conn: &mut PgConnection, quant_id: Uuid, counted: Decimal, diff: Decimal, ) -> Result<(), Error>

Stage a counted quantity on a quant (T4): record the count and its stored compute (inventory_diff_quantity = counted - quantity), and raise the inventory_quantity_set gate that Apply demands. The pending-count partial index (WHERE inventory_quantity_set = true) is the worklist this feeds.

pub async fn consume_staged_count( &self, conn: &mut PgConnection, quant_id: Uuid, ) -> Result<(), Error>

Consume the staged count: clear the count fields and drop the inventory_quantity_set gate. This deliberately does NOT write quantity — the is_inventory move the apply minted through the engine pipeline is the one writer that reconciled the quant to the count (its two-step sync maintains quantity, reserved_quantity, and the T2 stored compute together). Consuming the staging is what makes re-application a no-op: a second apply finds the gate down and mints nothing.

pub async fn staged_counts_at_location( &self, conn: &mut PgConnection, location_id: Uuid, ) -> Result<Vec<StagedCountRow>, Error>

All quants at a location with a staged-but-unapplied count (the pending-count worklist the partial index WHERE inventory_quantity_set = true serves).

Trait Implementations

impl Default for StockAdjustmentRepository

fn default() -> Self

Returns the “default value” for a type.