From 7fd6b22c6b5b6e3d7c006b1257b401c054f435f3 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 18 Nov 2025 22:33:08 +0100 Subject: [PATCH] Update checkout_server.go --- cmd/cart/checkout_server.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/cmd/cart/checkout_server.go b/cmd/cart/checkout_server.go index 42a7c72..9e8b04d 100644 --- a/cmd/cart/checkout_server.go +++ b/cmd/cart/checkout_server.go @@ -10,6 +10,7 @@ import ( "git.tornberg.me/go-cart-actor/pkg/actor" "git.tornberg.me/go-cart-actor/pkg/cart" + "git.tornberg.me/go-cart-actor/pkg/messages" "git.tornberg.me/mats/go-redis-inventory/pkg/inventory" amqp "github.com/rabbitmq/amqp091-go" ) @@ -84,11 +85,16 @@ func (a *App) HandleCheckoutRequests(amqpUrl string, mux *http.ServeMux, invento if inventoryService != nil { inventoryRequests := getInventoryRequests(grain.Items) err = inventoryService.ReserveInventory(r.Context(), inventoryRequests...) + if err != nil { logger.WarnContext(r.Context(), "placeorder inventory reservation failed") w.WriteHeader(http.StatusNotAcceptable) return } + a.pool.Apply(r.Context(), uint64(grain.Id), &messages.InventoryReserved{ + Id: grain.Id.String(), + Status: "success", + }) } err = confirmOrder(r.Context(), order, orderHandler)