iPddlZddlmZmZmZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)IntMarketOrder OrderBookStrTrade)Client)List) ExchangeErrorc `eZdZfdZdifdededefdZdZdddifde dedede e fd Z d e fd Zddifdededede e fd Zd e fd Zddede fdZdddifdededede efdZd e fdZdddifde dedede efdZd e fdZd e fdZd e fdZdZd e fdZxZS) hyperliquidc|tt|ddddddddddd dddiidddiidi|jd d dd iiid S) NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTrades watchPositionrpubliczwss://api.hyperliquid.xyz/wsz$wss://api.hyperliquid-testnet.xyz/ws)apitesti N)ping keepAliveexact)hasurlsoptions streaming exceptions) deep_extendsuperrdescriber)self __class__s Z/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/hyperliquid.pyr)zhyperliquid.describesk4 8 8 A A C C %!%""&#$ %#!&   "@  "H   " ?%F %F % % % Nsymbollimitreturnc\K|d{V||}|d}d|z}|jddd}dd|d d d }|||}|||||d{V} | S) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: the maximum amount of order book entries to return :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr. orderbook:rrr subscribel2Bookbasetypecoinmethod subscription) load_marketsmarketr#extendwatchr/) r*r.r/paramsr= messageHashurlrequestmessage orderbooks r,watch_order_bookzhyperliquid.watch_order_book8s!!!!!!!!!V$$!"V+ it$X.! v  ++gv..**S+w LLLLLLLL    r-c \||di}||d}|dz}||}|d}||dg}||dg||dgd} ||d } || || d d d d } ||jvr|| } | |j|<|j|} | | d|z}| | |dS)Ndatar8 /USDC:USDCr.levelsr)bidsaskstimerLrMpxszr2) safe_dict safe_stringr= safe_list safe_integerparse_order_book orderbooks order_bookresetresolve)r*clientrDentryr8marketIdr=r.rawDatarH timestampsnapshotobrErAs r,handle_order_bookzhyperliquid.handle_order_bookPs>4w33v..,&X&&!.."55NN7Ar22NN7Ar22  %%eV44 ((vy&&RVX\]]$/))**B&(DOF #OF+ !!!"V+ y+.....r-sincecKd}|d|\}}|d{Vd}|||}|d|zz }|jddd}dd |d d }|||} |||| |d{V} |jr| ||}|| |||d S) aS watches information on multiple trades made by the user :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of [order structures]{@link https://docs.ccxt.com/#/?id=order-structure NrmyTrades:rrrr3 userFillsr7userr9T) handlePublicAddressr<r.r#r>r? newUpdatesgetLimitfilter_by_symbol_since_limit) r*r.rbr/r@ userAddressrArBrCrDtradess r,watch_my_tradeszhyperliquid.watch_my_trades~s! "66OO V!!!!!!!!!  [[((F 3< 'Kit$X.!##  ++gv..zz#{G[IIIIIIII ? 3OOFE22E00tTTTr-rZc||di}|j0||jdd}t ||_|j}i}||dg}t |}|dkrdStdt |D]A} || } || } | d} d|| <| | Bt| } tdt | D]#} d| | z}| ||$d }| ||dS) NrH tradesLimitfillsrr.Tz myTrades:rd) rQrdrTr$rrSlenrangeparse_ws_tradeappendlistkeysrY)r*rZrDr[r/rnsymbolsrH dataLengthirawTradeparsedr.rycurrentMessageHashrAs r,handle_my_tradeszhyperliquid.handle_my_tradess`:w33 = %%dlM4HHE2599DM~~eWb11YY ?? Fq#d))$$ " "AAwH((22FH%F"GFO MM& ! ! ! !GLLNN##q#d))$$ 7 7A!,tAw!6  NN6#5 6 6 6 6 v{+++++r-cK|d{V||}|d}d|z}|jddd}dd|d d d }|||} |||| |d{V} |jr| ||}|| ||d d S)a watches information on multiple trades made in a market :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of [trade structures]{@link https://docs.ccxt.com/#/?id=trade-structure Nr.trade:rrrr3rnr5r6r9r^Tr<r=r#r>r?rjrkfilter_by_since_limit) r*r.rbr/r@r=rArBrCrDrns r, watch_tradeszhyperliquid.watch_tradess!!!!!!!!!V$$!' it$X.! v  ++gv..zz#{G[IIIIIIII ? 3OOFE22E))&% TRRRr-c^||dg}||di}||d}|dz}||}|d}||jvr5||jdd} t| } | |j|<|j|} tdt|D]B} ||| } | | }| |Cd|z}| | |dS) NrHrr8rIr.rqrrr) rSrQrRr=rnrTr$rrurtrvrwrY)r*rZrDr[firstr8r\r=r.r/storedrnr|rHtraderAs r, handle_tradeszhyperliquid.handle_tradess1"w33ua,,v..,&X&&!$+%%%%dlM4HHE&&F"(DK V$q#e**%% ! !A>>%++D''--E MM% ' v{+++++r-r=c||d}||d}||d}||d}|dz}||d}|d}||d} ||d} | | d krd nd } ||d } ||||||| dd| d||d| d dd |S)NrNrOrPr8rIr.tidsideAsellbuyfeeUSDC)costcurrency) infor^datetimer.idorderr7r takerOrMakerpriceamountrr)rTrR safe_market safe_tradeiso8601) r*rr=r^rrr8r\r.rrrs r,rvzhyperliquid.parse_ws_trades8D%%eV44   --!!%..v..,&!!(D11!   eU + +v..  "ckk66Due,," Y// V44    r-1mcK|d{V||}|d}|jddd}dd|d|d d }d |zd z|z} |||} ||| | | d{V} |jr| ||}|| ||d dS)aM watches historical candlestick data containing the open, high, low, close price, and the volume of a market :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Nr.rrrr3candler5)r7r8intervalr9candles:rerTr) r*r. timeframerbr/r@r=rBrCrArDohlcvs r, watch_ohlcvzhyperliquid.watch_ohlcvNs!!!!!!!!!V$$!it$X.! v%  !9,s2V; ++gv..jjk7KHHHHHHHH ? 2NN6511E))%q$GGGr-c ||di}||d}|dz}||d}||jvr i|j|<||j|vr;||jdd}t |}||j||<|j||} ||} | | d|zdz|z} || | dS) NrHsrIr| OHLCVLimitrrrre) rQrRohlcvsrTr$r parse_ohlcvrwrY) r*rZrDrHr5r.rr/rrr~rAs r, handle_ohlcvzhyperliquid.handle_ohlcvks$~~gvr22c** $$$T3// $+%%"$DK T[000%%dlL$GGE*511F-3DK  * F#I.!!$'' V 9,s2V; uk*****r-cK|d{Vd}|d|\}}d}d}|%||}|d}|dz|z}|jddd}d d |d d } || |} |||| |d{V} |jr| ||}|| |||d S)aS watches information on multiple orders made by the user :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of [order structures]{@link https://docs.ccxt.com/#/?id=order-structure Nrrr.rerrrr3 orderUpdatesrgr9T) r<rir=r#r>r?rjrkrl) r*r.rbr/r@rmr=rArBrCrDorderss r, watch_orderszhyperliquid.watch_orderss1!!!!!!!!! "66}fMM V  [[((FH%F%+f4Kit$X.!&#  ++gv..zz#{G[IIIIIIII ? 3OOFE22E00tTTTr-c||dg}|j0||jdd}t ||_t |}|dkrdS|j}d}i}t dt |D]O} || } || } || | | d} d|| <Pt| } t dt | D](} | | } |dz| z}| ||)| ||dS) NrH ordersLimitrrrrr.Tre) rSrrTr$rrtru parse_orderrwrRrxryrY)r*rZrDrHr/r{rrA marketSymbolsr|rawOrderrr.ryinnerMessageHashs r, handle_orderzhyperliquid.handle_orderse*~~gvr22 ; %%dlM4HHE077DKYY ?? F  q#d))$$ ) )AAwH$$X..E MM% %%eX66F$(M& ! !M&&(())q#d))$$ 5 5A!WF*S069  NN6#3 4 4 4 4v{+++++r-c||dd}||dd}|dkrt|jdz|zdS)NchannelrHerror F)rRrr)r*rZrDrret_msgs r,handle_error_messagez hyperliquid.handle_error_messages[""7Ir::""7FB77 g  #  788 85r-c|||rdS||dd}|j|j|j|j|j|jd}|||}||||dSt| }tdt|D]@}||}| ||dkr||} | ||dSAdS)Nrr)pongrnr4rrrfr)rrR handle_pongrrarrr safe_valuerxryrurtfind) r*rZrDtopicmethods exacMethodryr|keyr:s r,handle_messagezhyperliquid.handle_messages!  $ $VW 5 5  F  )R88$(,' -.   __We44  ! Jvw ' ' ' FGLLNN##q#d))$$  Aq'Czz$q'""a'' vw'''(  r-c ddiS)Nr:r)r*rZs r,rzhyperliquid.pings f  r-c<||d|_|S)Nr)rTlastPong)r*rZrDs r,rzhyperliquid.handle_pongs ++GV<<r-)N)__name__ __module__ __qualname__r)strrr rFrar r r ror rrrrrvrxrrrrrrrrr __classcell__)r+s@r,rrs& & & & & P@DB!!S!!S\!!!!0,/,/,/\37TX\egUUCUsURUUlpqvlwUUUU>3,v3,3,3,3,j<@d[]SSSSSSbfglbmSSSS6!,F!,!,!,!,F<<F<e<<<<|8<$]ajlHHHCHWZHquvzq{HHHH: +6 + + + +D04$UYbdUUUCUsUimnsitUUUUB*,6*,*,*,*,X 6    V0   &r-r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrrr-r,rs ffffffffffEEEEEEEEEEEEEEEE444444******~~~~~$$0~~~~~r-