How to Connect Firebase to Stripe for Payments

1# Install via Firebase CLI
2firebase ext:install stripe/firestore-stripe-payments --project=your-project-id
3
4# The CLI prompts for:
5# - Stripe API key (from Stripe Dashboard > Developers > API keys)
6# - Stripe webhook signing secret
7# - Firestore collection names (default: customers, products, subscriptions)
8# - Cloud Functions location

1// Stripe webhook URL format (from Firebase Console > Functions):
2// https://us-central1-your-project.cloudfunctions.net/ext-firestore-stripe-payments-handleWebhookEvents
3
4// Events to subscribe to in Stripe Dashboard:
5// - checkout.session.completed
6// - customer.subscription.created
7// - customer.subscription.updated
8// - customer.subscription.deleted
9// - invoice.payment_succeeded
10// - invoice.payment_failed

1import { db } from "@/lib/firebase";
2import { auth } from "@/lib/firebase";
3import {
4  collection, addDoc, onSnapshot
5} from "firebase/firestore";
6
7async function createCheckoutSession(priceId: string) {
8  const user = auth.currentUser;
9  if (!user) throw new Error("Must be logged in");
10
11  // Create a checkout session document
12  const checkoutRef = await addDoc(
13    collection(db, "customers", user.uid, "checkout_sessions"),
14    {
15      price: priceId,           // Stripe Price ID from your products
16      success_url: window.location.origin + "/success",
17      cancel_url: window.location.origin + "/pricing",
18    }
19  );
20
21  // Listen for the Stripe session URL
22  onSnapshot(checkoutRef, (snap) => {
23    const data = snap.data();
24    if (data?.url) {
25      window.location.assign(data.url); // Redirect to Stripe Checkout
26    }
27    if (data?.error) {
28      console.error("Checkout error:", data.error.message);
29    }
30  });
31}

1import { onRequest } from "firebase-functions/v2/https";
2import { defineSecret } from "firebase-functions/params";
3import { getFirestore } from "firebase-admin/firestore";
4import * as admin from "firebase-admin";
5import Stripe from "stripe";
6
7admin.initializeApp();
8const db = getFirestore();
9
10const stripeSecretKey = defineSecret("STRIPE_SECRET_KEY");
11const webhookSecret = defineSecret("STRIPE_WEBHOOK_SECRET");
12
13export const stripeWebhook = onRequest(
14  {
15    secrets: [stripeSecretKey, webhookSecret],
16    cors: false, // Stripe does not use CORS
17  },
18  async (req, res) => {
19    const stripe = new Stripe(stripeSecretKey.value());
20
21    // Verify webhook signature
22    let event: Stripe.Event;
23    try {
24      event = stripe.webhooks.constructEvent(
25        req.rawBody,
26        req.headers["stripe-signature"] as string,
27        webhookSecret.value()
28      );
29    } catch (err) {
30      res.status(400).send(`Webhook signature verification failed`);
31      return;
32    }
33
34    // Handle events
35    switch (event.type) {
36      case "checkout.session.completed": {
37        const session = event.data.object as Stripe.Checkout.Session;
38        await db.doc(`orders/${session.id}`).set({
39          customerId: session.customer,
40          status: "paid",
41          amount: session.amount_total,
42          createdAt: admin.firestore.FieldValue.serverTimestamp(),
43        });
44        break;
45      }
46      case "customer.subscription.updated": {
47        const sub = event.data.object as Stripe.Subscription;
48        await db.doc(`subscriptions/${sub.id}`).update({
49          status: sub.status,
50          currentPeriodEnd: new Date(sub.current_period_end * 1000),
51        });
52        break;
53      }
54    }
55
56    res.json({ received: true });
57  }
58);

1import { db, auth } from "@/lib/firebase";
2import {
3  collection, query, where, getDocs
4} from "firebase/firestore";
5
6async function checkSubscriptionStatus(): Promise<boolean> {
7  const user = auth.currentUser;
8  if (!user) return false;
9
10  // With Stripe Extension:
11  const subsRef = collection(
12    db, "customers", user.uid, "subscriptions"
13  );
14  const q = query(
15    subsRef,
16    where("status", "in", ["active", "trialing"])
17  );
18
19  const snapshot = await getDocs(q);
20  return !snapshot.empty;
21}
22
23// Usage:
24const isPremium = await checkSubscriptionStatus();
25if (isPremium) {
26  // Show premium features
27} else {
28  // Show upgrade prompt
29}