eiddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntMarketOrder OrderBookPositionStrStringsTickerTrade)Client)List) BadRequest) NotSupported) NetworkError)PreciseceZdZdeffd Zifdedededededed edefd Zifd edefd Z ifd edefd Z de fdZ dbingxreturncf|tt|iddddddddddddd dd dd dd dd ddddddddddddddddiidddddiddddidddd d!d"d#d$d%d&d'd(d)d*d+d,idd-d.d/d0d1d2d3iddd4ddd5d6d7id8did9d:d;id<S)=NwsT watchTradeswatchTradesForSymbolsFwatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTrades watchTicker watchTickers watchBalancewatchPositions unWatchOHLCVunWatchOrderBook unWatchTicker unWatchTradeslinearz+wss://vst-open-api-ws.bingx.com/swap-marketz"wss://open-api-ws.bingx.com/marketz)wss://open-api-swap.bingx.com/swap-marketz(wss://open-api-cswap-ws.bingx.com/marketspotr-inverse)testapii 6gunzip timeframes1m3m5m15m30m1h2h4h6h12h1d3d1w1M)r5r6r7r8r9r:r;r<r=r>r?r@rArB1min5min15min30min60min1day)r5r7r8r9r:r?)fetchBalanceSnapshotawaitBalanceSnapshot)fetchPositionsSnapshotawaitPositionsSnapshotdepthdignoreDuplicates)listenKeyRefreshRaterswapr/r'r(rr keepAlivei@w)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s L/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bingx.pyrYzbingx.describeseT 2 2 ; ; = =dt(!$  +E  d 't t!$#D  !" #* "O  D"M#M  )0d!"""$$""""$""""##&!$$&&%$ ## -1,0!! /3.3## S# ' [00dWgV@ V@ V V V messageHashsubMessageHash subscribeHashdataTypetopicmarket methodNamec zKd} d} d} ||||\} }||||d\} }| dkr(||jdd| } n'||jdd| } |} | |dd} g}|||dd| |g|g||d }||d }|||d <||d }|| || | |||d{VS) Nr-rQr2runsub)idrareqTypesymbolT) unsubscribergsubMessageHashes messageHashessymbolsrbsymbolsAndTimeframes) handle_market_type_and_paramshandle_sub_type_and_params safe_stringrTuuidappend safe_listomitwatchextend)rZr^r_r`rarbrcrdparams marketTypesubTypeurlrgrequestrm subscriptionrns r\un_watchzbingx.un_watchls !?? FTZ[[ F99*ffV^__   ""49U#3D#97CCCC""49U#3D#9:FFC YY[[       NN6(+ , , ,!/ 0)]    $~~f6LMM  +3GL/ 0YYv'=>>FZZ[$++gv2N2NP]_klllllllllr]ricK|d{V||}d}d}d}|d||\}}|d||d\}}|dkr(||jdd|}n'||jdd|}|ddz}|d |d }|} | |d } |dkrd | d <d| d} |||| | ||| d{VS)a  watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscribe%20to%2024-hour%20Price%20Change https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Subscribe%20to%2024-hour%20price%20changes https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscribe%20to%2024-Hour%20Price%20Change :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 ` Nr%r-rQr2rrg@tickertickerrirgrasubrhFrjrg) load_marketsrcrorprqrTget_message_hashrrrvrw) rZrirxrcryrzr{rar^rrr|r}s r\ watch_tickerzbingx.watch_tickers!!!!!!!!!V$$ !?? vW]^^ F99-QWYabb   ""49U#3D#97CCCC""49U#3D#9:FFC$<)+++HfX6FGG yy{{      !&GI    ZZ[$++gv2N2NP[]ijjjjjjjjjr]c K|d{V||}|ddz}|d|d}d|z}d}d}|||||||||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://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscribe%20to%2024-hour%20Price%20Change https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Subscribe%20to%2024-hour%20price%20changes https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscribe%20to%2024-Hour%20Price%20Change :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 ` Nrgrrri unsubscribe::r+rrcrr~ rZrirxrcrar_r^rbrds r\un_watch_tickerzbingx.un_watch_tickers!!!!!!!!!V$$$<)+..x9IJJ%6 $ ]]; XW\^dfprxyyyyyyyyyr]clientc||di}||d}|jddk}|rdnd}||dd|}|d}|||} | |j|<|| |d|||dd kr+|| |ddSdS) NdatasrQrr/rirraz all@ticker) safe_valuerqr{find safe_marketparse_ws_tickertickersresolver) rZrmessagermarketIdisSwapryrcrirs r\ handle_tickerzbingx.handle_tickers nw33##D#..((A-%1VV6 !!(D$ CC!%%dF33% Vvt44XvFFGGG   GZ 0 0L @ @ NN64#8#8#B#B C C C C C A @r]Nc||d}||d}|||}||d}|id|dd|d||d||dd ||d d ||d d ||dd||dd||dddd||dd|d|ddd||ddddd||d||d|d|S) NCrcri timestampdatetimehighhlowlbidB bidVolumebaskA askVolumeavwapopenocloselast previousClosechangep percentageaveragevq) baseVolume quoteVolumeinfo) safe_integerrqr safe_tickeriso8601)rZrrcrrrs r\rzbingx.parse_ws_ticker s .%%gs33 ##GS11!!(F33  #..! fX&! !   Y//!  D$$Wc22 ! 4##GS11 ! 4##GS11 !  ))'377!  4##GS11!  ))'377!  D!  D$$Wc22!  U!  E!  T!  d&&w44! $!! " t#! $**7C88++GS99)! ! ! * + r]rylimitc|d}nC|dks|dkr|gd|}n|dkr|ddg|}|S)NrNrQfuture) 2rNr/r)find_nearest_ceiling)rZryrs r\#get_order_book_limit_by_market_typez)bingx.get_order_book_limit_by_market_type>sj =EEV##zX'='=112F2F2FNNv%%112s)UCC r]unifiedChannelextrac>|}| |d|zz }n|dz }||d|zz }|S)N::r)rZrrirhashs r\rzbingx.get_message_hashHs?   D6M !DD CKD   D5L D r]sincecdK|d{V||}|d}d}d}d}|d||\}}|d||d\}}|dkr(||jdd|}n'||jdd|}|dd z} d |z} |} | | d } |dkrd | d <d| d} ||| || || | d{V}|j r| ||}| |||dd}| dddr-| |}||d}|S|S)an watches information on multiple trades made in a market https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscription%20transaction%20by%20transaction https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Subscribe%20the%20Latest%20Trade%20Detail https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscription%20transaction%20by%20transaction :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 :returns dict[]: a list of `order structures ` Nrirr-rQr2rrg@tradetrade::rrrhFrrTrO)rrcrorprqrTrrrvrw newUpdatesgetLimitfilter_by_since_limit handle_option!remove_repeated_trades_from_arraysort_by)rZrirrrxrcryrzr{rawHashr^rrr|r}tradesresultfiltereds r\ watch_tradeszbingx.watch_tradesRs!!!!!!!!!V$$! !?? vW]^^ F99-QWYabb   ""49U#3D#97CCCC""49U#3D#9:FFC,)&( yy{{     !&GI    zz#{DKK4P4PR]_kllllllll ? 3OOFE22E++FE5+tTT   m-? F F ==fEEH||Hk::HO r]c K|d{V||}|ddz}|d|d}d|z}d}d}|||||||||d{VS) a' unsubscribes from the trades channel https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscription%20transaction%20by%20transaction https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Subscribe%20the%20Latest%20Trade%20Detail https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscription%20transaction%20by%20transaction :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 ` Nrgrtraderirrr,rrs r\un_watch_tradeszbingx.un_watch_tradess!!!!!!!!!V$$$<(*..wx8HII%6 $ ]]; XW\^dfprxyyyyyyyyyr]c||dg}||d}|dd}|jddk}|rdnd}||dd|}|d} d| z} d} t |tr|||} n| ||g} ||j | } | 5| |j d d } t| } | |j | <tdt| D]}| | ||| | dS) Nrra@rrQr/rir tradesLimit)rrqsplitr{rr isinstancelist parse_trades parse_traderrrUrrangelenrsr)rZrrrrrrryrcrir^rstoredrjs r\ handle_tradeszbingx.handle_tradess|dw33""7J77==%%a(((A-%1VV6 !!(D$ CC!&(  dD ! ! 6&&tV44FF&&tV445Ff55 >%%dlM4HHE&&F"(DK q#f++&& % %A MM&) $ $ $ $v{+++++r]crK|d{V||}d}d}d}|d||\}}|d||d\}}|dkr(||jdd|}n'||jdd|}||jdi}||dd} |d d zdz| | z} | d |d } | } | | d } |dkrd| d<i}|dr| d||d}n| d||d}| || | | || |d{V}|S)aQ watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscribe%20Market%20Depth%20Data https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Partial%20Order%20Book%20Depth https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscribe%20to%20Limited%20Depth :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 Nrr-rQr2rrMrNrgr orderbookrirrrhr0F)rgrjcountrx)rgrjlevelrx)rrcrorprqrT safe_dictrUrnumber_to_stringrrrrvrWr)rZrirrxrcryrzr{rUrMsubscriptionHashr^rrr|subscriptionArgsrs r\watch_order_bookzbingx.watch_order_books!!!!!!!!!V$$ !??@PRXZ`aa F99:JFTZ\dee   ""49U#3D#97CCCC""49U#3D#9:FFC../?DD!!'7C88!$<#-7$:O:OPU:V:VV++K9IJJ yy{{(     !&GI !# )  $     $     **S+t7G7GQW7X7XZjl|}}}}}}}}    r]c hK|d{V||}||jdi}||dd}|ddzdz||z}d|z}d}d } |||||||| |d{VS) a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/Subscribe%20Market%20Depth%20Data https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Partial%20Order%20Book%20Depth https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscribe%20to%20Limited%20Depth :param str symbol: unified symbol of the market :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrrMrNrgrrrr*)rrcrrUrrr~) rZrirxrcrUrMr_r^rbrds r\un_watch_order_bookzbingx.un_watch_order_book6s!!!!!!!!!V$$../?DD!!'7C88+g58M8Me8T8TT%6 ' ]]; ^]bdjlvx~r]c||dd}||dd}|||dS)Nrrr) safe_float_2store)rZbooksidedeltapriceamounts r\ handle_deltazbingx.handle_deltaLsJ!!%C00""5!S11uf%%%%%r]c ,||di}||d}|d}|d}|dk}||d|}|jddk} | rdnd} ||dd| } | d} ||j| } | C|}|j|}| |d }| i||j| <|j| } d}| |d d }| |d d |}| d r| || |d ddd}n| || |d ddd}| |d}||d<| ||d| }|| ||r-|d}|| |dSdS)NrrarrallrirQr/rrtsr0bidsasksrrr lastUpdateIdnoncer)rrqrr{rrr orderbooks subscriptionsr order_booksafe_integer_2parse_order_bookresetrr)rZrrrraparts firstPart isAllEndpointrrryrcrirrr}rsnapshotrrr^messageHashForAlls r\handle_order_bookzbingx.handle_order_bookQs?H~~gvr22##GZ88s##!H "e+ ##D(I>>((A-%1VV6 !!(D$ CC!OODOV<<  ' !/0@AL%%lG< < &y 1;I   eY / /   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   r]cl|jddk}||d}|d}|d}|dk}||d|}|rdnd} ||dd| } d} |r9| dr||d ig} nG||d g} n/||d i} || d ig} | d } ||j| i|j| <|d d }||j | }||di}| ||}||j| |B|}|j |}| |d}t||j| |<|j| |}tdt| D]5}| |}||| }||6| ||g}|d| |}||||r/|dd|}|||dSdS)NrQrrarrrr/r0rKri_rr4rr)r{rrqrrrrtrohlcvsrUfind_timeframer rrrrrrsrr)rZrrrrarrrrryrccandlesrri rawTimeframe marketOptionsr4unifiedTimeframerr}rricandleparsed resolveDatar^rs r\ handle_ohlcvzbingx.handle_ohlcvsB((A-##GZ88s##!H "e+ ##GS)<<%1VV6 !!(D$ CC  6i  >>>'62>>?..&"==>>'6266D~~dC445G!"oodk62FF F~~c**1- t|Z@@ ^^M<DD ..|ZHH ??4;v. = = E' !/0@AL%%lG<!!!!!!!!!V$$ !?? fV\]] F99,PVX`aa   ""49U#3D#97CCCC""49U#3D#9:FFC ;TW'JJZWZeeff f//$, B??__WlB?? '' IyII ++GVH5EyQQ !$<)3lByy{{(     !&GI  $ " "  zz#{DKK4P4PRbdtuuuuuuuuq  ? 2NN6511E))%q$GGGr]c K|d{V||}||j|di}||di}||||}|ddz|z}d|z} d} d} |d |gg} | |d <|| || || || |d{VS) a  unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Market%20Data/K-line%20Streamst https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Market%20Data/Subscribe%20K-Line%20Data https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Market%20Data/Subscribe%20to%20Latest%20Trading%20Pair%20K-Line :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Ntyper4rgr*rrr)rirn)rrcrrUrqr~) rZrir(rxrcrUr4r r_r^rbrdrns r\un_watch_ohlcvzbingx.un_watch_ohlcvps!!!!!!!!!V$$//$,vCC__WlB?? '' IyII  1L@%6 # !'!19 =>)=%&]]; ^]bdjlvx~r]cdK|d{V|d{Vd}d}d}|||}|d}|d||\}}|d||d\}}|dk}d} d} |r| n| } d} d } |r| n| }||d |zz }|}d}d}|d krE|d krt |jd z||j dd|}n-||j dd|}|ddd}|dz|j dz}d|d}| |||| |d{V}|j r| ||}|||||dS)a/ watches information on multiple orders made by the user https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Account%20Data/order%20update%20event https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Account%20Data/Order%20update%20push https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Account%20Data/Order%20update%20push :param str [symbol]: unified market symbol of the market orders are made in :param int [since]: the earliest time in ms to watch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nrir#r-r/ spot:private swap:private spot:order swap:order:rQr0z: watchOrders is not supported for inverse swap markets yetr2rrspot.executionReportrgrhra ?listenKey= listenKeyFrTr authenticatercrorprrrrgrqrTrUrvrrfilter_by_symbol_since_limit)rZrirrrxr/rzrcisSpotspotHashswapHashrspotMessageHashswapMessageHashr^rrbaseUrlr|r{r}orderss r\ watch_orderszbingx.watch_orderss4!!!!!!!!!!!!!!!!!!  [[((FH%F99-QWXX f99-QWYabb&.!!'-;888&&)/Doo_   3< 'Kyy{{ 6>>)##"47-i#ijjj&&ty'7'=wGGGG&&ty'7'=tDDG 2G  % [(AA   zz#{G=M|\\\\\\\\ ? 3OOFE22E00tTTTr]cdK|d{V|d{Vd}d}d}|||}|d}|d||\}}|d||d\}}|dk}d} d} |r| n| } d} d } |r| n| }||d |zz }|}d}d}|d krE|d krt |jd z||j dd|}n-||j dd|}|ddd}|dz|j dz}d|d}| |||| |d{V}|j r| ||}|||||dS)a3 watches information on multiple trades made by the user https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Account%20Data/order%20update%20event https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Account%20Data/Order%20update%20push https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Account%20Data/Order%20update%20push :param str [symbol]: unified market symbol of the market the trades are made in :param int [since]: the earliest time in ms to watch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nrir$r-r/r2r3 spot:mytrades swap:mytradesr6rQr0z< watchMyTrades is not supported for inverse swap markets yetr2rrr7r8r9r:FrTr;)rZrirrrxr/rzrcr>r?r@rrArBr^rrrCr|r{r}rs r\watch_my_tradeszbingx.watch_my_tradess4!!!!!!!!!!!!!!!!!!  [[((FH%F99/6SYZZ f99/6SY[cdd&.!!'-;888)))/Doo_   3< 'Kyy{{ 6>>)##"47-k#klll&&ty'7'=wGGGG&&ty'7'=tDDG 2G  % [(AA   zz#{G=M|\\\\\\\\ ? 3OOFE22E00tTTTr]cK|d{V|d{Vd}d}|dd|\}}|dd|d\}}|dk}d}d}d}d}|r|n|} |r|n|} d} d} |} |dkrE|d krt |jd z||jd d |} n,||jd d |} | d d} | dz|j dz}| |}| |||| |d}d}| |ddd\}}| |ddd\}}|r |r| |dzd{Vd| d}||| | | |d{VS)a query for balance and get the amount of funds available for trading or funds locked in orders https://bingx-api.github.io/docs-v3/#/en/Spot/Websocket%20Account%20Data/Subscription%20account%20balance%20push https://bingx-api.github.io/docs-v3/#/en/Swap/Websocket%20Account%20Data/Account%20balance%20and%20position%20update%20push https://bingx-api.github.io/docs-v3/#/en/Coin-M%20Futures/Websocket%20Account%20Data/Account%20balance%20and%20position%20update%20push :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nr'r-r/z spot:balancer3z swap:balancerQr0z; watchBalance is not supported for inverse swap markets yetr2rACCOUNT_UPDATErr9r:rITrJF:fetchBalanceSnapshotr)rr<rorprrrrgrqrTrUrset_balance_cachehandle_option_and_paramsrrv)rZrxr/rzr> spotSubHash swapSubHashrArBr^rr|rCrrr{rrIrJr}s r\ watch_balancezbingx.watch_balancesw!!!!!!!!!!!!!!!!!!99.$PVWW f99.$PVX`aa&.$ $ (()/Doo_ *0A;;kyy{{ 6>>)##"47-j#jkkk&&ty'7'=wGGGG&&ty'7'=tDDG,G % [(AAS!! vtW6FOOO##'+'D'DV^]suy'z'z$f'+'D'DV^]suz'{'{$f  @$8 @--'> >?? ? ? ? ? ? ? ?   ZZ[';K\ZZZZZZZZZr]c||jvrdS||ddd}|rE|dz}||jvr5||||j||||dSdSi|j|<dS)Nr'rITrL)r rNfuturesrspawnload_balance_snapshotbalance)rZrr/rzrrxrIr^s r\rMzbingx.set_balance_cache0s v3 3 3 F#<11 k*** 45v{DRYZZZZZ21"$DL   r]cVK|||dd{V}||||j|i|j|<||jvrG|j|}|||j||dzdSdS)Nr/rz:balance) fetch_balancerwrrVrSr)rZrr^r/rzresponsers r\rUzbingx.load_balance_snapshot<s++Tg,N,NOOOOOOOO![[4??4|j7| |dzd{V}|||||dS|| |d| |d{V}|jr|S||j|||dS)aZ watch all open positions https://bingx-api.github.io/docs/#/en-us/swapV2/socket/account.html#Account%20balance%20and%20position%20update%20push :param str[]|None [symbols]: list of unified market symbols :param int [since]: the earliest time in ms to fetch positions for :param int [limit]: the maximum number of position structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr,r(rQr-r/z1 watchPositions is not supported for spot marketsr0z= watchPositions is not supported for inverse swap markets yetr3swap:positionsr2rr9r:rKTrLFr:fetchPositionsSnapshot)rr<market_symbolsis_emptyget_market_from_symbolsjoinrorprrgrqrTrUrset_positions_cacherNrr positionsrfilter_by_symbols_since_limitrvr)rZrmrrrxrcr^r/rzrrCr{rrKrLrrr}r newPositionss r\watch_positionszbingx.watch_positionsEs!!!!!!!!!!!!!!!!!! %%g..}}W%% 311'::F'!2!22K99:JFTZ\bcc f99:JFTZ\dee 6>>tw)\\]] ] i  tw)hhii i)&4 ""49U#3D#97CC % [(AAS!!   w777!%!%)-)F)FvO_ay{*A*A&)-)F)FvO_ay|A*B*B&yy{{    " ]&< ]AW#]]42K+KLLLLLLLLH55hPUW[\\ \!ZZ[$@PR^________ ?  11$.'5RWY]^^^r]c|jdS|ddd}|rD|dz}||jvr4||||j|||dSdSt |_dS)Nr(rKTr`)rfrrSrrTload_positions_snapshotr)rZrr/rmrKr^s r\rezbingx.set_positions_cachexs > % F!%!3!34DF^`d!e!e ! 8!::K6>11 k*** 47dSSSSS21677DNNNr]cK|d|ddd{V}t|_|j}tdt |D]<}||}||dd}|dkr||=||jvr:|j|} | |||ddSdS)Nr-rXr contractsr_) fetch_positionsrrfrrrrsrSr) rZrr^r/rfcacher#positionrmrs r\rkzbingx.load_positions_snapshots..tdx5X5XYYYYYYYY 133q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5"2 3 3 3 3 3 ) (r]c ||d}||d}tj|}||d}d}|dkr1d}tj|dstj|drd}nd }||d }|d kr||d nd} |id |ddd||dddddd|ddd||dd||dddd| |ddddd|d|ddddd dd| ddddd!S)"NrpapsTbothF0shortlongmtisolatediwrrgrirQnotional marginModeliquidationPrice entryPriceep unrealizedPnluprrm contractSize markPricesidehedgedrrmaintenanceMargin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio) rqr string_abssafe_string_lower string_eq string_ltr safe_position safe_symbol parse_number) rZrprcrrm contractsAbs positionSiderr|rs r\parse_ws_positionzbingx.parse_ws_positions"##Hc22$$Xt44 ))44 --h==  6 ! !F$Y44 *$Y44*#*LL#)L%%h55 :D :R:RT%%h555Y] !!# H# $#  d&&xtVDD#   # * #  #  $**8T::#  T--h==#  $#  **<88#  D#  #  L#  f#  # !# " ## $,0$!'+/# # #    r]c|jt|_|j}||di}||dg}g}t dt |D]}||}||} || d} | 8||d} | | d<| | | d<| | | | | |d} t dt | D]}| |} | d }|d }| d }| |d|d }||s||| ||d dS)NrPrriErrzswap:positions::rrr^Fr_)rfrrrtrrrrqrrrsfind_message_hashesrfilter_by_arrayrbr)rZrrror rawPositionsrhr# rawPositionrprirrlr^r symbolsStringfilteredSymbolsrfs r\handle_positionszbingx.handle_positionss, > !577DN~~gsB//~~dC44  q#l++,, # #A&q/K--k::H%%h99F~))'377I$-H[ !#'<< #:#:HZ    ) ) ) LL " " " "009KLL q#m,,-- 7 7A'*K%%d++E!!HM+11#66O,,\8_V[\\I==++ 7y+666|%566666r]c||d} |B|jdz||z}||jd||n,#t $r}||Yd}~nd}~wwxYwdS)Ncode exactT)rqrgjsonthrow_exactly_matched_exception exceptions Exceptionreject)rZrrrfeedbackes r\handle_error_messagezbingx.handle_error_messages00 7S=499W+=+==44T_W5MtU]^^^    MM!         tsAA B'BBcK||jd}|dS |d|id{Vn#t$r}gd}t dt |D]}||}||jdd|}|4|dz|z}||} t| j } t dt | D] } | | } | || !d|jd<d|jd<Yd}~dSd}~wwxYw| |jdd } | | |j|dS) Nr:r.rr2rr9lastAuthenticatedTimerP6)rqrU userAuthPrivatePutUserDataStreamrrrrTrrrSkeysrrdelaykeep_alive_listen_key)rZrxr:errortypesr#r/rCr{rrlrr^rPs r\rzbingx.keep_alive_listen_key s$$T\;??   F 77i8PQQ Q Q Q Q Q Q Q Q   111E1c%jj)) 6 6Qx**49U+;D+A4HH? - 9S)) $V^%8%8%:%: ; ; q#m"4"45566A"/"2KMM%55556)-DL %45DL0 1 FFFFF " $00?UW^__ ')CVLLLLLsA E C+D==EctK|}||jdd}||jdd}||z |kr`|d{V}||d|jd<||jd<|||j|dSdS)NrrrPrr:) millisecondsrrU!userAuthPrivatePostUserDataStreamrqrr)rZrxtimerrPr[s r\r<zbingx.authenticate's  "" $ 1 1$,@WYZ [ [#00?UW^__ ' '*> > >!CCEEEEEEEEH(,(8(8;(O(ODL %48DL0 1 JJ+T-G P P P P P ? >r]cK |dkr|dd{VdS||d}||d}|||dd{VdS#t$rM}t|jdz||z}||Yd}~dSd}~wwxYw)NPingPongpingr)pongrz pong failed with error )sendrqrrrgexception_messager )rZrrrrrrs r\rz bingx.pong1s& &  kk&)))))))))))''88''88kk  ##    +E!EH^H^_`HaHa!abbE LL          s!A3A A33 C =ACC cd|v}||ddi}|j0||jdd}t ||_|j}||}|||d}d} d} |r| n| } ||| ||| d z|zdS) Nrarr ordersLimitrrir4r5r6) safe_value_2rDrrUr parse_orderrsr) rZrrr>rrr parsedOrderrir?r@r^s r\ handle_orderzbingx.handle_orderIsh'  &#r:: ; %%dlM4HHE077DK&&t,,  k"""X&#)8hh v{+++v{S069:::::r]cd|v}||ddi}|j}|2||jdd}t |}||_|rdnd}||d}||dd |} ||| } | d } d } d } |r| n| }|| | ||| ||d z| zdS)Nrarrrrr/rQr-rirGrHr6) safe_dict_2myTradesrrUrrqrrrsr)rZrrr>r cachedTradesrr/rrcr%rir?r@r^s r\handle_my_tradeszbingx.handle_my_tradess!r'!!'63;;}  %%dlM4HHE1%88L(DM+vvV##FC00!!(D#t<<!!&&11!"""(6hhh F###|[111|[3%6%?@@@@@r]c@||di}||dg}||dd}d|vrdnd}||jvr i|j|<||j|d<||j|d <|||j|d <t d t |D]}||}||d} || } | } || d<||d | d <||d| d<| |j|| <| |j||j|<| |j||dzdS)NrrrrrrQr/rrrrlkusedwbfreerY) rrtr rVrrrrqsafe_currency_codeaccount safe_balancer) rZrrrrrr/r#rV currencyIdrrs r\handle_balancezbingx.handle_balancesJ NN7C , ,~~ab))''c:: ((vv $$!#DL %) T6"*3 T;')-i)@)@ T:&q#d))$$ / /A1gG))'377J**:66DllnnG%GFO"..w==GFO"..w==GFO'.DL t $ $!..t|D/ABB Tt|D)4*+<=====r]c|||sdS|dksd|vr||j||dS||dd}|ddkr|||dS|ddkr|||dS|ddkr|||dS|d dkr|||dS|d dkra| |d i}||d }|d kr| ||| ||dS||d}|dkr,| ||| |||dkr{| ||| |di}||d }||d}|d kr|dkr| ||| |d }||d} | dkr||||dkr| ||||dSdSdSdS)Nrrrar]z@depthrrrz@klineexecutionReportrxTRADErrKORDER_TRADE_UPDATErXFILLED 24hTicker)rrTrrqrrrrr'rrrrrhandle_subscription_status) rZrrrarr/rstatusmsgDatamsgEvents r\handle_messagezbingx.handle_message2s ((99  F v  6W#4#4 JJty&' 2 2 2 F##GZ<< == " "a ' '  " "67 3 3 3 F == # #q ( (   vw / / / F == " "a ' '   vw / / / F == " "a ' '   fg . . . F ==* + +q 0 0??7FB77D##D#..Dw%%fg666   fg . . . F   Wc * *     0 0 0  ! !&' 2 2 2 $ $ $   fg . . .??7C44D##D#..D%%dC00Ff&8&8%%fg666//'622##GS11 { " "   vw / / / r>>h.19  + +FG < < < < < >..99r]c||d}||jd}|||i}||dd}|r||||S)NrgrjF)rqindex_byr r safe_boolhandle_un_subscription)rZrrrgsubscriptionsByIdr}isUnSubMessages r\rz bingx.handle_subscription_status_s~  gt , , MM&*>EE~~&7R@@  mUKK  >  ' ' = = =r]r}c||dg}||dg}tdt|D])}||}||}||||*||dS)Nrlrkr)rtrrclean_unsubscription clean_cache)rZrr}rlrkr# unsubHashsubHashs r\rzbingx.handle_un_subscriptionps|_bII >>,8JBOOq#m,,-- B BA%a(I&q)G  % %fgy A A A A &&&&&r])N)NN);__name__ __module__ __qualname__rrYstrr r~rrrrrrr rrrrrrrrr rrrrrrr'r-r0r rErIrrQrMrUrr rirerkrrrrr<rrrrrrdictr __classcell__)r[s@r\rrsW #W W W W W W r\^mm#msmSVmbemnqm|BmPSmcfmmmmB68$k$k$kF$k$k$k$kL9;zzCzszzzz*BDFBDBDBDBDH0000dc#sCs<@d[]///S//bfglbm////b9;zzCzszzzz,f,Ff,f,f,f,P@DB3!3!S3!3!S\3!3!3!3!j=?@@@3@@@@,&&& e9e9e9e9e9N  D    4h;6h;h;h;h;T?CQUdhqs2H2H2H2H32H^a2Hx|~ByC2H2H2H2HhBFb@@3@3@UX@@@@404$UYbd7U7U7UC7Us7Uimnsit7U7U7U7Ur37TX\eg7U7UC7Us7URU7Ulpqvlw7U7U7U7Ur*,2[2[2[2[2[2[h $ $ $ $ $BBB8<$]ajl1_1_W1_C1_WZ1_quv~q1_1_1_1_f 8 8& 8 8 8 8 8 4 4 42 2 2 2 h07v07070707d&24MMMM6)+QQQQ   0a;a;a;FJAvJAJAJAJAX8>V8>8>8>8>t+=V+=+=+=+=Z"'V'4''''''''r]r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrrr]r\rsY AAAAAAAAAAAAoooooooooooooooooooooooooo444444''''''))))))))))))%%%%%%f'f'f'f'f'D  $f'f'f'f'f'r]