Rate Limits

import Commune from 'commune-ai';

const client = new Commune({ apiKey: process.env.COMMUNE_API_KEY });

async function sendWithBackoff(payload: Parameters<typeof client.messages.send>[0]) {
  const maxAttempts = 5;

  for (let attempt = 1; attempt <= maxAttempts; attempt++) {
    try {
      return await client.messages.send(payload);
    } catch (err: any) {
      if (err.error !== 'rate_limit_exceeded' || attempt === maxAttempts) {
        throw err;
      }

      // Honor the Retry-After value from the API
      const waitMs = (err.retryAfter ?? 60) * 1000;
      console.warn(`Rate limited. Waiting ${waitMs / 1000}s before retry ${attempt + 1}/${maxAttempts}`);
      await new Promise((resolve) => setTimeout(resolve, waitMs));
    }
  }
}