const response = await client.creators.search({
  query: 'tech reviewers',
  limit: 10
});

// Access rate limit info from response metadata
console.log('Credits remaining:', response.rateLimit.remaining);
console.log('Credits charged:', response.credits.charged);
console.log('Resets at:', new Date(response.rateLimit.reset * 1000));
console.log('Current tier:', response.billing.plan);

response = requests.post(
    'https://api.influship.com/v1/search',
    headers={'X-API-Key': API_KEY},
    json={'query': 'tech reviewers', 'limit': 10}
)

# Read headers
remaining = int(response.headers['RateLimit-Remaining'])
charged = float(response.headers['X-Credits-Charged'])
reset_time = int(response.headers['RateLimit-Reset'])
tier = response.headers['X-Billing-Plan']

print(f'Credits remaining: {remaining}')
print(f'Credits charged: {charged}')
print(f'Current tier: {tier}')
print(f'Resets at: {datetime.fromtimestamp(reset_time)}')

import time
from requests.exceptions import HTTPError

def search_with_retry(query: str, max_retries: int = 3):
    for attempt in range(max_retries):
        try:
            response = requests.post(
                'https://api.influship.com/v1/search',
                headers={'X-API-Key': API_KEY},
                json={'query': query}
            )
            response.raise_for_status()
            return response.json()
        except HTTPError as e:
            if e.response.status_code == 429:
                # Use Retry-After header if available
                retry_after = int(e.response.headers.get('Retry-After', 2 ** attempt))
                print(f'Rate limited, retrying in {retry_after}s...')
                time.sleep(retry_after)
            else:
                raise  # Don't retry other errors
    raise Exception('Max retries exceeded')

# Simple retry with exponential backoff in shell
for i in 1 2 4 8; do
  response=$(curl -s -w "%{http_code}" -X POST \
    https://api.influship.com/v1/search \
    -H 'X-API-Key: YOUR_API_KEY' \
    -d '{"query": "tech creators"}')

  if [ "$response" != "429" ]; then
    echo "Success!"
    break
  fi

  echo "Rate limited, waiting ${i}s..."
  sleep $i
done

class RateLimitMonitor:
    def __init__(self, warning_threshold=0.2):
        self.warning_threshold = warning_threshold

    def make_request(self, request_fn):
        response = request_fn()

        remaining = int(response.headers['RateLimit-Remaining'])
        limit = int(response.headers['RateLimit-Limit'])
        percentage = remaining / limit

        if percentage < self.warning_threshold:
            print(
                f'⚠️ Rate limit low: {remaining}/{limit} credits '
                f'remaining ({percentage * 100:.1f}%)'
            )

            # Implement adaptive throttling
            self._throttle_if_needed(percentage)

        return response

    def _throttle_if_needed(self, percentage):
        if percentage < 0.1:
            # Below 10%: aggressive throttling
            time.sleep(2)
        elif percentage < 0.2:
            # Below 20%: moderate throttling
            time.sleep(1)

# Track credits per request
response = requests.post(
    'https://api.influship.com/v1/search',
    headers={'X-API-Key': API_KEY},
    json={'query': 'fitness'}
)

log_usage({
    'endpoint': 'search',
    'credits_charged': float(response.headers['X-Credits-Charged']),
    'features': response.headers['X-Credits-Features'],
    'tier': response.headers['X-Billing-Plan'],
    'timestamp': datetime.now()
})

# Calculate hourly burn rate
hourly_usage = get_hourly_usage()
plan_limit = get_plan_limit(response.headers['X-Billing-Plan'])

if hourly_usage > plan_limit * 0.9:
    print('⚠️ Approaching 90% of hourly rate limit')