o ]j&@sdZddlmZmZddlmZddlmZddZdefdd Z d efd d Z d e defddZ ded e de fddZde fddZde fddZde fddZde fddZde fddZde fddZde fdd Zdefd!d"Zdefd#d$Zdefd%d&Zd'S)(a# market_time.py All schedule/time comparisons go through here so the rest of the code never does naive string or local-time comparisons (a common source of "incorrect market-time handling" bugs, especially around DST). Uses zoneinfo (stdlib, Python 3.9+) with America/New_York from config. )datetimetime)ZoneInfo) get_configcCsttddS)Nscheduletimezone)rrrr*/var/www/screener/premarket/market_time.py_tzsr returncCs ttS)N)rnowr rrrr now_ets r dtcCs|tS)zTrading-day date for an arbitrary (tz-aware) timestamp, e.g. a UTC exit_time/updated_at pulled from persisted state, converted to the exchange's own calendar day rather than UTC's.) astimezoner date)rrrr et_datesrhhmmsscCs&dd|dD\}}}t|||S)NcSsg|]}t|qSr)int).0xrrr sz_parse_time..:)splitdtime)rhmsrrr _parse_times rcurrentcCs|jddt|kS)N)tzinfo)timetzreplacer)rrrrr _is_after$sr"cCtd}tt|dS)Nrpremarket_scan_timerr"r cfgrrr is_premarket_scan_time( r(cCs.td}t}t||dot||d S)Nrmarket_open_timemarket_close_time)rr r")r'rrrr is_market_open-s r,cCr#)Nrr*r%r&rrr is_past_market_open3r)r-cCr#)Nrno_new_entries_afterr%r&rrr is_new_entries_cutoff8r)r/cCr#)Nrforce_liquidate_timer%r&rrr is_force_liquidate_time=r)r1cCr#)Nrr+r%r&rrr is_market_closed_for_dayBr)r2cCstdkS)N)r weekdayrrrr is_weekdayGsr5cCs4td}t|d}t}|j|j|j|jddS)a[BUGFIX 2026-09-09] Today's market_open_time as a tz-aware ET datetime -- for stream.py's historical backfill, which needs a real start timestamp for "give me every 1-min bar since the session opened," not just a minutes-elapsed float. Same open_time-parsing logic minutes_since_open() already uses, factored out here since that one only needs the elapsed count, not the datetime itself.rr*r)hourminutesecond microsecond)rrr r!r6r7r8)r' open_timerrrr session_open_dtKs   r;cCst}t|dS)a[FEATURE 2026-09-05] Minutes since market_open_time today, for regime_engine.classify_regime()'s session_elapsed_minutes param (its OPENING_VOLATILITY window check). Negative before the open -- callers that only care about "are we in the opening window" should treat a negative value the same as regime_engine already treats None (can't be in the opening window if the session hasn't started).gN@)r;r total_seconds)open_dtrrr minutes_since_openYsr>cCsBtd}t|d}t|d}|jd|j|jd|jS)ap[FEATURE 2026-09-14] market_close_time - market_open_time in minutes (390 for a normal 09:30-16:00 session), for fast_entry_gate.py's volume-pace floor -- relative_volume is cumulative-volume-so-far over the PRIOR full day's total, so it needs to be divided by how much of TODAY's session has elapsed to be comparable across different times of day.rr*r+<)rrr6r7)r'open_tclose_trrr session_length_minutesds    rBN)__doc__rrrzoneinfor config_loaderrr r rstrrboolr"r(r,r-r/r1r2r5r;floatr>rBrrrr s&