Billing & Subscriptions

# .env
STRIPE_SECRET_KEY=sk_test_...
STRIPE_WEBHOOK_SECRET=whsec_...
NEXT_PUBLIC_STRIPE_PUBLISHABLE_KEY=pk_test_...

import { createCheckoutSession } from '@/lib/stripe'
 
const session = await createCheckoutSession({
  organizationId: org.id,
  priceId: 'price_...',
  successUrl: '/dashboard/billing/success',
  cancelUrl: '/dashboard/billing',
})
 
// Redirect to checkout
window.location.href = session.url

# apps/api/app/routers/billing.py
@router.post("/webhooks/stripe")
async def stripe_webhook(request: Request):
    event = stripe.Webhook.construct_event(
        await request.body(),
        request.headers.get("stripe-signature"),
        settings.STRIPE_WEBHOOK_SECRET
    )
 
    if event.type == "customer.subscription.created":
        await handle_subscription_created(event.data.object)
    elif event.type == "customer.subscription.updated":
        await handle_subscription_updated(event.data.object)
    elif event.type == "invoice.payment_succeeded":
        await handle_payment_succeeded(event.data.object)
 
    return {"status": "success"}

const { url } = await createPortalSession({
  organizationId: org.id,
  returnUrl: '/dashboard/billing',
})
 
window.location.href = url

from app.services.billing import BillingService
 
await BillingService.record_usage(
    organization_id=org_id,
    metric="api_calls",
    quantity=1
)