Update api.py

api.py

@@ -631,6 +631,7 @@ INSTRUMENT_CATALOG = [
 
 # Symbol mappings from Frontend symbols to Yahoo Finance symbols
 SYMBOL_MAP = {
+    "NIFTY 50": "^NSEI",
     "NIFTY50": "^NSEI",
     "SENSEX": "^BSESN",
     "RELIANCE": "RELIANCE.NS",
@@ -680,15 +681,16 @@ def fetch_live_data(symbol: str, exchange: str = "", interval: str = "5min",
     }
     yq_interval = intervals_map.get(interval, "5m")
 
-    # Select history period based on interval
+    # Select history period based on interval to ensure we get 250+ valid bars
     if yq_interval == "1m":
         period = "5d"
     elif yq_interval in ["5m", "15m"]:
         period = "1mo"
     elif yq_interval == "1h":
-        period = "3mo" if interval == "4h" else "1mo"
+        # For 4h we resample from 1h, so we need 4x the data length (approx 1 year of 1h data)
+        period = "1y" if interval == "4h" else "3mo"
     else:
-        period = "1y"
+        period = "2y"  # 1day interval
 
     t = Ticker(yf_symbol)
     df = t.history(period=period, interval=yq_interval)
@@ -765,6 +767,65 @@ def list_instruments():
     }
 
 
+@app.get("/search")
+def search_tickers(q: str = Query(...)):
+    """Search Yahoo Finance for symbols/tickers matching a query."""
+    try:
+        from yahooquery import search
+        res = search(q)
+        quotes = res.get("quotes", [])
+        results = []
+        for quote in quotes:
+            symbol = quote.get("symbol")
+            if not symbol:
+                continue
+            name = quote.get("longname") or quote.get("shortname") or symbol
+            exchange = quote.get("exchDisp") or quote.get("exchange") or ""
+            quote_type = quote.get("typeDisp") or quote.get("quoteType") or "Equity"
+            
+            # Map type to category
+            category = "Equity"
+            if quote_type.lower() in ["cryptocurrency", "crypto"]:
+                category = "Crypto"
+            elif quote_type.lower() in ["currency", "forex"]:
+                category = "Forex"
+            elif quote_type.lower() in ["commodity", "future"]:
+                category = "Commodities"
+            elif quote_type.lower() in ["index"]:
+                category = "Indices"
+            elif quote_type.lower() in ["etf"]:
+                category = "ETF"
+            else:
+                category = "Equity"
+                
+            # Determine visual flag
+            flag = "📈"
+            if category == "Crypto":
+                flag = "₿"
+            elif category == "Forex":
+                flag = "💱"
+            elif category == "Commodities":
+                flag = "🥇"
+            elif category == "Indices":
+                flag = "📊"
+            elif exchange == "NSE" or exchange == "BSE":
+                flag = "🇮🇳"
+            elif exchange in ["NASDAQ", "NYSE", "AMEX"]:
+                flag = "🇺🇸"
+                
+            results.append({
+                "symbol": symbol,
+                "exchange": exchange,
+                "name": name,
+                "category": category,
+                "currency": quote.get("currency", "USD"),
+                "flag": flag
+            })
+        return {"results": results}
+    except Exception as e:
+        return {"error": str(e), "results": []}
+
+
 @app.get("/price/{symbol:path}")
 def get_price(symbol: str, exchange: str = Query(default="")):
     """Quick current-price lookup for a symbol."""