Update app/app.py

app/app.py

@@ -14,7 +14,9 @@ from contextlib import asynccontextmanager
 from typing import Optional, Union
 
 import httpx
-from fastapi import FastAPI, Request, BackgroundTasks
+# =================== FIX APPLIED HERE (1 of 2) ===================
+from fastapi import FastAPI, Request, BackgroundTasks, Form
+# =================================================================
 from fastapi.responses import HTMLResponse, StreamingResponse
 from fastapi.templating import Jinja2Templates
 from pydantic import BaseModel, constr
@@ -24,12 +26,6 @@ from .price_fetcher import PriceFetcher
 from .gemini_analyzer import GeminiAnalyzer
 from newsapi import NewsApiClient
 
-# --- Pydantic Model for API Input Validation ---
-
-class SentimentRequest(BaseModel):
-    """Ensures the text for sentiment analysis is a non-empty string."""
-    text: constr(strip_whitespace=True, min_length=1)
-
 # --- Application Lifespan for Resource Management ---
 
 @asynccontextmanager
@@ -47,7 +43,6 @@ async def lifespan(app: FastAPI):
         # Create separate queues for the two real-time feeds
         app.state.sentiment_queue: asyncio.Queue = asyncio.Queue()
         app.state.news_queue: asyncio.Queue = asyncio.Queue()
-        app.state.request_counter = 0
 
         # Create cancellable background tasks for periodic updates.
         price_task = asyncio.create_task(
@@ -84,15 +79,13 @@ async def run_periodic_news_analysis(app: FastAPI, interval_seconds: int):
                 q='bitcoin OR ethereum OR crypto OR blockchain',
                 language='en',
                 sort_by='publishedAt',
-                page_size=5  # Fetch the 5 most recent articles
+                page_size=5
             )
             analyzer: GeminiAnalyzer = app.state.gemini_analyzer
             for article in top_headlines.get('articles', []):
                 title = article.get('title')
                 if title and "[Removed]" not in title:
-                    # Run the full Gemini analysis on each headline
                     analysis = await analyzer.analyze_text(title)
-                    # Add the article URL to the payload for the frontend
                     analysis['url'] = article.get('url')
                     await app.state.news_queue.put(analysis)
         except Exception as e:
@@ -106,21 +99,14 @@ app = FastAPI(title="CryptoSentinel Pro", lifespan=lifespan)
 templates = Jinja2Templates(directory="templates")
 
 # --- HTML Rendering Helper ---
-
 def render_analysis_card(payload: dict, is_news: bool = False) -> str:
-    """Renders a dictionary of analysis into a styled HTML card."""
     s = payload
     text_to_show = s.get('summary', 'Analysis failed or not available.')
-
-    # Make the summary a clickable link if it's a news item
     if is_news:
         url = s.get('url', '#')
         text_to_show = f'<a href="{url}" target="_blank" rel="noopener noreferrer">{s.get("summary", "N/A")}</a>'
-
-    # Dynamically set CSS classes based on analysis results
     impact_class = f"impact-{s.get('impact', 'low').lower()}"
     sentiment_class = f"sentiment-{s.get('sentiment', 'neutral').lower()}"
-
     return f"""
     <div class="card {impact_class}">
         <blockquote>{text_to_show}</blockquote>
@@ -139,12 +125,10 @@ def render_analysis_card(payload: dict, is_news: bool = False) -> str:
 
 @app.get("/", response_class=HTMLResponse)
 async def serve_dashboard(request: Request):
-    """Serves the main interactive dashboard from `index.html`."""
     return templates.TemplateResponse("index.html", {"request": request})
 
 @app.get("/api/prices", response_class=HTMLResponse)
 async def get_prices_fragment(request: Request):
-    """Returns an HTML fragment with the latest cached crypto prices for HTMX."""
     price_fetcher: PriceFetcher = request.app.state.price_fetcher
     prices = price_fetcher.get_current_prices()
     html_fragment = "".join(
@@ -154,13 +138,19 @@ async def get_prices_fragment(request: Request):
     )
     return HTMLResponse(content=html_fragment)
 
+# =================== FIX APPLIED HERE (2 of 2) ===================
 @app.post("/api/sentiment")
-async def analyze_sentiment(payload: SentimentRequest, request: Request, background_tasks: BackgroundTasks):
+async def analyze_sentiment(
+    request: Request,
+    background_tasks: BackgroundTasks,
+    text: str = Form(...)  # Tell FastAPI to expect a form field named 'text'
+):
+# =================================================================
     """Queues user-submitted text for a full Gemini-powered analysis."""
     analyzer: GeminiAnalyzer = request.app.state.gemini_analyzer
 
     async def analysis_task_wrapper():
-        analysis_result = await analyzer.analyze_text(payload.text)
+        analysis_result = await analyzer.analyze_text(text) # Use the 'text' variable directly
         await request.app.state.sentiment_queue.put(analysis_result)
 
     background_tasks.add_task(analysis_task_wrapper)
@@ -168,30 +158,24 @@ async def analyze_sentiment(payload: SentimentRequest, request: Request, backgro
 
 @app.get("/api/sentiment/stream")
 async def sentiment_stream(request: Request):
-    """SSE stream for results from manual sentiment analysis requests."""
     queue: asyncio.Queue = request.app.state.sentiment_queue
     async def event_generator():
         while True:
             payload = await queue.get()
             html = render_analysis_card(payload)
-            # =================== FIX APPLIED HERE ===================
             data_payload = html.replace('\n', '')
             sse_message = f"event: sentiment_update\ndata: {data_payload}\n\n"
             yield sse_message
-            # ========================================================
     return StreamingResponse(event_generator(), media_type="text/event-stream")
 
 @app.get("/api/news/stream")
 async def news_stream(request: Request):
-    """SSE stream for the automated Market Intelligence Feed."""
     queue: asyncio.Queue = request.app.state.news_queue
     async def event_generator():
         while True:
             payload = await queue.get()
             html = render_analysis_card(payload, is_news=True)
-            # =================== FIX APPLIED HERE ===================
             data_payload = html.replace('\n', '')
             sse_message = f"event: news_update\ndata: {data_payload}\n\n"
             yield sse_message
-            # ========================================================
     return StreamingResponse(event_generator(), media_type="text/event-stream")