+ {/* Simple Navigation */}
+
-
);
}
diff --git a/app/api/v1/webhooks/paddle/route.ts b/app/api/v1/webhooks/paddle/route.ts
new file mode 100644
index 0000000..638bc47
--- /dev/null
+++ b/app/api/v1/webhooks/paddle/route.ts
@@ -0,0 +1,238 @@
+import { PaddleWebhookVerifier } from '@/server/payment';
+import { db } from '@/server/db/client';
+import type {
+ AllPaddleWebhookEvents,
+ SubscriptionCreatedEvent,
+ SubscriptionUpdatedEvent,
+ SubscriptionCanceledEvent,
+ TransactionCompletedEvent
+} from '@/constants/config/paddle-webhooks';
+import { NextRequest, NextResponse } from 'next/server';
+
+export async function POST(req: NextRequest) {
+ try {
+ // Get raw body and signature
+ const body = await req.text();
+ const signature = req.headers.get('paddle-signature');
+
+ if (!signature) {
+ console.error('Missing Paddle signature');
+ return NextResponse.json({ error: 'Missing signature' }, { status: 400 });
+ }
+
+ // Verify and parse webhook
+ const event = PaddleWebhookVerifier.parseWebhook(body, signature);
+ if (!event) {
+ console.error('Invalid webhook signature or payload');
+ return NextResponse.json({ error: 'Invalid webhook' }, { status: 400 });
+ }
+
+ console.log(`Processing Paddle webhook: ${event.event_type}`, {
+ eventId: event.event_id,
+ eventType: event.event_type,
+ });
+
+ // Handle different event types
+ await handleWebhookEvent(event);
+
+ return NextResponse.json({ success: true });
+ } catch (error) {
+ console.error('Paddle webhook error:', error);
+ return NextResponse.json(
+ { error: 'Webhook processing failed' },
+ { status: 500 }
+ );
+ }
+}
+
+async function handleWebhookEvent(event: AllPaddleWebhookEvents) {
+ switch (event.event_type) {
+ case 'subscription.created':
+ await handleSubscriptionCreated(event as SubscriptionCreatedEvent);
+ break;
+
+ case 'subscription.updated':
+ await handleSubscriptionUpdated(event as SubscriptionUpdatedEvent);
+ break;
+
+ case 'subscription.canceled':
+ await handleSubscriptionCanceled(event as SubscriptionCanceledEvent);
+ break;
+
+ case 'transaction.completed':
+ await handleTransactionCompleted(event as TransactionCompletedEvent);
+ break;
+
+ default:
+ console.log(`Unhandled webhook event: ${event.event_type}`);
+ }
+}
+
+async function handleSubscriptionCreated(event: SubscriptionCreatedEvent) {
+ const { data } = event;
+
+ try {
+ // Extract organization ID from custom data
+ const organizationId = data.custom_data?.organizationId as string;
+
+ if (!organizationId) {
+ console.error('No organization ID in subscription custom data');
+ return;
+ }
+
+ // Get the price ID to determine plan
+ const priceId = data.items[0]?.price.id;
+ if (!priceId) {
+ console.error('No price ID found in subscription');
+ return;
+ }
+
+ // Map price ID to plan (you'll need to implement this mapping)
+ const planType = mapPriceIdToPlan(priceId);
+ if (!planType) {
+ console.error(`Unknown price ID: ${priceId}`);
+ return;
+ }
+
+ // Update organization with subscription details
+ await db.organization.update({
+ where: { id: organizationId },
+ data: {
+ plan: planType,
+ paddleSubscriptionId: data.id,
+ paddleCustomerId: data.customer_id,
+ subscriptionStatus: 'ACTIVE',
+ subscriptionCurrentPeriodStart: new Date(data.current_billing_period.starts_at),
+ subscriptionCurrentPeriodEnd: new Date(data.current_billing_period.ends_at),
+ subscriptionCancelAtPeriodEnd: false,
+ },
+ });
+
+ console.log(`Subscription created for organization ${organizationId}: ${data.id}`);
+ } catch (error) {
+ console.error('Error handling subscription created:', error);
+ throw error;
+ }
+}
+
+async function handleSubscriptionUpdated(event: SubscriptionUpdatedEvent) {
+ const { data } = event;
+
+ try {
+ // Find organization by Paddle subscription ID
+ const organization = await db.organization.findFirst({
+ where: { paddleSubscriptionId: data.id },
+ });
+
+ if (!organization) {
+ console.error(`Organization not found for subscription: ${data.id}`);
+ return;
+ }
+
+ // Get the price ID to determine plan
+ const priceId = data.items[0]?.price.id;
+ if (!priceId) {
+ console.error('No price ID found in subscription update');
+ return;
+ }
+
+ const planType = mapPriceIdToPlan(priceId);
+ if (!planType) {
+ console.error(`Unknown price ID: ${priceId}`);
+ return;
+ }
+
+ // Update organization with new subscription details
+ await db.organization.update({
+ where: { id: organization.id },
+ data: {
+ plan: planType,
+ subscriptionStatus: data.status === 'active' ? 'ACTIVE' : 'INACTIVE',
+ subscriptionCurrentPeriodStart: new Date(data.current_billing_period.starts_at),
+ subscriptionCurrentPeriodEnd: new Date(data.current_billing_period.ends_at),
+ subscriptionCancelAtPeriodEnd: Boolean(data.canceled_at),
+ },
+ });
+
+ console.log(`Subscription updated for organization ${organization.id}: ${data.id}`);
+ } catch (error) {
+ console.error('Error handling subscription updated:', error);
+ throw error;
+ }
+}
+
+async function handleSubscriptionCanceled(event: SubscriptionCanceledEvent) {
+ const { data } = event;
+
+ try {
+ // Find organization by Paddle subscription ID
+ const organization = await db.organization.findFirst({
+ where: { paddleSubscriptionId: data.id },
+ });
+
+ if (!organization) {
+ console.error(`Organization not found for subscription: ${data.id}`);
+ return;
+ }
+
+ // Update organization subscription status
+ await db.organization.update({
+ where: { id: organization.id },
+ data: {
+ subscriptionStatus: 'CANCELED',
+ subscriptionCancelAtPeriodEnd: true,
+ // Keep current period end date for grace period
+ },
+ });
+
+ console.log(`Subscription canceled for organization ${organization.id}: ${data.id}`);
+ } catch (error) {
+ console.error('Error handling subscription canceled:', error);
+ throw error;
+ }
+}
+
+async function handleTransactionCompleted(event: TransactionCompletedEvent) {
+ const { data } = event;
+
+ try {
+ // Log successful payment
+ console.log(`Payment completed: ${data.id} for customer ${data.customer_id}`);
+
+ // If this is for a subscription, the subscription.updated event will handle the main logic
+ // This is mainly for logging and additional payment tracking if needed
+
+ // You could store payment records here if needed
+ // await db.payment.create({
+ // data: {
+ // paddleTransactionId: data.id,
+ // paddleCustomerId: data.customer_id,
+ // amount: parseInt(data.details.totals.total),
+ // currency: data.currency_code,
+ // status: 'completed',
+ // paidAt: new Date(data.billed_at),
+ // },
+ // });
+
+ } catch (error) {
+ console.error('Error handling transaction completed:', error);
+ throw error;
+ }
+}
+
+// Helper function to map Paddle price IDs to plan types
+function mapPriceIdToPlan(priceId: string): 'FREE' | 'PRO' | 'BUSINESS' | 'AGENCY' | 'CUSTOM' | null {
+ // You'll need to map your actual Paddle price IDs to plan types
+ // This should match the price IDs you set up in your Paddle dashboard
+ const priceIdToPlanMap: Record
= {
+ 'pri_pro_monthly': 'PRO',
+ 'pri_pro_yearly': 'PRO',
+ 'pri_business_monthly': 'BUSINESS',
+ 'pri_business_yearly': 'BUSINESS',
+ 'pri_agency_monthly': 'AGENCY',
+ 'pri_agency_yearly': 'AGENCY',
+ // Add your actual Paddle price IDs here
+ };
+
+ return priceIdToPlanMap[priceId] || null;
+}
diff --git a/app/api/webhooks/paddle/route.ts b/app/api/webhooks/paddle/route.ts
new file mode 100644
index 0000000..e69de29
diff --git a/app/sign-in/page.tsx b/app/sign-in/page.tsx
new file mode 100644
index 0000000..13825bf
--- /dev/null
+++ b/app/sign-in/page.tsx
@@ -0,0 +1,5 @@
+import { SignInPage } from "@/components/auth/sign-in-button";
+
+export default function SignIn() {
+ return ;
+}
diff --git a/app/test-paddle/page.tsx b/app/test-paddle/page.tsx
new file mode 100644
index 0000000..608b333
--- /dev/null
+++ b/app/test-paddle/page.tsx
@@ -0,0 +1,5 @@
+import { PaddleTestComponent } from "@/components/auth/paddle-test";
+
+export default function TestPaddlePage() {
+ return ;
+}
diff --git a/bun.lock b/bun.lock
index 2b3c584..2a23fda 100644
--- a/bun.lock
+++ b/bun.lock
@@ -6,8 +6,10 @@
"dependencies": {
"@clerk/nextjs": "^6.31.9",
"@neondatabase/serverless": "^1.0.1",
+ "@paddle/paddle-node-sdk": "^3.2.1",
"@prisma/adapter-neon": "^6.15.0",
"@prisma/client": "^6.15.0",
+ "@radix-ui/react-slot": "^1.2.3",
"@t3-oss/env-nextjs": "^0.13.8",
"class-variance-authority": "^0.7.1",
"clsx": "^2.1.1",
@@ -224,6 +226,8 @@
"@nolyfill/is-core-module": ["@nolyfill/is-core-module@1.0.39", "", {}, "sha512-nn5ozdjYQpUCZlWGuxcJY/KpxkWQs4DcbMCmKojjyrYDEAGy4Ce19NN4v5MduafTwJlbKc99UA8YhSVqq9yPZA=="],
+ "@paddle/paddle-node-sdk": ["@paddle/paddle-node-sdk@3.2.1", "", {}, "sha512-0IfxqYCJLHyH7oCGbPWxIPxQKw4Zi6rg04UMvmN7EqlWdJi5RXfzFAqwGXK+3tqHYzEBpo3RxiL9B+k5gCt3Hw=="],
+
"@prisma/adapter-neon": ["@prisma/adapter-neon@6.15.0", "", { "dependencies": { "@neondatabase/serverless": ">0.6.0 <2", "@prisma/driver-adapter-utils": "6.15.0", "postgres-array": "3.0.4" } }, "sha512-2PGfuSw2aECC6Nsph+p1rRG9RRumLdoadxxVxT/maoymxZishA9ASBQvMaPCjxpjhQ7qExYxqcooz6XyyYUhig=="],
"@prisma/client": ["@prisma/client@6.15.0", "", { "peerDependencies": { "prisma": "*", "typescript": ">=5.1.0" }, "optionalPeers": ["prisma", "typescript"] }, "sha512-wR2LXUbOH4cL/WToatI/Y2c7uzni76oNFND7+23ypLllBmIS8e3ZHhO+nud9iXSXKFt1SoM3fTZvHawg63emZw=="],
@@ -242,6 +246,10 @@
"@prisma/get-platform": ["@prisma/get-platform@6.15.0", "", { "dependencies": { "@prisma/debug": "6.15.0" } }, "sha512-Jbb+Xbxyp05NSR1x2epabetHiXvpO8tdN2YNoWoA/ZsbYyxxu/CO/ROBauIFuMXs3Ti+W7N7SJtWsHGaWte9Rg=="],
+ "@radix-ui/react-compose-refs": ["@radix-ui/react-compose-refs@1.1.2", "", { "peerDependencies": { "@types/react": "*", "react": "^16.8 || ^17.0 || ^18.0 || ^19.0 || ^19.0.0-rc" }, "optionalPeers": ["@types/react"] }, "sha512-z4eqJvfiNnFMHIIvXP3CY57y2WJs5g2v3X0zm9mEJkrkNv4rDxu+sg9Jh8EkXyeqBkB7SOcboo9dMVqhyrACIg=="],
+
+ "@radix-ui/react-slot": ["@radix-ui/react-slot@1.2.3", "", { "dependencies": { "@radix-ui/react-compose-refs": "1.1.2" }, "peerDependencies": { "@types/react": "*", "react": "^16.8 || ^17.0 || ^18.0 || ^19.0 || ^19.0.0-rc" }, "optionalPeers": ["@types/react"] }, "sha512-aeNmHnBxbi2St0au6VBVC7JXFlhLlOnvIIlePNniyUNAClzmtAUEY8/pBiK3iHjufOlwA+c20/8jngo7xcrg8A=="],
+
"@rtsao/scc": ["@rtsao/scc@1.1.0", "", {}, "sha512-zt6OdqaDoOnJ1ZYsCYGt9YmWzDXl4vQdKTyJev62gFhRGKdx7mcT54V9KIjg+d2wi9EXsPvAPKe7i7WjfVWB8g=="],
"@rushstack/eslint-patch": ["@rushstack/eslint-patch@1.12.0", "", {}, "sha512-5EwMtOqvJMMa3HbmxLlF74e+3/HhwBTMcvt3nqVJgGCozO6hzIPOBlwm8mGVNR9SN2IJpxSnlxczyDjcn7qIyw=="],
diff --git a/components/auth/paddle-test.tsx b/components/auth/paddle-test.tsx
new file mode 100644
index 0000000..adc0a01
--- /dev/null
+++ b/components/auth/paddle-test.tsx
@@ -0,0 +1,139 @@
+'use client';
+
+import { SignedIn, SignedOut } from '@clerk/nextjs';
+import { Button } from '@/components/ui/button';
+import { Card, CardContent, CardDescription, CardHeader, CardTitle } from '@/components/ui/card';
+import { SignInPage } from './sign-in-button';
+
+export function PaddleTestComponent() {
+ return (
+
+
+
+
Paddle Checkout Test
+
+ Sign in to test the Paddle payment integration
+
+
+
+
+
+
+
Paddle Integration Test
+
+ Test the Paddle checkout integration with different plans
+
+
+
+
+ {/* Pro Plan Test */}
+
+
+ Pro Plan Test
+ Test Paddle checkout with Pro plan
+ $29/mo
+
+
+
+ -
+ ✓
+ 1,000 content generations
+
+ -
+ ✓
+ 10 projects
+
+ -
+ ✓
+ API access
+
+
+
+
+
+
+ {/* Business Plan Test */}
+
+
+ Business Plan Test
+ Test Paddle checkout with Business plan
+ $99/mo
+
+
+
+ -
+ ✓
+ Unlimited content
+
+ -
+ ✓
+ Unlimited projects
+
+ -
+ ✓
+ Team collaboration
+
+
+
+
+
+
+ {/* Agency Plan Test */}
+
+
+ Agency Plan Test
+ Test Paddle checkout with Agency plan
+ $299/mo
+
+
+
+ -
+ ✓
+ White-label solution
+
+ -
+ ✓
+ Custom domain
+
+ -
+ ✓
+ Priority support
+
+
+
+
+
+
+
+
+
+ 💡 These buttons currently show alerts. The actual Paddle checkout will be implemented once you have valid Paddle credentials.
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ );
+}
+
+// Simple sign-in page component
+export function SignInPage() {
+ return (
+
+
+
+
+ Welcome to ThinkTapFast
+
+
+ Sign in to test the Paddle checkout integration
+
+
+
+
+
+
+
+
+
+
+
Click above to sign in and test the billing dashboard
+
+
+
+
+ {current.toLocaleString()}
+
+ / {limit === 999999 ? '∞' : limit.toLocaleString()} {unit}
+
+
+
+ {limit !== 999999 && (
+
+
+ {percentage}% used
+
+ {getStatusText()}
+
+
+
+
+ )}
+
+ {/* Current Plan Overview */}
+
+
+
+
+
+ {currentPlan} Plan
+ {subscriptionStatus && (
+
+ {subscriptionStatus}
+
+ )}
+
+
+ {nextBillingDate && `Next billing: ${new Date(nextBillingDate).toLocaleDateString()}`}
+
+
+
+ {currentPlan !== 'CUSTOM' && (
+
+ {currentPlan === 'FREE' && (
+
+ Upgrade to Pro
+
+ )}
+ {(currentPlan === 'PRO' || currentPlan === 'FREE') && (
+
+ Upgrade to Business
+
+ )}
+
+ )}
+
+
Plan Features:
+
+ {limits.features.map((feature) => (
+ -
+ ✓
+ {feature}
+
+ ))}
+
+
+
+ {/* Usage Overview */}
+
+
+
+
+
+
+ {/* Subscription Management */}
+ {organization.paddleSubscriptionId && (
+
+
+ Subscription Management
+
+ Manage your subscription and billing preferences
+
+
+
+
+
+
Subscription ID:
+
{organization.paddleSubscriptionId}
+
+ {organization.paddleCustomerId && (
+
+
Customer ID:
+
{organization.paddleCustomerId}
+
+ )}
+
+
+
+
+
+
+
+ )}
+
+
+
+ {error && (
+
{error}
+ )}
+
+ {plans.map((planOption) => (
+
+
+
{planOption.name}
+
{planOption.price}
+
per month
+
+
+
+ {planOption.features.map((feature) => (
+ -
+ ✓
+ {feature}
+
+ ))}
+
+
+
+ {currentPlan === planOption.plan
+ ? 'Current Plan'
+ : `Upgrade to ${planOption.name}`
+ }
+
+
+ ))}
+