import PQueue from 'p-queue';

const hexQueue = new PQueue({
  concurrency: 1,
  interval: 60000,   // Per minute
  intervalCap: 15,   // Leave buffer (limit is 20)
});

let hourlyCount = 0;
setInterval(() => { hourlyCount = 0; }, 3600000);

async function queuedRun(client: HexClient, projectId: string, params: any) {
  if (hourlyCount >= 55) throw new Error('Approaching hourly limit');
  return hexQueue.add(async () => {
    hourlyCount++;
    return client.runProject(projectId, params);
  });
}

async function runWithBackoff(client: HexClient, projectId: string, params: any) {
  for (let i = 0; i < 3; i++) {
    try { return await client.runProject(projectId, params); }
    catch (err: any) {
      if (!err.message.includes('429')) throw err;
      const delay = 30000 * Math.pow(2, i);
      console.log(`Rate limited, waiting ${delay / 1000}s`);
      await new Promise(r => setTimeout(r, delay));
    }
  }
}