voucher change

cmd/cart/main.go

@@ -149,7 +149,7 @@ func main() {
 	} else {
 		conn, err := amqp.Dial(amqpUrl)
 		if err != nil {
-			fmt.Errorf("failed to connect to RabbitMQ: %w", err)
+			log.Fatalf("failed to connect to RabbitMQ: %w", err)
 		}
 
 		amqpListener := actor.NewAmqpListener(conn, func(id uint64, msg []actor.ApplyResult) (any, error) {

cmd/cart/pool-server.go

@@ -456,6 +456,10 @@ func (s *PoolServer) AddVoucherHandler(w http.ResponseWriter, r *http.Request, c
 	v := voucher.Service{}
 	msg, err := v.GetVoucher(data.VoucherCode)
 	if err != nil {
+		s.ApplyLocal(cartId, &messages.PreConditionFailed{
+			Operation: "AddVoucher",
+			Error:     err.Error(),
+		})
 		w.WriteHeader(http.StatusInternalServerError)
 		w.Write([]byte(err.Error()))
 		return err