update

cmd/cart/main.go

@@ -138,6 +138,15 @@ func main() {
 		pool: pool,
 	}
 
+	klarnaClient := NewKlarnaClient(KlarnaPlaygroundUrl, os.Getenv("KLARNA_API_USERNAME"), os.Getenv("KLARNA_API_PASSWORD"))
+
+	syncedServer := NewPoolServer(pool, fmt.Sprintf("%s, %s", name, podIp), klarnaClient)
+
+	mux := http.NewServeMux()
+
+	if amqpUrl == "" {
+		log.Printf("no connection to amqp defined")
+	} else {
 		conn, err := amqp.Dial(amqpUrl)
 		if err != nil {
 			fmt.Errorf("failed to connect to RabbitMQ: %w", err)
@@ -151,6 +160,47 @@ func main() {
 		})
 		amqpListener.DefineTopics()
 		pool.AddListener(amqpListener)
+		orderHandler := NewAmqpOrderHandler(conn)
+		orderHandler.DefineTopics()
+
+		mux.HandleFunc("/push", func(w http.ResponseWriter, r *http.Request) {
+
+			if r.Method != http.MethodPost {
+				w.WriteHeader(http.StatusMethodNotAllowed)
+				return
+			}
+			orderId := r.URL.Query().Get("order_id")
+			log.Printf("Order confirmation push: %s", orderId)
+
+			order, err := klarnaClient.GetOrder(orderId)
+
+			if err != nil {
+				log.Printf("Error creating request: %v\n", err)
+				w.WriteHeader(http.StatusInternalServerError)
+				return
+			}
+
+			err = confirmOrder(order, orderHandler)
+			if err != nil {
+				log.Printf("Error confirming order: %v\n", err)
+				w.WriteHeader(http.StatusInternalServerError)
+				return
+			}
+
+			err = triggerOrderCompleted(syncedServer, order)
+			if err != nil {
+				log.Printf("Error processing cart message: %v\n", err)
+				w.WriteHeader(http.StatusInternalServerError)
+				return
+			}
+			err = klarnaClient.AcknowledgeOrder(orderId)
+			if err != nil {
+				log.Printf("Error acknowledging order: %v\n", err)
+			}
+
+			w.WriteHeader(http.StatusOK)
+		})
+	}
 
 	grpcSrv, err := actor.NewControlServer[*cart.CartGrain](controlPlaneConfig, pool)
 	if err != nil {
@@ -188,13 +238,6 @@ func main() {
 		}
 	}(GetDiscovery())
 
-	orderHandler := NewAmqpOrderHandler(conn)
-	orderHandler.DefineTopics()
-	klarnaClient := NewKlarnaClient(KlarnaPlaygroundUrl, os.Getenv("KLARNA_API_USERNAME"), os.Getenv("KLARNA_API_PASSWORD"))
-
-	syncedServer := NewPoolServer(pool, fmt.Sprintf("%s, %s", name, podIp), klarnaClient)
-
-	mux := http.NewServeMux()
 	mux.Handle("/cart/", http.StripPrefix("/cart", syncedServer.Serve()))
 	// only for local
 	mux.HandleFunc("GET /add/remote/{host}", func(w http.ResponseWriter, r *http.Request) {
@@ -295,43 +338,7 @@ func main() {
 		//}
 		w.WriteHeader(http.StatusOK)
 	})
-	mux.HandleFunc("/push", func(w http.ResponseWriter, r *http.Request) {
 
-		if r.Method != http.MethodPost {
-			w.WriteHeader(http.StatusMethodNotAllowed)
-			return
-		}
-		orderId := r.URL.Query().Get("order_id")
-		log.Printf("Order confirmation push: %s", orderId)
-
-		order, err := klarnaClient.GetOrder(orderId)
-
-		if err != nil {
-			log.Printf("Error creating request: %v\n", err)
-			w.WriteHeader(http.StatusInternalServerError)
-			return
-		}
-
-		err = confirmOrder(order, orderHandler)
-		if err != nil {
-			log.Printf("Error confirming order: %v\n", err)
-			w.WriteHeader(http.StatusInternalServerError)
-			return
-		}
-
-		err = triggerOrderCompleted(syncedServer, order)
-		if err != nil {
-			log.Printf("Error processing cart message: %v\n", err)
-			w.WriteHeader(http.StatusInternalServerError)
-			return
-		}
-		err = klarnaClient.AcknowledgeOrder(orderId)
-		if err != nil {
-			log.Printf("Error acknowledging order: %v\n", err)
-		}
-
-		w.WriteHeader(http.StatusOK)
-	})
 	mux.HandleFunc("/version", func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusOK)
 		w.Write([]byte("1.0.0"))