enhanced logging

app/code_reviewer.py

@@ -1,6 +1,9 @@
 import os
 import json
 import httpx
+import logging
+
+logger = logging.getLogger(__name__)
 
 DEEPSEEK_API_URL = "https://api.deepseek.com/v1/chat/completions"
 DEEPSEEK_API_KEY = os.getenv("DEEPSEEK_API_KEY")
@@ -10,6 +13,8 @@ async def analyze_code(file_name: str, patch: str) -> list:
     Analyze a single file diff using DeepSeek AI model.
     Returns a list of structured comments.
     """
+    logger.info(f"🤖 Sending to DeepSeek AI: {file_name} ({len(patch)} chars)")
+    
     prompt = f"""
     You are a senior code reviewer.
     Review the following diff from `{file_name}` and provide detailed, line-specific feedback.
@@ -37,21 +42,31 @@ async def analyze_code(file_name: str, patch: str) -> list:
         "messages": [{"role": "user", "content": prompt}]
     }
 
-    async with httpx.AsyncClient(timeout=60.0) as client:
-        response = await client.post(DEEPSEEK_API_URL, headers=headers, json=payload)
-        response.raise_for_status()
-        data = response.json()
+    try:
+        async with httpx.AsyncClient(timeout=60.0) as client:
+            logger.info("⏳ Waiting for DeepSeek response...")
+            response = await client.post(DEEPSEEK_API_URL, headers=headers, json=payload)
+            response.raise_for_status()
+            data = response.json()
+            logger.info("✅ DeepSeek response received")
 
-    text_output = data["choices"][0]["message"]["content"].strip()
+        text_output = data["choices"][0]["message"]["content"].strip()
+        logger.info(f"📄 Response length: {len(text_output)} chars")
 
-    # Defensive: handle non-JSON outputs
-    try:
-        # Remove markdown code blocks if present
-        if text_output.startswith("```json"):
-            text_output = text_output.replace("```json", "").replace("```", "").strip()
-        elif text_output.startswith("```"):
-            text_output = text_output.replace("```", "").strip()
-        
-        return json.loads(text_output)
+        # Defensive: handle non-JSON outputs
+        try:
+            # Remove markdown code blocks if present
+            if text_output.startswith("```json"):
+                text_output = text_output.replace("```json", "").replace("```", "").strip()
+            elif text_output.startswith("```"):
+                text_output = text_output.replace("```", "").strip()
+            
+            parsed = json.loads(text_output)
+            logger.info(f"✅ Parsed {len(parsed)} review comments")
+            return parsed
+        except Exception as e:
+            logger.warning(f"⚠️  Failed to parse JSON, returning raw text: {str(e)}")
+            return [{"line": 1, "severity": "info", "comment": text_output}]
     except Exception as e:
-        return [{"line": 1, "severity": "info", "comment": text_output}]
+        logger.error(f"❌ DeepSeek API error: {str(e)}")
+        raise

app/github_service.py

@@ -1,5 +1,8 @@
 import httpx
 import os
