feat: Implement abandoned checkout reactivation and repository methods

Author: gustaavik

internal/application/usecase/checkout_usecase.go

@@ -780,6 +780,26 @@ func (uc *CheckoutUseCase) GetOrCreateCheckoutBySessionIDWithCurrency(sessionID
 		return checkout, nil
 	}
 
+	// If no active checkout found, try to get an abandoned checkout and reactivate it
+	abandonedCheckout, err := uc.checkoutRepo.GetAbandonedBySessionID(sessionID)
+	if err == nil {
+		// Reactivate the abandoned checkout
+		abandonedCheckout.Reactivate()
+
+		// If currency is specified, change currency if different
+		if currency != "" && abandonedCheckout.Currency != currency {
+			return uc.ChangeCurrency(abandonedCheckout, currency)
+		}
+
+		// Update the checkout in repository
+		err = uc.checkoutRepo.Update(abandonedCheckout)
+		if err != nil {
+			return nil, fmt.Errorf("failed to reactivate abandoned checkout: %w", err)
+		}
+
+		return abandonedCheckout, nil
+	}
+
 	// If not found, create a new one
 	var checkoutCurrency string
 	if currency != "" {

internal/domain/entity/checkout.go

@@ -367,6 +367,12 @@ func (c *Checkout) MarkAsExpired() {
 	c.LastActivityAt = time.Now()
 }
 
+// Reactivate marks an abandoned checkout as active again
+func (c *Checkout) Reactivate() {
+	c.Status = CheckoutStatusActive
+	c.LastActivityAt = time.Now()
+}
+
 // IsExpired checks if the checkout has expired
 func (c *Checkout) IsExpired() bool {
 	return time.Now().After(c.ExpiresAt)

internal/domain/entity/checkout_test.go

@@ -323,6 +323,37 @@ func TestCheckoutStatus(t *testing.T) {
 		assert.Equal(t, CheckoutStatus("abandoned"), CheckoutStatusAbandoned)
 		assert.Equal(t, CheckoutStatus("expired"), CheckoutStatusExpired)
 	})
+
+	t.Run("MarkAsAbandoned", func(t *testing.T) {
+		checkout, err := NewCheckout("session123", "USD")
+		require.NoError(t, err)
+
+		originalTime := checkout.LastActivityAt
+		time.Sleep(1 * time.Millisecond) // Ensure time difference
+
+		checkout.MarkAsAbandoned()
+
+		assert.Equal(t, CheckoutStatusAbandoned, checkout.Status)
+		assert.True(t, checkout.LastActivityAt.After(originalTime))
+	})
+
+	t.Run("Reactivate", func(t *testing.T) {
+		checkout, err := NewCheckout("session123", "USD")
+		require.NoError(t, err)
+
+		// First mark as abandoned
+		checkout.MarkAsAbandoned()
+		assert.Equal(t, CheckoutStatusAbandoned, checkout.Status)
+
+		originalTime := checkout.LastActivityAt
+		time.Sleep(1 * time.Millisecond) // Ensure time difference
+
+		// Then reactivate
+		checkout.Reactivate()
+
+		assert.Equal(t, CheckoutStatusActive, checkout.Status)
+		assert.True(t, checkout.LastActivityAt.After(originalTime))
+	})
 }
 
 func TestCheckoutDTOConversions(t *testing.T) {

internal/domain/repository/checkout_repository.go

@@ -16,6 +16,9 @@ type CheckoutRepository interface {
 	// GetBySessionID retrieves an active checkout by session ID
 	GetBySessionID(sessionID string) (*entity.Checkout, error)
 
+	// GetAbandonedBySessionID retrieves an abandoned checkout by session ID
+	GetAbandonedBySessionID(sessionID string) (*entity.Checkout, error)
+
 	// Update updates a checkout
 	Update(checkout *entity.Checkout) error
 

internal/infrastructure/repository/gorm/checkout_repository.go

@@ -88,6 +88,19 @@ func (c *CheckoutRepository) GetBySessionID(sessionID string) (*entity.Checkout,
 	return &checkout, nil
 }
 
+// GetAbandonedBySessionID implements repository.CheckoutRepository.
+func (c *CheckoutRepository) GetAbandonedBySessionID(sessionID string) (*entity.Checkout, error) {
+	var checkout entity.Checkout
+	err := c.db.Preload("Items").Preload("Items.Product").Preload("Items.ProductVariant").
+		Preload("User").
+		Where("session_id = ? AND status = ?", sessionID, entity.CheckoutStatusAbandoned).
+		First(&checkout).Error
+	if err != nil {
+		return nil, err
+	}
+	return &checkout, nil
+}
+
 // GetByUserID implements repository.CheckoutRepository.
 func (c *CheckoutRepository) GetByUserID(userID uint) (*entity.Checkout, error) {
 	var checkout entity.Checkout