":hddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lm Z dd l!m"Z"Gd d ejFjHZ$y) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesInt LiquidationNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List)ArgumentsRequired) BadRequest) NotSupported) ChecksumError)PreciseceZdZdeffd ZdZdZdrdedefdZddifd e d e d e de e fd Z dddifd e e d e d e de e fdZdefdZdsdZddifd e d e d e de e fdZddifd e e d e d e de e fdZdefdZdifd e d e defdZdifd e e d e defdZifd e e defdZifd e defdZdifd e d e defdZdefdZdZdZdZdefdZdefdZ defd Z!defd!Z"ded"e#fd#Z$ddifd e e d e d e de e%fd$Z&ifd e e defd%Z'ifd e defd&Z(ddifd e d e d e de e%fd'Z)dsde%fd(Z*defd)Z+d*ddifd e d e d e de e,fd+Z-ddifd,e e e d e d e fd-Z.ifd,e e e defd.Z/d*ifd e defd/Z0defd0Z1ifd e de2fd1Z3d*ddifd e d e d e de e,fd2Z4defd3Z5ifd e de2fd4Z6ifd e de2fd5Z7difd e8de9fd6Z:difd e8de9fd7Z;difd e8defd8Zdifd;e d e8fd<Z?d=Z@defd>ZAdefd?ZBdefd@ZCdefdAZDd;e d edBeEfdCZFifdDZGifdEZHifdFZIdtdefdGZJdHZKifdeLfdIZMdefdJZNdefdKZOifd e de ePfdLZQdifd e8de ePfdMZRdefdNZSifdeLfdOZTdefdPZUifdQZVdifd e deWdReXdSeYdTeZde[f dUZ\defdVZ]defdWZ^ddifdXe d e deWdReXdSeZdTeZde[fdYZ_defdZZ`difdXe d ede[fd[Zadifd efd\ZbdifdXe d ede[fd]Zcdddifd ed e d e de e[fd^Zddddifd ed e d e de e[fd_Zedddifd ed e d e de e[fd`Zfdddifd ed e d e de e[fdaZgdsdbZhdefdcZidddifd e8d e d e de ePfddZjduded e8fdeZkdfZldgZmdsdhZndddifd ed e d e de e%fdiZodddifd ed e d e de e%fdjZpdefdkZqdddifd ed e d e de e%fdlZrdefdmZsdefdnZtdoZudefdpZvdefdqZwxZxS)vbinancereturnchtt| }|j||j SN)superrdescribe deep_extend describe_data)self superDescribe __class__s J/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/binance.pyr#zbinance.describes.gt57  t/A/A/CDDc6iddddddddddddddd dd dd dd dd dddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$dddddddddd%dd&d&d'd(d)d*d+d,d-idd.d.d/d0d1d2d3d,d4d5id6d7d8d9iid:dd;dd?d?d?d?d=d@|jdAdBdCdDdEdFdGdFdHdFdIdFdJdFdK|jdLdFddMdNiddMdOiddMdOid dMdPidQddRdddSdTdUidddVdWdXdYdZidOd[d\d]d^d_d`dadbdcS)dNwsT watchBalancewatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchBidsAsks watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrderswatchOrdersForSymbolswatchPositions watchTicker watchTickerswatchMarkPriceswatchMarkPrice watchTradeswatchTradesForSymbols createOrderWs editOrderWs cancelOrderWscancelOrdersWsFcancelAllOrdersWsfetchBalanceWsfetchDepositsWsfetchMarketsWsfetchMyTradesWs fetchOHLCVWsfetchOrderBookWsfetchOpenOrdersWs fetchOrderWs) fetchOrdersWsfetchPositionWsfetchPositionForSymbolWsfetchPositionsWs fetchTickerWs fetchTradesWsfetchTradingFeesWsfetchWithdrawalsWsz&wss://stream.testnet.binance.vision/wsz"wss://fstream.binancefuture.com/wsz"wss://dstream.binancefuture.com/wsz-wss://ws-api.testnet.binance.vision/ws-api/v3z*wss://testnet.binancefuture.com/ws-fapi/v1z*wss://testnet.binancefuture.com/ws-dapi/v1)spotfuturedelivery)rVmarginrWrXws-apiz wss://stream.binance.com:9443/wszwss://fstream.binance.com/wszwss://dstream.binance.com/wsz&wss://ws-api.binance.com:443/ws-api/v3z$wss://ws-fapi.binance.com/ws-fapi/v1z$wss://ws-dapi.binance.com/ws-dapi/v1zwss://fstream.binance.com/pm/ws)rVrYrWrXrZpapiz!https://developers.binance.com/en)testapidoc keepAlivei returnRateLimits streamLimits2)rVrYrWrXsubscriptionLimitByStreamstreamBySubscriptionsHash streamIndexwatchOrderBookRatedliquidationsLimitmyLiquidationsLimit tradesLimit ordersLimit OHLCVLimit requestIdwatchOrderBookLimitnametradetickerkline) maxRetrieschecksum)fetchBalanceSnapshotawaitBalanceSnapshot defaultTypeswap)fetchPositionsSnapshotawaitPositionsSnapshotwbOcost miniTicker markPrice ticker_1h ticker_4h ticker_1d bookTicker) 24hrTicker24hrMiniTickermarkPriceUpdate1hTicker4hTicker1dTickerr)r6r-r/r:walletlistenKeyRefreshRater,tickerChannelsMap)hasurls streamingoptions)create_safe_dictionary)r&s r)r%zbinance.describe_datas+d++$T+.t + &t + 0 + + +d+'+!$++D+t+(+!$+ t!+"#+$"4%+&!$'+(t)+*(++, -+.t/+0 1+2!%3+4$T5+6!$7+8"59+:!%;+<"4=+>?+@#DA+B$TC+DE+F"&#',0$(!%!%&+&+U+\ H"J"F$H$S&R(T#   B"D"@$B$L&L(N# !B  ;9>VD"ED  " !D,!! # .D,T-H-H-JDrD$%c%D&$T'D(&t)D*t+D,t-D.d/D0T88:1D2&t3D4G 5D:H ;D@H!ADFGGDN#$ $# -2,0! "60/3.2#(/A#+&2'2 + + +". &uD]S S r*c|j|jd|j}|j||d}|j |d}||jd|<|S)Nrpr) safe_dictrr safe_integersum)r&urlr previousValuenewValues r) request_idzbinance.request_ids]..{D++DLL-LK??4<<HL++L$?K%/K)K7O*5DLL '**?;FJPDLL4 56F G%)__T\\C]%^ "%-;?;V;V;X 78$($5$5dllC]6^`fhi$j !"7:J"J (,(9(9$,,Gb:ceikn(o %"%>> ,Q"QRR?TWg?gDLL3 4V < r*NsymbolsincelimitcHK|j|g|||d{S7w)a watch the public liquidations of a trading pair https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Liquidation-Order-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Liquidation-Order-Streams :param str symbol: unified CCXT market symbol :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :returns dict: an array of `liquidation structures ` N)watch_liquidations_for_symbolsr&rrrparamss r)watch_liquidationszbinance.watch_liquidationss(88&5%QWXXXXs " "symbolsc,K|jd{g}g}d}|j|ddd}|j|r#|jd|jdnst dt |D]D}|j ||} |j| ddz|jd||zF|d d j|zz }|j|} d} |jd | |\} }| d k(rt|jd zd} |jd | |\} }|j| | rd} n|j| | rd} t |} |jdd| dz|j!| || z}|j#|}d||d}d|i}|j%|||j'||||d{}|j(r|S|j+|j,|||dS774w)a watch the public liquidations of a trading pair https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/All-Market-Liquidation-Order-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/All-Market-Liquidation-Order-Streams :param str[] symbols: list of unified market symbols :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :returns dict: an array of `liquidation structures ` N liquidationsTz!forceOrder@arrr lowercaseIdz @forceOrderliquidations::::,r/rVz> watchLiquidationsForSymbols is not supported for spot symbolsrWrXr]r,/ SUBSCRIBEmethodrrr) load_marketsmarket_symbolsis_emptyappendrangelenmarketjoinget_market_from_symbolshandle_market_type_and_paramsrrhandle_sub_type_and_paramsisLinear isInverserrrwatch_multipleextend newUpdatesfilter_by_symbols_since_limitr)r&rrrrsubscriptionHashes messageHashes streamHashir firstMarketrsubTyperrrprequest subscribenewLiquidationss r)rz&binance.watch_liquidations_for_symbolssM!!! # %%gtT4@ == !  % %&< =   01c'l+ DWQZ0"))&*?-*OP$$%5 %BC D $'!22 2J227; 99:WYdflm f 6>TWW'ggh h99:WYdflm ==w 'D ^^D' *D12iit$T*S04;;tZQa3bbOOC( !(  ) !% 3 3C T[]cHdfx{D!EE ??" "11$2C2CWeUZ\`aaO "HEs"HHGHH2HHclientc|j|di}|j|d}|j|ddd}|d}|j||}|j|j|}|(|j |j dd} t| }|j|||j|<|j|gd|j|gd |zy) Noscontractrrjrkrr) rr safe_marketparse_ws_liquidationrrrrrresolve) r&rmessagerawLiquidationmarketIdrr liquidationrrs r)handle_liquidationzbinance.handle_liquidationsP#r:##NC8!!(D"jA!//G t'8'8&A  %%dll4GNE%e,LK($0&! }n5 }&6&?@r*c B|j|d}|j||}|j|d}|j||j |||j |d|j |d|j |ddd||j |d S)NrTl contractSizeap) infor contractsrprice baseValue quoteValue timestampdatetime)rrrsafe_liquidation safe_symbol safe_numberiso8601)r&rrrrs r)rzbinance.parse_ws_liquidationHsV##K5!!(F3%%k37 $$&&x8))+s; ,,V^D%%k48" Y/ &  r*c4K|j|g|||Sw)a watch the private liquidations of a trading pair https://developers.binance.com/docs/derivatives/usds-margined-futures/user-data-streams/Event-Order-Update https://developers.binance.com/docs/derivatives/coin-margined-futures/user-data-streams/Event-Order-Update :param str symbol: unified CCXT market symbol :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :returns dict: an array of `liquidation structures ` )!watch_my_liquidations_for_symbolsrs r)watch_my_liquidationszbinance.watch_my_liquidationss!55vhufUUscK|jd{|j|dddd}|j|}dg}|j|s3t dt |D]}||}|j d|zd} |jd||\} }d} |jd||\} }|j| | rd} n|j| | rd} |j|d{|jd d | d z|j| d z} d} |j| || | gd{} |jr| S|j!|j"|||S7Z7}75w) a watch the private liquidations of a trading pair https://developers.binance.com/docs/derivatives/usds-margined-futures/user-data-streams/Event-Order-Update https://developers.binance.com/docs/derivatives/coin-margined-futures/user-data-streams/Event-Order-Update :param str[] symbols: list of unified market symbols :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :returns dict: an array of `liquidation structures ` NTmyLiquidationsrmyLiquidations::r1rWrXr]r,r listenKey)rrrrrrrrrrr authenticaterrrrrr)r&rrrrrrrrrrrrrs r)rz)binance.watch_my_liquidations_for_symbolss!!!%%gtT4F--g6)* }}W%1c'l+ B $$%7&%@A B99:Y[acij f99:Y[acij ==w 'D ^^D' *D'''iit$T*S04<<3Ek3RR $ 3 3CRVQW XX ??" "11$2C2CWeUZ[[- " (Ys5E7E0CE75E36A E7?E51E73E75E7c|j|d}|dk7ry|j|d}|j|}|j|}|j||}|j |j |}|(|j |jdd} t| }|j|||j |<|j|gd|j|gd|zy)Nr LIQUIDATIONrrlrkrr) rrrrrrrrrrr) r&rr orderTyperrrrrrs r)handle_my_liquidationzbinance.handle_my_liquidationsZ$$Wc2  % ##GS1!!(+!!(+//@ )<)` indexed by market symbols N)watch_order_book_for_symbols)r&rrrs r)watch_order_bookzbinance.watch_order_books&j66xOOOOs !!cK|jd{|j|dddd}|j|d}|d}|dr |drdnd }d }d }|?t|}|d kDrt |j d z|ddj |zz }|j|jdd} g} g} tdt|D]S} || } |j| }| jd| z|ddz|z}|dz| zdz}| j|Ut| }|jdd|dz|j|||z}|j|}d| |d}t||||j|||d}|j!|| |j#||| |d{}|j%S77w)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#partial-book-depth-streams https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#diff-depth-stream https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Partial-Book-Depth-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Diff-Book-Depth-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Partial-Book-Depth-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Diff-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 NFTrrrlinearrWrXdepthmultipleOrderbookrdz} watchOrderBookForSymbols() accepts 200 symbols at most. To watch more symbols call watchOrderBookForSymbols() multiple timesrrrh100 orderbook::r@msr]r,rrr)rrrrrrrr)rrrrrrrrrrrrrrstrhandle_order_book_subscriptionrrr)r&rrrrrrrr symbolsLengthrh subParamsrrrrr symbolHashmessageHashesLengthrrpr subscription orderbooks r)rz$binance.watch_order_book_for_symbolsJs( !!!%%gtUD$Gkk'!*- 6" z "*848*D(  LMs" ,k"kll $'!22 2J!--dll` indexed by market symbols NFTrrrr rWrXr r rrrhr rzunsubscribe:orderbook:rrrr]r,r UNSUBSCRIBErr) unsubscriberrsubMessageHashesrtopic)rrrrrrrrrrrrrrr)r&rrrrrrrrhrrrrrrrrrrrprrs r)un_watch_order_book_for_symbolsz'binance.un_watch_order_book_for_symbolss!!!%%gtUD$Gkk'!*- 6" z "*848*D(   $'!22 2J!--dll` indexed by market symbols N)rr&rrs r)un_watch_order_bookzbinance.un_watch_order_books#996(FKKKK   c^K|jd{|j|}d|di}|||d<|jd||}|dk7rt|jdz|j dd d |}|j |}t|} d } |j|d d d \} }| |d <|j|d}| d|j|j||d} d|ji} |j|| | | | d{} |d| d<| S77w)a fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#order-book https://developers.binance.com/docs/derivatives/usds-margined-futures/market-data/websocket-api/Order-Book :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 NrrrrKrWz, fetchOrderBookWs only supports swap marketsr]r,rZFrAr`r\r rrrr)rrget_market_typerrrrrhandle_option_and_paramsomit sign_paramsrhandle_fetch_order_bookwatch)r&rrrrpayload marketTyperrp messageHashr`rrrs r)fetch_order_book_wszbinance.fetch_order_book_wsse!!!V$ fTl   $GG ))*r?r@)r&rrisSpotr,rrrr-rr3r7r2r8r conditionalrxrEs r)handle_order_bookzbinance.handle_order_bookUs&**//),r1 &VZ ##GS1!!(D$ C!#f, $//) OOF+ !!)W5 = OO " "7 ++ .%%gs3%%gs3&&w5:9W--$($5$5i$M &* $,,-Ei6H+H*mPQTUPUZcdkZlOlK-.Ei6H+HK& ::67IV$y'99 &y+ F'+'9'9:JJX\']H'&3DGGcMDDcDcdjDk4k&l lIg..7!33y?Q9Q ::67IV$ '(:: &y+ F'+'9'9:JJX\']H'&3DGGcMDDcDcdjDk4k&l l ( ; / ( :.B .OOF+((5 a-- .s&$B*HBH?H I",IIc|j|jdd}|j|d}|j|d|g}|j|d|}t dt |D]s}||} | |j vr |j | =|ji||j | <|j|d| i}|j|j|||uy)Nrqrkrrrr) rrrrrrr: order_bookrspawnrF) r&rrrrAsymbolOfSubscriptionrrrrs r)rz&binance.handle_order_book_subscriptions((7LdS #// hG//, *>E'8"bA x8   67L 1 mUK   ' ' =r*rc|j|dg}|j|dg}tdt|D]}||}||}|j|||!|j |y)Nrrr) safe_listrrclean_unsubscription clean_cache)r&rrrrj unsubHashsubHashs r)rgzbinance.handle_un_subscriptions{|_bI >>,8JBOq#m,- BA%a(I&q)G  % %fgy A B &r*c0K|jd{|j|dddd}d}|?t|}|dkDrt|jdz|ddj |zz }d}|j |d d d \}}|j|d }|j|d }|d} |dr |drdnd} g} g} td t|D]H} || } |j| }| jd| z|ddz|z}| j|J|j|d}t| }|jdd| dz|j| ||z}|j|}d| |d}d|i}|j|| |j||| |d{}|j r6|j#|d }|j%|d}|j'||}|j)|||ddS77^w)a2 get the list of most recent trades for a list of symbols https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#aggregate-trades https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#recent-trades https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Aggregate-Trade-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/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 :param str [params.name]: the name of the method to call, 'trade' or 'aggTrade', default is 'trade' :returns dict[]: a list of `trade structures ` NFTmultipleTradesrdw watchTradesForSymbols() accepts 200 symbols at most. To watch more symbols call watchTradesForSymbols() multiple timesrrr@rrrscallerMethodNamerrrr rWrXtrade::rrr]r,rrrrrr)rrrrrrr&r'rrrrrrrrrrrgetLimitfilter_by_since_limit)r&rrrrrrrrrrrrrrrrawHashquerysubParamsLengthrrprrtradesfirst tradeSymbols r)watch_trades_for_symbolsz binance.watch_trades_for_symbolss^ !!!%%gtUD$G%  LMs" ,e"eff $'!22 2J44V=TV\^ef f6#56kk'!*- 6" z "*848*D  q#g,' &AQZF[[(F  V!3 4]+c1D8G   W %  &  &&)i.iit$T*S04;;tZQ`3aaOOC( !  ) **3 t{{7TY?Z\iktuu ??OOFA.E**5(;KOOK7E))&% TRRQ "Fvs#HHFH5H6AHHcK|jd{|j|dddd}d}|?t|}|dkDrt|jdz|ddj |zz }d}|j |d d d \}}|j|d }|j|d }|d}|dr |drdnd}g}g} g} td t|D]\} || } |j| } |jd| z| jd| z| ddz|z}| j|^|j|d}t| }|jdd|dz|j|||z}|j|}d| |d}dt||| |dd}|j|| |j!||| |d{S77w)a unsubscribes from the trades channel https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#aggregate-trades https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#recent-trades https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Aggregate-Trade-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Aggregate-Trade-Streams :param str[] symbols: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.name]: the name of the method to call, 'trade' or 'aggTrade', default is 'trade' :returns dict[]: a list of `trade structures ` NFTrsrdrtrrr@rrrsrurrrr rWrXrvzunsubscribe:trade:rrr]r,rrrr|rrrrrr)rrrrrrr&r'rrrrrrrrr)r&rrrrrrrrrrrrrrryrzr{rrprrs r)un_watch_trades_for_symbolsz#binance.un_watch_trades_for_symbolss8!!!%%gtUD$G%  LMs" ,e"eff $'!22 2J44V=TV\^ef f6#56kk'!*- 6" z "*848*D  q#g,' &AQZF[[(F  # #I$6 7  !5!> ?]+c1D8G   W %  & &&)i.iit$T*S04;;tZQ`3aaOOC( #   i. 0*  ((mT[[RW=XZgiuvvvU "Tws"G#GGG#G!G#!G#cxK|jd{|j|g|d{S77w)a unsubscribes from the trades channel https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#aggregate-trades https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#recent-trades https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Aggregate-Trade-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Aggregate-Trade-Streams :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.name]: the name of the method to call, 'trade' or 'aggTrade', default is 'trade' :returns dict[]: a list of `trade structures ` N)rrr s r)un_watch_tradeszbinance.un_watch_tradesJs;!!!55vhGGG "Gs:6:8::cRKd|d<|j|g|||d{S7w)a1 get the list of most recent trades for a particular symbol https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#aggregate-trades https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#recent-trades https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Aggregate-Trade-Streams https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Aggregate-Trade-Streams :param str symbol: 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 :param str [params.name]: the name of the method to call, 'trade' or 'aggTrade', default is 'trade' :returns dict[]: a list of `trade structures ` r?ruN)rrs r) watch_tradeszbinance.watch_trades[s2 &3!"22F8UE6RRRRs '%'cF|j|d}|dk(}|s|j||S|j|dd}|j|d}|j|dd}|j|d}|r|j|d |}|j|d } | ||t j ||} |j|d } d |vrd nd} |j | dd| } |j|d} d}|j|d}d|vr| |drdnd} |drdnd}d}|j|d}|(|j|d}|j|}||d}|j|d}|j|||j|| ||||| ||| |d S)NxTRADEtrSrLpqrYrpsrrVSrmsellbuymakertakernNrcurrencyr) rrrrrorderr takerOrMakersiderrLrfee) r parse_trade safe_string_2rr string_mulrsafe_string_lowersafe_currency_code safe_trader)r&rsr executionTypeisTradeExecutionrrrrLrrr,rrrorderIdrfeeCost feeCurrencyIdfeeCurrencyCoders r)parse_ws_tradezbinance.parse_ws_tradensR((4 )W4##E62 2   sC 0%%eS1 ""5#s3!!%- %%eS&9Fs+ <!(:))%8##E3/$(EMZ !!(D$ C%%eS1 ""5#. %<|!&sv&+Cj7gL""5#.   ,,UC8M"55mDO+C%%eS1" Y/(   r*c|jjddkD}|rdnd}|j|d}|j|dd|}|d}d|z}|j ||} |j |j |} | (|j|jdd } t| } | j| | |j |<|j| |y) NrXrgrVrrrrvrmrk) rrZrrrrr|rrrrr) r&rrr]r,rrrr-rs tradesArrayrs r) handle_tradezbinance.handle_trade s**//),r1 &VZ ##GS1!!(D$ C!&( ##GV4oodkk6:  %%dllM4HE$U+K5!) F{K0r*1mcK|jd{|j|}|d}d|d<|j||gg|||d{}|||S7F7w)aG watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#klines https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Kline-Candlestick-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Kline-Candlestick-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 :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume Nrr4ru)rrwatch_ohlcv_for_symbols)r&r timeframerrrrr0s r) watch_ohlcvzbinance.watch_ohlcvs{ !!!V$!%1!"33fi5H4I5RWY_``f~i(( "as!A!A9A!A A!A!symbolsAndTimeframescK|jd{d}|j|ddd\}}|j|d}|j|dddd}|j |d}|d} |d r |d rd nd } | d k(} d} |j |dd\} }| duxr| dk(xst j| d} g} g}tdt|D]}||}|d}|d}|j|j||}|j |}|d}|dk(r|jdd}| xr| }d}|r|nd}| j|dz|zdz|z|z|jd|dzdz|z|jdd| dz|j| dz}|j!|}d | |d!}d"|i}|j#|d#}|j%|||j'||||d{\}}}|j(r|j+||}|j-|||dd} |j/||| S7=7Qw)$a` watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#klines https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Kline-Candlestick-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Kline-Candlestick-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 :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume NchannelrrrurFTrrr rWrXrVtimezone+08:008rrindexPriceKline_perpr@+08:00r_ohlcv::rrr]r,r multipleOHLCVrrrru)rhandle_param_string_2get_list_from_object_valuesrrhandle_param_stringr string_eqrrr timeframesreplacerrrrr'rrrrwrxcreate_ohlcv_object)!r&rrrr klineTyper marketSymbolsrrr]risUtc8 rawHashesrrsymAndTf symbolStringtimeframeStringintervalrr shouldUseUTC8suffix utcSuffixrrprrrrcandlesfiltereds! r)rzbinance.watch_ohlcv_for_symbols2s!!!  66vy&RYZ 6223GK++GT5%N kk-"23 6" z "*848*D&.33FJM&$&hh(.B-gwGXGXYacfGg  q#234 XA+A.H#A;L&qkO''/ZH[[.Fm,H--#++GR8#.MF"/RI   X^i7#=H9T U  VH-=!=!D!V W Xiit$T*S04;;t_3UUOOC( !  ) 6#56+/+>+>sMSWS^S^_fhnSoq~AJ,K&K" 7 ??$$VU3E--gueQM'' 8DD[ "R&Ks#IIG-IIAIIc|K|jd{d}|j|ddd\}}|j|d}|j|dddd}|j |d}|d}|d r |d rd nd }|d k(}d} |j |dd\} }| duxr| dk(xst j| d} g} g} g} tdt|D]}||}|d}|d}|j|j||}|j |}|d}|dk(r|jdd}| xr|}d}|r|nd}| j|dz|zdz|z|z| jd|dzdz|z| jd|dzdz|z|jdd|dz|j|d z}|j!|}d!| |d"}dt#|||| | d#d$}|j%|d%}|j'|| |j)||| |d{S7!7w)&a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#klines https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Kline-Candlestick-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Kline-Candlestick-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 dict [params]: extra parameters specific to the exchange API endpoint :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume NrrrrurFTrrr rWrXrVrrrrrrrrrrrrrrzunsubscribe::ohlcv::r]r,rrrrohlcv)rrrrrrrru)rrrrrrrrrrrrrrrrrrr'rr)r&rrrrrrrr]rrrrrrrrrrrrrrrrrprrs r)un_watch_ohlcv_for_symbolsz"binance.un_watch_ohlcv_for_symbolsps!!!  66vy&RYZ 6223GK++GT5%N kk-"23 6" z "*848*D&.33FJM&$&hh(.B-gwGXGXYacfGg  q#234 eA+A.H#A;L&qkO''/ZH[[.Fm,H--#++GR8#.MF"/RI   X^i7#=H9T U  # #Ix0@$@4$G/$Y Z  !7&:J!JT!QTc!c d e iit$T*S04;;t_3UUOOC( #   i.$8 0* 6#56((mT[[RX=Y[hjstttc "bus"H<H7HH<2H:3H<:H<cK|jd{|j|}|d}d|d<|j||gg|d{S7<7w)a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#klines https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/Kline-Candlestick-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Kline-Candlestick-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 :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume Nrr4ru)rrr)r&rrrrs r)un_watch_ohlcvzbinance.un_watch_ohlcvsg!!!V$!%1!"44vy6I5JFSSS "Ts!AA7AAAAc |j|d}ddd}|j|||}|j|d}|j|dd}|dk(r|j|d}|j|d}|j|}|j |d |j |d |j |d |j |d |j |d |j |dg} |j jddkD} | rdnd} |j|dd| } d| zdz|z} |j|j| i|j| <|j|j| |}|:|j |jdd}t|}||j| |<|j| | ||g}|j|| y)NrErmarkPriceKline)indexPrice_klinemarkPrice_klinekrrrrrhrcvrXrgrVrrrrork)rrrfind_timeframerrHrrZrohlcvsrrrr)r&rreventeventMaprurrunifiedTimeframeparsedr]r,rr-storedr resolveDatas r) handle_ohlcvzbinance.handle_ohlcvs6  #. 1/   5%8-%%eS$7 % %''6H##E3/..x8   eS ) OOE3 ' OOE3 ' OOE3 ' OOE3 ' OOE3 '  **//),r1 &VZ !!(D$ C&(4/2BB "oodkk62F FV!46FG >%%dllL$GE*51F4:DKK  0 1 f/8 {K0r*crK|jd{|j|}d|di}|jd||}|dk7rt|jdz|j ddd |}|j |}t|}d |ji} d } |j|dd d \} }| |d <|j|d }d} |j|dd d\} }|| |j|j||d} |j||| || d{} | S77 w)a? fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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 str [params.method]: method to use can be ticker.price or ticker.book :param boolean [params.returnRateLimits]: return the rate limits for the exchange :returns dict: a `ticker structure ` NrrrRrWz) fetchTickerWs only supports swap marketsr]r,rZrFr`r\z ticker.bookr$)rrr%rrrrrhandle_ticker_wsr&r'r(rr*)r&rrrr+rrrpr-rr`rrrts r)fetch_ticker_wszbinance.fetch_ticker_wsse!!!V$ fTl ##OVVD 8 TWW'RRS Siit$X.t4OOC( )n d++ !#'#@#@Zlns#t &&6"#66*66vPXZgh&&t{{7F'CD  zz#{G[,WW 5 "2Xs"D7D2DD7+D5,D75D7cK|jd{|j|}|jd||}|dk7r|dk7rt|jdz|j ddd|}|j |} t| } d } |j|dd d \} }|j|| |j|d } |j|d } |j|d }||| d <||| d<| | | d<| d|j| |d}d|ji}|j|| || |d{S747w)a` query historical candlestick data containing the open, high, low, and close price, and the volume of a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#klines :param str symbol: unified symbol of the market to query 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 :param int params['until']: timestamp in ms of the earliest candle to fetch EXCHANGE SPECIFIC PARAMETERS :param str params['timeZone']: default=0(UTC) :returns int[][]: A list of candles ordered, open, high, low, close, volume NrJrVrWz0 fetchOHLCVWs only supports spot or swap marketsr]r,rZFr`)rr`runtil startTimerendTimeklinesr$r)rrr%rrrrrr& market_idrrr'rhandle_fetch_ohlcvr*)r&rrrrrrr,rrpr-r`r+rrrs r)fetch_ohlcv_wszbinance.fetch_ohlcv_ws(s"!!!V$)).&&I  J($:TWW'YYZ Ziit$X.z:OOC( )n  #'#@#@Ykmr#s &nnV, 0 2  !!&'267+  #(GK  $GG   !&GI kk'62  d-- ZZ['; UUU? ">Vs"EE D.EE E Ec|j|d}|j|}|j|d}|j||y)Nr0r)rl parse_ohlcvsrr)r&rrr0rr-s r)rzbinance.handle_fetch_ohlcvZsE@2""6*&&w5 v{+r*cK|jd{|j|}|j|g|j|ddid{}||S7G7 w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#individual-symbol-mini-ticker-stream https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#all-market-mini-tickers-stream https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Individual-Symbol-Ticker-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/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 :param str [params.name]: stream to use can be ticker or miniTicker :returns dict: a `ticker structure ` Nrur;)rr watch_tickersrr&rrtickerss r) watch_tickerzbinance.watch_tickersd !!!V$**F8T[[J\^kIl5mnnv "n!A"A=A"A  A" A"cK|jd{|j|}|j|g|j|ddid{}||S7G7 w)aK watches a mark price for a specific market https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/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 ` Nrur>)rrwatch_mark_pricesrrs r)watch_mark_pricezbinance.watch_mark_pricesd!!!V$..xVN`brMs9tuuv "urcKd}|j|ddd\}}|jd|||d{}|jr|S|j|jd|S7/w)aY watches the mark price for all markets https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Mark-Price-Stream-for-All-market :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 ` Nr=rrrr)r&watch_multi_ticker_helperrfilter_by_arrayrr&rr channelName newTickerss r)rzbinance.watch_mark_pricessu #;;FDUW]_jk V99:K[Zacijj ?? ##DLL(GDDks1A%A#0A%cKd}|j|ddd\}}|dk(rt|jdz|jd|||d{}|jr|S|j |j d|S7/w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#individual-symbol-mini-ticker-stream https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#all-market-mini-tickers-stream https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Individual-Symbol-Ticker-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/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 ` Nr<rrrtrV deprecation notice - to subscribe for bids-asks, use watch_bids_asks() method insteadr)r&rrrrrrrs r)rzbinance.watch_tickerss ";;FNTZ\de V , &TWW'A A99.+W^`fgg ?? ##DLL(GDDhsABB0Bc|Kd}|j|ddd\}}|dk(rt|jdz|jd{d}|j |dddd}d}d}|du}|r|j |d }|j |||\}}d}|j|||\}}d} |j||rd } n;|j||rd } n&|d k(r|} nt|jd z|zdz|dk(} g} g} g} |rtd t|D]k}||}|j |}| j|ddz|z| j|j||d| | jd|zmn| r8|d k(rt|jd z|zdz| jd|zn| jd|zdz| j|j|d| | jd|}|r|dzdj!|z}|j"dd| dz|j%| |z}|j'|}d| |d}dt)|| | |dd}|j+|| |j-||| |d{S7k7w)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://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#individual-symbol-mini-ticker-stream https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#all-market-mini-tickers-stream https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Individual-Symbol-Ticker-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/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 ` Nr<rrrtrrTFrrWrXrVrY#() does not support options marketsrrrzunsubscribe:ticker:5() requires symbols for self channel for spot markets!@arrzunsubscribe:tickerrrr]r,rrrr)r&rrrrrrrrrrrrrget_message_hashrrrrrrrr)r&rrr methodNamerr,symbolsDefinedr rawMarketTypeisBidAsksubscriptionArgsrrrrrrrrprrs r)un_watch_tickerszbinance.un_watch_tickerss. ";;FNTZ\de V , &TWW'A A!!!# %%gtT5$G  !- ++gaj1K!?? KY_` F99*kSYZ ==W -$M ^^J 0&M 6 !&Mtww}z9 GU[@\^np|}}}u "t~s%A J< J7 I%J<2J:3J<:J<cDK|j|g|d{S7w)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://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#individual-symbol-mini-ticker-stream https://developers.binance.com/docs/binance-spot-api-docs/web-socket-streams#all-market-mini-tickers-stream https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/Individual-Symbol-Ticker-Streams https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/All-Market-Mini-Tickers-Stream https://developers.binance.com/docs/derivatives/coin-margined-futures/websocket-market-streams/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 ` N)rr s r)un_watch_tickerzbinance.un_watch_ticker!s#**F8V<<<` NTFr2rr)rrrrrbidsasks)r&rrr0s r)watch_bids_askszbinance.watch_bids_asks2s{!!!%%gtT5$G55o|U\^dee ??M##DMM8WEE "es!A;A70A;A90A;9A;rcTK|jd{|j|dddd}|dk(}|dk(}|j|dd}d}d} |du} | r|j|d}|rdnd} |j |||| \} }d} |j |||\} }d} |j | | rd} n;|j| | rd } n&| d k(r| } nt|jd z|zd zg}g}d }|r|rdnd }| rstdt|D]Z}||}|j|}|j|ddz|z|z|j|j||d|\n|r8| d k(rt|jd z|zdz|jd|zn4|r|jd|zdz|zn|jd|zdz|j|j|d||}| r|dzdj|z}|j dd| dz|j#| |z}|j%|}d||d}d|i}|j'|||j)||||d{}| s|Si}|||d<|S77w)NTFrr use1sFreqrr|rWrXrVrYrrz@1srrrr r r rrr]r,rrrr)rrrfrrrrrrrrrrr rrrrrrr$)r&r rrrr isMarkPricerrr,r defaultMarketrrrrrrrrrrrprrr0newDicts r)rz!binance.watch_multi_ticker_helperEs*!!!%%gtT5$G</"k1 NN6;=   !- ++gaj1K#.T !?? KY_ano F99*kSYZ ==W -$M ^^J 0&M 6 !&Mtww}z9rrErrr)rrZ isinstancelistrrrrrr;rrr r)r&rr methodTyper]r,rrresolvedMessageHashes rawTickersrrrtr parsedTickerrr-lengthbatchMessageHashs r)r@z$binance.handle_tickers_and_bids_asksLsu**//),r1 &VZ )+ "  gt $ J   g &q#j/* 6A]F$$VS1E$**4<<8K+LeUZ[K"// CL!(+F!-Jv (4 f%'3 V$// VXNK ! ( ( 5 NN< 5# 6&*+ A:#44[$Q  NN:'7 8 r*rcD|rdnd}||dz|zdz|zS|dzdz|zS)Nbidaskrt:rr)r&rrrprefixs r)r zbinance.get_message_hashps>%8  C<+-3f< <C<#% 3 3r*c|j|j|j|jd|}|j |j d}|||d<|j |d}|||d<|j |}|j|}d}|jjddkDrct|jdkDr|j||jd}nv|j|j||jd}nI|j|j||j|jtj }||d<|S) N)rapiKey recvWindowz PRIVATE KEYrgxsha256ed25519 signature)check_required_credentialsrr3rTrrkeysort urlencodesecretrZrrsaeddsaencodehmachashlibrW)r&rextendedParamsdefaultRecvWindowrUrzrYs r)r(zbinance.sign_paramsws> '')kk&  !--dllLI  (#4F< &&v|<  !#-F< n5~. ;;  M *R /4;;#% HHUDKKB  JJt{{5'94;; R  $++e"4dkk$++6NPWP^P^_I&/{#r*c>K|j}d}|jdd|\}}d}|jdd|\}}d}|j|dddd\}}|j ||rd}n|j ||rd}d}|j d|\}}|dk(}|dk(xs|du}|j|d } |j|d }|j|j|i} |j| d d } |j|jd d } |j| d} || z | kDrUd}|r.|j|d{}|j|ddi}n|dk(r|j|d{}n|dk(r|j!|d{}n|dk(r|r|j#|d{}nt|rY| t%|j&dz|j)| }|j|d |i}|j+|d{}n|j-|d{}|j| |j|d|d|j|<|j/| |j0|yy7>7777y7aw)Nrr[portfolioMarginFrWrXisolatedcrossrlastAuthenticatedTimerrri'TrYzC authenticate() requires a symbol argument for isolated margin moderrri) millisecondsrrhandle_option_and_params_2rrhandle_margin_mode_and_paramsrr'rrrrpapiPostListenKeyrfapiPrivatePostListenKeydapiPrivatePostListenKeysapiPostUserDataStreamrrrsapiPostUserDataStreamIsolatedpublicPostUserDataStreamdelaykeep_alive_listen_key)r&rrrrisPortfolioMargin marginModeisIsolatedMargin isCrossMarginrrrirrtresponsers r)rzbinance.authenticates  "99.$PVW f99.$PVW $($C$CFN\bduw|$}!6 ==w 'D ^^D' *D !??PVW F&*4#w.GJ$4F !!&(368,//$,,b9 $ 1 1';RTU V#00?UW^_-u5 ' '% /H !%!7!7!??V.?-FG!!%!>!>v!FF#!%!>!>v!FF!m!%!+DGG6{,{||>>&1Vh-AB!%!D!DV!LL!%!>!>v!FF!%W!--h D)-7"DLL  JJ+T-G-G P/ 0@GFD MFsnEJJ2JJJ#J$ JJAJJ J9J:AJJJJJJcK|j|jddd}|j|d|}d}|j|dddd\}}|j dd|}|d }|j ||rd }n|j ||rd }|j|j|i}|j|d }|yi}|j|d } |j|dd g}|j} |r>|j|j||d{|j|ddi}n|d k(r*|j|j||d{n|d k(r*|j|j||d{nb||d <|dk(r/| |d <|j|j||d{n)|j|j||d{|j||| d|j|<t'|j2j5}|j7|jdd}t-d t/|D]n}||}t'|j8j+}t-d t/|D],}||}||k(s|j;||j<|ypy777W7!7#t $r} |} |rd} |j"dd| dz|j|d z} |j%| }t'|j(j+}t-d t/|D]}||}|j1| ||j|dd d|j|<Yd} ~ yd} ~ wwxYww)Nr{rrVrkeepAliveListenKeyr[rfFrrWrXrrTrYr]r,rrjrr)rrrrlrrrrr'rkpapiPutListenKeyrfapiPrivatePutListenKeydapiPrivatePutListenKeysapiPutUserDataStreampublicPutUserDataStreamr>rrrGfutureskeysrrr@clientsvaluesrr?rtru)r&rrrv subTypeInforrrrrrerrorurlTyperrrrr-rrsubscriptionKeysro subscribeTypes r)ruzbinance.keep_alive_listen_keys!!$,, ~vV5 $($C$CFL`bhj{~C%D!6556JDRXY a. ==w 'D ^^D' *D//$,,b9$$Wk:   !!&(36FH#56  "  ++DKK,HIIIV.?-FG!224;;w3OPPP#224;;w3OPPP'0 $8#(.GH%44T[[&5QRRR66t{{7F7STTT "[["%)3   T t||**,-#00?UW^_q#g,' AQZF#F$8$8$=$=$?@ 1c"234  0 3  D(JJ3T5O5OQWX   GJQP ST G  ))E"4(1C7$,,t:L[:YYC[[%F !4!4!67M1c-01 2+A.  e[1 2"&W!)*7"DLL   sC7N?:&K1 K#!AK1#K&$.K1K)8K1 K, )K15K/6K1:CN??$N?#K1&K1)K1,K1/K11 N<:B8N72N?7N<<N?c,||jvry|j|jd}|j|dd}|rE|dz}||jvr1|j ||j |j||||yyi|j|<y)Nr-ryF:fetchBalanceSnapshot) r?rrrfrrWrbload_balance_snapshotbalance)r&rrrvrryr-s r)set_balance_cachezbinance.set_balance_cache s 6'' ' //$,,?#~~g7MuU !88K6>>1 k* 455v{DRcd2"$DLL r*cNKd|i}|rd|d<|j|d{}|j||j|j|i|j|<|j|}|j |j |j||dzy7w)NrTrf:balance) fetch_balancerrrrr)r&rr-rrvrrzrWs r)rzbinance.load_balance_snapshot s D  (,F$ %++F33![[4??4<` NrFrVrWrXz2 fetchBalanceWs only supports spot or swap marketsr]r,rZFr`rzaccount.statusr$) rr%rrrrrr&r(rhandle_account_status_wshandle_balance_wsr*) r&rrrrpr-r`r+rrrs r)fetch_balance_wszbinance.fetch_balance_ws sV!!!##$4dFC 6>dh.4:3ETWW'[[\ \iit$X.t4OOC( )n  #'#@#@IY[mot#u &  0 66v?OQY[kl&&t{{7F'CD  BR8Rd33Y]YoYo ZZ['; UUU- ",Vs"D%D DD%D#D%#D%c |j|d}d}t|dtr|j|dg}n&|j |di}|j|dg}|j |}|j ||y)Nrr0assets)rrFrGrlrparseBalanceCustomr)r&rrr- rawBalancer0parsedBalancess r)rzbinance.handle_balance_wsC s&&w5  gh' .2>J^^GXr:F"=J00<~{3r*c|j|d}|j|di}|j|}|j||yNrr0)rrrr)r&rrr-r0rs r)rz binance.handle_account_status_wsR sG^&&w5 26008~{3r*cDK|j|g|d{S7w)a fetch data on an open position https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Position-Information :param str symbol: unified market symbol of the market the position is held in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `position structure ` N)fetch_positions_wsr s r)fetch_position_wszbinance.fetch_position_ws s#,,fXv>>>>r"cK|jd{i}d}|j|dddd}|,t|}|dk(r|j|d}|d|d<|j d||}|d k7r|d k7rt |j d z|jd d d|}|j|}t|} d} |j|ddd\} }| |d<d} |j|ddd\} }| | |j|j||d} d|ji} |j|| | | | d{}|j|d|dS7P7w)a fetch all open positions https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Position-Information https://developers.binance.com/docs/derivatives/coin-margined-futures/trade/websocket-api/Position-Information :param str[] [symbols]: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.returnRateLimits]: set to True to return rate limit informations, defaults to False. :param str|None [params.method]: method to use. Can be account.position or v2/account.position :returns dict[]: a list of `position structure ` Nr|TrrrrrQrWrXz, fetchPositionsWs only supports swap marketsr]r,rZFr`rzaccount.positionr$)rrrrr%rrrrrr&r(rhandle_positions_wsr*filter_by_array_positions)r&rrr+rrrrrpr-r`rrrr0s r)rzbinance.fetch_positions_ws s!!!%%gvtT4H  LM!WQZ0$*4L!##$6G 8  2TWW'UUV Viit$X.t4OOC( )n  #'#@#@I[]oqv#w &&6"#66v?QS[]op&&t{{7F'CD  d.. zz#{G[,WW--fhOO; "8Xs"E+E&D6E+ E)E+)E+c<|j|d}|j|dg}g}tdt|D]K}|j ||}|j|d}|dk7s/|dk7s5|dk7s;|j |M|j ||y)Nrr0r entryPrice0z0.0z 0.00000000)rrlrrparse_position_riskrr) r&rrr-r0 positionsrrrs r)rzbinance.handle_positions_ws s>&&w5 26 q#f+& )A--fQi8F))&,?Jc! e(;*P\B\  (  ) y+.r*crK|jd{|j|d{|j|jdd}|j|d|}d}|j dd|\}}d}|j |dddd\}}|j ||rd }n|j||rd }|}|rd}|jd d |d z|j|dz}|j|}|j||||j||d||j|jd} |j| dd} |j| dd} | r| r|j|dzd{|dz} d} |j|| | |d{S777-7 w)a watch balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.portfolioMargin]: set to True if you would like to watch the balance of a portfolio margin account :returns dict: a `balance structure ` Nr{rVrr-r[rfFrWrXr]r,rrryrzTrr)rrrrrrlrrrrrset_positions_cacherrfrWr*)r&rr{rrrvrrrrryrzr-rs r) watch_balancezbinance.watch_balance s!!!'''&&t||]FK  <99.$PVW $($C$CFN\bduw|$}!6 ==w 'D ^^D' *D Giit$W-3dll46H6UUS! vt->?   t5FG..~>#~~g7MuU#~~g7MtT $8--'> >? ? ?Z' ZZ['4@@@5 "', @AsDF7F-F7F0EF7F3"F7(F5)F70F73F75F7cP|j|jdd}t|jj }|d}|dz}|j |i|j |<||j |d<|j|d}|dk(r|j|d}|j |} |j} |j|d } | |j |vrP|j || d } t| ts|j| } tj| | | d <n| | d <| |j || <n|j|d|}|j|d } tdt!| D]}| |}|j|d}|j |} |j} |j|d | d <|j|d | d<|j||| d<| |j || <|j#|d}||j |d<|j%||j |d<|j'|j ||j |<|j)|j ||y)NrrrrrrE balanceUpdaterSdfreer&frusedtotalrVrr)rrrGr?rrraccountrFrrr string_addrrlrrrr safe_balancer)r&rrrr? accountTyper-r currencyIdcoderrKrr&rentryrs r)handle_balancezbinance.handle_balance st!!$,,$?V116689 #A& !J. << $ ,(*DLL %,3 [!&)  #. O #))'37J**:6DllnG$$Wc2Et||K00 $ [ 9$ ? G !-5$($9$9-$HM")"4"4]E"J"'.5DLL %d +nnWc7;Gw,A1c!f% :!!--eS9 ..z:,,."&"2"25#">"&"2"25#">#'#3#3E6#B 29 [)$/ :%%gs3 1: [!+.04 Y0G [!*-$($5$5dll;6O$P [!t||K0+>r*cd}|j|||\}}d}|j|||\}}|j||rd}|S|j||rd}|S)NrWrX)rrrr)r&rrrrrs r)r%zbinance.get_market_typem sp99&&&Q f99&&&Q ==w 'D ^^D' *D r*rrLrcK|jd{|j|}|jd||}|dk7r"|dk7r|dk7rt|jdz|j ddd |} |j | } t| } |j|d d d } |j|d d }|j||||||} d }|j|dd d \}}|| d <|j|dd }|j|d}| d|j|j| |d}|r | rd|d<nd|d<d|ji}|j!| | || |d{S7c7w)a[ create a trade order https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#place-new-order-trade https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/New-Order https://developers.binance.com/docs/derivatives/coin-margined-futures/trade/websocket-api :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float|None [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean params['test']: test order, default False :param boolean params['returnRateLimits']: set to True to return rate limit information, default False :returns dict: an `order structure ` NrArVrWrXz1 createOrderWs only supports spot or swap marketsr]r,rZsorSORFr`r\z order.placer$zsor.order.testrz order.test)rrr%rrrrr safe_bool_2r'create_order_requestr&rfr(rhandle_order_wsr*)r&rrrrLrrrr,rrpr-rr+r`r\rrs r)create_order_wszbinance.create_order_wsx s$!!!V$))/66J  J($:zZ?WTWW'ZZ[ [iit$X.z:OOC( )n vueU;65%0++FD$vV #'#@#@Zlns#t &&6"#~~ffe466*#&&t{{7F'CD  $4!$0! d** ZZ['; UUU; ":Vs"E>E9EE>4E<5E><E>c|j|d}|j|di}|j|}|j||yrrr parse_orderr)r&rrr-r0rs r)rzbinance.handle_order_ws sG`&&w5 26  (uk*r*c|j|d}|j|dg}|j|}|j||yr)rrl parse_ordersr)r&rrr-r0orderss r)handle_orders_wszbinance.handle_orders_ws sGL&&w5 26""6*v{+r*rc K|jd{|j|}|jd||} | dk7r"| dk7r| dk7rt|jdz|j ddd | } |j | } t| } | dk(xs| dk(} d}| dk(r|j|||||||}n| r|j|||||||}d }|j|dd d \}}||d <| | rd nd |j|j||d}d|ji}|j| | || |d{S7:7w)a edit a trade order https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#cancel-and-replace-order-trade https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Modify-Order https://developers.binance.com/docs/derivatives/coin-margined-futures/trade/websocket-api/Modify-Order :param str id: order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of the currency you want to trade in units of the base currency :param float|None [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` NrBrVrWrXz/ editOrderWs only supports spot or swap marketsr]r,rZFr`z order.modifyzorder.cancelReplacer$r)rrr%rrrrreditSpotOrderRequesteditContractOrderRequestr&r(rhandle_edit_order_wsr*)r&rrrrrLrrrr,rrpr-isSwapr+r`rrs r) edit_order_wszbinance.edit_order_ws s"!!!V$))-H  J($:zZ?WTWW'XXY Yiit$X.z:OOC( )n (DJ*,D  //FD$PUW]^G 33BdFTY[abG #'#@#@Xjlq#r &&6"#)/n6K&&t{{7F'CD  d// ZZ['; UUU3 "2Vs"EED4E E EEc|j|d}|j|di}|j|d}d}||j|}n|j|}|j||y)Nrr0newOrderResponser)r&rrr-r0 newSpotOrderrs r)rzbinance.handle_edit_order_ws5 ssF&&w5 26~~f.@A   #$$\2E$$V,Euk*r*cK|jd{|t|jdz|j|}|j d||}|j ddd|}|j |}t|}d} |j|ddd\} }|j|| d } |j|d d } | | | d <n|j|| d <|j|d d g}|d |j|j| |d} d|ji} |j!||| || d{S777w)ak cancel multiple orders https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#cancel-order-trade https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Cancel-Order https://developers.binance.com/docs/derivatives/coin-margined-futures/trade/websocket-api/Cancel-Order :param str id: order id :param str [symbol]: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :param str|None [params.cancelRestrictions]: Supported values: ONLY_NEW - Cancel will succeed if the order status is NEW. ONLY_PARTIALLY_FILLED - Cancel will succeed if order status is PARTIALLY_FILLED. :returns dict: an list of `order structures ` N cancelOrderWs requires a symbolrCr]r,rZFr`rr`origClientOrderId clientOrderIdr order.cancelr$r)rrrrr%rrrr&rr parse_to_intr'r(rrr*r&rrrrrrrpr-r`r+rrrs r)cancel_order_wszbinance.cancel_order_ws sy!!! >TWW'IIJ JV$##OVVDiit$X.t4OOC( )n  #'#@#@Zlns#t &nnV, 0 **63FX  $+8G' (!%!2!22!6GI 6$7#IJ$&&t{{7F'CD  d** ZZ['; UUU9 "8Vs"EE D1EE EEc0K|jd{|j|}|jd||}|dk7r|dk7rt|jdz|j ddd|}|j |}t|}d }|j|dd d \}}|j||d } |d |j|j| |d } d|ji} |j||| || d{S77w)a cancel all open orders in a market https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#cancel-open-orders-trade :param str [symbol]: unified market symbol of the market to cancel orders in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NrErVrWz5 cancelAllOrdersWs only supports spot or swap marketsr]r,rZFr`rrr$r)rrr%rrrrrr&rr(rrr*) r&rrrrrrpr-r`r+rrs r)cancel_all_orders_wszbinance.cancel_all_orders_ws s3!!!V$##$7H 6>dh.TWW'^^_ _iit$X.t4OOC( )n  #'#@#@I\^prw#x &nnV, 0  $&&t{{7F'CD  d++ ZZ['; UUU- ",Vs"DDC6D DDDcK|jd{|t|jdz|j|}|j d||}|dk7r"|dk7r|dk7rt|jdz|j dd d |}|j |}t|}d } |j|dd d \} }|j|| d } |j|dd} | | | d<n|j|| d<|d|j|j| |d} d|ji} |j||| || d{S7J7w)a fetches information on an order made by the user https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#query-order-user_data https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Query-Order https://developers.binance.com/docs/derivatives/coin-margined-futures/trade/websocket-api/Query-Order :param str id: order id :param str [symbol]: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` NrrMrVrWrXz0 fetchOrderWs only supports spot or swap marketsr]r,rZFr`rrrrz order.statusr$r)rrrrr%rrrr&rrrr(rrr*rs r)fetch_order_wszbinance.fetch_order_ws s!!! >TWW'IIJ JV$##NFFC 6>dh.4:3ETWW'YYZ Ziit$X.t4OOC( )n  #'#@#@Ykmr#s &nnV, 0 **63FX  $+8G' (!%!2!22!6GI $&&t{{7F'CD  d** ZZ['; UUU; ":Vs"E%E EE%E#E%#E%cK|jd{|t|jdz|j|}|j d||}|dk7rt|jdz|j ddd|}|j |}t|} d } |j|d d d \} }|j|| d } | d |j|j| |d} d|ji} |j|| | | | d{}|j||||S7%7w)a fetches information on multiple orders made by the user https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#order-lists :param str symbol: unified market symbol of the market orders were made in :param int|None [since]: the earliest time in ms to fetch orders for :param int|None [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.orderId]: order id to begin at :param int [params.startTime]: earliest time in ms to retrieve orders for :param int [params.endTime]: latest time in ms to retrieve orders for :param int [params.limit]: the maximum number of order structures to retrieve :returns dict[]: a list of `order structures ` Nz fetchOrdersWs requires a symbolrNrVz) fetchOrdersWs only supports spot marketsr]r,rZFrMr`r allOrdersr$r)rrrrr%rrrr&rr(rrr*filter_by_symbol_since_limitr&rrrrrrrrpr-r`r+rrrs r)fetch_orders_wszbinance.fetch_orders_ws sZ !!! >TWW'IIJ JV$##OVVD 6>TWW'RRS Siit$X.t4OOC( )n  #'#@#@Ykmr#s &nnV, 0  !&&t{{7F'CD  d++ zz#{G[,WW00NN3 "0Xs"ED;D E"D>#E>EcK|j||||d{}g}tdt|D]!}||}|ddk(s|j|#|S7Aw)a  fetch closed orders https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#order-lists :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch open orders for :param int [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nrstatusclosed)rrrr) r&rrrrr closedOrdersrrs r)fetch_closed_orders_wszbinance.fetch_closed_orders_wsG sq++FE5&II q#f+& +A1IEX(*##E* + JsAA+AAcfK|jd{|j|}|jd||}|dk7r|dk7rt|jdz|j ddd|}|j |}t|} d } |j|d d d \} }d | i} ||j|| d <| d |j|j| |d} d|ji} |j|| | | | d{}|j||||S77w)aQ fetch all unfilled currently open orders https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/trading-requests#current-open-orders-user_data :param str symbol: unified market symbol :param int|None [since]: the earliest time in ms to fetch open orders for :param int|None [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NrLrVrWz5 fetchOpenOrdersWs only supports spot or swap marketsr]r,rZFrMr`rzopenOrders.statusr$r)rrr%rrrrrr&rr(rrr*rrs r)fetch_open_orders_wszbinance.fetch_open_orders_ws[ sX!!!V$##$7H 6>dh.TWW'^^_ _iit$X.t4OOC( )n  #'#@#@Ykmr#s &  0    $v 6GH )&&t{{7F'CD  d++ zz#{G[,WW00NN1 ".Xs"D1D,C` NrrrPr8rWrXrrrYrVr[rfFr]r,rrT)rrrrrrrrrmrlrrrrrr*rrwr)r&rrrrr-rrrrwrrvrrrrs r) watch_orderszbinance.watch_orders s !!!   [[(FH%F 3< 'K99-QWX f99-QWX ==w 'D ^^D' *DVdf%EF''' !?? vV F H 46> 8NG $($C$CFM[actv{$|!6 Giit$W-3dll46H6UUS! vt->?   t5FGzz#{GTBB ??OOFE2E00tTTE " (Cs5GF?B*GGCGG8GGGc |j|d}|j|d}|j|d}d|vrdnd}|j|dd|}|j|d}|j|d} d} |d k(s |d k(s|d k(r| | }n|d k(r| } | } d} |j|d } | >tj| dr(|j|d}|j |}| |d} |j|d}|j|d}|j |d}|j |d}|j|d}|j|d}|j|d}|j|d}|j|}d}|j|d}|t|dk(r|j|d}|j|dd}|j|d}|dk(rd }|jid!|d"|d#|d$|d%|d&|j|d'| d(| d)|d*|d+dd,|j|d-d.|d/|d0|d1|d2||||d|| |d3S)4NrrrrrrVOrNEW AMENDMENTCANCELEDrrrrrrrrrzZrXr rrr5sprGTXPOrrrrrrlastTradeTimestamplastUpdateTimestampr timeInForcepostOnly reduceOnlyRrr stopPrice triggerPricerL)rr6filled remainingrrr|) rrrr string_gtrrparse_order_statusrr safe_orderrrf)r&rrrrrr,rrrrrrrr feeCurrencyrrLrrrrr6 rawStatusrr|rrrs r)parse_ws_orderzbinance.parse_ws_order s9Z((4 ""5#.##E3/$(EMZ !!(D$ C%%eS1   eS )! E !]k%A]V`E`  g %!" ""5#.  g&7&7&E ,,UC8M11-@K'C  ,!!%-%%eS1%%eS1!!%-s+""5$/$$UC0 ((3((4  !s='9Q'> ,,UC8M&&uc48 &&uc2 % K E f  '  ]     Y/   !"4  "#6  D  ;    $..4  D  U   I! " f# $1   r*c|j|d}|dk(r|j|d|}|j|||j|||j ||y)NrEORDER_TRADE_UPDATEr)rrhandle_my_trade handle_orderr)r&rrrEs r)handle_order_updatezbinance.handle_order_updateF sbd   Wc * $ $nnWc7;G VW- &'* ""673r*cK|jd{d}d}|j|}|j|s%|j|}ddj |z}d}|j d||\}}|dk(s|dk(rd}d}|j d||\}}|j||rd}n|j||rd }i} || d <|| d <|j|j| |d{|d z|z}d} |j|dd dd\} }|} | rd } |jdd| dz|j|dz} |j| } |j| || |j!| ||| |j#ddd}|j#ddd}|j%|j&|}|r5|r3|1| j)|dzd{}|j+||||dS|j-| |d|d{}|j.r|S|j+||||dS7-7K7^7/w)a  watch all open positions :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 :param boolean [params.portfolioMargin]: set to True if you would like to watch positions in a portfolio margin account :returns dict[]: a list of `position structure ` Nrrrr:rVrYrWrXrr :positionsr[rfFr]r,rrr}Tr~:fetchPositionsSnapshot)rrrrrrrrrrrrlrrrrrr[rrrWrr*r)r&rrrrrr-rrmarketTypeObjectrvrrrr}r~r<rB newPositionss r)watch_positionszbinance.watch_positions s!!! %%g.}}W%11':F'!22K99:JFTZ[ f 6>TX-D99:JFTZ[ ==w 'D ^^D' *D!##' &-# ,?   w8IJ!%!3!34DF^`d!e!%!3!34DF^`d!e5 !&<#]]42K+KLLH55hPUW[\ \!ZZ[$EE ?? 11%%PTUUQ "( GMEsGI IC$I ;I  >> !DN 4>> ! !%!3!34DF^`e!f !!::K6>>1 k* 477dTef2$<#=DNN4 r*cKd|i}|rd|d<|jd|d{}t|j|<|j|}tdt |D]1}||} |j | dd} | dkDs!|j | 3|j|} | j||j||dzy7w)NrTrfrrz :position) fetch_positionsrrrrrrrr) r&rr-rrvrrr<rpositionrrWs r)rzbinance.load_positions_snapshot s D  (,F$ %..tV<< 79tt$q#i.) 'A |H((;BI1} X&  '  ,uud[01=s!CC ACA Cc|t|jj}|d}|ji|_||jvrt |j|<|j|}|j |di}|j |dg}g}tdt|D]e} || } |j| } |j|d} | | d<|j| | d<|j| |j| g|j||dz} tdt| D]f} | | }|jd}|d }|jd }|j|d |d }|j!|rU|j#||h|j#||d zy)NrrSr5rVrrz :positions::rrrrFr)rGr?rrrrrlrrparse_ws_positionrrrfind_message_hashessplitrrr)r&rrr?rr<data rawPositionsrr rawPositionrrrr-parts symbolsStringrrs r)handle_positionszbinance.handle_positions s<V116689 #A& >> !DNt~~-*B*DDNN; '{+~~gsB/~~dC4  q#l+, #A&q/K--k:H))'37I$-H[ !#'<< #:HZ    ) LL " #00~9UV q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |[<%?@r*c h|j|d}|j|d}tj|j|d}|j|d}d}|dk(r3d}tj|dstj |drd}nd }|j id |d dd |j|ddd ddd|j|dddd|j|dd|j|dddd|j|ddddd|d|dddddddddddddS) NrparTbothFrshortlongrrrrnotionalrwmtliquidationPricerep unrealizedPnlupr4rrrrhedgedrrmaintenanceMargin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio) rr string_absrr string_lt safe_positionrr parse_number)r&rrrr contractsAbs positionSider/s r)rzbinance.parse_ws_position1s##Hc2$$Xt4 ))$*:*:8T*JK --h=  6 !F$$Y4$$Y4#*L#)L!!# H# $#  d&&xtZH#   # $**8T: #  #  $**8T:#  T--h=#  $#  **<8#  D#  #  L#  f#  # !# " ## $,0!'+/#   r*cK|jd{|t|jdz|j|}|j d||}|dk7r#|dk7rt|jdz|zdz|j dd d |}|j |}t|} d } |j|dd d \} }|j|| d } ||| d<||| d<|j|d} | |t|jdz| d|j|j| |d} d|ji}|j|| | | |d{}|j||||S7l7w)a fetch all trades made by the user https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/account-requests#account-trade-history-user_data :param str symbol: unified market symbol :param int|None [since]: the earliest time in ms to fetch trades for :param int|None [limit]: the maximum number of trades structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.endTime]: the latest time in ms to fetch trades for :param int [params.fromId]: first trade Id to fetch :returns dict[]: a list of `trade structures ` Nz" fetchMyTradesWs requires a symbolrIrVrWz" fetchMyTradesWs does not support  marketsr]r,rZFr`rrrfromIdz_ fetchMyTradesWs does not support fetching by both fromId and since parameters at the same timemyTradesr$r)rrrrr%rrrr&rrr(rhandle_trades_wsr*r)r&rrrrrrrrpr-r`r+r?rrr|s r)fetch_my_trades_wszbinance.fetch_my_trades_wsds!!! >TWW'KKL LV$##$5vvF 6>dh.TWW'KKdRU__` `iit$X.t4OOC( )n  #'#@#@IZ\npu#v &nnV, 0   #(GK  $GG ""684  %"3TWW(IIJ J &&t{{7F'CD  d++ zz#{G[,WW00NNA ">Xs"FFEF)F*FFcK|jd{|t|jdz|j|}|j d||}|dk7r#|dk7rt|jdz|zdz|j dd d |}|j |}t|} d } |j|dd d \} }|j|| d } ||| d<| d|j| |d} d|ji} |j|| | | | d{}|j|||S7'7w)a fetch all trades made by the user https://developers.binance.com/docs/binance-spot-api-docs/websocket-api/market-data-requests#recent-trades :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trades structures to retrieve, default=500, max=1000 :param dict [params]: extra parameters specific to the exchange API endpoint EXCHANGE SPECIFIC PARAMETERS :param int [params.fromId]: trade ID to begin at :returns dict[]: a list of `trade structures ` Nz+ fetchTradesWs() requires a symbol argumentrSrVrWz fetchTradesWs does not support r>r]r,rZFr`rrztrades.historicalr$r)rrrrr%rrrr&rrrAr*rx)r&rrrrrrrrpr-r`r+rrr|s r)fetch_trades_wszbinance.fetch_trades_wsso!!! >TWW'TTU UV$##OVVD 6>dh.TWW'IIDPS]]^ ^iit$X.t4OOC( )n  #'#@#@Zlns#t &nnV, 0   $GG )kk'62  d++ zz#{G[,WW))&%??7 "4Xs"ED=DE%E&EEc|j|d}|j|dg}|j|}|j||yr)rrl parse_tradesr)r&rrr-r0r|s r)rAzbinance.handle_trades_wssG\&&w5 26""6*v{+r*cK|jd{d}d}||j|}|d}|jd||\}}d}|jd||\}}|j ||rd}n|j ||rd}d}|1|j |}|d|zz }|j||d|d }|j|d{|} |d k(rd } d} |j|dd d d\} }| rd } |jdd| dz|j|dz} |j| } |j| || |j| |d| d} |j| || |d{}|j r|j#||}|j%||||dS777<w)ai 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 boolean [params.portfolioMargin]: set to True if you would like to watch trades in a portfolio margin account :returns dict[]: a list of `trade structures ` Nrr3rWrXr@rPrrrYrVr[rfFr]r,rrT)rrrrrrrrrrlrrrrrr*rrwr)r&rrrrrrrr-rrvrrrr|s r)watch_my_tradeszbinance.watch_my_tradess!!!  [[(FH%F99/6SYZ f99/6SYZ ==w 'D ^^D' *D  [[(F 3< 'K[[&.F)STF''' 8 G $($C$CFO]cevx}$~!6 Giit$W-3dll46H6UUS! vt->?   t5FGzz#{GTBB ??OOFE2E00tTTE "$ (Cs5F>F7CF>F:B'F>?F<8F>:F><F>cDd}|j|d}|dk(r|j|}|j|d}|j|di}|ji|}|j|d}||||j} | }|j | j |i} |j | |} | K|j | d} |j | d} |j| sd}td t| D]U}| |}|d |d k(s|j|d |d }t|j|d || d|d <d }n|r|| dj|ng| `| d |d k(r=|j| d |d }t|j|d || dd <n| d || d<n| |g| d<d| d<n|| d<|j| d g}|j||| d <|j-|j!|j"dd}t%||_|j}|j||j'|j||dz|z}|j'|j|yy)Nr@rrrrrfeesTrrrFr|rmrkrP)rrrrrrhashmaprrrrfloatcurrency_to_precisionrrlr@rrrr)r&rrr-rrsrtradeFeer cachedOrdersrrrJrinsertNewFeeCurrencyrorderFeer orderTradesrr@messageHashSymbols r)r zbinance.handle_my_trade!s ((#6 G #''0E&&ug6G~~eUB7H{{2x0H%%eX6F"x';@R#{{ +!__\-A-A62NF OOFG _":(:2FF*.((3v;@P*Q7} | | } |j|j| d} || k(s-|j|| @Yd}~d}~wwxYw) NrFrrmsgTr5)rrr handle_errorsrjsonr>r@rGr?rrrr;)r&rrrrejectedrrrYrErrrsubscriptionId codeStrings r)handle_ws_errorzbinance.handle_ws_errorysj  gt ,w4  /ue, 7   tS&**dD$))EBRTY[_ae f MM'2 &%%eV4  "A#)= LL !*> " 7H MM!R #F$8$8$=$=$?@ 1c"234 7#3A#6 !%!1!1&2F2FGW2XZ^!_'MM!%56  7 7s 2C E# A8EEE#c |j|d}|j|d}|||dk7r|j||y|j|d}|j|j|}|j|d}| |||yid|jd|j d|j d |j d |j d |j d |jd |jd|jd|jd|jd|jd|jd|jd|jd|jd|j|j|j|j|j|j|j|j|jd}|j|d} t|tr|d} |j| ddz} |j|| }|G|j|d} | |j||y| d|vrd|vr|j||yyyy|||y)Nrr200rr depthUpdatersaggTraderurrz 1hTicker@arrz 4hTicker@arrz 1dTicker@arrz24hrTicker@arrz24hrMiniTicker@arrrrrrrr)zmarkPriceUpdate@arrroutboundAccountPositionrACCOUNT_UPDATEexecutionReportr  forceOrderrErr rSrU)rrr`r?r_rrrDrBrrWrrrFrGrj) r&rrrrrr?rmethodsrrrps r)handle_messagezbinance.handle_messages!!'841  6#5&E/   1    gt ,(<((($7I$//@}#.sg~%%fg68F.} 67 #r*)rr!)F)NF)y__name__ __module__ __qualname__rr#r%rrrrr rr rrrrrrrrr rrrr!r.r)rFrMrPr=r_rrjdictrgrrrrrrrrGrrrrrrrrrrrrrrrrrrrr;rrBrDr@boolr r(rrurrrrrrrrrrrrr%rrrLr r rrrrrrrrrrrrr rrrrr#rrBrDrArHr r rWr`rj __classcell__)r(s@r)rrs E#ET l3#.BFTXac Ys Y3 Yc Yhlmxhy YIM[_nr{}4bDI4bUX4bhk4bCGHSCT4bl4A4AlX tEIW[df V# Vc VQT Vkop{k| VX\jnwy#\tCy#\QT#\dg#\CDOP#\J;CF;Cz@DB5PS5P5PS\5PnSW_a9!$s)9!C9!fo9!vPR5xT#Y5xVY5xn=?LL3L"CGr''C'V_'R/f/>+*Z& 3T.T.lVVV $'V'4'OSaenp8Sd3i8S8S[^8SuyzvA8StLN8wc8wRU8wt9;HCHsH"<@d[]SSSSSbfglbmS&Y EY v161$8<$]ajl))C)WZ)quvzq{).aeswAC<E$tCy/<EZ]<Emp<E|^`>uT$s)_>udg>u@;?rT3TcT(=16=1~9;#C#v#J;?T`dmo0V30Vs0VZ]0Vtxy}t~0Vd$,$,L68F*:<S :>bEwEWE*6:"E7EE09=RM~gM~CM~^9;=C=s="8-/%V8%VN 4 424v24h;= ?c ?h ?;?r*P*PdS[n*PX'/&'/R*,!A!AFa?Va?F68 pt|~/VC/Vy/V /V[`/Vil/VDI/Vb3+f3+j),v),Vim{IK*Vc*V3*Vi*Vy*Vbe*Vux*VPU*VXk+6k+Z<@*V*VS*Vu*VX8D_cln3cY\swx}s~(8<$]ajl$O$OC$OWZ$Oquv{q|$OL04$UYbd2U2UC2Us2Uimnsit2UhO bW4&W4r8<$]ajl2VW2VC2VWZ2Vquv~q2Vh>&>> 2&9Av1 f6:[_hj.Os.O#.OUX.Oostyoz.O`37TX\eg*@C*@s*@RU*@lpqvlw*@X1,v1,f37TX\eg,UC,Us,URU,Ulpqvlw,U\5=f5=nD6D:/!"f!"FA$VA$r*r)%ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrbccxt.base.typesrrr r r r r rrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrccxt.base.preciser async_supportrrQr*r)rzsf AAYYYYY4.')*%J?$d  ((J?$r*