":hddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZGddej*j,Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyIntOrder OrderBookStrTickerTrade)Client)List) ExchangeErrorc eZdZdeffd ZdZdddifdedededee fd Z dddifdedededee fd Z d Z ifdede fd Zifdede fd ZdZd dZddifdedededeefdZddifdedededeefdZdZd dZdddifdedededeefdZdZd dZdZdifdededefdZdifdededefdZdZ dZ!de"fdZ#dZ$ifdZ%xZ&S)!lbankreturnc|jtt|ddddddddddddddddddiiddd d d d d dddddd iiiidS)NTF)ws fetchOHLCVWsfetchOrderBookWs fetchTickerWs fetchTradesWs watchBalance watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOrderswatchOrderBook watchOHLCVapirzwss://www.lbkex.net/ws/V2/r! timeframes1min5min15min30min1hr4hrdayweekmonthyear) 1m5m15m30m1h4h1d1w1M1y)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s H/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/lbank.pyr?zlbank.describeseT ; = $$(!%!% %# %#).!&#"&""6  $$&&###$%$ #  Q*@ * * c|j|jdd}|j|d}||jd<|S)N requestIdr) safe_integerr:sum)r@ previousValuenewValues rB request_idzlbank.request_id>s=))$,, QG 88M1-$, [!rCr.Nsymbolsincelimitc4K|jd{|j|}|jdd}|j|jdi}|j|di} |j | ||} d|dzdz| z} d d | |d d } |3|j ttj|d z | d<||| d<|j| |} |j}|j|| | || d{S77w)a https://www.lbank.com/en-US/docs/index.html#request-amp-subscription-instruction watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 Nr"rr!r# fetchOHLCV:rL:requestkbarid)actionrRrSpairstartsize) load_marketsmarketr9 safe_valuer: safe_string parse_to_intintmathfloorr=rKwatch)r@rL timeframerMrNparamsr[urlwatchOHLCVOptionsr# timeframeId messageHashmessagerRrEs rBfetch_ohlcv_wszlbank.fetch_ohlcv_wsDs+!!!V$iit$ OODLL,K__%6 bI &&z9iH #fX&66<{J 4L    #00TZZ 5M1NOGG   #GFO""7F3OO% ZZ['9gNNN' "&Os"DDC8DDDDcK|jd{|j|}|j|jdi}|j|di}|j |||} d|dzdz| z} |j dd} d d | |d d } |j | |} |j| | | | d{}|jr|j||}|j|||d dS779w)a https://www.lbank.com/en-US/docs/index.html#subscription-of-k-line-data watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 Nr!r#ohlcv:rLrQr"r subscriberSrT)rUrmrSrVrT) rZr[r\r:r]r9r=rb newUpdatesgetLimitfilter_by_since_limit)r@rLrcrMrNrdr[rfr#rgrhrermrRohlcvs rB watch_ohlcvzlbank.watch_ohlcvfs!!!V$ OODLL,K__%6 bI &&z9iH !11C7+E iit$!4L  ""9f5jjk7KHH ??NN651E))%q$GG# "Is"C>C:B+C>C<8C><C>c D|j|d}|j|dd}|j|jdi}|j|di}|j|d}|S|j|dg}|j |d|j |d|j |d|j |d |j |d |j |d g} |j|d } |j | |} |j|j|i|j|<|j|j|| } | :|j |jd d} t| } | |j|| <| j| d|zdz| z}|j| |y|j|d i}|j|d} |j|d}|j||j |d|j |d|j |d|j |d|j |dg} |j | |} |j|j|i|j|<|j|j|| } | :|j |jd d} t| } | |j|| <| j| d|zdz| z}|j| |y)NrV_r!r#recordsrrFrS OHLCVLimitrWrPrQslottohlcvrl) r] safe_symbolr\r:rG safe_numberfind_timeframeohlcvsrappendresolve parse8601)r@clientrimarketIdrLrfr#rurawOHLCVparsedrgrcstoredrNrhdatetimes rB handle_ohlcvzlbank.handle_ohlcvsh##GV4!!(D#6 OODLL,K__%6 bI //'95  w26H!!(A.  1-  1-  1-  1-  1- F**7F;K++KDI"&//$++vr"JDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !'&036DK NN6; /w;H**8V` Nr"r fetchTicker:rLrRtickrT)rUrRrVrZr[r9r=rKrb) r@rLrdr[rerhrirRrEs rBfetch_ticker_wszlbank.fetch_ticker_wss!!!V$iit$$vh'77 4L  ""7F3OO% ZZ['9gNNN "Os"BBA2B B BBcK|jd{|j|}|jdd}d|dz}dd|dd }|j||}|j |||||d{S7g7w) a https://www.lbank.com/en-US/docs/index.html#market watches 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 lbank api endpoint :returns dict: a `ticker structure ` Nr"rticker:rLrmrrTrUrmrV)rZr[r9r=rb)r@rLrdr[rerhrirRs rB watch_tickerzlbank.watch_tickers!!!V$iit$&"22 !4L  ""7F3ZZ[';PPP "Qs"BA>A"B9B:BBc |j|d}|j|}|j|}|j||}||j|<d|z}|j ||d|z}|j ||y)NrVrr)r]r safe_marketparse_ws_tickertickersr)r@rrirrLr[ parsedTickerrhs rB handle_tickerzlbank.handle_tickers,##GV4!!(+!!(+++GV< + V&( |[1$v- |[1rCc|j|d}|j||}|j|d}|j|d}|jid|d|j |d|d|j|dd|j|dd dd dd dd dd dddddd|j|dddddd|j|ddd|j|d|j|d|d|S)NrVTSrrL timestamprhighlowbid bidVolumeask askVolumevwapopencloselastlatest previousClosechange percentageaveragevolturnover) baseVolume quoteVolumeinfo)r]rr\ safe_tickerr)r@tickerr[rrLr tickerDatas rBrzlbank.parse_ws_ticker8s,##FF3!!(F3##FD1__VV4 ! f! 1!  !  D$$Z8 ! 4##J6 ! 4 !  !  4!  !  D!  D!  T!  D$$Z:!  T!  d! $**:x@!! " t#! $**:u=++J C)! * + rCc2K|jd{|j|}|jdd}d|dz}|d}dd|d |d }|j||} |j } |j ||| | | d{S7|7w) a8 get the list of most recent trades for a particular symbol https://www.lbank.com/en-US/docs/index.html#request-amp-subscription-instruction :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 :returns Trade[]: a list of `trade structures ` Nr"r fetchTrades:rL rRtraderT)rUrRrVrYr) r@rLrMrNrdr[rerhrirRrEs rBfetch_trades_wszlbank.fetch_trades_wsis!!!V$iit$$vh'77 =E4L   ""7F3OO% ZZ['9gNNN "Os"BBA7BBBBc2K|jd{|j|}|jdd}d|dz}dd|dd }|j||} |j ||| || d{} |j | ||d d S7|7w) a https://www.lbank.com/en-US/docs/index.html#trade-record get the list of most recent trades for a particular symbol :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 :returns dict[]: a list of `trade structures ` Nr"rtrades:rLrmrrTrrT)rZr[r9r=rbrp) r@rLrMrNrdr[rerhrirRtradess rB watch_tradeszlbank.watch_tradess!!!V$iit$&"22 ! 4L  ""7F3zz#{G['RR))&% TRR "Ss"BBA"B9B:BBc|j|d}|j|}|j|}|j|j|}|7|j |j dd}t|}||j|<|j|d}|j|d|g} tdt| D]-} |j| | |} || d<|j| /||j|<d|z} |j|j|| d |z} |j|j|| y) NrV tradesLimitrWrrrrLrr) r]rrr\rrGr:rrangelenparse_ws_traderr) r@rrirrLr[rrNrawTrade rawTradesirrhs rB handle_tradeszlbank.handle_tradess:6##GV4!!(+!!(+f5 >%%dllM4HE&F"(DKK ??7G4OOGXzB q#i.) !A'' ! f=E$E(O MM%  !% F&( t{{6*K8$v- t{{6*K8rCc|j|d}||j|n|j|d}||j|}|j |dd}|j d}|j|d}|j|d}|} ||dk(r | dk(rd nd} |j ||ddddd| |j |d d|j |d d |j|d d|d |S)Nrr directionrwrtrFmakerbuysellpricevolumervamount) rrrLrTordertype takerOrMakersiderrcostfeer)rGiso8601r]r safe_string_2split safe_trade) r@rr[rrrawSideparts firstPart secondPartrs rBrzlbank.parse_ws_trades %%eQ/ 1:1FDLL+dN^N^_dfjNk  x0I$$UK; c"$$UA. %%eQ/   !jG&;"em6%D"  ''w:((!<$$UH5   rCcK|jd{|j|d{}|jdd}d}d}|d}n/|j|} |j |}d| dz}| d}d d ||d } |j | |} |j ||| || d{} |j| |||d S777w) a https://www.lbank.com/en-US/docs/index.html#update-subscribed-orders get the list of trades associated with the user :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 lbank api endpoint :returns dict[]: a list of `trade structures ` Nr"rallz orders:allorders:rLrTrm orderUpdate)rUrm subscribeKeyrVT)rZ authenticater9r[rLr=rbfilter_by_symbol_since_limit) r@rLrMrNrdkeyrerhrVr[rirRorderss rB watch_orderszlbank.watch_orderss!!!%%f--iit$  >&K[[(F[[(F#fX&66K$` indexed by market symbols Nr"rfetchOrderbook:rLdrRdepthrT)rUrRrrV)rZr[r9r=rbrN r@rLrNrdr[rerhrmrR orderbooks rBfetch_order_book_wszlbank.fetch_order_book_wss!!!V$iit$'&*:: =E4L  ""9f5**S+w LL    "Ms"BBA&B=B>BBcTK|jd{|j|}|jdd}d|dz}|j|d}|d}dd ||d d }|j ||}|j ||||d{} | j S77w) aD https://www.lbank.com/en-US/docs/index.html#market-depth watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified symbol of the market to fetch the order book for :param int|None limit: the maximum amount of order book entries to return :param dict params: extra parameters specific to the lbank api endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr"r orderbook:rL aggregationrrmrrT)rUrmrrV)rZr[r9omitr=rbrNrs rBwatch_order_bookzlbank.watch_order_books!!!V$iit$"VH%55 6=1 =E! 4L  ""9f5**S+w LL    "Ms"B(B$A8B(B&B(&B(c|j|d}|j|}|j|d|}|j|d}|j|}||jvr|j i|j|<|j|}|j |||dd} |j| d|z} |j|| d|z} |j|| y)NrVrrbidsasksrr) r]rr\r orderbooks order_bookparse_order_bookresetr) r@rrirrL orderBookrrrsnapshotrhs rBhandle_order_bookzlbank.handle_order_booksr##GV4!!(+OOGWg> ##GT2NN8, $//)&*oob&9DOOF #OOF+ ((FIvvV!"V+ y+.'&0 y+.rCc|j|dd}t|jdz|z}|j|y)Nrir )r]rrTreject)r@rrierrMsgerrors rBhandle_error_messagezlbank.handle_error_messages;!!'9b9dggmf45 erCrcK|j|d} |jd|dd{y7#t$r}|j||Yd}~yd}~wwxYww)Npingpong)rUr.)r]send Exceptionon_error)r@rripingIdes rB handle_pingzlbank.handle_ping"sb!!'62 %++    % MM&! $ $ %s6A535A5 AAAAAct|j|d}|dk(r|j||y|j|dd}|dk(r|j|j||y|j |j |j|j|jd}|j||}| |||yy)Nrr*rrUr-)rSrrrr) r]r+rspawnr4rr%rrrr\)r@rrirrhandlershandlers rBhandle_messagezlbank.handle_message/s!!'84 W   % %fg 6 !!'68< 6> JJt'' 9 %%++''&&--  //(D1   FG $ rCcK|jdd}|j|}|j}d}|j|j|}||j |j |d{}|j|d}|durt|jdz|j|d|j|dd |jd<n|j|d d } | |krzd |d i} |j|j| |d{}|j|d}|dk7rt|jdz|j|d|ddd <|jdd S7 7cw)Nr"r authenticatedresultTz failed to get subscribe keydataiZ2)rexpiresr>rrrtruez# failed to refresh the SubscribeKey subscriptions)r9r millisecondsr\r@check_required_credentialsspotPrivatePostSubscribeGetKeyrrTr]rHrG"spotPrivatePostSubscribeRefreshKeyextend) r@rdrernowrhr;responser<r>rRs rBrzlbank.authenticateCsiit$S!!% (<(rWs? ff JJJ4*W