async function flyApiWithRetry<T>(
  fn: () => Promise<Response>,
  maxRetries = 4
): Promise<T> {
  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    const res = await fn();
    if (res.ok) return res.json();

    if (res.status === 429) {
      const retryAfter = parseInt(res.headers.get('Retry-After') || '10');
      const delay = retryAfter * 1000 + Math.random() * 2000;
      console.log(`Rate limited. Retry in ${(delay / 1000).toFixed(0)}s`);
      await new Promise(r => setTimeout(r, delay));
      continue;
    }

    if (res.status >= 500 && attempt < maxRetries) {
      await new Promise(r => setTimeout(r, Math.pow(2, attempt) * 1000));
      continue;
    }

    throw new Error(`Fly API ${res.status}: ${await res.text()}`);
  }
  throw new Error('Max retries exceeded');
}

import PQueue from 'p-queue';

// Limit concurrent machine operations
const flyQueue = new PQueue({ concurrency: 3, interval: 10000, intervalCap: 10 });

async function batchCreateMachines(configs: Array<{ region: string; config: any }>) {
  return Promise.all(
    configs.map(c => flyQueue.add(() =>
      flyApiWithRetry(() => fetch(`${FLY_API}/v1/apps/${app}/machines`, {
        method: 'POST', headers,
        body: JSON.stringify(c),
      }))
    ))
  );
}