ei/bddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZGddejjZdS)N) ArrayCacheArrayCacheBySymbolById) AnyBoolIntMarketOrder OrderBookStrStringsTickerTickers FundingRate FundingRatesTrade)Client)Listc reZdZdeffd ZdZifdZdefdZddifde d e d e de e fd Z defd Zdifde d e defd ZdefdZifde defdZdifdedefdZdddifded e d e de efdZdefdZdefdZifde defdZdifdedefdZdefdZ dde!defdZ"dede#fdZ$defdZ%xZ&S)paradexreturnc|tt|dddddddddddd dddiddidd d d d iid S)NTF) wswatchFundingRatewatchFundingRates watchTicker watchTickerswatchOrderBook watchOrders watchTradeswatchTradesForSymbols watchBalance watchOHLCVz https://x.com/tradeparadex/photorz"wss://ws.api.prod.paradex.trade/v1z%wss://ws.api.testnet.paradex.trade/v1zhttps://www.paradex.trade/z'https://docs.api.testnet.paradex.trade/z7https://docs.paradex.trade/getting-started/trading-fees)logoapitestwwwdocfeesreferral)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/paradex.pyr1zparadex.describesgt 4 4 = = ? ?$(%)# $"&##). %#  ;>A4@Q  9B B    cz|||jddd}||jd<|S)N requestIdr)sum safe_integerr-)r2r7s r4 request_idzparadex.request_id/s;HHT..t|[!LLaPP $- [!r5cK|jdd}||}d}|d}||j|}|a|d{V}d|dd|id}||||||||d{VS)Nr%r authenticated2.0authbearer)jsonrpcidmethodparams) r,clientreusableFuture safe_value subscriptionsauthenticateRestr;watchr/) r2rDurlrE messageHashfuturer=tokenrequests r4 authenticatezparadex.authenticate4sit$S!!% &&77(` Nztrades.rBALLr%rr> subscribechannelrArCrD timestampT) load_marketsmarketr,rJr/ newUpdatesgetLimitfilter_by_since_limit) r2rXrYrZrDrLrbrKrOtradess r4 watch_tradeszparadex.watch_tradesVs!!!!!!!!!  [[((F 6$< 'KK 5 Kit$!;  zz#{D4D4DWf4U4UWbcccccccc ? 3OOFE22E))&% TRRRr5c||di}||di}||}|d}||d}||j|}|3t ||jdd}||j|<||| |||S)NrDdatarXr^ tradesLimit) rS parse_trade safe_stringrGrfrr:r-appendrU) r2rErVrDri parsedTraderXrLstoreds r4 handle_tradezparadex.handle_tradevs&266~~ffb11&&t,, X&&&vy99 f55 > 1 1$, t T TUUF"(DK  k"""v{+++r5cBK|d{V||}d|dzdz}|jdd}ddd |id }|||||||d{V}|S) aC watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.paradex.trade/ws/web-socket-channels/order-book/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 Nz order_book.rBz.snapshot@15@100msr%rr>r]r^r_)rarbr,rJr/rZ) r2rXrZrDrbrLrKrO orderbooks r4watch_order_bookzparadex.watch_order_books!!!!!!!!!V$$#fTl25II it$!;  **S+t7G7GQW7X7XZeffffffff    r5c||di}||di}||d}||}||d}|d}||jvr||j|<ggd} ||d} tdt| D]} || | } || d } || d }|| d }| d kr| d  ||g~| d ||g|j|}| | ||d d}||d|d<| |||d}| ||dS)NrDrirblast_updated_atrX)bidsasksinsertsrsidepricesizeBUYrwrxseq_nononcer^) rSrm safe_marketr: orderbooks order_book safe_listrangelenrnparse_order_bookresetrU)r2rErVrDrimarketIdrbr`rX orderbookDataryiinsertrzr{r|rssnapshotrLs r4handle_order_bookzparadex.handle_order_books<266~~ffb11##D(33!!(++%%d,=>> !$/))&*oo&7&7DOF #  ..y11q#g,,'' < ` Nmarkets_summaryr%rr>r]r^r_.rarXr,rJr/r2rXrDr^rKrOrLs r4 watch_tickerzparadex.watch_tickers!!!!!!!!!V$$#it$!7  mf, ZZ[$2B2B7F2S2SU`aaaaaaaaar5symbolscJK|d{V||}d}|jdd}ddd|id}g}|Yt|trDt d t |D]%}|d z||z}||&n|||||| |||d{V} |j ri} | | | d <| S| |j d |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.paradex.trade/ws/web-socket-channels/markets-summary/markets-summary :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 ` Nrr%rr>r]r^r_rrrX) ramarket_symbolsr, isinstancelistrrrnwatch_multipler/rcfilter_by_arraytickers) r2rrDr^rKrO messageHashesrrL newTickerrRs r4 watch_tickerszparadex.watch_tickerssk!!!!!!!!!%%g..#it$!7    :gt#<#< 1c'll++ 2 2%mgaj8 $$[1111 2   ) ) )--c=$BRBRSZ\bBcBcerssssssss ? F*3F9X& 'M##DL(GDDDr5cK|d{V|d{Vd}d}|1||}|d}||dz }|d|zz }n|dz }|jdd }d d d |id } ||||| ||d{V} |jr| ||}|| |||dS)a6 watches information on multiple orders made by the user https://docs.paradex.trade/ws/web-socket-channels/orders/orders :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 ` Norderszorders.rXrB:r\r%rr>r]r^r_T) rarPrbr,rJr/rcrdfilter_by_symbol_since_limit) r2rXrYrZrDrLr^rbrKrOrs r4 watch_orderszparadex.watch_orders%sE!!!!!!!!!!!!!!!!!!   [[((FH%F vd| #G 3< 'KK u Git$!7  zz#{D4D4DWf4U4UW^________ ? 3OOFE22E00tTTTr5c||di}||di}||}||d}|j0||jdd}t ||_|j|d}||j||%|dz|z} ||j| dSdS)NrDrirX ordersLimitrkrr) rS parse_orderrmrr:r-rrnrU) r2rErVrDriparsedrXrZrLsymbolMessageHashs r4 handle_orderzparadex.handle_orderIs8266~~ffb11!!$''!!&(33 ; %%dlM4HHE077DK 6""" t{K000   +c 1F :  NN4;(9 : : : : :  r5c||di}||di}||d}||}|d}||d}|dz|z} |||} | |j|<|| ||| | |SNrDrirXr^r)rSrmr parse_tickerrrU) r2rErVrDrirrbrXr^rLtickers r4 handle_tickerzparadex.handle_tickerss2266~~ffb11##D(33!!(++!""6955mf, ""400% Vvw'''v{+++r5cK|d{V||}d}|jdd}ddd|id}|d z|z}|||||||d{VS) a watch the current funding rate for a symbol https://docs.paradex.trade/ws/web-socket-channels/funding-data-market-symbol/funding-data-market-symbol :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` N funding_datar%rr>r]r^r_rrrs r4watch_funding_ratezparadex.watch_funding_rates!!!!!!!!!V$$ it$!7  mf, ZZ[$2B2B7F2S2SU`aaaaaaaaar5cvK|d{V||}d}|jdd}ddd|id}g}|ot|}|d krDt d t|D]%}|d z||z} || &n+||n|||||||||d{V} |jri} | | | d <| S| |j d |S) a watch the funding rate for multiple markets https://docs.paradex.trade/ws/web-socket-channels/markets-summary/markets-summary :param str[] [symbols]: a list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` Nrr%rr>r]r^r_rrrX) rarr,rrrnrr/rcr fundingRates) r2rrDr^rKrOr symbolsLengthrrLnewFundingRatesrRs r4watch_funding_rateszparadex.watch_funding_ratess!!!!!!!!!%%g.. it$!7    LLMq  q#g,,//66A")C-'!*"bbsb+bbbb0<@%J%J%J|%J%J%J%JN1&11118# # f# # # # # J6t81(V1(1(1(1(1(1(1(1(r5r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingr async_supportrr5r4rsG OOOOOOOOFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF444444Y (Y (Y (Y (Y (d (Y (Y (Y (Y (Y (r5