i~ddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)BalancesIntOrder OrderBookStrTickerTrade)Client)List) BadRequest) NetworkError)Precisec eZdZfdZifdedefdZdefdZd!dZ ddifded e d e de e fd Z defd Zdifded e defd ZdZdefdZd!defdZdefdZdddifded e d e de efdZdddifded e d e de efdZdddifded e d e de e fdZifdefdZdefdZdZdZifdZ ifdZ!dZ"dZ#defdZ$defdZ%defd Z&xZ'S)"bingxc|tt|dddddddddd dddddiid d did d d dddddddddddddid dddddd d!iddd"d#d$d%id&S)'NTF) ws watchTradeswatchOrderBook watchOHLCV watchOrders watchMyTrades watchTicker watchTickers watchBalanceapirz"wss://open-api-ws.bingx.com/marketz)wss://open-api-swap.bingx.com/swap-market)spotswapi 6gunzip timeframes1m3m5m15m30m1h2h4h6h12h1d3d1w1M)r#r$r%r&r'r(r)r*r+r,r-r.r/r01min5min15min30min60min1day)r#r%r&r'r(r-)fetchBalanceSnapshotawaitBalanceSnapshot)listenKeyRefreshRaterr rr keepAlivei@w)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s T/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/bingx.pyrAzbingx.describes$eT 2 2 ; ; = =#"&"#!%# % $   D K)0d!"""$$""""$""""##&!$$&&%$ ## -1,1!!C%%NWu=@ =@ = = = symbolreturncK|d{V||}|d||\}}||jdd|}|t |jdz|zdz|ddz}|}||d } |d krd | d <|||| | ||d{VS) a  watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: https://bingx-api.github.io/docs/#/en-us/swapV2/socket/market.html#Subscribe%20to%2024-hour%20price%20changes :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 ` Nrrr" watchTrades is not supported for markets.id@tickerrKdataTyper subreqType) load_marketsmarkethandle_market_type_and_params safe_valuer<rrKuuidwatchextend) rBrFparamsrR marketTypequeryurl messageHashrUrequests rD watch_tickerzbingx.watch_tickerRs!!!!!!!!!V$$ >>}fV\]] Eoodi.t4jAA ;TW'KKjX[ffgg gTlY. yy{{#     !&GI ZZ[$++gu2M2M{[[[[[[[[[rEclientcj||di}||d}|jddk}|rdnd}||dd|}|d}|||} | |j|<|ddz} || | dS) Ndatasr rrrFrKrL)rT safe_stringr[find safe_marketparse_ws_tickertickersresolve) rBr_messageramarketIdisSwaprYrRrFtickerr\s rD handle_tickerzbingx.handle_tickerjsnw33##D#..((A-%1VV6 !!(D$ CC!%%dF33% VTlY. v{+++++rENc||d}||d}|||}||d}|id|dd|d||d||dd ||d d ||d d ||dd||dd||dddd||dd|d|ddd||ddddd||d||d|d|S) NtsrbcrF timestampdatetimehighhlowlbidB bidVolumebaskA askVolumeavwapopenocloselast previousClosechangep percentageaveragevq) baseVolume quoteVolumeinfo) safe_integerrcre safe_tickeriso8601)rBrirRrqrjrs rDrfzbingx.parse_ws_tickers .%%gt44 ##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)! ! ! * + rEsincelimitcRK|d{V||}|d||\}}||jdd|}|t |jdz|zdz|ddz} |} | | d } |d krd | d <||| | | || d{V} |j r| ||}| | ||d dS)a watches information on multiple trades made in a market :see: https://bingx-api.github.io/docs/#/spot/socket/market.html#Subscribe%20to%20tick-by-tick :see: https://bingx-api.github.io/docs/#/swapV2/socket/market.html#Subscribe%20the%20Latest%20Trade%20Detail :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]{@link https://docs.ccxt.com/#/?id=order-structure NrrrrIrJrK@traderMr rOrPrqT) rQrRrSrTr<rrKrUrVrW newUpdatesgetLimitfilter_by_since_limit) rBrFrrrXrRrYrZr[r\rUr]tradess rD watch_tradeszbingx.watch_tradessT!!!!!!!!!V$$ >>}fV\]] Eoodi.t4jAA ;TW'KKjX[ffgg gTlX- yy{{#     !&GI zz#{DKK4O4OQ\]]]]]]]] ? 3OOFE22E))&% TRRRrEc||dg}||d}|dd}|jddk}|rdnd}||dd|}|d} d} t |tr|||} n| ||g} ||j | } | 5| |j dd } t| } | |j | <tdt| D]} | | | || |dS) NrarN@rr rrF tradesLimit)rTrcsplitr[rdre isinstancelist parse_trades parse_traderrr=rrangelenappendrh)rBr_rirar\rjrkrYrRrFrstoredrjs rD handle_tradeszbingx.handle_tradesstxw33&&w ;; $$S))!,((A-%1VV6 !!(D$ CC! dD ! ! 6&&tV44FF&&tV445Ff55 >%%dlM4HHE&&F"(DK q#f++&& % %A MM&) $ $ $ $v{+++++rEcK|d{V||}|d||\}}|d}ne|dkr6|dkr/|dkr)|dkr#|dkr|dkrt|jd zn)|d kr#|dkr|dkrt|jd z||jd d |}|t|jdz|zdz|ddzt|z}|} | |d} |dkrd| d<| ||| | ||d{V} | S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://bingx-api.github.io/docs/#/spot/socket/market.html#Subscribe%20Market%20Depth%20Data :see: https://bingx-api.github.io/docs/#/swapV2/socket/market.html#Subscribe%20Market%20Depth%20Data :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 Nrdr  2zB watchOrderBook()(swap) only supports limit 5, 10, 20, 50, and 100rz7 watchOrderBook()(spot) only supports limit 20, and 100rrz% watchOrderBook is not supported for rJrK@depthrMrOrP) rQrRrSrrKrTr<strrUrVr?r) rBrFrrXrRrYrZr[r\rUr] orderbooks rDwatch_order_bookzbingx.watch_order_bookNs!!!!!!!!!V$$ >>?OQWY_`` E =EEV##QJJUb[[u{{RT[`dg[g[g$TW/s%stttv%%RKKesll$TW/h%hiiioodi.t4jAA ;TW'NNQ[[^iijj jTlX-E : yy{{#     !&GI **S+t7G7GQV7W7WYdeeeeeeee    rEc||d}||d}|||dS)Nr) safe_floatstore)rBbooksidedeltapriceamounts rD handle_deltazbingx.handle_deltarsBq))**uf%%%%%rEc  ||dg}||d}|dd}|jddk}|rdnd}||dd|}|d} ||j| } | |} ||| ddd dd } | | | |j| <| | |dS) NrarNrrr rrFbidsasksr) rTrcrr[rdre orderbooks order_bookparse_order_bookresetrh) rBr_rirar\rjrkrYrRrFrsnapshots rDhandle_order_bookzbingx.handle_order_bookwsPw33&&w ;; $$S))!,((A-%1VV6 !!(D$ CC!OODOV<<  ))I((vtVVQPQRR!!!"+y+.....rEc |drdnd}|||||d||d||d||d||dgS) NrtTrrtrvrpr)r safe_number)rBohlcvrRrqs rDparse_ws_ohlcvzbingx.parse_ws_ohlcvs#6N4CC   eY / /   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   rEc||dg}d}t|tr|}n||dgg}||d}|dd}|dd}|jddk}|rdnd } ||dd| } | d } ||j| i|j| <||j| |} | ;| |j d d } t| } | |j| |<tdt|D]5}||}||| }| |6|| |dS) NraKrN_rrrr rrF OHLCVLimitr)rTrrrcrr[rdreohlcvsrr=rrrrrrh)rBr_riracandlesr\ timeframeIdrjrkrYrRrFrricandleparseds rD handle_ohlcvzbingx.handle_ohlcvsZw33 dD ! ! 7GGtS"556G&&w ;; !'',,Q/ $$S))!,((A-%1VV6 !!(D$ CC!"oodk62FF FV!4kBB >%%dlL$GGE*511F/5DK  ,q#g,,'' " "AQZF((88F MM& ! ! ! !v{+++++rEr#cK|d{V||}|d||\}}||jdd|} | t |jdz|zdz||j|i} || di} || ||} |dd z| z} | }|| d }|d krd |d <| | | | ||| d{V}|j r| ||}||||ddS)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :see: https://bingx-api.github.io/docs/#/spot/socket/market.html#K%E7%BA%BF%20Streams :see: https://bingx-api.github.io/docs/#/swapV2/socket/market.html#Subscribe%20K-Line%20Data :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Nrrrz! watchOHLCV is not supported for rJr"rKz@kline_rMr rOrPrT)rQrRrSrTr<rrKr=rcrUrVrWrrr)rBrF timeframerrrXrRrYrZr[r=r"intervalr\rUr]rs rD watch_ohlcvzbingx.watch_ohlcv s!!!!!!!!!V$$ >>|VU[\\ Eoodi.t4jAA ;TW'JJZWZeeff f//$, B??__WlB?? ##J 9EETlY.9 yy{{#     !&GI jjk4;;w3N3NP[\\\\\\\\ ? 2NN6511E))%q$GGGrEcfK|d{V|d{Vd}d}|||}|d}|d||\}}|dk}d}d} |r|n| } d} d} |r| n| } || d |zz } |jd d |d z|jd z}d}|}|r|dd}||| || d{V}|jr| ||}| ||||dS)a :see: https://bingx-api.github.io/docs/#/spot/socket/account.html#Subscription%20order%20update%20data :see: https://bingx-api.github.io/docs/#/swapV2/socket/account.html#Account%20balance%20and%20position%20update%20push watches information on multiple orders made by the user :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NrFrr spot:private swap:private spot:order swap:order:rr ?listenKey= listenKeyspot.executionReportrMT rQ authenticaterRrSr<r=rUrVrrfilter_by_symbol_since_limit)rBrFrrrXtyperRisSpotspotHashswapHashsubscriptionHashspotMessageHashswapMessageHashr\r[r]rUorderss rD watch_orderszbingx.watch_orders.s!!!!!!!!!!!!!!!!!!  [[((FH%F99-QWXX f&.!!'-;888&&)/Doo_   3< 'Kit$T*]:T\+=VVyy{{  2Gzz#{G=MNNNNNNNN ? 3OOFE22E00tTTTrEcfK|d{V|d{Vd}d}|||}|d}|d||\}}|dk}d}d} |r|n| } d} d} |r| n| } || d |zz } |jd d |d z|jd z}d}|}|r|dd}||| || d{V}|jr| ||}| ||||dS)a :see: https://bingx-api.github.io/docs/#/spot/socket/account.html#Subscription%20order%20update%20data :see: https://bingx-api.github.io/docs/#/swapV2/socket/account.html#Account%20balance%20and%20position%20update%20push watches information on multiple trades made by the user :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to trades orders for :param int [limit]: the maximum number of trades structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of [trade structures]{@link https://docs.ccxt.com/#/?id=trade-structure NrFrrrr spot:mytrades swap:mytradesrrrrrrrMTr)rBrFrrrXrrRr spotSubHash swapSubHashrrrr\r[r]rUrs rDwatch_my_tradeszbingx.watch_my_tradesWs!!!!!!!!!!!!!!!!!!  [[((FH%F99-QWXX f&.$ $ *0A;;k)))/Doo_   3< 'Kit$T*]:T\+=VVyy{{  2Gzz#{G=MNNNNNNNN ? 3OOFE22E00tTTTrEcK|d{V|d{Vd}|dd|\}}|dk}d}d}d}d}|r|n|}|r|n|} |jdd|d z|jd z} d} |} |dkr| d d } || } || || |d}d}||dd d\}}||ddd\}}|r |r| |dzd{V| | || | d{VS)a :see: https://bingx-api.github.io/docs/#/spot/socket/account.html#Subscription%20order%20update%20data :see: https://bingx-api.github.io/docs/#/swapV2/socket/account.html#Account%20balance%20and%20position%20update%20push query for 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 :returns dict: a `balance structure ` Nrrz spot:balancerz swap:balancerrrrACCOUNT_UPDATErMr7Tr8F:fetchBalanceSnapshot) rQrrSr<r=rUr_set_balance_cachehandle_option_and_paramsfuturerV)rBrXrrrrrrr\rr[r]rUr_r7r8s rD watch_balancezbingx.watch_balances!!!!!!!!!!!!!!!!!!99.$PVWW f&.$ $ (()/Doo_ *0A;;kit$T*]:T\+=VVyy{{ 6>>,GS!! vt-=vFFF##'+'D'DV^]suy'z'z$f'+'D'DV^]suz'{'{$f  @$8 @--'> >?? ? ? ? ? ? ? ?ZZ[';KLLLLLLLLLrEc||jvrdS||ddd}|rD|dz}||jvr4||||j|||dSdSi|j|<dS)Nrr7Tr) subscriptionsrfuturesrspawnload_balance_snapshotbalance)rBr_rrrXr7r\s rDrzbingx.set_balance_caches v3 3 3 F#<11 k*** 45v{DQQQQQ21"$DL   rEc>K|d|id{V}||||j|i|j|<|j|}|||j||dzdS)Nr:balance) fetch_balancerWrTrrrh)rBr_r\rresponsers rDrzbingx.load_balance_snapshots++VTN;;;;;;;;![[4??4 > >!CCEEEEEEEEH(,(8(8;(O(ODL %48DL0 1 JJ+T-G P P P P P ? >rEcK |dkr|dd{VdS||d}||d}|||dd{VdS#t$rM}t|jdz||z}||Yd}~dSd}~wwxYw)NPingPongpingr)pongrz pong failed with error )sendrcr rrKr r)rBr_rir#rrrs rDr$z bingx.pongs" &  kk&)))))))))))''88''88kk  ##    +E!E RS !TUUE LL          s!A3A A33 C =ACC cd|v}||ddi}|j0||jdd}t ||_|j}||}|||d}d} d} |r| n| } ||| ||| d z|zdS) NrNrar ordersLimitrrFrrr) safe_value_2rrr=r parse_orderrrh) rBr_rirrarr parsedOrderrFrrr\s rD handle_orderzbingx.handle_ordersh'  &#r:: ; %%dlM4HHE077DK&&t,,  k"""X&#)8hh v{+++v{S069:::::rEcd|v}||ddi}|j}|2||jdd}t |}||_||}|d}d} d} |r| n| } ||||| ||| d z|zdS) NrNrarrrrFrrr)r(myTradesrr=rrrrh) rBr_rirresult cachedTradesrrrFrrr\s rDhandle_my_tradeszbingx.handle_my_tradesisr'""7FC<<}  %%dlM4HHE1%88L(DM!!&))!"""(6hhh F###|[111|[3%6%?@@@@@rEc||di}||dg}||dd}d|vrdnd}||j|d<||j|d <|||j|d <t d t |D]}||}||d} || } | |j|vr|j|| n|} ||d | d <||d} | d,tj || d| | d<| |j|| <| |j||j|<| |j||dzdS)Nr~rxrEPr rrrqrrrwbfreebcusedr) rTsafe_integer_2rrrrrcsafe_currency_codeaccountr string_sub safe_balancerh) rBr_rir~rarqrrr currencyIdrr: balanceChanges rDhandle_balancezbingx.handle_balancesJ OOGS" - -q#r**''c:: ((vv%) T6"*3 T;')-i)@)@ T:&q#d))$$ / /A1gG))'377J**:66D374<;M3M3Mdl4(..TXT`T`TbTbG"..w==GFO ,,Wd;;Mv*")"4T5E5Egv5V5VXe"f"f'.DL t $ $!..t|D/ABB Tt|D)4*+<=====rEc*|||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|||dSdS)Nr!r#rNrrrLrz@klineexecutionReportraxTRADErrORDER_TRADE_UPDATErXFILLED 24hTicker) rrr$rcrdrrmrrrTr0r+r?) rBr_rirNrarrstatusmsgDatamsgEvents rDhandle_messagezbingx.handle_messages((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 $ $ $   fg . . .??7C44D##D#..D%%dC00Ff&8&8%%fg666//'622##GS11 { " "   vw / / / / / # "rE)N)(__name__ __module__ __qualname__rArr r^r rmrfrrr rrr rrrrrrrr rrrrrrrrrrr$r+r0r?rL __classcell__)rCs@rDrrs> > > > > @68\\\F\\\\0A,FA,A,A,A,F0000d<@d[]SSSSSSbfglbmSSSS>>&24MMMM0)+QQQQ   0a;a;a;FGAvGAGAGAGAR7>V7>7>7>7>r(0V(0(0(0(0(0(0(0(0rEr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrrccxt.base.preciser async_supportrrErDr[s ffffffffffOOOOOOOOOOOOOOOOOO444444''''''))))))%%%%%%C0C0C0C0C0D  $C0C0C0C0C0rE