adding top-stocks route that is dynamic to stocks day change %

Author: kushagra21-afk

controllers/topStocks.py

@@ -6,29 +6,50 @@
     "User-Agent": "Chrome/122.0.0.0"
 })
 
-def get_top_stocks(symbols):
+def get_top_stock_info():
+    tickers_list = [
+        "AAPL", "MSFT", "GOOGL", "AMZN", "NVDA", "TSLA", "META", "BRK-B", "JPM", 
+        "JNJ", "V", "PG", "UNH", "MA", "HD", "XOM", "PFE", "NFLX", "DIS", "PEP",
+        "KO", "CSCO", "INTC", "ORCL", "CRM", "NKE", "WMT", "BA", "CVX", "T", "UL",
+        "IBM", "AMD"
+    ]
     stock_data = []
     try:
-        top_stocks = symbols.split()
-        tickers = yf.Tickers(symbols)
-        while top_stocks:
-            stock = top_stocks.pop()
-            info = tickers.tickers[stock].info
-            stock_info = {
+        data = yf.download(tickers_list, period="2d", interval="1d", group_by='ticker', auto_adjust=True)
+        changes = []
+
+        for ticker in tickers_list:
+            try:
+                close_prices = data[ticker]['Close']
+                percent_change = ((close_prices[-1] - close_prices[-2]) / close_prices[-2]) * 100
+                changes.append((ticker, round(percent_change, 2)))
+            except Exception:
+                continue
+
+        # Sort by absolute percent change and pick top 5
+        top_5_tickers = [ticker for ticker, _ in sorted(changes, key=lambda x: abs(x[1]), reverse=True)[:5]]
+        tickers = yf.Tickers(top_5_tickers)
+        while top_5_tickers:
+            try:
+                stock = top_5_tickers.pop()
+                info = tickers.tickers[stock].info
+                stock_info = {
                     'symbol': stock,
                     'name': info.get('shortName', 'N/A'),
                     'currentPrice': info.get('currentPrice', 'N/A'),
                     'previousClose': info.get('previousClose', 'N/A'),
                     'sector': info.get('sector', 'N/A')
-                    }
-            
-            stock_data.append(stock_info)
+                }
+                stock_data.append(stock_info)
+            except Exception as e:
+                print(f"⚠️ Could not fetch info for {stock}: {e}")
+        
         print("✅ Data fetching done successfully!")
         return stock_data
+
     except Exception as e:
-            print(f"❌ Error fetching {symbols}: {e}")
-            time.sleep(5)
-    
+        print(f"❌ Error fetching stock data: {e}")
+        return []
 
 def get_stock(symbol):
     try:

routes/stockRoutes.py

@@ -2,7 +2,7 @@
 from fastapi_cache import FastAPICache
 from fastapi_cache.backends.redis import RedisBackend
 from utils.redisCache import get_cache
-from controllers.topStocks import get_top_stocks, get_stock
+from controllers.topStocks import get_stock, get_top_stock_info
 from controllers.stockNews import fetch_news
 from controllers.stockAgent import stock_analyzer_agent, extract_json_from_response, create_default_stock_data, merge_stock_data
 from fastapi.responses import JSONResponse, HTMLResponse
@@ -31,9 +31,7 @@ async def read_top_stocks(request: Request, cache: RedisBackend = Depends(get_ca
     if cached_result:
         result = json.loads(cached_result)
     else:
-        top_stocks = ['AAPL', 'MSFT', 'AMZN', 'GOOGL', 'TSLA', 'META', 'NVDA']
-        stocks = " ".join(top_stocks)
-        result = get_top_stocks(stocks)
+        result = get_top_stock_info()
         await cache.set(cache_key, json.dumps(result), 10)
 
     # Check if request is from a browser
@@ -79,29 +77,29 @@ async def stock_news(request: Request, cache: RedisBackend = Depends(get_cache))
 
     return result
 
-@router.get("/stock/{name}")
-async def read_stock(request: Request, name: str, cache: RedisBackend = Depends(get_cache)):
-    # Use f-string to properly interpolate the name variable
-    cache_key = f"stock_{name}"
+@router.get("/stock/{symbol}")
+async def read_stock(request: Request, symbol: str, cache: RedisBackend = Depends(get_cache)):
+    # Use f-string to properly interpolate the symbol variable
+    cache_key = f"stock_{symbol}"
     cached_result = await cache.get(cache_key)
 
     if cached_result:
         result = json.loads(cached_result)
     else:
-        result = get_stock(name)
+        result = get_stock(symbol)
         await cache.set(cache_key, json.dumps(result), 10)
 
     # Check if request is from a browser
     accept_header = request.headers.get("accept", "")
     if "text/html" in accept_header:
         return templates.TemplateResponse("route.html", {
             "request": request,
-            "route_path": f"/stock/{{{name}}}",
+            "route_path": f"/stock/{{{symbol}}}",
             "method": "GET",
-            "full_path": request.url.scheme + "://" + request.url.netloc + f"/stock/{name}",
+            "full_path": request.url.scheme + "://" + request.url.netloc + f"/stock/{symbol}",
             "description": "Returns detailed information about a specific stock",
             "parameters": [
-                {"name": "name", "type": "string", "description": "Stock symbol (e.g., AAPL, MSFT)"}
+                {"name": "symbol", "type": "string", "description": "Stock symbol (e.g., AAPL, MSFT)"}
             ],
             "example_response": json.dumps(result, indent=2),
             "current_year": datetime.datetime.now().year