Upload 42 files

kotak_neo.py

@@ -605,8 +605,7 @@ class KotakNeoManager:
 
         if live_previous_close is not None:
             is_same_as_static_ltp = (
-                not session_started
-                and last_traded_price is not None
+                last_traded_price is not None
                 and abs(live_previous_close - last_traded_price) < 0.01
             )
             if not is_same_as_static_ltp:
@@ -634,8 +633,8 @@ class KotakNeoManager:
         if session_started:
             range_high = max([value for value in [session_high, last_traded_price] if value is not None], default=None)
             range_low = min([value for value in [session_low, last_traded_price] if value is not None], default=None)
-            return_base = session_open
-            return_basis = "open"
+            return_base = previous_close
+            return_basis = "previous_close"
         else:
             range_high = session_high
             range_low = session_low

nifty_backend/runtime.py

@@ -701,6 +701,9 @@ def load_tomorrow_summary() -> dict[str, Any]:
 def latest_tomorrow_prediction() -> dict[str, Any]:
     sync_daily_forecaster_outputs()
     latest_daily = latest_parquet_date(NIFTY_1D_PATH)
+    expected_daily = expected_completed_daily_date()
+    valid_daily = min(latest_daily, expected_daily) if latest_daily and expected_daily else (expected_daily or latest_daily)
+
     if TOMORROW_LATEST_PATH.exists():
         row = pd.read_csv(TOMORROW_LATEST_PATH).iloc[-1].to_dict()
         cleaned = {k: (None if pd.isna(v) else v) for k, v in row.items()}
@@ -708,14 +711,14 @@ def latest_tomorrow_prediction() -> dict[str, Any]:
             input_day = date.fromisoformat(str(cleaned.get("input_date"))[:10])
         except Exception:
             input_day = None
-        if latest_daily is not None and (input_day is None or input_day < latest_daily):
+        if valid_daily is not None and (input_day is None or input_day < valid_daily):
             try:
-                refreshed = refresh_tomorrow_prediction(session_date=latest_daily)
+                refreshed = refresh_tomorrow_prediction(session_date=valid_daily)
                 try:
                     refreshed_day = date.fromisoformat(str(refreshed.get("input_date"))[:10])
                 except Exception:
                     refreshed_day = None
-                if refreshed_day is not None and refreshed_day >= latest_daily:
+                if refreshed_day is not None and refreshed_day >= valid_daily:
                     return refreshed
             except Exception:
                 pass
@@ -725,9 +728,9 @@ def latest_tomorrow_prediction() -> dict[str, Any]:
         summary_input_day = date.fromisoformat(str(summary.get("latest_forecast_date"))[:10])
     except Exception:
         summary_input_day = None
-    if latest_daily is not None and (summary_input_day is None or summary_input_day < latest_daily):
+    if valid_daily is not None and (summary_input_day is None or summary_input_day < valid_daily):
         try:
-            return refresh_tomorrow_prediction(session_date=latest_daily)
+            return refresh_tomorrow_prediction(session_date=valid_daily)
         except Exception:
             pass
     return {