implement validate callback

main.go

@@ -220,6 +220,7 @@ func main() {
 					Terms:        "https://slask-finder.tornberg.me/terms",
 					Checkout:     "https://slask-finder.tornberg.me/checkout?order_id={checkout.order.id}",
 					Confirmation: "https://slask-finder.tornberg.me/confirmation/{checkout.order.id}",
+					Validation:   "https://cart.tornberg.me/validation",
 					Push:         "https://cart.tornberg.me/push?order_id={checkout.order.id}",
 				},
 			})
@@ -262,6 +263,31 @@ func main() {
 		w.WriteHeader(http.StatusOK)
 		w.Write([]byte(fmt.Sprintf(tpl, order.HTMLSnippet)))
 	})
+	mux.HandleFunc("/validate", func(w http.ResponseWriter, r *http.Request) {
+		if r.Method != "POST" {
+			w.WriteHeader(http.StatusMethodNotAllowed)
+			return
+		}
+		order := &CheckoutOrder{}
+		err := json.NewDecoder(r.Body).Decode(order)
+		if err != nil {
+			w.WriteHeader(http.StatusBadRequest)
+		}
+		err = confirmOrder(order, orderHandler)
+		if err != nil {
+			log.Printf("Error confirming order: %v\n", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+
+		err = triggerOrderCompleted(err, syncedServer, order)
+		if err != nil {
+			log.Printf("Error processing cart message: %v\n", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+		w.WriteHeader(http.StatusOK)
+	})
 	mux.HandleFunc("/push", func(w http.ResponseWriter, r *http.Request) {
 
 		if r.Method != http.MethodPost {
@@ -276,39 +302,21 @@ func main() {
 		if err != nil {
 			log.Printf("Error creating request: %v\n", err)
 			w.WriteHeader(http.StatusInternalServerError)
-			w.Write([]byte(err.Error()))
 			return
 		}
 
-		orderToSend, err := json.Marshal(order)
+		err = confirmOrder(order, orderHandler)
 		if err != nil {
-			log.Printf("Error marshaling order: %v\n", err)
-		} else {
-			err = orderHandler.Connect()
-			if err != nil {
-				log.Printf("Error connecting to order handler: %v\n", err)
-				w.WriteHeader(http.StatusInternalServerError)
-				w.Write([]byte(err.Error()))
-				return
-			}
-			defer orderHandler.Close()
-			err = orderHandler.OrderCompleted(orderToSend)
-			if err != nil {
-				log.Printf("Error sending order: %v\n", err)
-				w.WriteHeader(http.StatusInternalServerError)
-				w.Write([]byte(err.Error()))
-				return
-			}
+			log.Printf("Error confirming order: %v\n", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
 		}
-		_, err = syncedServer.pool.Process(ToCartId(order.MerchantReference1), Message{
-			Type: OrderCompletedType,
-			Content: &messages.OrderCreated{
-				OrderId: order.ID,
-				Status:  order.Status,
-			},
-		})
+
+		err = triggerOrderCompleted(err, syncedServer, order)
 		if err != nil {
 			log.Printf("Error processing cart message: %v\n", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
 		}
 
 		w.WriteHeader(http.StatusOK)
@@ -334,3 +342,32 @@ func main() {
 	<-done
 
 }
+
+func triggerOrderCompleted(err error, syncedServer *PoolServer, order *CheckoutOrder) error {
+	_, err = syncedServer.pool.Process(ToCartId(order.MerchantReference1), Message{
+		Type: OrderCompletedType,
+		Content: &messages.OrderCreated{
+			OrderId: order.ID,
+			Status:  order.Status,
+		},
+	})
+	return err
+}
+
+func confirmOrder(order *CheckoutOrder, orderHandler *AmqpOrderHandler) error {
+	orderToSend, err := json.Marshal(order)
+	if err != nil {
+		return err
+	}
+	err = orderHandler.Connect()
+	if err != nil {
+		return err
+	}
+	defer orderHandler.Close()
+	err = orderHandler.OrderCompleted(orderToSend)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}