o ̿SiE @sddlZddlZddlZddlmZddlmZddlmZddlm Z m Z ddl m Z m Z mZmZmZmZmZeeZedZeZedd pLd d vZdd d Zdded dfddZdS)N)datetime)ZoneInfo) get_mongo_db)refresh_movers_service&refresh_live_movers_from_latest_movers)backend_market_window format_windowis_backend_market_hourslocal_time_str local_nownext_backend_market_open_local seconds_untilz Asia/Kolkata#MOVERS_REFRESH_ENFORCE_MARKET_HOURS1)0falsenooffreturncCst}t|}z[z2t|}t|dg}t|dg}t|}td|d||td|d|dWntyHt dYnwWz| Wd Stybtj d d d Yd Swz| Wwtyytj d d d Yww) zRun a single ET movers refresh cycle (synchronous). This is run in a worker thread so the FastAPI event loop stays responsive. gainerslosersz;[MoversRefresh] Refreshed movers: %s | gainers=%d losers=%d fetched_atzE[MoversRefresh] Rebuilt live_movers from movers | built=%s skipped=%sbuiltskippedz*[MoversRefresh] Error refreshing ET moversz*[MoversRefresh] Error closing DB generatorT)exc_infoN) rnextrlengetrloggerinfo Exception exceptionclosedebug)db_gendbrecordrrlmr(>/var/www/html/Trade-python/app/v1/background/movers_refresh.py_refresh_movers_once_syncs@    r*interval_secondsc stdIdHtd| tr=ts=t}tdttt |dur4tt t |IdHqt|IdHqt rOtdt|IdHqt 4IdHttIdHWdIdHn 1IdHsnwYt|IdHq)a-Background loop to refresh ET movers periodically. Intended to be started from FastAPI's startup event via `asyncio.create_task(movers_refresh_loop(...))`. Parameters ---------- interval_seconds: int Sleep interval between refresh cycles. Default: 900s (15 minutes). Nz@[MoversRefresh] Background ET movers loop started (interval=%ss)TzJ[MoversRefresh] Skipped: outside backend market hours | now=%s | window=%szB[MoversRefresh] Previous refresh still running; skipping this tick)asynciosleeprrrr r r rrr r _MOVERS_REFRESH_LOCKlocked to_threadr*)r,nxtr(r(r)movers_refresh_loop:s8   (r4)rN)r+) r.loggingosrzoneinforapp.db.databaserapp.v1.services.moversrrapp.v1.utils.market_timerrr r r r r getLogger__name__rISTLockr0getenvstriplowerrr*intr4r(r(r(r)s"   $  #