feat: Implement checkout expiration process and related commands

Author: gustaavik

Makefile

@@ -41,6 +41,7 @@ build: ## Build the application
 	go build -o bin/api ./cmd/api
 	go build -o bin/migrate ./cmd/migrate
 	go build -o bin/seed ./cmd/seed
+	go build -o bin/expire-checkouts ./cmd/expire-checkouts
 
 run: db-start ## Run the application locally with database
 	@echo "Starting database and waiting for it to be ready..."
@@ -105,3 +106,7 @@ vet: ## Run go vet
 
 mod-tidy: ## Tidy Go modules
 	go mod tidy
+
+# Maintenance commands
+expire-checkouts: ## Expire old checkouts manually
+	go run ./cmd/expire-checkouts

cmd/api/main.go

@@ -48,6 +48,9 @@ func main() {
 	// Initialize API server
 	server := api.NewServer(cfg, db, logger)
 
+	// Start background checkout expiry process
+	go startCheckoutExpiryProcess(server, logger)
+
 	// Start server in a goroutine
 	go func() {
 		logger.Info("Starting server on port %s", cfg.Server.Port)
@@ -73,3 +76,33 @@ func main() {
 
 	logger.Info("Server exited properly")
 }
+
+// startCheckoutExpiryProcess runs a background process to expire old checkouts
+func startCheckoutExpiryProcess(server *api.Server, logger logger.Logger) {
+	// Run every 15 minutes
+	ticker := time.NewTicker(15 * time.Minute)
+	defer ticker.Stop()
+
+	// Run immediately on startup
+	expireCheckouts(server, logger)
+
+	for range ticker.C {
+		expireCheckouts(server, logger)
+	}
+}
+
+// expireCheckouts expires old checkouts
+func expireCheckouts(server *api.Server, logger logger.Logger) {
+	checkoutUseCase := server.GetContainer().UseCases().CheckoutUseCase()
+	if checkoutUseCase == nil {
+		logger.Error("CheckoutUseCase not available")
+		return
+	}
+
+	amountExpired, err := checkoutUseCase.ExpireOldCheckouts()
+	if err != nil {
+		logger.Error("Failed to expire old checkouts: %v", err)
+	} else {
+		logger.Info("Expired %d old checkouts", amountExpired)
+	}
+}

cmd/expire-checkouts/main.go

@@ -0,0 +1,49 @@
+package main
+
+import (
+	"log"
+
+	"github.com/joho/godotenv"
+	"github.com/zenfulcode/commercify/config"
+	"github.com/zenfulcode/commercify/internal/infrastructure/container"
+	"github.com/zenfulcode/commercify/internal/infrastructure/database"
+	"github.com/zenfulcode/commercify/internal/infrastructure/logger"
+)
+
+func main() {
+	// Load environment variables
+	if err := godotenv.Load(); err != nil {
+		log.Println("No .env file found, using environment variables")
+	}
+
+	// Initialize logger
+	logger := logger.NewLogger()
+	logger.Info("Starting checkout expiry cleanup tool")
+
+	// Load configuration
+	cfg, err := config.LoadConfig()
+	if err != nil {
+		logger.Fatal("Failed to load configuration: %v", err)
+	}
+
+	// Connect to database
+	db, err := database.NewPostgresConnection(cfg.Database)
+	if err != nil {
+		logger.Fatal("Failed to connect to database: %v", err)
+	}
+	defer db.Close()
+
+	// Initialize dependency container
+	diContainer := container.NewContainer(cfg, db, logger)
+
+	// Get checkout use case
+	checkoutUseCase := diContainer.UseCases().CheckoutUseCase()
+
+	// Expire old checkouts
+	amountExpired, err := checkoutUseCase.ExpireOldCheckouts()
+	if err != nil {
+		logger.Fatal("Failed to expire old checkouts: %v", err)
+	}
+
+	logger.Info("Expired %d old checkouts", amountExpired)
+}

internal/application/usecase/checkout_usecase.go

@@ -492,13 +492,15 @@ func (uc *CheckoutUseCase) RemoveDiscountCode(checkout *entity.Checkout) (*entit
 }
 
 // ExpireOldCheckouts marks expired checkouts as expired
-func (uc *CheckoutUseCase) ExpireOldCheckouts() error {
+func (uc *CheckoutUseCase) ExpireOldCheckouts() (int, error) {
 	// Get expired checkouts
 	expiredCheckouts, err := uc.checkoutRepo.GetExpiredCheckouts()
 	if err != nil {
-		return err
+		return 0, err
 	}
 
+	amountExpired := len(expiredCheckouts)
+
 	// Mark each as expired
 	for _, checkout := range expiredCheckouts {
 		checkout.MarkAsExpired()
@@ -509,7 +511,7 @@ func (uc *CheckoutUseCase) ExpireOldCheckouts() error {
 		}
 	}
 
-	return nil
+	return amountExpired, nil
 }
 
 // CreateOrderFromCheckout creates an order from a checkout

internal/interfaces/api/server.go

@@ -237,6 +237,11 @@ func (s *Server) setupRoutes() {
 	admin.HandleFunc("/variants/{variantId:[0-9]+}/prices/{currency}", productHandler.RemoveVariantPrice).Methods(http.MethodDelete)
 }
 
+// GetContainer returns the dependency injection container
+func (s *Server) GetContainer() container.Container {
+	return s.container
+}
+
 // setupStripeWebhooks configures Stripe webhooks
 func (s *Server) setupStripeWebhooks(api *mux.Router, webhookHandler *handler.WebhookHandler) {
 	if !s.config.Stripe.Enabled {