Upgrade to React 19 and Next 15

apps/web/app/[domain]/page.tsx

@@ -6,12 +6,14 @@ export const revalidate = 0;
 export async function generateMetadata({
   params,
 }: {
-  params: { domain: string };
+  params: Promise<{ domain: string }>;
 }) {
-  const title = `${params.domain.toUpperCase()} - A ${
+  const { domain } = await params;
+
+  const title = `${domain.toUpperCase()} - A ${
     process.env.NEXT_PUBLIC_APP_NAME
   } Custom Domain`;
-  const description = `${params.domain.toUpperCase()} is a custom domain on ${
+  const description = `${domain.toUpperCase()} is a custom domain on ${
     process.env.NEXT_PUBLIC_APP_NAME
   } - an open-source link management tool for modern marketing teams to create, share, and track short links.`;
 

apps/web/app/[domain]/stats/[key]/page.tsx

@@ -7,13 +7,15 @@ export const runtime = "edge";
 export default async function OldStatsPage({
   params,
 }: {
-  params: { domain: string; key: string };
+  params: Promise<{ domain: string; key: string }>;
 }) {
+  const { domain, key } = await params;
+
   const link = await prismaEdge.link.findUnique({
     where: {
       domain_key: {
-        domain: params.domain,
-        key: params.key,
+        domain,
+        key,
       },
     },
     select: {

apps/web/app/api/cron/email/new-sale-created.ts

@@ -0,0 +1,81 @@
+import { limiter } from "@/lib/cron/limiter";
+import { prisma } from "@/lib/prisma";
+import z from "@/lib/zod";
+import { sendEmail } from "emails";
+import NewSaleCreated from "emails/new-sale-created";
+
+const schema = z.object({
+  saleId: z.string(),
+});
+
+// Notify the partner about the new sale came via their referral link
+export const newSaleCreated = async (payload: any) => {
+  const { saleId } = schema.parse(payload);
+
+  const { program, partner, ...sale } = await prisma.sale.findUniqueOrThrow({
+    where: {
+      id: saleId,
+    },
+    select: {
+      amount: true,
+      earnings: true,
+      program: {
+        select: {
+          id: true,
+          name: true,
+          logo: true,
+        },
+      },
+      partner: {
+        select: {
+          id: true,
+          programs: {
+            select: {
+              link: {
+                select: {
+                  shortLink: true,
+                },
+              },
+            },
+          },
+        },
+      },
+    },
+  });
+
+  const referralLink = partner.programs[0].link?.shortLink!;
+
+  const partnerUsers = await prisma.partnerUser.findMany({
+    where: {
+      partnerId: partner.id,
+    },
+    include: {
+      user: {
+        select: {
+          email: true,
+        },
+      },
+    },
+  });
+
+  return await Promise.all(
+    partnerUsers.map(({ user }) =>
+      limiter.schedule(() =>
+        sendEmail({
+          subject: "You just made a sale via Dub Partners!",
+          from: "Dub Partners <[email protected]>",
+          email: user.email!,
+          react: NewSaleCreated({
+            email: user.email!,
+            program,
+            partner: {
+              id: partner.id,
+              referralLink,
+            },
+            sale,
+          }),
+        }),
+      ),
+    ),
+  );
+};

apps/web/app/api/cron/email/route.ts

@@ -0,0 +1,38 @@
+import { handleAndReturnErrorResponse } from "@/lib/api/errors";
+import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
+import z from "@/lib/zod";
+import { log } from "@dub/utils";
+import { NextResponse } from "next/server";
+import { newSaleCreated } from "./new-sale-created";
+
+const schema = z.object({
+  event: z.string(),
+  payload: z.record(z.any()),
+});
+
+export async function POST(req: Request) {
+  try {
+    const body = await req.json();
+
+    await verifyQstashSignature(req, body);
+
+    const { event, payload } = schema.parse(body);
+
+    switch (event) {
+      case "new-sale-created":
+        await newSaleCreated(payload);
+        break;
+    }
+
+    return NextResponse.json({
+      response: "success",
+    });
+  } catch (error) {
+    await log({
+      message: `Error transferring domain: ${error.message}`,
+      type: "cron",
+    });
+
+    return handleAndReturnErrorResponse(error);
+  }
+}

apps/web/app/api/scim/v2.0/[...directory]/route.ts

@@ -9,10 +9,7 @@ import type {
 import { getSearchParams } from "@dub/utils";
 import { NextResponse } from "next/server";
 
-const handler = async (
-  req: Request,
-  { params }: { params: Record<string, string> },
-) => {
+const handler = async (req: Request, { params }) => {
   const authHeader = req.headers.get("Authorization");
   const apiSecret = authHeader ? authHeader.split(" ")[1] : null;
 

apps/web/app/api/stripe/connect/webhook/checkout-session-completed.ts

@@ -1,4 +1,3 @@
-import { notifyPartnerSale } from "@/lib/api/partners/notify-partner-sale";
 import { createSaleData } from "@/lib/api/sales/sale";
 import { prisma } from "@/lib/prisma";
 import { getLeadEvent, recordSale } from "@/lib/tinybird";
@@ -8,6 +7,7 @@ import { transformSaleEventData } from "@/lib/webhook/transform";
 import { nanoid } from "@dub/utils";
 import { Customer } from "@prisma/client";
 import { waitUntil } from "@vercel/functions";
+import { queueEmail } from "emails/publish-qstash";
 import type Stripe from "stripe";
 
 // Handle event "checkout.session.completed"
@@ -162,15 +162,10 @@ export async function checkoutSessionCompleted(event: Stripe.Event) {
     });
 
     waitUntil(
-      notifyPartnerSale({
-        partner: {
-          id: partner.id,
-          referralLink: link.shortLink,
-        },
-        program,
-        sale: {
-          amount: saleRecord.amount,
-          earnings: saleRecord.earnings,
+      queueEmail({
+        event: "new-sale-created",
+        payload: {
+          saleId: saleRecord.id,
         },
       }),
     );

apps/web/app/api/stripe/connect/webhook/invoice-paid.ts

@@ -1,4 +1,3 @@
-import { notifyPartnerSale } from "@/lib/api/partners/notify-partner-sale";
 import { createSaleData } from "@/lib/api/sales/sale";
 import { prisma } from "@/lib/prisma";
 import { getLeadEvent, recordSale } from "@/lib/tinybird";
@@ -7,6 +6,7 @@ import { sendWorkspaceWebhook } from "@/lib/webhook/publish";
 import { transformSaleEventData } from "@/lib/webhook/transform";
 import { nanoid } from "@dub/utils";
 import { waitUntil } from "@vercel/functions";
+import { queueEmail } from "emails/publish-qstash";
 import type Stripe from "stripe";
 
 // Handle event "invoice.paid"
@@ -144,15 +144,10 @@ export async function invoicePaid(event: Stripe.Event) {
     });
 
     waitUntil(
-      notifyPartnerSale({
-        partner: {
-          id: partner.id,
-          referralLink: link.shortLink,
-        },
-        program,
-        sale: {
-          amount: saleRecord.amount,
-          earnings: saleRecord.earnings,
+      queueEmail({
+        event: "new-sale-created",
+        payload: {
+          saleId: saleRecord.id,
         },
       }),
     );

apps/web/app/api/track/sale/route.ts

@@ -1,5 +1,4 @@
 import { DubApiError } from "@/lib/api/errors";
-import { notifyPartnerSale } from "@/lib/api/partners/notify-partner-sale";
 import { createSaleData } from "@/lib/api/sales/sale";
 import { parseRequestBody } from "@/lib/api/utils";
 import { withWorkspaceEdge } from "@/lib/auth/workspace-edge";
@@ -14,6 +13,7 @@ import {
 } from "@/lib/zod/schemas/sales";
 import { nanoid } from "@dub/utils";
 import { waitUntil } from "@vercel/functions";
+import { queueEmail } from "emails/publish-qstash";
 import { NextResponse } from "next/server";
 
 export const runtime = "edge";
@@ -154,15 +154,11 @@ export const POST = withWorkspaceEdge(
             prismaEdge.sale.create({
               data: saleRecord,
             }),
-            notifyPartnerSale({
-              partner: {
-                id: partner.id,
-                referralLink: link.shortLink,
-              },
-              program,
-              sale: {
-                amount: saleRecord.amount,
-                earnings: saleRecord.earnings,
+
+            queueEmail({
+              event: "new-sale-created",
+              payload: {
+                saleId: saleRecord.id,
               },
             }),
           ]);

apps/web/app/app.dub.co/(auth)/auth/reset-password/[token]/page.tsx

@@ -5,13 +5,13 @@ import { InputPassword } from "@dub/ui";
 
 export const runtime = "nodejs";
 
-interface Props {
-  params: {
-    token: string;
-  };
-}
+export default async function ResetPasswordPage({
+  params,
+}: {
+  params: Promise<{ token: string }>;
+}) {
+  const { token } = await params;
 
-export default async function ResetPasswordPage({ params: { token } }: Props) {
   const validToken = await isValidToken(token);
 
   if (!validToken) {

apps/web/app/app.dub.co/(auth)/invites/[code]/page.tsx

@@ -5,17 +5,17 @@ import { LoadingSpinner } from "@dub/ui";
 import { LinkBroken, Users6 } from "@dub/ui/src/icons";
 import { APP_NAME } from "@dub/utils";
 import { redirect } from "next/navigation";
-import { Suspense } from "react";
+import { Suspense, use } from "react";
 
 export const runtime = "nodejs";
 
-export default function InitesPage({
+export default function InvitesPage({
   params,
 }: {
-  params: {
-    code: string;
-  };
+  params: Promise<{ code: string }>;
 }) {
+  const { code } = use(params);
+
   return (
     <div className="flex flex-col items-center justify-center gap-6 text-center">
       <Suspense
@@ -27,7 +27,7 @@ export default function InitesPage({
           />
         }
       >
-        <VerifyInvite code={params.code} />
+        <VerifyInvite code={code} />
       </Suspense>
     </div>
   );

apps/web/app/app.dub.co/(auth)/oauth/authorize/page.tsx

@@ -23,16 +23,17 @@ export const metadata = constructMetadata({
 export default async function Authorize({
   searchParams,
 }: {
-  searchParams?: z.infer<typeof authorizeRequestSchema>;
+  searchParams?: Promise<z.infer<typeof authorizeRequestSchema>>;
 }) {
   const session = await getSession();
 
   if (!session) {
     redirect("/login");
   }
 
-  const { error, integration, requestParams } =
-    await vaidateAuthorizeRequest(searchParams);
+  const { error, integration, requestParams } = await vaidateAuthorizeRequest(
+    await searchParams,
+  );
 
   if (error || !integration) {
     return (

apps/web/app/app.dub.co/(dashboard)/[slug]/programs/[programId]/partners/invites/page.tsx

@@ -1,13 +1,16 @@
 import { PageContent } from "@/ui/layout/page-content";
 import { MaxWidthWrapper } from "@dub/ui";
+import { use } from "react";
 import { InvitePartnerButton } from "../invite-partner-button";
 import { ProgramPartnersInvitesPageClient } from "./page-client";
 
 export default function ProgramPartners({
-  params: { slug, programId },
+  params,
 }: {
-  params: { slug: string; programId: string };
+  params: Promise<{ slug: string; programId: string }>;
 }) {
+  const { slug, programId } = use(params);
+
   return (
     <PageContent
       title="Invited partners"

apps/web/app/app.dub.co/(dashboard)/[slug]/programs/[programId]/payouts/use-payout-filters.tsx

@@ -154,7 +154,8 @@ function usePartnerFilterOptions(search: string) {
           (p) => p.id === searchParamsObj.partnerId,
         ))
       ? null
-      : ([
+      : // @ts-ignore
+        ([
           ...(partners ?? []),
           // Add selected partner to list if not already in partners
           ...(selectedPartners

apps/web/app/app.dub.co/(dashboard)/[slug]/programs/[programId]/sales/sale-table.tsx

@@ -148,6 +148,7 @@ const SaleTableBusinessInner = memo(
           minSize: 43,
           size: 43,
           maxSize: 43,
+          // @ts-ignore
           cell: ({ row }) => <SaleRowMenu row={row} />,
         },
       ],