پایش وضعیت پردازش اسناد

async function waitForIngestJob(assistantCode, jobId, { timeoutMs = 5 * 60_000 } = {}) {
  const start = Date.now();
  let delay = 1000;
 
  while (true) {
    const res = await fetch(
      `https://<host>/v1/assistants/${assistantCode}/documents/jobs/${jobId}`,
      { headers: { Authorization: `Bearer ${process.env.PLEXIT_API_KEY}` } },
    );
    const { data, response } = await res.json();
    if (!res.ok) throw new Error(`${response.status}: ${response.message}`);
 
    if (data.status === "ready") return data;
    if (data.status === "failed") {
      throw new Error(`Ingest job failed: ${data.errorMessage}`);
    }
 
    if (Date.now() - start > timeoutMs) {
      throw new Error(`Timed out waiting for ingest job ${jobId}`);
    }
 
    await new Promise((resolve) => setTimeout(resolve, delay));
    delay = Math.min(delay * 2, 15_000);
  }
}

import time
import requests
 
def wait_for_ingest_job(assistant_code, job_id, timeout_s=300):
    start = time.monotonic()
    delay = 1.0
    url = f"https://<host>/v1/assistants/{assistant_code}/documents/jobs/{job_id}"
    headers = {"Authorization": f"Bearer {PLEXIT_API_KEY}"}
 
    while True:
        res = requests.get(url, headers=headers)
        body = res.json()
        if not res.ok:
            raise RuntimeError(f"{body['response']['status']}: {body['response']['message']}")
 
        data = body["data"]
        if data["status"] == "ready":
            return data
        if data["status"] == "failed":
            raise RuntimeError(f"Ingest job failed: {data['errorMessage']}")
 
        if time.monotonic() - start > timeout_s:
            raise TimeoutError(f"Timed out waiting for ingest job {job_id}")
 
        time.sleep(delay)
        delay = min(delay * 2, 15)