Zillow data for CRM and lead enrichment

import { readFileSync, writeFileSync } from "node:fs";

const BASE = "https://api.propertiesapi.com/v1";
const leads = JSON.parse(readFileSync("leads.json", "utf8")); // [{ id, address }, ...]
const enriched = [], review = [];

for (let i = 0; i < leads.length; i += 50) {
  const chunk = leads.slice(i, i + 50);
  const res = await fetch(`${BASE}/zillow/batch`, {
    method: "POST",
    headers: { "x-api-key": process.env.PROPERTIESAPI_KEY, "content-type": "application/json" },
    body: JSON.stringify({ items: chunk.map((l) => ({ address: l.address })) }),
    signal: AbortSignal.timeout(320_000),
  });
  const body = await res.json();
  if (!res.ok) throw new Error(`${body.error.code}: ${body.error.message}`);

  for (const r of body.data) {
    const lead = chunk[r.index];
    if (r.ok) {
      const h = r.data;
      enriched.push({
        id: lead.id,
        zillow_url: h.detailUrl,
        listing_status: h.statusText ?? h.homeStatus,
        list_price: h.price,
        zestimate: h.zestimate,
        days_on_market: h.calculated.days_on_market,
        listing_agent: h.agentName,
        listing_broker: h.brokerName,
      });
    } else if (r.error.code === "address_ambiguous") {
      review.push({ id: lead.id, address: lead.address, closest_match: r.error.details?.candidate?.detailUrl ?? null });
    }
  }
}
writeFileSync("enriched.json", JSON.stringify(enriched, null, 2));
writeFileSync("review.json", JSON.stringify(review, null, 2));