o 0z"compute_health..cSrM)vr.rOr.r.r/rRrSflat_slope_threshold_pctstructure_lookback_bars)lookbackcss|]}|dVqdS)hNr.rOr.r.r/ sz!compute_health..rr1stale_range_contraction_pct atr_periodr:)periodweights price_slopepositiveg?price_slope_flat_creditprice_slope_negative_credit)rarK vwap_supportvwap_support_partial_creditvwap_support_weak_creditstale_volume_decline_ratio volume_participation_rvol_targetvolume_participation!volume_declining_score_multiplierstructure_mixed_credit structurerange_expansion"range_contracting_score_multiplier!max_distance_from_recent_high_pctdistance_from_recent_highdnegativeno_new_highs_threshold_pct) rBhigher_highs_higher_lowslower_highs_lower_lowsvolume_decliningrange_contractingrvolr no_new_highsmomentum_fadingrrrzr) rrrrrrr r!r"r#r%r&)rr3r<rrr rrArr r sumr r r2rrrr7valuesroundrF).rrGrHrDrXwindowr8volumes current_pricev_wapvwap_serrrr flat_threshr!r"r#rBstruct_lookbackhh_hlrC total_volumery vol_accel recent_highdist_from_high tight_recenttight_earlier_bars tight_earlierrxawr%rdrw rvol_targetstructure_creditmax_disttotal max_possiblerr{r&severerr.r.r/compute_healths         $      .rFreading persistedrc Cstd}|dd}|dd}|dd}|dd}|jdv}|jd k} |jd v} |r2|d nd}| r:|d nd}| rB|d nd}|} |d krMd } n@|rRd } n;|r]||dkr]d } n0| rh||dkrhd } n%|jdkrt|d vrtd} n|jdkr|dkrd} n |jdkr|d kr| sd} | r||dkrd } | d kr|d ks|d kr||dkrd } | |krtd|jd|d| d|jd|jd|jd | ||||j|j|j|j t t j d S)a Applies hysteresis on top of a single raw reading. `persisted` is this symbol's existing entry from state/intraday_health.json (a fresh {} if never seen before). Returns the new persisted entry; caller is responsible for saving it back via data_store. rstaterconsecutive_badrconsecutive_goodconsecutive_deteriorating)rrrrr:rrunhealthy_confirm_readshealthy_confirm_readsr"remove_after_consecutive_unhealthyz [HEALTH]  z -> z (score=z, price_slope=z , vwap_slope=)) rrrrrr!r"r# updated_at)rgetrloginforrr!r"r#rnowrutc isoformat) rrrrD prev_staterrr is_bad_read is_good_readis_deteriorating_read new_stater.r.r/update_health_state+sb          rpersisted_statec Csftd}t|||}t|j|jdd|jdd|}||i}t|||d}|d|_||fS)a Convenience wrapper: compute this instant's reading, apply hysteresis against the persisted state for this symbol, and return (HealthReading with confirmed_state filled in, new_persisted_entry). Does not touch disk -- caller batches the save. rrBFrv)rr)rrrFrr&rrr) rrGrHrrDrrentry new_entryr.r.r/evaluate_symbol{s    r health_statecCs|t}g}|D]\}}|d}|r!tt||kr&||q |D]}||=q)|rsB<  4   ,P "