Merge pull request #10 from yashksaini-coder/kush2

Adding api endpoint to fetch detailed information on a particular stock

Author: yashksaini-coder

app.py

@@ -15,7 +15,7 @@
 import json
 from redis import asyncio as aioredis
 # Custom imports
-from topStocks import get_top_stocks
+from topStocks import get_top_stocks, get_stock
 from ask import groq_chat
 from stockNews import fetch_news
 from agents import multi_ai
@@ -79,11 +79,11 @@ async def read_top_stocks(cache: RedisBackend = Depends(get_cache)):
         return json.loads(cached_result)
 
     top_stocks = ['AAPL', 'MSFT', 'AMZN', 'GOOGL']
-    stock = " ".join(top_stocks)
-    stock_info = get_top_stocks(stock)
+    stocks = " ".join(top_stocks)
+    stocks_info = get_top_stocks(stocks)
 
-    await cache.set(cache_key, json.dumps(stock_info), 10) 
-    return stock_info
+    await cache.set(cache_key, json.dumps(stocks_info), 10) 
+    return stocks_info
 
 @app.get("/stock-news")
 async def stock_news(cache: RedisBackend = Depends(get_cache)):
@@ -95,6 +95,16 @@ async def stock_news(cache: RedisBackend = Depends(get_cache)):
     await cache.set(cache_key, json.dumps(news_stack), 300) 
     return news_stack
 
+@app.get("/stocks/{name}")
+async def read_stock(name: str, cache: RedisBackend = Depends(get_cache)):
+    cache_key = "stock_{name}"
+    cached_result = await cache.get(cache_key)
+    if cached_result:
+        return json.loads(cached_result)
+    stock_info = get_stock(name)
+    await cache.set(cache_key, json.dumps(stock_info), 10)
+    return stock_info
+
 
 @app.get("health/")  # Changed to GET since it's retrieving status
 async def health_check():

stockNews.py

@@ -10,7 +10,7 @@
 
 if not NEWS_API_KEY:
     raise ValueError("Please provide a NEWS API key")
-    
+
 session = requests.Session()
 session.headers.update({
     "User-Agent": "Chrome/122.0.0.0"

topStocks.py

@@ -24,7 +24,25 @@ def get_top_stocks(symbols):
 
             stock_data.append(stock_info)
         print("✅ Data fetching done successfully!")
+        return stock_data
     except Exception as e:
             print(f"❌ Error fetching {symbols}: {e}")
             time.sleep(5)
-    return stock_data
+    
+
+def get_stock(symbol):
+    try:
+        stock = yf.Ticker(symbol)
+        info = stock.info
+        stock_info = {
+                'symbol': symbol,
+                'name': info.get('shortName', 'N/A'),
+                'currentPrice': info.get('currentPrice', 'N/A'),
+                'previousClose': info.get('previousClose', 'N/A'),
+                'sector': info.get('sector', 'N/A')
+            }
+        print("✅ Data fetching done successfully!")
+        return stock_info
+    except Exception as e:
+        print(f"❌ Error fetching {symbol}: {e}")
+        time.sleep(5)