backbone_inventory/application/service/
picking_batch_service.rs1use backbone_core::GenericCrudService;
9
10use crate::presentation::dto::{CreatePickingBatchDto, UpdatePickingBatchDto};
11use crate::domain::entity::PickingBatch;
12use crate::infrastructure::persistence::PickingBatchRepository;
13
14pub type PickingBatchService = GenericCrudService<
29 PickingBatch,
30 CreatePickingBatchDto,
31 UpdatePickingBatchDto,
32 PickingBatchRepository,
33>;
34
35pub struct PickingBatchRowRules;
40
41#[async_trait::async_trait]
42impl backbone_core::write_guard::WriteGuard<PickingBatch> for PickingBatchRowRules {
43 async fn check(
44 &self,
45 ctx: &backbone_core::write_guard::WriteCtx<'_, PickingBatch>,
46 ) -> backbone_core::write_guard::GuardOutcome {
47 use backbone_core::row_rule as r;
48 use backbone_core::violation::Violation;
49 use backbone_core::write_guard::{GuardOutcome, WriteKind};
50 let (create, update) = (ctx.kind == WriteKind::Create, ctx.kind == WriteKind::Update);
51 let Some(after) = ctx.after.filter(|_| create || update) else {
52 return GuardOutcome::allow();
53 };
54 let Ok(row) = serde_json::to_value(after) else {
55 return GuardOutcome::allow();
56 };
57 let row = &row;
58 let old = ctx.before.and_then(|b| serde_json::to_value(b).ok());
59 let shadow = Vec::new();
60 let mut refuse = Vec::new();
61 if (create || (update && r::changed(old.as_ref(), row, &["name"]))) && !r::holds(&r::le(r::length(r::field(row, "name")), r::Val::Num(40.0_f64))) {
63 refuse.push(Violation::new("name", "max_length", "name must be at most 40 characters").with_param("max", 40_i64));
64 }
65 if (create || (update && r::changed(old.as_ref(), row, &["note"]))) && !r::holds(&r::le(r::length(r::field(row, "note")), r::Val::Num(2000.0_f64))) {
67 refuse.push(Violation::new("note", "max_length", "note must be at most 2000 characters").with_param("max", 2000_i64));
68 }
69 GuardOutcome { refuse, shadow }
70 }
71}
72