White labeled embed UI

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

@@ -0,0 +1,50 @@
+import { getAnalytics } from "@/lib/analytics/get-analytics";
+import { calculateEarnings } from "@/lib/api/sales/commission";
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { analyticsQuerySchema } from "@/lib/zod/schemas/analytics";
+import { NextResponse } from "next/server";
+
+// GET /api/analytics/client - get analytics for the current link
+export const GET = withEmbedToken(async ({ link, searchParams, program }) => {
+  const parsedParams = analyticsQuerySchema
+    .pick({
+      event: true,
+      start: true,
+      end: true,
+      interval: true,
+      groupBy: true,
+      timezone: true,
+    })
+    .parse(searchParams);
+
+  const response = await getAnalytics({
+    ...parsedParams,
+    linkId: link.id,
+  });
+
+  let data;
+
+  if (response instanceof Array) {
+    data = response.map((item) => {
+      return {
+        ...item,
+        earnings: calculateEarnings({
+          program,
+          sales: item.sales ?? 0,
+          saleAmount: item.saleAmount ?? 0,
+        }),
+      };
+    });
+  } else {
+    data = {
+      ...response,
+      earnings: calculateEarnings({
+        program,
+        sales: response.sales,
+        saleAmount: response.saleAmount,
+      }),
+    };
+  }
+
+  return NextResponse.json(data);
+});

apps/web/app/api/cron/cleanup-expired-public-tokens/route.ts

@@ -0,0 +1,32 @@
+import { handleAndReturnErrorResponse } from "@/lib/api/errors";
+import { verifyVercelSignature } from "@/lib/cron/verify-vercel";
+import { prisma } from "@/lib/prisma";
+import { log } from "@dub/utils";
+import { NextResponse } from "next/server";
+
+export const dynamic = "force-dynamic";
+
+// Cron to remove the expired public embed tokens
+// Run every day (0 12 * * *)
+export async function GET(req: Request) {
+  try {
+    await verifyVercelSignature(req);
+
+    await prisma.embedPublicToken.deleteMany({
+      where: {
+        expires: {
+          lt: new Date(),
+        },
+      },
+    });
+
+    return NextResponse.json({ status: "OK" });
+  } catch (error) {
+    await log({
+      message: `Referrals public token cleanup failed - ${error.message}`,
+      type: "errors",
+    });
+
+    return handleAndReturnErrorResponse(error);
+  }
+}

apps/web/app/api/events/client/route.ts

@@ -0,0 +1,42 @@
+import { getEvents } from "@/lib/analytics/get-events";
+import { calculateEarnings } from "@/lib/api/sales/commission";
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { eventsQuerySchema } from "@/lib/zod/schemas/analytics";
+import { NextResponse } from "next/server";
+
+// GET /api/events/client - get events for the current link
+export const GET = withEmbedToken(async ({ searchParams, program, link }) => {
+  const parsedParams = eventsQuerySchema
+    .omit({
+      linkId: true,
+      externalId: true,
+      domain: true,
+      root: true,
+      key: true,
+      tagId: true,
+    })
+    .parse(searchParams);
+
+  // TODO:
+  // Replace with sales data
+
+  const response = await getEvents({
+    ...parsedParams,
+    linkId: link.id,
+  });
+
+  return NextResponse.json(
+    response.map((item: any) => {
+      return {
+        ...item,
+        ...(parsedParams.event === "sales" && {
+          earnings: calculateEarnings({
+            program,
+            sales: item.sales ?? 0,
+            saleAmount: item.sale?.amount ?? 0,
+          }),
+        }),
+      };
+    }),
+  );
+});

apps/web/app/api/referrals/invite/route.ts

@@ -0,0 +1,48 @@
+import { invitePartner } from "@/lib/api/partners/invite-partner";
+import { parseRequestBody } from "@/lib/api/utils";
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { requestPartnerInviteSchema } from "@/lib/dots/schemas";
+import { prisma } from "@/lib/prisma";
+import { NextResponse } from "next/server";
+
+// GET /api/referrals/invite - check if a partner is already invited to a program
+export const GET = withEmbedToken(async ({ link, program }) => {
+  const [programEnrollment, programInvite] = await Promise.all([
+    prisma.programEnrollment.findFirst({
+      where: {
+        programId: program.id,
+        linkId: link.id,
+      },
+    }),
+
+    prisma.programInvite.findFirst({
+      where: {
+        programId: program.id,
+        linkId: link.id,
+      },
+    }),
+  ]);
+
+  return NextResponse.json({
+    programEnrollment,
+    programInvite,
+  });
+});
+
+// POST /api/referrals/invite - invite a partner to dub partners
+export const POST = withEmbedToken(
+  async ({ req, link, program, workspace }) => {
+    const { email } = requestPartnerInviteSchema.parse(
+      await parseRequestBody(req),
+    );
+
+    const programInvited = await invitePartner({
+      email,
+      program,
+      link,
+      workspace,
+    });
+
+    return NextResponse.json(programInvited);
+  },
+);

