Merge pull request #189 from Pseudo-Lab/feat/start-challenge

feat(getcloser): start challenge by assigning a question

Author: HanNayeoniee

getcloser/backend/app/api/v1/__init__.py

@@ -1,9 +1,9 @@
 from api.v1.users import users
+from api.v1.challenge import assign_challenge
 from api.v1.teams import teams
-from api.v1.challenges import challenges
 from fastapi import APIRouter
 
 api_router = APIRouter()
 api_router.include_router(users.router, prefix="/users", tags=["users"])
+api_router.include_router(assign_challenge.router, prefix="/challenge", tags=["challenge"])
 api_router.include_router(teams.router, prefix="/teams", tags=["teams"])
-api_router.include_router(challenges.router, prefix="/challenges", tags=["challenges"])

getcloser/backend/app/api/v1/challenge/assign_challenge.py

@@ -0,0 +1,29 @@
+from fastapi import APIRouter, HTTPException, Depends
+from sqlalchemy.orm import Session
+from schemas.challenge_schema import ChallengeRequest, ChallengeResponse
+from services.challenge_service import assign_challenges_logic
+from services.user_service import parse_user_id
+from core.database import get_db
+
+router = APIRouter()
+
+@router.post("/assign-challenges", response_model=ChallengeResponse)
+def assign_challenges(request: ChallengeRequest, db: Session = Depends(get_db)):
+    try:
+        # my_id = parse_user_id(request.my_id).get("id")
+        # if not my_id:
+        #     raise HTTPException(status_code=400, detail="올바른 형식의 유저 태그가 아닙니다. 예: 김민준#0001")
+        
+        # members_ids = [request.my_id]  # 팀원에 자기 자신 포함
+        # for tag in request.members_ids:
+        #     parsed = parse_user_id(tag)
+        #     if "error" in parsed:
+        #         raise HTTPException(status_code=400, detail=parsed["error"])
+        #     members_ids.append(parsed["id"])
+
+        members_ids = [request.my_id] + request.members_ids
+        assigned = assign_challenges_logic(request.my_id, members_ids, db)
+        return ChallengeResponse(team_id=request.team_id, my_assigned=assigned)
+    
+    except ValueError as e:
+        raise HTTPException(status_code=400, detail=str(e))

getcloser/backend/app/api/v1/users/users.py

@@ -1,6 +1,6 @@
 from core.database import get_db
 from fastapi import APIRouter, Depends
-from services.user_service import auth_user, get_user
+from services.user_service import auth_user, get_user, parse_user_id
 from sqlalchemy.orm import Session
 from schemas.user_schema import UserAuth, UserResponse
 
@@ -16,3 +16,12 @@ def auth(user_auth: UserAuth, db: Session = Depends(get_db)):
 def get_user_name(id: int, db: Session = Depends(get_db)):
   user = get_user(db, id)
   return {"data": f"{user.name}#{str(user.id).zfill(4)}"}
+
+
+@router.get("/user_id/{tag}")
+def get_user_id(tag: str):
+    """
+    '이름#0001' 형식의 문자열을 받아서 ID(int)로 변환합니다.
+    """
+    response = parse_user_id(tag)
+    return response

getcloser/backend/app/main.py

@@ -7,6 +7,9 @@
 from routers import test_db
 from api.v1 import api_router
 
+from scripts.users import seed_users_from_csv
+from scripts.challenge_question import seed_challenge_questions_from_csv
+
 
 # .env 파일 로드
 load_dotenv()
@@ -50,3 +53,10 @@ async def read_root():
 async def health_check():
     """헬스 체크 엔드포인트"""
     return {"status": "healthy"}
+
+# 서버 시작 시 실행
+@app.on_event("startup")
+def on_startup():
+    print("🚀 Server starting, seeding challenge questions...")
+    seed_users_from_csv("./scripts/user_data.csv")
+    seed_challenge_questions_from_csv("./scripts/challenge_question.csv")

getcloser/backend/app/models/challenge_question.py

