Support multiple links per partner

apps/web/app/api/embed/analytics/route.ts

@@ -3,13 +3,15 @@ import { withEmbedToken } from "@/lib/embed/auth";
 import { NextResponse } from "next/server";
 
 // GET /api/embed/analytics – get timeseries analytics for a link from an embed token
-export const GET = withEmbedToken(async ({ link }) => {
+export const GET = withEmbedToken(async ({ programId, partnerId }) => {
   const analytics = await getAnalytics({
     event: "composite",
     groupBy: "timeseries",
-    linkId: link.id,
     interval: "1y",
+    programId,
+    partnerId,
   });
+  console.log("analytics", analytics);
 
   return NextResponse.json(analytics);
 });

apps/web/app/api/embed/leaderboard/route.ts

@@ -5,39 +5,44 @@ import { NextResponse } from "next/server";
 import z from "node_modules/zod/lib";
 
 // GET /api/embed/sales – get sales for a link from an embed token
-export const GET = withEmbedToken(async ({ program, searchParams }) => {
-  const programEnrollments = await prisma.programEnrollment.findMany({
-    where: {
-      programId: program.id,
-      partner: {
-        showOnLeaderboard: true,
-      },
-    },
-    orderBy: [
-      {
-        link: {
-          saleAmount: "desc",
-        },
-      },
-      {
-        link: {
-          leads: "desc",
-        },
-      },
-      {
-        link: {
-          clicks: "desc",
-        },
-      },
-    ],
-    select: {
-      partner: true,
-      link: true,
-    },
-    take: 20,
-  });
+export const GET = withEmbedToken(async ({ program }) => {
+  const partners = await prisma.$queryRaw`
+    SELECT 
+      p.id,
+      p.name,
+      pe.status, 
+      pe.programId, 
+      pe.partnerId, 
+      pe.createdAt as enrollmentCreatedAt,
+      COALESCE(SUM(l.clicks), 0) as totalClicks,
+      COALESCE(SUM(l.leads), 0) as totalLeads,
+      COALESCE(SUM(l.sales), 0) as totalSales,
+      COALESCE(SUM(l.saleAmount), 0) as totalSaleAmount
+    FROM 
+      ProgramEnrollment pe 
+    INNER JOIN 
+      Partner p ON p.id = pe.partnerId  AND p.showOnLeaderboard = true
+    LEFT JOIN 
+      Link l ON l.partnerId = pe.partnerId 
+    WHERE 
+      pe.programId = ${program.id}
+    GROUP BY 
+      p.id, pe.id
+    ORDER BY 
+      totalSaleAmount DESC,
+      totalLeads DESC,
+      totalClicks DESC
+    LIMIT 20`;
 
-  return NextResponse.json(
-    z.array(LeaderboardPartnerSchema).parse(programEnrollments),
-  );
+  // @ts-ignore
+  const response = partners.map((partner) => ({
+    id: partner.id,
+    name: partner.name,
+    clicks: Number(partner.totalClicks),
+    leads: Number(partner.totalLeads),
+    sales: Number(partner.totalSales),
+    saleAmount: Number(partner.totalSaleAmount),
+  }));
+
+  return NextResponse.json(z.array(LeaderboardPartnerSchema).parse(response));
 });

apps/web/app/api/embed/sales/route.ts

@@ -6,36 +6,39 @@ import { prisma } from "@dub/prisma";
 import { NextResponse } from "next/server";
 
 // GET /api/embed/sales – get sales for a link from an embed token
-export const GET = withEmbedToken(async ({ link, searchParams }) => {
-  const { page } = z
-    .object({ page: z.coerce.number().optional().default(1) })
-    .parse(searchParams);
+export const GET = withEmbedToken(
+  async ({ programId, partnerId, searchParams }) => {
+    const { page } = z
+      .object({ page: z.coerce.number().optional().default(1) })
+      .parse(searchParams);
 
-  const sales = await prisma.sale.findMany({
-    where: {
-      linkId: link.id,
-    },
-    select: {
-      id: true,
-      amount: true,
-      earnings: true,
-      currency: true,
-      status: true,
-      createdAt: true,
-      updatedAt: true,
-      customer: {
-        select: {
-          email: true,
-          avatar: true,
+    const sales = await prisma.sale.findMany({
+      where: {
+        programId,
+        partnerId,
+      },
+      select: {
+        id: true,
+        amount: true,
+        earnings: true,
+        currency: true,
+        status: true,
+        createdAt: true,
+        updatedAt: true,
+        customer: {
+          select: {
+            email: true,
+            avatar: true,
+          },
         },
       },
-    },
-    take: SALES_PAGE_SIZE,
-    skip: (page - 1) * SALES_PAGE_SIZE,
-    orderBy: {
-      createdAt: "desc",
-    },
-  });
+      take: SALES_PAGE_SIZE,
+      skip: (page - 1) * SALES_PAGE_SIZE,
+      orderBy: {
+        createdAt: "desc",
+      },
+    });
 
-  return NextResponse.json(z.array(PartnerSaleResponseSchema).parse(sales));
-});
+    return NextResponse.json(z.array(PartnerSaleResponseSchema).parse(sales));
+  },
+);

apps/web/app/api/embed/token/route.ts

@@ -2,6 +2,6 @@ import { withEmbedToken } from "@/lib/embed/auth";
 import { NextResponse } from "next/server";
 
 // GET /api/embed/token - get the embed token for the given link
-export const GET = withEmbedToken(async ({ linkToken }) => {
-  return NextResponse.json(linkToken);
+export const GET = withEmbedToken(async ({ embedToken }) => {
+  return NextResponse.json(embedToken);
 });

apps/web/app/api/partner-profile/programs/[programId]/analytics/route.ts

@@ -8,7 +8,7 @@ import { NextResponse } from "next/server";
 // GET /api/partner-profile/programs/[programId]/analytics – get analytics for a program enrollment link
 export const GET = withPartnerProfile(
   async ({ partner, params, searchParams }) => {
-    const { link, program } = await getProgramEnrollmentOrThrow({
+    const { program } = await getProgramEnrollmentOrThrow({
       partnerId: partner.id,
       programId: params.programId,
     });
@@ -24,7 +24,7 @@ export const GET = withPartnerProfile(
 
     const response = await getAnalytics({
       ...parsedParams,
-      linkId: link.id,
+      partnerId: partner.id,
     });
 
     let data;

apps/web/app/api/partner-profile/programs/route.ts

@@ -19,7 +19,7 @@ export const GET = withPartnerProfile(async ({ partner }) => {
     z.array(ProgramEnrollmentSchema).parse(
       programEnrollments.map((enrollment) => ({
         ...enrollment,
-        link: null, // hacky way of not having to fetch link
+        links: null, // hacky way of not having to fetch link
       })),
     ),
   );

apps/web/app/api/partners/[partnerId]/route.ts

@@ -33,22 +33,28 @@ export const GET = withWorkspace(
       },
       include: {
         partner: true,
-        link: true,
         program: true,
+        links: true,
       },
     });
 
-    const { program, link } = programEnrollment;
+    const { program, links } = programEnrollment;
+
+    const earnings = links?.reduce((acc, link) => {
+      return (
+        acc +
+        ((program.commissionType === "percentage"
+          ? link?.saleAmount
+          : link?.sales) ?? 0) *
+          (program.commissionAmount / 100)
+      );
+    }, 0);
 
     const partner = {
       ...programEnrollment.partner,
       ...programEnrollment,
       id: programEnrollment.partnerId,
-      earnings:
-        ((program.commissionType === "percentage"
-          ? link?.saleAmount
-          : link?.sales) ?? 0) *
-        (program.commissionAmount / 100),
+      earnings,
     };
 
     return NextResponse.json(EnrolledPartnerSchema.parse(partner));