Function createInvoice

app/src/server/tasks/generateInvoices.task.ts:51–170

(projectId: string, startDate: Date, endDate: Date)

});

export async function createInvoice(projectId: string, startDate: Date, endDate: Date) {
  return await kysely.transaction().execute(async (tx) => {
    const existingInvoice = await tx
      .selectFrom("Invoice")
      .where("projectId", "=", projectId)
      .where("createdAt", ">=", toUTC(new Date()).startOf("month").toDate())
      .where("billingPeriod", "=", getPreviousMonthWithYearString())
      .executeTakeFirst();

    if (existingInvoice) return;
    // 1. Create empty invoice
    let invoice = await tx
      .insertInto("Invoice")
      .values({
        id: uuidv4(),
        projectId: projectId,
        amount: 0,
        slug: generateInvoiceSlug(),
        billingPeriod: getPreviousMonthWithYearString(),
      })
      .returning([
        "id",
        "createdAt",
        "slug",
        "amount",
        "billingPeriod",
        "status",
        "description",
        "projectId",
      ])
      .executeTakeFirst();

    if (!invoice) throw new Error("No data available for invoice generation");

    // 2. Associate stats with invoice
    await tx
      .updateTable("UsageLog")
      .set({
        invoiceId: invoice.id,
      })
      .where("projectId", "=", projectId)
      .where("createdAt", ">=", startDate)
      .where("createdAt", "<=", endDate)
      .where("invoiceId", "is", null)
      .execute();

    // 3. Calculate usage stats
    const stats = await getStats(
      tx.selectFrom("UsageLog as ul").where("ul.invoiceId", "=", invoice.id),
    );

    // 4. Calculate available credits
    const creditsAvailable = await tx
      .selectFrom("CreditAdjustment as ca")
      .where("ca.projectId", "=", projectId)
      .where("ca.createdAt", "<=", endDate)
      .select(({ fn }) => fn.sum(sql<number>`amount`).as("amount"))
      .executeTakeFirst();