ei~ddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesIntOrder OrderBookStrTickerTrade)Client)List) ExchangeErrorc eZdZdeffd ZdZdddifdededed edee f d Z dddifdededed edee f d Z d Z ifdede fd Zifdede fdZdZd#dZddifdeded edeefdZddifdeded edeefdZdZd#dZdddifdeded edeefdZdZd#dZdZifdefdZdefdZ difded ede!fdZ"difded ede!fdZ#dZ$dZ%defd Z&d!Z'ifd"Z(xZ)S)$lbankreturnc|tt|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 L/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/lbank.pyr@zlbank.describeseT 2 2 ; ; = = $$(!%!% $# %#).!&#"&""6  $$&&###$%$ # #  Q*@ *@ * * * c|||jdd}||d}||jd<||S)N requestIdr)lock_id safe_integerr;sum unlock_id)rA previousValuenewValues rC request_idzlbank.request_id>s\ ))$, QGG 88M1--$, [! rDr/Nsymbol timeframesincelimitcrK|d{V||}|jdd}||jdi}||di} || ||} d|dzdz| z} d d | |d d } |:|ttj |d z | d<||| d<| | |} | }| || | || d{VS)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:rO:requestkbarid)actionrVrWpairstartsize) load_marketsmarketr: safe_valuer; safe_string parse_to_intintmathfloorr>rNwatch)rArOrPrQrRparamsr_urlwatchOHLCVOptionsr$ timeframeId messageHashmessagerVrFs rCfetch_ohlcv_wszlbank.fetch_ohlcv_wsFs]!!!!!!!!!V$$it$ OODL,KK__%6 bII &&z9iHH #fX&66<{J 4L     #00TZ 5M5M1N1NOOGG   #GFO""7F33OO%% ZZ['9gNNNNNNNNNrDc.K|d{V||}||jdi}||di}||||} d|dzdz| z} |jdd} d d | |d d } || |} || | | | d{V}|jr| ||}| |||d dS)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:rOrUr#r subscriberWrX)rYrprWrZrT) r^r_r`r;rar:r>rf newUpdatesgetLimitfilter_by_since_limit)rArOrPrQrRrgr_rir$rjrkrhrprVohlcvs rC watch_ohlcvzlbank.watch_ohlcvhsA!!!!!!!!!V$$ OODL,KK__%6 bII &&z9iHH !11C7+E it$!4L   ""9f55jjk7KHHHHHHHH ? 2NN6511E))%q$GGGrDc ||d}||dd}||jdi}||di}||d}|}||dg}||d||d||d||d ||d ||d g} ||d } || |} ||j|i|j|<||j|| } | ;||jd d} t| } | |j|| <| | d|zdz| z}| | |dS||d i}||d} ||d}| |||d||d||d||d||dg} || |} ||j|i|j|<||j|| } | ;||jd d} t| } | |j|| <| | d|zdz| z}| | |dS)NrZ_r"r$recordsrrGrW OHLCVLimitr[rTrUslottohlcvro) ra safe_symbolr`r;rI safe_numberfind_timeframeohlcvsrappendresolve parse8601)rAclientrlmarketIdrOrir$rxrawOHLCVparsedrjrPstoredrRrkdatetimes rC handle_ohlcvzlbank.handle_ohlcvseh##GV44!!(D#66 OODL,KK__%6 bII //'955  w266H!!(A..  1--  1--  1--  1--  1-- F**7F;;K++KDDI"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! !'&036DK NN6; / / / / /w;;H**8V<` Nr#r fetchTicker:rOrVtickrX)rYrVrZr^r_r:r>rNrf) rArOrgr_rhrkrlrVrFs rCfetch_ticker_wszlbank.fetch_ticker_wss!!!!!!!!!V$$it$$vh'77 4L   ""7F33OO%% ZZ['9gNNNNNNNNNrDc"K|d{V||}|jdd}d|dz}dd|dd }|||}||||||d{VS) 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:rOrprrXrYrprZ)r^r_r:r>rf)rArOrgr_rhrkrlrVs rC watch_tickerzlbank.watch_tickers!!!!!!!!!V$$it$&"22 !4L   ""7F33ZZ[';PPPPPPPPPrDc2||d}||}||}|||}||j|<d|z}|||d|z}|||dS)NrZrr)rar safe_marketparse_ws_tickertickersr)rArrlrrOr_ parsedTickerrks rC handle_tickerzlbank.handle_tickers,##GV44!!(++!!(++++GV<< + V&( |[111$v- |[11111rDcf||d}|||}||d}||d}|id|d||d|d||dd||dd dd dd dd dd dddddd||dddddd||ddd||d||d|d|S)NrZTSrrO timestamprhighlowbid bidVolumeask askVolumevwapopencloselastlatest previousClosechange percentageaveragevolturnover) baseVolume quoteVolumeinfo)rarr` safe_tickerr)rAtickerr_rrOr tickerDatas rCrzlbank.parse_ws_ticker:s,##FF33!!(F33##FD11__VV44 ! f! 11!  !  D$$Z88 ! 4##J66 ! 4 !  !  4!  !  D!  D!  T!  D$$Z::!  T!  d! $**:x@@!! " t#! $**:u==++J CC)! ! ! * + rDcTK|d{V||}|jdd}d|dz}|d}dd|d |d }|||} |} |||| | | d{VS) a6 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:rO rVtraderX)rYrVrZr]r) rArOrQrRrgr_rhrkrlrVrFs rCfetch_trades_wszlbank.fetch_trades_wsks!!!!!!!!!V$$it$$vh'77 =E4L    ""7F33OO%% ZZ['9gNNNNNNNNNrDcK|d{V||}|jdd}d|dz}dd|dd }|||} |||| || d{V} || ||d d } || d S) 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:rOrprrXrrT)r^r_r:r>rfrssort_by) rArOrQrRrgr_rhrkrlrVtradesresults rC watch_tradeszlbank.watch_tradess!!!!!!!!!V$$it$&"22 ! 4L   ""7F33zz#{G['RRRRRRRR++FE5+tTT||FK000rDc||d}||}||}||j|}|5||jdd}t|}||j|<||d}||d|g} tdt| D]8} | | | |} || d<| | 9||j|<d|z} | |j|| d |z} | |j|| dS) NrZ tradesLimitr[rrrrOrr) rarrr`rrIr;rrangelenparse_ws_traderr) rArrlrrOr_rrRrawTrade rawTradesirrks rC handle_tradeszlbank.handle_tradessg6##GV44!!(++!!(++f55 >%%dlM4HHE&&F"(DK ??7G44OOGXzBB q#i..)) ! !A'' ! f==E$E(O MM% $ F&( t{6*K888$v- t{6*K88888rDcR||d}|||n||d}|||}||dd}|d}||d}||d}|} ||dkr | dkrd nd} |||ddddd| ||d d||d d ||d d|d |S)Nrr directionrzrwrGmakerbuysellpricevolumeryamount) rrrOrXordertype takerOrMakersiderrcostfeer)rIiso8601rar safe_string_2split safe_trade) rArr_rrrawSideparts firstPart secondPartrs rCrzlbank.parse_ws_tradesU%%eQ// 1:1FDLL+++dN^N^_dfjNkNk  x00I$$UK;; c""$$UA.. %%eQ//   !jG&;&;"emm66%D"  ''w::((!<<$$UH55    rDcK|d{V||d{V}|jdd}d}d}|d}n=||} ||}d| dz}| d}d d ||d } || |} |||| || d{V} || |||d S) 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:rOrXrp orderUpdate)rYrp subscribeKeyrZT)r^ authenticater:r_rOr>rffilter_by_symbol_since_limit) rArOrQrRrgkeyrhrkrZr_rlrVorderss rC watch_orderszlbank.watch_orderss(!!!!!!!!!%%f--------it$  >&KK[[((F[[((F#fX&66K$` Nr#rbalancerp assetUpdate)rYrpr)r^rr:r>rf)rArgrrhrkrlrVs rC watch_balancezlbank.watch_balances!!!!!!!!!%%f--------it$ !&   ""7F33ZZ[';PPPPPPPPPrDrc||di}|||d}||}||jd<||jd<||jd<||d}||}|}||d|d<||d|d <||d |d <||j|<||j|_||jd dS) Ndatarrrr assetCodefreefreezeusedassettotalr) safe_dictrrarrsafe_currency_codeaccount safe_balancer) rArrlrrr currencyIdcoder#s rChandle_balancezlbank.handle_balances/ ~~gvr22NN4#3#3GT#B#BCC << **# V$- [!#+ Z %%dK88 &&z22,,..**488**4::++D'::$ T((66 t|Y/////rDcRK|d{V||}|jdd}d|dz}|d}dd||d d }|||}|||||d{V} | S) a\ https://www.lbank.com/en-US/docs/index.html#request-amp-subscription-instruction 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#rfetchOrderbook:rOdrVdepthrX)rYrVr+rZ)r^r_r:r>rfrR rArOrRrgr_rhrkrprV orderbooks rCfetch_order_book_wszlbank.fetch_order_book_wss!!!!!!!!!V$$it$'&*:: =E4L   ""9f55**S+w LLLLLLLL    rDc~K|d{V||}|jdd}d|dz}||d}|d}dd ||d d }|||}|||||d{V} | S) 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:rO aggregationr*rpr+rX)rYrpr+rZ)r^r_r:omitr>rfrRr,s rCwatch_order_bookzlbank.watch_order_books!!!!!!!!!V$$it$"VH%55 6=11 =E! 4L   ""9f55**S+w LLLLLLLL    rDc||d}||}||d|}||d}||}||jvr|i|j|<|j|}||||dd} || d|z} ||| d|z} ||| dS)NrZr+rbidsasksr0r)) rarr`r orderbooks order_bookparse_order_bookresetr) rArrlrrO orderBookrrr-snapshotrks rChandle_order_bookzlbank.handle_order_booksr##GV44!!(++OOGWg>> ##GT22NN8,, $/))&*oob&9&9DOF #OF+ ((FIvvVV!!!"V+ y+...'&0 y+.....rDc||dd}t|jdz|z}||dS)Nrlr )rarrXreject)rArrlerrMsgerrors rChandle_error_messagezlbank.handle_error_messageMsK!!'9b99dgmf455 erDcK||d} |d|dd{VdS#t$r!}|||Yd}~dSd}~wwxYw)Npingpong)rYrF)rasend Exceptionon_error)rArrlpingIdes rC handle_pingzlbank.handle_pingZs!!'622 %++           % % % MM&! $ $ $ $ $ $ $ $ $ %s: A%A  A%c~||d}|dkr|||dS||dd}|dkr||j||dS|j|j|j|j|j |j d}| ||}||||dSdS)NrrBrrYrE)rWr+rrrr) rarCrspawnrLrr=rrrr'r`)rArrlrrhandlershandlers rChandle_messagezlbank.handle_messagegs!!'844 W    % %fg 6 6 6 F!!'68<< 6>> JJt' 9 9 9 F%+'&-.   //(D11   GFG $ $ $ $ $  rDcjK|jdd}||}|}d}||j|}||||d{V}||d}|durt|jdz| |d| |dd |jd<n| |d d } | |krd |d i} | | | |d{V}| |d}|dkrt|jdz| |d|ddd <|jdd S)Nr#r authenticatedrTz failed to get subscribe keyriZ2)rexpiresrTrrrtruez# failed to refresh the SubscribeKey subscriptions)r:r millisecondsr`rVcheck_required_credentialsspotPrivatePostSubscribeGetKeyrrXrarJrI"spotPrivatePostSubscribeRefreshKeyextend) rArgrhrnowrkrSresponserrTrVs rCrzlbank.authenticate|sit$S!!!!% (rms ffffffffff TTTTTTTTTTTTTTTTTTTT444444******P<P<P<P<P