AhaSend Node.js SDK

await ahasend.messages.send(body, {
  idempotencyKey: `order-${orderId}`, // drive the key from your own identifier
  timeoutMs: 5_000, // override the per-attempt timeout
  retry: { maxRetries: 1 }, // restrict retries, or false to disable
  signal: AbortSignal.timeout(10_000), // cancel the request
  headers: { "x-trace-id": traceId },
});

import { AhaSendAPIError, AhaSendRateLimitError } from "@ahasend/sdk";

try {
  await ahasend.messages.send(body);
} catch (err) {
  if (err instanceof AhaSendRateLimitError) {
    console.warn(`Rate limited, retry after ${err.retryAfterSeconds}s`);
  } else if (err instanceof AhaSendAPIError) {
    console.error(`AhaSend error ${err.status} (request ${err.requestId})`);
  } else {
    throw err;
  }
}

for await (const message of ahasend.messages.iterate({ status: "Delivered" })) {
  // pages are fetched as needed
}

import {
  AhaSendWebhookVerificationError,
  WebhookVerifier,
  isKnownWebhookEvent,
  type AnyWebhookEvent,
  type WebhookHeadersInput,
} from "@ahasend/sdk/webhooks";

const verifier = new WebhookVerifier(process.env.AHASEND_WEBHOOK_SECRET!);

// `rawBody` is the bounded raw read your framework already performed.
export async function handleWebhook(
  headers: WebhookHeadersInput,
  rawBody: Uint8Array,
): Promise<number> {
  let event: AnyWebhookEvent;
  try {
    event = await verifier.parse(headers, rawBody);
  } catch (err) {
    if (!(err instanceof AhaSendWebhookVerificationError)) throw err;
    // Answer with an empty body: `err.reason` names the check that failed and
    // is yours to act on, not something to hand back to the sender.
    return err.reason === "body_too_large" ? 413 : 400;
  }

  if (isKnownWebhookEvent(event)) {
    switch (event.type) {
      case "message.delivered":
        break;
      case "message.bounced":
        break;
    }
  }

  return 202;
}