Rendre vos intégrations robustes

import { randomUUID } from "node:crypto";
import { call } from "./retriever.mjs";

job.idempotencyKey ??= randomUUID();
await db.jobs.save(job); // persister AVANT l'appel
const run = await call("/v1/runs", { method: "POST", headers: { "Idempotency-Key": job.idempotencyKey }, body: job.payload });
job.runId = run.id;
await db.jobs.save(job);

import { API, KEY, sleep } from "./retriever.mjs";

async function pollWithEtag(id) {
  let etag;
  let run;
  for (;;) {
    const res = await fetch(`${API}/v1/runs/${id}`, {
      headers: { Authorization: `Bearer ${KEY}`, ...(etag ? { "If-None-Match": etag } : {}) },
    });
    if (res.status === 200) {
      etag = res.headers.get("etag");
      run = await res.json();
      if (!["queued", "running", "recovering"].includes(run.status)) return run;
    } else if (res.status !== 304 && res.status !== 429 && res.status < 500) {
      throw new Error(`poll ${id}: HTTP ${res.status}`);
    }
    await sleep(Number(res.headers.get("retry-after") || 15) * 1000);
  }
}