Migrating from v1

async function listAll<T>(path: string): Promise<T[]> {
  const items: T[] = [];
  let cursor: string | null = null;

  do {
    const url = new URL(`https://inboxapp.com/api/v2${path}`);
    if (cursor) url.searchParams.set("cursor", cursor);

    const response = await fetch(url, {
      headers: { Authorization: `Bearer ${process.env.INBOX_API_TOKEN}` },
    });

    if (!response.ok) {
      const error = await response.json();
      throw new Error(`${error.code}: ${error.message} (${error.requestId})`);
    }

    const page = await response.json();
    items.push(...page.data);
    cursor = page.nextCursor;
  } while (cursor);

  return items;
}

const tags = await listAll("/tags");

import { randomUUID } from "node:crypto";

async function send(threadId: string, content: string) {
  const key = randomUUID();

  for (let attempt = 0; attempt < 3; attempt++) {
    const response = await fetch("https://inboxapp.com/api/v2/messages", {
      method: "POST",
      headers: {
        Authorization: `Bearer ${process.env.INBOX_API_TOKEN}`,
        "Content-Type": "application/json",
        "Idempotency-Key": key,
      },
      body: JSON.stringify({ target: { type: "thread", threadId }, content }),
    });

    if (response.ok) return (await response.json()).message;

    const error = await response.json();

    if (error.code === "sendUnconfirmed") {
      // The platform may have delivered it. Don't retry with a new key.
      return { id: error.details.messageId, unconfirmed: true };
    }

    if (response.status < 500 && response.status !== 429) {
      throw new Error(`${error.code}: ${error.message} (${error.requestId})`);
    }

    await new Promise((resolve) => setTimeout(resolve, 1000 * 2 ** attempt));
  }

  throw new Error("Send failed after 3 attempts");
}