feat: Add daily job digest with personalized AI summary

backend/app/api/routes/digest.py

@@ -0,0 +1,107 @@
+"""
+Daily job digest - personalized AI-summarized digest of new relevant jobs.
+"""
+import json
+import logging
+from datetime import datetime, timedelta, timezone
+
+import litellm
+from fastapi import APIRouter
+from sqlalchemy import and_, or_, select
+
+from app.api.deps import CurrentUser, DBSession
+from app.core.config import settings
+from app.models.job import Job, JobStatus
+from app.models.user import Profile
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter(prefix="/digest", tags=["digest"])
+
+
+@router.get("/today")
+async def get_daily_digest(db: DBSession, user: CurrentUser):
+    """
+    Generate a personalized daily digest of new relevant jobs.
+    Uses profile skills and preferences to filter and rank.
+    """
+    # Get profile
+    profile_result = await db.execute(select(Profile).where(Profile.user_id == user.id))
+    profile = profile_result.scalar_one_or_none()
+
+    # Get jobs from last 24 hours
+    since = datetime.now(timezone.utc) - timedelta(hours=24)
+
+    query = select(Job).where(
+        and_(Job.date_seen_first >= since, Job.status == JobStatus.ACTIVE)
+    ).order_by(Job.date_posted.desc().nullslast()).limit(50)
+
+    # If user has skills, prioritize matching jobs
+    if profile and profile.skills:
+        skill_names = []
+        for s in profile.skills:
+            if isinstance(s, dict):
+                skill_names.append(s.get("name", "").lower())
+            elif isinstance(s, str):
+                skill_names.append(s.lower())
+
+        if skill_names:
+            # Try to find jobs matching skills
+            skill_conditions = [Job.title.ilike(f"%{s}%") for s in skill_names[:5]]
+            query = select(Job).where(
+                and_(
+                    Job.date_seen_first >= since,
+                    Job.status == JobStatus.ACTIVE,
+                    or_(*skill_conditions) if skill_conditions else True,
+                )
+            ).order_by(Job.date_posted.desc().nullslast()).limit(30)
+
+    result = await db.execute(query)
+    jobs = result.scalars().all()
+
+    # Format jobs
+    digest_jobs = []
+    for job in jobs[:20]:
+        digest_jobs.append({
+            "id": str(job.id),
+            "title": job.title,
+            "company": job.company_name,
+            "location": job.locations[0]["raw"] if job.locations else None,
+            "remote": job.remote_type,
+            "salary_min": job.salary_min,
+            "salary_max": job.salary_max,
+            "posted": job.date_posted.isoformat() if job.date_posted else None,
+            "url": f"/jobs/{job.id}",
+        })
+
+    # Generate AI summary if we have enough jobs
+    ai_summary = None
+    if len(digest_jobs) >= 3 and (settings.OPENAI_API_KEY or settings.DEEPSEEK_API_KEY or settings.OLLAMA_BASE_URL):
+        try:
+            model = "ollama/llama3.2"
+            if settings.OPENAI_API_KEY:
+                model = "openai/gpt-4o-mini"
+            elif settings.DEEPSEEK_API_KEY:
+                model = "deepseek/deepseek-chat"
+
+            jobs_text = "\n".join([f"- {j['title']} at {j['company']}" for j in digest_jobs[:10]])
+            response = await litellm.acompletion(
+                model=model,
+                messages=[
+                    {"role": "system", "content": "You're a career advisor. Write a 2-3 sentence summary of today's job market activity based on new postings. Be encouraging and highlight interesting opportunities. Keep it under 60 words."},
+                    {"role": "user", "content": f"Today's new jobs ({len(digest_jobs)} total):\n{jobs_text}"},
+                ],
+                temperature=0.7,
+                max_tokens=100,
+            )
+            ai_summary = response.choices[0].message.content.strip()
+        except Exception as e:
+            logger.warning(f"Digest AI summary failed: {e}")
+
+    return {
+        "date": datetime.now(timezone.utc).strftime("%B %d, %Y"),
+        "total_new_jobs": len(digest_jobs),
+        "ai_summary": ai_summary,
+        "jobs": digest_jobs,
+        "personalized": bool(profile and profile.skills),
+    }