diff options
| author | soryu <soryu@soryu.co> | 2026-02-16 19:01:56 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-02-16 19:01:56 +0000 |
| commit | 4bd40f047a6f4703945c6db2811d8feda27241d6 (patch) | |
| tree | b53feed7931309520c0886585487d143fc2957f4 /makima/src/server/handlers/directives.rs | |
| parent | b3de779d87450033f1e0361144c621a1d5f1dbf8 (diff) | |
| download | soryu-4bd40f047a6f4703945c6db2811d8feda27241d6.tar.gz soryu-4bd40f047a6f4703945c6db2811d8feda27241d6.zip | |
soryu-co/soryu - makima (#66)
* feat: soryu-co/soryu - makima: Fix contracts page scrolling overflow
* WIP: heartbeat checkpoint
* WIP: heartbeat checkpoint
* WIP: heartbeat checkpoint
* WIP: heartbeat checkpoint
Diffstat (limited to 'makima/src/server/handlers/directives.rs')
| -rw-r--r-- | makima/src/server/handlers/directives.rs | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/makima/src/server/handlers/directives.rs b/makima/src/server/handlers/directives.rs index 960da94..15df6d5 100644 --- a/makima/src/server/handlers/directives.rs +++ b/makima/src/server/handlers/directives.rs @@ -1063,7 +1063,7 @@ pub async fn pick_up_orders( }; // Fetch available orders - let orders = match repository::get_available_orders_for_pickup(pool, auth.owner_id).await { + let orders = match repository::get_available_orders_for_pickup(pool, auth.owner_id, id).await { Ok(o) => o, Err(e) => { tracing::error!("Failed to fetch available orders: {}", e); @@ -1078,7 +1078,7 @@ pub async fn pick_up_orders( // If no orders available, return early if orders.is_empty() { return Json(PickUpOrdersResponse { - message: "No orders available to pick up".to_string(), + message: "No orders available to plan".to_string(), order_count: 0, task_id: None, }) @@ -1125,6 +1125,13 @@ pub async fn pick_up_orders( .into_response(); } + // Mark picked-up orders as in_progress + if let Err(e) = + repository::bulk_update_order_status(pool, auth.owner_id, &order_ids, "in_progress").await + { + tracing::warn!("Failed to update order status to in_progress: {}", e); + } + // Create the planning task let req = CreateTaskRequest { contract_id: None, @@ -1199,7 +1206,7 @@ pub async fn pick_up_orders( let _ = repository::advance_directive_ready_steps(pool, id).await; Json(PickUpOrdersResponse { - message: format!("Picked up {} orders", order_count), + message: format!("Planning {} orders", order_count), order_count, task_id: Some(task.id), }) |