9&j<ddlmZddlmZmZddlmZddlmZedGddZ edGd d Z edGd d Z d&dZ d'dZ d(dZd)dZd*dZd+dZd,dZdddd-d%ZdS).) annotations) dataclassfield)Decimal)AnyT)frozenc<eZdZUded<ded<ded<dZded<dS)LocalOrderRecordstrcoinclient_order_id order_roleNzDecimal | Nonesize)__name__ __module__ __qualname____annotations__r_/home/agent/projects/CryptoTradingBot/Crypto_Agent/src/reconciliation/hyperliquid_reconciler.pyr r sA IIIOOODrr c.eZdZUded<ded<ded<dS)ReconcilerSnapshotzdict[str, dict[str, Any]] positionslist[dict[str, Any]] open_orderszlist[LocalOrderRecord] local_ordersN)rrrrrrrrrs6((((%%%%((((((rrceZdZUded<ded<ded<dZded<d Zd ed <ee Zd ed<ee Z ded<dZ ded<dS)ReconciliationResultboolnew_entries_allowedintstops_missing_countztuple[str, ...]alertsFblock_new_entriesOKr severity)default_factoryztuple[dict[str, Any], ...]recommended_actionszdict[str, list[dict[str, Any]]]stops_by_positionrexposure_mismatchN) rrrrr$r&rtupler(dictr)r*rrrrrs#####H6;eE6R6R6RRRRR9>t9T9T9TTTTT)+++++++rrpositiondict[str, Any]returnrc dD]9}||vr3tt||pdcS:|d}t|trt |StdS)N)szi contractsr0r-)rr get isinstancer,_position_size)r-keynesteds rr6r6#s+:: (??3x||C007C8899 9 9 9  \\* % %F&$&f%%% 3<<rorderc dD]F}||vr@ttt||pdcSGtdS)N)szrorigSzr3)absrr r4)r9r7s r _order_sizer>-s^'<< %<<ws599S>>#8S99::;; ; ; ;  3<<rr ct|dd}|dvr|St|dkrdndS)Nside>longshortrrBrC)r r4lowerr6)r-explicits r_position_siderF4sV8<<++,,2244H$$$#H--1166w>rcHt|dd}|dvrdS|dvrdS|ddus|d durdS|dd us|d d urdS|S) Nr@rA>bbidbuyrJ>asasksellrNisBuyTis_buyF)r r4rD)r9r@s r _order_siderQ;s uyy$$ % % + + - -D """u (((v yyT!!UYYx%8%8D%@%@u yyU""eii&9&9U&B&Bv KrrcRt|dp|d}t|dp+|dp|dpd}|o| p d|vpd|vpd |vS) N reduceOnly reduce_only orderType order_typetyperAtriggerstoptake)rr4r rD)r9rTrVs r_is_reduce_only_triggerr[Hsuyy..J%))M2J2JKKKUYY{++auyy/F/Fa%))TZJ[J[a_abbhhjjJ  v Nui:.EuS]I]uagkuauvrr rrc fd|DS)Ncg|]^}t|ddkMt|\|_S)r rA)r r4upperr[).0r9r s r z)_stop_orders_for_coin..Ssv E E Eec%))FB2G2G.H.H.N.N.P.PTXT^T^T`T`.`.`e|~CfDfD.`E.`.`.`rrr rs` r_stop_orders_for_coinrbRs5 E E E E{ E E EErc<tt||S)N)rrbras r_has_reduce_only_stoprdVs %dK88 9 99rN)max_position_notional_usdmidssnapshotreDecimal | int | float | Nonerf'dict[str, Decimal | int | float] | Nonecg}g}g}i}d}d|jD}t} |jD]\} } | } t | } | dkr0| | t| |j} | || <| s|dz }| d| | |vr-| d| | | t| }t| }|dkrdnd}| D]o}t|}|dkr||kr| d | t|r+t||kr| d | p|x|rv| |vrr|tt|| z}|tt|kr-| d | | | t!|| z D]} | d | |jD] }t#|d p|d}|st|dp|dpddvrt#|dp|dsK| dt|dd t)d|D}|r,| ddd|d|r| dddt-| |t/|||rdn|rd nd!t/||t/t!t|"S)#NrcVh|]&}|jdk |j'S)entry)rr r^)r_records r z.reconcile_hyperliquid_state..es5qqqTZTeipTpTp**,,TpTpTprzposition_without_stop:z(exchange_position_without_local_journal:rBrNrJzstop_wrong_size:zstop_wrong_direction:zposition_exposure_exceeded:z1local_journal_position_without_exchange_position:rSrTrUrVrA>rllimitmarketdeadmanProtecteddeadman_protectedzentry_order_without_deadman:r UNKNOWNc3@K|]}|dVdS))position_without_stop stop_wrongposition_exposure_exceeded'exchange_position_without_local_journalN) startswith)r_alerts r z.reconcile_hyperliquid_state..sWkk[`5##%UVVkkkkkkrprepare_telegram_alertCRITICAL;)actionr&messager$ stops_missing)rreasonWARNINGr%)r r"r#r$r&r(r)r*)rsetritemsr^r6addrbrappendr=rFr>rQrr sortedrr4rDanyjoinrr+)rgrerfr# recommendedexposurer)missinglocal_entry_coinsexchange_position_coinsr r-rstops position_abspos_sideexpected_stop_siderY stop_sizenotionalr9rTcriticals rreconcile_hyperliquid_staterZs F(*KH9;Gqq8;Pqqq(+",2244&&hzz||h'' 199 ##D)))%dH,@AA"'$ ; qLG MM9499 : : : ( ( ( MMKTKK L L L OOD ! ! !4yy !(++'/6'9'9VVu > >D#D))IA~~)|";"; 7778884   >[%6%6:L%L%L &>>H'#&?"@"@AAAA BDBBCCC%%%(+BBCCRR P$PPQQQQ%jj599\22Neii 6N6NOO  js599[#9#9#ZUYY|=T=T#ZXZ[[aacchD D D "455WCV9W9WXX j hS6S\A]A]=^=^=d=d=f=fhhiiikkdjkkkkkHv&>JcfckcklrcscsttuuuW&9_UUVVV  (L#V}}"'L6.Kiit!+..+s8}} 5 566    r)r-r.r/r)r9r.r/r)r-r.r/r )r9r.r/r )r9r.r/r)r r rrr/r)r r rrr/r)rgrrerhrfrir/r) __future__r dataclassesrrdecimalrtypingrr rrr6r>rFrQr[rbrdrrrrrs""""""(((((((( $         $))))))))  $,,,,,,,,????    wwwwEEEE::::?C48 BBBBBBBBr