add adyen

cmd/cart/pool-server.go

@@ -7,6 +7,7 @@ import (
 	"fmt"
 	"log"
 	"net/http"
+	"os"
 	"strconv"
 	"sync"
 	"time"
@@ -15,6 +16,9 @@ import (
 	"git.k6n.net/go-cart-actor/pkg/cart"
 	messages "git.k6n.net/go-cart-actor/pkg/messages"
 	"git.k6n.net/go-cart-actor/pkg/voucher"
+	"github.com/adyen/adyen-go-api-library/v14/src/adyen"
+	"github.com/adyen/adyen-go-api-library/v14/src/hmacvalidator"
+	"github.com/adyen/adyen-go-api-library/v14/src/webhook"
 	"github.com/gogo/protobuf/proto"
 	"github.com/matst80/go-redis-inventory/pkg/inventory"
 	"github.com/prometheus/client_golang/prometheus"
@@ -44,17 +48,19 @@ type PoolServer struct {
 	actor.GrainPool[*cart.CartGrain]
 	pod_name           string
 	klarnaClient       *KlarnaClient
+	adyenClient        *adyen.APIClient
 	inventoryService   inventory.InventoryService
 	reservationService inventory.CartReservationService
 }
 
-func NewPoolServer(pool actor.GrainPool[*cart.CartGrain], pod_name string, klarnaClient *KlarnaClient, inventoryService inventory.InventoryService, inventoryReservationService inventory.CartReservationService) *PoolServer {
+func NewPoolServer(pool actor.GrainPool[*cart.CartGrain], pod_name string, klarnaClient *KlarnaClient, inventoryService inventory.InventoryService, inventoryReservationService inventory.CartReservationService, adyenClient *adyen.APIClient) *PoolServer {
 	srv := &PoolServer{
 		GrainPool:          pool,
 		pod_name:           pod_name,
 		klarnaClient:       klarnaClient,
 		inventoryService:   inventoryService,
 		reservationService: inventoryReservationService,
+		adyenClient:        adyenClient,
 	}
 
 	return srv
@@ -537,8 +543,8 @@ func (s *PoolServer) ProxyHandler(fn func(w http.ResponseWriter, r *http.Request
 }
 
 var (
-	tracer = otel.Tracer(name)
-
+	tracer     = otel.Tracer(name)
+	hmacKey    = os.Getenv("ADYEN_HMAC")
 	meter      = otel.Meter(name)
 	logger     = otelslog.NewLogger(name)
 	proxyCalls metric.Int64Counter
@@ -716,6 +722,35 @@ func (s *PoolServer) CreateCheckoutOrderHandler(w http.ResponseWriter, r *http.R
 	return s.WriteResult(w, reply)
 }
 
+func (s *PoolServer) AdyenSessionHandler(w http.ResponseWriter, r *http.Request, cartId cart.CartId) error {
+
+	grain, err := s.Get(r.Context(), uint64(cartId))
+	if err != nil {
+		return err
+	}
+	host := getOriginalHost(r)
+	country := getCountryFromHost(host)
+	meta := &CheckoutMeta{
+		Terms:        fmt.Sprintf("https://%s/terms", host),
+		Checkout:     fmt.Sprintf("https://%s/checkout?order_id={checkout.order.id}", host),
+		Confirmation: fmt.Sprintf("https://%s/confirmation/{checkout.order.id}", host),
+		Country:      country,
+		Currency:     getCurrency(country),
+		Locale:       getLocale(country),
+	}
+	sessionData, err := BuildAdyenCheckoutSession(grain, meta)
+	if err != nil {
+		return err
+	}
+	service := s.adyenClient.Checkout()
+	req := service.PaymentsApi.SessionsInput().CreateCheckoutSessionRequest(*sessionData)
+	res, _, err := service.PaymentsApi.Sessions(r.Context(), req)
+	if err != nil {
+		return err
+	}
+	return s.WriteResult(w, res)
+}
+
 func (s *PoolServer) Serve(mux *http.ServeMux) {
 
 	// mux.HandleFunc("OPTIONS /cart", func(w http.ResponseWriter, r *http.Request) {
@@ -739,6 +774,24 @@ func (s *PoolServer) Serve(mux *http.ServeMux) {
 		}))
 	}
 
+	handleFunc("/adyen_hook", func(w http.ResponseWriter, r *http.Request) {
+		var notificationRequest webhook.Webhook
+		if err := json.NewDecoder(r.Body).Decode(&notificationRequest); err != nil {
+			http.Error(w, err.Error(), http.StatusBadRequest)
+			return
+		}
+		for _, notification := range notificationRequest.GetNotificationItems() {
+			isValid := hmacvalidator.ValidateHmac(*notification, hmacKey)
+			if !isValid {
+				http.Error(w, "Invalid HMAC", http.StatusUnauthorized)
+				return
+			} else {
+				log.Printf("Recieved notification event code: %s, %v", notification.EventCode, notification)
+			}
+		}
+		w.WriteHeader(http.StatusAccepted)
+	})
+
 	handleFunc("GET /cart", CookieCartIdHandler(s.ProxyHandler(s.GetCartHandler)))
 	handleFunc("GET /cart/add/{sku}", CookieCartIdHandler(s.ProxyHandler(s.AddSkuToCartHandler)))
 	handleFunc("POST /cart/add", CookieCartIdHandler(s.ProxyHandler(s.AddMultipleItemHandler)))
@@ -754,6 +807,7 @@ func (s *PoolServer) Serve(mux *http.ServeMux) {
 	handleFunc("PUT /cart/subscription-details", CookieCartIdHandler(s.ProxyHandler(s.SubscriptionDetailsHandler)))
 	handleFunc("DELETE /cart/voucher/{voucherId}", CookieCartIdHandler(s.ProxyHandler(s.RemoveVoucherHandler)))
 	handleFunc("PUT /cart/user", CookieCartIdHandler(s.ProxyHandler(s.SetUserIdHandler)))
+	handleFunc("GET /cart/adyen-session", CookieCartIdHandler(s.ProxyHandler(s.AdyenSessionHandler)))
 	handleFunc("PUT /cart/item/{itemId}/marking", CookieCartIdHandler(s.ProxyHandler(s.LineItemMarkingHandler)))
 	handleFunc("DELETE /cart/item/{itemId}/marking", CookieCartIdHandler(s.ProxyHandler(s.RemoveLineItemMarkingHandler)))