o uƌjO*@sdZddlmZmZmZddlmZddlmZddlm Z ddl m Z ddl Z ddl Z ddlZedZd efd d Zd ed ed efddZddeded efddZd efddZedkrxeZerreded deddSeddSdS)u top_stocks.py Runs whenever a position closes and a slot opens up. Re-scans CURRENT market conditions (not the stale 09:25 list) to find the strongest actionable candidate right now, respecting symbol cooldowns and currently-open positions. [FEATURE 2026-08-17] The candidate pool searched here is now premarket_20 (the full morning list of 20), not final_10 -- per the project's updated intraday-scanner requirement, premarket_20 is the primary intraday universe. Ranking now uses intraday_health.py's continuous health score (via evaluate_symbol()) rather than a one-shot score_premarket_candidate() call, so the same continuously-updated health state that decides entry eligibility also decides replacement ranking -- one source of truth, not two competing scores. Symbols health.evaluate_symbol() confirms as STALE/UNHEALTHY/REMOVED are excluded from replacement selection entirely. [FEATURE 2026-08-18] Every symbol in premarket_20 -- not just the ones currently eligible to fill a slot -- gets its health recomputed and persisted every time find_replacement() runs. Previously, a symbol sitting in exclude_symbols (currently open) or on cooldown never got recomputed during a replacement search, so its state/intraday_health.json entry could go stale until the next periodic 60-second cycle even though other parts of the system (the entry shortlist ranking, the dashboard) read that same file. Now every slot-open event doubles as a full health refresh for the whole pool, and selection among the symbols that CAN fill the slot is still: highest health_score wins, total_score only breaks a tie. Writes the running result to state/top_stocks.json (write_top_stocks) so the whole system has a single canonical file of "what looks best right now," as required by the project spec. The returned candidate still must pass entry_engine.evaluate_entry() before monitor.py actually buys it — this module only ranks, it never enters directly. )datetimetimezone timedelta) get_config) get_logger) get_client)score_premarket_candidateN top_stocksreturnc CsJg}|D]}||jt|jt|jt|jt|jt|jdq|S)N)tohlcv)append timestampfloatopenhighlowclosevolume)barsoutbrF/var/www/screener/trade/premarket_backup_2026-09-08_2010/top_stocks.py_bars_to_dicts6s rsymbol cooldownscCsD||}|s dStdd}t|t|d}ttj|kS)NFrisksymbol_cooldown_minutes)minutes)getrr fromisoformatrnowrutc)rr tscooldown_minutesexpiresrrr_is_on_cooldown@s r+exclude_symbolscandidate_poolc Cst}t|pg}t}t}|dur,t}|dgp$|dg}dd|D}|s5tddSt }t t j }|t|ddd }|d d } td t|d i} i} |D]T} || } | rot| ddnd}t| |\}}|std| d|q`t|| ||}t|dkrtd| dq`t| || |\}}|| | <||f| | <q`| r|| t|tdt| dt|dg}| D]\} \}}| |vrqt| |rtd| dqt|jstd| d|jqtdd|D}| | }|r|j!rt"|j!nd}|r-|j#r-t"|j#nd}t$| ||t%dd|D| ||}||d<|j&|d<|j|d<|j'|d<|j(|d <|)|q|shtd!dS|j*d"d#d$d%|d&}|d'id(d&}|d|krtd)|d*d+|dd,|d-t+|dStd.td|d*d/|dd0|dd1|d2d3 t+||S)4a exclude_symbols: currently-open symbols, always excluded from filling the slot (but still get a fresh health refresh below -- see [FEATURE 2026-08-18]). candidate_pool: optional restricted pool; if None, defaults to state/watchlist.json's premarket_20 (falling back to final_10 only if premarket_20 is somehow empty -- e.g. a very early call before the 09:00 scan has ever written the file). [FEATURE 2026-08-18] Every symbol in the pool -- including ones currently open or on cooldown, not just the ones that could fill THIS slot -- gets a fresh intraday_health.evaluate_symbol() call and a persisted state/intraday_health.json update before any selection happens. Previously, a symbol sitting in exclude_symbols/cooldown never got its health recomputed during a replacement search (its entry in the state file could go stale until the next periodic 60-second eval cycle), even though that same file also feeds _scan_for_entries()' shortlist ranking and the dashboard. Refreshing the whole pool here means every slot-open event doubles as a full health refresh for premarket_20, not just for the symbols eligible to fill it right now. Selection itself is unchanged: among symbols that ARE eligible to fill the slot (not excluded, not on cooldown, health-eligible per that just-refreshed reading), the highest health_score wins, total_score only breaks a tie. N premarket_20final_10cSs"g|] }t|tr |dn|qS)r) isinstancedict).0rrrr ns"z$find_replacement..z3[REPLACEMENT] No candidate pool available to searchintraday_healthfull_rescan_lookback_hours)hoursuniversemin_avg_daily_volumez([REPLACEMENT] Refreshing health for all z? premarket_20 symbols before selecting a fill for the open slotnamez[REPLACEMENT] z skipped: z4 skipped: insufficient bars for a fresh health checkz#[REPLACEMENT] Refreshed health for /z pool symbolsz skipped: on cooldownz skipped: health=cs|]}|dVqdS)r Nrr2rrrr z#find_replacement..csr=)rNrr>rrrr?r@pm_high health_score health_state price_slope vwap_slopez>[REPLACEMENT] No actionable (health-eligible) candidates foundcSs|d|dfS)NrB total_scorer)rrrrsz"find_replacement..T)keyreversertradingmin_replacement_health_scorez[REPLACEMENT] Best candidate rz (health_score=z() is below min_replacement_health_score=zI -- leaving slot empty this cycle rather than filling it with a weak pickz#[REPLACEMENT] Running top_stocks.pyz selected (health=z, health_score=z, score=rF)),rset data_storeload_cooldownsload_health_stateload_watchlistr$loginforrr&rr'rlen get_assetgetattrsymbol_filterspasses_symbol_filtersdebugrget_minute_barsr4evaluate_symbolupdatesave_health_stateitemsr+is_eligible_for_entryconfirmed_statemaxget_latest_quote bid_pricer ask_pricerminrBprice_slope_classvwap_slope_classrsortwrite_top_stocks)r,r-cfgr rC watchlistclientr&startavg_vol_baselinehealth_updatesfreshrasset asset_nameokreasonrreadingnew_health_entryscored session_highquotebidaskresultbestrLrrrfind_replacementIs                     rcCs*t}ttj||<t|dS)N)rOrPrr&rr' isoformatsave_cooldowns)rr rrrregister_cooldownsr__main__zBest replacement: z score=rFzNo replacement candidate found.)NN)__doc__rrr config_loaderr logger_setupr alpaca_clientrscorerrrXr4rOrSlistrstrr1boolr+rr__name__r}printrrrrs*(