Refunds

import { createClient } from "@easylabs/node";
// EasyApiError ships from @easylabs/common; @easylabs/node re-exports the
// *type* but not the runtime value, so `instanceof` needs the common import.
import { EasyApiError } from "@easylabs/common";
const easy = await createClient({ apiKey: process.env.EASY_API_KEY! });

type RefundReason = "customer_request" | "duplicate" | "fraud" | "shipping_delay" | "dispute_received";

export async function refundOrder(
  orderId: string,
  amountCents: number | "full",
  reason: RefundReason,
  approvedBy: string,
) {
  const { data: order } = await easy.getOrder(orderId);
  if (!order.transfer) throw new Error("Order has no captured transfer.");
  if (order.transfer.state !== "SUCCEEDED") {
    throw new Error(`Cannot refund transfer in state ${order.transfer.state}.`);
  }

  const refund_amount = amountCents === "full" ? order.transfer.amount : amountCents;

  try {
    const reversal = await easy.createRefund(order.transfer.id, {
      refund_amount,
      tags: {
        reason,
        approved_by: approvedBy,
        order_number: order.order_number,
      },
    });

    // Persist reversal.data.id against the order in your DB
    return reversal.data;
  } catch (err) {
    if (err instanceof EasyApiError && err.status === 422) {
      // Probably trying to refund more than was captured
      throw new Error(`Refund rejected: ${err.message}`);
    }
    throw err;
  }
}

import { EasyWebhooks } from "@easylabs/node";

export async function handleWebhook(rawBody: string, sigHeader: string) {
  const event = EasyWebhooks.constructEvent(
    rawBody,
    sigHeader,
    process.env.EASY_WEBHOOK_SECRET!,
  );

  if (event.type === "dispute.created") {
    const dispute = event.data as { id: string; amount: number; transfer?: { id: string } };
    if (dispute.amount < 1000 && dispute.transfer) {
      // Cheaper to refund than to fight
      await easy.createRefund(dispute.transfer.id, {
        refund_amount: dispute.amount,
        tags: { reason: "dispute_received", dispute_id: dispute.id },
      });
      await easy.acceptDispute(dispute.id);
    }
  }
}

const reversal = await refundOrder(orderId, "full", "customer_request", "agent_42");
console.log({
  ledger_entry: "refund",
  amount_cents: reversal.amount,
  parent_transfer: reversal.parent_transfer,
  reversal_id: reversal.id,
  state: reversal.state,
});