Build a Production Search Client

const baseUrl = "https://api.orbitsearch.com";
const apiKey = process.env.ORBIT_API_KEY;

async function orbit(path, init = {}) {
  const response = await fetch(`${baseUrl}${path}`, {
    ...init,
    headers: {
      Authorization: `Bearer ${apiKey}`,
      "Content-Type": "application/json",
      ...init.headers,
    },
  });

  const body = await response.json();
  if (!response.ok) {
    const error = new Error(body.error?.message ?? `Orbit returned ${response.status}`);
    error.status = response.status;
    error.code = body.error?.code;
    error.retryAfterMs = Number(response.headers.get("retry-after") ?? 0) * 1000;
    throw error;
  }
  return body;
}

const initial = await orbit("/v3/search", {
  method: "POST",
  body: JSON.stringify({
    query: "Machine learning engineers in the San Francisco Bay Area who built production recommendation systems",
    candidate_discovery: true,
    profile_depth: "partial",
    include_profile: true,
    limit: 10,
  }),
});

const terminal = new Set(["completed", "completed_with_errors", "failed"]);
let search = initial;
let attempt = 0;

while (!terminal.has(search.status)) {
  const delay = Math.min(10_000, 500 * 2 ** attempt);
  const jitter = Math.round(delay * (0.8 + Math.random() * 0.4));
  await new Promise((resolve) => setTimeout(resolve, jitter));

  try {
    search = await orbit(search.links.status);
    attempt += 1;
  } catch (error) {
    if (error.status !== 429 && error.status < 500) throw error;
    await new Promise((resolve) =>
      setTimeout(resolve, error.retryAfterMs || jitter)
    );
    attempt += 1;
  }
}

const readyProfiles = search.results
  .filter((result) => result.status === "ready")
  .map((result) => result.profile);

const failures = search.results.filter((result) => result.status === "failed");

if (search.status === "failed") {
  throw new Error("Search completed without a ready profile");
}