fix: company info from chart API meta, multi-market sentiment, factor analysis

backend/app/services/data_ingestion/yahoo.py

@@ -126,43 +126,62 @@ def _direct_fetch_history(ticker: str, period: str = "1y", interval: str = "1d",
 
 
 def _direct_fetch_info(ticker: str) -> dict:
-    """Fetch quote info directly from Yahoo's quote API via curl_cffi."""
+    """Fetch quote info from Yahoo's chart API meta field via curl_cffi.
+
+    The v7/finance/quote endpoint is blocked on cloud IPs, but the v8/finance/chart
+    endpoint works and includes a 'meta' field with useful company data.
+    """
     if not _USE_CURL or not _curl_session:
         return _yfinance_fetch_info(ticker)
 
     try:
-        resp = _curl_session.get(_QUOTE_URL, params={"symbols": ticker}, timeout=10)
+        # Use the chart API which is confirmed working — extract from meta
+        url = _CHART_URL.format(ticker=ticker)
+        params = {
+            "period1": str(int(time.time()) - 86400 * 5),
+            "period2": str(int(time.time())),
+            "interval": "1d",
+            "includeAdjustedClose": "true",
+        }
+        resp = _curl_session.get(url, params=params, timeout=10)
         if resp.status_code != 200:
-            logger.debug("Yahoo quote API returned %d for %s", resp.status_code, ticker)
+            logger.debug("Yahoo chart meta API returned %d for %s", resp.status_code, ticker)
             return {}
 
         data = resp.json()
-        results = data.get("quoteResponse", {}).get("result", [])
-        if not results:
+        result = data.get("chart", {}).get("result")
+        if not result:
             return {}
 
-        q = results[0]
+        meta = result[0].get("meta", {})
+
+        # Calculate basic metrics from price data if available
+        prev_close = meta.get("chartPreviousClose") or meta.get("previousClose")
+        reg_price = meta.get("regularMarketPrice")
+
         return {
-            "longName": q.get("longName"),
-            "shortName": q.get("shortName"),
-            "currency": q.get("currency", "USD"),
-            "exchange": q.get("exchange"),
-            "sector": q.get("sector"),
-            "industry": q.get("industry"),
-            "marketCap": q.get("marketCap"),
-            "trailingPE": q.get("trailingPE"),
-            "forwardPE": q.get("forwardPE"),
-            "priceToBook": q.get("priceToBook"),
-            "dividendYield": q.get("dividendYield"),
-            "trailingEps": q.get("epsTrailingTwelveMonths"),
-            "fiftyTwoWeekHigh": q.get("fiftyTwoWeekHigh"),
-            "fiftyTwoWeekLow": q.get("fiftyTwoWeekLow"),
-            "averageVolume": q.get("averageDailyVolume3Month"),
-            "beta": q.get("beta"),
-            "country": q.get("region"),
+            "longName": meta.get("longName"),
+            "shortName": meta.get("shortName") or meta.get("symbol"),
+            "currency": meta.get("currency", "USD"),
+            "exchange": meta.get("exchangeName") or meta.get("exchange"),
+            "sector": None,  # Not available from chart meta
+            "industry": None,
+            "marketCap": None,
+            "trailingPE": None,
+            "forwardPE": None,
+            "priceToBook": None,
+            "dividendYield": None,
+            "trailingEps": None,
+            "fiftyTwoWeekHigh": meta.get("fiftyTwoWeekHigh"),
+            "fiftyTwoWeekLow": meta.get("fiftyTwoWeekLow"),
+            "averageVolume": None,
+            "beta": None,
+            "country": None,
+            "regularMarketPrice": reg_price,
+            "previousClose": prev_close,
         }
     except Exception as e:
-        logger.debug("Direct quote API failed for %s: %s", ticker, e)
+        logger.debug("Direct chart meta fetch failed for %s: %s", ticker, e)
         return {}
 
 

backend/app/services/sentiment/engine.py

@@ -143,18 +143,24 @@ async def fetch_multi_sentiment(tickers: List[str]) -> List[Dict[str, Any]]:
 
 # ── Trending / Market Mood ───────────────────────────────────────────────
 MARKET_TICKERS = [
+    # US
     "SPY", "QQQ", "AAPL", "MSFT", "GOOGL", "AMZN", "NVDA", "TSLA",
-    "META", "BRK-B", "JPM", "V", "UNH", "MA", "HD",
+    # India
+    "RELIANCE.NS", "TCS.NS", "HDFCBANK.NS", "INFY.NS",
+    # Europe
+    "ASML", "SAP", "SHEL", "AZN",
+    # Asia
+    "9988.HK", "7203.T",
 ]
 
 async def get_market_mood() -> Dict[str, Any]:
-    """Get overall market sentiment from major tickers."""
+    """Get overall market sentiment from major tickers across all markets."""
     cache_key = "sentiment:market_mood"
     cached = await cache_get(cache_key)
     if cached:
         return cached
 
-    results = await fetch_multi_sentiment(MARKET_TICKERS[:8])
+    results = await fetch_multi_sentiment(MARKET_TICKERS[:10])
 
     if not results:
         return {"mood": "neutral", "score": 0, "tickers_analyzed": 0}