feat: 점수 저장을 위한 game 도메인 생성, 점수 업데이트 로직 구현

Author: jungminseo7812

src/configs/database.py

@@ -1,9 +1,12 @@
 import psycopg2
-from psycopg2.extras import RealDictCursor
+from psycopg2.extras import RealDictCursor, register_uuid
 
 from src.configs import setting
 from src.utils.logger import logger
 
+# UUID
+register_uuid()
+
 
 def get_db_connection():
     """

src/domains/game/__init__.py

@@ -0,0 +1,13 @@
+from datetime import datetime
+from uuid import UUID
+from pydantic import BaseModel, Field
+
+
+class GameResponse(BaseModel):
+    game_id: UUID = Field(..., description="게임 고유 ID")
+    user_id: UUID = Field(..., description="사용자 ID")
+    game_type: str = Field(..., description="게임 유형 (discoverex, magic-eye 등)")
+    created_at: datetime = Field(..., description="생성 일시")
+
+    class Config:
+        from_attributes = True

src/domains/game/dtos/__init__.py

@@ -0,0 +1,44 @@
+from typing import Optional
+from uuid import UUID
+
+from src.domains.game.dtos.game_dto import GameResponse
+from src.utils.load_sql import load_sql
+
+
+class GameService:
+    """
+    게임 정보를 조회하고 관리하는 서비스 클래스입니다.
+    """
+
+    def __init__(self, cursor):
+        self.cursor = cursor
+
+    def get_game_by_id(self, game_id: UUID) -> Optional[GameResponse]:
+        """
+        주어진 game_id에 해당하는 게임 정보를 조회합니다.
+        """
+        query = load_sql("domains/game", "get_game_by_id")
+        self.cursor.execute(query, (game_id,))
+        result = self.cursor.fetchone()
+        if result:
+            return GameResponse(**result)
+        return None
+
+    def create_game(self, game_id: UUID, game_type: str, user_id: UUID) -> GameResponse:
+        """
+        새로운 게임을 생성합니다.
+        """
+        query = load_sql("domains/game", "create_game")
+        self.cursor.execute(query, (game_id, user_id, game_type))
+        result = self.cursor.fetchone()
+        return GameResponse(**result)
+
+    def get_or_create_game(self, game_id: UUID, game_type: str, user_id: UUID) -> GameResponse:
+        """
+        게임이 존재하면 조회하고, 없으면 새로 생성합니다.
+        """
+        game = self.get_game_by_id(game_id)
+        if game:
+            return game
+
+        return self.create_game(game_id=game_id, game_type=game_type, user_id=user_id)

src/domains/game/dtos/game_dto.py

@@ -0,0 +1,3 @@
+INSERT INTO game (game_id, user_id, game_type)
+VALUES (%s, %s, %s)
+RETURNING game_id, user_id, game_type, created_at;

src/domains/game/game_service.py

@@ -0,0 +1,7 @@
+SELECT
+    game_id,
+    game_type
+FROM
+    game
+WHERE
+    game_id = %s;

src/domains/game/queries/__init__.py

@@ -8,6 +8,7 @@
 from src.common.dtos.wrapped_response import WrappedResponse
 from src.configs.database import get_db_cursor
 from src.domains.auth.auth_service import AuthService
+from src.domains.game.game_service import GameService # GameService 임포트
 from src.domains.score.dtos.score_dto import ScoreCreateRequest, ScoreResponse
 from src.domains.auth.utils.verify_token import verify_user
 
@@ -19,6 +20,9 @@ def get_score_service(cursor=Depends(get_db_cursor)) -> ScoreService:
 def get_auth_service(cursor=Depends(get_db_cursor)) -> AuthService:
     return AuthService(cursor)
 
+def get_game_service(cursor=Depends(get_db_cursor)) -> GameService: # GameService 의존성 제공자 추가
+    return GameService(cursor)
+
 @score_router.post(
     "/",
     status_code=status.HTTP_201_CREATED,
@@ -30,7 +34,8 @@ async def post_score(
     request: ScoreCreateRequest,
     user_info: dict = Depends(verify_user),
     score_service: ScoreService = Depends(get_score_service),
-    auth_service: AuthService = Depends(get_auth_service)
+    auth_service: AuthService = Depends(get_auth_service),
+    game_service: GameService = Depends(get_game_service) # GameService 주입
 ):
     # 1. 토큰에서 추출한 이메일로 DB 상의 사용자 정보를 확인
     email = user_info.get("email")
@@ -40,7 +45,11 @@ async def post_score(
     user_data = auth_service.handle_login_or_register(email=email, name=name)
 
     # 3. 점수 기록
-    result = score_service.register_score(user_id=user_data.user_id, request=request)
+    result = score_service.register_score(
+        user_id=user_data.user_id,
+        request=request,
+        game_service=game_service # game_service 전달
+    )
 
     return WrappedResponse(
         data=result,

src/domains/game/queries/create_game.sql

@@ -2,6 +2,7 @@
 from typing import List, Optional
 from uuid import UUID
 
+from src.domains.game.game_service import GameService
 from src.domains.score.dtos.score_dto import ScoreCreateRequest, ScoreResponse
 from src.utils.load_sql import load_sql
 
@@ -14,10 +15,17 @@ class ScoreService:
     def __init__(self, cursor):
         self.cursor = cursor
 
-    def register_score(self, user_id: UUID, request: ScoreCreateRequest) -> ScoreResponse:
+    def register_score(self, user_id: UUID, request: ScoreCreateRequest, game_service: GameService) -> ScoreResponse:
         """
         사용자의 게임 점수를 DB에 등록합니다.
         """
+        # 1. game_id 조회 또는 생성
+        game_service.get_or_create_game(
+            game_id=request.game_id,
+            game_type=request.game_type,
+            user_id=user_id
+        )
+
         query = load_sql("domains/score", "insert_score")
         self.cursor.execute(
             query,
@@ -27,10 +35,10 @@ def register_score(self, user_id: UUID, request: ScoreCreateRequest) -> ScoreRes
         return ScoreResponse(**result)
 
     def get_user_scores(
-        self, 
-        user_id: Optional[UUID] = None, 
+        self,
+        user_id: Optional[UUID] = None,
         game_type: Optional[str] = None,
-        start_date: Optional[datetime] = None, 
+        start_date: Optional[datetime] = None,
         end_date: Optional[datetime] = None
     ) -> List[ScoreResponse]:
         """
@@ -46,5 +54,5 @@ def get_user_scores(
         )
         self.cursor.execute(query, params)
         results = self.cursor.fetchall()
-        
+
         return [ScoreResponse(**row) for row in results]