Sync from GitHub

app/commentary.py

@@ -0,0 +1,175 @@
+"""
+AI Commentary Generator using OpenRouter API.
+Generates human-readable market analysis from FinBERT + XGBoost results.
+"""
+
+import httpx
+import logging
+from typing import Optional
+from datetime import datetime
+
+from .settings import get_settings
+
+logger = logging.getLogger(__name__)
+
+
+async def generate_commentary(
+    current_price: float,
+    predicted_price: float,
+    predicted_return: float,
+    sentiment_index: float,
+    sentiment_label: str,
+    top_influencers: list[dict],
+    news_count: int = 0,
+) -> Optional[str]:
+    """
+    Generate AI commentary using OpenRouter API.
+    
+    Args:
+        current_price: Current copper price
+        predicted_price: Model's predicted price for tomorrow
+        predicted_return: Expected return percentage
+        sentiment_index: Current sentiment score (-1 to 1)
+        sentiment_label: Bullish/Bearish/Neutral
+        top_influencers: List of top feature influencers
+        news_count: Number of news articles analyzed
+        
+    Returns:
+        AI-generated commentary or None if failed
+    """
+    settings = get_settings()
+    
+    if not settings.openrouter_api_key:
+        logger.warning("OpenRouter API key not configured, skipping commentary")
+        return None
+    
+    # Build the prompt
+    influencers_text = "\n".join([
+        f"  - {inf.get('feature', 'Unknown')}: {inf.get('importance', 0)*100:.1f}%"
+        for inf in top_influencers[:5]
+    ])
+    
+    change_direction = "artış" if predicted_return > 0 else "düşüş"
+    change_emoji = "📈" if predicted_return > 0 else "📉"
+    
+    prompt = f"""Sen bir finans analisti asistanısın. Aşağıdaki bakır (copper) piyasası verilerini analiz et ve yatırımcılar için kısa, anlaşılır bir Türkçe yorum yaz.
+
+## Güncel Veriler:
+- **Güncel Fiyat:** ${current_price:.4f}
+- **Yarınki Tahmin:** ${predicted_price:.4f} ({change_emoji} %{abs(predicted_return*100):.2f} {change_direction})
+- **Piyasa Duyarlılığı:** {sentiment_label} (Skor: {sentiment_index:.3f})
+- **Analiz Edilen Haber Sayısı:** {news_count}
+
+## En Etkili Faktörler (XGBoost Model):
+{influencers_text}
+
+## Talimatlar:
+1. 3-4 paragraf yaz (toplam 150-200 kelime)
+2. Teknik terimler kullanma, sade ve anlaşılır ol
+3. İlk paragrafta genel durumu özetle
+4. İkinci paragrafta önemli faktörleri açıkla
+5. Son paragrafta kısa vadeli görünümü belirt
+6. 🎯 emoji ile önemli noktaları vurgula
+7. Bu finansal tavsiye DEĞİLDİR uyarısını ekle
+
+Yorumunu yaz:"""
+
+    try:
+        async with httpx.AsyncClient(timeout=30.0) as client:
+            response = await client.post(
+                "https://openrouter.ai/api/v1/chat/completions",
+                headers={
+                    "Authorization": f"Bearer {settings.openrouter_api_key}",
+                    "Content-Type": "application/json",
+                    "HTTP-Referer": "https://copper-mind.vercel.app",
+                    "X-Title": "CopperMind AI Analysis",
+                },
+                json={
+                    "model": settings.openrouter_model,
+                    "messages": [
+                        {
+                            "role": "system",
+                            "content": "Sen uzman bir emtia piyasası analistsin. Bakır fiyatları hakkında kısa ve öz Türkçe yorumlar yapıyorsun."
+                        },
+                        {
+                            "role": "user", 
+                            "content": prompt
+                        }
+                    ],
+                    "max_tokens": 500,
+                    "temperature": 0.7,
+                }
+            )
+            
+            if response.status_code == 200:
+                data = response.json()
+                commentary = data.get("choices", [{}])[0].get("message", {}).get("content", "")
+                if commentary:
+                    logger.info(f"AI commentary generated successfully ({len(commentary)} chars)")
+                    return commentary.strip()
+                else:
+                    logger.warning("Empty response from OpenRouter")
+                    return None
+            else:
+                logger.error(f"OpenRouter API error: {response.status_code} - {response.text}")
+                return None
+                
+    except Exception as e:
+        logger.error(f"Failed to generate AI commentary: {e}")
+        return None
+
+
+# Cache for commentary (simple in-memory)
+_commentary_cache: dict = {
+    "commentary": None,
+    "generated_at": None,
+    "expires_at": None,
+}
+
+
+async def get_cached_commentary(
+    current_price: float,
+    predicted_price: float,
+    predicted_return: float,
+    sentiment_index: float,
+    sentiment_label: str,
+    top_influencers: list[dict],
+    news_count: int = 0,
+    ttl_minutes: int = 60,
+) -> Optional[str]:
+    """
+    Get cached commentary or generate new one if expired.
+    """
+    global _commentary_cache
+    
+    now = datetime.now()
+    
+    # Check if cache is valid
+    if (
+        _commentary_cache["commentary"] 
+        and _commentary_cache["expires_at"] 
+        and now < _commentary_cache["expires_at"]
+    ):
+        logger.debug("Returning cached AI commentary")
+        return _commentary_cache["commentary"]
+    
+    # Generate new commentary
+    commentary = await generate_commentary(
+        current_price=current_price,
+        predicted_price=predicted_price,
+        predicted_return=predicted_return,
+        sentiment_index=sentiment_index,
+        sentiment_label=sentiment_label,
+        top_influencers=top_influencers,
+        news_count=news_count,
+    )
+    
+    if commentary:
+        from datetime import timedelta
+        _commentary_cache = {
+            "commentary": commentary,
+            "generated_at": now,
+            "expires_at": now + timedelta(minutes=ttl_minutes),
+        }
+    
+    return commentary

app/main.py

@@ -312,6 +312,75 @@ async def health_check():
     )
 
 
+# =============================================================================
+# AI Commentary Endpoint
+# =============================================================================
+
+@app.get(
+    "/api/commentary",
+    summary="AI-generated market commentary",
+    description="Returns an AI-generated analysis of the current copper market situation using FinBERT + XGBoost results."
+)
+async def get_commentary(
+    symbol: str = Query(default="HG=F", description="Symbol to analyze")
+):
+    """
+    Generate AI commentary for the current market situation.
+    
+    Uses OpenRouter API with a free LLM to create human-readable
+    analysis from FinBERT sentiment and XGBoost predictions.
+    """
+    from app.commentary import get_cached_commentary
+    
+    settings = get_settings()
+    
+    # Check if OpenRouter is configured
+    if not settings.openrouter_api_key:
+        return {
+            "symbol": symbol,
+            "commentary": None,
+            "error": "AI commentary not configured. Set OPENROUTER_API_KEY environment variable.",
+            "generated_at": None,
+        }
+    
+    # Get the latest analysis
+    try:
+        analysis = await get_analysis(symbol)
+    except HTTPException:
+        return {
+            "symbol": symbol,
+            "commentary": None,
+            "error": "No analysis data available to comment on.",
+            "generated_at": None,
+        }
+    
+    # Get news count
+    with SessionLocal() as session:
+        week_ago = datetime.now() - timedelta(days=7)
+        news_count = session.query(func.count(NewsArticle.id)).filter(
+            NewsArticle.published >= week_ago
+        ).scalar() or 0
+    
+    # Generate commentary
+    commentary = await get_cached_commentary(
+        current_price=analysis.current_price,
+        predicted_price=analysis.predicted_price,
+        predicted_return=analysis.predicted_return,
+        sentiment_index=analysis.sentiment_index,
+        sentiment_label=analysis.sentiment_label,
+        top_influencers=[inf.dict() for inf in analysis.top_influencers],
+        news_count=news_count,
+        ttl_minutes=60,  # Cache for 1 hour
+    )
+    
+    return {
+        "symbol": symbol,
+        "commentary": commentary,
+        "error": None if commentary else "Failed to generate commentary",
+        "generated_at": datetime.now(timezone.utc).isoformat() if commentary else None,
+    }
+
+
 # =============================================================================
 # Root redirect (optional convenience)
 # =============================================================================

app/settings.py

@@ -50,6 +50,10 @@ class Settings(BaseSettings):
     tz: str = "Europe/Istanbul"
     scheduler_enabled: bool = True
     
+    # OpenRouter AI Commentary
+    openrouter_api_key: Optional[str] = None
+    openrouter_model: str = "meta-llama/llama-3.2-3b-instruct:free"
+    
     @property
     def symbols_list(self) -> list[str]:
         """Parse comma-separated symbols into a list."""