E#i@SSKrSSKJrJr SSKJrJrJrJ r SSK J r SSK J r SSKJr "SS\R R"5rg) N) ArrayCacheArrayCacheByTimestamp)AnyInt OrderBookTrade)Client)List) ExchangeErrorc <^\rSrSrS\4U4SjjrSS04S\S\S\S\\ 4Sjjr 04S\S\4S jjr S r SS jr S04S\S\S\4S jjr04S\S\4S jjrS\4SjrSrSSS04S\S\S\S\\4SjjrS04S\S\4SjjrS\4SjrS\4SjrS\4SjrSrU=r$)dydxreturnc r>UR[[U]5SSSSSSSS.SS0SS0S.000S.5$) NTF)ws watchBalance watchTicker watchTickers watchTradeswatchOrderBook watchOHLCVrz+wss://indexer.v4testnet.dydx.exchange/v4/wszwss://indexer.dydx.trade/v4/ws)testapi)hasurlsoptions streaming exceptions) deep_extendsuperr describe)self __class__s G/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/dydx.pyr! dydx.describeskdD : < %$ %#"&"G: )?   Nsymbolsincelimitcj# UR5IShvN URSSnURU5nSUS-nSSUSS .nURXWUR X5U5IShvN n UR (aU R X5nURXUS S 5$NN<7f) a get the list of most recent trades for a particular symbol https://docs.dydx.xyz/indexer-client/websockets#trades :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 ` Nrrtrade:r' subscribe v4_tradesidtypechannelr. timestampT) load_marketsrmarketwatchextend newUpdatesgetLimitfilter_by_since_limit) r"r'r(r)paramsurlr4 messageHashrequesttradess r$ watch_tradesdydx.watch_trades(s!!!iit$V$!11 ",  zz#DKK4PR]^^ ??OOF2E))& TRR "_s"B3B/AB34B15;B31B3c# UR5IShvN URSSnURU5nSUS-nSSUSS .nURX5UR Xb5U5IShvN $NbN7f) aJ unsubscribes from the trades channel https://docs.dydx.xyz/indexer-client/websockets#trades :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 ` Nrrr+r' unsubscriber-r.r/r3rr4r5r6r"r'r:r;r4r<r=s r$un_watch_tradesdydx.un_watch_tradesBs!!!iit$V$!11 !",  ZZ$++g2NP[\\\ "]"A=A9AA=4A;5A=;A=cURUS5nURU5nUSnURUS5nURUS/5nUR UR U5nUc6UR URSS5n [U 5nXR U'URXt5n [S[U 55Hn Xn URU 5 M SU-n URX5 g) Nr.r'contentsr> tradesLimitrr+) safe_string safe_market safe_dict safe_list safe_valuer> safe_integerrr parse_tradesrangelenappendresolve)r"clientmessagemarketIdr4r'content rawTradesstoredr) parsedTradesiparsedr<s r$ handle_tradesdydx.handle_tradesWs.##GT2!!(+!..*5NN7Hb9 f5 >%%dllM4HE&F"(KK ((; q#l+,A!_F MM& !-$f, v+r&cbURURUS55nURURUS5UUURU5URUS5SUR US5UR US5SURUS5URUS5SSS. U5$) N createdAtr.r'r0sidepricesize) r.infor2datetimer'orderr0rd takerOrMakerreamountcostfee) parse8601rL safe_tradeiso8601safe_string_lower)r"trader4r2s r$parse_ws_tradedydx.parse_ws_tradesNN4#3#3E;#GH ""5$/" Y/&&vx8**5&9**5&9 %%eW5&&uf5   r&c# UR5IShvN URSSnURU5nSUS-nSSUSS .nURXFUR Xs5U5IShvN nUR 5$NrN7f) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.dydx.xyz/indexer-client/websockets#orders :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 Nrr orderbook:r'r, v4_orderbookr.r/)r3rr4r5r6r)) r"r'r)r:r;r4r<r= orderbooks r$watch_order_bookdydx.watch_order_books!!!iit$V$"VH%55 %,  **St{{77SU`aa    "bs"B B AB 4B 5B  B c# UR5IShvN URSSnURU5nSUS-nSSUSS .nURX5UR Xb5U5IShvN $NbN7f) a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.dydx.xyz/indexer-client/websockets#orders :param str symbol: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrrrvr'rBrwr.r/rCrDs r$un_watch_order_bookdydx.un_watch_order_books!!!iit$V$"VH%55 !%,  ZZ$++g2NP[\\\ "]rGrWcURUS5nURU5nUSnURUS5nURURU5nUcUR 5nXWS'UR US/5nUR US/5n URUSU5 URUSU 5 URUS5US'SU-n XpRU'URXz5 g) Nr.r'rIasksbids message_idnoncerv) rLrMrNrP orderbooks order_bookrO handle_deltasrQrV) r"rWrXrYr4r'rZrxrrr<s r$handle_order_bookdydx.handle_order_books0##GT2!!(+!..*5OODOOV<  )I$(~~gvr2~~gvr2 9V,d3 9V,d3!..w E '"V+ "+y.r&c[U[5(a6URUS5nURUS5nURX45 gUR USS5nUR U5 g)Nrrerf) isinstancelist safe_floatstore parse_bid_ask storeArray)r"booksidedeltarerkbidAsks r$ handle_deltadydx.handle_deltas] eT " "OOE1-E__UA.F NN5 )''w?F    'r&1mc# UR5IShvN URSSnURU5nSUS-nURURX"5n SSUSS -U -S .n UR XhUR X5U5IShvN n UR(aU RX5nURXUS S 5$NN<7f) aK watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.dydx.xyz/indexer-client/websockets#candles :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 Nrrohlcv:r'r, v4_candlesr./r/rT) r3rr4rL timeframesr5r6r7r8r9) r"r' timeframer(r)r:r;r4r< resolutionr=ohlcvs r$ watch_ohlcvdydx.watch_ohlcvs!!!iit$V$!11 %%dooyL #,$z1  jj4;;w3OQ\]] ??NN61E))%q$GG "^s"CCA?CC;CCcB# UR5IShvN URSSnURU5nSUS-nURURX"5nSSUSS -U-S .nUR XFUR X5U5IShvN $NN7f) aL unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.dydx.xyz/indexer-client/websockets#candles :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume Nrrrr'rBrr.rr/)r3rr4rLrr5r6) r"r'rr:r;r4r<rr=s r$un_watch_ohlcvdydx.un_watch_ohlcvs!!!iit$V$!11 %%dooyL !#,$z1  ZZ$++g2NP[\\\ "]s"BBA?BBBBcURUS5nURS5nURUS5nURU5nURUS5nURU5nUSn UR US5n UR U S5n SU -n UR U SU 5n UR X5nURURU 05URU 'URURU U5nUc9URURS S 5n[U5nXRU U'URU5 URX5 g) Nr.rrrr'rIcandlesr OHLCVLimitrK)rLsplitfind_timeframerMrNrO parse_ohlcvrPohlcvsrQrrrUrV)r"rWrXr.partintervalrrYr4r'rZrr<rr_r\r)s r$ handle_ohlcvdydx.handle_ohlcv.sFh  gt ,xx}##D!,''1 ##D!,!!(+!..*5..)4' w73!!%0"oodkk62F FV!4i@ >%%dllL$GE*51F-3KK  * fv+r&cURUS5n[URS-U-5e![anUR U5 SnAgSnAff=f)NrX T)rLr r. Exceptionreject)r"rWrXmsges r$handle_error_messagedydx.handle_error_messagewsS ""7I6C#  34 4  MM!   s-/ AAAcURUS5nUS:XaURX5 gUbTURUS5nURURURS.nUR XT5nUb U"X5 ggg)Nr0errorr1)r-rwr)rLrr`rrrP)r"rWrXr0topicmethodsmethods r$handle_messagedydx.handle_messages0 7?  % %f 6   $$Wi8E!// $ 6 6"//G __W4F!v'" r&)N)__name__ __module__ __qualname____firstlineno__rr!strrr rr?rEr`rsrryr|r rrrrrrrr__static_attributes__ __classcell__)r#s@r$r r sB # 0<@d[]SSSSSbfglbmS49;]C]s]*&,P:@DB!S!!S\!.=?]]3]*'/'/R(8<$]ajlHHCHWZHquvzq{H8;?r]3]c]0G,6G,R6 (V((r&r )ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrr!ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportr rr&r$rs6 N664*G(4   " "G(r&