6Jia UdZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl Z ddl Z ddl mZddlmZmZmZddlmZedZd Zd Zd Zd ZeGd dZeGddZeGddZdedededefdZ dede!eeffdZ"dCdedede!eeffdZ#GddZ$e$d e$dd Z%e&ee$fe'd!<gZ(e)ee'd"<da*e jVdze'd#<de jVfd$Z,d%Z-d&Z.d'Z/eZ0e0jcd(e)d*Z2e0jgd+d,efd-Z4e0jkd.d/Z6d0Z7e8d1k(re9d2d3e9d4e9d5e9d6e9d7e9d8e9d9e9d:e9d3e9d;e9d<e9d=e9d>e9d3d2e jte0d?d@dAByy)Du Turbo Dashboard — Green-on-black terminal-style trading interface. BTC 5MIN + 15MIN prediction markets on Monad with Pyth oracle. Run: python backend/dashboard.py Open: http://localhost:8080 N) dataclassfield)Path) load_dotenv)FastAPI WebSocketWebSocketDisconnect) HTMLResponsez3https://hermes.pyth.network/v2/updates/price/latestB0xe62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415b43i@B?c"eZdZUeed<eed<y)LevelpricesizeN)__name__ __module__ __qualname__int__annotations__floatbackend/dashboard.pyrr(s J KrrcReZdZUeeZeeed<eeZeeed<y) OrderBookdefault_factorybidsasksN) rrrrlistrrrr rrrrr-s(d3D$u+3d3D$u+3rrceZdZUdZeed<dZeed<dZe ed<dZ eed<dZ eed <d Z e ed <ee Zeed <ee Zeed<dZe ed<dZe ed<y) MarketState market_idinterval strike_pricer start_timeend_timeFresolvedryes_bookno_bookyes_posno_posN)rrrr%strrr'rr)rr*r+r,boolrrr-r.r/r0rrrr#r#2spIsHcL%JHcHd :Hi:y9GY9GUFErr#r' boundary_tsstrikereturnc d|d|dt|dz}dtj|jj ddzS)Nz TURBO-BTC-zm--g.A0x)rhashlibsha256encode hexdigest)r'r3r4raws rgenerate_market_idr?@sN xj;-qVc\1B0C DC '...88:3B? ??rinterval_minuteschttj}|dz}||z|z}||z}||fS)z2Get current market window [start, end] timestamps.<)rtime)r@now interval_secsstartends rget_current_boundaryrHEs? diik C$r)M M !] 2E - C #:r mid_price spread_centscddlt|tz}t|z }t|tzdz dtdtffd }||||fS)z6Generate mock YES and NO orderbooks around a midpoint.rNmidr5c pg}g}ttD]}|z |dzz }|z|dzz}|dkDr6|jt|t j ddd|t ks^|jt|t j dddt||S)Nir rrrr )range OB_LEVELSappendrrounduniform PRICE_SCALEr)rMrr ibpap half_spreadrandoms r make_bookz%generate_mock_book..make_bookUsy! SA{"QX-B{"QX-BAv Ev~~a7La1PQRK Ev~~a7La1PQR  Sd..r)r]rrXr)rIrJyes_midno_midr^r\r]s @@rgenerate_mock_bookraNs])k)*G 7 "Fl[0367K /s /y / W y0 00rcXeZdZdZdefdZdefdZdZdZ defd Z de fd Z d efd Z y )TurboMarketManagerz'Manages one BTC market (5min or 15min).r'c||_t||_d|_d|_g|_d|_d|_d|_y)N)r'r(r Ttk) r'r#mkt btc_pricepyth_mid log_linespausedstrategyrJ)selfr's r__init__zTurboMarketManager.__init__ks@  1 #" $&  !"rmsgctjd}d|d|jd|}|jj |t |jdkDr|jdd|_t |dy) Nz%H:%M:%S[z] [BTC/zm] iTflush)rCstrftimer'rjrUlenprint)rmrotslines r_logzTurboMarketManager._logusk ]]: &2$gdmm_Cu5 d# t~~  #!^^CD1DN d$rct|j\}}t|j||jxsd}|jj |k7r|jdkDr|jj }t ||j|j|||_|r |jd|jdy|jd|jdyyy)z*Create or rotate to current market window.ipr)r%r'r)r*r+uMARKET ROTATION → Strike: $z,.2fuNEW MARKET → Strike: $N)rHr'r?rhrgr%r#rz)rmrFrG expected_idolds rcheck_market_rotationz(TurboMarketManager.check_market_rotation}s)$--8 s(t~~?VQVW 88   ,!1C(($$C"%!^^  DH 9$..9NOP 4T^^D4IJK2D ,rc |jdks|jjsy|jjdkDr\|j|jjz |jjz }t dt dd|dzz|_nd|_t|j |j\|j_ |j_ y)z?Update orderbooks (mock for now, real when contracts deployed).rNg?gffffff?r r ) rhrgr%r)maxminrirarJr-r.)rmdiff_pcts r update_bookszTurboMarketManager.update_bookss >>Q dhh&8&8  88 1 $)>)>>$((BWBWWHc$hl0B&CDDMDM.@PTPaPa.b+488+rr5c|jjdk(rytd|jjtt jz S)Nr)rgr+rrrC)rms rtime_remainingz!TurboMarketManager.time_remainings> 88   !1dhh''#diik*::;;rcTdtdtfd}|j}|j|jj r|jj dddznd|jj |j|j|dzd|dzd |||jj||jj|jj|jj|j|j|j|j d dd S) Nbookr5c|jdtDcgc]}|j|jdc}|jdtDcgc]}|j|jdc}dScc}wcc}w)NrQrR)rrTrrr )rls r book_to_listz0TurboMarketManager.to_dict..book_to_lists`EIYYzPYEZ[177AFF;[EIYYzPYEZ[177AFF;[ [[s A2 A7r9z...r$rB:02di)r'r%r4rhrirseconds_remainingr-r.r/r0rkrlrJlogs)rdictrr'rgr%r)rhrir-r.r/r0rkrlrJrj)rmrtrs rto_dictzTurboMarketManager.to_dicts y T   " <@HHr>(+D%II C523"'  +  s6C)E ,*D6E D63E 6EE EE N)rrr__doc__rrnr1rzr~rrrrrrrrrcrchsM1##  L& c<<   4rrcr&)r r&managers ws_clients _http_clientcnKttjrtjdatSw)Ng@)timeout)r is_closedhttpx AsyncClientrrrget_httprs*|55((5 s35cK td{}|jtdtid{}|j |j }|jdrB|ddd}t |dd|d zz}tjD] }||_ tjd d{77#t$r}td |d Yd}~@d}~wwxYw7/w) z*Fetch BTC price from Pyth every 2 seconds.TNzids[])paramsparsedrrrPexpoz[PYTH] Error: rs)rgetPYTH_HERMES_URL PYTH_BTC_FEEDraise_for_statusjsonrrvaluesrh Exceptionrwasynciosleep)httprespdataprmgres r price_looprs  4!#D/7M:RSSD  ! ! #99;Dxx!N1%g.AgJ26?;#??,*C$)CM*mmA #S 4 N1#&d 3 3 4s[C9 CC $CCA7C/C9C7C9 CC C4C/*C9/C44C9cK tjD]"}|j|j$t j t d{[7w)z(Check market rotations and update books.N)rrr~rrrREFRESH_INTERVAL)rs r market_looprsV ??$ C  % % '     mm,---  .sAA!AA!cK trtjDcic]\}}t||j !}}}t j |}g}tD]} |j|d{|D]}tj|tjdd{cc}}w7F#t$r|j|Y}wxYw7-w)z$Push state to all WebSocket clients.Ng?) rritemsr1rrdumps send_textrrUremoverr)kvstatepayloaddeadwss rbroadcast_loopr s  5=^^5EFTQSVQYY[(FEFjj'GD  $$,,w/// $  &!!"% &mmD!!! F 0 $KKO$ "sRC($B>#C()C=C>C6C(8C&9 C(CC# C("C##C(/)response_classcKtSwN)DASHBOARD_HTMLrrrrootr"s s z/wsrcbK|jd{tj| |jd{} t j |}t |jdd}|jdd}|tvr"|r t|j|d{77t7 #tjtf$rY"wxYw#t$rYnwxYw |tvrtj|yy#|tvrtj|wwxYww)Nr'r&rr$)acceptrrU receive_textrloadsrrrrJSONDecodeErrorrr r)rrror'rs rwebsocket_endpointr's ))+b"**D jj&swwz267ggeR(x'C"8,;;C@@@+ A((*5           b ! 2    b ! sD/B8D/CB:C A'B>2B<3B>7C8D/:C<B>>CCCC C)&D (C))D -D/ D,,D/startupcKtjttjttjt ywr)r create_taskrrrrrrstart_bgr=s7  %  & ()sAAu1 TURBO — BTC Prediction Markets
BTC $--,---.--
Tab switch panel 7 Sell Y 8 Buy Y 9 Buy N 0 Sell N R Pause N Cancel
__main__ z7=======================================================uu ████████╗██╗ ██╗██████╗ ██████╗ ██████╗ u} ╚══██╔══╝██║ ██║██╔══██╗██╔══██╗██╔═══██╗uk ██║ ██║ ██║██████╔╝██████╔╝██║ ██║uk ██║ ██║ ██║██╔══██╗██╔══██╗██║ ██║us ██║ ╚██████╔╝██║ ██║██████╔╝╚██████╔╝ui ╚═╝ ╚═════╝ ╚═╝ ╚═╝╚═════╝ ╚═════╝ z! BTC Prediction Markets on Monadz" Markets: BTC 5MIN + BTC 15MINz Oracle: Pyth Networkz Chain: Monadz! Dashboard: http://0.0.0.0:8080z0.0.0.0iwarning)hostport log_level)rf);rrrosrCr: dataclassesrrpathlibrruvicorndotenvrfastapirrr fastapi.responsesr rrrXrTrrrr#rrr1r?tuplerHrarcrrrrr!rrrrrrapprr websocketron_eventrrrrwrunrrrrs ( ;;* HT     44 4     @@3@@#@ 35c?1%1s15T]I]C^14mmj!2+$s&& '! DO )- e$&-))$."*i\*+u"""*i**Kb z Bvh- BD JL wy wy B uw -/ VH .0 &( ! -/ VHB-GKK)$)D!r