@i;dZddlmZddlZddlmZddlmZddlmZddl Z ddl m Z ddl mZdd lmZdd lmZdd lmZed GddZddZddZdZ ddZddZddZGddZy)a8 H4 bias pipeline. Two layers: 1. compute_algo_bias(df4) -> BiasData Deterministic EMA20/50 + HH/HL + RSI extremes (port V15 bias_computer.compute_algo_bias). Pure function. 2. compute_ai_bias(...) -> BiasData (async) AI override invoked ONLY when algo flags ambiguous=True (port V15 bias_computer.ai_override_bias). Silent fallback to algo on any error. 3. BiasResolver Stateful facade: dispatches algo + AI, persists outcomes to SessionState.bias_cache (BiasEntry), respects TTL on cache hits. Used by the orchestrator. Brain modules consume the resolved BiasData via TechSnapshot.bias / allowed_direction populated upstream. V16 layering rule: analysis/ does NOT import from brain/. The AI client is injected; a tiny inline JSON-extract helper avoids the dependency. ) annotationsN) dataclass)datetime)Optional)calc_atr)calc_rsi)utc_now)extract_json_from_response) BiasEntryT)frozencVeZdZUdZded<ded<ded<ded<dZd ed <dZd ed <y ) BiasDataaV H4 bias output (typed). bias: "RIALZISTA" | "RIBASSISTA" | "NEUTRO" allowed_direction: "BUY" | "SELL" | "BOTH" | "NONE" h1_compatibility: 0.3..1.0 h1_reason: human-readable ambiguous: True when algo is uncertain (can be fed to BrainBias later) rsi_h4_override: True when RSI H4 extreme triggered an override strbiasallowed_directionfloath1_compatibility h1_reasonFbool ambiguousrsi_h4_overrideN)__name__ __module__ __qualname____doc____annotations__rr$/home/work/apex_v16/analysis/bias.pyrr's3  INIt!OT!rrc"tddd|dS)NNEUTRONONE?Frrrrr)r)reasons r_neutror&;s     rc|t|dkr tdS|djdj}|djdj}t |dj d}t |j d}t |j d} t t |j d}|d kDrtd d d d |dddS|dkrtddd d |dddS||kDxr||kD}||kxr||k}|dj ddj|dj ddjtfdtdtD} tfdtdtD} tfdtdtD} tfdtdtD} | dk\xr| dk\} | dk\xr| dk\}|r| rtdddd| d | d!"S|r|rtd d dd#| d$| d%"S|r|stddd&d'| d(| d)| d*| d% "S|r| std d d&d+| d*| d,| d(| d! "S|r|s|r| rtd-d.d/d0|d1|d2d3Std-d.d4d5|d6d7|d6d8| d9| d3S#t$rd}YwxYw):a{ Algorithmic H4 bias from EMA(20/50) + structural HH/HL on last 8 bars. V15-parity overrides (priority over EMA/struct): RSI H4 > 80 -> RIBASSISTA, allowed SELL (overbought MR) RSI H4 < 20 -> RIALZISTA, allowed BUY (oversold MR) Returns: BiasData. ambiguous=True when EMA and structure disagree (a downstream BrainBias may resolve). Ninsufficient_h4_barsclosespan2gI@P RIBASSISTASELLg333333?zOVERRIDE: RSI H4 z.1fz > 80 (overbought extreme)T)rrrrr RIALZISTABUYz < 20 (oversold extreme)highlowc3@K|]}||dz kDsdywNr.0ihighss r z$compute_algo_bias..w$ H1a5Q<0GQ Hr9c3@K|]}||dz kDsdywr8rr;r<lowss rr>z$compute_algo_bias..x$ E1tAwa!e/DQ Er@c3@K|]}||dz ksdywr8rr:s rr>z$compute_algo_bias..yr?r@c3@K|]}||dz ksdywr8rrBs rr>z$compute_algo_bias..zrDr@?zEMA20>EMA50 H4 + HH/HL (z HH, z HL))rrrrzEMA20# 3B4tB4wrd$rdRVW   >$ 3B4tB4wrd$rdRVW    KN$ 6{m>R`Qaabc      .z#.>a 3?OuUWTXX\]_\`a  S s0!J:: K K u Sei un analista di mercato. Analizza questo contesto H4 e determina il bias. SYMBOL: {symbol} H4 Close recenti: {h4_closes} H4 EMA20: {ema20:.4f} EMA50: {ema50:.4f} H4 RSI: {rsi_h4:.1f} ATR H4: {atr_h4:.4f} Il calcolo algoritmico ha rilevato ambiguità ({algo_reason}). Decidi il bias finale. Restituisci SOLO JSON valido, zero testo fuori dal JSON: {{ "bias": "RIALZISTA" | "RIBASSISTA" | "NEUTRO", "allowed_direction": "BUY" | "SELL" | "NONE", "h1_compatibility": 0.3-1.0, "reason": "max 15 words" }}c 6K|t|dkr|S t|djdjjd}t|djdjjd}tt |jd}tt |jd}|djddjDcgc]}tt|d } }tj|| |||||jxsd } |j| d d{} | j|S tj t#| j} t)| t*rd| vr|S| j-d} | dvr|S| j-dd}|dvrd}| dk(rd} t| j-dd}t1dt3d|}t5| j-dddd}t7| ||d|ddScc}w#t$r|cYSwxYw7#t$r|cYSwxYw#tj$t&f$r|cYSwxYw#t.t&f$rd}YwxYww)a< AI override on ambiguous algo bias. Pure function (no state). Silent fallback to algo_result on: - df4 None or shorter than 10 bars - feature-extraction exception - AIResponse.text is None (any error_kind: credit / overload / invalid / unknown) - JSON parse failure - missing 'bias' field in AI response - bias not in {RIALZISTA, RIBASSISTA, NEUTRO} (V16 stricter than V15 which silently coerced unknown bias to NEUTRO; V16 prefers algo) Validation rules (V15-parity, see V15 bias_computer.py:254-262): - allowed_direction whitelist {BUY, SELL, NONE}; anything else (incl. "BOTH") -> coerced to NONE - bias=NEUTRO -> allowed_direction forced to NONE (V14 coherence rule preserved by V15) - h1_compatibility clamped to [0.3, 1.0] N r*r(r+r.r-r5rGr)symbol h4_closesrUrVrZatr_h4 algo_reasonrI) temperaturer)r2r0r!rr")r3r1r"r!rr#333333?rHr%overridezAI: Frrrrrr)rLrrMrNrOrrtolistroundrPAI_BIAS_PROMPTformatrasktextjsonloadsr JSONDecodeError ValueError isinstancedictget TypeErrormaxminrr) ai_clientrfrT algo_resultema20_vema50_vrsi_h4_vatr_h4_vcrgpromptrespai_datarallowedh1_compr%s rcompute_ai_biasrs4 {c#hmG ((b(1668==bABG ((b(1668==bAB#++B/0#++B/014W1B1B231G1N1N1PQAU58Q'Q Q " "W))8[ #F]]6s];; yy**7 BC gt $g(= ;;v D 88kk-v6G-- x $6<=#s3()G Xz2 3DS 9F  ! /  ]R <   * -$ z "sJCH<,H7H< *J5I I  IJ(I!A JJ/AJ7H<< I J I  J I IJIJ!I?<J>I??JJJJJc tdtdtt|jdz}t |j ||jxsdddtjS)z Persist subset of BiasData. ambiguous and rsi_h4_override are process flags, not output: intentionally NOT persisted. dNrm) direction confidence rationale computed_at) r}r~intrprr rrr isoformat)bdrs r_bias_data_to_entryr)sf RS#eB,?,?#,E&F"GHIJ &&<<%2t,I'')  rcdddj|jd}tdtd|jdz }t ||j||j dd S) z Reconstruct a BiasData from a persisted BiasEntry. The bias label is deterministically derived from allowed_direction (V15 mapping is 1:1 in compute_algo_bias and ai-override). Process flags reset. r2r0)r3r1r!rkrHgY@Frn)r{rr}r~rrr)be bias_for_dirrs r_entry_to_bias_datar7sk c",,!#s3  567G  ,, ,,  rc\eZdZdZdZded d dZd dZdddZddZdd Z dd Z dd Z y) BiasResolverab H4 bias dispatcher with AI override + per-symbol cache. Coordinates: 1. compute_algo_bias (deterministic algo) 2. compute_ai_bias (AI override on ambiguous; silent fallback) 3. SessionState.bias_cache (TTL persistence for cold start) Cache semantics (V15 parity, TTL=3600s): - resolve(symbol, df4) returns cached BiasData if BiasEntry.computed_at is within ttl_seconds; otherwise recomputes. - Cache writes happen for BOTH algo-only and AI-resolved decisions, so the next cold start finds them all (state v2 BiasCache). - resolve() does NOT save SessionState; the orchestrator owns the save after each tick (V15-BUG-9 discipline preserved). AI failure policy (silent fallback): - AIResponse.text is None / parse error / schema violation -> use algo. - state.brain.bias_calls_count is incremented when an AI call is ATTEMPTED (algo-ambiguous path), regardless of success. Failure rate is greppable from system.log via "[BIAS AI] {symbol} fallback". A dedicated bias_ai_failures_count is on BACKLOG. iN)logger ttl_secondsc<||_||_||_||_yN)rstaterr)selfrrrrs r__init__zBiasResolver.__init__gs!#  &rcK|j|}||S|t|dkr$tddddd}|j|||St |}|j r}|j jxjdz c_t|j||| d{}||us|j|jk(r|jd |d n|}|j|||S7Mw) Nr(r!BOTHr# no_h4_dataFr$r9)rrfrTrz [BIAS AI] z%: fallback algo (no override applied)) _cache_getrLr _cache_putrcrrbrainbias_calls_countrrr _log_warning)rrfrTcachedralgofinals rresolvezBiasResolver.resolvets(  M ;#c(R-"(!$& B OOFB 'I % >> JJ   - - 2 -).. E }4>> A!! (MNE & sB&C8(C6)AC8c|/|jjjjy|jjjj |dy)z JJ ! ! ) ) / / 1 JJ ! ! ) ) - -fd ;rc(|j|duS)z True iff there is a non-expired BiasEntry for symbol. Used by the orchestrator to skip the H4 REST fetch when resolve() will return the cached value anyway (df4 is unused on cache hit). N)rrs rhas_fresh_cachezBiasResolver.has_fresh_caches v&d22rc<|jjjj|}|y t j |j }t|z j}||jk\ryt|S#ttf$rYywxYwr) rrrr{r fromisoformatrr|rxr total_secondsrr)rrfentryrages rrzBiasResolver._cache_gets %%--11&9 = "001B1BCKy;&557 $"" ""5)) :&  sB BBc\t||jjj|<yr)rrrr)rrfrs rrzBiasResolver._cache_puts!0CB0G %%f-rc|jy |jjj|y#t$rYywxYwr)rsystemwarningrP)rmsgs rrzBiasResolver._log_warnings> ;;    KK   & &s +   s%5 AA)rrreturnNone)rfrrTzOptional[pd.DataFrame]rrr)rfz Optional[str]rr)rfrrr)rfrrzOptional[BiasData])rfrrrrr)rrrr) rrrrDEFAULT_TTL_SECONDSrrrrrrrrrrrrLsP0. '  '  ''R<3 *Hrr)r%rrr)rT pd.DataFramerr)rfrrTrrrrr)rrrr )rr rr)r __future__rru dataclassesrrtypingrpandaspdanalysis.indicators.atrranalysis.indicators.rsircore.contractsr core.json_parsingr persistence.state_storer rr&rcrqrrrrrrrrs,# !,,"8- $"""&hf&W W  W  W  W| *zzr