refactor : FAST API Response 리펙토링

apps/pre-processing-service/app/api/endpoints/blog.py

@@ -7,6 +7,7 @@
 from ...service.blog.blogger_blog_post_adapter import (
     BloggerBlogPostAdapter,
 )  # 수정된 import
+from app.utils.response import Response
 
 router = APIRouter()
 
@@ -36,44 +37,45 @@ async def publish(request: RequestBlogPublish):
     """
     if request.tag == "naver":
         naver_service = NaverBlogPostService()
-        result = naver_service.post_content(
+        response_data = naver_service.post_content(
             title=request.post_title,
             content=request.post_content,
             tags=request.post_tags,
         )
 
-        if not result:
+        if not response_data:
             raise CustomException(
                 "네이버 블로그 포스팅에 실패했습니다.", status_code=500
             )
-        return ResponseBlogPublish(status="success", metadata=result)
+
+        return Response.ok(response_data)
 
     elif request.tag == "tistory":
         tistory_service = TistoryBlogPostService()
-        result = tistory_service.post_content(
+        response_data = tistory_service.post_content(
             title=request.post_title,
             content=request.post_content,
             tags=request.post_tags,
         )
 
-        if not result:
+        if not response_data:
             raise CustomException(
                 "티스토리 블로그 포스팅에 실패했습니다.", status_code=500
             )
 
-        return ResponseBlogPublish(status="success", metadata=result)
+        return Response.ok(response_data)
 
     elif request.tag == "blogger":
         blogger_service = BloggerBlogPostAdapter()  # 수정: Adapter 사용
-        result = blogger_service.post_content(
+        response_data = blogger_service.post_content(
             title=request.post_title,
             content=request.post_content,
             tags=request.post_tags,
         )
 
-        if not result:
+        if not response_data:
             raise CustomException(
                 "블로거 블로그 포스팅에 실패했습니다.", status_code=500
             )
 
-        return ResponseBlogPublish(status="success", metadata=result)
+        return Response.ok(response_data)

apps/pre-processing-service/app/api/endpoints/keywords.py

@@ -6,11 +6,6 @@
 router = APIRouter()
 
 
-@router.get("/")
-async def root():
-    return {"message": "keyword API"}
-
-
 @router.post(
     "/search", response_model=ResponseNaverSearch, summary="네이버 키워드 검색"
 )
@@ -28,15 +23,3 @@ async def search(request: RequestNaverSearch):
     """
     response_data = await keyword_search(request)
     return response_data
-
-
-@router.post(
-    "/ssadagu/validate",
-    response_model=ResponseNaverSearch,
-    summary="사다구몰 키워드 검증",
-)
-async def ssadagu_validate(request: RequestNaverSearch):
-    """
-    사다구몰 키워드 검증 테스트용 엔드포인트
-    """
-    return ResponseNaverSearch()

apps/pre-processing-service/app/api/endpoints/product.py

@@ -24,12 +24,12 @@ async def search(request: RequestSadaguSearch):
     """
     try:
         search_service = SearchService()
-        result = await search_service.search_products(request)
+        response_data = await search_service.search_products(request)
 
-        if not result:
+        if not response_data:
             raise CustomException(500, "상품 검색에 실패했습니다.", "SEARCH_FAILED")
 
-        return result
+        return response_data
     except InvalidItemDataException as e:
         raise HTTPException(status_code=e.status_code, detail=e.detail)
     except Exception as e:
@@ -43,12 +43,12 @@ async def match(request: RequestSadaguMatch):
     """
     try:
         match_service = MatchService()
-        result = match_service.match_products(request)
+        response_data = match_service.match_products(request)
 
-        if not result:
+        if not response_data:
             raise CustomException(500, "상품 매칭에 실패했습니다.", "MATCH_FAILED")
 
-        return result
+        return response_data
     except InvalidItemDataException as e:
         raise HTTPException(status_code=e.status_code, detail=e.detail)
     except Exception as e:
@@ -64,14 +64,14 @@ async def similarity(request: RequestSadaguSimilarity):
     """
     try:
         similarity_service = SimilarityService()
-        result = similarity_service.select_product_by_similarity(request)
+        response_data = similarity_service.select_product_by_similarity(request)
 
-        if not result:
+        if not response_data:
             raise CustomException(
                 500, "유사도 분석에 실패했습니다.", "SIMILARITY_FAILED"
             )
 
-        return result
+        return response_data
     except InvalidItemDataException as e:
         raise HTTPException(status_code=e.status_code, detail=e.detail)
     except Exception as e:
@@ -87,12 +87,12 @@ async def crawl(body: RequestSadaguCrawl):
     """
     try:
         crawl_service = CrawlService()
-        result = await crawl_service.crawl_product_detail(body)
+        response_data = await crawl_service.crawl_product_detail(body)
 
-        if not result:
+        if not response_data:
             raise CustomException(500, "상품 크롤링에 실패했습니다.", "CRAWL_FAILED")
 
-        return result
+        return response_data
     except InvalidItemDataException as e:
         raise HTTPException(status_code=e.status_code, detail=e.detail)
     except ItemNotFoundException as e: