Optimización de llamadas a la API y del procesamiento de webhooks

Why Optimize Stripe Interactions?

API Rate Limits Explained

Handling Rate Limits with Backoff

import com.stripe.exception.StripeException;
import com.stripe.model.Customer;
import com.stripe.param.CustomerCreateParams;

public class Main {
  public static void main(String[] args) {
    // This is a simplified example.
    // In real code, handle API key and error details.
    int maxRetries = 5;
    long delayMs = 100; // Start with 100ms

    for (int i = 0; i < maxRetries; i++) {
      try {
        CustomerCreateParams params = CustomerCreateParams.builder()
            .setName("Jane Doe")
            .setEmail("jane@example.com")
            .build();
        // Customer.create(params); // Uncomment to run with real Stripe key
        System.out.println("Customer creation simulated!");
        break; // Exit loop on success
      } catch (StripeException e) {
        if (e.getStatusCode() == 429) { // Too Many Requests
          System.out.println("Rate limit hit. Retrying in " + delayMs + "ms...");
          try {
            Thread.sleep(delayMs);
          } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
            System.err.println("Retry interrupted.");
            break;
          }
          delayMs *= 2; // Exponential increase
        } else {
          System.err.println("Stripe error: " + e.getMessage());
          break; // Other errors, don't retry
        }
      }
    }
  }
}

What is Idempotency?

Using Idempotency Keys

import com.stripe.exception.StripeException;
import com.stripe.model.Charge;
import com.stripe.param.ChargeCreateParams;
import java.util.UUID;

public class Main {
  public static void main(String[] args) {
    // Set your secret key (e.g., Stripe.apiKey = "sk_test_...");
    // This is a simplified example.

    String idempotencyKey = UUID.randomUUID().toString();
    String sourceToken = "tok_visa"; // Simulate a payment token

    try {
      ChargeCreateParams params = ChargeCreateParams.builder()
          .setAmount(1000L) // $10.00
          .setCurrency("usd")
          .setSource(sourceToken)
          .setDescription("Example charge")
          .build();

      // Charge charge = Charge.create(params, 
      //     new com.stripe.net.RequestOptions.RequestOptionsBuilder()
      //         .setIdempotencyKey(idempotencyKey)
      //         .build()); // Uncomment to run with real Stripe key

      System.out.println("Idempotency key generated: " + idempotencyKey);
      System.out.println("Charge creation simulated using this key.");
      // System.out.println("Charge ID: " + charge.getId());

    } catch (StripeException e) {
      System.err.println("Stripe error: " + e.getMessage());
    }
  }
}

Streamlining Webhook Handling

Async Processing Architecture

Handling Duplicate Webhooks

import java.util.HashSet;
import java.util.Set;

public class WebhookProcessor {
  private static Set<String> processedEventIds = new HashSet<>();

  public static void handleWebhookEvent(String eventId, String payload) {
    if (processedEventIds.contains(eventId)) {
      System.out.println("Duplicate event received, ID: " + eventId + ". Ignoring.");
      return; // Already processed, ignore
    }

    // Simulate pushing to a queue for async processing
    System.out.println("Received event " + eventId + ". Pushing to queue...");
    // messageQueue.send(payload); // Real implementation

    // Mark as processed *after* successfully sending to queue
    // (or after successful processing by worker)
    processedEventIds.add(eventId); 
    System.out.println("Event " + eventId + " marked for processing.");
  }

  public static void main(String[] args) {
    // Simulate receiving an event
    handleWebhookEvent("evt_123", "{...}");
    handleWebhookEvent("evt_456", "{...}");
    // Simulate a duplicate event
    handleWebhookEvent("evt_123", "{...}"); 
  }
}

Holistic Optimization

Optimizing Interactions Quiz

Recap: Scaling Stripe Interactions