o j6)@sdZddlmZmZddlmZdddddddddd d d d d d d d ddddddddddddddd ddddgdddddZeGdd d Zd!ed"efd#d$Z d%e d"efd&d'Z d(ed)e d"e fd*d+Zd,e d)e d"efd-d.Z / / /d5d0e d1e d2e d)e d"ef d3d4Zd/S)6aC winner_score.py [Phase 4 -- new] Composite 0-100 ranking score, ADDITIVE ONLY -- see the 2026-09-08 design discussion: entry_score.py's five separate scores (trend/structure/prediction/entry/risk) remain the ONLY thing that gates should_enter, unchanged. WINNER_SCORE never overrides that gate; it exists purely for cross-symbol ranking, the market-state output, and score-velocity tracking (RISING_FAST etc.) -- exactly the two independent fields the project's own requested output schema already has (`winner_score` and `entry_status` side by side, not one derived from the other). Composition follows the project's own suggested starting weights (all configurable, none hard-coded): trend_structure 20, relative_strength 15, volume_expansion 15, vwap_structure 15, premarket_setup 10, breakout_quality 10, volatility_expansion 5, sector_strength 5, market_regime 5. SCORE MOMENTUM (velocity/acceleration/trend) needs a caller-held history -- same ownership pattern as every other stateful piece in this pipeline (entry_score.py's confirmation_state, stream_features.py's `prior`): the caller holds a bounded list of (timestamp, score, velocity) tuples, oldest first, passes it in as `score_history`, and is responsible for appending this call's own (now, score, velocity) to that list afterward -- this function never mutates or stores it. ) dataclassfield) get_config  trend_structurerelative_strengthvolume_expansionvwap_structurepremarket_setupbreakout_qualityvolatility_expansionsector_strength market_regimeg333333?g?)trend structure) accelerationrelative_volume@I@dK<2()STRONG_VWAP_SUPPORT VWAP_RECLAIM VWAP_HOLDVWAP_EXTENSION VWAP_FLATVWAP_DECLINING VWAP_FAILURE?g333333?g??)STRONG_RISK_ONRISK_ONNEUTRALRISK_OFFSTRONG_RISK_OFFBREAKOUT_RETESTCOMPRESSION_EXPANSION@)weightstrend_structure_blendvolume_expansion_blendrelative_volume_saturation#volatility_expansion_saturation_pctno_sector_default_scorevwap_classification_scoresmarket_regime_creditno_market_regime_default_creditbreakout_setup_names breakout_quality_no_setup_creditvelocity_lookback_readingsscore_trend_threshold_per_min"score_trend_fast_threshold_per_minc@sveZdZUeed<dZeed<dZeed<dZeed<dZ eed<e e dZ e ed <d Z eed <e edZeed <d S)WinnerScoreReadingsymbol winner_scorevelocity_per_minacceleration_per_minSTABLE score_trend)default_factory breakdownFinsufficient_datamissingN)__name__ __module__ __qualname__str__annotations__rAfloatrBrCrErdictrGrHboollistrIrSrS+/var/www/screener/premarket/winner_score.pyr>:s      r>xreturncCstdtd|S)Nr@r&)maxmin)rUrSrSrT_clamp01FsrYpointscs~t|}|dkr dStdd|D|tdd|D|tfdd|D}tfdd|D}|r=||SdS)aBLeast-squares slope of `points` ([(elapsed_seconds, value), ...]) against real elapsed time -- the general form of indicators. linreg_slope() (which assumes evenly-spaced integer x=0..n-1), needed here because winner_score readings aren't guaranteed evenly spaced in wall-clock time the way 1-min bars are.r@cs|]}|dVqdS)rNrS.0prSrSrT Sz'_time_weighted_slope..csr\)NrSr]rSrSrTr`Trac3s$|] \}}||VqdSNrS)r^rUymean_xmean_yrSrTr`Us"c3s |] \}}|dVqdS)r[NrS)r^rU_)rfrSrTr`Vs)lensum)rZnnumdenrSrerT_time_weighted_slopeJsrnrBcfgcCsJ|d|d}}||krdS||krdS|| krdS|| kr#dSdS)Nr=r< RISING_FASTRISINGDECLINING_FAST DECLININGrDrS)rBrofastnormalrSrSrT _score_trendZs  rvsetupscCsd}|rdd|D}t|dddd}|dur#t|dds#|jnd}|dur?|j|d vr?t|jd |d d d St||d d d S)NcSsg|]}|jr|qSrS)valid)r^rrSrSrT jsz%_breakout_quality..cSs|jSrc) confidence)ryrSrSrTksz#_breakout_quality..)keydefaultrHFr@r9gffffff?g333333?Y@r:)valuesrWgetattrbreakout_pressure_scoresetuprYr{)rw compressionrobestrxpressurerSrSrT_breakout_qualitygsrNr?premarket_result score_historyc ) s@ddlm} m}it| ptdi} | p| |j} t|dds5t|dds5t|dds5t|ddr=t|ddgdS| d | d }|j |d |j |d }|d ur`t|dds`|j n| d}| d}|j d}|j d}t |pxdddd}t |pd| dd}||d||d}|j d}| d|d}| r| ddn| d}t|pi|| }|jd}|d urt |pd| ddn| d}| d}|d urt|dds|jd urt |jpdd d!d}|jdd"|d"}|d urt|dds| d#|j| d$n| d$d} ||||||||| d% fd&d'D}!t}"tt t|!|"dd(}#| pKgrXfd)d*Dng}$|$ri| ddnd|#ft|$}%t|%d+d,}&rd-d(nd}'t|&|'d,}(t||#|&|(t|&| d.d'Ddd/S)0a features/trend/structure/prediction: required, same readings the rest of this pipeline already computes. relative_strength: optional relative_strength_engine.RelativeStrengthReading. Omit to fall back to a neutral component (never a hard block, per the project's "sector confirmation is additional, not required" principle extended to RS in general when the market data isn't available yet). compression: optional compression_engine.CompressionReading. setups: optional {name: setup_engine.SetupResult} dict. market_regime: optional relative_strength_engine.MarketRegimeReading. premarket_result: optional scorer.score_premarket_candidate() dict for THIS symbol -- reuses its total_score directly as the premarket_setup component (the "premarket produces the thesis" fix). Omit if unavailable; falls back to a neutral 50. score_history: optional caller-held list of (timestamp, score, velocity_per_min) tuples, oldest first, NOT including this call's own reading -- see module docstring. Omit (or pass []) for a cold start (velocity/acceleration read as 0.0, trend as STABLE). r)datetimetimezonerArHFTz7one or more required upstream readings was insufficient)r?rHrIr0r1rrNr5r2volume_accelerationrr&g?g333333?rr@r3rclassificationr6r total_scorerrange_expansion_pctr4rr/r'r7r8r cs(i|]}|t||ddqS)rr[round)r^k) componentswrSrT s(z(compute_winner_score..r[cs*g|]\}}}|dd|fqS)r) total_seconds)r^ts_v)historyrSrTrzs*z(compute_winner_score..gN@cSsi|] \}}|t|dqS)r[r)r^rvrSrSrTrs)r?rArBrCrErGrH)rrDEFAULT_CONFIGrgetnowutcrr>score final_scorevolumerYvwapr volatilitysector_breadthsector_momentumregimerjrrappendrrnrvitems))r?featuresrr predictionr rrwrrrrrorrtbtrend_structure_scorers_scorevb vol_accelrvol accel_credit rvol_creditvolume_expansion_score vwap_classvwap_structure_scorepremarket_setup_scorebreakout_quality_scorerange_expansionvolatility_expansion_score sector_scoremomentum_creditmarket_regime_scorerG weight_totalrArZ slope_per_secrBprior_velocityrCrS)rrrrTcompute_winner_scoress          (r)NNNNNNNN)__doc__ dataclassesrr config_loaderrrr>rOrYrRrnrPrMrvrrrSrSrSrTsT