notification url

cmd/cart/checkout_builder.go

@@ -14,6 +14,7 @@ type CheckoutMeta struct {
 	Terms        string
 	Checkout     string
 	Confirmation string
+	Notification string
 	Validation   string
 	Push         string
 	Country      string
@@ -107,6 +108,7 @@ func BuildCheckoutOrderPayload(grain *cart.CartGrain, meta *CheckoutMeta) ([]byt
 			Terms:        meta.Terms,
 			Checkout:     meta.Checkout,
 			Confirmation: meta.Confirmation,
+			Notification: meta.Notification,
 			Validation:   meta.Validation,
 			Push:         meta.Push,
 		},

cmd/cart/checkout_server.go

@@ -102,6 +102,21 @@ func (a *App) HandleCheckoutRequests(amqpUrl string, mux *http.ServeMux) {
 		w.WriteHeader(http.StatusOK)
 		fmt.Fprintf(w, tpl, order.HTMLSnippet)
 	})
+	mux.HandleFunc("/notification", func(w http.ResponseWriter, r *http.Request) {
+		log.Printf("Klarna order notification, method: %s", r.Method)
+		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)
+		}
+		log.Printf("Klarna order notification: %s", order.ID)
+
+		w.WriteHeader(http.StatusOK)
+	})
 	mux.HandleFunc("POST /validate", func(w http.ResponseWriter, r *http.Request) {
 		log.Printf("Klarna order validation, method: %s", r.Method)
 		if r.Method != "POST" {

cmd/cart/pool-server.go

@@ -318,6 +318,7 @@ func (s *PoolServer) CreateOrUpdateCheckout(ctx context.Context, host string, id
 		Confirmation: fmt.Sprintf("https://%s/confirmation/{checkout.order.id}", host),
 		Validation:   fmt.Sprintf("https://%s/validate", host),
 		Push:         fmt.Sprintf("https://%s/push?order_id={checkout.order.id}", host),
+		Notification: "https://cart.tornberg.me/notification",
 		Country:      country,
 		Currency:     getCurrency(country),
 		Locale:       getLocale(country),