Update app/services/auth_service.py

app/services/auth_service.py

@@ -7,13 +7,12 @@ from passlib.context import CryptContext
 from ..models.auth import UserProfile, LoginResponse
 from ..core.config import settings
 from ..db.crud import get_user_by_email
-from ..db.database import get_db
-from sqlalchemy.ext.asyncio import AsyncSession
+from ..db.database import get_db, AsyncSession
 
 pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
-oauth2_scheme = OAuth2PasswordBearer(tokenUrl="api/auth/login")
+oauth2_scheme = OAuth2PasswordBearer(tokenUrl="api/v1/auth/login")
 
-async def authenticate_user(email: str, password: str, db: AsyncSession = Depends(get_db)) -> Optional[UserProfile]:
+async def authenticate_user(email: str, password: str, db: AsyncSession) -> Optional[UserProfile]:
     """Authenticate a user and return their profile if credentials are valid."""
     user = await get_user_by_email(db, email)
     if not user or not verify_password(password, user.hashed_password):
@@ -52,7 +51,7 @@ def create_refresh_token(data: dict) -> str:
     to_encode.update({"exp": expire, "refresh": True})
     return jwt.encode(to_encode, settings.SECRET_KEY, algorithm=settings.ALGORITHM)
 
-async def refresh_access_token(refresh_token: str) -> LoginResponse:
+async def refresh_access_token(refresh_token: str, db: AsyncSession) -> LoginResponse:
     """Create new access token using refresh token."""
     try:
         payload = jwt.decode(
@@ -71,7 +70,7 @@ async def refresh_access_token(refresh_token: str) -> LoginResponse:
                 status_code=status.HTTP_401_UNAUTHORIZED,
                 detail="Invalid refresh token"
             )
-        user = await get_user_by_email(email)
+        user = await get_user_by_email(db, email)
         if not user:
             raise HTTPException(
                 status_code=status.HTTP_401_UNAUTHORIZED,