stripe supa table integration PR

Author: starmorph

package.json

@@ -27,11 +27,14 @@
     "@radix-ui/react-dropdown-menu": "^2.1.15",
     "@radix-ui/react-label": "^2.1.2",
     "@radix-ui/react-navigation-menu": "^1.2.13",
+    "@radix-ui/react-progress": "^1.1.7",
     "@radix-ui/react-select": "^2.2.5",
     "@radix-ui/react-separator": "^1.1.2",
     "@radix-ui/react-slot": "^1.2.2",
     "@radix-ui/react-switch": "^1.2.4",
     "@radix-ui/react-tooltip": "^1.1.8",
+    "@stripe/react-stripe-js": "^3.7.0",
+    "@stripe/stripe-js": "^7.3.0",
     "@supabase/ssr": "^0.6.1",
     "@supabase/supabase-js": "^2.49.8",
     "class-variance-authority": "^0.7.1",
@@ -55,6 +58,7 @@
     "remark-gfm": "^4.0.1",
     "remark-math": "^6.0.0",
     "sonner": "^2.0.1",
+    "stripe": "^18.1.1",
     "tailwind-merge": "^3.0.2",
     "tailwindcss-animate": "^1.0.7",
     "use-stick-to-bottom": "^1.0.46",

pnpm-lock.yaml

@@ -5,6 +5,6 @@ import { initApiPassthrough } from "langgraph-nextjs-api-passthrough";
 
 export const { GET, POST, PUT, PATCH, DELETE, OPTIONS, runtime } =
   initApiPassthrough({
-    apiUrl: process.env.LANGGRAPH_API_URL, // default, if not defined it will attempt to read process.env.LANGGRAPH_API_URL
+    apiUrl: process.env.LANGGRAPH_API_URL, 
     runtime: "edge", // default
   });

src/app/api/[..._path]/route.ts

@@ -0,0 +1,108 @@
+import { NextResponse } from "next/server"
+import Stripe from "stripe"
+import { supabaseServer } from "@/lib/auth/supabase-server"
+
+type SessionCreateParams = Stripe.Checkout.SessionCreateParams
+
+// Initialize Stripe
+const stripe = new Stripe(process.env.STRIPE_SECRET_KEY || "")
+
+export async function POST(request: Request) {
+  try {
+    const { priceId, userId, customerEmail } = await request.json()
+
+    console.log("Checkout session request:", { priceId, userId, customerEmail })
+
+    if (!priceId || !userId || !customerEmail) {
+      console.error("Missing required parameters:", { priceId, userId, customerEmail })
+      return NextResponse.json({ error: "Missing required parameters" }, { status: 400 })
+    }
+
+    // Verify Stripe is initialized
+    if (!process.env.STRIPE_SECRET_KEY) {
+      console.error("STRIPE_SECRET_KEY is not set")
+      return NextResponse.json({ error: "Stripe not configured" }, { status: 500 })
+    }
+
+    // Get or create Stripe customer
+    let customerId: string
+
+    // Check if user already has a Stripe customer ID
+    const { data: userData, error: userError } = await supabaseServer
+      .from("users")
+      .select("stripe_customer_id, email")
+      .eq("id", userId)
+      .single()
+
+    if (userError && userError.code !== "PGRST116") {
+      console.error("Error fetching user:", userError)
+      return NextResponse.json({ error: "Failed to fetch user data" }, { status: 500 })
+    }
+
+    if (userData?.stripe_customer_id) {
+      customerId = userData.stripe_customer_id as string
+      console.log("Using existing Stripe customer:", customerId)
+    } else {
+      // Create a new customer
+      console.log("Creating new Stripe customer for:", customerEmail)
+      const customer = await stripe.customers.create({
+        email: customerEmail,
+        metadata: {
+          userId,
+        },
+      })
+
+      customerId = customer.id
+      console.log("Created new Stripe customer:", customerId)
+
+      // Create or update user record in Supabase
+      const { error: updateError } = await supabaseServer.from("users").upsert({
+        id: userId,
+        email: customerEmail,
+        stripe_customer_id: customerId,
+        credits_available: 0,
+        subscription_status: "inactive",
+      }, {
+        onConflict: "id"
+      })
+
+      if (updateError) {
+        console.error("Error creating/updating user record:", updateError)
+        // Don't fail the checkout, but log the error
+      }
+    }
+
+    // Create a checkout session
+    const baseUrl = process.env.NEXT_PUBLIC_BASE_URL || "http://localhost:3000"
+    
+    const sessionParams: SessionCreateParams = {
+      customer: customerId,
+      payment_method_types: ["card"],
+      line_items: [
+        {
+          price: priceId,
+          quantity: 1,
+        },
+      ],
+      mode: "subscription",
+      success_url: `${baseUrl}/success?session_id={CHECKOUT_SESSION_ID}`,
+      cancel_url: `${baseUrl}/pricing`,
+      metadata: {
+        userId,
+      },
+      subscription_data: {
+        metadata: {
+          userId,
+        },
+      },
+    }
+
+    const session = await stripe.checkout.sessions.create(sessionParams)
+
+    return NextResponse.json({ sessionId: session.id })
+  } catch (error) {
+    console.error("Error creating checkout session:", error)
+    return NextResponse.json({ error: "Failed to create checkout session" }, { status: 500 })
+  }
+}
+

src/app/api/create-checkout-session/route.ts

@@ -0,0 +1,65 @@
+import { NextResponse } from "next/server"
+import { supabaseServer } from "@/lib/auth/supabase-server"
+
+export async function GET(request: Request) {
+  try {
+    const { searchParams } = new URL(request.url)
+    const userId = searchParams.get("userId")
+
+    if (!userId) {
+      return NextResponse.json({ error: "Missing userId parameter" }, { status: 400 })
+    }
+
+    console.log("Fetching credits for user:", userId)
+
+    // Get user's credit information from Supabase
+    const { data: userData, error } = await supabaseServer
+      .from("users")
+      .select("credits_available, subscription_status, price_id")
+      .eq("id", userId)
+      .single()
+
+    if (error) {
+      console.error("Error fetching user credits:", error)
+      
+      // If user doesn't exist, create a basic record
+      if (error.code === "PGRST116") {
+        console.log("User not found in database, creating basic record...")
+        
+        const { data: newUser, error: createError } = await supabaseServer
+          .from("users")
+          .insert({
+            id: userId,
+            credits_available: 0,
+            subscription_status: "inactive"
+          })
+          .select("credits_available, subscription_status, price_id")
+          .single()
+
+        if (createError) {
+          console.error("Error creating user record:", createError)
+          return NextResponse.json({ error: "Failed to create user record" }, { status: 500 })
+        }
+
+        return NextResponse.json({
+          credits: newUser.credits_available || 0,
+          subscriptionStatus: newUser.subscription_status,
+          priceId: newUser.price_id
+        })
+      }
+
+      return NextResponse.json({ error: "Failed to fetch credits" }, { status: 500 })
+    }
+
+    return NextResponse.json({
+      credits: userData.credits_available || 0,
+      subscriptionStatus: userData.subscription_status,
+      priceId: userData.price_id
+    })
+
+  } catch (error) {
+    console.error("Credits API error:", error)
+    return NextResponse.json({ error: "Internal server error" }, { status: 500 })
+  }
+}
+