Function create_checkout_session_max

api/payments.py:380–426

Creates a Stripe Checkout session for the currently authenticated user to purchase the Max plan. The user's Auth0 ID is passed to Stripe for identification in webhooks.

(current_user: AuthUser, body: CheckoutRequest = None)

    summary="Create Stripe Checkout Session for Max Subscription"
)
async def create_checkout_session_max(current_user: AuthUser, body: CheckoutRequest = None):
    """
    Creates a Stripe Checkout session for the currently authenticated user to
    purchase the Max plan. The user's Auth0 ID is passed to Stripe for
    identification in webhooks.
    """
    base_url = get_base_url(body.return_base_url if body else None)

    has_sub, existing_id, provider, active_customer_id = _get_subscription_from_metadata(current_user)
    if has_sub:
        if provider == "apple":
            raise HTTPException(
                status_code=400,
                detail="You have an active Apple subscription. Please cancel it in iOS Settings before purchasing via Stripe."
            )
        elif provider == "stripe" and active_customer_id:
            portal = stripe.billing_portal.Session.create(
                customer=active_customer_id,
                return_url=f"{base_url}/refresh",
            )
            return {"url": portal.url, "redirect": "portal"}

    if not MAX_PRICE_ID:
        logger.error("MAX_PRICE_ID not configured but Max checkout was requested.")
        raise HTTPException(status_code=503, detail="Max tier is not currently available.")

    try:
        # Get or create Stripe customer with Auth0 email to prevent Link email mismatch
        customer_id = get_or_create_stripe_customer(current_user)

        checkout_params = {
            "line_items": [{"price": MAX_PRICE_ID, "quantity": 1}],
            "mode": "subscription",
            "client_reference_id": current_user.id,
            "success_url": f"{base_url}/upgrade-success",
            "cancel_url": base_url,
            "allow_promotion_codes": True,
        }

        if customer_id:
            checkout_params["customer"] = customer_id

        checkout_session = stripe.checkout.Session.create(**checkout_params)
        return {"url": checkout_session.url}
    except Exception as e:
        logger.error(f"Stripe Checkout creation failed for Max tier for user {current_user.id}: {e}")
        raise HTTPException(status_code=500, detail="Could not create payment session.")


@payments_router.post(