Upload 42 files

kotak_neo.py

@@ -58,6 +58,19 @@ def _first_number(*values: Any) -> float | None:
     return None
 
 
+def _first_market_number(*values: Any) -> float | None:
+    fallback = None
+    for value in values:
+        parsed = _to_float(value)
+        if parsed is None:
+            continue
+        if fallback is None:
+            fallback = parsed
+        if parsed > 0:
+            return parsed
+    return fallback
+
+
 def _first_text(*values: Any) -> str | None:
     for value in values:
         if isinstance(value, dict):
@@ -403,6 +416,14 @@ class KotakNeoManager:
             raise KotakNeoError("Kotak Neo did not return a NIFTY 50 quote.")
 
         item = items[0]
+        last_traded_price = _first_market_number(item.get("last_traded_price"), item.get("ltp"), item.get("iv"))
+        close = _first_market_number(item.get("ic"), item.get("close"), item.get("c"))
+        change = _first_number(item.get("cng"), item.get("change"))
+        change_pct = _first_number(item.get("nc"), item.get("net_change_percentage"))
+        high = _first_market_number(item.get("highPrice"), item.get("high"), item.get("h"), item.get("hp"))
+        low = _first_market_number(item.get("lowPrice"), item.get("low"), item.get("l"), item.get("lp"))
+        open_price = _first_market_number(item.get("openingPrice"), item.get("open"), item.get("o"))
+
         payload = {
             "symbol": "NIFTY 50",
             "exchange_segment": "nse_cm",
@@ -414,13 +435,13 @@ class KotakNeoManager:
                 reference["quote_instrument_token"],
             ),
             "display_name": _first_text(item.get("trading_symbol"), item.get("ts"), item.get("name"), "NIFTY 50"),
-            "last_traded_price": _first_number(item.get("last_traded_price"), item.get("ltp"), item.get("iv")),
-            "close": _first_number(item.get("close"), item.get("c"), item.get("ic")),
-            "change": _first_number(item.get("change"), item.get("cng")),
-            "change_pct": _first_number(item.get("net_change_percentage"), item.get("nc")),
-            "open": _first_number(item.get("openingPrice"), item.get("open"), item.get("o")),
-            "high": _first_number(item.get("highPrice"), item.get("high"), item.get("h")),
-            "low": _first_number(item.get("lowPrice"), item.get("low"), item.get("l")),
+            "last_traded_price": last_traded_price,
+            "close": close,
+            "change": change,
+            "change_pct": change_pct,
+            "open": open_price,
+            "high": high,
+            "low": low,
             "exchange_feed_time": _first_text(item.get("tvalue"), item.get("updRecvTm"), item.get("hsUpTm")),
             "as_of": _utc_now_iso(),
             "source": {