Update core/security.py

core/security.py

@@ -5,6 +5,9 @@ from fastapi import Depends, HTTPException, status
 from fastapi.security import OAuth2PasswordBearer
 from core.config import SECRET_KEY, ALGORITHM, ACCESS_TOKEN_EXPIRE_MINUTES
 from db.mongo import users_collection
+import logging
+
+logger = logging.getLogger(__name__)
 
 # OAuth2 setup
 oauth2_scheme = OAuth2PasswordBearer(tokenUrl="/auth/login")
@@ -29,22 +32,24 @@ def create_access_token(data: dict, expires_delta: timedelta = None):
 
 # Get the current user from the JWT token
 async def get_current_user(token: str = Depends(oauth2_scheme)):
-    print("🔐 Raw token received:", token)
+    logger.info(f"🔐 Raw token received: {token}")
     try:
         payload = jwt.decode(token, SECRET_KEY, algorithms=[ALGORITHM])
         email: str = payload.get("sub")
         if email is None:
+            logger.error("Invalid token: subject missing")
             raise HTTPException(status_code=401, detail="Invalid token: subject missing")
     except JWTError as e:
-        print("❌ JWTError while decoding token:", str(e))
+        logger.error(f"❌ JWTError while decoding token: {str(e)}")
         raise HTTPException(status_code=401, detail="Could not validate token")
     
     try:
         user = await users_collection.find_one({"email": email})
         if not user:
+            logger.error(f"User not found: {email}")
             raise HTTPException(status_code=404, detail="User not found")
-        print("✅ Authenticated user:", user["email"])
+        logger.info(f"✅ Authenticated user: {user['email']}")
         return user
     except Exception as e:
-        print("❌ MongoDB error:", str(e))
+        logger.error(f"❌ MongoDB error: {str(e)}")
         raise HTTPException(status_code=500, detail="Database error")