Added the Stripe(Payment Gateway) now the Users need to pay to view any course and if He is owner/CourseCreator then he has free Access!

Author: suraj-9849

.env.example

@@ -5,4 +5,7 @@ GROQ_API_KEY = ""
 AWS_ACCESS_KEY_ID=""
 AWS_SECRET_ACCESS_KEY=""
 BUCKET_NAME= ""
-ENDPOINT ="https://...com"
+ENDPOINT ="https://...com"
+STRIPE_SECRET_KEY = ""
+NEXT_PUBLIC_STRIPE_KEY=""
+NEXT_PUBLIC_BASE_URL = "http://localhost:3000"

package-lock.json

@@ -27,6 +27,7 @@
     "@radix-ui/react-slot": "^1.1.1",
     "@radix-ui/react-tabs": "^1.1.2",
     "@radix-ui/react-tooltip": "^1.1.5",
+    "@stripe/stripe-js": "^5.4.0",
     "@tabler/icons-react": "^3.26.0",
     "@types/bcryptjs": "^2.4.6",
     "axios": "^1.7.9",
@@ -44,6 +45,7 @@
     "react-dom": "^18.0.0",
     "react-dropzone": "^14.3.5",
     "react-hot-toast": "^2.4.1",
+    "stripe": "^17.5.0",
     "tailwind-merge": "^2.5.5",
     "tailwindcss-animate": "^1.0.7",
     "zod": "^3.24.1"

package.json

@@ -0,0 +1,41 @@
+import prisma from '@/lib/prisma';
+import { NextRequest, NextResponse } from 'next/server';
+
+export async function GET(req: NextRequest) {
+  const userId = req.headers.get('X-User-Id');
+  const courseId = req.headers.get('X-Course-Id');
+
+  if (!userId || !courseId) {
+    return NextResponse.json({ error: 'Missing required headers' }, { status: 400 });
+  }
+
+  try {
+    const course = await prisma.course.findUnique({
+      where: { course_id: parseInt(courseId) },
+      include: { creator: true }
+    });
+
+    if (!course) {
+      return NextResponse.json({ error: 'Course not found' }, { status: 404 });
+    }
+
+    if (course.creator_id === userId) {
+      return NextResponse.json({ isCreator: true, hasPurchased: false });
+    }
+
+    const purchase = await prisma.coursePurchase.findFirst({
+      where: {
+        user_id: userId,
+        course_id: parseInt(courseId),
+        payment_status: true
+      }
+    });
+
+    return NextResponse.json({ 
+      isCreator: false, 
+      hasPurchased: Boolean(purchase) 
+    });
+  } catch (error) {
+    return NextResponse.json({ error: 'Server error' }, { status: 500 });
+  }
+}

src/app/api/check-course-access/route.ts

@@ -0,0 +1,33 @@
+import { NextRequest, NextResponse } from 'next/server';
+import Stripe from 'stripe';
+
+const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);
+
+export async function POST(req: NextRequest) {
+  try {
+    const { courseId, userId, price, title } = await req.json();
+
+    const session = await stripe.checkout.sessions.create({
+      payment_method_types: ['card'],
+      line_items: [
+        {
+          price_data: {
+            currency: 'usd',
+            product_data: {
+              name: title,
+            },
+            unit_amount: Math.round(price * 100),
+          },
+          quantity: 1,
+        },
+      ],
+      mode: 'payment',
+      success_url: `${process.env.NEXT_PUBLIC_BASE_URL}/api/payment/success?session_id={CHECKOUT_SESSION_ID}&courseId=${courseId}&userId=${userId}`,
+      cancel_url: `${process.env.NEXT_PUBLIC_BASE_URL}/dashboard`,
+    });
+
+    return NextResponse.json({ sessionId: session.id });
+  } catch (error) {
+    return NextResponse.json({ error: 'Error creating checkout session' }, { status: 500 });
+  }
+}