Upload folder using huggingface_hub

lib/job_manager.py

@@ -3,7 +3,7 @@ Job status management for course_generation_jobs table
 Provides helpers to update job progress from HuggingFace Space backend
 """
 import logging
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import Optional, Dict, Any
 from db import get_supabase
 
@@ -39,7 +39,7 @@ async def update_job_progress(
         result = supabase.table("course_generation_jobs").update({
             "progress": progress,
             "progress_message": message,
-            "updated_at": datetime.utcnow().isoformat()
+            "updated_at": datetime.now(timezone.utc).isoformat()
         }).eq("id", job_id).execute()
 
         if result.data:
@@ -82,8 +82,8 @@ async def complete_job(
             "result": result,
             "progress": 100,
             "progress_message": "완료",
-            "completed_at": datetime.utcnow().isoformat(),
-            "updated_at": datetime.utcnow().isoformat()
+            "completed_at": datetime.now(timezone.utc).isoformat(),
+            "updated_at": datetime.now(timezone.utc).isoformat()
         }).eq("id", job_id).execute()
 
         if update_result.data:
@@ -125,8 +125,8 @@ async def fail_job(
             "status": "failed",
             "error": error,
             "progress_message": f"실패: {error}",
-            "completed_at": datetime.utcnow().isoformat(),
-            "updated_at": datetime.utcnow().isoformat()
+            "completed_at": datetime.now(timezone.utc).isoformat(),
+            "updated_at": datetime.now(timezone.utc).isoformat()
         }).eq("id", job_id).execute()
 
         if update_result.data:

routers/course.py

@@ -29,7 +29,7 @@ import json
 import logging
 import asyncio
 import time
-from datetime import datetime, timedelta
+from datetime import datetime, timedelta, timezone
 from typing import Optional, List, Dict, Any, AsyncGenerator
 
 from fastapi import APIRouter
@@ -206,7 +206,7 @@ async def generate_course(request: CourseGenerateRequest):
                 from db import get_supabase
                 supabase = get_supabase()
 
-                one_hour_ago = (datetime.utcnow() - timedelta(hours=1)).isoformat()
+                one_hour_ago = (datetime.now(timezone.utc) - timedelta(hours=1)).isoformat()
 
                 cached_result = supabase.table("courses") \
                     .select("*") \
@@ -1199,7 +1199,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
         if not spots_dict:
             return BatchStoryByIdsResponse(
                 stories=[],
-                generated_at=datetime.utcnow(),
+                generated_at=datetime.now(timezone.utc),
                 model=STORY_BATCH_MODEL,
                 success=False,
                 error={
@@ -1216,7 +1216,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
         if len(missing_ids) == len(request.spot_ids):
             return BatchStoryByIdsResponse(
                 stories=[],
-                generated_at=datetime.utcnow(),
+                generated_at=datetime.now(timezone.utc),
                 model=STORY_BATCH_MODEL,
                 success=False,
                 error={
@@ -1255,7 +1255,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
             )
             return BatchStoryByIdsResponse(
                 stories=[],
-                generated_at=datetime.utcnow(),
+                generated_at=datetime.now(timezone.utc),
                 model=STORY_BATCH_MODEL,
                 success=False,
                 error={
@@ -1277,7 +1277,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
             )
             return BatchStoryByIdsResponse(
                 stories=[],
-                generated_at=datetime.utcnow(),
+                generated_at=datetime.now(timezone.utc),
                 model=STORY_BATCH_MODEL,
                 success=False,
                 error={
@@ -1313,7 +1313,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
 
         response = BatchStoryByIdsResponse(
             stories=stories,
-            generated_at=datetime.utcnow(),
+            generated_at=datetime.now(timezone.utc),
             model=STORY_BATCH_MODEL,
             success=True
         )
@@ -1337,7 +1337,7 @@ async def generate_stories_batch_by_ids(request: BatchStoryByIdsRequest):
         end_token_session()
         return BatchStoryByIdsResponse(
             stories=[],
-            generated_at=datetime.utcnow(),
+            generated_at=datetime.now(timezone.utc),
             model=STORY_BATCH_MODEL,
             success=False,
             error={

routers/db_activity.py

@@ -6,7 +6,7 @@ from typing import Optional, List, Any, Dict
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import internal_server_error
@@ -76,7 +76,7 @@ async def log_activity(request: LogActivityRequest) -> LogActivityResponse:
                 "activity_type": request.activity_type,
                 "details": request.details,
                 "ip_address": request.ip_address,
-                "created_at": datetime.utcnow().isoformat()
+                "created_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 

routers/db_collection.py

@@ -10,7 +10,7 @@ from typing import Optional, List
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import internal_server_error
@@ -73,7 +73,7 @@ def _grant_collection_reward(supabase, user_id: str, amount: int, category_name:
             .upsert({
                 "user_id": user_id,
                 "balance": new_balance,
-                "updated_at": datetime.utcnow().isoformat()
+                "updated_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -364,8 +364,8 @@ async def update_collection_on_unlock(request: UpdateOnUnlockRequest):
                     "collected_count": new_count,
                     "collected_story_ids": collected_ids,
                     "is_completed": now_completed,
-                    "completed_at": datetime.utcnow().isoformat() if now_completed else None,
-                    "last_collected_at": datetime.utcnow().isoformat()
+                    "completed_at": datetime.now(timezone.utc).isoformat() if now_completed else None,
+                    "last_collected_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
 

routers/db_course.py

@@ -17,7 +17,7 @@ from math import radians, cos
 logger = logging.getLogger(__name__)
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import (
@@ -433,7 +433,7 @@ async def create_courses(request: CreateCourseRequest):
                     "main_image_url": course_input.main_image_url,
                     "is_ai_generated": True,
                     "generation_params": course_input.generation_params,
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }
 
                 result = supabase.table("courses") \
@@ -537,7 +537,7 @@ async def save_course(request: SaveCourseRequest):
                 "course_id": request.course_id,
                 "user_id": request.user_id,
                 "memo": request.memo,
-                "saved_at": datetime.utcnow().isoformat()
+                "saved_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -1361,7 +1361,7 @@ async def save_taste_profile(request: SaveTasteProfileRequest):
             .upsert({
                 "user_id": request.user_id,
                 "taste_profile": request.profile,
-                "updated_at": datetime.utcnow().isoformat()
+                "updated_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -1642,7 +1642,7 @@ async def get_course_batch(
         }
 
         metadata = {
-            "loaded_at": datetime.utcnow().isoformat(),
+            "loaded_at": datetime.now(timezone.utc).isoformat(),
             "user_id": user_id,
         }
 

routers/db_mwohaen.py

@@ -6,7 +6,7 @@ from typing import Optional, List
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import internal_server_error
@@ -320,7 +320,7 @@ async def update_stats_on_course_complete(request: UpdateStatsRequest):
     """코스 완료 시 통계 업데이트"""
     try:
         supabase = get_supabase()
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(timezone.utc).isoformat()
 
         # 현재 통계 조회
         stats_result = supabase.table("user_travel_stats") \
@@ -439,7 +439,7 @@ async def _check_and_grant_badges(user_id: str, stats: dict) -> List[BadgeDefini
                     .insert({
                         "user_id": user_id,
                         "badge_id": b["id"],
-                        "earned_at": datetime.utcnow().isoformat()
+                        "earned_at": datetime.now(timezone.utc).isoformat()
                     }) \
                     .execute()
 

routers/db_share.py

@@ -6,7 +6,7 @@ from typing import Optional, List, Dict, Any
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime, timedelta
+from datetime import datetime, timedelta, timezone
 import secrets
 import string
 
@@ -141,7 +141,7 @@ async def create_share_link(request: CreateShareRequest) -> CreateShareResponse:
             expires: datetime = datetime.fromisoformat(share["expires_at"].replace("Z", "+00:00"))
 
             # 아직 유효한 공유가 있으면 재사용
-            if expires > datetime.utcnow().replace(tzinfo=expires.tzinfo):
+            if expires > datetime.now(timezone.utc).replace(tzinfo=expires.tzinfo):
                 return CreateShareResponse(
                     share_code=share["share_code"],
                     share_url=f"https://aewol.app/join/{share['share_code']}",
@@ -150,7 +150,7 @@ async def create_share_link(request: CreateShareRequest) -> CreateShareResponse:
 
         # 새 공유 코드 생성
         share_code: str = generate_share_code()
-        expires_at: str = (datetime.utcnow() + timedelta(days=7)).isoformat()
+        expires_at: str = (datetime.now(timezone.utc) + timedelta(days=7)).isoformat()
 
         # DB에 저장
         result = supabase.table("course_shares") \
@@ -162,7 +162,7 @@ async def create_share_link(request: CreateShareRequest) -> CreateShareResponse:
                 "current_members": 1,  # 소유자 포함
                 "is_active": True,
                 "expires_at": expires_at,
-                "created_at": datetime.utcnow().isoformat()
+                "created_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -172,7 +172,7 @@ async def create_share_link(request: CreateShareRequest) -> CreateShareResponse:
                 "share_id": result.data[0]["id"],
                 "user_id": request.user_id,
                 "role": "owner",
-                "joined_at": datetime.utcnow().isoformat()
+                "joined_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -187,7 +187,7 @@ async def create_share_link(request: CreateShareRequest) -> CreateShareResponse:
                         "share_code": share_code,
                         "max_members": request.max_members
                     },
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
         except Exception:
@@ -223,7 +223,7 @@ async def get_share_info(share_code: str) -> ShareInfoResponse:
 
         # 만료 체크
         expires = datetime.fromisoformat(share["expires_at"].replace("Z", "+00:00"))
-        if expires < datetime.utcnow().replace(tzinfo=expires.tzinfo):
+        if expires < datetime.now(timezone.utc).replace(tzinfo=expires.tzinfo):
             return ShareInfoResponse(valid=False)
 
         course_info = share.get("courses", {}) or {}
@@ -265,7 +265,7 @@ async def join_shared_course(request: JoinShareRequest):
 
         # 만료 체크
         expires = datetime.fromisoformat(share["expires_at"].replace("Z", "+00:00"))
-        if expires < datetime.utcnow().replace(tzinfo=expires.tzinfo):
+        if expires < datetime.now(timezone.utc).replace(tzinfo=expires.tzinfo):
             return JoinShareResponse(success=False, error="expired")
 
         # 이미 참여했는지 확인
@@ -295,7 +295,7 @@ async def join_shared_course(request: JoinShareRequest):
                 "share_id": share["id"],
                 "user_id": request.user_id,
                 "role": "member",
-                "joined_at": datetime.utcnow().isoformat()
+                "joined_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -320,7 +320,7 @@ async def join_shared_course(request: JoinShareRequest):
                         "course_id": share["course_id"],
                         "share_code": request.share_code
                     },
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
         except Exception:
@@ -407,7 +407,7 @@ async def get_share_status(share_id: str):
 
         # 만료 체크
         expires = datetime.fromisoformat(share["expires_at"].replace("Z", "+00:00"))
-        is_expired = expires < datetime.utcnow().replace(tzinfo=expires.tzinfo)
+        is_expired = expires < datetime.now(timezone.utc).replace(tzinfo=expires.tzinfo)
 
         return ShareStatusResponse(
             id=share["id"],

routers/db_social.py

@@ -6,7 +6,7 @@ from typing import Optional, List
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import (
@@ -107,7 +107,7 @@ async def toggle_like(request: ToggleLikeRequest):
                 .insert({
                     "spot_id": request.spot_id,
                     "user_id": request.user_id,
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
             liked = True
@@ -129,7 +129,7 @@ async def toggle_like(request: ToggleLikeRequest):
                         "liked": liked,
                         "total_likes": count_result.count or 0
                     },
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
         except Exception:
@@ -197,7 +197,7 @@ async def create_review(request: CreateReviewRequest):
                 "spot_id": request.spot_id,
                 "user_id": request.user_id,
                 "content": request.content,
-                "created_at": datetime.utcnow().isoformat()
+                "created_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -263,7 +263,7 @@ async def report_review(request: ReportReviewRequest):
                 "review_id": request.review_id,
                 "reporter_id": request.user_id,
                 "reason": request.reason,
-                "created_at": datetime.utcnow().isoformat()
+                "created_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 

routers/db_stories.py

@@ -6,7 +6,7 @@ from typing import Optional, List
 import logging
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
-from datetime import datetime
+from datetime import datetime, timezone
 
 from db import get_supabase
 from utils.error_responses import (
@@ -211,7 +211,7 @@ async def unlock_course(request: UnlockCourseRequest):
                             "user_id": request.user_id,
                             "spot_id": spot_id,
                             "course_id": request.course_id,
-                            "unlocked_at": datetime.utcnow().isoformat()
+                            "unlocked_at": datetime.now(timezone.utc).isoformat()
                         }) \
                         .execute()
 
@@ -246,7 +246,7 @@ async def unlock_course(request: UnlockCourseRequest):
             .upsert({
                 "user_id": request.user_id,
                 "course_id": request.course_id,
-                "unlocked_at": datetime.utcnow().isoformat()
+                "unlocked_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -267,7 +267,7 @@ async def unlock_course(request: UnlockCourseRequest):
                         "spot_ids": unlocked_spots,
                         "unlocked_count": len(unlocked_spots)
                     },
-                    "created_at": datetime.utcnow().isoformat()
+                    "created_at": datetime.now(timezone.utc).isoformat()
                 }) \
                 .execute()
         except Exception:

routers/db_streak.py

@@ -17,7 +17,7 @@ Supabase 테이블:
 from typing import Optional, List
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel, Field, field_validator
-from datetime import datetime, date, timedelta
+from datetime import datetime, date, timedelta, timezone
 import logging
 
 from db import get_supabase
@@ -200,7 +200,7 @@ class ClaimChallengeRewardResponse(BaseModel):
 def _get_today_date_str() -> str:
     """오늘 날짜 문자열 (UTC 기준, KST 고려하려면 +9시간)"""
     # 한국 시간 기준으로 날짜 계산 (UTC+9)
-    now_kst = datetime.utcnow() + timedelta(hours=9)
+    now_kst = datetime.now(timezone.utc) + timedelta(hours=9)
     return now_kst.strftime("%Y-%m-%d")
 
 
@@ -268,7 +268,7 @@ def _grant_tokens_fallback(supabase, user_id: str, amount: int, reason: str) ->
             .upsert({
                 "user_id": user_id,
                 "balance": new_balance,
-                "updated_at": datetime.utcnow().isoformat()
+                "updated_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -307,7 +307,7 @@ async def streak_check_in(request: StreakCheckInRequest):
     """
     try:
         supabase = get_supabase()
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(timezone.utc).isoformat()
         today_str = _get_today_date_str()
         today = date.fromisoformat(today_str)
 
