Export conversations and recordings

import { writeFile } from 'node:fs/promises';

const BASE = 'https://answeringagent.com/api/v1';

async function api(path) {
  const res = await fetch(`${BASE}${path}`, {
    headers: { 'X-API-KEY': process.env.ANSWERING_AGENT_API_KEY },
  });
  if (res.status === 429) {
    await new Promise((r) => setTimeout(r, Number(res.headers.get('Retry-After') ?? 60) * 1000));
    return api(path);
  }
  return res;
}

async function archive(range) {
  const saved = new Set();
  for (let page = 1; page; ) {
    const body = await (await api(`/conversations?range=${range}&limit=50&page=${page}`)).json();
    for (const { id, has_recording } of body.conversations) {
      if (saved.has(id)) continue;
      saved.add(id);

      const conversation = await (await api(`/conversations/${id}`)).json();
      await writeFile(`conversation-${id}.json`, JSON.stringify(conversation, null, 2));

      if (has_recording) {
        const audio = await api(`/conversations/${id}/recording`);
        if (audio.ok) await writeFile(`conversation-${id}-recording`, Buffer.from(await audio.arrayBuffer()));
      }
    }
    page = body.next_page;
  }
  return saved.size;
}

await archive('yesterday');