eifddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lm Z dd l!m"Z"Gd d ej#j$Z$dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesInt LiquidationNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List)ArgumentsRequired) BadRequest) NotSupported) ChecksumError)PreciseceZdZdeffd ZdZdZdefdZdde d e fd Z d Z d Z d Z ddifdedededeefdZddifdeedededeefdZdefdZddZddifdedededeefdZddifdeedededeefdZdefdZdifdededefdZdifdeededefdZifdeedefdZifdedefdZdifdededefdZdefdZd Z d!Z!d"Z"defd#Z#defd$Z$defd%Z%defd&Z&ded'e'fd(Z(ddifdeedededee)fd)Z*ifdeedefd*Z+ifdedefd+Z,ddifdedededee)fd,Z-dde)fd-Z.defd.Z/d/ddifded0edededee0f d1Z1ddifd2eeededefd3Z2ifd2eeedefd4Z3d/ifded0edefd5Z4defd6Z5ifdede6fd7Z7d/ddifded0edededee0f d8Z8defd9Z9ifdede6fd:Z:ifdede6fd;Z;difdedifdeZ@difdeidd?d?d8d9d@d;diddAdAdBdCdDdEdFd=dGdHidIdJdKdLiidMddNdOdOdOdOdPdQdRdRdRdRdPdS|dTdUdVdWdXdYdZdYd[dYd\dYd]dYd^|d_dYdd`daidd`dbidd`dcid d`ddideddfdddgdhdiidddjdkdldmdnidbdcdodpdqdrdsdtdudvS)wNwsT watchBalancewatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchBidsAsks watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrderswatchOrdersForSymbolswatchPositions watchTicker watchTickerswatchMarkPriceswatchMarkPrice watchTradeswatchTradesForSymbols createOrderWs editOrderWs cancelOrderWscancelOrdersWsFcancelAllOrdersWsfetchBalanceWsfetchDepositsWsfetchMarketsWsfetchMyTradesWs fetchOHLCVWsfetchOrderBookWsfetchOpenOrdersWs fetchOrderWs fetchOrdersWsfetchPositionWsfetchPositionForSymbolWsfetchPositionsWs fetchTickerWs fetchTradesWsfetchTradingFeesWsfetchWithdrawalsWs unWatchTickerunWatchTickers unWatchOHLCVunWatchOHLCVForSymbolsunWatchOrderBookunWatchOrderBookForSymbols unWatchTradesunWatchTradesForSymbolsunWatchMyTrades) unWatchOrdersunWatchPositionsunWatchMarkPricesunWatchMarkPricez&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)rcmarginrdrews-apiz wss://demo-stream.binance.com/wsz'wss://demo-ws-api.binance.com/ws-api/v3z 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)rcrfrdrergpapiz!https://developers.binance.com/en)testdemoapidoc keepAlivei returnRateLimits streamLimits2)rcrfrdresubscriptionLimitByStreamstreamBySubscriptionsHash streamIndexwatchOrderBookRatedliquidationsLimitmyLiquidationsLimit tradesLimit ordersLimit OHLCVLimit requestIdwatchOrderBookLimitnametradeticker miniTickerkline) maxRetrieschecksum)fetchBalanceSnapshotawaitBalanceSnapshot defaultTypeswap)fetchPositionsSnapshotawaitPositionsSnapshotwbOcost 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^8d88$T8.t 8 &t 8 0 8 8 8d8'8!$8+D8t8(8!$8 t!8"#88$"4%8&!$'8(t)8*(+8, -8.t/80 182!%384$T586!$788"598:!%;8<"4=8>?8@#DA8B$TC8DE888F G8H"4I8J+DK8L#DM8N O8P Q8R%eS8T%eU8V W8X!$Y8Z[8\)$]8^#D_8`-da8b c8d*4e8f"5g88h"'$)%)$(o888v H"J"F$H$S&R(T##    B"D"F$H$M&R(T##    B"D"@$B$L&L(N## !B   ;S**XVD"ED  " !!D,!! # ..D,T-H-H-J-JDrD$%c%D&$T'D(&t)D*t+D,t-D.d/D0T88::1D2&t3D4G 5D:H ;D@L!ADFGGDN#$ $## -2,0!! "60/3.2##(/A#+&2'2 + + +". & &uDDDQm m m r*c||jd|}|||d}||d}||jd|<|S)Nr~r) safe_dictrr safe_integersum)r&urlr previousValuenewValues r) request_idzbinance.request_idse..{D++DL-LLK??4<HHL++L$??K%/K)K7O*5DL '**?;;FJPDL4 56F G%)__T\C]%^%^ "%-;?;V;V;X;X 78$($5$5dlC]6^`fhi$j$j !"7:J"J (,(9(9$,Gb:ceikn(o(o %"%>>> ,Q"QRRR?TWg?gDL3 4V < r*c||jdd|}|dkr|dd|zdzS|S)Nrkr,rdz/ws/)rreplace)r&rcategorybaseUrls r) get_ws_urlzbinance.get_ws_urlsE)E"4(. 8  ??5#.5*@AA Ar*cF|dks|dks|dks |dks|dkrdSdS)NdepthrpiDepthrraggTradepublicmarket)r&channels r)get_future_ws_categoryzbinance.get_future_ws_categorysO g  J!6!6'\:Q:QU\`gUgUgkrwAlAlA8xr*c|dkr||ddz|zS|jdd|dz|zS)Nrdprivatez ?listenKey=rkr,r)rr)r&r listenKeys r)get_private_ws_urlzbinance.get_private_ws_urlsL 8  ??433mCiO Oy%d+c1I==r*NsymbolsincelimitcDK||g|||d{VS)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_liquidationss788&5%QWXXXXXXXXXr*symbolscK|d{Vg}g}d}||ddd}||r+|d|dnt dt |D]Y}|||} || ddz|d||zZ|d d |zz }||} d} | d | |\} }| d krt|j d zd} | d | |\} }| | | rd} n|| | rd} t |} || |ddz|| || z}||}d||d}d|i}||||||||d{V}|jr|S||j|||dS)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/rcz> watchLiquidationsForSymbols is not supported for spot symbolsrdre forceOrderr SUBSCRIBEmethodrrr) load_marketsmarket_symbolsis_emptyappendrangelenrjoinget_market_from_symbolshandle_market_type_and_paramsrrhandle_sub_type_and_paramsisLinear isInverserrrrwatch_multipleextend newUpdatesfilter_by_symbols_since_limitr)r&rrrrsubscriptionHashes messageHashes streamHashir firstMarketrsubTyperrr~request subscribenewLiquidationss r)rz&binance.watch_liquidations_for_symbols s!!!!!!!!! # %%gtT4@@ == ! ! 3  % %&< = = =   0 0 0 01c'll++ D DWQZ00"))&*?-*OPPP$$%5 %BCCCC $'!2!22 2J227;; 99:WYdflmm f 6>>TW'gghh h99:WYdflmm ==w ' ' DD ^^D' * * D122oodD$?$? $M$MNNQTTW[WbWbcgisvFXGXGGOOC(( !(   ) !% 3 3C T[]cHdHdfx{D!E!EEEEEEE ? #" "11$2CWeUZ\`aaar*c||di}||d}||ddd}|d}|||}|j0||jdd}t||_|j} | || |gd| |gd |zdS) Noscontractrrxryrr) rr safe_marketparse_ws_liquidationrrrrrresolve) r&rmessagerawLiquidationmarketIdrr liquidationrcaches r)handle_liquidationzbinance.handle_liquidation?sP#r::##NC88!!(D"jAA!//GG   $%%dl4GNNE *5 1 1D ! [!!! }n555 }&6&?@@@@@r*c||d}|||dd}||d}|||||||d||d||d||ddd|||d S) NrrTl contractSizeapS) infor contractsrpriceside baseValue quoteValue timestampdatetime)rrrsafe_liquidation safe_symbol safe_numbersafe_string_loweriso8601)r&r rr rs r)rzbinance.parse_ws_liquidationtsV##K55!!(FD&AA%%k377 $$&&x88))+s;; ,,V^DD%%k488**;<<" Y// & &   r*c8K||g|||S)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$55vhufUUUr*c.K|d{V||dddd}||}dg}||s@t dt |D]"}||}|d|z#d} |d||\} }d} |d||\} }| | | rd} n| | | rd} | |d{V|j | d } | | | } d} || || | gd{V}|jr|S||j|||S) 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::r1rdrer)rrrrrrrrrrr authenticaterrrrrr)r&rrrrrrrrrrrrrrs r)r"z)binance.watch_my_liquidations_for_symbolss!!!!!!!!!%%gtT4FF--g66)* }}W%% B1c'll++ B B $$%7&%@AAAA99:Y[acijj f99:Y[acijj ==w ' ' DD ^^D' * * D'''''''''L&{3 %%dI66 $ 3 3CRVQW X XXXXXXX ? #" "11$2CWeUZ[[[r*c||d}|dkrdS||d}||ddd}|||}|||}|j}|+||jdd} t| }||||_| |gd| |gd|zdS) Nr LIQUIDATIONrrrzryr%r&) rrrrr%rrrrr) r&rr orderTyper rrr r rs r)handle_my_liquidationzbinance.handle_my_liquidations Z$$Wc22  % % F##GS11!!(D$??!!(F33//@@ # =%%dl4I4PPEu%%E [!!!# }&6777 }&86&ABBBBBr*cBK||g||d{VS)aO 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/usds-margined-futures/websocket-market-streams/Diff-Book-Depth-Streams-RPI 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 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 N)watch_order_book_for_symbols)r&rrrs r)watch_order_bookzbinance.watch_order_bookAs5l66xOOOOOOOOOr*cK|d{V||dddd}||d}|d}|dr |drdnd }d }d }|Gt|}|d krt |jd z|dd|zz }d} ||ddd\} }d} ||ddd\} }| r |dkrd}d} g} g} tdt|D]r} || }||}| d|z|ddz|z}|dzt| zdz}| |st| }| || |dz| |||z}||}d| |d}t||||j|||d}||| |||| |d{V}|S)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/usds-margined-futures/websocket-market-streams/Diff-Book-Depth-Streams-RPI 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 :param boolean [params.rpi]: *future only* set to True to use the RPI endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NFTrrrlinearrdrermultipleOrderbookrrz} watchOrderBookForSymbols() accepts 200 symbols at most. To watch more symbols call watchOrderBookForSymbols() multiple timesrrr7rv100rpir500 orderbook::r@msrrr)rrrrrrr)rrrrrrrhandle_option_and_paramsrrstrrrrrhandle_order_book_subscriptionrrr)r&rrrrrrr symbolsLengthrvr3 subParamsrrrrr symbolHashmessageHashesLengthrr~r subscription orderbooks r)r-z$binance.watch_order_book_for_symbolsys$!!!!!!!!!%%gtUD$GGkk'!*-- 6" z " E*84D88*D(  LLMs"" ,k"klll $'!2!22 2J!%)%B%B6Keg{~C&D&D"F33F` indexed by market symbols NFTrrrr0rdrerr1rrrvr2r5zunsubscribe:orderbook:rr6r7r UNSUBSCRIBErr@) unsubscriberrsubMessageHashesrtopic)rrrrrrrrrrrrrr9rr)r&rrrrrrrvr<rDrrrrrr=r>rr~rr?s r)un_watch_order_book_for_symbolsz'binance.un_watch_order_book_for_symbolssw!!!!!!!!!%%gtUD$GGkk'!*-- 6" z " E*84D88*D(   $'!2!22 2J!--dl` indexed by market symbols N)rFr&rrs r)un_watch_order_bookzbinance.un_watch_order_books2996(FKKKKKKKKKr*cK|d{V||}d|di}|||d<|d||}|dkrt|jdz|jdd d |}||}t|} d } ||d d d \} }| |d <| |d}| d| | ||d} d|j i} | || | | | d{V} |d| d<| S)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 NrrrrKrdz, fetchOrderBookWs only supports swap marketsrkr,rgFrArnrirrrrr)rrget_market_typerrrrr9r8omit sign_paramsrhandle_fetch_order_bookwatch)r&rrrrpayload marketTyperr~ messageHashrnrr?r@s r)fetch_order_book_wszbinance.fetch_order_book_wss!!!!!!!!!V$$ fTl   $GG ))*||d}||jd}|||i}||d}| ||||||dd}|r||||S)NrrrCF)rindex_byrdr safe_boolhandle_un_subscription)r&rrrsubscriptionsByIdr?risUnSubMessages r)handle_subscription_statusz"binance.handle_subscription_statuss  gt , , MM&*>EE'8"bAA x88   F67L 1 1 1 mUKK  >  ' ' = = =r*r?c||dg}||dg}tdt|D])}||}||}||||*||dS)NrrDr) safe_listrrclean_unsubscription clean_cache)r&rr?rrDj unsubHashsubHashs r)rzbinance.handle_un_subscriptions|_bII >>,8JBOOq#m,,-- B BA%a(I&q)G  % %fgy A A A A &&&&&r*cK|d{V||dddd}d}|Gt|}|dkrt|jdz|dd|zz }d}||d d d \}}||d }||d }|d} |dr |drdnd} g} g} td t|D]Z} || } || }| d| z|ddz|z}| |[||d}t| }| | | |dz| | ||z}||}d| |d}d|i}||| |||| |d{V}|jrB||d }||d}|||}||||ddS)a0 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 ` NFTmultipleTradesrrw watchTradesForSymbols() accepts 200 symbols at most. To watch more symbols call watchTradesForSymbols() multiple timesrrr@rrcallerMethodNamerrrr0rdretrade::rr6rrrrrr)rrrrrrr8rMrrrrrrrrrrrrgetLimitfilter_by_since_limit)r&rrrrrr;rrrrr<rrrrawHashquerysubParamsLengthrr~rrtradesfirst tradeSymbols r)watch_trades_for_symbolsz binance.watch_trades_for_symbols s !!!!!!!!!%%gtUD$GG%  LLMs"" ,e"efff $'!2!22 2J44V=TV\^eff f6#566kk'!*-- 6" z " E*84D88*D  q#g,,'' & &AQZF[[((F  V!3 4 4 4]+c1D8G   W % % % % &&))i..oodD$?$?$E$EFFLt{{[_akm|O}O}}OOC(( !   ) **3 t{{7TY?Z?Z\iktuuuuuuuu ? 8OOFA..E**5(;;KOOK77E))&% TRRRr*cK|d{V||dddd}d}|Gt|}|dkrt|jdz|dd|zz }d}||d d d \}}||d }||d }|d}|dr |drdnd}g}g} g} td t|D]r} || } || } | d| z| d| z| ddz|z}| |s||d}t| }| || |dz| |||z}||}d| |d}dt||| |dd}||| |||| |d{VS)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 ` NFTrrrrrrr@rrrrrrr0rdrerzunsubscribe:trade:rr6rrBrrrCrrDrrrE)rrrrrrr8rMrrrrrrrr9rr)r&rrrr;rrrrDr<rrrrrrrrr~rr?s r)un_watch_trades_for_symbolsz#binance.un_watch_trades_for_symbolsGs!!!!!!!!!%%gtUD$GG%  LLMs"" ,e"efff $'!2!22 2J44V=TV\^eff f6#566kk'!*-- 6" z " E*84D88*D  q#g,,'' & &AQZF[[((F  # #I$6 7 7 7  !5!> ? ? ?]+c1D8G   W % % % % &&))i..oodD$?$?$E$EFFLt{{[_akm|O}O}}OOC(( #    i.. 0*   ((mT[[RW=X=XZgiuvvvvvvvvvr*ctK|d{V||g|d{VS)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)rrrHs r)un_watch_tradeszbinance.un_watch_tradessV!!!!!!!!!55vhGGGGGGGGGr*cNKd|d<||g|||d{VS)a/ 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?rN)rrs r) watch_tradeszbinance.watch_tradessA &3!"22F8UE6RRRRRRRRRr*c||d}|dk}|s|||S||dd}||d}||dd}||d}|r||d |}||d } | ||t j||} ||d } d |vrd nd} || dd| } ||d} d}||d}d|vr| |drdnd} |drdnd}d}||d}|0||d}||}||d}||d}| ||| || ||||| ||| |d S)NxTRADEtrxrLpqrYrpsrrcrrmsellbuymakertakernNrcurrencyr) rrrrrorderr takerOrMakerrrrqrfee) r parse_trade safe_string_2rr string_mulrrsafe_currency_code safe_trader )r&rr executionTypeisTradeExecutionrrrrqrr rRrrrorderIdrfeeCost feeCurrencyIdfeeCurrencyCoders r)parse_ws_tradezbinance.parse_ws_tradesUR((44 )W4 3##E622 2   sC 0 0%%eS11 ""5#s33!!%--  :%%eS&99Fs++ <!(:)%88##E3//$(EMMZZ !!(D$ CC%%eS11 ""5#.. %<<|!&s6vv&+Cj=77gL""5#..   ,,UC88M"55mDDO+C%%eS11" Y//(     r*c||}|rdnd}||d}||dd|}|d}d|z}|||} ||j|} | +||jdd} t| } | | | |j|<| | |dS)Nrcrrrrr{ry) rrrrrrrrrrr) r&rrrrRr rrrSr tradesArrayrs r) handle_tradezbinance.handle_trade@s!!&)) &7VVZ ##GS11!!(D$ CC!&( ##GV44oodk6::  %%dlM4HHE$U++K5!!!) F{K00000r*1m timeframecK|d{V||}|d}d|d<|||gg|||d{V}|||S)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 Nrr4r)rrwatch_ohlcv_for_symbols)r&rrrrrrrVs r) watch_ohlcvzbinance.watch_ohlcvRs !!!!!!!!!V$$!%1!"33fi5H4I5RWY_````````f~i((r*symbolsAndTimeframescK|d{Vd}||ddd\}}||d}||dddd}||d}|d} |d r |d rd nd } | d k} d} ||dd\} }| duo| dkpt j| d} g} g}tdt|D]}||}|d}|d}| |j ||}||}|d}|dkr| dd}| o| }d}|r|nd}| |dz|zdz|z|z| d|dzdz|z|| ||dz|| dz}||}d| |d}d |i}||d!}||||||||d{V}|\}}} |jr| ||}|| ||dd}!||||!S)"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 NrrrrFTrrr0rdrerctimezone+08:008rrindexPriceKline_perpr@+08:00r6_ohlcv::rrr multipleOHLCVrrrr)rhandle_param_string_2get_list_from_object_valuesrrhandle_param_stringr string_eqrrr timeframesrrrrrrrMrrrrrcreate_ohlcv_object)"r&rrrr klineTyper marketSymbolsrrrrisUtc8 rawHashesrrsymAndTf symbolStringtimeframeStringintervalrr  shouldUseUTC8suffix utcSuffixrr~rrresrrcandlesfiltereds" r)rzbinance.watch_ohlcv_for_symbolsisK!!!!!!!!!  66vy&RYZZ 6223GKK++GT5%NN kk-"233 6" z " E*84D88*D&.33FJMM&$&hh(.B-gwGXYacfGgGg  q#23344 X XA+A.H#A;L&qkO''/ZZH[[..Fm,H---#++GR88#.MF"/7RI   X^i7#=H9T U U U  VH-=!=!D!V W W W WoodD$?$? $J$JKKcQTXT_T_`dfuTvTvvOOC(( !   ) 6#566'']DKKQW%%dlL$GGE*511F4:DK  0 1 f/8 {K00000r*cK|d{V||}d|di}|d||}|dkrt|jdz|jddd |}||}t|}d |ji} d } | |dd d \} }| |d <| |d }d} | |dd d\} }|| | | ||d} | ||| || d{V} | S)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 ` NrrrRrdz) fetchTickerWs only supports swap marketsrkr,rgrFrnriz ticker.bookrK)rrrLrrrrr9handle_ticker_wsr8rMrNrrP)r&rrrrQrrr~rSr?rnrrrs r)fetch_ticker_wszbinance.fetch_ticker_ws;s!!!!!!!!!V$$ fTl ##OVVDD 8  TW'RRSS Sit$X.t4OOC(( )nn d+ !#'#@#@Zlns#t#t &&6"#66**66vPXZghh&&t{{7F'C'CDD   zz#{G[,WWWWWWWW r*cK|d{V||}|d||}|dkr|dkrt|jdz|jddd|}||} t| } d } ||dd d \} }| || |j |d } | |d } | |d }||| d <||| d<| | | d<| d| | |d}d|ji}||| || |d{VS)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 NrJrcrdz0 fetchOHLCVWs only supports spot or swap marketsrkr,rgFrn)rrnruntil startTimerendTimeklinesrKr)rrrLrrrrr9r8 market_idrrrMrhandle_fetch_ohlcvrP)r&rrrrrrrRrr~rSrnrQr rr?s r)fetch_ohlcv_wszbinance.fetch_ohlcv_ws`s"!!!!!!!!!V$$)).&&II   J($:$:TW'YYZZ Zit$X.z:OOC(( )nn  #'#@#@Ykmr#s#s &nnV,, 0 2   !!&'2267++  #(GK  $GG   !&GI kk'622   d- ZZ['; UUUUUUUUUr*c||d}||}||d}|||dS)NrVr)r parse_ohlcvsrr)r&rrrVrrSs r)rzbinance.handle_fetch_ohlcvsZ@22""6**&&w55 v{+++++r*cK|d{V||}||g||ddid{V}||S)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 ` Nrr;)rr watch_tickersrr&rrtickerss r) watch_tickerzbinance.watch_tickers !!!!!!!!!V$$**F8T[[J\^kIl5m5mnnnnnnnnvr*cK|d{V||}||g||ddid{V}||S)aI 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 ` Nrr>)rrwatch_mark_pricesrrs r)watch_mark_pricezbinance.watch_mark_prices!!!!!!!!!V$$..xVN`brMs9t9tuuuuuuuuvr*cKd}||ddd\}}|d|||d{V}|jr|S||jd|S)aW 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=rrr)r8watch_multi_ticker_helperrfilter_by_arrayrr&rr channelName newTickerss r)rzbinance.watch_mark_pricess #;;FDUW]_jkk V99:K[Zacijjjjjjjj ?  ##DL(GDDDr*cKd}||ddd\}}|dkrt|jdz|d|||d{V}|jr|S||jd|S)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<rrrV deprecation notice - to subscribe for bids-asks, use watch_bids_asks() method insteadr)r8rrrrrrr s r)rzbinance.watch_tickerss ";;FNTZ\hii V , & &TW'AA A99.+W^`fgggggggg ?  ##DL(GDDDr*cKd}||ddd\}}|dkrt|jdz|d|||dd{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://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<rrrr$rWT)r8rrrr&rrr!s r)un_watch_tickerszbinance.un_watch_tickers s ";;FNTZ\dee V , & &TW'AA A334DkSZ\bdhiiiiiiiiir*cKd}||ddd\}}|d{V|d|||dd{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://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-market-streams/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 :returns dict: a `ticker structure ` Nr=rrraT)r8rrr&s r)un_watch_mark_priceszbinance.un_watch_mark_pricess ";;FDUW]_jkk V!!!!!!!!!334GV]_egklllllllllr*c@K||g|d{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://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 :returns dict: a `ticker structure ` N)r)rHs r)un_watch_mark_pricezbinance.un_watch_mark_price.s2..x@@@@@@@@@r*c@K||g|d{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://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)r'rHs r)un_watch_tickerzbinance.un_watch_ticker:s2**F8V<<<<<<<<` NTFr2rr)rrrrrbidsasks)r&rrrVs r)watch_bids_askszbinance.watch_bids_asksKs!!!!!!!!!%%gtT5$GG55o|U\^deeeeeeee ? M##DM8WEEEr*Fr! isUnsubscribecfK|d{V||dddd}|dk}|dk}||dd}d} d} |du} | r||d} |rdnd} ||| || \} }d} ||| |\} }d}|| | rd}n?|| | rd }n&| d kr| }nt|j d z|zd z|r;| | ddgs#t|j d z|zd z| zdzg}g}g}d}|r|rdnd}d}|rd}n|rd}nd}| rtdt|D]}||}||}| |ddz|z|z| |dz|zdz|z|r$| d|zdz|zdz|zn|r<| d krt|j d z|zdz| d|zn<|r| d|zdz|zn| d|zdz| |dz|z| d|z|}| r|dzd|z}||||dz|||z}||}|rdnd||d }|}d!|i}|rdt)||||dd"}|}||||||||d{V}|r|S| s|Si}|||d#<|S)$NTFrr use1sFreqrrrdrercr}z#() does not support options marketsz() does not support z markets yetrz@1sbidaskrrr6:z unsubscribe::z5() requires symbols for self channel for spot markets!@arrs:rrrrBrrrrr)rrrrrrrrrrin_arrayrrrrrrrrrr9rr$)r& methodNamer!rrr1isBidAsk isMarkPricer3rrRsymbolsDefined defaultMarketr rawMarketTypesubscriptionArgsrunsubscribeMessageHashesr unifiedPrefixrrrrrr~rhashesr?rVnewDicts r)rz!binance.watch_multi_ticker_helper^s!!!!!!!!!!%%gtT5$GG</"k1 NN6;==   !-  2++gaj11K#.9T !?? KY_anoo F99*kSYZZ ==W - - c$MM ^^J 0 0 c&MM 6 ! !&MMtw}z9 The subscription ID for the user data stream rkr,rgNTz"userDataStream.subscribe.signaturerKrrr?) rrrdrrkeys#get_account_type_from_subscriptionsrr9rN!handle_user_data_stream_subscriberP) r&rRrrrdsubscriptionsKeys accountTyper~rSrr?s r).ensure_user_data_stream_ws_subscribe_signaturez6binance.ensure_user_data_stream_ws_subscribe_signaturesit$X.z:S!!,  !3!3!5!566>>?PQQ * $ $ F+/Z(OOC(( )nn :&&r**   <&  jjk7KNNNNNNNNNNNr*cr||d}|j}t|}||}||di}||d}||j|=||||||dS)NrrVsubscriptionId) rrdrrrrrrrer) r&rrrSrdrrrVrs r)rz)binance.handle_user_data_stream_subscribes&&w55 ,  !3!3!5!566>>?PQQ 266**63CDD  !$[1 MM'; / / /w ,,,,,r*rfc fK|jdddd}||j|i}||dd}||jdd}|}||d }||z |kr||d } ||d d } ||d } i} | r8| t|j dz| | } | | d <d| d <| | | d <| | d{V}||d}||d}| |}t|}|dd|id}||j|d}|||||| | | d|j|<||z dz }|dkr4||d|i}|||j|||||||d{VdSdS)a subscribes to user data stream using listenToken(for margin) :param str marketType: - the market type(e.g., 'margin') :param dict params: - extra parameters specific to the request :param str [params.symbol]: - required for isolated margin :param boolean [params.isIsolated]: - whether it is isolated margin :param number [params.validity]: - validity in milliseconds, default 24 hours, max 24 hours {@link https://developers.binance.com/docs/derivatives/usds-margined-futures/websocket-api/user-data-stream Binance User Data Stream Documentation} :returns: Promise rkr,rgrclastAuthenticatedTimerlistenTokenRefreshRateim'r isIsolatedFvalidityNza ensureUserDataStreamWsSubscribeListenToken() requires a symbol argument for isolated margin modeTtokenexpirationTimez$userDataStream.subscribe.listenToken listenTokenrKr)rrrrrri`r)rrrr millisecondsrrrrrrsapiPostUserListenTokenrr9rrdelayrenew_listen_tokenrP)r&rRrrrrrrGrrrrrr responserrr~rSrr? renewalTimers r)1ensure_user_data_stream_ws_subscribe_listen_tokenz9binance.ensure_user_data_stream_ws_subscribe_listen_tokensit$X.v6..z2>> $ 1 1';RTU V V!%!2!24+DG7Z-Z[[[>>&11$,!(, %#&. #!99'BBBBBBBBH**8W==K!..x9IJJN,,Ii..K!@!;G"@ *""L (,{{7*"0)- ($ ==((DL $)4/%7KQ!%Vfj5I!J!J ;(?PPP**S+w \RR R R R R R R R R R[ 0 /r*c\K||dd}||j|i}||d}||dd}||d}i}|||d<|r||d<|||d<|||d{VdS)NrrfrrFr)rrrrrr)r&rrrrrr renewParamss r)rzbinance.renew_listen_token= s99..tR88!!'844^^G\5AA $$Wj99  $*K !  3(2K %  &.K #DDT;WWWWWWWWWWWr*c<K|}d}|dd|\}}d}|dd|\}}d}||dddd\}}|||rd}n|||rd}|dkr|dd{VdSd}|d|\}}|dk}||d }|d ks|r.i} ||| d <|rd | d <| d | d{VdS| |d }| |j |i} | | d d} | |j dd} || d} || z | krd}|r4||d{V}||dd i}n_|dkr||d{V}n=|dkr||d{V}n||d{V}|| ||d|d|j |<|| |j|dSdS)Nr'rhportfolioMarginFrdrercisolatedrrfTrrrrrrrrr)rrrhandle_option_and_params_2rrrhandle_margin_mode_and_paramsrrrMrrrrpapiPostListenKeyrfapiPrivatePostListenKeydapiPrivatePostListenKeypublicPostUserDataStreamrkeep_alive_listen_key)r&rrGrrisPortfolioMargin marginModeisIsolatedMarginr marginParamsrrrrrs r)r'zbinance.authenticateL sW  ""99.$PVWW f99.$PVWW $($C$CFN\bduw|$}$}!6 ==w ' ' DD ^^D' * * D 6>>EEfMM M M M M M M M F !??PVWW F&*4!!&(33 8  / !#L!)/ X& 2-1 \*HHS_`` ` ` ` ` ` ` ` F68,,//$,b99 $ 1 1';RTU V V#00?UW^__-u55 ' '% / /H  G!%!7!7!?!???????V.?-FGG!!!%!>!>v!F!FFFFFFF##!%!>!>v!F!FFFFFFF!%!>!>v!F!FFFFFFF!%W!--h DD)-77""DL  JJ+T-G P P P P P 0 /r*cK||jddd}||d|}d}||dddd\}}|dd|}|d }|||rd }n|||rd }|d krdS||j|i}||d }|dSi}||ddg}| } |rH| | ||d{V| |ddi}n|d kr0| | ||d{Vnj|d kr0| | ||d{Vn4||d <|| ||d{Vn#t$r} |} |rd} |j|d } || | } || }t%|j}t+d t-|D] }||}|| |!| |dd d|j|<Yd} ~ dSd} ~ wwxYw| ||| d|j|<t%|j}||jdd}t+d t-|D]~}||}t%|j}t+d t-|D]0}||}||kr |||j|dS1dS)Nrr'rcrkeepAliveListenKeyrhrFrrdrerfrrTrrr)rrrrrrrrrMrpapiPutListenKeyrfapiPrivatePutListenKeydapiPrivatePutListenKeypublicPutUserDataStreamrcrrrrfuturesrrrreclientsvaluesrrdrr)r&rrr subTypeInforrrrrGerrorurlTypecachedListenKeyrrrrrSrrsubscriptionKeysr subscribeTypes r)rzbinance.keep_alive_listen_key sw!!$, ~vVV55 $($C$CFL`bhj{~C%D%D!6556JDRXYY a. ==w ' ' DD ^^D' * * D 8   F//$,b99$$Wk::   F6FH#566  ""  Q++DKK,H,HIIIIIIIIIV.?-FGG!!224;;w3O3OPPPPPPPPPP##224;;w3O3OPPPPPPPPPP'0 $224;;w3O3OPPPPPPPPP   G  ! "l40=O))'?CCC[[%%F !4!4!6!677M1c-0011 2 2+A.  e[1111!%W!)*77""DL  FFFFF  "[["%)3 3    T t|**,,--#00?UW^__q#g,,''  AQZF#F$8$=$=$?$?@@ 1c"23344   0 3  D((JJ3T5OQWXXXFFF)   sC*G== KC KKc4||jvr ||jvrdS||jd}||dd}|rE|dz}||jvr5||||j||||dSdSi|j|<dS)Nr-rF:fetchBalanceSnapshot) rdbalancerrrrrdrload_balance_snapshot)r&rrrrrrSs r)set_balance_cachezbinance.set_balance_cache s F( ( (tt|/C/C F//$,??#~~g7MuUU  $!88K6>11 k*** 45v{DRcddddd21"$DL   r*cfKd|i}|rd|d<||d{V}||||j|i|j|<||jvrG|j|}|||j||dzdSdS)NrTr:balance) fetch_balancerrrrr)r&rrSrrrrrds r)rzbinance.load_balance_snapshot s D   -(,F$ %++F33333333![[4??4` NrFrcrdrez2 fetchBalanceWs only supports spot or swap marketsrkr,rgFrnrzaccount.statusrK) rrLrrrrr9r8rNrhandle_account_status_wshandle_balance_wsrP) r&rrrr~rSrnrQrrr?s r)fetch_balance_wszbinance.fetch_balance_ws s!!!!!!!!!##$4dFCC 6>>dh..4:3E3ETW'[[\\ \it$X.t4OOC(( )nn  #'#@#@IY[mot#u#u &  0 66v?OQY[kll&&t{{7F'C'CDD   BR8R8Rd33Y]Yo ZZ['; UUUUUUUUUr*cN||d}d}t|dtr||dg}n.||di}||dg}||}|||dS)NrrVassets)rrqrrrrparseBalanceCustomr)r&rrrS rawBalancerVparsedBalancess r)rzbinance.handle_balance_ws s&&w55  gh' . . >2>>JJ^^GXr::F"==J00<<~{33333r*c||d}||di}||}|||dSNrrV)rrrr)r&rrrSrVrs r)rz binance.handle_account_status_ws s\^&&w55 2660088~{33333r*c@K||g|d{VS)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_wsrHs r)fetch_position_wszbinance.fetch_position_wsF s2,,fXv>>>>>>>>>r*cTK|d{Vi}d}||dddd}|;t|}|dkr&||d}|d|d<|d||}||d krd }|d kr|d krt |jd z|jd dd|}||}t|} d} | |ddd\} }| |d<d} | |ddd\} }| | | | ||d} d|j i} ||| | | | d{V}||d|dS)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 ` NrTrrrrrQrcrdrez, fetchPositionsWs only supports swap marketsrkr,rgFrnrzaccount.positionrK)rrrrrLrrrrr9r8rNrhandle_positions_wsrPfilter_by_array_positions)r&rrrQrr;rrr~rSrnrrr?rVs r)rzbinance.fetch_positions_wsR s!!!!!!!!!%%gvtT4HH  LLM!!WQZ00$*4L!##$6GG ?D 8   2 2TW'UUVV Vit$X.t4OOC(( )nn  #'#@#@I[]oqv#w#w &&6"#66v?QS[]opp&&t{{7F'C'CDD   d. zz#{G[,WWWWWWWW--fhOOOr*c||d}||dg}g}tdt|D]Z}|||}||d}|dkr!|dkr|dkr||[|||dS)NrrVr entryPrice0z0.0z 0.00000000)rrrrparse_position_riskrr) r&rrrSrV positionsrrrs r)rzbinance.handle_positions_ws s>&&w55 266 q#f++&& ) )A--fQi88F))&,??Jc!! e(;(;*P\B\B\  (((y+.....r*c K|d{V||d{V||jdd}||d|}d}|dd|\}}d}||dddd\}}|||rd }n|||rd }d }|}|dks|d kr |jd ddd}n+|rd}| ||j|d}| |}| |||| ||d|| |jd} || dd} || dd} | r | r||dzd{V|dz} d} ||| | |d{VS)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 ` Nrrcrr-rhrFrdrerrfrkr,rgrrrTrr)rr'rrrrrrrrrrset_positions_cacherrrdrP)r&rrrrrrrrrrrrSrs r) watch_balancezbinance.watch_balance sj!!!!!!!!!'''''''''&&t|]FKK  <<99.$PVWW $($C$CFN\bduw|$}$}!6 ==w ' ' DD ^^D' * * D 6>>TX--)E"4(26:CC  ! ))'4<3Ek3RSSCS!! vt->???   t5FGGG..~>>#~~g7MuUU#~~g7MtTT  @$8 @--'> >?? ? ? ? ? ? ? ?Z' ZZ['4@@@@@@@@@r*c||jdd}|j}t|}||}|dz}|j| i|j|<||j|d<||d}|dkr||d} || } |} ||d} | |j|vr\|j|| d } t| ts| | } tj | | | d <n| | d <| |j|| <n||d|}||d }t!d t#|D]}||}||d} || } |} ||d | d <||d | d<|||| d<| |j|| <||d}||j|d<|||j|d<||j||j|<||j||dS)Nrrrrrj balanceUpdaterxdfreerNrfrusedtotalr{rr)rrrdrrrrrraccountrqr9rr string_addrrrrrr  safe_balancer)r&rrrrdrrrSr currencyIdcoderrprrNrentryrs r)handle_balancezbinance.handle_balance sD!!$,$??,  !3!3!5!566>>?PQQ !J. < $ ,(*DL %,3 [!&)  #.. O # #))'377J**:66DllnnG$$Wc22Et|K000 $ [ 9$ ? G !-55I$($9$9-$H$HM")"4]E"J"J"'.5DL %d + +nnWc7;;Gw,,A1c!ff%% : :!!--eS99 ..z::,,.."&"2"25#">">"&"2"25#">">#'#3#3E6#B#B 29 [)$//%%gs33 1: [!+.04 Y0G0G [!*-$($5$5dl;6O$P$P [!t|K0+>>>>>r*rdcd}tdt|D]&}||}|dks|dks |dks|dkr|}n'|S)Nrrrcrfrdre)rr)r&rdrrr?s r)rz+binance.get_account_type_from_subscriptions> s q#m,,--  A(+L&&LH,D,D,ZbJbJbhtyCiCiC* iCr*cd}||||\}}d}||||\}}|||rd}n|||rd}|S)Nrdre)rrrr)r&rrrrrs r)rLzbinance.get_market_typeG s99&&&QQ f99&&&QQ ==w ' ' DD ^^D' * * D r*rrqrcK|d{V||}|d||}|dkr#|dkr|dkrt|jdz|jddd |} || } t| } ||d d d } | |d d }| |d d} | |d| }| |d}| |d}| |gd}|du}|dup|du}|du}| du}|p|p|p|}| ||||||}d }||ddd \}}||d<||dd }| |d}|dr|dr|rd|d<| d||||d}|r | rd|d<nd|d<|dr|dr|rd|d<d|ji}|| | || |d{VS)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 https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/New-Algo-Order :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 ` NrArcrdrez1 createOrderWs only supports spot or swap marketsrkr,rgsorSORF triggerPrice stopPrice stopLossPricetakeProfitPrice trailingDelta)trailingPercent callbackRaterrnrir0r CONDITIONALalgoTypez order.placerKzsor.order.testrz order.testzalgoOrder.place)rrrLrrrrr9 safe_bool_2rMrr safe_string_ncreate_order_requestr8rrNrhandle_order_wsrP)r&rrrrqrrrrRrr~rSrrrrrrisTrailingPercentOrder isStopLoss isTakeProfitisTriggerOrder isConditionalrQrnrirr?s r)create_order_wszbinance.create_order_wsR s &!!!!!!!!!V$$))/66JJ   J($:$:zZ?W?WTW'ZZ[[ [it$X.z:OOC(( )nn vueU;;65%00))&.+NN ((,OO **63DEE((AA ,,V5i5i5ijj!0!<"$.K-t2K &d2 %T1&^*@^J^R^ ++FD$vVV #'#@#@Zlns#t#t &&6"#~~ffe4466** (  0v 0= 0"/GJ #&&t{{7F'C'CDD    1 1$4!!$0! (  2v 2= 2 1GH  d* ZZ['; UUUUUUUUUr*c||d}||di}||}|||dSrrr parse_orderr)r&rrrSrVrs r)rzbinance.handle_order_ws s\`&&w55 266  ((uk*****r*c||d}||dg}||}|||dSr)rr parse_ordersr)r&rrrSrVorderss r)handle_orders_wszbinance.handle_orders_ws s\L&&w55 266""6**v{+++++r*rc K|d{V||}|d||} | dkr#| dkr| dkrt|jdz|jddd | } || } t| } | dkp| dk} d}| dkr||||||||}n| r| |||||||}d }| |dd d \}}||d <| | rd nd | | ||d}d|j i}|| | || |d{VS)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 ` NrBrcrdrez/ editOrderWs only supports spot or swap marketsrkr,rgFrnz order.modifyzorder.cancelReplacerKr)rrrLrrrrr9editSpotOrderRequesteditContractOrderRequestr8rNrhandle_edit_order_wsrP)r&rrrrrqrrrrRrr~rSisSwaprQrnrr?s r) edit_order_wszbinance.edit_order_ws s"!!!!!!!!!V$$))-HH   J($:$:zZ?W?WTW'XXYY Yit$X.z:OOC(( )nn (DJ*,D   //FD$PUW]^^GG  c33BdFTY[abbG #'#@#@Xjlq#r#r &&6"#)/Knn6K&&t{{7F'C'CDD   d/ ZZ['; UUUUUUUUUr*c||d}||di}||d}d}|||}n||}|||dS)NrrVnewOrderResponser )r&rrrSrV newSpotOrderrs r)rzbinance.handle_edit_order_ws sF&&w55 266~~f.@AA   #$$\22EE$$V,,Euk*****r*cK|d{V|t|jdz||}|d||}|jddd|}||}t|}d} ||ddd\} }| || d } | |gd } | |gd } |d o |d o| } | | r| | d<n9| | d<n3| r| || d<n| || d<| |gd}|d||| |d}| rd|d<d|ji}||||||d{VS)aB 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 https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/websocket-api/Cancel-Algo-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. :param boolean [params.trigger]: set to True if you would like to cancel a conditional order :returns dict: an list of `order structures ` N cancelOrderWs requires a symbolrCrkr,rgFrnrrn)stoptriggerr) clientAlgoIdorigClientOrderId clientOrderIdr0rr!r"algoIdr)r"r#rr rz order.cancelrKzalgoOrder.cancelr)rrrrrLrrr9r8r safe_bool_nrrrMrNrrrP)r&rrrrrrr~rSrnrQr r#shouldUseAlgoOrderrr?s r)cancel_order_wszbinance.cancel_order_ws s> !!!!!!!!! >TW'IIJJ JV$$##OVVDDit$X.t4OOC(( )nn  #'#@#@Zlns#t#t &nnV,, 0  ((1S1S1STT **63i3i3ijj #H-R&.R]  $! =*7''/<+,,! ?$($9$9"$=$=!!%)%:%:2%>%> "6#k#k#kll$&&t{{7F'C'CDD    3 2GH  d* ZZ['; UUUUUUUUUr*cfK|d{V||}|d||}|dkrt|jdz|jddd|}||}t|}d}||dd d\}}| ||d } |d | | | |d } d |j i} | ||| || d{VS)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 ` NrErcz- cancelAllOrdersWs only supports spot marketsrkr,rgFrnrzopenOrders.cancelAllrKr)rrrLrrrrr9r8rrNrrrP) r&rrrrrr~rSrnrQrr?s r)cancel_all_orders_wszbinance.cancel_all_orders_ws sc!!!!!!!!!V$$##$7HH 6>>TW'VVWW Wit$X.t4OOC(( )nn  #'#@#@I\^prw#x#x &nnV,, 0   ,&&t{{7F'C'CDD   d+ ZZ['; UUUUUUUUUr*cK|d{V|t|jdz||}|d||}|dkr#|dkr|dkrt|jdz|jdd d |}||}t|}d } ||dd d \} }| || d } | |dd} | | | d<n| || d<|d| | | |d} d|ji} |||| || d{VS)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 ` NrrMrcrdrez0 fetchOrderWs only supports spot or swap marketsrkr,rgFrnrr"r#rz order.statusrKr)rrrrrLrrr9r8rrrrNrrrP)r&rrrrrrr~rSrnrQr#rr?s r)fetch_order_wszbinance.fetch_order_ws s!!!!!!!!! >TW'IIJJ JV$$##NFFCC 6>>dh..4:3E3ETW'YYZZ Zit$X.t4OOC(( )nn  #'#@#@Ykmr#s#s &nnV,, 0  **63FXX  $+8G' ( (!%!6!6r!:!:GI $&&t{{7F'C'CDD   d* ZZ['; UUUUUUUUUr*cK|d{V|t|jdz||}|d||}|dkrt|jdz|jddd|}||}t|} d } ||d d d \} }| || d } | d | | | |d} d|j i} | || | | | d{V}|||||S)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 symbolrNrcz) fetchOrdersWs only supports spot marketsrkr,rgFrMrnr allOrdersrKr)rrrrrLrrr9r8rrNrrrPfilter_by_symbol_since_limitr&rrrrrrrr~rSrnrQrr?rs r)fetch_orders_wszbinance.fetch_orders_ws s !!!!!!!!! >TW'IIJJ JV$$##OVVDD 6>>TW'RRSS Sit$X.t4OOC(( )nn  #'#@#@Ykmr#s#s &nnV,, 0   !&&t{{7F'C'CDD   d+ zz#{G[,WWWWWWWW00NNNr*cK|||||d{V}g}tdt|D]+}||}|ddkr||,|S)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)r0rrr) r&rrrrr closedOrdersrrs r)fetch_closed_orders_wszbinance.fetch_closed_orders_ws< s++FE5&IIIIIIII q#f++&& + +A1IEX(**##E***r*cK|d{V||}|d||}|dkr|dkrt|jdz|jddd|}||}t|} d } ||d d d \} }d | i} || || d <| d | | | |d} d|j i} | || | | | d{V}|||||S)aO 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 ` NrLrcrdz5 fetchOpenOrdersWs only supports spot or swap marketsrkr,rgFrMrnrzopenOrders.statusrKr)rrrLrrrrr9r8rrNrrrPr.r/s r)fetch_open_orders_wszbinance.fetch_open_orders_wsP s!!!!!!!!!V$$##$7HH 6>>dh..TW'^^__ _it$X.t4OOC(( )nn  #'#@#@Ykmr#s#s &  0    $v 6 6GH )&&t{{7F'C'CDD   d+ zz#{G[,WWWWWWWW00NNNr*cHK|d{Vd}d}|%||}|d}|d|zz }d}|d||\}}d}|d||\}}|||rd}n|||rd}|||||d}||d{Vd} |d|\} }|} |d ks|d kr| d } d} | |dd d d \} }d} |d ks|d kr |j dddd } n+| rd } | | |j |d} | | } || || || |d| d}|| |||d{V}|jr|||}|||||dS)ag watches information on multiple orders made by the user https://developers.binance.com/docs/binance-spot-api-docs/user-data-stream#order-update https://developers.binance.com/docs/margin_trading/trade-data-stream/Event-Order-Update https://developers.binance.com/docs/derivatives/usds-margined-futures/user-data-streams/Event-Order-Update https://developers.binance.com/docs/derivatives/usds-margined-futures/user-data-streams/Event-Algo-Order-Update :param str symbol: unified market symbol of the market the 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|None [params.marginMode]: 'cross' or 'isolated', for spot margin :param boolean [params.portfolioMargin]: set to True if you would like to watch portfolio margin account orders :returns dict[]: a list of `order structures ` Nrrr5r8rdre)rrrrfrcrhrFrrkr,rgrT)rrrrrrrr'rrrrrrrrrPrrr.)r&rrrrrSrrrrrrrrrrs r) watch_orderszbinance.watch_ordersv s"!!!!!!!!!   [[((FH%F 3< 'K99-QWXX f99-QWXX ==w ' ' DD ^^D' * * DVdfQX%Y%YZZ''''''''' !?? vVV F H  46>> 8NG $($C$CFM[actv{$|$|!6 6>>TX--)E"4(26:CC  ! ))'4<3Ek3RSSCS!! vt->???   t5FGGGzz#{GTBBBBBBBB ? 3OOFE22E00tTTTr*c ||d}||d}d|vrdnd}||dd|}||d}||d}d} |dks |d ks|d kr||}n|d kr|} |} d} ||d } | Etj| d r0||d} || }| |d} ||d}||}||dd}|t|dkr||d}| |gd}||d}|dkrd}| id|d|d||ddd|d|d | |d!| d"| d#| | |d$d%|d&dd'||d(d)| |d*d+||d,d-|d.|d/||d0||d1||d2||d3d|| dd4S)5NrrrrrcOrNEW AMENDMENTCANCELEDrrrrrXrHcaidrr)r]sptprGTXPOrrrraidr#rrlastTradeTimestamplastUpdateTimestamprr timeInForcepostOnly reduceOnlyRrrrrrrrqrZrz)rr^filled remainingr2rr)rrrr string_gtrparse_order_statusrrr safe_orderr parseOrderTyperr)r&rrrr rRrrrrFrGrrr feeCurrency rawStatusr2r#rrHs r)parse_ws_orderzbinance.parse_ws_order sV((44 ##E3//$(EMMZZ !!(D$ CC%%eS11   eS ) )! E ! !]k%A%A]V`E`E`  g % %!" ""5#..  g&7&E&E  ,,UC88M11-@@K'C$$UC00 ((33**5#v>>  !s='9'9Q'>'> ,,UC88M&&u.?.?.?@@ &&uc22 %  K E f  $$$UC77  ]     Y//   !"4  "#6  D''(>(>uc(J(JKK  ;    $..44  D**5#66  T%%eS11   I! " d&&uc22# $$$UC00''t44&&uc221      r*c||d}|dks|dkr||d|}|||||||||dS)NrjORDER_TRADE_UPDATE ALGO_UPDATEr)rrhandle_my_trade handle_orderr+)r&rrrjs r)handle_order_updatezbinance.handle_order_updateVsj   Wc * * % % %1 +=+=nnWc7;;G VW--- &'*** ""6733333r*cK|d{Vd}d}||}||s-||}dd|z}d}|d||\}}|dks|dkrd}d}|d||\}}|||rd}n|||rd }i} || d <|| d <| | | |d{V|d z|z}d} | |dd dd\} }|} | rd } | | |j |d} || } || || || ||| |ddd}|ddd}||j|}|r;|r9|7| |dzd{V}|||||dS|| |d|d{V}|jr|S|||||dS)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:rcrfrdrerr :positionsrhrFrrTr:fetchPositionsSnapshot)rrrrrrrrrr'rrrrrrrr~rrrdrrPr)r&rrrrrrSrrmarketTypeObjectrrrrrrr rg newPositionss r)watch_positionszbinance.watch_positionss!!!!!!!!! %%g..}}W%% 311'::F'!2!22K99:JFTZ[[ f 6>>TX--D99:JFTZ[[ ==w ' ' DD ^^D' * * D!##' &-# ,???   w8IJJJ!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e55 ! ]&< ]#]]42K+KLLLLLLLLH55hPUW[\\ \!ZZ[$EEEEEEEE ?  11%%PTUUUr*c0|dkrdS|ji|_||jvrdS|ddd}|rE|dz}||jvr5||||j||||dSdSt |j|<dS)Nrcr:rFr_)rr~rrdrload_positions_snapshotr)r&rrrrrrSs r)rzbinance.set_positions_caches 6>> F > !DN 4> ! ! F!%!3!34DF^`e!f!f ! >!::K6>11 k*** 47dTefffff21$<#=#=DN4 r*cKd|i}|rd|d<|d|d{V}t|j|<|j|}tdt |D]<}||} || dd} | dkr|| =||jvr=|j|} | ||||dzdSdS)NrTrrrz :position) fetch_positionsrrrrrrrr) r&rrSrrrrr rpositionrrds r)rdzbinance.load_positions_snapshots D   -(,F$ %..tV<<<<<<<< 799tt$q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5$"4 5 5 5 5 5 ) (r*c&|j}t|}||}|ji|_||jvrt |j|<|j|}||di}||dg}g} tdt|D]|} || } | | } | |d} | | d<| | | d<| | | | }|||dz}tdt|D]} || }|d}|d }|d }|| d |d }||s||||| |d zdS)Nrxr]rr{rrz :positions::rrrrFr^)rdrrrrrrrrrrparse_ws_positionrr rfind_message_hashessplitrrr)r&rrrdrrr data rawPositionsrar rawPositionrgrrrSparts symbolsStringrrs r)handle_positionszbinance.handle_positions*s<,  !3!3!5!566>>?PQQ > !DNt~--*B*D*DDN; '{+~~gsB//~~dC44  q#l++,, # #A&q/K--k::H))'377I$-H[ !#'<< #:#:HZ    ) ) ) LL " " " "00~9UVV q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[<%?@@@@@r*c ||d}||d}tj||d}||d}d}|dkr1d}tj|dstj|drd}nd }|id |d dd ||ddd ddd||dddd||dd||dddd| |ddddd|d|dddddddddddddS) NrparTbothFrshortlongrrrrnotionalrmtliquidationPricerep unrealizedPnlupr\rrrrhedgedrrmaintenanceMargin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio) rr string_absrr string_lt safe_positionrr parse_number)r&rgrr r contractsAbs positionSider}s r)rizbinance.parse_ws_positionfs##Hc22$$Xt44 )$*:*:8T*J*JKK --h==  6 ! !F$Y44 *$Y44*#*LL#)L!!# H# $#  d&&xtVDD#   # $**8T:: #  #  $**8T::#  T--h==#  $#  **<88#  D#  #  L#  f#  # !# " ## $,0!'+/# # #    r*c^K|d{V|t|jdz||}|d||}|dkr#|dkrt|jdz|zdz|jdd d |}||}t|} d } ||dd d \} }| || d } ||| d<||| d<| |d} | |t|jdz| d| | | |d} d|j i}||| | | |d{V}|||||S)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 symbolrIrcrdz" fetchMyTradesWs does not support  marketsrkr,rgFrnrr rfromIdz_ fetchMyTradesWs does not support fetching by both fromId and since parameters at the same timemyTradesrKr)rrrrrLrrr9r8rrrNrhandle_trades_wsrPr.)r&rrrrrrrr~rSrnrQrrr?rs r)fetch_my_trades_wszbinance.fetch_my_trades_wss!!!!!!!!! >TW'KKLL LV$$##$5vvFF 6>>dh..TW'KKdRU__`` `it$X.t4OOC(( )nn  #'#@#@IZ\npu#v#v &nnV,, 0    #(GK  $GG ""6844  %"3TW(IIJJ J &&t{{7F'C'CDD   d+ zz#{G[,WWWWWWWW00NNNr*cK|d{V||}|d||}|dkr#|dkrt|jdz|zdz|jddd |}||}t|} d } ||dd d \} }| || d } ||| d <| d| | |d} d|j i} | || | | | d{V}| |||S)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 ` NrSrcrdz fetchTradesWs does not support rrkr,rgFrnrrztrades.historicalrKr)rrrLrrrrr9r8rrrrPr)r&rrrrrrrr~rSrnrQrr?rs r)fetch_trades_wszbinance.fetch_trades_wss!!!!!!!!!V$$##OVVDD 6>>dh..TW'IIDPS]]^^ ^it$X.t4OOC(( )nn  #'#@#@Zlns#t#t &nnV,, 0    $GG )kk'622   d+ zz#{G[,WWWWWWWW))&%???r*c||d}||dg}||}|||dSr)rr parse_tradesr)r&rrrSrVrs r)rzbinance.handle_trades_wss\\&&w55 266""6**v{+++++r*chK|d{Vd}d}|||}|d}|d||\}}d}|d||\}}|||rd}n|||rd}d}|<||}|d|zz }|||d|d }||||d |d{V|} |d krd } d} | |dd dd\} }d} |d ks|d kr |j dddd } n+| rd } | | |j |d} | | } || || || |d| d} || || |d{V}|jr|||}|||||dS)ag 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 ` Nrr3rdrerr5r)rr)rrrfrcrhrFrrkr,rgrT)rrrrrrrrr'rrrrrrrrPrrr.)r&rrrrrrrrSrrrrrrs r)watch_my_tradeszbinance.watch_my_trades&s!!!!!!!!!  [[((FH%F99/6SYZZ f99/6SYZZ ==w ' ' DD ^^D' * * D  [[((F 3< 'K[[&.F)S)STTF Tg,N,NPV W WXXXXXXXXX 8  G $($C$CFO]cevx}$~$~!6 6>>TX--)E"4(26:CC  ! ))'4<3Ek3RSSCS!! vt->???   t5FGGGzz#{GTBBBBBBBB ? 3OOFE22E00tTTTr*c<d}||d}|dkr||}||d}||di}|i|}||d}||||j} | || j|i} || |} | || d} || d} || sd}td t| D]z}| |}|d |d kr^| |d |d }t| |d || d|d <d }n{|r| d |n| | d |d krU| | d |d }t| |d || dd <n | d || d<n| |g| d<d| d<n|| d<|| d g}| ||| d <|j0||jdd}t%||_|j}| |||j||dz|z}||j|dSdS)NrrrrrrfeesTrrrFrr{ryr5)rrrrrrhashmaprrrrfloatcurrency_to_precisionrrrrrrr)r&rrrSrrrtradeFeer cachedOrdersrrrrinsertNewFeeCurrencyrorderFeer orderTradesrrmessageHashSymbols r)rZzbinance.handle_my_tradeXsA ((#66 G # #''00E&&ug66G~~eUB77H{{2x00H%%eX66F"x';@R#{ +!__\-A62NNF OOFG< > > _":(:2FFF*.((3v;@P*Q*Q7N>NPUWY[] ^ ^ ^ ^ ? ? ?H MM!R #F$8$=$=$?$?@@ 1c"23344 ? ?#3A#6 !%!1!1&2FGW2XZ^!_!_#//0DEU0VXfgg ''MM!%5666#/"0> ? ? ? ? ? ? ' MM'2 & & &%%eV44  "A#)=)= LL ! ! ! ! ! # ")=)=s5B E5CE00E5c||d}|j}t|}||}|dkr |j|=|||dSdS)NrjeventStreamTerminated)rrdrrrrre)r&rrrrdrrs r)handle_event_stream_terminatedz&binance.handle_event_stream_terminateds  #..,  !3!3!5!566>>?PQQ + + +$[1 MM'; / / / / / , +r*c ||d}||}||d}||d}|||dkr|||dS||d}||j|}||d}||||dSid|jd|jd |jd |jd |jd |jd |jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|j |j |j |j |j |j |j |j |j |j|j|j d } ||d} t!|t"r!|d} || ddz} || | }|X||d} | |||dS| d|vrd|vr| ||dSdSdSdS|||dS)Nrr2r200rr depthUpdaterrrrrz 1hTicker@arrz 4hTicker@arrz 1dTicker@arrz24hrTicker@arrz24hrMiniTicker@arrrrrrrr) zmarkPriceUpdate@arrroutboundAccountPositionrACCOUNT_UPDATEexecutionReportrXrYrrexternalLockUpdaterjrr7rxrz)rrrrrdrrrrlrorjrrr\r rrqrrr) r&rreventMsgr2rrrdrmethodsrrlr~s r)handle_messagezbinance.handle_messages>>'733  G!!'84411  6#5&E//   1 1 1 F   gt , ,((($77I$//@@@}#..sg~~%%fg66666}..~~ F67 # # # # #r*)rr!)rc)F)NF)__name__ __module__ __qualname__rr#r%rrrrrrrrr9r rr rrr rr#r"r+r r.r-rFrIrTrOrkrrrurbrr:rdictrrrrrrrrrrrrrrrrr rrrrrrrrr'r)r+r-r0boolrrcr rjrlrorhrNrrrrr'rrrrrrrrrrrrrrrLrrrr r r rrrrr'r)r+r0r5r7r9rVr\rbrrdrqrirrrrrZr[rrrr __classcell__)r(s@r)rrsE#EEEEEEn n n `Y&YYYY3#.  >>> BFTXac Y Ys Y3 Yc Yhlmxhy Y Y Y YUYgktv4b4bDI4bc4bad4b{AL|M4b4b4b4bl3A3A3A3A3AjY Y Y Y vEIW[df V V# Vc VQT Vkop{k| V V V VX\jnwy$\$\tCy$\QT$\dg$\CDOP$\$\$\$\L;CF;C;C;C;Cz@DB6P6PS6P6PS\6P6P6P6PpSW_aA!A!$s)A!CA!foA!A!A!A!FPR5x5xT#Y5xVY5x5x5x5xn=?LLL3LLLL"CGr'''C'V_''''R/f////>+*+*+*Z&&& 333T.T.T.T.T.lVVVVVV $'V'4''''OSaenp8S8Sd3i8S8S[^8SuyzvA8S8S8S8StLN8w8wc8wRU8w8w8w8wt9;HHCHsHHHH"<@d[]SSSSSSbfglbmSSSS&Y Y EY Y Y Y v161111$?CQUdhqs))))3)^a)x|~ByC)))).aeswAC=E=E$tCy/=EZ]=Emp=E=E=E=E~^`>u>uT$s)_>udg>u>u>u>u@BFbTT3T3TUXTTTT(=16=1=1=1=1~9;##C#v####JBFTXgktv0V0V30V30Vc0Vad0V{AE|F0V0V0V0Vd$,$,$,$,$,L68F*:<S :>bEEwEWEEEE*6:"EE7EEEEE09=RjjgjCjjjj*=A m m' mPS m m m m=? A A A3 A A A A9;==C=s===="8-----*Yaik@S@SRU@S@S@S@SD/1 X X X X)+1Q1Q1Q1Qf24@@@@D $ $ $ $ $ $ B B B-/%V%V8%V%V%V%VN 4 4 4 4 424v24242424h;= ? ?c ?h ? ? ? ?;?r.P.P.PdS[n.P.P.P.P`'/&'/'/'/'/R*,&A&A&A&A&A&APi?Vi?i?i?i?Vcs68    pt|~>V>VC>Vy>V >V[`>Vil>VDI>V>V>V>V@3+f3+3+3+3+j),v),),),),Vim{IK*V*Vc*V3*Vi*Vy*Vbe*Vux*VPU*V*V*V*VXk+6k+k+k+k+Z<@6V6V6VS6Vu6V6V6V6Vp8D_cln3cY\swx}s~(8<$]ajl$O$O$OC$OWZ$Oquv{q|$O$O$O$OL04$UYbd8U8U8UC8Us8Uimnsit8U8U8U8Utd d d d Lz4&z4z4z4z4x8<$]ajl2V2VW2VC2VWZ2Vquv~q2V2V2V2Vh>>&>>>>> 666(:A:A:Ax1 1 1 1 f6:[_hj.O.Os.O#.OUX.Oostyoz.O.O.O.O`?CQU^`(@(@C(@(@3(@eijoep(@(@(@(@T1,v1,1,1,1,f37TX\eg0U0UC0Us0URU0Ulpqvlw0U0U0U0Ud5=f5=5=5=5=nD6DDDD:///$"f$"$"$"$"L 0V 0 0 0 0H$VH$H$H$H$H$H$H$H$r*r)%ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrccxt.base.typesrrr r r r r rrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrccxt.base.preciser async_supportrrr*r)rs AAAAAAAAAAAAYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYY444444......''''''))))))******%%%%%%ZD$ZD$ZD$ZD$ZD$d (ZD$ZD$ZD$ZD$ZD$r*