apps/web/app/api/referrals/link/route.ts

@@ -0,0 +1,17 @@
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { NextResponse } from "next/server";
+
+// GET /api/referrals/link - get the link for the given affiliate
+export const GET = withEmbedToken(async ({ link }) => {
+  const { id, url, shortLink, clicks, leads, sales, saleAmount } = link;
+
+  return NextResponse.json({
+    id,
+    url,
+    shortLink,
+    clicks,
+    leads,
+    sales,
+    saleAmount,
+  });
+});

apps/web/app/api/referrals/program/route.ts

@@ -0,0 +1,8 @@
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { ProgramSchema } from "@/lib/zod/schemas/programs";
+import { NextResponse } from "next/server";
+
+// GET /api/referrals/program - get the program for the given affiliate
+export const GET = withEmbedToken(async ({ program }) => {
+  return NextResponse.json(ProgramSchema.parse(program));
+});

apps/web/app/api/referrals/sales/count/route.ts

@@ -0,0 +1,23 @@
+import { getStartEndDates } from "@/lib/analytics/utils/get-start-end-dates";
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { prisma } from "@/lib/prisma";
+import { getPartnerSalesCountQuerySchema } from "@/lib/zod/schemas/partners";
+import { NextResponse } from "next/server";
+
+// GET /api/referrals/sales/count – get sales count for a link
+export const GET = withEmbedToken(async ({ searchParams, link }) => {
+  const parsed = getPartnerSalesCountQuerySchema.parse(searchParams);
+  const { startDate, endDate } = getStartEndDates(parsed);
+
+  const salesCount = await prisma.sale.count({
+    where: {
+      linkId: link.id,
+      createdAt: {
+        gte: startDate.toISOString(),
+        lte: endDate.toISOString(),
+      },
+    },
+  });
+
+  return NextResponse.json({ count: salesCount });
+});

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

@@ -0,0 +1,30 @@
+import { withEmbedToken } from "@/lib/auth/embed-token";
+import { prisma } from "@/lib/prisma";
+import z from "@/lib/zod";
+import { PartnerSaleResponseSchema } from "@/lib/zod/schemas/partners";
+import { NextResponse } from "next/server";
+
+// GET /api/referrals/sales – get sales for a link
+export const GET = withEmbedToken(async ({ link }) => {
+  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: true,
+    },
+    take: 10,
+    orderBy: {
+      createdAt: "desc",
+    },
+  });
+
+  return NextResponse.json(z.array(PartnerSaleResponseSchema).parse(sales));
+});

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

@@ -0,0 +1,23 @@
+import { getLinkOrThrow } from "@/lib/api/links/get-link-or-throw";
+import { parseRequestBody } from "@/lib/api/utils";
+import { withWorkspace } from "@/lib/auth";
+import { createOrRetrieveEmbedToken } from "@/lib/referrals/create-or-retrieve-embed-token";
+import {
+  createReferralTokenSchema,
+  referralTokenSchema,
+} from "@/lib/zod/schemas/referrals";
+import { NextResponse } from "next/server";
+
+// POST /api/tokens/embed - create a new embed token for the given link
+export const POST = withWorkspace(async ({ workspace, req }) => {
+  const { linkId } = createReferralTokenSchema.parse(
+    await parseRequestBody(req),
+  );
+  await getLinkOrThrow({ linkId, workspaceId: workspace.id });
+
+  const token = await createOrRetrieveEmbedToken(linkId);
+
+  return NextResponse.json(referralTokenSchema.parse(token), {
+    status: 201,
+  });
+});

apps/web/app/api/workspaces/[idOrSlug]/embed-token/route.ts

