iddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)IntOrder OrderBookStrTickerTrade)Client)List) ExchangeErrorc eZdZfdZdZdddifdedededeefd Z dddifdedededeefd Z d Z ifde fd Z ifdede fd ZdZd dZddifdedededeefdZddifdedededeefdZdZd dZdddifdedededeefdZdZd dZdZdifdededefdZdifdededefdZdZdZ de!fdZ"dZ#ifdZ$xZ%S)!lbankc|tt|dddddddddddddd dddiiddd d d d d dddddd iiiidS)NTF) ws fetchOHLCVWsfetchOrderBookWs fetchTickerWs fetchTradesWs watchBalance watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVapirzwss://www.lbkex.net/ws/V2/r timeframes1min5min15min30min1hr4hrdayweekmonthyear) 1m5m15m30m1h4h1d1w1M1y)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s T/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/lbank.pyr<zlbank.describeseT 2 2 ; ; = = $$(!%!% %# %#!&#"&" 6  $$&&###$%$ # #  O)@ )@ ) ) ) c~||jdd}||d}||jd<|S)N requestIdr) safe_integerr7sum)r= previousValuenewValues r? request_idzlbank.request_id=s?))$, QGG 88M1--$, [!r@r+NsymbolsincelimitreturncrK|d{V||}|jdd}||jdi}||di} || ||} d|dzdz| z} d d | |d d } |:|ttj |d z | d<||| d<| | |} | }| || | || d{VS)a :see: 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 Nrrrr fetchOHLCV:rI:requestkbarid)actionrPrQpairstartsize) load_marketsmarketr6 safe_valuer7 safe_string parse_to_intintmathfloorr:rHwatch)r=rI timeframerJrKparamsrYurlwatchOHLCVOptionsr timeframeId messageHashmessagerPrBs r?fetch_ohlcv_wszlbank.fetch_ohlcv_wsCs]!!!!!!!!!V$$it$ OODL,KK__%6 bII &&z9iHH #fX&66<{J 4L     #00TZ 5M5M1N1NOOGG   #GFO""7F33OO%% ZZ['9gNNNNNNNNNr@c.K|d{V||}||jdi}||di}||||} d|dzdz| z} |jdd} d d | |d d } || |} || | | | d{V}|jr| ||}| |||d dS)a :see: 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 Nrr ohlcv:rIrOrr subscriberQrR)rSrkrQrTrT) rXrYrZr7r[r6r:r` newUpdatesgetLimitfilter_by_since_limit)r=rIrarJrKrbrYrdr rerfrcrkrPohlcvs r? watch_ohlcvzlbank.watch_ohlcvcsA!!!!!!!!!V$$ OODL,KK__%6 bII &&z9iHH !11C7+E it$!4L   ""9f55jjk7KHHHHHHHH ? 2NN6511E))%q$GGGr@c ||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)NrT_rr recordsrrCrQ OHLCVLimitrUrNrOslottohlcvrj) r[ safe_symbolrZr7rD safe_numberfind_timeframeohlcvsrappendresolve parse8601)r=clientrgmarketIdrIrdr rsrawOHLCVparsedrerastoredrKrfdatetimes r? 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<` Nrr fetchTicker:rIrPtickrR)rSrPrTrXrYr6r:rHr`) r=rIrbrYrcrfrgrPrBs r?fetch_ticker_wszlbank.fetch_ticker_wss!!!!!!!!!V$$it$$vh'77 4L   ""7F33OO%% ZZ['9gNNNNNNNNNr@c"K|d{V||}|jdd}d|dz}dd|dd }|||}||||||d{VS) a :see: 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 ` Nrrticker:rIrkrrRrSrkrT)rXrYr6r:r`)r=rIrbrYrcrfrgrPs r? watch_tickerzlbank.watch_tickers!!!!!!!!!V$$it$&"22 !4L   ""7F33ZZ[';PPPPPPPPPr@c2||d}||}||}|||}||j|<d|z}|||d|z}|||dS)NrTrr)r[r safe_marketparse_ws_tickertickersr)r=rrgrrIrY parsedTickerrfs r? handle_tickerzlbank.handle_tickers,##GV44!!(++!!(++++GV<< + V&( |[111$v- |[11111r@cf||d}|||}||d}||d}|id|d||d|d||dd||dd dd dd dd dd dddddd||dddddd||ddd||d||d|d|S)NrTTSrrI timestamprhighlowbid bidVolumeask askVolumevwapopencloselastlatest previousClosechange percentageaveragevolturnover) baseVolume quoteVolumeinfo)r[rrZ safe_tickerr)r=tickerrYrrIr tickerDatas r?rzlbank.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)! ! ! * + r@cTK|d{V||}|jdd}d|dz}|d}dd|d |d }|||} |} |||| | | d{VS) a< get the list of most recent trades for a particular symbol :see: 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 ` Nrr fetchTrades:rI rPtraderR)rSrPrTrWr) r=rIrJrKrbrYrcrfrgrPrBs r?fetch_trades_wszlbank.fetch_trades_ws`s!!!!!!!!!V$$it$$vh'77 =E4L    ""7F33OO%% ZZ['9gNNNNNNNNNr@cTK|d{V||}|jdd}d|dz}dd|dd }|||} |||| || d{V} || ||d d S) a# :see: 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 ` Nrrtrades:rIrkrrRrrT)rXrYr6r:r`rn) r=rIrJrKrbrYrcrfrgrPtradess r? watch_tradeszlbank.watch_tradeszs!!!!!!!!!V$$it$&"22 ! 4L   ""7F33zz#{G['RRRRRRRR))&% TRRRr@c||d}||}||}||j|}|5||jdd}t|}||j|<||d}||d|g} tdt| D]8} | | | |} || d<| | 9||j|<d|z} | |j|| d |z} | |j|| dS) NrT tradesLimitrUrrrrIrr) r[rrrZrrDr7rrangelenparse_ws_traderr) r=rrgrrIrYrrKrawTrade rawTradesirrfs r? 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*K88888r@c||d}|||n||d}|||}||dd}|dd}|||ddddd|||dd||d d ||d d|d |S) Nrr directionru_marketpricerCvolumertamount) rrrIrRordertype takerOrMakersiderrcostfeer)rDiso8601r[r safe_string_2replace safe_trade)r=rrYrrrs r?rzlbank.parse_ws_trades%%eQ// 1:1FDLL+++dN^N^_dfjNkNk  x00I!!%a88||Ir**"  ''w::((!<<$$UH55    r@cK|d{V||d{V}|jdd}d}d}|d}n=||} ||}d| dz}| d}d d ||d } || |} |||| || d{V} || |||d S) ax :see: https://github.com/LBank-exchange/lbank-official-api-docs/blob/master/API-For-Spot-EN/WebSocket%20API(Asset%20%26%20Order).md#websocketsubscribeunsubscribe 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 ` Nrrallz orders:allorders:rIrRrk orderUpdate)rSrk subscribeKeyrTT)rX authenticater6rYrIr:r`filter_by_symbol_since_limit) r=rIrJrKrbkeyrcrfrTrYrgrPorderss r? watch_orderszlbank.watch_orderss(!!!!!!!!!%%f--------it$  >&KK[[((F[[((F#fX&66K$` indexed by market symbols NrrfetchOrderbook:rIdrPdepthrR)rSrPrrT)rXrYr6r:r`rK r=rIrKrbrYrcrfrkrP orderbooks r?fetch_order_book_wszlbank.fetch_order_book_wss!!!!!!!!!V$$it$'&*:: =E4L   ""9f55**S+w LLLLLLLL    r@c~K|d{V||}|jdd}d|dz}||d}|d}dd ||d d }|||}|||||d{V} | S) a :see: https://www.lbank.com/en-US/docs/index.html#market-depth :see: https://www.lbank.com/en-US/docs/index.html#market-increment-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 Nrr orderbook:rI aggregationr rkrrR)rSrkrrT)rXrYr6omitr:r`rKrs r?watch_order_bookzlbank.watch_order_books!!!!!!!!!V$$it$"VH%55 6=11 =E! 4L   ""9f55**S+w LLLLLLLL    r@c ||d}||}||d|}||d}||}||j|}||i}||j|<||||dd} || d|z} ||| d|z} ||| dS)NrTrrbidsasksrr ) r[rrZr orderbooks order_bookparse_order_bookresetr) r=rrgrrI orderBookrrrsnapshotrfs r?handle_order_bookzlbank.handle_order_booksr##GV44!!(++OOGWg>> ##GT22NN8,, OODOV<<  ++I&/DOF #((FIvvVV!!!"V+ y+...'&0 y+.....r@c||dd}t|jdz|z}||dS)Nrgr )r[rrRreject)r=rrgerrMsgerrors r?handle_error_messagezlbank.handle_error_messagesK!!'9b99dgmf455 er@rcrK||d}|d|dd{VdS)Npingpong)rSr))r[send)r=rrgpingIds r? handle_pingzlbank.handle_ping sk!!'622kk             r@cr||d}|dkr|||dS||dd}|dkr||j||dS|j|j|j|j|j d}| ||}||||dSdS)Nrr%rrSr()rQrrrr) r[r&rspawnr,rr rrrrZ)r=rrgrrhandlershandlers r?handle_messagezlbank.handle_messages!!'844 W    % %fg 6 6 6 F!!'68<< 6>> JJt' 9 9 9 F%+'&-   //(D11   GFG $ $ $ $ $  r@cjK|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)Nrr authenticatedresultTz failed to get subscribe keydataiZ2)rexpiresr6rrrtruez# failed to refresh the SubscribeKey subscriptions)r6r millisecondsrZr8check_required_credentialsspotPrivatePostSubscribeGetKeyrrRr[rErD"spotPrivatePostSubscribeRefreshKeyextend) r=rbrcrnowrfr3responser4r6rPs r?rzlbank.authenticate(sit$S!!!!% (s@r?rrs* * * * * X ;?T`dmoOO3OsOZ]Otxy}t~OOOO@8<$]ajlHHHCHWZHquvzq{HHHHrOs ffffffffff EEEEEEEEEEEEEEEE444444******| <| <| <| <|