-
+
{subscription.plan.name}
-
+
{subscription.status}
-
+
{subscription.plan.price === 0 ? (
"Free"
@@ -73,23 +86,30 @@ export default async function SettingsPage({ params }: { params: { locale: strin
<>
€{(subscription.plan.price / 100).toFixed(2)}
- /{subscription.plan.interval === "lifetime" ? "lifetime" : subscription.plan.interval}
+ /
+ {subscription.plan.interval === "lifetime"
+ ? "lifetime"
+ : subscription.plan.interval}
)}
-
-
- {format(new Date(subscription.currentPeriodEnd), "MMMM d, yyyy")}
-
-
+
+
+ {format(
+ new Date(subscription.currentPeriodEnd),
+ "MMMM d, yyyy",
+ )}
+
+
@@ -101,6 +121,25 @@ export default async function SettingsPage({ params }: { params: { locale: strin
)}
+
+ {/* Clerk Account Management */}
+
+
+ Account Management
+
+
+
+
+
);
diff --git a/src/app/api/cdn/[...path]/route.ts b/src/app/api/cdn/[...path]/route.ts
new file mode 100644
index 0000000..fce003a
--- /dev/null
+++ b/src/app/api/cdn/[...path]/route.ts
@@ -0,0 +1,49 @@
+import { GetObjectCommand } from "@aws-sdk/client-s3";
+import { NextResponse } from "next/server";
+import { s3Client, BUCKET_NAME } from "@/lib/s3";
+
+const MAX_BYTES = 5 * 1024 * 1024;
+
+export async function GET(
+ _request: Request,
+ { params }: { params: Promise<{ path: string[] }> }
+) {
+ const { path } = await params;
+
+ if (path.some((segment) => segment === ".." || segment === "")) {
+ return new NextResponse("Bad request", { status: 400 });
+ }
+
+ const key = path.join("/");
+
+ try {
+ const response = await s3Client.send(
+ new GetObjectCommand({ Bucket: BUCKET_NAME, Key: key })
+ );
+
+ if (response.ContentLength && response.ContentLength > MAX_BYTES) {
+ return new NextResponse("File too large", { status: 413 });
+ }
+
+ if (!response.Body) {
+ return new NextResponse("Not found", { status: 404 });
+ }
+
+ const headers = new Headers({
+ "Content-Type": response.ContentType ?? "application/octet-stream",
+ "Cache-Control": "public, max-age=31536000, immutable",
+ });
+
+ if (response.ContentLength) {
+ headers.set("Content-Length", String(response.ContentLength));
+ }
+
+ return new NextResponse(response.Body.transformToWebStream(), { headers });
+ } catch (error: unknown) {
+ if ((error as { name?: string })?.name === "NoSuchKey") {
+ return new NextResponse("Not found", { status: 404 });
+ }
+ console.error("CDN proxy error:", error);
+ return new NextResponse("Internal server error", { status: 500 });
+ }
+}
diff --git a/src/app/api/webhooks/paddle/route.ts b/src/app/api/webhooks/paddle/route.ts
new file mode 100644
index 0000000..2e32de8
--- /dev/null
+++ b/src/app/api/webhooks/paddle/route.ts
@@ -0,0 +1,236 @@
+import { NextRequest, NextResponse } from "next/server";
+import { Paddle, EventName, Environment } from "@paddle/paddle-node-sdk";
+import { db } from "@/db";
+import { users, userSubscriptions, subscriptionPlans } from "@/db/schema";
+import { eq } from "drizzle-orm";
+import {
+ sendWelcomeToPremiumEmail,
+ sendPaymentFailedEmail,
+ sendSubscriptionCanceledEmail,
+} from "@/lib/email";
+
+const paddle = new Paddle(process.env.PADDLE_API_KEY!, {
+ environment:
+ process.env.PADDLE_ENVIRONMENT === "production"
+ ? Environment.production
+ : Environment.sandbox,
+});
+
+export const dynamic = "force-dynamic";
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+ try {
+ const signature = req.headers.get("paddle-signature");
+ const rawBody = await req.text();
+
+ if (!signature) {
+ return NextResponse.json({ error: "Missing signature" }, { status: 401 });
+ }
+
+ // Verify webhook signature
+ const secretKey = process.env.PADDLE_WEBHOOK_SECRET!;
+ const eventData = paddle.webhooks.unmarshal(rawBody, secretKey, signature);
+
+ const event = JSON.parse(rawBody);
+ const eventType = event.event_type;
+
+ console.log(`Paddle webhook: ${eventType}`);
+
+ switch (eventType) {
+ case EventName.SubscriptionCreated:
+ case EventName.SubscriptionUpdated:
+ await handleSubscriptionUpdate(event.data);
+ break;
+ case EventName.SubscriptionCanceled:
+ await handleSubscriptionCanceled(event.data);
+ break;
+ case EventName.TransactionCompleted:
+ await handleTransactionCompleted(event.data);
+ break;
+ case EventName.TransactionPaymentFailed:
+ await handlePaymentFailed(event.data);
+ break;
+ default:
+ console.log(`Unhandled: ${eventType}`);
+ }
+
+ return NextResponse.json({ received: true });
+ } catch (err) {
+ console.error("Paddle webhook error:", err);
+ return NextResponse.json(
+ { error: "Processing failed" },
+ { status: 500 },
+ );
+ }
+}
+
+async function handleSubscriptionUpdate(subscription: any) {
+ const userId = subscription.custom_data?.userId;
+ if (!userId) {
+ console.error("No userId in subscription custom_data");
+ return;
+ }
+
+ const priceId = subscription.items[0]?.price?.id;
+ const plan = await db.query.subscriptionPlans.findFirst({
+ where: eq(subscriptionPlans.paddlePriceId, priceId),
+ });
+
+ if (!plan) {
+ console.error("No plan found for price:", priceId);
+ return;
+ }
+
+ // Parse Paddle timestamps (ISO 8601 strings)
+ const billingPeriod = subscription.current_billing_period;
+ const currentPeriodStart = billingPeriod?.starts_at
+ ? new Date(billingPeriod.starts_at)
+ : null;
+ const currentPeriodEnd = billingPeriod?.ends_at
+ ? new Date(billingPeriod.ends_at)
+ : null;
+
+ const existing = await db.query.userSubscriptions.findFirst({
+ where: eq(userSubscriptions.userId, userId),
+ });
+
+ const subscriptionData = {
+ planId: plan.id,
+ paddleSubscriptionId: subscription.id,
+ paddleCustomerId: subscription.customer_id,
+ status: subscription.status as any,
+ currentPeriodStart,
+ currentPeriodEnd,
+ cancelAtPeriodEnd: subscription.scheduled_change?.action === "cancel",
+ updatedAt: new Date(),
+ };
+
+ if (existing) {
+ await db
+ .update(userSubscriptions)
+ .set(subscriptionData)
+ .where(eq(userSubscriptions.userId, userId));
+ } else {
+ await db.insert(userSubscriptions).values({
+ userId,
+ ...subscriptionData,
+ });
+ }
+
+ console.log(
+ "✅ Subscription synced successfully for user:",
+ userId,
+ "- Plan:",
+ plan.name,
+ "- Status:",
+ subscription.status,
+ );
+
+ // Send welcome email for new premium subscriptions
+ if (
+ (subscription.status === "active" || subscription.status === "trialing") &&
+ !existing
+ ) {
+ const user = await db.query.users.findFirst({
+ where: eq(users.id, userId),
+ });
+ if (user) {
+ try {
+ await sendWelcomeToPremiumEmail(user.email, user.username || "there");
+ } catch (emailError) {
+ console.error("Failed to send welcome email:", emailError);
+ }
+ }
+ }
+}
+
+async function handleSubscriptionCanceled(subscription: any) {
+ const userId = subscription.custom_data?.userId;
+ const existingSub = await db.query.userSubscriptions.findFirst({
+ where: userId
+ ? eq(userSubscriptions.userId, userId)
+ : eq(userSubscriptions.paddleSubscriptionId, subscription.id),
+ });
+
+ if (!existingSub) return;
+
+ await db
+ .update(userSubscriptions)
+ .set({
+ status: "canceled",
+ canceledAt: new Date(),
+ updatedAt: new Date(),
+ })
+ .where(eq(userSubscriptions.userId, existingSub.userId));
+
+ // Downgrade to free plan
+ const freePlan = await db.query.subscriptionPlans.findFirst({
+ where: eq(subscriptionPlans.interval, "free"),
+ });
+
+ if (freePlan) {
+ await db
+ .update(userSubscriptions)
+ .set({ planId: freePlan.id })
+ .where(eq(userSubscriptions.userId, existingSub.userId));
+ }
+
+ // Send cancellation email
+ const user = await db.query.users.findFirst({
+ where: eq(users.id, existingSub.userId),
+ });
+
+ if (user && existingSub.currentPeriodEnd) {
+ try {
+ await sendSubscriptionCanceledEmail(
+ user.email,
+ user.username || "there",
+ existingSub.currentPeriodEnd,
+ );
+ } catch (emailError) {
+ console.error("Failed to send cancellation email:", emailError);
+ }
+ }
+}
+
+async function handleTransactionCompleted(transaction: any) {
+ // Refresh subscription data after successful payment
+ if (transaction.subscription_id) {
+ const subscription = await paddle.subscriptions.get(
+ transaction.subscription_id,
+ );
+ await handleSubscriptionUpdate(subscription);
+ }
+}
+
+async function handlePaymentFailed(transaction: any) {
+ const subscriptionId = transaction.subscription_id;
+ if (!subscriptionId) return;
+
+ const subscription = await db.query.userSubscriptions.findFirst({
+ where: eq(userSubscriptions.paddleSubscriptionId, subscriptionId),
+ });
+
+ if (!subscription) return;
+
+ await db
+ .update(userSubscriptions)
+ .set({
+ status: "past_due",
+ updatedAt: new Date(),
+ })
+ .where(eq(userSubscriptions.userId, subscription.userId));
+
+ const user = await db.query.users.findFirst({
+ where: eq(users.id, subscription.userId),
+ });
+
+ if (user) {
+ try {
+ await sendPaymentFailedEmail(user.email, user.username || "there");
+ } catch (emailError) {
+ console.error("Failed to send payment failed email:", emailError);
+ }
+ }
+}
diff --git a/src/components/admin/create-plan-dialog.tsx b/src/components/admin/create-plan-dialog.tsx
index 3c01832..14a8cd8 100644
--- a/src/components/admin/create-plan-dialog.tsx
+++ b/src/components/admin/create-plan-dialog.tsx
@@ -31,8 +31,8 @@ export function CreatePlanDialog() {
const [loading, setLoading] = useState(false);
const [formData, setFormData] = useState({
name: "",
- stripePriceId: "",
- stripeProductId: "",
+ paddlePriceId: "",
+ paddleProductId: "",
price: 0,
interval: "month" as "month" | "year" | "lifetime" | "free",
sortOrder: 10,
@@ -45,8 +45,8 @@ export function CreatePlanDialog() {
try {
const result = await createSubscriptionPlan({
name: formData.name,
- stripePriceId: formData.stripePriceId || null,
- stripeProductId: formData.stripeProductId || null,
+ paddlePriceId: formData.paddlePriceId || null,
+ paddleProductId: formData.paddleProductId || null,
price: Math.round(formData.price * 100), // Convert to cents
interval: formData.interval,
isActive: true,
@@ -61,8 +61,8 @@ export function CreatePlanDialog() {
// Reset form
setFormData({
name: "",
- stripePriceId: "",
- stripeProductId: "",
+ paddlePriceId: "",
+ paddleProductId: "",
price: 0,
interval: "month",
sortOrder: 10,
@@ -89,8 +89,8 @@ export function CreatePlanDialog() {
Create Subscription Plan
- Add a new subscription plan. Enter the Stripe Price ID from your
- Stripe Dashboard.
+ Add a new subscription plan. Enter the Paddle Price ID from your
+ Paddle Dashboard.
@@ -149,14 +149,14 @@ export function CreatePlanDialog() {
-
+
- setFormData({ ...formData, stripePriceId: e.target.value })
+ setFormData({ ...formData, paddlePriceId: e.target.value })
}
- placeholder="price_..."
+ placeholder="pri_..."
className="font-mono text-sm"
/>
@@ -165,17 +165,17 @@ export function CreatePlanDialog() {
-
+
setFormData({
...formData,
- stripeProductId: e.target.value,
+ paddleProductId: e.target.value,
})
}
- placeholder="prod_..."
+ placeholder="pro_..."
className="font-mono text-sm"
/>
diff --git a/src/components/admin/edit-plan-dialog.tsx b/src/components/admin/edit-plan-dialog.tsx
index eff3565..f063a5d 100644
--- a/src/components/admin/edit-plan-dialog.tsx
+++ b/src/components/admin/edit-plan-dialog.tsx
@@ -24,8 +24,8 @@ interface Plan {
interval: string;
isActive: boolean;
isInternal: boolean;
- stripePriceId: string | null;
- stripeProductId: string | null;
+ paddlePriceId: string | null;
+ paddleProductId: string | null;
sortOrder: number;
}
@@ -43,8 +43,8 @@ export function EditPlanDialog({
const [formData, setFormData] = useState({
name: plan.name,
price: plan.price / 100, // Convert cents to dollars
- stripePriceId: plan.stripePriceId || "",
- stripeProductId: plan.stripeProductId || "",
+ paddlePriceId: plan.paddlePriceId || "",
+ paddleProductId: plan.paddleProductId || "",
isActive: plan.isActive,
isInternal: plan.isInternal,
});
@@ -57,8 +57,8 @@ export function EditPlanDialog({
const result = await updateSubscriptionPlan(plan.id, {
name: formData.name,
price: Math.round(formData.price * 100), // Convert to cents
- stripePriceId: formData.stripePriceId || null,
- stripeProductId: formData.stripeProductId || null,
+ paddlePriceId: formData.paddlePriceId || null,
+ paddleProductId: formData.paddleProductId || null,
isActive: formData.isActive,
isInternal: formData.isInternal,
});
@@ -116,14 +116,14 @@ export function EditPlanDialog({
-
+
- setFormData({ ...formData, stripePriceId: e.target.value })
+ setFormData({ ...formData, paddlePriceId: e.target.value })
}
- placeholder="price_..."
+ placeholder="pri_..."
className="font-mono text-sm"
/>
@@ -132,14 +132,14 @@ export function EditPlanDialog({
-
+
- setFormData({ ...formData, stripeProductId: e.target.value })
+ setFormData({ ...formData, paddleProductId: e.target.value })
}
- placeholder="prod_..."
+ placeholder="pro_..."
className="font-mono text-sm"
/>
diff --git a/src/components/admin/subscription-plans-table.tsx b/src/components/admin/subscription-plans-table.tsx
index 08645cb..55b1af3 100644
--- a/src/components/admin/subscription-plans-table.tsx
+++ b/src/components/admin/subscription-plans-table.tsx
@@ -21,8 +21,8 @@ interface Plan {
interval: string;
isActive: boolean;
isInternal: boolean;
- stripePriceId: string | null;
- stripeProductId: string | null;
+ paddlePriceId: string | null;
+ paddleProductId: string | null;
sortOrder: number;
}
@@ -40,7 +40,7 @@ export function SubscriptionPlansTable({ plans }: { plans: Plan[] }) {
Interval
Status
Visibility
- Stripe Price ID
+ Paddle Price ID
Actions
@@ -65,7 +65,7 @@ export function SubscriptionPlansTable({ plans }: { plans: Plan[] }) {
- {plan.stripePriceId || "—"}
+ {plan.paddlePriceId || "—"}