eiUddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List)ArgumentsRequired)Precisec deZdZdeffd ZdeedefdZifdedefdZ ifdedefdZ difd e de fd Z difd e defd Zifdedefd Zifdedefd Zdifd e de fdZdifd e defdZdefdZdZdifd e de fdZdifd e defdZdefdZdAdZddifdedededeefdZifdedefdZddifd eedededeefdZifd eedefdZdefdZ dAdefdZ!difdedede"fdZ#ifdedefd Z$difd eedede"fd!Z%ifd eedefd"Z&defd#Z'd$ddifdedededee(fd%Z)d$ifdedefd&Z*ddifd'eeededefd(Z+ifd'eeedefd)Z,defd*Z-dAde(fd+Z.d,ifd-Z/ifd.Z0dBd/Z1ifde2fd0Z3defd1Z4d2Z5defd3Z6dddifd e dededee7fd4Z8defd5Z9d6Z:d7Z;dAd8Zfd9Z?dddifde=dededeefd:Z@defd;ZAdefd<ZBdefd=ZCdAd>ZDdefd?ZEdefd@ZFxZGS)CasterreturncL|tt|iddddddddddddddd dd dd dd dd dddddddddddddddddddddd dddddddddiidddddddddddddddd d!iid"S)#NwsT watchBalance watchBidsAskswatchMarkPricewatchMarkPrices watchTradeswatchTradesForSymbols watchOrderswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbolswatchPositions watchTicker watchTickers watchMyTrades unWatchTicker) unWatchTickersunWatchMarkPriceunWatchMarkPricesunWatchBidsAsks unWatchTradesunWatchTradesForSymbolsunWatchOrderBookunWatchOrderBookForSymbols unWatchOHLCVunWatchOHLCVForSymbolsapiz!wss://sstream.asterdex.com/streamz!wss://fstream.asterdex.com/stream)spotswapzwss://sstream.asterdex.com/wszwss://fstream.asterdex.com/ws)publicprivater6F)fetchBalanceSnapshotawaitBalanceSnapshotwb)fetchPositionsSnapshotawaitPositionsSnapshot) listenKeylastAuthenticatedTimelistenKeyRefreshRaterwalletr&)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s L/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/aster.pyrKzaster.describeseT 2 2 ; ; = =d !$  "4  t (t!$+Dd'!$t  !" #$#'$(%)#'!%+/$(.2 $*.7<$G$G## %D$C$$     !  ** $#)) -2,0!!.2.2##%.IE@ E@ E E E subscriptionsczd}tdt|D]}||}|dks|dkr|}n|S)Nrr6r7)rangelen)rLrP accountTypei subscriptions rN#get_account_type_from_subscriptionsz)aster.get_account_type_from_subscriptionsYs_ q#m,,--  A(+L&&LF,B,B* -CrOsymbolcKd|d<|d{V||}||g|d{V}||S)as watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#full-ticker-per-symbol https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#individual-symbol-ticker-streams :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` r'callerMethodNameN) load_markets safe_symbol watch_tickersrLrYparamstickerss rN watch_tickerzaster.watch_tickerbs}&3!"!!!!!!!!!!!&))**F8V<<<<<<<<vrOcJKd|d<||g|d{VS)a  unWatches a price ticker https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#full-ticker-per-symbol https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#individual-symbol-ticker-streams :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` r*r[N)un_watch_tickersrLrYr`s rNun_watch_tickerzaster.un_watch_tickerss=&5!"**F8V<<<<<<<<` NTtyper7r[r(r (() requires a non-empty array of symbolsr5rr8 SUBSCRIBEmethodr`id@tickerticker:rY)r\market_symbolsget_market_from_symbols safe_stringrThandle_param_stringomitrrorErSmarketappendsafe_string_lowerwatch_multipleextend newUpdatesfilter_by_arrayra)rLrgr` firstMarketri symbolsLength methodNameurlsubscriptionArgs messageHashesrequestrVrYrw newTickerresults rNr^zaster.watch_tickerss!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PR`aa F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 !&  q#g,,'' ? ?AQZF[[((F  # #D$:$:64$H$H9$T U U U  VH-=!= > > > >--c=$++gW]B^B^ae`fgggggggg ? F*3F9X& 'M##DL(GDDDrOcPK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |}g}g} d |d} tdt |D]i} || } | | } | | | ddz| d| dzj||| || ||gd{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#full-ticker-per-symbol https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#individual-symbol-ticker-streams :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NTrir7r[r+rrjrkr5rr8 UNSUBSCRIBErmrorpunsubscribe:ticker:rYr\rrrsrtrTrurvrrorErSrwrxryrzr{rLrgr`r~rirrrrrrrVrYrws rNrdzaster.un_watch_tickerss!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRbcc F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 #&  q#g,,'' K KAQZF[[((F  # #D$:$:64$H$H9$T U U U  !69I!I J J J J((mT[[RX=Y=Y\`[abbbbbbbbbrOcKd|d<|d{V||}||g|d{V}||S)a: watches a mark price for a specific market https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#mark-price-stream :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.use1sFreq]: *default is True* if set to True, the mark price will be updated every second, otherwise every 3 seconds :returns dict: a `ticker structure ` rr[N)r\r]watch_mark_pricesr_s rNwatch_mark_pricezaster.watch_mark_prices}&6!"!!!!!!!!!!!&))..x@@@@@@@@vrOcJKd|d<||g|d{VS)a< unWatches a mark price for a specific market https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#mark-price-stream :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.use1sFreq]: *default is True* if set to True, the mark price will be updated every second, otherwise every 3 seconds :returns dict: a `ticker structure ` r,r[N)un_watch_mark_pricesres rNun_watch_mark_pricezaster.un_watch_mark_prices=&8!"..x@@@@@@@@@rOcK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |}g}g} d |d} | |dd} tdt |D]r} || } | | }| rdnd}| ||ddz|z| d|dzs||| || ||gd{V}|jri}|||d<|S||jd|S)9 watches the mark price for all markets https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#mark-price-stream :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.use1sFreq]: *default is True* if set to True, the mark price will be updated every second, otherwise every 3 seconds :returns dict: a `ticker structure ` NTrir7r[rrrjrkr5rr8rlrm use1sFreq@1srRro @markPricerqrY)r\rrrsrtrTrurvrrorE safe_boolrSrwrxryrzr{r|r}ra)rLrgr`r~rirrrrrrrrVrYrwsuffixrrs rNrzaster.watch_mark_pricess>!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRcdd F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 !&  NN6;== q#g,,'' ? ?AQZF[[((F(1UUrF  # #D$:$:64$H$H<$WZ`$` a a a  VH-=!= > > > >--c=$++gW]B^B^ae`fgggggggg ? F*3F9X& 'M##DL(GDDDrOcK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |}g}g} d |d} | |dd} tdt |D]r} || } | | }| rdnd}| ||ddz|z| d|dzs||| || ||gd{VS)rNTrir7r[r-rrjrkr5rr8rrmrrrRrorrrY)r\rrrsrtrTrurvrrorErrSrwrxryrzr{)rLrgr`r~rirrrrrrrrVrYrwrs rNrzaster.un_watch_mark_pricess!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PReff F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 #&  NN6;== q#g,,'' K KAQZF[[((F(1UUrF  # #D$:$:64$H$H<$WZ`$` a a a  !69I!I J J J J((mT[[RX=Y=Y\`[abbbbbbbbbrOclientcH|j}t|}||}||d}|||}|d}d|z} ||j|<||j|| dS)NdatarYrq)rPlistkeysrX safe_dictparse_ws_tickerraresolve) rLrmessagerPsubscriptionsKeys marketTypetickerparsedrY messageHashs rN handle_tickerzaster.handle_ticker:sN,  !3!3!5!566==>OPP 00%%fj99!&( % Vt|F+[99999rOc ||d}|d}||d}||d}||d}||dd|}||d} |dkr]||d||||||d ||d d S|id|dd |d ||d||dd||dddddddddd||dd||dd| d| ddd||d d||dd d||d!||d"|d#|S)$Ne@sEcmarkPriceUpdaterYprV)rY timestampdatetimeinfo markPrice indexPricerrhighhlowlbid bidVolumeask askVolumevwapwopenocloselast previousClosechange percentagePaveragevq) baseVolume quoteVolumer)rtsplit safe_integer safe_market safe_tickeriso8601) rLrreventpartchannelmarketIdrrwrs rNrzaster.parse_ws_tickerks  #..{{3""4++##GS11%%gs33 !!(D$ CC-- ' ' '## *& LL33!--gs;;"..w<< %% ! fX&! !   Y//!  D$$Wc22 ! 4##GS11 ! 4 !  !  4!  !  D$$Wc22!  D$$Wc22!  T!  D!  T!  d&&w44! $**7C88!! " t#! $**7C88++GS99)! ! ! * + rOcDK|d{V||dddd}||}||dd}t |}|dkrt |jdz|jddd |}g}g}d |d } tdt |D]i} || } | | } | | | d d z| d| dzj| ||| | ||gd{V} |jri}| || d<|S||jd|S)a. watches best bid & ask for symbols https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#best-order-book-information-by-symbol https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#individual-symbol-book-ticker-streams :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NTrir7rz6 watchBidsAsks() requires a non-empty array of symbolsr5rr8rlrmro @bookTickerbidask:rY)r\rrrsrtrTrrorErSrwrxryrzr{r|r}bidsasks)rLrgr`r~rirrrrrrVrYrwrrs rNwatch_bids_askszaster.watch_bids_askss!!!!!!!!!%%gtT4FF227;;  VV<<G A  #DG.f$fgg git$X.t4 !&  q#g,,'' ? ?AQZF[[((F  # #D$:$:64$H$H=$X Y Y Y  VH-=!= > > > >--c=$++gW]B^B^ae`fgggggggg ? F*3F9X& 'M##DM8WEEErOcK|d{V||dddd}||}||dd}t |}|dkrt |jdz|jddd |}g}g}d |d } tdt |D]i} || } | | } | | | d d z| d| dzj| ||| | ||gd{VS)a0 unWatches best bid & ask for symbols https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#best-order-book-information-by-symbol https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#individual-symbol-book-ticker-streams :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NTrir7rz8 unWatchBidsAsks() requires a non-empty array of symbolsr5rr8rrmrorzunsubscribe:bidask:rY)r\rrrsrtrTrrorErSrwrxryrzr{) rLrgr`r~rirrrrrrVrYrws rNun_watch_bids_askszaster.un_watch_bids_askss!!!!!!!!!%%gtT4FF227;;  VV<<G A  #DG.h$hii iit$X.t4 #&  q#g,,'' K KAQZF[[((F  # #D$:$:64$H$H=$X Y Y Y  !69I!I J J J J((mT[[RX=Y=Y\`[abbbbbbbbbrOc|j}t|}||}||di}||d}||dd|}|||} | d} | |j| <d| z} | | | dS)NrrrYr) rPrrrXrrtrparse_ws_bid_askrr) rLrrrPrrrrrwrrYrs rNhandle_bid_askzaster.handle_bid_asks",  !3!3!5!566==>OPP ~~gvr22##D#..!!(D$ CC&&tV44! & f&( v{+++++rOc >||d}||d|||||d||d||d||d|d|S)NTrYaAbB)rYrrrrrrr)rrrrt)rLrrwrs rNrzaster.parse_ws_bid_asks%%gs33 X&" Y//##GS11))'377##GS11))'377 ! !     rOsincelimitcNKd|d<||g|||d{VS)a watches information on multiple trades made in a market https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#collection-transaction-flow https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#aggregate-trade-streams :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 ` rr[N)watch_trades_for_symbols)rLrYrrr`s rN watch_tradeszaster.watch_tradessA&3!"22F8UE6RRRRRRRRRrOcJKd|d<||g|d{VS)a  unsubscribe from the trades channel https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#collection-transaction-flow https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#aggregate-trade-streams :param str symbol: unified market symbol of the market trades were made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` r/r[N)un_watch_trades_for_symbolsres rNun_watch_tradeszaster.un_watch_tradess=&5!"55vhGGGGGGGGGrOcK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |} g} g} d | d} tdt |D]i} || }| |}| | |ddz| d|dzj|| | || ||gd{V}|jrB||d}||d}|||}||||ddS)a get the list of most recent trades for a list of symbols https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#collection-transaction-flow https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#aggregate-trade-streams :param str[] symbols: unified symbol of the market to fetch trades for :param int [since]: timestamp in ms of the earliest trade to fetch :param int [limit]: the maximum amount of trades to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NTrir7r[r rrjrkr5rr8rlrmro @aggTradetrade:rYr)r\rrrsrtrTrurvrrorErSrwrxryrzr{r| safe_valuegetLimitfilter_by_since_limit)rLrgrrr`r~rirrrrrrrVrYrwtradesfirst tradeSymbols rNrzaster.watch_trades_for_symbols s9!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRijj F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 !&  q#g,,'' > >AQZF[[((F  # #D$:$:64$H$H;$V W W W  F8,` NTrir7r[r0rrjrkr5rr8rrmrorzunsubscribe:trade:rYrrs rNrz!aster.un_watch_trades_for_symbolsJs!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRkll F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 #&  q#g,,'' J JAQZF[[((F  # #D$:$:64$H$H;$V W W W  !5x8H!H I I I I((mT[[RX=Y=Y\`[abbbbbbbbbrOcH|j}t|}||}||d}||d}||dd|}|||} | d} ||j | } | 5| |j dd} t| } | |j | <| | d| z} || | dS)NrrrY tradesLimitr)rPrrrXrrtrparse_ws_traderrrrFrrxr)rLrrrPrrtraderrwrrYstoredrrs rN handle_tradezaster.handle_tradems$,  !3!3!5!566==>OPP w//##E3//!!(D$ CC$$UF33!f55 >%%dlM4HHE&&F"(DK  f#f, v{+++++rOc||d}|dkp|dk}||dd}||d}||dd}d}|r||d }n||d }||d } | ||tj||} ||d } |||jd dn|d} || |d| } ||d} d}||d}d|vr| |drdnd} |drdnd}d}||d}|0||d}||}||d}||d}| ||| || ||||| ||| |d S)NrraggTradetrrLrrrYr defaultTyper6riSrVmsellbuymakertakernNcostcurrencyr) rrrrYroorderri takerOrMakersidepriceamountrfee) rt safe_string_2rr string_mulrFr]rysafe_currency_code safe_trader)rLrrwr isPublicTraderorrrrrrrYrrorderIdrfeeCost feeCurrencyIdfeeCurrencyCoderis rNrzaster.parse_ws_trades^R   UC ( (g;1 ?   sC 0 0%%eS11 ""5#s33  2%%eS11FF%%eS11Fs++ <!(:)%88##E3//PVP^d&&t|]FKKKeklres !!(FD+FF%%eS11 ""5#.. %<<|!&s6vv&+Cj=77gL""5#..   ,,UC88M"55mDDO+C%%eS11" Y//(     rOcLKd|d<||g||d{VS)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#limited-depth-information https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#partial-book-depth-streams :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 r"r[N)watch_order_book_for_symbols)rLrYrr`s rNwatch_order_bookzaster.watch_order_book,s?&6!"66xOOOOOOOOOrOcJKd|d<||g|d{VS)a unsubscribe from the orderbook channel https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#limited-depth-information https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#partial-book-depth-streams :param str symbol: symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols r1r[N)un_watch_order_book_for_symbolsres rNun_watch_order_bookzaster.un_watch_order_book;s=&8!"996(FKKKKKKKKKrOcK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |}g} g} d | d} ||dkr|dkr|dkrd}tdt |D]y} || } | | }| | |ddzt|z| d|dzz||| || ||gd{V}|S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#limited-depth-information https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#partial-book-depth-streams :param str[] symbols: unified array of symbols :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 NTrir7r[r#rrjrkr5rr8rlrm ro@depth orderbook:rY)r\rrrsrtrTrurvrrorErSrwrxrystrrzr{r)rLrgrr`r~rirrrrrrrVrYrw orderbooks rNr!z"aster.watch_order_book_for_symbolsJs!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRlmm F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 !&   =UaZZERKKERKKEq#g,,'' B BAQZF[[((F  # #D$:$:64$H$H8$SVYZ_V`V`$` a a a  x0@!@ A A A A--c=$++gW]B^B^ae`fgggggggg    rOcK|d{V||dddd}||}||dd}t |}d}||dd\}}||d}|dkrt|jdz|zd z|j d d d |}g}g} d |d} | |d} ||d}| | dkr| dkr| dkrd} tdt |D]l} || } | | }| ||ddz| z| d|dzm||| || ||gd{VS)a unsubscribe from the orderbook channel https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#limited-depth-information https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#partial-book-depth-streams :param str[] symbols: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols NTrir7r[r2rrjrkr5rr8rrmrr'r(r)ror*zunsubscribe:orderbook:rY)r\rrrsrtrTrurvrrorE safe_numberrSrwrxryrzr{)rLrgr`r~rirrrrrrrrVrYrws rNr$z%aster.un_watch_order_book_for_symbolsqs,!!!!!!!!!%%gtT4FF227;;  VV<<G  !55f>PRnoo F6#566 A  #DGcMJ$>Ak$kll lit$X.t4 #&    1167++ =UaZZERKKERKKEq#g,,'' N NAQZF[[((F  # #D$:$:64$H$H8$SV[$[ \ \ \  !9F8OPP ~~gv..##D#..%%dC00 !!(D$ CC!$/))&*oo&7&7DOF #OF+ ((vy#sKK!!!'&0 "+y+.....rO1mcKd|d<|d{V||}|||gg|||d{V}|||S)a$ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#k-line-streams https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#klinecandlestick-streams :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 r$r[N)r\r]watch_ohlcv_for_symbols)rLrY timeframerrr`rs rN watch_ohlcvzaster.watch_ohlcvs&2!"!!!!!!!!!!!&))33fi5H4I5RWY_````````f~i((rOcNKd|d<|||gg|d{VS)a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#k-line-streams https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#klinecandlestick-streams :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume r3r[N)un_watch_ohlcv_for_symbols)rLrYr:r`s rNun_watch_ohlcvzaster.un_watch_ohlcvsC&4!"44vy6I5JFSSSSSSSSSrOsymbolsAndTimeframescK|d{Vt|}d}||dd\}}||d}|dkrt |jdz|zdz||d}||dddd}||d} | | d d } |j d d d | } g} g} d| d}tdt|D]}||}| |d}||}|d}| |d}| |j ||}| ||ddz|z| d|dzdz|z|| | |||| gd{V\}}}|jr|||}||||dd}||||S)a: watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#k-line-streams https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#klinecandlestick-streams :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :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 dict: A list of candles ordered, open, high, low, close, volume Nr[r%rrjrkFTrir7r5rr8rlrmrYrro@kline_ohlcv::)r\rTrurvrroget_list_from_object_valuesrrrwrtrErS timeframesrxryrzr{r|rrcreate_ohlcv_object)rLr?rrr`rrrg marketSymbolsr~rirrrrrVr symbolStringrwunfiedTimeframe timeframeIdrYr:rfiltereds rNr9zaster.watch_ohlcv_for_symbolss!!!!!!!!!011  !55f>PRhii F6#566 A  #DGcMJ$>Ak$kll l223GKK++GT5$MM kk-"233  VV<<it$X.t4 !&  q#23344 V VA'*D++D!44L[[..F!(+L"..tQ77O**4?O_]]K  # #D$:$:64$H$H9$TWb$b c c c  F8,PRjkk F6#566 A  #DGcMJ$>Ak$kll l223GKK++GT5$MM kk-"233  VV<<it$X.t4 #&  q#23344 b bA'*D++D!44L[[..F!(+L"..tQ77O**4?O_]]K  # #D$:$:64$H$H9$TWb$b c c c  !5x8H!H3!NQ`!` a a a a((mT[[RX=Y=Y\`[abbbbbbbbbrOcL|j}t|}||}||d}||d}||dd|}|d} ||d} || d} || } ||j | } | i|j | <|| | 9| |j dd}t||j | | <|j | | }| | }||d| zd z| z}| | |g}|||dS) NrrrYkrV OHLCVLimitrrBrC)rPrrrXrrtrfind_timeframerohlcvsrrFrparse_ws_ohlcvrxr)rLrrrPrrrrrwrYklinerJr:ohlcvsByTimeframerrrr resolveDatas rN handle_ohlcvzaster.handle_ohlcv>s<,  !3!3!5!566==>OPP ~~gv..##D#..!!(D$ CC!tS))&&uc22 '' 44  OODK@@  $"$DK  ??,i 8 8 @%%dlL$GGE-B5-I-IDK  *V$Y/$$U++ f'#- 9 y&1 {K00000rOc ||d||d||d||d||d||dgS)Nrrrrrr)rr/)rLohlcvrws rNrRzaster.parse_ws_ohlcvss~   eS ) )   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   rOr6cbK|}||jdi}|||d}||jdi}|||d}||z |krd}|dkr||d{V}n||d{V}||d|jd|<||jd|<|d|i|}|||j |dSdS)NrArrBr:r6r@ri) millisecondsrrFrsapiPrivatePostV1ListenKeyfapiPrivatePostV1ListenKeyrtr{delaykeep_alive_listen_key) rLrir`timelastAuthenticatedTimeOptionsrAlistenKeyRefreshRateOptionsrBresponses rN authenticatezaster.authenticate}s^  ""'+~~dlD[]_'`'`$ $ 1 12NPTVW X X&*nnT\CY[]&^&^##001LdT[\\ ' '*> > >Hv~~!%!@!@!H!HHHHHHH!%!@!@!H!HHHHHHH.2.>.>x.U.UDL %d +:>DL0 1$ 7[[&$88F JJ+T-G P P P P P ? >rOc&K||dd}||jdi}|||}|dS |d{Vn#t$r}|jddd|dz|z}||}t|j }tdt|D] } || } | || !d|jd|<d|jd |<Yd}~dSd}~wwxYw||jd i} | | d d } || |j|dS) Nrir6r@r5rr9/rrAlistenKeyRefreshrBr:)rtrrFsapiPrivatePutV1ListenKey ExceptionrErrfuturesrrSrTrejectrr]r^) rLr`rilistenKeyOptionsr@errorrrrrVrlistenKeyRefreshOptionsrBs rNr^zaster.keep_alive_listen_keys77>>$, RHH$$%5t<<   F 0022 2 2 2 2 2 2 2 2   )E"4(3D9C?)KC[[%%F !4!4!6!677M1c-0011 2 2+A.  e[1111.2DL %d +:;DL0 1$ 7 FFFFF #'..?QSU"V"V#001HJ`bijj ')CVLLLLLsA,, D?6B>D::D?c||jdi}|||}|jddd|dz|z}|S)Nr@r5rr9re)rrFrtrE)rLrirkr@rs rNget_private_urlzaster.get_private_urlsZ>>$, RHH$$%5t<< it$Y/5;iG rOcLK|d{Vd}|dd||\}}|||d{V||}||}|||||jd}||dd}||dd}|r |r| |dzd{V|dz}d} | ||| |d{VS) aI query for balance and get the amount of funds available for trading or funds locked in orders https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#payload-account_update https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#event-balance-and-position-update :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: 'spot' or 'swap', default is 'spot' :returns dict: a `balance structure ` Nrr;Fr<T:fetchBalanceSnapshot:balance) r\handle_market_type_and_paramsrcrorset_balance_cacherrFrfuturewatch) rLr`rirrrFr;r<rrs rN watch_balancezaster.watch_balancesj!!!!!!!!!99.$PVX\]] ff---------""4((S!! vt,,,..~>>#~~g7MuUU#~~g7MtTT  @$8 @--'> >?? ? ? ? ? ? ? ?Z' ZZ['4@@@@@@@@@rOc2||jvr ||jvrdS||jd}||dd}|rD|dz}||jvr4||||j|||dSdSi|j|<dS)Nrr;Frq) rPbalancerrFrriruspawnload_balance_snapshot)rLrrirFr;rs rNrtzaster.set_balance_caches F( ( (tt|/C/C F//$,??#~~g7MuUU  $!88K6>11 k*** 45v{DQQQQQ21"$DL   rOcXKd|i}||d{V}||||j|i|j|<||jvrG|j|}|||j||dzdSdS)Nrirr) fetch_balancer{rryrir)rLrrrir`rbrus rNr{zaster.load_balance_snapshots D ++F33333333![[4??4>?PQQ !J. < $ ,(*DL %,3 [!&)..#w77 NN7C , ,!!$,$??q#a&&!! 6 6AaDE))%55J**:66DllnnG"..uc::GFO"..uc::GFO#//v>>GG .5DL %d + +%%gs33 1: [!+.04 Y0G0G [!*-$($5$5dl;6O$P$P [!t|K0+>>>>>rOcBK|d{Vd}|||d{V||}||}||g}d} ||ddd}||| nCtdt|D]%} || } || dz| z&| ddd} | dd d} |j }| r8| r6|4| dd{V}| ||||dS| ||d|gd{V}|jr|S| ||||dS) a watch all open positions https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#event-balance-and-position-update :param str[]|None symbols: list of unified market symbols :param number [since]: since timestamp :param number [limit]: limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr7 positionsTr::r&r>r?)r\rcrorset_positions_cacherrrxrSrT handle_optionrrufilter_by_symbols_since_limitrzr|)rLrgrrr`rirrrrrVrYr>r?cacher5 newPositionss rNwatch_positionszaster.watch_positions.s !!!!!!!!!f---------""4((S!!   ((( ! %%gvtTBB ?   - - - -1c'll++ B B $$[4%7&%@AAAA!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e ! ]&< ]#]]+CDDDDDDDDH55hPUW[\\ \!00mTD6RRRRRRRR ?  11%%PTUUUrOc|jdS|ddd}|r@d}||jvr3||||j||dSdSt |_dS)Nr&r>F)rrrirurzload_positions_snapshotr)rLrr>rs rNrzaster.set_positions_cacheTs > % F!%!3!34DF^`e!f!f ! 82K6>11 k*** 47MMMMM21677DNNNrOcK|d{V}t|_|j}tdt |D]<}||}||dd}|dkr||=||jvr:|j|}||||ddSdS)Nr contractsr) fetch_positionsrrrSrTr/rxrir) rLrrrrrVpositionrrus rNrzaster.load_positions_snapshot`s..00000000 133q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5+ . . . . . ) (rOcd}|jt|_|j}||di}||dg}g}t dt |D]|}||} || } ||d} | | d<|| | d<| | | | }| ||} | | sft dt |D]0}||} | d} |d z| z}| | |1| |ddSdS) NrrrrrrrrYr) rrrrrSrTparse_ws_positionrrrxfind_message_hashesis_emptyr)rLrrrrr rawPositionsrrV rawPositionrrrrYsymbolMessageHashs rNhandle_positionszaster.handle_positionsos@" > !577DN~~gsB//~~dC44  q#l++,, # #A&q/K--k::H))'377I$-H[ !#'<< #:#:HZ    ) ) ) LL " " " "00EE }}]++ 61c,//00 < <'?!(+$/$$6$?!x):;;;; NN< 5 5 5 5 5  6 6rOc ||d}||d}tj||d}||d}d}|dkr1d}tj|dstj|drd}nd }|id |d dd ||ddd ddd||dddd||dd||dddd| |ddddd|d|dddddddddddddS) NrpapsTbothF0shortlongrrorYr7notional marginModemtliquidationPrice entryPriceep unrealizedPnluprr contractSizerrhedgedrrmaintenanceMargin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio) rtr string_absry string_eq string_lt safe_positionr]r/ parse_number)rLrrwrr contractsAbs positionSiders rNrzaster.parse_ws_positions##Hc22$$Xt44 )$*:*:8T*J*JKK --h==  6 ! !F$Y44 *$Y44*#*LL#)L!!# H# $#  d&&xtVDD#   # $**8T:: #  #  $**8T::#  T--h==#  $#  **<88#  D#  #  L#  f#  # !# " ## $,0!'+/# # #    rOc2K|d{Vd}|||}|d}d}d}|d|||\}}|||d{V||d|zz }||}||} || ||||gd|gd{V} |jr| ||}| | |||dS)a watches information on multiple orders made by the user https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#payload-order-update https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#event-order-update :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.type]: 'spot' or 'swap', default is 'spot' if symbol is not provided :returns dict[]: a list of `order structures ` NrYordersr!rT r\rwrsrcrorrtrzr|rfilter_by_symbol_since_limit) rLrYrrr`rwrrirrrs rN watch_orderszaster.watch_orderssY!!!!!!!!!  [[((FH%F 99-QWY]^^ ff---------   4&= (K""4((S!! vt,,,**3 tdVLLLLLLLL ? 3OOFE22E00tTTTrOc2K|d{Vd}|||}|d}d}d}|d|||\}}|||d{V||d|zz }||}||} || ||||gd|gd{V} |jr| ||}| | |||dS)a watches information on multiple trades made by the user https://github.com/asterdex/api-docs/blob/master/aster-finance-spot-api.md#payload-order-update https://github.com/asterdex/api-docs/blob/master/aster-finance-futures-api.md#event-order-update :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.type]: 'spot' or 'swap', default is 'spot' if symbol is not provided :returns dict[]: a list of `trade structures ` NrYmyTradesr!rTr) rLrYrrr`rwrrirrrs rNwatch_my_tradeszaster.watch_my_tradessY!!!!!!!!!  [[((FH%F 99-QWY]^^ ff---------   4&= (K""4((S!! vt,,,**3 tdVLLLLLLLL ? 3OOFE22E00tTTTrOc||d|}||d}|dks|dkr||d|}||||||dS)NrrORDER_TRADE_UPDATE ALGO_UPDATE)rrt handle_orderhandle_my_trade)rLrrrawOrderrs rNhandle_order_updatezaster.handle_order_updates>>'388   Wc * * % % %1 +=+=nnWc7;;G &(+++ VW-----rOcd}||d}|dkr8|jddk}|rdnd}|d|i}|||}||d } ||d i} |i| } ||d } | | | |j} | || j | i} || | }|||d }||d }| |sd }tdt|D]z}||}|d| dkr^| | d|d}t|| d||d |d<d}n{|r|d | n||d| dkrU| |d| d}t|| d||d d<n |d| |d <n|| g|d <d|d <n| |d <||dg}||||d<|j0||jdd}t+||_|j}||||j||dz| z}||j|dSdS)NrxTRADEfstreamrr7r6rirrrYfeesTrrFrrrr)rtrfindsafe_market_structurerrr{rrhashmaprrSrTsumfloatcurrency_to_precisionrxrrrrFrr)rLrrr executionTypeisSwapri fakeMarketrrtradeFeerY cachedOrdersrrrrinsertNewFeeCurrencyrVorderFeer orderTradesrrmessageHashSymbols rNrzaster.handle_my_trade$s ((#66 G # #Z__Y//14F#/66D33VTNCCJ''< > > _":(:2FFF*.((3v;@P*Q*Q7>  !s='9'9Q'>'> ,,UC88M&&u.?.?.?@@ &&uc22 %  K E fX&  $$$UC77  ]     Y//   !"4  "#6  D''(>(>uc(J(JKK  ;    $..44  D**5#66  T%%eS11   I! " d&&uc22# $$$UC00''t44&&uc221      rOc||d}|j}t|}||}||dd|S)Nr)rtrPrrrXr)rLrrrrPrrs rNrzaster.get_market_from_ordersg##E3//,  !3!3!5!566==>OPP $jAAArOc ||d}||d}||dd}|d}||dd}|j|j|j|j|j|j|j|jd}|||}||||dSdS||d} | d kr|||dS| d kr.|||| ||dS| d ks| d kr| ||dSdS) NstreamrrrR_r)rrdepth5depth10depth20rSr bookTickerroutboundAccountPositionACCOUNT_UPDATErexecutionReport) rtrrrr6rVrrrrr) rLrrr rtopicpart2methodsrnrs rNhandle_messagezaster.handle_messages!!'844  <<$$D$$T1b11EKK$$E$$UAr22E, -011*!/"1  G__We44F!vw'''''"!$$Wc22E111##FG44444***##FG444%%fg66666///U>O5O5O((999996P5OrO)N)r6)H__name__ __module__ __qualname__rrKrr,rXrrbrfrrr^rdrrrrrrrrrrrr rrrrrrrr r"r%r!r$r6rr;r>r9r=rVrRrcr^rorrwrtr{rr rrrrrr r rrrrrrrr __classcell__)rMs@rNrrs6 F #F F F F F F Pcs68F"9; = =C =s = = = =6:"&E&E7&E&E&E&E&EP9=R!c!cg!cC!c!c!c!cF:<S"=? A A A3 A A A A:>b(E(Ew(EW(E(E(E(ET=A#c#c'#cPS#c#c#c#cJ/:F/:/:/:/:b&&&P8r's5 AAAAAAAAAAAApppppppppppppppppppppppppp444444......%%%%%%H:H:H:H:H:D  $H:H:H:H:H:rO