Rate Limits

class RateLimitedClient {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.remaining = Infinity;
    this.resetTime = 0;
  }
 
  async request(endpoint, options = {}) {
    // Check if we're approaching the limit
    if (this.remaining < 10) {
      const waitTime = Math.max(0, this.resetTime - Date.now());
      if (waitTime > 0) {
        console.log(`Rate limit low, waiting ${waitTime}ms`);
        await this.sleep(waitTime);
      }
    }
 
    const response = await fetch(`https://dev.nutalk.ai/v1${endpoint}`, {
      ...options,
      headers: {
        'Authorization': `Bearer ${this.apiKey}`,
        'Content-Type': 'application/json',
        ...options.headers,
      },
    });
 
    // Update rate limit info from headers
    this.remaining = parseInt(
      response.headers.get('X-RateLimit-Remaining') || '1000'
    );
    this.resetTime = parseInt(
      response.headers.get('X-RateLimit-Reset') || '0'
    ) * 1000;
 
    // Handle rate limit error
    if (response.status === 429) {
      const retryAfter = this.resetTime - Date.now() + 1000;
      console.log(`Rate limited. Retrying in ${retryAfter}ms`);
      await this.sleep(retryAfter);
      return this.request(endpoint, options);
    }
 
    return response.json();
  }
 
  sleep(ms) {
    return new Promise(resolve => setTimeout(resolve, ms));
  }
}
 
// Usage
const client = new RateLimitedClient(process.env.NUTALK_API_KEY);
 
const agents = await client.request('/agents');
console.log(agents);

{
  "success": false,
  "error": {
    "code": "RATE_LIMITED",
    "message": "Too many requests. Please slow down."
  }
}