retry logic

Author: Aniruddha434

frontend/src/services/paymentService.js

@@ -4,6 +4,11 @@ const API_BASE_URL = import.meta.env.VITE_API_BASE_URL || 'http://localhost:5000
 
 class PaymentService {
   constructor() {
+    // Cache for pricing data to avoid repeated API calls
+    this.pricingCache = null
+    this.pricingCacheExpiry = null
+    this.CACHE_DURATION = 5 * 60 * 1000 // 5 minutes
+
     this.api = axios.create({
       baseURL: API_BASE_URL,
       headers: {
@@ -26,47 +31,106 @@ class PaymentService {
       return config
     })
 
-    // Handle response errors
+    // Handle response errors with retry logic for rate limiting
     this.api.interceptors.response.use(
       (response) => response.data,
       (error) => {
-        const message = error.response?.data?.message || error.message || 'An error occurred'
-        throw new Error(message)
+        const enhancedError = new Error(error.response?.data?.message || error.message || 'An error occurred')
+        enhancedError.status = error.response?.status
+        enhancedError.response = error.response
+        enhancedError.retryAfter = error.response?.data?.retryAfter
+        throw enhancedError
       }
     )
   }
 
-  // Create payment order
+  // Helper method to handle retries for rate limiting
+  async makeRequestWithRetry(requestFn, retryCount = 0, maxRetries = 3) {
+    try {
+      return await requestFn()
+    } catch (error) {
+      // Handle rate limiting (HTTP 429)
+      if (error.status === 429 && retryCount < maxRetries) {
+        const retryAfter = error.retryAfter || Math.pow(2, retryCount + 1) // Exponential backoff
+        const delayMs = retryAfter * 1000
+
+        console.warn(`[PaymentService] Rate limited (429). Retrying after ${delayMs}ms... (attempt ${retryCount + 1}/${maxRetries})`)
+
+        await new Promise(resolve => setTimeout(resolve, delayMs))
+        return this.makeRequestWithRetry(requestFn, retryCount + 1, maxRetries)
+      }
+
+      // For 429 errors that exceed max retries, provide user-friendly message
+      if (error.status === 429) {
+        const userFriendlyError = new Error('Too many requests. Please wait a moment and try again.')
+        userFriendlyError.status = 429
+        userFriendlyError.isRateLimit = true
+        throw userFriendlyError
+      }
+
+      throw error
+    }
+  }
+
+  // Create payment order with retry logic
   async createOrder(amount, planId) {
-    const response = await this.api.post('/payment/create-order', {
-      amount,
-      planId
+    return this.makeRequestWithRetry(async () => {
+      const response = await this.api.post('/payment/create-order', {
+        amount,
+        planId
+      })
+      return response
     })
-    return response
   }
 
-  // Get international pricing based on user's location
+  // Get international pricing with caching and retry logic
   async getInternationalPricing() {
-    const response = await this.api.get('/payment/pricing')
-    return response
+    // Check cache first
+    if (this.pricingCache && this.pricingCacheExpiry && Date.now() < this.pricingCacheExpiry) {
+      console.log('[PaymentService] Returning cached pricing data')
+      return this.pricingCache
+    }
+
+    return this.makeRequestWithRetry(async () => {
+      const response = await this.api.get('/payment/pricing')
+
+      // Cache the response
+      this.pricingCache = response
+      this.pricingCacheExpiry = Date.now() + this.CACHE_DURATION
+
+      return response
+    })
   }
 
-  // Verify payment
+  // Verify payment with retry logic
   async verifyPayment(paymentData) {
-    const response = await this.api.post('/payment/verify', paymentData)
-    return response
+    return this.makeRequestWithRetry(async () => {
+      const response = await this.api.post('/payment/verify', paymentData)
+      return response
+    })
   }
 
-  // Get payment history
+  // Get payment history with retry logic
   async getPaymentHistory() {
-    const response = await this.api.get('/payment/history')
-    return response.payments
+    return this.makeRequestWithRetry(async () => {
+      const response = await this.api.get('/payment/history')
+      return response.payments
+    })
   }
 
-  // Cancel subscription
+  // Cancel subscription with retry logic
   async cancelSubscription() {
-    const response = await this.api.post('/payment/cancel-subscription')
-    return response
+    return this.makeRequestWithRetry(async () => {
+      const response = await this.api.post('/payment/cancel-subscription')
+      return response
+    })
+  }
+
+  // Clear pricing cache (useful for testing or manual refresh)
+  clearPricingCache() {
+    this.pricingCache = null
+    this.pricingCacheExpiry = null
+    console.log('[PaymentService] Pricing cache cleared')
   }
 }