@@ -552,7 +552,7 @@ async def get_active_challenges():
     """
     try:
         supabase = get_supabase()
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(timezone.utc).isoformat()
 
         try:
             result = supabase.table("challenges") \
@@ -703,7 +703,7 @@ async def update_challenge_progress(request: UpdateChallengeProgressRequest):
     """
     try:
         supabase = get_supabase()
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(timezone.utc).isoformat()
         today_str = _get_today_date_str()
 
         # 해당 target_type의 활성 챌린지 조회
@@ -863,7 +863,7 @@ async def claim_challenge_reward(request: ClaimChallengeRewardRequest):
     """
     try:
         supabase = get_supabase()
-        now = datetime.utcnow().isoformat()
+        now = datetime.now(timezone.utc).isoformat()
 
         # 챌린지 정의 조회
         try:

routers/db_tokens.py

@@ -13,7 +13,7 @@ Token API endpoints
 from typing import Optional, List
 from fastapi import APIRouter, HTTPException, Query
 from pydantic import BaseModel, Field, field_validator
-from datetime import datetime
+from datetime import datetime, timezone
 import logging
 
 from db import get_supabase
@@ -366,7 +366,7 @@ async def add_tokens(request: AddTokensRequest):
             .upsert({
                 "user_id": request.user_id,
                 "balance": new_balance,
-                "updated_at": datetime.utcnow().isoformat()
+                "updated_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 
@@ -463,7 +463,7 @@ async def grant_bonus(request: GrantBonusRequest):
             .upsert({
                 "user_id": request.user_id,
                 "balance": new_balance,
-                "updated_at": datetime.utcnow().isoformat()
+                "updated_at": datetime.now(timezone.utc).isoformat()
             }) \
             .execute()
 

utils/logging_config.py

@@ -15,7 +15,7 @@ import logging.handlers
 import json
 import sys
 import os
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import Any, Dict, Optional
 from pathlib import Path
 
@@ -48,7 +48,7 @@ class JSONFormatter(logging.Formatter):
             JSON 문자열
         """
         log_data: Dict[str, Any] = {
-            "timestamp": datetime.utcnow().isoformat() + "Z",
+            "timestamp": datetime.now(timezone.utc).isoformat() + "Z",
             "level": record.levelname,
             "logger": record.name,
             "message": record.getMessage(),