feat: Add force delete command for expired and abandoned checkouts

Author: gustaavik

Makefile

@@ -129,3 +129,6 @@ mod-tidy: ## Tidy Go modules
 # Maintenance commands
 expire-checkouts: ## Expire old checkouts manually
 	go run ./cmd/expire-checkouts
+
+force-delete-checkouts: ## Force delete all expired, abandoned, and old completed checkouts
+	go run ./cmd/expire-checkouts -force

cmd/expire-checkouts/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"flag"
 	"log"
 
 	"github.com/joho/godotenv"
@@ -11,14 +12,22 @@ import (
 )
 
 func main() {
+	// Parse command line flags
+	forceDelete := flag.Bool("force", false, "Force delete all expired, abandoned, and old completed checkouts")
+	flag.Parse()
+
 	// 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")
+	if *forceDelete {
+		logger.Info("Starting checkout force deletion tool")
+	} else {
+		logger.Info("Starting checkout expiry cleanup tool")
+	}
 
 	// Load configuration
 	cfg, err := config.LoadConfig()
@@ -39,15 +48,27 @@ func main() {
 	// Get checkout use case
 	checkoutUseCase := diContainer.UseCases().CheckoutUseCase()
 
-	// Expire old checkouts
-	result, err := checkoutUseCase.ExpireOldCheckouts()
-	if err != nil {
-		logger.Fatal("Failed to expire old checkouts: %v", err)
-	}
+	if *forceDelete {
+		// Force delete all expired checkouts
+		deleteResult, err := checkoutUseCase.ForceDeleteAllExpiredCheckouts()
+		if err != nil {
+			logger.Fatal("Failed to force delete expired checkouts: %v", err)
+		}
+
+		logger.Info("Force deletion completed:")
+		logger.Info("- Force deleted checkouts: %d", deleteResult.DeletedCount)
+		logger.Info("Total processed: %d", deleteResult.DeletedCount)
+	} else {
+		// Regular expire old checkouts
+		expireResult, err := checkoutUseCase.ExpireOldCheckouts()
+		if err != nil {
+			logger.Fatal("Failed to expire old checkouts: %v", err)
+		}
 
-	logger.Info("Checkout cleanup completed:")
-	logger.Info("- Abandoned checkouts: %d", result.AbandonedCount)
-	logger.Info("- Deleted checkouts: %d", result.DeletedCount)
-	logger.Info("- Expired checkouts: %d", result.ExpiredCount)
-	logger.Info("Total processed: %d", result.AbandonedCount+result.DeletedCount+result.ExpiredCount)
+		logger.Info("Checkout cleanup completed:")
+		logger.Info("- Abandoned checkouts: %d", expireResult.AbandonedCount)
+		logger.Info("- Deleted checkouts: %d", expireResult.DeletedCount)
+		logger.Info("- Expired checkouts: %d", expireResult.ExpiredCount)
+		logger.Info("Total processed: %d", expireResult.AbandonedCount+expireResult.DeletedCount+expireResult.ExpiredCount)
+	}
 }

internal/application/usecase/checkout_usecase.go

@@ -572,6 +572,28 @@ func (uc *CheckoutUseCase) ExpireOldCheckoutsLegacy() (int, error) {
 	return result.AbandonedCount + result.DeletedCount + result.ExpiredCount, nil
 }
 
+// ForceDeleteAllExpiredCheckouts forcefully deletes all expired, abandoned, and old completed checkouts
+func (uc *CheckoutUseCase) ForceDeleteAllExpiredCheckouts() (*CheckoutCleanupResult, error) {
+	result := &CheckoutCleanupResult{}
+
+	// Get all expired checkouts for deletion
+	checkoutsToDelete, err := uc.checkoutRepo.GetAllExpiredCheckoutsForDeletion()
+	if err != nil {
+		return result, fmt.Errorf("failed to get expired checkouts for deletion: %w", err)
+	}
+
+	for _, checkout := range checkoutsToDelete {
+		err = uc.checkoutRepo.Delete(checkout.ID)
+		if err != nil {
+			log.Printf("Failed to force delete checkout %d: %v", checkout.ID, err)
+			continue
+		}
+		result.DeletedCount++
+	}
+
+	return result, nil
+}
+
 // CreateOrderFromCheckout creates an order from a checkout
 func (uc *CheckoutUseCase) CreateOrderFromCheckout(checkoutID uint) (*entity.Order, error) {
 	// Get checkout

internal/domain/repository/checkout_repository.go

@@ -48,4 +48,7 @@ type CheckoutRepository interface {
 
 	// HasActiveCheckoutsWithProduct checks if a product has any active checkouts
 	HasActiveCheckoutsWithProduct(productID uint) (bool, error)
+
+	// GetAllExpiredCheckoutsForDeletion retrieves all expired checkouts for force deletion
+	GetAllExpiredCheckoutsForDeletion() ([]*entity.Checkout, error)
 }

internal/infrastructure/repository/gorm/checkout_repository.go

@@ -249,6 +249,28 @@ func (c *CheckoutRepository) Update(checkout *entity.Checkout) error {
 	})
 }
 
