o yj@sdZddlmZmZddlmZdZdZdZdZdd d d d Z eGd ddZ ddZ dde de dedededede fddZdS)a exit_resistance_timer_experimental.py [2026-09-19] NOT wired into monitor.py's live loop -- backtest-only. User's proposed design (2026-09-19), deliberately simpler than exit_prf_experimental.py's multi-stage confirm-count state machine: once price stops printing new highs, check whether trade imbalance is still positive (buyers still active). If so, that's "at resistance" -- start a fixed real-time clock (recovery_window_seconds). If price hasn't made a new high by the time that clock runs out, exit. No confirm-read voting, no structure (lower-highs/lower-lows) layer, no strong-imbalance floor -- just "resistance detected -> wait N seconds for a new high -> exit if none came." Time-boxed in wall-clock seconds (not poll counts), since poll cadence isn't guaranteed constant (config's poll_interval_seconds=5 is the target, but real logged poll times drift -- see simulate.py's load_real_poll_times docstring). state_in carries the resistance-start timestamp as an ISO string so evaluate() stays a pure function of its inputs, same convention as exit_prf_experimental.py's state_in/state_out. Reversible exactly like PRF: any poll that prints a fresh peak high cancels the timer outright, no matter how much of the window had elapsed. ) dataclassfield)datetimeNORMAL AT_RESISTANCEHOLDEXITg@g333333?gN@) min_mfe_pctresistance_band_pctresistance_imbalance_thresholdrecovery_window_secondsc@s^eZdZUeed<eZeed<dZeed<dZ eed<e e dZ e ed<e e dZ e ed <d S) ResistanceTimerDecisionsymbolstateF should_exitreason)default_factorymetrics state_outN)__name__ __module__ __qualname__str__annotations__ STATE_HOLDrrboolrrdictrrrr=/var/www/screener/trade/exit_resistance_timer_experimental.pyr+s    rcCsit|piSN)DEFAULT_CONFIG)cfgrrr _merge_cfg5sr$Nrbars entry_pricenow_tsstate_inr#returnc Cst|}t|pi}t|dkrt|d|dS|dd}|d|}t||} ||k} |d} |d} |r@| ||d nd } | |d k}|t| d t| d|| || d }d| i}|sxt|td| dd|d d|i|ddddS| r| rd|ddnd|dd}t|t||i|ddddS|durt|| rtntd|i|| | ddS||dk}|| d|dd k}| ||d| dur |r|rt|td| dd |d!d"|d#d$d%|i|| | ddSt|td&|d!d|i|ddddS|t |  }t|d|d'<| r&| || d nd }t|d|d(<||d#krZt|td)d*|d#d$d+| dd,|d$d-|dd |i|dddd.St|td| dd/|d$d0|d#d$d1|dd2 |i|| | ddS)3a bars: same short rolling 1-min-bar window exit.py/exit_prf_experimental.py take. trade_imbalance: stream.py's get_trade_imbalance() live read, None on a cold buffer (fails open -- holds whatever state was already in progress). now_ts: this poll's timestamp (UTC datetime) -- the recovery window is measured against this, not a poll count. state_in: caller-held state fed back every poll -- {"peak_price", "resistance_since" (ISO string or None), "peak_at_resistance"}. Fresh {} at entry. zinsufficient bar data)rrrc peak_priceresistance_sincepeak_at_resistancegY@r r )pricer-mfe_pctarmed made_new_hightrade_imbalanceresistance_since_inznot armed yet (MFE z.2fz% < z%)N)r.r/)rrrrrz new high $z.4fz -- resistance timer cancelledzmaking new highs ($)z&no imbalance data this poll -- holdingr r )imbalance_positiveat_resistance_bandzat resistance $z , imbalance z+.0%z) still positive, no new high -- starting r z.0fzs recovery timerzIno new high but not at-resistance-with-positive-imbalance yet (imbalance elapsed_seconds giveback_pctTzno recovery within zs of hitting resistance at $z (z's elapsed, still no new high, giveback )rrrrrrz, /z)s elapsed waiting for recovery, giveback %)r$rlenrgetmaxroundrSTATE_AT_RESISTANCEupdate isoformatr fromisoformat total_seconds STATE_EXIT)rr%r&r5r'r(r#r1 prior_peakr-r4r.r/r2r3r base_staterr9r:elapsedr<rrr evaluate9s              rLr!)__doc__ dataclassesrrr STATE_NORMALrCrrHr"rr$rlistfloatrrLrrrr s2