@@ -0,0 +1,27 @@
+import { DubApiError } from "@/lib/api/errors";
+import { withWorkspace } from "@/lib/auth";
+import { APP_DOMAIN_WITH_NGROK } from "@dub/utils";
+import { NextResponse } from "next/server";
+
+// GET /api/workspaces/[idOrSlug]/embed-token - create a new public embed token for the workspace
+export const POST = withWorkspace(async ({ workspace }) => {
+  const { referralLinkId } = workspace;
+
+  if (!referralLinkId) {
+    throw new DubApiError({
+      code: "bad_request",
+      message: "Referral link not found for this workspace.",
+    });
+  }
+
+  const token = await fetch(`${APP_DOMAIN_WITH_NGROK}/api/tokens/embed`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${process.env.DUB_API_KEY}`,
+    },
+    body: JSON.stringify({ linkId: referralLinkId }),
+  }).then((res) => res.json());
+
+  return NextResponse.json(token);
+});

apps/web/app/app.dub.co/(dashboard)/[slug]/settings/billing/usage-chart.tsx

@@ -3,8 +3,7 @@ import { Bars } from "@/ui/charts/bars";
 import TimeSeriesChart from "@/ui/charts/time-series-chart";
 import XAxis from "@/ui/charts/x-axis";
 import YAxis from "@/ui/charts/y-axis";
-import { EmptyState } from "@dub/blocks/src/empty-state";
-import { LoadingSpinner } from "@dub/ui";
+import { EmptyState, LoadingSpinner } from "@dub/ui";
 import { CircleDollar, CursorRays, Hyperlink } from "@dub/ui/src/icons";
 import { formatDate, nFormatter } from "@dub/utils";
 import { LinearGradient } from "@visx/gradient";

apps/web/app/app.dub.co/(dashboard)/[slug]/settings/domains/default-domains.tsx

@@ -5,7 +5,7 @@ import useDefaultDomains from "@/lib/swr/use-default-domains";
 import useWorkspace from "@/lib/swr/use-workspace";
 import { DomainCardTitleColumn } from "@/ui/domains/domain-card-title-column";
 import { UpgradeRequiredToast } from "@/ui/shared/upgrade-required-toast";
-import { Logo, Switch } from "@dub/ui";
+import { Logo, Switch, TooltipContent } from "@dub/ui";
 import {
   Amazon,
   CalendarDays,
@@ -15,7 +15,6 @@ import {
   GoogleEnhanced,
   Spotify,
 } from "@dub/ui/src/icons";
-import { TooltipContent } from "@dub/ui/src/tooltip";
 import { DUB_DOMAINS } from "@dub/utils";
 import Link from "next/link";
 import { useEffect, useState } from "react";

apps/web/app/app.dub.co/(dashboard)/[slug]/settings/domains/page-client.tsx

@@ -14,18 +14,20 @@ import { useRegisterDomainSuccessModal } from "@/ui/modals/register-domain-succe
 import { AnimatedEmptyState } from "@/ui/shared/animated-empty-state";
 import EmptyState from "@/ui/shared/empty-state";
 import { SearchBoxPersisted } from "@/ui/shared/search-box";
-import { PaginationControls } from "@dub/blocks/src/pagination-controls";
 import {
   Badge,
   Button,
+  CursorRays,
   Globe,
+  InfoTooltip,
+  LinkBroken,
+  PaginationControls,
   Popover,
+  ToggleGroup,
+  TooltipContent,
   usePagination,
   useRouterStuff,
 } from "@dub/ui";
-import { CursorRays, LinkBroken } from "@dub/ui/src/icons";
-import { ToggleGroup } from "@dub/ui/src/toggle-group";
-import { InfoTooltip, TooltipContent } from "@dub/ui/src/tooltip";
 import { capitalize, pluralize } from "@dub/utils";
 import { ChevronDown, Crown } from "lucide-react";
 import { useEffect, useState } from "react";

apps/web/app/app.dub.co/(dashboard)/[slug]/settings/integrations/[integrationSlug]/page-client.tsx

@@ -17,6 +17,8 @@ import {
   MaxWidthWrapper,
   Popover,
   TokenAvatar,
+  Tooltip,
+  TooltipContent,
 } from "@dub/ui";
 import {
   CircleWarning,
@@ -25,7 +27,6 @@ import {
   OfficeBuilding,
   ShieldCheck,
 } from "@dub/ui/src/icons";
-import { Tooltip, TooltipContent } from "@dub/ui/src/tooltip";
 import {
   cn,
   formatDate,

apps/web/app/app.dub.co/(dashboard)/[slug]/settings/library/tags/page-client.tsx

@@ -7,8 +7,13 @@ import { TAGS_MAX_PAGE_SIZE } from "@/lib/zod/schemas/tags";
 import { useAddEditTagModal } from "@/ui/modals/add-edit-tag-modal";
 import { AnimatedEmptyState } from "@/ui/shared/animated-empty-state";
 import { SearchBoxPersisted } from "@/ui/shared/search-box";
-import { PaginationControls } from "@dub/blocks";
-import { CardList, Tag, usePagination, useRouterStuff } from "@dub/ui";
+import {
+  CardList,
+  PaginationControls,
+  Tag,
+  usePagination,
+  useRouterStuff,
+} from "@dub/ui";
 import { createContext, Dispatch, SetStateAction, useState } from "react";
 import { TagCard } from "./tag-card";
 import { TagCardPlaceholder } from "./tag-card-placeholder";