i<0zddlZddlmZddlmZmZmZmZddl m Z ddl m Z Gddej jZdS)N) ArrayCache) IndexTypeInt OrderBookTrade)Client)Listc eZdZfdZddifdedededeefdZde fd Z ddefd Z difdedede fd Z de fd ZddedededefdZddededefdZddededefdZdZde fdZxZS)lunoc |tt|ddddddddddddiidiiiidS) NTF)ws watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVapir zwss://ws.luno.com/api/1sequenceNumbers)hasurlsoptions streaming exceptions) deep_extendsuperr describe)self __class__s S/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/luno.pyrz luno.describesdD 1 1 : : < <$ %#!&#"&#  3 "2+? ?    NsymbolsincelimitreturncK||d{V||}|d}d|dz}d|i}|jdd|z}d|z} |j|jd} || |} ||| | ||d{V} |jr| ||}| | ||d d S) a& get the list of most recent trades for a particular symbol :see: https://www.luno.com/en/developers/api#tag/Streaming-API :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#/stream/idrr trades: api_key_idapi_key_secret timestampT) check_required_credentials load_marketsmarketrapiKeysecretrwatch newUpdatesgetLimitfilter_by_since_limit) rr#r$r%paramsr1subscriptionHash subscriptionurl messageHash subscriberequesttradess r! watch_tradeszluno.watch_trades)s% '')))!!!!!!!!!V$$!%t 4 &) it$'77&( +"k  ""9f55zz#{G=M|\\\\\\\\ ? 3OOFE22E))&% TRRRr"clientcF||dg}t|}|dkrdS|d}||}d|z}||j|} | 5||jdd} t | } | |j|<tdt|D]5} || } || |} | | 6| |j|<| |j||dS)N trade_updatesrr#r* tradesLimiti) safe_valuelenr1r? safe_integerrrrange parse_tradeappendresolve)rrAmessager: rawTradeslengthr#r1r<storedr%irawTradetrades r! handle_tradeszluno.handle_tradesEs" OOG_bAA Y Q;; Fh'V$$&( f55 >%%dlM4HHE&&F"(DK q#i..)) ! !A |H$$Xv66E MM% $ Ft{6*K88888r"c||ddd|dddddd||d||ddd |S)Nr#basecounter) infor)r.datetimer#ordertypeside takerOrMakerpriceamountcostfee) safe_trade safe_string)rrRr1s r!rIzluno.parse_tradehsuX& &&uf55$$UI66    r"cK||d{V||}|d}d|dz}d|i}|jdd|z}d|z}|j|jd} || |} |||| ||d{V} | S) aS 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 [limit]: the maximum amount of order book entries to return :param dictConstructor [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: accepts l2 or l3 for level 2 or level 3 order book :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr#r(r)rr orderbook:r+) r/r0r1rr2r3rr4r%) rr#r%r8r1r9r:r;r<r=r> orderbooks r!watch_order_bookzluno.watch_order_books '')))!!!!!!!!!V$$!%t 4 &) it$'77"V+ +"k  ""9f55**S+w@PR^________    r"c  |d}d|z}||d}||j|}||i}||j|<||d}|2||||ddddd} || n3|||||d<|||d <||d } | |d <| ||dS) Nr#rdr.asksbidsr]volumer)rXsequencenonce) rbrE orderbooksindexed_order_bookcustom_parse_order_bookreset handle_deltaiso8601rGrK) rrArLr:r#r<r.rerhsnapshotrls r!handle_order_bookzluno.handle_order_books+Bh'"V+ $$Wk:: OODOV<<  //33I&/DOF #w//  33GVYPVX^`giqswxxH OOH % % % %   i 1 1 1%.Ik "$(LL$;$;Ij !!!':66" 'y+.....r"rirhr]rjasksKeypriceKey amountKey countOrIdKeyc @||||g|||} ||||g|||} ||| dd|| d|||ddS)NrT)r#rirhr.rXrl)parse_bids_asksrEsort_byrr) rrer#r.bidsKeyrvrwrxryrirhs r!rozluno.custom_parse_order_books##DOOIw$K$KXW`bnoo##DOOIw$K$KXW`bnooLLq$//LLq))" Y//    r"thirdKeyc ||}g}tdt|D]3}|||||||4|S)Nr)to_arrayrHrFrJcustom_parse_bid_ask)rbidasksrwrxr~resultrPs r!r{zluno.parse_bids_askssl--((q#g,,'' ` `A MM$33GAJ)U]^^ _ _ _ _ r"c|||}|||}||g}|+|||}|||SN) safe_numberrbrJ) rbidaskrwrxr~r]r^r thirdValues r!rzluno.custom_parse_bid_asksg  22!!&)44  ))&(;;J MM* % % % r"c||d}|d}|d}|e||ddd}||d}|dkr||n|d kr||||d }|H||d} |d d | g|d d | gdSdS) N create_updaterhrir]rjorder_idrZASKBID delete_updater)rErrb storeArray) rrerL createUpdate asksOrderSide bidsOrderSide bidAskArrayrZ deleteUpdateorderIds r!rqzluno.handle_deltasVw@@ !&) !&)  #33L'8U_``K##L&99Du}}((5555((555w@@  #&&|Z@@G  $ $aG_ 5 5 5  $ $aG_ 5 5 5 5 5 $ #r"c|dkrdSt|j}|j|jg}t dt |D]}||}||||ddS)Nr)list subscriptionsvaluesrtrSrHrF)rrArLrhandlersjhandlers r!handle_messagezluno.handle_message)s b== FV188::;; *D,>?q#h--(( 7 7AqkG GFG]1%5 6 6 6 6 7 7r"r)Nrirhr]rjru)r]rjru)__name__ __module__ __qualname__rstrrr rr@rrSrIrrfrtrror{rrqr __classcell__)r s@r!r r s     4<@d[]SSSSSSbfglbmSSSS8!9F!9!9!9!9F:@DB!!S!!S\!!!!22/2/2/2/2/h   bk  AJ  aj  EN     QZqzYU^u~969696v7V77777777r"r )ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrr!ccxt.async_support.base.ws.clientrtypingr async_supportr r"r!rs 777777<<<<<<<<<<<<444444c7c7c7c7c74  "c7c7c7c7c7r"