Update core/security.py

core/security.py

@@ -32,24 +32,26 @@ 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)):
-    logger.info(f"🔐 Raw token received: {token}")
+    print("🔐 Token received:", token)
+
+    if not token:
+        print("❌ No token received")
+        raise HTTPException(status_code=401, detail="No token provided")
+
     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")
+        print("🧠 Token payload:", payload)
+
+        email = payload.get("sub")
+        if not email:
+            raise HTTPException(status_code=401, detail="Invalid token: missing subject")
     except JWTError as e:
-        logger.error(f"❌ JWTError while decoding token: {str(e)}")
+        print("❌ JWT decode error:", 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")
-        logger.info(f"✅ Authenticated user: {user['email']}")
-        return user
-    except Exception as e:
-        logger.error(f"❌ MongoDB error: {str(e)}")
-        raise HTTPException(status_code=500, detail="Database error")
+
+    user = await users_collection.find_one({"email": email})
+    if not user:
+        raise HTTPException(status_code=404, detail="User not found")
+
+    print("✅ Authenticated user:", user["email"])
+    return user