Update app.py

app.py

@@ -1,21 +1,24 @@
 import os
 import requests
 import uvicorn
+import logging
 from fastapi import FastAPI, Request, Header, HTTPException
 from typing import Optional
 
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
 app = FastAPI()
 
 TEAMS_WEBHOOK_URL = os.getenv("TEAMS_WEBHOOK_URL")
 WEBHOOK_SECRET = os.getenv("WEBHOOK_SECRET")
-HF_TOKEN = os.getenv("HF_TOKEN")  # private 레포면 필요
+HF_TOKEN = os.getenv("HF_TOKEN")
 
 @app.get("/")
 def root():
     return {"status": "running"}
 
 def get_commit_info(repo_type, repo_name, head_sha):
-    """HF API로 커밋 메시지와 변경 파일 목록 조회"""
     type_map = {"model": "models", "dataset": "datasets", "space": "spaces"}
     api_type = type_map.get(repo_type, "models")
 
@@ -23,36 +26,63 @@ def get_commit_info(repo_type, repo_name, head_sha):
     if HF_TOKEN:
         headers["Authorization"] = f"Bearer {HF_TOKEN}"
 
-    # 최근 커밋 목록 조회
-    commits_url = f"https://huggingface.co/api/{api_type}/{repo_name}/commits/main"
-    resp = requests.get(commits_url, headers=headers)
-
     commit_title = head_sha[:8]
     commit_author = "unknown"
-    if resp.ok:
-        for commit in resp.json():
-            if commit.get("id", "").startswith(head_sha[:8]):
-                commit_title = commit.get("title", head_sha[:8])
-                commit_author = commit.get("authors", [{}])[0].get("user", "unknown") if commit.get("authors") else "unknown"
-                break
-
-    # 변경 파일 목록 조회
-    diff_url = f"https://huggingface.co/api/{api_type}/{repo_name}/diff/{head_sha}"
-    diff_resp = requests.get(diff_url, headers=headers)
-
     changed_files = []
-    if diff_resp.ok:
-        for item in diff_resp.json():
-            status = item.get("status", "")
-            path = item.get("path", item.get("rfilename", ""))
-            if status == "added":
-                changed_files.append(f"🆕 {path}")
-            elif status == "modified":
-                changed_files.append(f"✏️ {path}")
-            elif status == "removed":
-                changed_files.append(f"🗑️ {path}")
-            else:
-                changed_files.append(f"📄 {path}")
+
+    # 1) 커밋 목록에서 커밋 메시지, 작성자 조회
+    try:
+        commits_url = f"https://huggingface.co/api/{api_type}/{repo_name}/commits/main"
+        logger.info(f"Fetching commits: {commits_url}")
+        resp = requests.get(commits_url, headers=headers, timeout=10)
+        logger.info(f"Commits API status: {resp.status_code}")
+        if resp.ok:
+            for commit in resp.json():
+                if commit.get("id", "").startswith(head_sha[:8]):
+                    commit_title = commit.get("title", head_sha[:8])
+                    authors = commit.get("authors", [])
+                    if authors:
+                        commit_author = authors[0].get("user", "unknown")
+                    break
+    except Exception as e:
+        logger.error(f"Commits API error: {e}")
+
+    # 2) 커밋 상세 (변경 파일) - 여러 엔드포인트 시도
+    endpoints_to_try = [
+        f"https://huggingface.co/api/{api_type}/{repo_name}/commit/{head_sha}",
+        f"https://huggingface.co/api/{api_type}/{repo_name}/diff/{head_sha}",
+        f"https://huggingface.co/{repo_name}/resolve/{head_sha}/.commit_info",
+    ]
+
+    for url in endpoints_to_try:
+        try:
+            logger.info(f"Trying: {url}")
+            resp = requests.get(url, headers=headers, timeout=10)
+            logger.info(f"  Status: {resp.status_code}")
+            logger.info(f"  Body (first 500): {resp.text[:500]}")
+            if resp.ok:
+                data = resp.json() if resp.headers.get("content-type", "").startswith("application/json") else {}
+                # dict 형태인 경우
+                if isinstance(data, dict):
+                    for f in data.get("files", []):
+                        path = f.get("filename", f.get("path", f.get("rfilename", "")))
+                        status = f.get("status", "changed")
+                        changed_files.append(f"{status}: {path}")
+                    if not changed_files and "siblings" in data:
+                        for f in data["siblings"]:
+                            changed_files.append(f.get("rfilename", ""))
+                # list 형태인 경우
+                elif isinstance(data, list):
+                    for item in data:
+                        if isinstance(item, dict):
+                            path = item.get("path", item.get("filename", item.get("rfilename", "")))
+                            status = item.get("status", "")
+                            changed_files.append(f"{'🆕 ' if status == 'added' else '✏️ ' if status == 'modified' else '🗑️ ' if status == 'removed' else '📄 '}{path}")
+                if changed_files:
+                    logger.info(f"  Found {len(changed_files)} files!")
+                    break
+        except Exception as e:
+            logger.error(f"  Error: {e}")
 
     return commit_title, commit_author, changed_files
 