+import logging
+
+logger = logging.getLogger(__name__)
 
 GITHUB_TOKEN = os.getenv("GITHUB_TOKEN")
 HEADERS = {
@@ -26,8 +29,11 @@ async def post_review_summary(owner: str, repo: str, pr_number: int, review_comm
     Formats all AI feedback into a single markdown summary
     and posts it as a PR comment.
     """
+    logger.info(f"📝 Formatting review summary ({len(review_comments)} comments)...")
+    
     if not review_comments:
         summary_body = "✅ **No issue found by AI reviewer!**"
+        logger.info("✨ No issues found - posting clean review")
     else:
         summary_body = "### 🤖 AI Code Review Summary\n\n"
         summary_body += "The following findings were automatically generated by the AI reviewer:\n\n"
@@ -42,6 +48,10 @@ async def post_review_summary(owner: str, repo: str, pr_number: int, review_comm
             summary_body += f"{emoji} **{severity}** — `{file}` (L{line}): {comment}\n"
 
         summary_body += "\n---\n_This review was auto-generated by **PRism AI Reviewer**._ 🤖"
+        logger.info(f"📋 Summary length: {len(summary_body)} characters")
 
     # Post the formatted comment
-    return await post_pr_comment(owner, repo, pr_number, summary_body)
+    logger.info(f"🚀 Posting comment to PR #{pr_number}...")
+    result = await post_pr_comment(owner, repo, pr_number, summary_body)
+    logger.info(f"✅ Comment posted successfully (ID: {result.get('id', 'unknown')})")
+    return result

app/github_webhook.py

@@ -6,7 +6,9 @@ import asyncio
 import hmac
 import hashlib
 import os
+import logging
 
+logger = logging.getLogger(__name__)
 router = APIRouter()
 
 def verify_signature(payload_body: bytes, signature_header: str) -> bool:
@@ -21,13 +23,24 @@ def verify_signature(payload_body: bytes, signature_header: str) -> bool:
 
 @router.post("/webhook/github")
 async def github_webhook(payload: PullRequestPayload, request: Request):
+    logger.info("=" * 60)
+    logger.info("🔔 WEBHOOK RECEIVED")
+    logger.info("=" * 60)
+    
     # Verify webhook signature
     signature = request.headers.get("X-Hub-Signature-256", "")
     body = await request.body()
+    
+    logger.info(f"📝 Action: {payload.action}")
+    
     if not verify_signature(body, signature):
+        logger.error("❌ Invalid webhook signature!")
         raise HTTPException(status_code=403, detail="Invalid signature")
     
+    logger.info("✅ Signature verified")
+    
     if payload.action not in ["opened", "synchronize"]:
+        logger.info(f"⏭️  Ignoring action: {payload.action}")
         return {"message": "Ignored non-PR-open events."}
 
     repo_info = payload.repository
@@ -35,16 +48,32 @@ async def github_webhook(payload: PullRequestPayload, request: Request):
     owner = repo_info["owner"]["login"]
     repo = repo_info["name"]
     pr_number = pr["number"]
+    
+    logger.info(f"📦 Repository: {owner}/{repo}")
+    logger.info(f"🔢 PR Number: #{pr_number}")
+    logger.info(f"👤 Author: {pr['user']['login']}")
+    logger.info(f"📋 Title: {pr['title']}")
 
     # Fetch changed files
+    logger.info("📥 Fetching changed files from GitHub...")
     files = await fetch_pr_files(owner, repo, pr_number)
+    logger.info(f"✅ Found {len(files)} changed files")
 
     review_comments = []
+    files_analyzed = 0
 
-    for f in files:
+    for idx, f in enumerate(files, 1):
         if not f.get("patch"):
+            logger.info(f"⏭️  Skipping {f['filename']} (no patch)")
             continue
+        
+        files_analyzed += 1
+        logger.info(f"🔍 [{idx}/{len(files)}] Analyzing: {f['filename']}")
+        logger.info(f"   Status: {f.get('status', 'unknown')}, Changes: {f.get('changes', 0)} lines")
+        
         ai_feedback = await analyze_code(f["filename"], f["patch"])
+        logger.info(f"   ✅ AI returned {len(ai_feedback)} comments")
+        
         for c in ai_feedback:
             review_comments.append({
                 "file": f["filename"],
@@ -53,9 +82,17 @@ async def github_webhook(payload: PullRequestPayload, request: Request):
                 "comment": c.get("comment", "")
             })
 
+    logger.info(f"📊 Analysis complete: {files_analyzed} files analyzed, {len(review_comments)} total comments")
+
     # Format feedback as PR comment
     from .github_service import post_review_summary
 
+    logger.info("📤 Posting review summary to GitHub PR...")
     await post_review_summary(owner, repo, pr_number, review_comments)
+    logger.info("✅ Review posted successfully!")
+    
+    logger.info("=" * 60)
+    logger.info("🎉 WEBHOOK PROCESSING COMPLETE")
+    logger.info("=" * 60)
     
     return {"status": "AI review posted", "count": len(review_comments)}

app/main.py

@@ -3,16 +3,33 @@ from .github_webhook import router as github_router
 from dotenv import load_dotenv
 import logging
 import json
+import os
 
 load_dotenv()  # call this if you want dotenv to load env vars
 
-logging.basicConfig(level=logging.INFO)
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(levelname)s:     %(message)s'
+)
 logger = logging.getLogger(__name__)
 
 app = FastAPI(title="AI Code Review System")
 
 app.include_router(github_router)
 
+@app.on_event("startup")
+async def startup_event():
+    logger.info("=" * 60)
+    logger.info("🚀 PRism AI Code Reviewer Starting...")
+    logger.info("=" * 60)
+    logger.info(f"✅ GITHUB_TOKEN: {'Set' if os.getenv('GITHUB_TOKEN') else '❌ MISSING'}")
+    logger.info(f"✅ DEEPSEEK_API_KEY: {'Set' if os.getenv('DEEPSEEK_API_KEY') else '❌ MISSING'}")
+    logger.info(f"✅ GITHUB_WEBHOOK_SECRET: {'Set' if os.getenv('GITHUB_WEBHOOK_SECRET') else '⚠️  Not set (signature verification disabled)'}")
+    logger.info("=" * 60)
+    logger.info("📡 Webhook endpoint: POST /webhook/github")
+    logger.info("🏥 Health check: GET /")
+    logger.info("=" * 60)
+
 @app.get("/")
 def root():
     return {"message": "AI Code Review System is running 🚀"}