eiddlZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZGddejjZdS) N) ArrayCache) AnyInt Liquidation OrderBookStrStringsTickerTickersTrade)Client)List)Precisec eZdZdeffd Zd/dededefdZifdZifd Z ifd Z d Z d Z d e fdZd e fdZdifdededefdZifdedefdZd e fdZifdedefdZifdedefdZdifdedefdZdifdedefdZifdedefdZdifdedefdZifdedefdZdifdedefdZd0dZ d e fdZ!ddifdededede"e#fd Z$ifdedefd!Z%d e fd"Z&dddifdededede"e#fd#Z'difdedefd$Z(d0d%Z)d e fd&Z*ddifdededede"e+fd'Z,d(Z-d e fd)Z.d e fd*Z/d e d+e0fd,Z1d e fd-Z2d.Z3xZ4S)1lighterreturnc|tt|iddddddddddddd dd dd dd dd dddddddddddddddddddddddddd ddiddididS)NwsT watchTickerwatchMarkPricewatchMarkPrices watchTickers watchBidsAsksFwatchOrderBook watchTradeswatchTradesForSymbolswatchOrderBookForSymbols watchBalancewatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchOHLCVwatchOHLCVForSymbols) watchOrders watchMyTradeswatchPositionswatchFundingRatewatchFundingRatesunWatchOrderBook unWatchTickerunWatchTickers unWatchTradesunWatchMyTradesunWatchMarkPriceunWatchMarkPricesz(wss://mainnet.zklighter.elliot.ai/streamz(wss://testnet.zklighter.elliot.ai/stream)apitest)hasurlsoptions) deep_extendsuperrdescribe)self __class__s N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/lighter.pyr8zlighter.describeslgt 4 4 = = ? ?dt!$"4      !$t(+E$T.u&u0 e!"'#$ %!%"'$)%*$(!%"&!%#'$(%);BDD Q)B )B ) ) ) NunifiedChannelsymbolextrac>|}| |d|zz }n|dz }||d|zz }|S)Nz::s)r9r=r>r?hashs r;get_message_hashzlighter.get_message_hash<s?   D6M !DD CKD   D5L D r<cK|jdd}ddi}||d}||||||||d{VS)Nr1rtype subscribe messageHashparamsr4watchextendr9rIrJurlrequest subscriptions r;subscribe_publiczlighter.subscribe_publicFsuit$ K '  ZZ[$++gv2N2NP[]ijjjjjjjjjr<cK|jdd}ddi}||d}||||||||d{VS)Nr1rrFrG) messageHashesrJ)r4watch_multiplerM)r9rTrJrOrPrQs r;subscribe_public_multiplez!lighter.subscribe_public_multipleQsxit$ K +  ((mT[[RX=Y=Y[hjvwwwwwwwwwr<cK|jdd}ddi}||d}||||||||d{VS)Nr1rrF unsubscriberHrKrNs r;unsubscribe_publiczlighter.unsubscribe_public\suit$ M '  ZZ[$++gv2N2NP[]ijjjjjjjjjr<c||d}||d}|||dS)Npricesize) safe_floatstore)r9booksidedeltar[amounts r; handle_deltazlighter.handle_deltagsBw////uf%%%%%r<c~tdt|D]}||||dS)Nr)rangelenrb)r9r_deltasis r; handle_deltaszlighter.handle_deltaslsHq#f++&& 3 3A   hq 2 2 2 2 3 3r<clientc||di}||d||dg||d||dg||d|d<||d}||d<|||d<|S)N order_bookasksbidsoffsetnonce timestampdatetime) safe_dictrh safe_list safe_integeriso8601)r9rimessage orderbookdatarps r;handle_order_book_messagez!lighter.handle_order_book_messageps~~g|R88 9V,dnnT62.N.NOOO 9V,dnnT62.N.NOOO!..tX>> '%%g{;; !* + $ Y 7 7 *r<c ||di}||dd}|d}|d}||}|d}||d} ||jvr||j|<|j|} ||dd} | d krJ|||| d d d d } ||d| d<| | n| dkr| ||| | d|} | | | dS)Nrkchannel:r>rprFzsubscribed/order_bookrmrlr[r\rnrozupdate/order_bookrw) rr safe_stringsplit safe_marketrt orderbooksrkparse_order_bookresetryrDresolve)r9rirvrxr{partsmarketIdmarketr>rprwrFparsedrIs r;handle_order_bookzlighter.handle_order_bookzsp4~~g|R88""7Ir:: c""8!!(++!%%g{;; $/))&*oo&7&7DOF #OF+ 44 * * ***4FFT[]cddF"//h??F7O OOF # # # # ( ( (  * *67I F F F++K@@ y+.....r<limitc2K|d{V||}dd|dzi}|d|}|||||d{V}|S)a= watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://apidocs.lighter.xyz/docs/websocket-reference#order-book :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 Nr{ order_book/idrw) load_marketsrrDrRrMr)r9r>rrJrrPrIrws r;watch_order_bookzlighter.watch_order_books!!!!!!!!!V$$ }vd|3 ++K@@ // T[[RX=Y=YZZZZZZZZ    r<c K|d{V||}dd|dzi}|d|}|||||d{VS)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://apidocs.lighter.xyz/docs/websocket-reference#order-book :param str symbol: unified symbol of the market :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr{rrrXrrrDrYrMr9r>rJrrPrIs r;un_watch_order_bookzlighter.un_watch_order_books!!!!!!!!!V$$ }vd|3 ++M6BB ,,[$++gv:V:VWWWWWWWWWr<c(||di}||d}|dkrt|}t dt |D]}||}||}|d} ||||} | |j| <| | | d| | | | ddS||d}||}|d} |||} | |j| <| | | d| dS)N market_statsr{zmarket_stats:allrr>ticker market_id) rrrlistkeysrdrer parse_tickertickersrrD) r9rirvrxr{ marketIdsrgrrr>rs r; handle_tickerzlighter.handle_tickersh~~g~r::""7I66 ( ( (TYY[[))I1c)nn-- H H$Q<))(33)**4>6BB'- V$vt'<'` Nr{ market_stats/rrrrrDrRrMrs r; watch_tickerzlighter.watch_tickers!!!!!!!!!V$$ 5 ++Hf== **; GV8T8TUUUUUUUUUr<c K|d{V||}dd|dzi}|d|}|||||d{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://apidocs.lighter.xyz/docs/websocket-reference#market-stats :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 ` Nr{rrrXrrs r;un_watch_tickerzlighter.un_watch_ticker(s!!!!!!!!!V$$ 5 ++M6BB ,,[$++gv:V:VWWWWWWWWWr<symbolscRK|d{V||}ddi}g}|t|dkr)||dnQt dt|D]3}||}||d|4|||||d{V}|jri}|||d<|S| |j d|S)a https://apidocs.lighter.xyz/docs/websocket-reference#market-stats watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] [symbols]: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` Nr{market_stats/allrrr>) rmarket_symbolsreappendrDrdrVrM newUpdatesfilter_by_arrayr) r9rrJrPrTrgr> newTickerresults r; watch_tickerszlighter.watch_tickers:sR!!!!!!!!!%%g.. )  ?c'lla//  !6!6x!@!@ A A A A1c'll++ N N $$T%:%:8V%L%LMMMM88 T[]cHdHdeeeeeeee ? F*3F9X& 'M##DL(GDDDr<cK|d{Vddi}|d}|||||d{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://apidocs.lighter.xyz/docs/websocket-reference#market-stats :param str[] [symbols]: 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 ` Nr{rrX)rrDrYrM)r9rrJrPrIs r;un_watch_tickerszlighter.un_watch_tickersXs!!!!!!!!! ) ++M:: ,,[$++gv:V:VWWWWWWWWWr<c>K|||d{VS)ar https://apidocs.lighter.xyz/docs/websocket-reference#market-stats watches a mark price :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 ` N)rr9r>rJs r;watch_mark_pricezlighter.watch_mark_priceis0&&vv666666666r<c>K|||d{VS)av https://apidocs.lighter.xyz/docs/websocket-reference#market-stats watches mark prices :param str[] [symbols]: 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 ` N)rr9rrJs r;watch_mark_priceszlighter.watch_mark_pricesus0''888888888r<c>K|||d{VS)at https://apidocs.lighter.xyz/docs/websocket-reference#market-stats unWatches a mark price :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 ` N)rrs r;un_watch_mark_pricezlighter.un_watch_mark_prices0))&&999999999r<c>K|||d{VS)ax https://apidocs.lighter.xyz/docs/websocket-reference#market-stats unWatches mark prices :param str[] [symbols]: 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 ` N)rrs r;un_watch_mark_priceszlighter.un_watch_mark_pricess0**7F;;;;;;;;;r<c2||d}||d}||d}||d}||d}|durdnd}||d } tj| d } tj| | } |||d||||d|d|d ||||d | d dd |S)Nrptrade_idr[r\ is_maker_askTsellbuy maker_fee100maker usd_amountUSDC)costcurrency) infororderrprqr>rFside takerOrMakerr[rarfee) rtr safe_boolr string_div string_mul safe_traderu safe_symbol) r9traderrptradeId priceString amountString isMakerAskr makerFeeRater feeAmounts r;parse_ws_tradezlighter.parse_ws_trades<:%%e[99 ""5*55&&ug66 ''v66 ^^E>:: $,,vv5'' << "<77&ul;; " Y//&&tV44# "$$UL99!"  " # r<c||dg}t|dkr|||||dg}||dd}|d}|d}||}|d} ||j| } | 5||j d d } t| } | |j| <tdt|D]3} | || |} | | 4|d | }|| |dS) Nliquidation_tradesrtradesr{r|r}r~r> tradesLimitr)rsrehandle_liquidationrrr safe_valuerrtr5rrdrrrDr)r9rirvliquidationDatarxr{rrrr>storedrrgrrIs r; handle_tradeszlighter.handle_tradessoJ..2FKK   ! # #  # #FG 4 4 4~~gx44""7Ir:: c""8!!(++!f55 >%%dlM4HHE&&F"(DK q#d))$$ ! !A''Q88E MM% ++GV<< v{+++++r<sincecK|d{V||}dd|dzi}|d|d}|||||d{VS)a! get the list of most recent trades for a particular symbol https://apidocs.lighter.xyz/docs/websocket-reference#trade :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{trade/rrr>rr9r>rrrJrrPrIs r; watch_tradeszlighter.watch_trades s!!!!!!!!!V$$ x&,. ++GVH5EFF **; GV8T8TUUUUUUUUUr<c K|d{V||}dd|dzi}|d|}|||||d{VS)a} unsubscribe from the trades channel https://apidocs.lighter.xyz/docs/websocket-reference#trade :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nr{rrrXrrs r;un_watch_tradeszlighter.un_watch_tradess!!!!!!!!!V$$ x&,. ++M6BB ,,[$++gv:V:VWWWWWWWWWr<c,||di}t|}t|}|dkrdS|j0||jdd}t||_|j}|d}tdt|D]} || } | | } | || g} tdt| D]i} | | | | }| ||d}|,|d|}|||j|||dS) NrrFrrmyTradesr>T)rrrrrerrtr5rrDrdrrsrrr)r9rirvrxr idsLengthrrrIrgrrrjrr>symbolSpecificMessageHashs r;handle_my_tradeszlighter.handle_my_trades1sF~~gx44%%  NN >>5 = %%dlM4HHE&u--DM++J77 q#i..)) F FA |H%%h//F^^D(B77F1c&kk** F F++F1Iv>> e$$$x%040E0EjRX0Y0Y-NN6+DEEE  F v{+++tr<cK|d{Vd}||dddd{V\}}|d}|3||}|d}|d|}dd||zi}|||||d{V} |jr| ||}| | |||d S) a subscribe to recent trades of an account. https://apidocs.lighter.xyz/docs/websocket-reference#account-all-trades :param str [symbol]: unified market symbol :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& accountIndex account_indexrr>r{account_all_trades/T) rhandleAccountIndexrDrnumber_to_stringrRrMrgetLimitfilter_by_symbol_since_limit) r9r>rrrJrrIrrPrs r;watch_my_tradeszlighter.watch_my_tradesls<!!!!!!!!! %)%<%` r.rrNrXrr>r{r)rrDrrrYrM)r9r>rJrrIrrPs r;un_watch_my_tradeszlighter.un_watch_my_tradess  %)%<%r[r\) rr> contracts contractSizer[r baseValue quoteValuerprq)rtsafe_liquidationrru)r9 liquidationrrps r;parse_ws_liquidationzlighter.parse_ws_liquidations:%%k;?? $$X& %%k7;;$$[&99" Y// & &   r<cx||dg}||dd}|d}|d}||}|d}||j|} | 7||jdd} t| |_|j} td t|D]3} | || |} | | 4| d |} || | dS) Nrr{r|r}r~r>liquidationsLimitrr liquidations)rsrrrrrrtr5rrdrerrrDr)r9rirvrxr{rrrr>rrrgrrIs r;rzlighter.handle_liquidations2J~~g';R@@""7Ir:: c""8!!(++!!2F;; >%%dl4GNNE *5 1 1D &Fq#d))$$ ' 'A33DGVDDK MM+ & & & &++NFCC v{+++++r<c K|d{V||}dd|dzi}|d|}|||||d{VS)a watch the public liquidations of a trading pair https://apidocs.lighter.xyz/docs/websocket-reference#trade :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{rrrrrs r;watch_liquidationszlighter.watch_liquidationss!!!!!!!!!V$$ x&,. ++NFCC **; GV8T8TUUUUUUUUUr<cF||d} |Z||d}|B|jdz||z}||jd||n,#t $r}||Yd}~nd}~wwxYwdS)Nerrorcode exactT)rrrrjsonthrow_exactly_matched_exception exceptions Exceptionreject)r9rirvr r feedbackes r;handle_error_messagezlighter.handle_error_messagesw00  ''88##w}tyy/A/AAH889QSWYabbb    MM!         tsAA55 B?BBc|||sdS||dd}|dkr|||dS||dd}|ddkr|||dS|ddkr|||dS|ddkr|||dS|d dkr|||dS|dkr|||dSdS) NrFr|pingr{z order_book:rz market_stats:ztrade:zaccount_all_trades:) rr handle_pingfindrrrrhandle_subscription_status)r9rirvrFr{s r;handle_messagezlighter.handle_message(sf((99  F44 6>>   VW - - - F""7Ir:: << & &! + +  " "67 3 3 3 F << ( (A - -   vw / / / F << ! !Q & &   vw / / / F <<- . .! 3 3  ! !&' 2 2 2 F b==  + +FG < < < < < =r<c||dd}||d}||jd}|||i}|dkr||||S)NrFr| session_idr unsubscribed)rindex_by subscriptionsrrhandle_un_subscription)r9rirvrFrsubscriptionsByIdrQs r;rz"lighter.handle_subscription_status?s44   g| 4 4 MM&*>EE~~&7R@@ > ! !  ' ' = = =r<rQc||dg}||dg}tdt|D])}||}||}||||*||dS)NrTsubMessageHashesr)rsrdreclean_unsubscription clean_cache)r9rirQrTr#rg unsubHashsubHashs r;r zlighter.handle_un_subscriptionSs|_bII >>,8JBOOq#m,,-- B BA%a(I&q)G  % %fgy A A A A &&&&&r<c>||j||dSN)spawnpong)r9rirvs r;rzlighter.handle_ping\s" 49fg.....r<cHKddi}||d{VdS)NrFr+)send)r9rirvrPs r;r+z lighter.pongbs> F kk'"""""""""""r<)NNr))5__name__ __module__ __qualname__rr8strrrDrRrVrYrbrhr ryrrrrrrr rrr r rrrrrrrrrr rrrrrrrrrrrrdictr rr+ __classcell__)r:s@r;rrs* #* * * * * * XsCs:< k k k kEG x x x x<> k k k k&&& 333,/,/,/,/,/\@DB!!S!!S\!!!!(=?XXX3XXXX$FLFFLFLFLFLP68VVVFVVVV$9;XXCXsXXXX$6:"EE7EEEEE<9=RXXgXCXXXX":< 7 7S 7 7 7 7 7:>b 9 9w 9W 9 9 9 9=? : : :3 : : : :=A < <' r<s 777777bbbbbbbbbbbbbbbbbbbbbb444444%%%%%%X #X #X #X #X #d (X #X #X #X #X #r<