o ̿SiG9@sddlmZddlZddlmZddlmZddlmZmZm Z m Z m Z d9d d Z d d dd:ddZ d;ddZdd)d*Zd?d,d-Zed.d/Gd0d1d1Zdd2d@d7d8ZdS)A) annotationsN) dataclass)datetime)AnyDictListOptionalTuplevrreturnOptional[float]cCsdz'|durWdSt|trWdSt|}||ks"|tdtdfvr%WdS|WSty1YdSw)Ninf-inf) isinstanceboolfloat Exception)r fr:/var/www/html/Trade-python/app/v1/services/entry_engine.py _safe_float s  rgeA min_value max_valuenamestrdefaultrrrcCst|}|dust|dkrt|Sz tt|}Wn ty,t|YSw||ks;|tdtdfvr?t|Stt|t||S)Nr r)osgetenvrstriprrmaxmin)rrrrrawr rrr _env_floats   r% market_dataDict[str, Any] timeframeList[Dict[str, Any]]cCsLt|tsgS|d}t|tsgS||}t|tsgSdd|DS)NcandlescSsg|] }t|tr|qSr)rdict.0crrr -sz _get_candles..)rr+getlist)r&r( candles_by_tfarrrrr _get_candles$s     r4r.keycCs t||p||ddS)N)rr0)r.r5rrr _candle_num0s r7r*lookbackint'Tuple[Optional[float], Optional[float]]cCs~|sdStdt|}|| d}dd|D}dd|D}dd|D}dd|D}|r4t|nd|r.cSr;)lowr=r,rrrr/:r>cSg|]}|dur|qSNr)r-hrrrr/;cSr@rAr)r-lrrrr/<rC)r"r9r#)r*r8windowhighslowsrrr_swing_high_low4s"rH preferredfallbackcCsXt|tr |dnd}t|tsiS||fD]}||}t|tr)|r)|SqiS)N indicators)rr+r0)r&rIrJindtfsrrr_latest_indicator_summary@s   rODict[str, float]cCsrt|tr |dnd}t|tsiS|d}t|tsiSi}dD]}t||}|dur6t|||<q#|S)Npivotsday)R1R2R3PS1S2S3)rr+r0rr)r&rQrRoutkr rrr_get_pivots_dayKs    r\T)frozenc@sFeZdZUded<ded<ded<ded<ded <d ed <d ed <dS) ExecutionPlanrP entry_zonez List[str]entry_trigger_reasonr slz List[float]targetsrr_ratiorstater' diagnosticsN)__name__ __module__ __qualname____annotations__rrrrr^[s  r^)now_utcdecisionrjOptional[datetime]Optional[ExecutionPlan]c8 s |pd}|dvrdS|pt}tddddd}ttd d d d d}td dddd}tddddd}t|d}t|d} t|d} t|dd} t| dt rX| dni} t | d} t | d}t | d}t | d}t |}d}d}| dur|durt t| t|}tt| t|}|dkr|dkr||kr||d}d}n ddd}nddd}| dddks| dddkrf|dkrdD]}||vrt||}d |}nqnd!D]}||vrt||}d |}nq|dur;| r;t| d"kr | d#n| d$}t|d}t|d}|dkr+|dur+t|}d%}n|d&kr;|dur;t|}d'}|durK|durKt|}d(}|durf|dkrft|d)|t|d)|d}t|pk| |d*\}}d}d}| r| d$}t|d}t|d}d} g}!|dkr g}"|dur|"t|d+|vr|"t|d+|dur|"t||"rt|"} d,D]}||vr|!t||qt| dpdfd-d.|!D}!|!s |dur|kr|!t||dur |kr |!t|n{g}"|dur|"t|d/|vr'|"t|d/|dur3|"t||"r:t |"} d0D]}||vrL|!t||qnd?|'r3d@}(d}1| dur|!rt| dpEdt| dpNddA}2t|!d}3|dkri|2t| }4|3|2}5n t| |2}4|2|3}5|4dkr|5dkrt|5|4dB}1|| |||||||dCdD }6g}7|(d2kr|*r|*d$}+t|+d}.t|+d}/t| dpdt| dpd|dkr|.durdkr|.d)|kr|7|)dkrdEndF|d&kr|/durdkr|/d)|kr|7|)dkrdGndH|7r|7|6dI<|)r|)|6dJ<tt| dpdt| dp(dd|'| dur5t| nddKd.|!D|1durEt|1nd|(|6dLS)MaRule-based execution plan. - Does NOT use LTP/current price as entry. - Produces an entry_zone + trigger-based activation state. - SL/Targets are derived from pivots + recent swings (structure). This function is intentionally deterministic and read-only. r>BUYSELLNENTRY_ZONE_BUFFER_PCTgMbP?rg{Gz?rENTRY_SWING_LOOKBACK g@gi@ENTRY_MISSED_PCTg{Gz?g?ENTRY_SL_BUFFER_PCT5minute15minuterRema921vwapcloser)r?r<EMA_PULLBACK_ZONEr?r<rn)rSrVPIVOT_)rWrVPREV_15M_HIGH_BREAKOUTroPREV_15M_LOW_BREAKDOWNFALLBACK_CLOSE_LEVELg?)r8rW)rSrTrUcsg|]}|kr|qSrrr-t) zone_highrrr/rCz(build_execution_plan..rS)rWrXrYcsg|]}|kr|qSrrr)zone_lowrrr/rCWAITING_FOR_ENTRYopen5M_CLOSE_ABOVE_ZONE15M_CLOSE_ABOVE_ZONE5M_GAP_OPEN_ABOVE_ZONE15M_GAP_OPEN_ABOVE_ZONEBREAKOUT_RETEST_HOLDBREAKOUT_RETEST_HOLD_15M5M_CLOSE_BELOW_ZONE15M_CLOSE_BELOW_ZONE5M_GAP_OPEN_BELOW_ZONE15M_GAP_OPEN_BELOW_ZONEBREAKDOWN_RETEST_HOLDBREAKDOWN_RETEST_HOLD_15MENTRY_ACTIVATEDg@Z) ref_reasonema9ema21rzr{ swing_high swing_lowrQ computed_atPRICE_RAN_UP_WITHOUT_TRIGGER PRICE_RAN_UP_WITHOUT_TRIGGER_15MPRICE_DROPPED_WITHOUT_TRIGGER!PRICE_DROPPED_WITHOUT_TRIGGER_15Mmissed_trade_reasonstrigger_timeframecSsg|] }|durt|qSrA)rrrrrr/zs)r_r`rarbrcrdre)r!upperrutcnowr%r9r4rOrr0r+rr\r#rr"lenr7rHappendrround isoformatr^)8rkr&rjdzone_buffer_pctswing_lookback missed_pct sl_buffer_pct candles_5m candles_15m candles_dayrLrwrrrzr{piv ref_levelrr?r<r_r[prev prev_highprev_lowrrday_highday_lowlast_dayrarb candidateszlzhmax_okmin_okreasonsrd trigger_tftrigger_candleslastc_openc_closec_highc_low prev_closerrzone_midt1riskrewardremissedr)rrrbuild_execution_planfs        "                 2         <,  <,         00( r)r rr r ) rrrrrrrrr r)r&r'r(rr r))r.r'r5rr r )r*r)r8r9r r:)r&r'rIrrJrr r')r&r'r rP)rkrr&r'rjrlr rm) __future__rr dataclassesrrtypingrrrrr rr%r4r7rHrOr\r^rrrrrs