red/cdb
red/cdb
1
0
Fork 0
Code Issues 2 Pull requests Projects Releases Packages 1 Wiki Activity

fix

Browse source
This commit is contained in:
JMARyA 2024-09-25 22:59:00 +02:00
parent e3128d7214
commit 9468629302
Signed by: jmarya
GPG key ID: 901B2ADDF27C2263
2 changed files with 26 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
src/flow.rs
View file

@ -164,27 +164,27 @@ impl Flow {
for prod in produced {
let t = Item::get(&prod.item)
.await
.ok_or_else(item_does_not_exist_error)?
.variant(&prod.variant)
.ok_or_else(variant_does_not_exist_error)?;
.await
.ok_or_else(item_does_not_exist_error)?
.variant(&prod.variant)
.ok_or_else(variant_does_not_exist_error)?;
t_create.push((t, prod));
}
t_create.push((t, prod));
}
for (item, info) in t_create {
let t = item
.supply(
Price::zero(),
Some(&format!("flow::{}::{}", self.kind.id(), self._id)),
info.location.as_ref().map(|x| x.as_str()),
info.note.as_ref().map(|x| x.as_str()),
)
.await;
ret.entry(item.item_variant_id().clone())
.or_insert(Vec::new())
.push(t._id.clone());
produced_ref.push(t.reference());
let t = item
.supply(
Price::zero(),
Some(&format!("flow::{}::{}", self.kind.id(), self._id)),
info.location.as_ref().map(|x| x.as_str()),
info.note.as_ref().map(|x| x.as_str()),
)
.await;
ret.entry(item.item_variant_id().clone())
.or_insert(Vec::new())
.push(t._id.clone());
produced_ref.push(t.reference());
}
self.change()

8
src/routes/flow.rs
View file

@ -156,6 +156,10 @@ pub async fn end_flow_route(id: &str, form: Json<EndFlow>) -> FallibleApiRespons
.await
.ok_or_else(|| api_error("Flow not found"))?;
if flow.done.is_some() {
return Err(api_error("Flow already ended"));
}
if let Some(produced) = &form.produced {
let prod = flow.end_with_produce(produced).await?;
Ok(json!({"produced": prod}))
@ -175,6 +179,10 @@ pub async fn continue_flow_route(
.await
.ok_or_else(|| api_error("Flow not found"))?;
if this_flow.done.is_some() {
return Err(api_error("Flow already ended"));
}
// create next flow
let next_kind = flows
.get(this_flow.kind.id())