Function chargeInvoice

app/src/server/tasks/chargeInvoices.task.ts:36–116

(invoiceId: string)

});

export async function chargeInvoice(invoiceId: string) {
  const invoice = await prisma.invoice.findUnique({
    where: {
      id: invoiceId,
    },
  });

  if (invoice?.status !== "UNPAID" || Number(invoice.amount) < 1) {
    return error("The invoice has already been paid.");
  }

  const project = await prisma.project.findUnique({
    where: {
      id: invoice.projectId,
    },
  });

  if (!project || !project.stripeCustomerId) {
    return error("Add a default payment method.");
  }

  let paymentMethodToUse = await getDefaultPaymentMethodId(project.stripeCustomerId);

  if (!paymentMethodToUse) {
    // Search for available payment methods and use the first one
    const paymentMethods = await getPaymentMethods(project.stripeCustomerId);

    if (paymentMethods && paymentMethods.data[0]?.id) {
      paymentMethodToUse = paymentMethods.data[0]?.id;
    } else {
      // TODO: Replace it with a "Payment Failed" notification once we require a card to be added.
      await sendToOwner(invoice.projectId, (email: string) =>
        sendInvoiceNotification(
          invoice.id,
          Number(invoice.amount),
          invoice.description,
          invoice.billingPeriod || "",
          project.name,
          project.slug,
          email,
        ),
      );
      return error("Add a payment method.");
    }
  }

  try {
    const paymentIntent = await createStripePaymentIntent({
      amount: usdToCents(invoice.amount),
      invoiceId: invoiceId,
      stripeCustomerId: project.stripeCustomerId,
      paymentMethodId: paymentMethodToUse,
      returnUrl: `${env.NEXT_PUBLIC_HOST}/p/${project?.slug}/billing/invoices`,
    });

    // Sometimes it will not work because processing may take some time.
    // In this case we will handle it using webhooks (see app/src/pages/api/stripe/webhook.ts)
    if (paymentIntent.status === "succeeded") {