+// GetAllExpiredCheckoutsForDeletion implements repository.CheckoutRepository.
+func (c *CheckoutRepository) GetAllExpiredCheckoutsForDeletion() ([]*entity.Checkout, error) {
+	var checkouts []*entity.Checkout
+
+	// Get all checkouts that are expired, abandoned, or completed (older than 30 days to be safe)
+	thirtyDaysAgo := time.Now().AddDate(0, 0, -30)
+
+	err := c.db.Preload("Items").Preload("Items.Product").Preload("Items.ProductVariant").
+		Where("status IN (?, ?, ?) OR updated_at < ?",
+			entity.CheckoutStatusExpired,
+			entity.CheckoutStatusAbandoned,
+			entity.CheckoutStatusCompleted,
+			thirtyDaysAgo).
+		Find(&checkouts).Error
+
+	if err != nil {
+		return nil, fmt.Errorf("failed to get expired checkouts for deletion: %w", err)
+	}
+
+	return checkouts, nil
+}
+
 // NewCheckoutRepository creates a new GORM-based CheckoutRepository
 func NewCheckoutRepository(db *gorm.DB) repository.CheckoutRepository {
 	return &CheckoutRepository{db: db}

readme.md

@@ -481,3 +481,63 @@ Use Stripe's test cards for development:
 - `4000 0000 0000 9995` - Payment declined
 
 For more test card numbers, visit [Stripe's testing documentation](https://stripe.com/docs/testing).
+
+## Maintenance Commands
+
+The project includes useful maintenance commands for database cleanup and optimization:
+
+### Checkout Cleanup
+
+The system provides two modes for managing expired and old checkouts:
+
+```bash
+# Regular cleanup (recommended for scheduled runs)
+make expire-checkouts
+# or
+go run ./cmd/expire-checkouts
+```
+
+This command performs the following operations:
+
+- Marks checkouts with customer/shipping info as **abandoned** after 15 minutes of inactivity
+- **Deletes** empty checkouts older than 24 hours
+- **Deletes** abandoned checkouts older than 7 days
+- Marks remaining expired checkouts as **expired** (legacy support)
+
+```bash
+# Force deletion (use with caution)
+make force-delete-checkouts
+# or
+go run ./cmd/expire-checkouts -force
+```
+
+This command performs aggressive cleanup:
+
+- **Force deletes** all expired, abandoned, and completed checkouts
+- **Force deletes** checkouts older than 30 days regardless of status
+- Should be used carefully as it permanently removes checkout data
+
+### Usage Examples
+
+```bash
+# Show help and available options
+./bin/expire-checkouts --help
+
+# Regular cleanup (safe for automation)
+./bin/expire-checkouts
+
+# Force delete all expired checkouts
+./bin/expire-checkouts -force
+```
+
+### Scheduling Maintenance
+
+For production environments, consider scheduling regular cleanup:
+
+```bash
+# Example crontab entry (runs every hour)
+0 * * * * /path/to/commercify/bin/expire-checkouts
+
+# Example crontab entry for weekly force cleanup (use with caution)
+0 2 * * 0 /path/to/commercify/bin/expire-checkouts -force
+```