@@ -66,6 +96,13 @@ async def handle_webhook(
             raise HTTPException(status_code=403, detail="Invalid secret")
 
     payload = await request.json()
+
+    # 전체 payload 로깅 (디버깅용)
+    logger.info(f"=== WEBHOOK RECEIVED ===")
+    logger.info(f"Full payload keys: {list(payload.keys())}")
+    logger.info(f"Event: {payload.get('event')}")
+    logger.info(f"Repo: {payload.get('repo')}")
+
     event = payload.get("event", {})
     repo = payload.get("repo", {})
 
@@ -74,16 +111,14 @@ async def handle_webhook(
         repo_type = repo.get("type", "model")
         head_sha = repo.get("headSha", "")
 
-        # HF API로 상세 정보 조회
         commit_title, commit_author, changed_files = get_commit_info(repo_type, repo_name, head_sha)
 
-        # 파일 목록 텍스트 생성
         if changed_files:
-            files_text = "\n".join(changed_files[:15])  # 최대 15개
+            files_text = "\n".join(changed_files[:15])
             if len(changed_files) > 15:
                 files_text += f"\n...외 {len(changed_files) - 15}개 파일"
         else:
-            files_text = "(파일 목록을 가져올 수 없습니다)"
+            files_text = "(변경 파일 조회 실패 - Space 로그를 확인하세요)"
 
         card = {
             "type": "message",
@@ -98,9 +133,7 @@ async def handle_webhook(
                         {
                             "type": "TextBlock",
                             "text": f"📦 {repo_name}",
-                            "wrap": True,
-                            "weight": "Bolder",
-                            "size": "Large"
+                            "wrap": True, "weight": "Bolder", "size": "Large"
                         },
                         {
                             "type": "FactSet",
@@ -113,22 +146,19 @@ async def handle_webhook(
                         {
                             "type": "TextBlock",
                             "text": "**변경된 파일:**",
-                            "wrap": True,
-                            "spacing": "Medium"
+                            "wrap": True, "spacing": "Medium"
                         },
                         {
                             "type": "TextBlock",
                             "text": files_text,
-                            "wrap": True,
-                            "fontType": "Monospace",
-                            "size": "Small"
+                            "wrap": True, "fontType": "Monospace", "size": "Small"
                         },
                         {
                             "type": "ActionSet",
                             "actions": [{
                                 "type": "Action.OpenUrl",
-                                "title": "레포 바로가기",
-                                "url": f"https://huggingface.co/{repo_name}"
+                                "title": "커밋 보기",
+                                "url": f"https://huggingface.co/{repo_name}/commit/{head_sha}"
                             }]
                         }
                     ]