refactor: code cleanup

Author: ddoed

app/handlers/auth_handler.py

@@ -14,29 +14,33 @@
 )
 oauth2_scheme = OAuth2PasswordBearer(tokenUrl="/users/token")
 
-# 현재 로그인한 사용자를 가져오는 의존성 함수
+# 현재 로그인한 사용자를 가져오기
 async def get_current_user(token: str = Depends(oauth2_scheme), db: Session = Depends(get_db_session)):
     jwt_util = JWTUtil()
     payload = jwt_util.decode_token(token)
+    
     if payload is None:
         raise HTTPException(
             status_code=404,
             detail="Could not validate credentials",
             headers={"WWW-Authenticate": "Bearer"},
         )
-    user_id: int = payload.get("id")  # 수정: "id"를 추출
+    
+    user_id: int = payload.get("id")
     if user_id is None:
         raise HTTPException(
             status_code=404,
             detail="Could not validate credentials",
             headers={"WWW-Authenticate": "Bearer"},
         )
-    user = db.get(User, user_id)  # 수정: user_id (id)를 사용하여 조회
+    
+    user = db.get(User, user_id)  
     if user is None:
         raise HTTPException(status_code=404, detail="User not found")
+    
     return user
 
-
+# 토큰 발급
 @router.post("/token")
 def login_for_access_token(
     form_data: OAuth2PasswordRequestForm = Depends(),
@@ -66,15 +70,15 @@ def login_for_access_token(
     return {
         "access_token": access_token,
         "token_type": "bearer",
-        **payload  # 사용자 정보 포함
+        **payload
     }
 
 #회원가입
 @router.post("/signup")
 async def auth_signup(req:AuthSignupReq,
-                      db=Depends(get_db_session),
-                      jwtUtil:JWTUtil=Depends(),
-                      authService:AuthService=Depends()):
+                    db=Depends(get_db_session),
+                    jwtUtil:JWTUtil=Depends(),
+                    authService:AuthService=Depends()):
     user = authService.signup(db, req.login_id, req.pwd, req.name, req.email)
 
     if not user:
@@ -89,14 +93,14 @@ async def auth_signup(req:AuthSignupReq,
         "created_at": user.created_at
     }
 
-    # 🔹 토큰 생성
+    # 토큰 생성
     token = jwtUtil.create_token(payload)
 
-    # 🔹 DB에 반영되도록 저장
+    # DB에 반영되도록 저장
     user.access_token = token  
-    db.add(user)  # 변경된 객체 추가
-    db.commit()   # DB에 반영
-    db.refresh(user)  # DB에서 최신 상태 불러오기 (flush 역할)
+    db.add(user)
+    db.commit()
+    db.refresh(user)
 
     return {
         "id": user.id,
@@ -105,7 +109,7 @@ async def auth_signup(req:AuthSignupReq,
         "username": user.username,
         "role": user.role,
         "created_at": user.created_at,
-        "access_token": user.access_token  # ✅ DB에도 반영됨!
+        "access_token": user.access_token
     }
 
 # 로그인
@@ -120,142 +124,3 @@ def auth_signin(req:AuthLoginReq,
     user.access_token = jwtUtil.create_token(user.model_dump())
     return user
 
-
-## 내 판매 내역 조회
-
-@router.get("/selling", status_code=200)
-def check_my_selling_list(
-    db: Session = Depends(get_db_session),
-    current_user: User = Depends(get_current_user),
-):
-    """
-    현재 로그인한 사용자의 판매 내역 조회
-    """
-    selling_list = db.exec(select(Product).where(Product.user_id == current_user.id)).all()
-    return {"my_selling_list": selling_list}
-# 내 구매 내역 조회
-@router.get("/{user_id}/bought")
-def get_user_bought(user_id: int, db: Session = Depends(get_db_session)):
-    # 사용자 ID에 해당하는 구매 내역을 가져옵니다.
-    purchases = db.exec(select(Purchase).where(Purchase.user_id == user_id)).all()
-
-    # 각 구매 내역에 대해 상품을 찾아서 반환합니다.
-    # 만약 값이 없으면 빈 리스트를 출력
-    results = [db.get(Product, purchase.product_id) for purchase in purchases]
-
-    return results
-
-# 내 좋아요 내역 조회
-@router.get("/{user_id}/likes")
-def get_user_likes(user_id: int, db: Session = Depends(get_db_session)):
-    # 사용자 ID에 해당하는 좋아요 내역을 가져옵니다.
-    like_products = db.exec(select(Likes).where(Likes.user_id == user_id)).all()
-
-    # 각 좋아요 내역에 대해 상품을 찾아서 반환합니다.
-    # 만약 값이 없으면 빈 리스트를 출력
-    results = [db.get(Product, like_product.product_id) for like_product in like_products]
-
-    return results
-
-
-# 내 프로필 조회
-@router.get("/{user_id}")
-def check_profile(user_id: int, db=Depends(get_db_session)):
-    if not user_id:
-        raise HTTPException(status_code=404, detail="Not Found")
-    user = db.exec(select(User).filter(User.id == user_id)).first()
-    if not user:
-        raise HTTPException(status_code=404, detail="User not found")
-    
-    return {
-        "id": user.id,
-        "login_id": user.login_id,
-        "email": user.email,
-        "username": user.username,
-        "role": user.role,
-        "created_at": user.created_at
-    }
-
-#프로필 수정
-@router.put("/profile")
-def update_profile(
-    update_data: ProfileUpdateRequest,
-    current_user: User = Depends(get_current_user),
-    db: Session = Depends(get_db_session),
-    auth_service: AuthService = Depends(),
-    jwt_util: JWTUtil = Depends()
-):
-    # 현재 비밀번호 확인 (비밀번호 변경 시)
-    if update_data.password:
-        if not auth_service.verify_pwd(update_data.current_password, current_user.password):
-            raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Current password is incorrect")
-        current_user.password = auth_service.get_hashed_pwd(update_data.password)
-    
-    # 이메일 중복 확인
-    if update_data.email and update_data.email != current_user.email:
-        existing_user = db.exec(select(User).where(User.email == update_data.email)).first()
-        if existing_user:
-            raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Email already in use")
-    
-    # 로그인 ID 중복 확인
-    if update_data.login_id and update_data.login_id != current_user.login_id:
-        existing_user = db.exec(select(User).where(User.login_id == update_data.login_id)).first()
-        if existing_user:
-            raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Login ID already in use")
-    
-    # 사용자 정보 업데이트
-    if update_data.username and update_data.username != current_user.username:
-        current_user.username = update_data.username
-    if update_data.email and update_data.email != current_user.email:
-        current_user.email = update_data.email
-    if update_data.login_id and update_data.login_id != current_user.login_id:
-        current_user.login_id = update_data.login_id
-    
-    try:
-        db.add(current_user)
-        db.commit()
-        db.refresh(current_user)
-    except Exception as e:
-        db.rollback()
-        raise HTTPException(status_code=500, detail="An error occurred while updating the profile")
-    
-    # 새로운 토큰 생성 (필요한 경우)
-    payload = {
-        "id": current_user.id,
-        "login_id": current_user.login_id,
-        "email": current_user.email,
-        "username": current_user.username,
-        "role": current_user.role,
-        "created_at": str(current_user.created_at)  # datetime -> string 변환 필요
-    }
-    new_access_token = jwt_util.create_token(payload)
-
-    # 업데이트된 사용자 정보와 새 토큰 반환
-    return {
-        "id": current_user.id,
-        "login_id": current_user.login_id,
-        "email": current_user.email,
-        "username": current_user.username,
-        "role": current_user.role,
-        "created_at": str(current_user.created_at),
-        "access_token": new_access_token  # 새 토큰 포함
-    }
-
-
-# 회원 탈퇴
-@router.delete("/profile")
-def delete_profile(
-    current_user: User = Depends(get_current_user),
-    db: Session = Depends(get_db_session)
-):
-    # 사용자 확인
-    user = db.get(User, current_user.id)
-    if not user:
-        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="User not found")
-
-    # 데이터베이스에서 사용자 삭제
-    db.delete(user)
-    db.commit()
-
-    return {"message": "Profile deleted successfully"}
-

app/handlers/category_handler.py

@@ -11,20 +11,18 @@
 class CategoryRequest(BaseModel):
     name: str
 
-# ✅ 전체 카테고리 목록 조회
+# 전체 카테고리 목록 조회
 @router.get("/", status_code=200)
 def get_categories(db: Session = Depends(get_db_session)) -> List[Category]:
-    """전체 카테고리 목록 가져오기"""
     categories = db.exec(select(Category)).all()
     return categories
 
-# ✅ 새로운 카테고리 추가 API
+# 새로운 카테고리 추가
 @router.post("/", status_code=201)
 def create_category(
     categoryRequest: CategoryRequest = Body(...),
     db: Session = Depends(get_db_session)
 ) -> Category:
-    """새로운 카테고리 추가"""
 
     # 이미 존재하는 카테고리인지 확인
     existing_category = db.exec(select(Category).where(Category.name == categoryRequest.name)).first()

app/handlers/comment_handlers.py

@@ -34,9 +34,6 @@ def create_comment(
     new_comment = comment_service.create_comment(session, product_id, current_user.id, content)
     return RespComments(comments=[new_comment])
 
-# ✅ Pydantic 모델 정의
-class CommentUpdate(BaseModel):
-    content: str
 
 # 댓글 수정 (인증 필요)
 @router.put("/{comment_id}", status_code=200)