Rate Limiting

async function fetchWithRetry(url, options, maxRetries = 3) {
  let lastError;

  for (let attempt = 0; attempt < maxRetries; attempt++) {
    try {
      const response = await fetch(url, {
        ...options,
        headers: {
          'X-API-Key': process.env.PORTALDATA_API_KEY,
          ...options.headers
        }
      });

      // Jika rate limited, tunggu dan retry
      if (response.status === 429) {
        const retryAfter = parseInt(response.headers.get('Retry-After') || '30');
        console.log(`Rate limited. Waiting ${retryAfter}s before retry...`);
        await new Promise(resolve => setTimeout(resolve, retryAfter * 1000));
        continue;
      }

      // Log rate limit info untuk monitoring
      const remaining = response.headers.get('X-RateLimit-Remaining');
      if (remaining && parseInt(remaining) < 10) {
        console.warn(`Low rate limit remaining: ${remaining}`);
      }

      return response;
    } catch (error) {
      lastError = error;
      // Exponential backoff untuk network errors
      const delay = Math.pow(2, attempt) * 1000;
      await new Promise(resolve => setTimeout(resolve, delay));
    }
  }

  throw lastError;
}

import time
import requests
from functools import wraps

class PortalDataClient:
    def __init__(self, api_key):
        self.api_key = api_key
        self.base_url = 'https://api.portaldata.id/api/v1'
        self.session = requests.Session()
        self.session.headers['X-API-Key'] = api_key

    def _request(self, method, endpoint, **kwargs):
        url = f'{self.base_url}{endpoint}'
        max_retries = 3

        for attempt in range(max_retries):
            response = self.session.request(method, url, **kwargs)

            # Track rate limit
            remaining = response.headers.get('X-RateLimit-Remaining')
            if remaining:
                print(f'Rate limit remaining: {remaining}')

            # Handle rate limit
            if response.status_code == 429:
                retry_after = int(response.headers.get('Retry-After', 30))
                print(f'Rate limited. Waiting {retry_after}s...')
                time.sleep(retry_after)
                continue

            return response

        raise Exception('Max retries exceeded')

    def get_regions(self, **params):
        return self._request('GET', '/regions', params=params).json()

    def get_kbli(self, code):
        return self._request('GET', f'/kbli/{code}').json()

# Penggunaan
client = PortalDataClient(api_key='pk_live_xxx')
regions = client.get_regions(level='province')