From Automation Log to Report of Use: An End-to-End Enrichment Pipeline

// A play log has one row per spin. Resolve each DISTINCT track once —
// a track aired 40 times should cost one lookup, not forty.

type Row = { artist: string; title: string; album?: string; playedAt: string };

const keyOf = (r: Row) => (r.artist + " | " + r.title).toLowerCase().trim();

const rows: Row[] = parseExport(raw);            // your CSV / log parser
const unique = new Map<string, Row>();
for (const r of rows) unique.set(keyOf(r), r);

console.log(unique.size + " distinct tracks from " + rows.length + " spins");

// Resolve one distinct track to the two fields the log is missing.
// Both artist AND title are required — there is no free-text query.

type Enriched = { isrc: string | null; album: string | null; label: string | null };

const cache = new Map<string, Enriched>();

async function resolve(r: Row): Promise<Enriched> {
  const u = new URL(BASE + "/v1/tracks/search");
  u.searchParams.set("artist", r.artist);
  u.searchParams.set("title", r.title);
  u.searchParams.set("limit", "1");

  const res = await fetch(u, { headers: { "x-api-key": API_KEY } });
  if (res.status === 429) {                         // rate limited — respect Retry-After
    const wait = Number(res.headers.get("retry-after") || 2);
    await sleep(wait * 1000);
    return resolve(r);                              // retry after backoff
  }

  const { results } = await res.json();
  const top = results[0];
  if (!top) return { isrc: null, album: null, label: null };

  const rel = top.releases[0];                       // representative release
  return {
    isrc:  top.isrc,                                // may be null
    album: rel ? rel.title : null,
    label: rel && rel.label ? rel.label.name : null,
  };
}

// Sum spins per distinct track, then join on the enriched identifiers.
// Census reporting = actual total performances over the period.

const counts = new Map<string, number>();
for (const r of rows) {
  const k = keyOf(r);
  counts.set(k, (counts.get(k) || 0) + 1);
}

const reportRows = [...unique].map(([k, row]) => {
  const e = cache.get(k)!;                          // resolved earlier
  return {
    title:        row.title,
    artist:       row.artist,
    isrc:         e.isrc,                            // ISRC path…
    album:        e.album,                           // …or album + label
    label:        e.label,                           // as the fallback
    performances: counts.get(k) || 0,
  };
});