E#ilSSKrSSKJrJrJrJr SSKrSSKJ r J r J r J r J r JrJrJrJrJrJr SSKJr SSKJr SSKJr "SS\R4R65rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTrade)Client)List) ExchangeErrorc F^\rSrSrS\4U4SjjrS\4SjrS\S\S\ S\4S jr 04S \S\ 4S jjr S\4S jr S*SjrSS S 04S \S\S\S\\4SjjrS\4SjrS*S\4SjjrS 04S \S\S\4SjjrS\4SjrSrS S 04S \S\S\S\\4SjjrS\4SjrS*Sjr04Sjr04S\4SjjrS\4Sjr Sr!S S S 04S\"S\S\S\\#4S jjr$S!r%S 04S"\\S\\S\\#4S#jjr&S*S$jr'S S S 04S \(S\S\S\\)4S%jjr*S\4S&jr+S*S\)4S'jjr,S\S\-4S(jr.S)r/U=r0$)+arkhamreturnc>UR[[U]5SSSSSSSSSSSSS. SSS00SSS S .0S S 0S .5$)NTF) ws watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTrades watchTicker watchTickers watchBalanceapirzwss://arkm.com/wsrdi)depthinterval keepAlivei)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s I/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/arkham.pyr1arkham.describesfd < >#)."&,1"(-#!&# % $ - ! ##V5A   clientc TURX5(agURURURURUR UR URURS.nURUS5nUS:XagURX45nUb U"X5 gg)N)tickercandles l2_updatestradesbalances positionsorder_statusestrigger_orderschannel confirmations) handle_error_message handle_ticker handle_ohlcvhandle_order_book handle_tradeshandle_balancehandle_positions handle_order safe_string safe_value)r2r7messagemethodsrAmethods r4handle_messagearkham.handle_message1s  $ $V 5 5 ((((00((++.."//"//  ""7I6 o %  2   6 # r6 messageHash rawChannelparamsc# UnUUS.UR5SS.nURURSSXU5IShvN $N7f)N)rArT subscribe)argsconfirmationIdrOr&r)uuidwatchr,)r2rRrSrTsubscriptionHashrequests r4rVarkham.subscribeNsW&& #iik!  ZZ % 0 6 N^____sAA AA symbolc# UR5IShvN URU5nSUS0nSUS-nURUSURX$55IShvN $NNN7f)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://arkm.com/docs#stream/ticker :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^idticker::r9) load_marketsmarketrVextend)r2r^rTrc requestArgrRs r4 watch_tickerarkham.watch_tickerZsr!!!V$ fTl !6(#33 ^^K4;;v;Z[[[ " \s"A)A%A A) A'!A)'A)cURUS05nURUS5nURUS5nUSnURX55nXpRU'UR USU-5 g)Ndatar^ra) safe_dictrK safe_marketparse_ws_tickertickersresolve)r2r7rMrimarketIdrcr^r9s r4rDarkham.handle_tickerlss8~~gvr2##D(3!!(D1!%%d3% VvzF23r6Nc$URX5$N) parse_ticker)r2rMrcs r4rlarkham.parse_ws_tickers  11r61msincelimitc# UR5IShvN URU5nURURX"5nUSUS.nSUS-S-U-n UR U SUR X55IShvN n U n UR (aU RUSU5nURXUSS 5$NNB7f) a8 watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://arkm.com/docs#stream/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 Nr`)r^durationohlcv::r^::r:rT) rbrcrK timeframesrVrd newUpdatesgetLimitfilter_by_since_limit) r2r^ timeframervrwrTrc rawTimeframererRresultohlcvs r4 watch_ohlcvarkham.watch_ohlcvs!!!V$''N Tl$  &"22T9LH ~~k9dkk*>]^^ ??NN6(#3U;E))%q$GG "_s#CCA,CCACCc8URUS05nURUS5nURUS5nUSnURUS5nUR U5nSU-S-U-n UR UR U05UR U'XR U;a.URSSS5n [U 5UR UU'UR UUn URX55n U RU 5 URX5 U$) Nrir^ryrzr{rrw) rjrKrk safe_integerfindTimeframeByDurationrLohlcvs handle_optionrparse_ws_ohlcvappendrn) r2r7rMrirorcr^ryrrRrwstoredparseds r4rEarkham.handle_ohlcvs$~~gvr2##D(3!!(D1!$$T:600: &(4/); "oodkk62F F[[00&&|WdCE-B5-IDKK  *V$Y/$$T2 fv+r6c$URX5$rr) parse_ohlcv)r2rrcs r4rarkham.parse_ws_ohlcv..r6c# UR5IShvN URU5nUSSS.nSUS-nURUSURXS55IShvN nUR 5$N_N7f)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://arkm.com/docs#stream/l2_updates :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`T)r^snapshot orderBook::r^r;)rbrcrVrdrw)r2r^rwrTrcrerR orderbooks r4watch_order_bookarkham.watch_order_books!!!V$Tl $fX&66 ..lDKKPZDcdd    "es"A:A6A A:!A8"A:8A:c URUS5nURUS5nURUS5nURU5nUSnSU-nXpR;a#UR 05n XyS'XRU'URUn US:Xa;UR USS5n UR X7U SS S S 5n U RU 5 OdUS :Xa^UR US S5n URUS5n U S:XaU SOU S nURX5 XS'URU 5U S'XRU'URURUU5 g)Nrityper^rrlastTimegMbP?bidsaskspricesizeupdatetimesidebuy timestampdatetime) rjrKrk orderbooks order_booksafe_integer_productparse_order_bookreset handle_deltaiso8601rn)r2r7rMrirrorcr^rRobrrparsedOrderBookrbooksides r4rFarkham.handle_order_booksl@~~gv.0##D(3!!(+!#f, //)$B!xL&(OOF #OOF+ : 11$ EJI"33D)VU[]dflmO OOO , X 11$FI##D&1D-1U]y(6ARH   h -%.k "$(LL$;Ij !"+tv. ` Nr^r`trade::r<rT)rbrcrVrdr}r~r) r2r^rvrwrTrcrerRr<s r4 watch_tradesarkham.watch_trades+s!!!V$ fTl  &"22 ~~k8T[[=\]] ??OOF8$4eACG$NQXXG 11$++>M $++g"6 w~~W_`I!,>&8.2kk.1'l09 $   $N  ( ( 8 KK %(. /+ !sE Ec# UR5IShvN UR5IShvN SS0nSnURUSURX!55IShvN nU$NNN8N 7f)a watch balance and get the amount of funds available for trading or funds locked in orders https://arkm.com/docs#stream/balances :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: spot or contract if not provided self.options['defaultType'] is used :returns dict: a `balance structure ` NrTr=)rrbrVrd)r2rTrerRrs r4 watch_balancearkham.watch_balance|so!!!!!!  ! ~~k:t{{:?^__  "! `s1A+A%A+A'/A+A)A+'A+)A+cURUS5n0nUS:Xa.URUS5nURU5nX$S'X@lOZUR US5nU/nURU5nURUS5nUR U5nXHURU'Sn UR URUR5U 5 g)Nrrriinfor^r=)rK safe_listparse_ws_balancebalancerjsafe_currency_codern safe_balance) r2r7rMrrri balancesArray currencyIdcoderRs r4rHarkham.handle_balancesr0 : >>'62D**40F$6N!L>>'62D!FM**=9F))$9J**:6D!'DLL  t((6 Dr6c$URU5$rr) parse_balance)r2rs r4rarkham.parse_ws_balances!!'**r6symbolsc# UR5IShvN UR5IShvN SnURU5(d(URU5nUSSR U5-- n[ 5UlSS0nURUSURXd55IShvN nUR(aU$URUR XUS5$NNN97f)a https://arkm.com/docs#stream/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 ` Nr>r{,rFT) rrbis_emptymarket_symbolsjoinrr>rVrdr}filter_by_symbols_since_limit)r2rrvrwrTrRre newPositionss r4watch_positionsarkham.watch_positionss!!!!!!! }}W%%))'2G 4#((7"33 3K13  "^^KdkkR\Feff ?? 11$..'RWY]^^ "!gs2C'C!C'C#A)r>rKrrangelenparse_ws_positionrrrjfind_message_hashessplitfilter_by_arrayrrn)r2r7rMrrriipositionr^ messageHashesrRparts symbolsStringrr>lengths r4rIarkham.handle_positionssB >> !DN0 : >>'626D1c$i(11$':$$X|<A ''1!--hAF-5NN6* )>>'62D--d3H%%h9F%-NN6 "    )00G q#m,-A'*K%%d+E!!HM#))#.G,,\8WeTI==++y6.\" A: NN< 5 r6r>cURU5nURU5n/n[S[U55H8nUR UR XS5U5nUR U5 M: URUSUS5$)Nrr^F)rto_arrayrrrdrrfilter_by_array_positions)r2r>rrTrr r s r4parse_ws_positionsarkham.parse_ws_positions9s~%%g.MM), q#i.)A{{4#9#9),#MvVH MM( #*--fhOOr6c$URX5$rr)parse_position)r2r rcs r4rarkham.parse_ws_positionBs""844r6c# UR5IShvN UR5IShvN SnUbURU5nSS0nSnURUSSS5uptU(aSOSnSn Ub U S US -- n U S U-- n UR XUR Xd55IShvN n UR (aU RX5nURXX#S 5$NNN=7f) a watches information on multiple orders made by the user https://arkm.com/docs#stream/order_statuses :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 ` NrFr!triggerr@r?ordersr{r^T) rrbrchandle_option_and_paramsrVrdr}r~filter_by_symbol_since_limit) r2r^rvrwrTrcreisTriggerOrderrSrRrs r4 watch_ordersarkham.watch_ordersFs!!!!!!  [[(F  !%!>!>v}V_af!g)7%=M    4&"22 2Ktj(( ~~kt{{:?^__ ??OOF2E00tTT% "!`s2C,C&C,C(A=C,,C*-:C,(C,*C,cURUS5nURUS5nURc-URURSS5n[ U5UlURnUR U5nURU5 URUS5 URUSUS-S-U-5 URUSU-5 g) NrAri ordersLimitrrzorders::r^r{) rKrjrrr-rparse_ws_orderrrn)r2r7rMrArirwrorders r4rJarkham.handle_orderfsJ""7I6~~gv. ;; %%dllM4HE07DK##D) evx(vzE(O;dBWLMvzG34r6c$URX5$rr) parse_order)r2r$rcs r4r#arkham.parse_ws_orderrr6cURUS5nUbURU5nURUS5nURS-U-nURURSXV5 URURSX65 UR URSX65 [ URS-U-5eg)NrMr` exactbroadF)rKjsonr`throw_exactly_matched_exception exceptionsthrow_broadly_matched_exceptionr)r2r7responserMbody errorCodefeedbacks r4rCarkham.handle_error_messages""8Y7  99X&D((48Iww}t+H  0 01I9 _  0 01I7 ]  0 01I7 ]#  45 5r6)rrr>rr)1__name__ __module__ __qualname____firstlineno__rr1rrPrdictrVrrfrDrlr rlistrrErr rrFrrrrGrrrrrHrrr rrIrrrr rrJr#r rC__static_attributes__ __classcell__)r3s@r4rrs] # @$V$: `3 `C ` `RU `68\\F\$"4F"4N28<$]ajlHHCHWZHquvzq{H6!6!F/D/@DB!S!!S\!*7=7=r$<@d[]SSSSSbfglbmS.3F34/)+08*,&IEVIEV+8<$]ajl_W_C_WZ_quv~q_6>6@MQY[PDIPS P`dem`nP504$UYbdUUCUsUimnsitU@/56/5b/E/6r6r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsr async_supportrr6r4rGsH AAmmmm4*_ T   & &_ r6