JjZ>6ddlmZddlmZmZddlmZddlmZddlm Z m Z ddl m Z m Z ddlmZmZddlmZdd lmZdd lmZdd lmZmZmZdd lmZmZdd lmZddl m!Z!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2d Z3d!S)") annotations)datetimetimezone)Decimal)summarize_l2_book)build_market_confluence_reportscore_coin_confluence)CoinMarketContextMarketContextSnapshot)event_risk_from_news_itemsload_event_risk_context)CoinGeckoFundamentalsClient) build_normalized_market_snapshot)!_build_research_sentiment_context)append_snapshotenrich_with_derivatives_deltas write_latest)collect_news_event_riskparse_rss_itemsclassify_market_rows) build_reportc idddtddtddtdd td d td d tddtddtddtjtjdtddddddtddtddtdd td!tdtd"td#td#td$td$td%td%d&}||t d'i|S)(NcoinBTCrsi55sma_fast101sma_slow100atr1.2funding0volume50000000mid102 spread_pctz0.03 timestampreliability_scorez0.99 stale_dataF l2_availableT open_interest12345.67premiumz0.00002 oracle_pxz102.0mark_pxz102.057500000050000z0.02z0.04) prev_day_px day_ntl_vlmbid_depth_notional_5ask_depth_notional_5buy_impact_1k_pctsell_impact_1k_pctbuy_impact_5k_pctsell_impact_5k_pct)rrnowrutcupdater ) overridesdatas tests/test_market_confluence.pyctxrEs   wt}}  GENN  GENN   wu~~   73<<   '*%%  wu~~  gfoo  X\(,//  WV__  e    ,,  79%%  WW%%! " 78$$# $u~~z** ' 0 0 ' 0 0$V__%foo$V__%foo3   D6 KK   $ $t $ $$ctt}|jtdksJ|jdksJ|jdusJ|jdusJ|jdksJdS)N60paper_candidateFr>)r rE final_scorerrecommendationlive_order_allowedmainnet_signed_actionblockersscores rD7test_score_coin_confluence_accepts_clean_retest_contextrQ3s !#%% ( (E   - - - -  #4 4 4 4 4  #u , , , ,  &% / / / / >R      rFc ptttdtdtdtddtdtd}|jdksJd|jvsJd |jvsJd |jvsJd |jvsJd |jvsJdS) N825000000z0.20Fz0.18)rr&r7r*r.r:r;block_new_entrymomentum_overheatedweak_liquidityspread_too_widel2_unavailableimpact_slippage_too_high)r rErrKrNrOs rD@test_score_coin_confluence_blocks_overheated_or_illiquid_contextr[=s !#'$-- @R@R`ghq`r`r@GHN@O@O^cw~EwFwF[bci[j[j#k#k#k l lE  #4 4 4 4 4 EN 2 2 2 2 u~ - - - -  . . . . u~ - - - - % 7 7 7 7 7 7rFctdddddddgddddddggi}|jJ|jtdksJ|jtd ksJ|jJ|jJdS) Nlevels9920)pxsz98rr)39404060)rr*r8rr9r:r;)summarys rD2test_summarize_l2_book_calculates_depth_and_impactrfHsD ! !$d#;#;<T " "5$=$=>,!G   ) ) )  '76?? : : : :  '76?? : : : :  $ 0 0 0  % 1 1 1 1 1rFc >tttdtdtdtd}|jdksJ|jtdksJd|jvsJd |jvsJd |jvsJdS) Nz0.00018z0.0015r!z100.4)r$r1r2r3rUrHcrowded_positive_fundingpremium_too_highmark_oracle_basis_wide)r rErrKderivatives_scorerNrOs rD=test_score_coin_confluence_blocks_crowded_derivatives_contextrlUs !#gi.@.@'RZJ[J[gnotgugu@GHO@P@P#Q#Q#Q R RE  #4 4 4 4 4  "WT]] 2 2 2 2 % 7 7 7 7  / / / / #u~ 5 5 5 5 5 5rFc ~tjtdtdtdtdtdtdtd td td  g}t |}|}|jd vsJ|jdksJ|ddusJ|ddusJ|ddksJd|dvsJ|ddddksJd|ddvsJd|ddvsJd|ddvsJd|ddvsJd|ddvsJ|ddd|dddksJ|dddd ksJdS)!NrrETHrr!103)rrr r(WLD803000000z0.15)rrr&r*>risk_on selectiverLFrM score_versionconfluence_score.v1riskweightsscoresrKrIrksentiment_scoreevent_risk_scoreportfolio_score risk_scorefinal_trade_scorerJrU)r from_coin_contextsrErrto_dict market_regimeeligible_count)snapshotreportrCs rD>test_build_market_confluence_report_sets_regime_and_serializesr_s$7  '%..gV[nn]]] GDMM')2D2DQXY_Q`Q`aaa9H ,H 5 5F >>  D  #; ; ; ; ;  A % % % % $ % . . . . ' (E 1 1 1 1  $9 9 9 9 9 T)_ $ $ $ $ >% !1 26G G G G G $x."7 7 7 7 7 Xu 5 5 5 5 5 h!6 6 6 6 6 Xu 5 5 5 5 5 4>%0 0 0 0 0 >% !4 5h9N}9] ] ] ] ] >% !1 26G G G G G G GrFc Jtjtdtdtdtdtddg}t |}t ||}|d d}|d d ksJ|d d usJ|dd usJtgd|sJ|dddksJ|dddksJ|dddksJt|ddtdksJt|ddtdksJt|ddtdksJ|dddksJ|dd d!ksJ|d"d d!ksJ|d#d d!ksJt|d"dtd$ksJt|d%dtdksJ|d&d'd(ksJ|d&d)|d&d*ksJ|d&d+d,ksJdS)-Nrz0.00012z0.0012)rr$r1roz0.12T)rr*r.coinsschema_versionzmarket_snapshot.v1rLFrM) priceohlcvtrendmomentum volatility liquidity derivatives fundamentals sentiment event_riskregimery confluencersourcehyperliquid_metaAndAssetCtxsr$z 0.00012000r/r0rPr%rr:z0.0200r;crowding_state crowded_longrstatus not_loadedrr50.00ryrrwrxrrJrKrU) r rrErrrrsetissubset)rr normalizedbtcs rDKtest_build_normalized_market_snapshot_exposes_phase2_schema_and_derivativesrys$7  2 2GH > > > 3{#$78 9 9WX=N=N N N N N 3{#$89 : :gh>O>O O O O O } . /> A A A A ~ x (L 8 8 8 8 { H % 5 5 5 5 | X &, 6 6 6 6 3{#G, - -1A1A A A A A 3v;w' ( (73<< 7 7 7 7 | _ -1F F F F F | 0 1S5F}5U U U U U | - .2C C C C C C CrFcGdd}t|d}|d}|jdksJ|ddksJ|ddksJ|d d ksJ|d d ksJ|d dksJ|ddksJ|ddksJ|ddksJ|ddksJ|ddksJdS)NceZdZdddZdS)Stest_coingecko_fundamentals_client_maps_public_market_fields..FakeTransport )timeoutc<d|dvsJdddddddd d d dd d d gS)Nbitcoinidsi2g@gg?g)@d) id market_capfully_diluted_valuation total_volumemarket_cap_rank'price_change_percentage_24h_in_currency&price_change_percentage_7d_in_currency&price_change_percentage_1h_in_currency'price_change_percentage_30d_in_currencyathatlcirculating_supply total_supplyr>)selfurlparamsrs rDgetzWtest_coingecko_fundamentals_client_maps_public_market_fields..FakeTransport.getsRu ----"+/ "#$;>:?:=;?&( " rFN)__name__ __module__ __qualname__rr>rFrD FakeTransportrs0.0       rFr)rrloadedrcoingecko_marketsr coingecko_idrmarket_cap_usd1000rrprice_change_1h_pctz0.5price_change_30d_pctz12.5ath_usdr!atl_usd1fdv_to_market_capr#)rcollectfor_coinr)rrrs rDU " " " " y>S " #u , , , , , ,rFc tjtdg}t|}t ||dddddidddd d d idd dd ddi}|dddddksJ|dddddksJ|dddddksJ|ddddd ksJ|ddddd ksJdS)Nrrnrrr)rrr&tradingview_community_research_contextloaded_research_onlyrrv)rrrPrecent_ideas_countnews_search_research_contextgreen80.00)rr risk_levelrP)rrrrrrrrrrr)r rrErrr)rrrs rD;test_normalized_market_snapshot_accepts_loaded_fundamentalsrsx$7%8IJJH/99J1(;xdeffg%MYo{BZ[\\]&DPfv}IPQQR  gii  g u %n 5h ?8 K K K K g u %n 56G HA M M M M g u %k 28 <@V V V V V g u %k 23G HA M M M M g u %l 3L AW L L L L L LrFc^|dz }||dz ddtdt|\}}|dd d ksJ|dd d ksJ|dd dusJ|dddusJ|d dusJdS)Nresearchz!tradingview_community_ideas.jsonlzY{"coin":"BTC","bias":"bullish","live_order_allowed":false,"mainnet_signed_action":false} utf-8encoding)rro)r runtime_dirrrrrr research_onlyTrLF)mkdir write_textrstr)tmp_path research_dirrowsres rD0test_research_sentiment_context_is_research_onlyrsj(L77CCEalsCttt5NX[\dXeXefffMD' ;x $L L L L L ;+ , 1 1 1 1 ; '4 / / / / ;+ , 5 5 5 5 ? #t + + + + + +rFcfd}t|dd}tdd}td|}td|}t |d ksJ|d d vsJ|d d ksJ|d dusJ|ddusJdS)Na} Bitcoin rallies before FOMC decisionCrypto traders watch CPI and Fed risk.https://example.test/btc Solana bridge exploit reportedSOL ecosystem exploit risk.https://example.test/sol unit)rSOL)rrr>)feedsrrrrvr>redyellowrrLFrM)rrr rlen)rssitemspayload manual_btc manual_sols rDAtest_news_event_risk_collector_parses_rss_and_stays_research_onlyrs C Cn E E EE%BnEEEG+E599AACCJ+E599AACCJ u::???? l #'8 8 8 8 8 l #u , , , , ' (E 1 1 1 1 * +u 4 4 4 4 4 4rFcldddddiddd}|dz }|d z }t||t|||d d d ksJt d|d }|ddusJ|ddusJdS)N2026-07-05T00:00:00+00:00rr%r)r$r/Fr+rrLrMzderivatives_history.jsonlzderivatives_latest.jsonrr rjsonrLrM)rr read_textcount __import__loads)rrhistorylatestrs rD6test_derivatives_history_writers_emit_jsonl_and_latestrs75VYloJpJpBqJOjoppG44G 1 1FGW%%%!!!   g  . . 4 4T : :a ? ? ? ?    % %f&6&6&6&H&H I IF & '5 0 0 0 0 ) *e 3 3 3 3 3 3rFcddddddiddd}d dd d d did g}t||d}|dd}|ddddksJ|ddddksJ|ddksJdS)Nz2026-07-05T01:00:00+00:00r110z0.00006z0.0006)r/r$r1Frrr!z0.00001z0.0001)r+r)<)windowsrderivatives_deltas60mopen_interest_change_pctz10.0000funding_changez 0.00005000crowding_alertneutral)r)rrenrichedrs rD3test_derivatives_history_enriches_oi_funding_deltasrs75\anwEMKNKNCOglGLMMG8E]boxFNLOLODPQQRG-gwNNNH 7 E "C # $U +,F G9 T T T T # $U +,< = M M M M  I - - - - - -rFcdgddddg}td|}|ddksJ|d d ksJdS) NMARKETz"Crypto market watches FOMC and CPIzFed macro riskcrypto_news_rsssymbolstitlerecategoryrrrrPrr r)rrs rD3test_event_risk_market_macro_is_yellow_not_coin_redrst".R_o~OPP QE $UE 2 2 : : < ).0rows rD zOtest_coin_opportunity_radar_detects_hl_movers_research_only..)s 0 0 0cCM 0 0 0rFsharp_1h_selloffrreasonscoingecko_trendingrLFrMr)r candidatess rD;test_coin_opportunity_radar_detects_hl_movers_research_onlyr9 s5 9QRdmZ[HJZ^ _ _ZX[mq^`MO P P(qbkXZGJ K K D &du~Y^X_```J 0 0Z 0 0 0UEN B B B B Ay!9 9 9 9 9 :a=#; ; ; ; ; a=- .% 7 7 7 7 a=0 1U : : : : : :rFc|dz dz }|d|dz dd|d z d d|d z |d z d z d dt||dz d}|dd}|ddusJ|ddksJ|ddddksJ|ddksJdS)N experiments"candidate_v76_fee_aware_anti_chaseT)parentszsignal_journal.jsonlz{"final_decision":"blocked:confluence_block_new_entry","would_enter":false,"block_reason":["confluence_block_new_entry","tv_bias_bearish"],"confluence_gate":{"score":"55"},"tradingview_context":{"available":true}} rrztrade_journal.jsonlz&{"event":"exit","net_pnl_usd":"0.10"} reportszmarket_confluence_latest.jsonz>{"confluence":{"market_regime":"risk_off","eligible_count":0}}r) runtime_rootexperiment_rootlimit strategiesrLF signals_seenr top_blockersrconfluence_block_new_entrytv_available_signals)rrr)rexprr3s rD6test_confluence_gate_impact_report_summarizes_blockersrH0sX ] "%I ICIIdI !!-- b.  ,,-Vah,iii   """ ;;GGIIT[G\\\ xMAYac d d dF  C DC & '5 0 0 0 0 ~ ! # # # # ~ q !! $(D D D D D % &! + + + + + +rFN)4 __future__rrrdecimalrsrc.hyperliquid.market_datarsrc.market.confluencerr src.market.contextr r src.market.event_riskr r src.market.fundamentalsrsrc.market.snapshotr"src.tools.market_confluence_reportr'src.tools.derivatives_history_collectorrrr#src.tools.news_event_risk_collectorrr src.tools.coin_opportunity_radarr'src.tools.confluence_gate_impact_reportrrErQr[rfrlrrrrrrrrrrr#r9rHr>rFrDrVsN""""""''''''''999999WWWWWWWWGGGGGGGGUUUUUUUU??????@@@@@@PPPPPPqqqqqqqqqqXXXXXXXXAAAAAA@@@@@@%%%@   888 2 2 2666HHH4DDD>!-!-!-HMMM$ , , ,555$ 4 4 4 . . .######### ; ; ; ,,,,,rF