Polar.sh Setup

bun add @polar-sh/sdk @polar-sh/better-auth

import { Polar } from "@polar-sh/sdk";

export const polarClient = new Polar({
  accessToken: process.env.POLAR_ACCESS_TOKEN,
  server: "sandbox", // or "production"
});

import { betterAuth } from "better-auth";
import { polar } from "@polar-sh/better-auth";

export const auth = betterAuth({
  plugins: [
    polar({
      client: polarClient,
      createCustomerOnSignUp: true,
      use: [
        checkout({
          products: products.map((product) => ({
            productId: product.productId,
            slug: product.slug,
          })),
          successUrl: `${process.env.POLAR_SUCCESS_URL}`,
          authenticatedUsersOnly: true,
        }),
        portal(),
        webhooks({
          secret: process.env.POLAR_WEBHOOK_SECRET,
          onPayload: async ({ data, type }) => {
            // Handle webhook events
          },
        }),
      ],
    }),
  ],
});

import { webhooks } from "@polar-sh/better-auth";

export const auth = betterAuth({
  plugins: [
    webhooks({
      secret: process.env.POLAR_WEBHOOK_SECRET ||
		(() => {
			throw new Error("POLAR_WEBHOOK_SECRET environment variable is required",);})(),
					onPayload: async ({ data, type }) => {
						if (
							type === "subscription.created" ||
							type === "subscription.active" ||
							type === "subscription.canceled" ||
							type === "subscription.revoked" ||
							type === "subscription.uncanceled" ||
							type === "subscription.updated"
						) {
							console.log(
								"🎯 Processing subscription webhook:",
								type,
							);
							console.log(
								"📦 Payload data:",
								JSON.stringify(data, null, 2),
							);

							try {
								const userId = data.customer?.externalId;

								const subscriptionData = {
									id: data.id,
									provider: Provider.POLAR,
									providerSubscriptionId: data.id,
									providerCustomerId: data.customerId,
									userId: userId as string,
									plan: products.find(
										(p) => p.productId === data.productId,
									)?.slug ?? "default",
									amount: data.amount,
									currency: data.currency,
									status: data.status,
									cancelAtPeriodEnd: data.cancelAtPeriodEnd,
									currentPeriodStart: new Date(
										data.currentPeriodStart,
									),
									currentPeriodEnd: data.currentPeriodEnd
										? new Date(data.currentPeriodEnd)
										: undefined,
									createdAt: new Date(data.createdAt),
									updatedAt: data.modifiedAt
										? new Date(data.modifiedAt)
										: undefined,
									metadata: data.metadata ?? {},
								};

								console.log("💾 Final subscription data:", {
									id: subscriptionData.id,
									status: subscriptionData.status,
									userId: subscriptionData.userId,
									amount: subscriptionData.amount,
								});

								console.log(
									"🔍 Checking for existing subscription:",
									data.id,
								);
								const existingSubscription = await prisma
									.subscription.findUnique({
										where: {
											id: data.id,
										},
									});

								if (existingSubscription) {
									console.log(
										"🔄 Updating existing subscription:",
										data.id,
									);
									await prisma.subscription.update({
										where: {
											id: data.id,
										},
										data: subscriptionData,
									});
								} else {
									console.log(
										"🆕 Creating new subscription:",
										data.id,
									);
									await prisma.subscription.create({
										data: subscriptionData,
									});
								}

								console.log(
									"✅ Subscription processed:",
									data.id,
								);
							} catch (error) {
								console.error(
									"💥 Error processing subscription webhook:",
									error,
								);
							}
						}
					},
				}),

import { createAuthClient } from "better-auth/react";
import { polarClient } from "@polar-sh/better-auth";

export const authClient = createAuthClient({
  baseURL: process.env.NEXT_PUBLIC_SERVER_URL!,
  plugins: [
    polarClient(),
  ],
});

export const products = [
  {
    productId: process.env.POLAR_PRODUCT1_PRODUCT_ID,
    slug: "basic",
    name: "Basic Plan",
    price: "$10/month",
    features: ["Feature 1", "Feature 2"],
  },
  {
    productId: process.env.POLAR_PRODUCT2_PRODUCT_ID,
    slug: "pro",
    name: "Pro Plan",
    price: "$20/month",
    features: ["Feature 1", "Feature 2", "Feature 3"],
  },
];

export const products = [
  {
    productId: process.env.POLAR_PRODUCT1_PRODUCT_ID,
    slug: "basic",
    name: "Basic Plan",
    price: "$10/month",
    features: ["Feature 1", "Feature 2"],
  },
  {
    productId: process.env.POLAR_PRODUCT2_PRODUCT_ID,
    slug: "pro",
    name: "Pro Plan",
    price: "$20/month",
    features: ["Feature 1", "Feature 2", "Feature 3"],
  },
];

// src/app/api/webhooks/polar/route.ts
import { polar } from "@/lib/polar/client";
import { headers } from "next/headers";

export async function POST(req: Request) {
  const body = await req.json();
  const signature = headers().get("polar-signature");

  try {
    const event = polar.webhooks.constructEvent(
      body,
      signature!,
      process.env.POLAR_WEBHOOK_SECRET!
    );

    switch (event.type) {
      case "subscription.created":
      case "subscription.active":
      case "subscription.canceled":
      case "subscription.revoked":
      case "subscription.uncanceled":
      case "subscription.updated":
        await handleSubscriptionEvent(event.data);
        break;
    }

    return new Response("Webhook processed", { status: 200 });
  } catch (error) {
    console.error("Webhook error:", error);
    return new Response("Webhook error", { status: 400 });
  }
}

await authClient.checkout({
  products: [productId],
  slug: productSlug,
});