eiddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequiredc eZdZdeffd ZdefdZd-deede deedefd Z d Z ifd ede fd Z d ifdedefdZdefdZd.dZd d ifd edededeefdZd d ifdeedededeefdZdefdZd.dZdd d ifd ededededeef dZd d ifdeeededefdZdefdZd.defdZd ifd ededefdZd ifdeededefd Z defd!Z!ifd"Z"d d d ifd e#dededeefd#Z$defd$Z%d.d%Z&d d d ifdedededee'fd&Z(d'Z)d.d(Z*d d d ifd e#dededee+fd)Z,defd*Z-d.de+fd+Z.dede/fd,Z0xZ1S)/grvtreturnc|tt|ddddddddddddd dddddiidd d d d d d dddidS)NT) ws watchTicker watchTickers watchTradeswatchTradesForSymbols watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchMyTradeswatchPositions watchOrdersapirz!wss://market-data.grvt.io/ws/fullzwss://trades.grvt.io/ws/full) publicMarketprivateTradingd v1.book.s)depthintervalchannel v1.ticker.s)r/r.)r#r keepAlivei)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s K/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/grvt.pyr8z grvt.describesdD 1 1 : : < <# $#)-"(,"&,0!%"&#  (K*H! #*-- - #!!  VE%? %? % % % clientc t|||rdS|j|j|j|j|j|j|j|j|j|j|jd }||d}|dkrdS||d}| ||}||||dSdS)N) r0z v1.ticker.dz v1.mini.dz v1.mini.sv1.trade v1.candler, v1.book.dv1.fill v1.positionv1.ordermethod subscribestream) handle_error_message handle_ticker handle_trades handle_ohlcvhandle_order_bookhandle_my_tradehandle_position handle_order safe_string safe_value)r9r=messagemethods methodNamer/rEs r;handle_messagezgrvt.handle_message:s@  $ $VW 5 5  F--++**//+/)   %%gx88  $ $ F""7H55'22   F67 # # # # #  r<T messageHashesrequest rawHashescKdd||d}|rdnd}||jdd||||d{VS)Nz2.0rF)jsonrpcrEparamsidr(r)r'r) request_idwatch_multipler3)r9rVrWrXpublicOrPrivatepayloadapiParts r;subscribe_multiplezgrvt.subscribe_multiplersx!//##    %4I..9I((5)9$)?)H-Y`bklllllllllr<c||||jddd}||jd<||S)N requestIdr)lock_idsum safe_integerr4 unlock_id)r9newValues r;r]zgrvt.request_id|sW 88D--dlKKKQOO$, [! r<symbolcK|d{V||}||g||ddid{V}||S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://api-docs.grvt.io/market_data_streams/#mini-ticker-snap-feed-selector :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 ` NcallerMethodNamer) load_marketsrk watch_tickersextend)r9rkr[tickerss r; watch_tickerzgrvt.watch_tickers!!!!!!!!!V$$**F8T[[J\^kIl5m5mnnnnnnnnvr<NsymbolscK|t|jdzd}||ddd\}}d}||ddd\}}|d{V||}g}g}t dt |D]m}||}||} | d } || d zt|z|d | d zn||d } | || || |d{V} |j ri} | | | d <| S| |jd |S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://docs.backpack.exchange/#tag/Streams/Public/Ticker :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 ` Nz) watchTickers requires a symbols argumentrr/r0r.r+rr\@ticker::rkrG selectors)rr\handle_option_and_paramsrnmarket_symbolsrangelenmarketappendstrrbrp newUpdatesfilter_by_arrayrq)r9rsr[r/r.rXrVirkr}marketIdrWtickerrqs r;rozgrvt.watch_tickerss ?#DG.Y$YZZ Z77PY[hii88Q[]`aa&!!!!!!!!!%%g..  q#g,,'' @ @AQZF[[((Fd|H   X^c(mm; < < <  fX.>!> ? ? ? ?"  ..}dkk&RY>Z>Z\effffffff ? G(.GF8$ %N##DL(GDDDr<cd||di}||d}|d}||d}||d}|d}|||} | |j|<|| d|zdS)Nfeedselectorrurrkrv) safe_dictrPsplit safe_marketparse_ws_tickerrqresolve) r9r=rRdatarpartsrr}rkrs r;rIzgrvt.handle_tickersZ~~gvr22##GZ88s####E1--!!(D11!%%dF33% VvzF233333r<c.|||SN) parse_ticker)r9rRr}s r;rzgrvt.parse_ws_tickers  &111r<sincelimitcDK||g|||d{VS)a* watches information on multiple trades made in a market https://api-docs.grvt.io/market_data_streams/#trade_1 :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` N)watch_trades_for_symbols)r9rkrrr[s r; watch_tradeszgrvt.watch_tradess622F8UE6RRRRRRRRRr<cK|d{V||}g}g}tdt|D]w}||}||} | d} ||dd} || dz| z|d| dzxd |d } ||||| |d{V} |j rB| | d}| |d}| ||}| | ||d d S) a] get the list of most recent trades for a list of symbols https://api-docs.grvt.io/market_data_streams/#trade_1 :param str[] symbols: 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 :param str [params.limit]: 50, 200, 500, 1000(default 50) :returns dict[]: a list of `trade structures ` Nrr\r2rutrade::rkr?rw timestampT)rnrzr{r|r}rhr~rbrprrQrPgetLimitfilter_by_since_limit)r9rsrrr[rXrVrrkr}rlimitRawrWtradesfirst tradeSymbols r;rzgrvt.watch_trades_for_symbols s!!!!!!!!!%%g..  q#g,,'' ? ?AQZF[[((Fd|H(("==H   X^h6 7 7 7  VH-=!= > > > > "  ..}dkk&RY>Z>Z\effffffff ? 8OOFA..E**5(;;KOOK77E))&% TRRRr<c ||di}||d}|d}||d}||d}|d}||jvr3||jdd} t| |j|<||} |j|} | | | | d|zdS) Nrrrurrk tradesLimitr) rrPrrrrhr4rparse_ws_trader~r) r9r=rRrrrrr}rkrparsedstoreds r;rJzgrvt.handle_tradesCs.~~gvr22##GZ88s####E1--!!(D11!$+%%%%dlM4HHE",U"3"3DK $$T**V$ fvy6122222r<c.|||Sr parse_trader9trader}s r;rzgrvt.parse_ws_tradehv...r<1m timeframecK|d{V||}d|d<|||gg|||d{V}|||S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://api-docs.grvt.io/market_data_streams/#candlestick_1 :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 rm)rnrkwatch_ohlcv_for_symbols)r9rkrrrr[results r; watch_ohlcvzgrvt.watch_ohlcvls!!!!!!!!!V$$%1!"33fi5H4I5RWY_````````f~i((r<symbolsAndTimeframescK|d{Vg}g}tdt|D]}||}||d} || } | d} ||dd} ||j| | } || dz| zdz|d| d zd z| zd |d }||||||d{V\}}}|j r| ||}| |||dd }| |||S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://api-docs.grvt.io/market_data_streams/#candlestick_1 :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :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 dict: A list of candles ordered, open, high, low, close, volume Nrr\re1ru-TRADEohlcv::rk::r@rwT) rnr{r|rPr} timeframesr~rbrprrrcreate_ohlcv_object)r9rrrr[rXrVrr symbolStringr}runfiedTimeframe timeframeIdrWrkrrfiltereds r;rzgrvt.watch_ohlcv_for_symbolss!!!!!!!!!  q#23344 X XA'*D++D!44L[[..Fd|H"..tQ<` indexed by market symbols N)rnrkwatch_order_book_for_symbols)r9rkrr[s r;watch_order_bookzgrvt.watch_order_booksi!!!!!!!!!V$$66xOOOOOOOOOr<c&K|d{Vd}||ddd\}}|dk}t|}|dkrt|jdz|||ddd \}}d}||dd d \}}||}|r|d z|zn|}g} g} t dt|D]`} || } || } | d }| |dz|z| d| dza|| d}| | | ||| d{V}| S)ab watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api-docs.grvt.io/market_data_streams/#orderbook-snap https://api-docs.grvt.io/market_data_streams/#orderbook-delta :param str[] symbols: unified array of symbols :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"r/rAr,rzA watchOrderBookForSymbols() requires a non-empty array of symbolsrr*r.r+-r\ru orderbook::rkrw) rnryr|rr\rzr{r}r~rbrpr)r9rsrr[r/ isSnapshot symbolsLengthr. extraPartrXrVrrkr}rrW orderbooks r;rz!grvt.watch_order_book_for_symbolss!!!!!!!!!77@PR[]hii + G A  #DG.q$qrr r = 99&BRT[]`aaME688AQS]_bcc&%%g..0:HX^e++   q#g,,'' C CAQZF[[((Fd|H   X^i7 8 8 8  1A!A B B B B"  11-WV\A]A]_hiiiiiiii    r<c ||di}||d}|d}||d}||d}|d}||dd} ||jvr||j|<|j|} ||d} ||d } | d k} | dk}| s|r1|||| d d d d}| |n| |d g}| |d g}| | d |d d| | d |d d| | d<| | | d<| | d<d|z}| |j|<| | |dS)Nrrrurrk event_timegư>sequence_numberrGr,bidsaskspricesizerdatetimenoncer)rrPrrsafe_integer_product orderbooks order_bookrhparse_order_bookreset safe_listhandle_deltas_with_keysiso8601r)r9r=rRrrrrr}rkrrsequenceNumberrGisSnapshotChannelisSnapshotMessagesnapshotrrrs r;rLzgrvt.handle_order_books6~~gvr22##GZ88s####E1--!!(D11!--dL(KK $/))&*oo&7&7DOF #OF+ **74EFF!!'844"k1*a/  < 1 <,,T69ffV]_effH OOH % % % %>>$33D>>$33D  ( (6):D'6 R R R  ( (6):D'6 R R R%.Ik "$(LL$;$;Ij !+ '#f, "+y+.....r<c K||d{V||jdi}||d}|||jd}||jd}||t |jdzddd||diii}||||j d dd dSdS) Nrtoken AuthAccountIdAuthCookieValuezJ : at first, you need to authenticate with exchange using signIn() method.r4headers)CookiezX-Grvt-Account-Idr'r)) check_required_credentialssign_inrr4rPrr\extend_exchange_optionsr=r3)r9r[ wsOptions authenticated accountId cookieValuedefaultOptionss r; authenticatezgrvt.authenticate>s; '')))llnn..tR@@ ((G<<  ((GGI**4<9JKKK"i&7)$'5A+ABBB!&11:$$  $N  ( ( 8 8 8 KK %(./?@ A A A A A! ! r<c|K||}|d{V|d{Vg}g}|U||}||dz|dz|d|dzn*|d||d|d} |||| ||d d{V} |jr| ||}| | ||d d S) am watches information on multiple trades made by the user https://api-docs.grvt.io/trading_streams/#fill :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.unifiedMargin]: use unified margin account :returns dict[]: a list of `trade structures ` Nrr\ myTrades::rkmyTradesrBrwFrT) getSubAccountIdrnrr}r~rbrprrr) r9rkrrr[ subAccountIdrVrXr}rWrs r;watch_my_tradeszgrvt.watch_my_tradesUsx++F33 !!!!!!!!!!!!!!!!!!   [[((F   \C/&,> ? ? ?  x0@!@ A A A A   , , ,   \ * * *"  ..}dkk'SY>Z>Z\ikpqqqqqqqq ? 3OOFE22E))&% TRRRr<c~||di}|j0||jdd}t ||_||}|j|||jd|dz||jddS)Nrrrrrkr)rrrhr4rparse_ws_my_trader~r)r9r=rRrrrs r;rMzgrvt.handle_my_tradewsH~~gvr22 = %%dlM4HHE2599DM&&t,, U###t}lU8_&DEEEt}j11111r<c.|||Srrrs r;rzgrvt.parse_ws_my_tradesv...r<cK||}|d{V|d{V||}g}g}|}t dt |D]^}||} || } ||dz| dz|d| dz_n*|d||d|d } ||| | ||d d{V} |j r| S| |j |||d S) a https://api-docs.grvt.io/trading_streams/#positions watch all open positions :param str[] [symbols]: list of unified market symbols :param int [since]: the earliest time in ms to fetch positions for :param int [limit]: the maximum number of positions to retrieve :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nrrr\ positions::rk positionsrCrwFT) rrrnrzr{r|r}r~rbrprfilter_by_symbols_since_limitr) r9rsrrr[rrXrVrrkr}rW newPositionss r;watch_positionszgrvt.watch_positionss++F33 !!!!!!!!!!!!!!!!!!%%g..   1c'll++ G G V,,  !3fTl!BCCC$$]VH5E%EFFFF  G   - - -   \ * * *#"  "44]DKKPWY_D`D`bkmrssssssss ?  11$.'5RWY]^^^r<c||jt|_||d}||}||d}|j|g}||||d|z||ddS)Nrrkrr)rrrparse_ws_positionrPr~r)r9r=rRrpositionrkrs r;rNzgrvt.handle_positions: > !577DN~~gv..))$//!!(H55 h''' H%%%|]V%;<<<|[11111r<c.|||Sr)parse_position)r9r r}s r;r zgrvt.parse_ws_positions""8V444r<c|K||}|d{V|d{Vg}g}|+|d||nT||}|d|dz||dz|dzd|d} |||| ||d d{V} |jr| ||}| | |||d S) a4 watches information on multiple orders made by the user https://api-docs.grvt.io/trading_streams/#order_1-feed-selector :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Norderszorder::rkrr\rDrwFT) rrnrr~r}rbrprrfilter_by_symbol_since_limit) r9rkrrr[rrVrXr}rWrs r; watch_orderszgrvt.watch_orderssw++F33 !!!!!!!!!!!!!!!!!!  >   * * *   \ * * * *[[((F  VH-=!= > > >   \C/&,> ? ? ? "  ..}dkk'SY>Z>Z\eglmmmmmmmm ? 3OOFE22E00tTTTr<c||d}|j0||jdd}t ||_||}|j|||jd||j|dddd}||d|dzdS)Nr ordersLimitrrrkTzorders::) rrrhr4rparse_ws_orderr~rr)r9r=rRrrorderordersForSymbols r;rOzgrvt.handle_ordersB~~gv.. ; %%dlM4HHE077DK##D)) 5!!!t{H---;;DKxZ^`dfjkk U8_(DEEEEEr<c.|||Sr) parse_order)r9rr}s r;rzgrvt.parse_ws_ordercrr<c||d}||d}|||}|jdz|z}||d}||jd||||jd||||jd||t|jdz|zdS)Nerrorcode rRexactbroadF)rrPjsonr\throw_exactly_matched_exception exceptionsthrow_broadly_matched_exceptionr)r9r=responser errorCodebodyfeedbackrRs r;rHzgrvt.handle_error_messagegsx11$$UF33  99X&&Dw}t+H&&ui88G  0 01I9V^ _ _ _  0 01I7T\ ] ] ]  0 01I7T\ ] ] ]#  455 5ur<)Tr)2__name__ __module__ __qualname__rr8rrUrrdictrbr]rrrrrrorIrr rrrrJrlistrrrKrr rrrLrr rrMrr rrNr r rrOrrrH __classcell__)r:s@r;rrs& #& & & & & & P6$V6$6$6$6$pmmd3im$m[_`c[dm@Cmmmm68   F    6:"#E#E7#E#E#E#E#EJU4FU4U4U4U4n2222<@d[] S S SS S Sbfglbm S S S SOSaenp!S!Sd3i!S!S[^!SuyzvA!S!S!S!SF#3F#3#3#3#3J////?CQUdhqs))))3)^a)x|~ByC))))&aeswAC E E$tCy/ EZ] Emp E E E ED'16'1'1'1'1R//D////@DBPPSPPS\PPPP SW_a&!&!$s)&!C&!fo&!&!&!&!P6/6/6/6/6/p)+BBBB.37TX\eg S SC Ss SRU Slpqvlw S S S SD+2f+2+2+2+2Z////8<$]ajl"_"_W"_C"_WZ"_quv~q"_"_"_"_H&2&2&2P555504$UYbdUUUCUsUimnsitUUUUBIF6IFIFIFIFV//E////6r<r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrr<r;r6sG AAAAAAAAAAAAllllllllllllllllllllllllll444444******000000......m m m m m 4  "m m m m m r<