@@ -0,0 +1,9 @@
+from core.database import Base
+from sqlalchemy import Column, Integer, String
+
+class ChallengeQuestion(Base):
+    __tablename__ = 'challenge_questions'
+    id = Column(Integer, primary_key=True, index=True)
+    user_id = Column(Integer)
+    category = Column(String)
+    answer = Column(String)

getcloser/backend/app/models/user_challenge.py

@@ -0,0 +1,14 @@
+from core.database import Base
+from sqlalchemy import Column, Integer, String, DateTime, Boolean, ForeignKey
+from sqlalchemy.orm import relationship
+
+class UserChallengeStatus(Base):
+    __tablename__ = "user_challenge_status"
+
+    id = Column(Integer, primary_key=True, index=True)
+    user_id = Column(Integer, ForeignKey("users.id"), nullable=False)
+    challenge_id = Column(Integer, ForeignKey("challenge_questions.id"), nullable=False)
+    is_correct = Column(Boolean, default=False)
+    submitted_at = Column(DateTime, nullable=True)
+    is_redeemed = Column(Boolean, default=False)
+    redeemed_at = Column(DateTime, nullable=True)

getcloser/backend/app/schemas/challenge_schema.py

@@ -1,4 +1,21 @@
 from pydantic import BaseModel
+from typing import List
+
+class ChallengeRequest(BaseModel):
+    team_id: int
+    my_id: int
+    members_ids: List[int]
+
+class AssignedChallenge(BaseModel):
+    user_id: int
+    assigned_challenge_id: int
+    from_user_id: int
+    category: str
+    answer: str
+
+class ChallengeResponse(BaseModel):
+    team_id: int
+    my_assigned: AssignedChallenge
 from datetime import datetime
 from typing import Optional
 

getcloser/backend/app/scripts/challenge_question.py

@@ -0,0 +1,37 @@
+import csv
+from sqlalchemy.orm import Session
+from core.database import SessionLocal, engine, Base
+from models.challenge_question import ChallengeQuestion
+
+def seed_challenge_questions_from_csv(file_path: str):
+    # 테이블 생성 (없으면)
+    Base.metadata.create_all(bind=engine)
+
+    db: Session = SessionLocal()
+    try:
+        with open(file_path, mode='r', encoding='utf-8') as csvfile:
+            reader = csv.DictReader(csvfile)
+            for row in reader:
+                challenge = ChallengeQuestion(
+                    id=int(row["challenge_id"]),
+                    user_id=int(row["user_id"]),
+                    category=row["category"],
+                    answer=row["answer"]
+                )
+                # 이미 같은 challenge_id가 있는지 확인
+                existing = db.query(ChallengeQuestion).filter_by(id=challenge.id).first()
+                if not existing:
+                    db.add(challenge)
+
+        db.commit()
+        print("✅ Challenge questions seeded successfully!")
+
+    except Exception as e:
+        print("❌ Error while seeding data:", e)
+
+    finally:
+        db.close()
+
+
+# if __name__ == "__main__":
+#     seed_challenge_questions_from_csv("./scripts/challenge_question.csv")

getcloser/backend/app/scripts/user_data.csv

@@ -0,0 +1,21 @@
+user_id,name,email
+1,김민준,minjun_kim@gmail.com
+2,이서연,seoyeon_lee@naver.com
+3,박도윤,doyoon2025@daum.net
+4,최지우,jiwoo_choi@gmail.com
+5,정하은,haeun_jeong@naver.com
+6,강시우,siwoo12@daum.net
+7,조서아,seoa_jo@gmail.com
+8,윤예준,yejun_yoon@naver.com
+9,장유나,yuna_jang@daum.net
+10,임지호,jiho_im10@gmail.com
+11,김하윤,hayoon_kim@naver.com
+12,이은우,eunwoo_lee33@daum.net
+13,박서준,seojun_park@gmail.com
+14,최아린,arin_choi@naver.com
+15,정수아,sua_jeong@daum.net
+16,강지안,jiankang@gmail.com
+17,조하준,hajun_jo2@naver.com
+18,윤다은,daeun_yoon@daum.net
+19,장선우,sunwoo_jang19@gmail.com
+20,임채원,chaewon_im@naver.com