Function api_current_user

main.py:1370–1414

Get current user information

(request: Request, db: Session = Depends(get_db))

@app.get("/api/current-user")
async def api_current_user(request: Request, db: Session = Depends(get_db)):
    """Get current user information"""
    if USE_POSTGRES:
        try:
            user = get_current_user(request, db)
            if not user:
                raise HTTPException(status_code=401, detail="Not authenticated")

            # Return basic user info immediately, skip Stripe validation to prevent blocking
            # Stripe validation can be done asynchronously in the background if needed
            user_dict = user.to_dict()

            # Only check subscription status if user has a Stripe ID
            if user.stripe_id:
                try:
                    # Add timeout to prevent blocking
                    subscription_item_id = await asyncio.wait_for(
                        get_subscription_item_id_for_user_email_async(user.email), timeout=3.0
                    )
                    user_dict["is_subscribed"] = subscription_item_id is not None
                except asyncio.TimeoutError:
                    logger.warning(f"Subscription check timed out for user {user.email}")
                    user_dict["is_subscribed"] = False
                except Exception as e:
                    logger.error(f"Error checking subscription for user {user.email}: {e}")
                    user_dict["is_subscribed"] = False
            else:
                user_dict["is_subscribed"] = False

            # Set default values for optional fields
            user_dict["num_self_hosted_instances"] = 0

            return JSONResponse(user_dict)
        except HTTPException:
            raise
        except Exception as e:
            logger.error(f"Error in current-user endpoint: {e}")
            raise HTTPException(status_code=401, detail="Not authenticated")
    else:
        # Fallback to simple session checking
        session_secret = request.cookies.get("session_secret")
        if session_secret and session_secret in active_sessions:
            return JSONResponse(active_sessions[session_secret])
        else:
            raise HTTPException(status_code=401, detail="Not authenticated")


@app.get("/api/subscription-status")