Struct PickingBatchProjectionRepository 

pub struct PickingBatchProjectionRepository;

The batch mint/membership/probe SQL. Stateless — every method takes the caller’s connection so the header insert, the membership write, and the projection recompute commit as one unit.

Implementations

impl PickingBatchProjectionRepository

pub fn new() -> Self

pub async fn insert_batch( &self, conn: &mut PgConnection, b: &NewBatchRow<'_>, ) -> Result<(), Error>

Insert the batch header (a draft grouping point). Leaks the raw sqlx::Error deliberately so the service can turn a unique violation on the name — the composing decorator’s org-scoped arbiter — into the typed duplicate-name error.

pub async fn fetch_batch( &self, conn: &mut PgConnection, batch_id: Uuid, ) -> Result<Option<BatchHeaderRow>, Error>

Read one batch header (probe surface — the projected state is READ here, never asserted by callers).

pub async fn fetch_members( &self, conn: &mut PgConnection, batch_id: Uuid, ) -> Result<Vec<BatchMemberRow>, Error>

Read a batch’s member pickings (the projection inputs, for the probe surface).

pub async fn add_member( &self, conn: &mut PgConnection, batch_id: Uuid, picking_id: Uuid, ) -> Result<(), Error>

Attach a picking to its batch: set the membership pointer and stamp the SB-1 discriminator (had_members — once true, an empty batch auto-cancels instead of falling back to draft). The caller reprojects right after; this write only moves the pointer.

pub async fn remove_member( &self, conn: &mut PgConnection, batch_id: Uuid, picking_id: Uuid, ) -> Result<bool, Error>

Detach a picking from its batch (removal is always allowed — a done or cancelled picking still leaves its batch). Returns false when the picking was not a member.

pub async fn reproject_batch( &self, conn: &mut PgConnection, batch_id: Uuid, ) -> Result<Option<String>, Error>

The SB-1 projection recompute (spec misc-features.md SB, ADR-0016 projection shape). picking_batches.state is a STORED COMPUTE over its member pickings: the LEAST-advanced live member band, with cancelled members dropping out of the aggregation entirely — live member draft/confirmed → batch draft (nothing ready to wave-pick yet) every live member ≥ waiting → waiting every live member ≥ assigned → ready every live member done → done no live member, members exist (all cancelled) → cancel no member at all, the batch HAS grouped one before → cancel (auto-cancel on empty — SB-1: an emptied batch must not linger as a live work item) no member at all, never grouped one → draft (a freshly minted batch the operator is about to fill) A member’s confirmed counts at the draft band (Odoo’s _compute_state has no confirmed in any prefix: a confirmed-but-unreserved picking is not wave-ready). Returns the new projected state (text), or None when the batch row is gone.

pub async fn picking_membership( &self, conn: &mut PgConnection, picking_id: Uuid, ) -> Result<Option<Option<Uuid>>, Error>

Read one picking’s batch membership. Outer None = the transfer row is absent (or fenced out — the ambient org scope’s fence hides it); inner None = the picking belongs to no batch. The membership-guard input for the typed already-batched refusal.

pub async fn reproject_batch_of_picking( &self, conn: &mut PgConnection, picking_id: Uuid, ) -> Result<Option<String>, Error>

The picking-projection cascade entry: after a picking’s own state was re-derived, re-derive its batch’s (if the picking belongs to one). Called by StockMoveRepository::reproject_picking on every member-state change so the batch never lags its members — the picking and its batch roll-up commit in the same transaction.

Trait Implementations

impl Default for PickingBatchProjectionRepository

fn default() -> Self

Returns the “default value” for a type.