ei~lddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTrade)Client)List) ExchangeErrorc "eZdZdeffd ZdefdZdedededefdZ ifd ede fd Z defd Z d(d Z dd d ifd edededeefdZdefdZd(defdZd ifd ededefdZdefdZdZd d ifd edededeefdZdefdZd(dZifdZifdefdZdefdZdZ d d d ifde!dededee"fdZ#d Z$d ifd!eedeedee"fd"Z%d(d#Z&d d d ifd e'dededee(fd$Z)defd%Z*d(de(fd&Z+dede,fd'Z-xZ.S))arkhamreturnc|tt|ddddddddddddd dddiiddd d id d id S)NTF) ws watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTrades watchTicker watchTickers watchBalanceapirzwss://arkm.com/wsrdi)depthinterval keepAlivei)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/arkham.pyr0zarkham.describesfd 3 3 < < > >#)."&,1"(-#!&# % $  - ! ###V5A A    clientc $|||rdS|j|j|j|j|j|j|j|jd}||d}|dkrdS| ||}||||dSdS)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)r1r5messagemethodsr?methods r3handle_messagezarkham.handle_message1s  $ $VW 5 5  F((0(+."/"/   ""7I66 o % % F '22   F67 # # # # #  r4 messageHash rawChannelparamscK|}||d|dd}||jdd|||d{VS)N)r?rQ subscribe)argsconfirmationIdrMr%r)uuidwatchr+)r1rOrPrQsubscriptionHashrequests r3rSzarkham.subscribeNss&& #iikk!   ZZ % 0 6 WN^_________r4symbolcK|d{V||}d|di}d|dz}||d|||d{VS)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 ` NrZidticker::r7) load_marketsmarketrSextend)r1rZrQr_ requestArgrOs r3 watch_tickerzarkham.watch_tickerZs!!!!!!!!!V$$ fTl !6(#33 ^^K4;;vz;Z;Z[[[[[[[[[r4c||di}||d}||d}|d}|||}||j|<||d|zdS)NdatarZr]) safe_dictrI safe_marketparse_ws_tickertickersresolve)r1r5rKrdmarketIdr_rZr7s r3rBzarkham.handle_tickerls8~~gvr22##D(33!!(D11!%%dF33% VvzF233333r4Nc.|||SN) parse_ticker)r1rKr_s r3rgzarkham.parse_ws_tickers  &111r41msincelimitcK|d{V||}||j||}|d|d}d|dzdz|z} || d|||d{V} | } |jr| |d|}|| ||dd S) a 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\)rZdurationohlcv::rZ::r8rT) r^r_rI timeframesrSr` newUpdatesgetLimitfilter_by_since_limit) r1rZ timeframerorprQr_ rawTimeframerarOresultohlcvs r3 watch_ohlcvzarkham.watch_ohlcvs!!!!!!!!!V$$''INN Tl$   &"22T9LH ~~k9dkk*V\>]>]^^^^^^^^ ? <NN6(#3U;;E))%q$GGGr4c~||di}||d}||d}|d}||d}||}d|zdz|z} ||j|i|j|<||j|vr4|ddd} t| |j||<|j||} | ||} | | | | | |S) NrdrZrrrsrtrrp) rerIrf safe_integerfindTimeframeByDurationrJohlcvs handle_optionrparse_ws_ohlcvappendri) r1r5rKrdrjr_rZrrryrOrpstoredparseds r3rCzarkham.handle_ohlcvs:$~~gvr22##D(33!!(D11!$$T:6600:: &(4/); "oodk62FF FT[000&&|WdCCE-B5-I-IDK  *V$Y/$$T622 fv{+++r4c.|||Srl) parse_ohlcv)r1r|r_s r3rzarkham.parse_ws_ohlcvv...r4cK|d{V||}|ddd}d|dz}||d|||d{V}|S)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)rZsnapshot orderBook::rZr9)r^r_rSr`rp)r1rZrprQr_rarO orderbooks r3watch_order_bookzarkham.watch_order_books!!!!!!!!!V$$Tl  $fX&66 ..lDKKPZ\bDcDcdddddddd    r4c ,||d}||d}||d}||}|d}d|z}||jvr$|i} || d<| |j|<|j|} |dkrH||dd} |||| dd d d } | | n||d krv||d d} ||d} | dkr| dn| d }|||| | d<| | | d<| |j|<| |j||dS)NrdtyperZrrlastTimegMbP?bidsaskspricesizeupdatetimesidebuy timestampdatetime) rerIrf orderbooks order_booksafe_integer_productparse_order_bookreset handle_deltaiso8601ri)r1r5rKrdrrjr_rZrOobrrparsedOrderBookrbooksides r3rDzarkham.handle_order_books@~~gv..00##D(33!!(++!#f, $/))$$B!BxL&(DOF #OF+ :  11$ EJJI"33D&)VU[]dflmmO OOO , , , , X  11$FFI##D&11D-1U]]y((6ARH   h - - -%.Ik "$(LL$;$;Ij !"+tv. <<<<` NrZr\trade::r:rT)r^r_rSr`rvrwrx) r1rZrorprQr_rarOr:s r3 watch_tradeszarkham.watch_trades+s!!!!!!!!!V$$ fTl  &"22 ~~k8T[[U[=\=\]]]]]]]] ? =OOF8$4e<>ACG$NQXXG 11$+>>M $++g"6"6 w~W_``I!,>&8.2k.1'll09 $$   $N  ( ( 8 8 8 KK %(. / / / / /+ ! r4cK|d{V|d{Vddi}d}||d|||d{V}|S)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;)rr^rSr`)r1rQrarOr{s r3 watch_balancezarkham.watch_balance|s!!!!!!!!!!!!!!!!!!  ! ~~k:t{{:W]?^?^________ r4c||d}i}|dkr8||d}||}||d<||_ni||d}|g}||}||d}||}|||j|<d} |||j| dS)NrrrdinforZr;)rI safe_listparse_ws_balancebalanceresafe_currency_coderi safe_balance) r1r5rKrrrd balancesArray currencyIdcoderOs r3rFzarkham.handle_balancesr00 :  >>'622D**400F$F6N!DLL>>'622D!FM**=99F))$99J**:66D!'DL  t((66 DDDDDr4c,||Srl) parse_balance)r1rs r3rzarkham.parse_ws_balances!!'***r4symbolscK|d{V|d{Vd}||s0||}|dd|zz }t |_ddi}||d|||d{V}|j r|S| |j|||dS)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<rt,rFT) rr^is_emptymarket_symbolsjoinrr<rSr`rvfilter_by_symbols_since_limit)r1rrorprQrOra newPositionss r3watch_positionszarkham.watch_positionss!!!!!!!!!!!!!!!!!!! }}W%% 4))'22G 4#((7"3"33 3K133  "^^KdkkR\^dFeFeffffffff ?  11$.'5RWY]^^^r4c"g}|ji|_||d}|dkr||dg}tdt |D]l}|||}||ddkr5||||d}||j|<mn`||d}||}||d}||j|<||| |d} tdt | D]}| |} | d} | d } | d } | |d| d }| |s| || t |}|dkr| |d dSdS) Nrrrdr entryPricerZz positions::rtrFr<)r<rIrrangelenparse_ws_positionrrrefind_message_hashessplitfilter_by_arrayrri)r1r5rKrrrdipositionrZ messageHashesrOparts symbolsStringrr<lengths r3rGzarkham.handle_positionssB > !DN00 :  >>'6266D1c$ii(( 6 611$q'::$$X|<<AA ''111!--hAAF-5DN6*  6>>'622D--d33H%%h99F%-DN6 "    ) ) )00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666\"" A:: NN< 5 5 5 5 5 :r4r<cT||}||}g}tdt|D]G}||||d|}||H||d|dS)NrrZF)rto_arrayrrr`rrfilter_by_array_positions)r1r<rrQr{rrs r3parse_ws_positionszarkham.parse_ws_positions9s%%g..MM),, q#i..)) $ $A{{4#9#9)A,#M#MvVVH MM( # # # #--fhOOOr4c.|||Srl)parse_position)r1rr_s r3rzarkham.parse_ws_positionBs""8V444r4cK|d{V|d{Vd}|||}ddi}d}||ddd\}}|rdnd}d} || d |d zz } | d |zz } || ||||d{V} |jr| ||}|| |||d S) 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=ordersrtrZT) rr^r_handle_option_and_paramsrSr`rvrwfilter_by_symbol_since_limit) r1rZrorprQr_raisTriggerOrderrPrOrs r3 watch_orderszarkham.watch_ordersFsM!!!!!!!!!!!!!!!!!!  [[((F  !%!>!>v}V_af!g!g)7M%%=M    4&"22 2Ktj(( ~~k:t{{:W]?^?^________ ? 3OOFE22E00tTTTr4c||d}||d}|j0||jdd}t ||_|j}||}||||d||d|dzdz|z||d|zdS) Nr?rd ordersLimitrrzorders::rZrt) rIrerrr,rparse_ws_orderrri)r1r5rKr?rdrprorders r3rHzarkham.handle_orderfsJ""7I66~~gv.. ; %%dlM4HHE077DK##D)) evx(((vzE(O;dBWLMMMvzG344444r4c.|||Srl) parse_order)r1r r_s r3r zarkham.parse_ws_orderrr4c||d}|||}||d}|jdz|z}||jd||||jd||||jd||t |jdz|zdS)NrKr\ exactbroadF)rIjsonr\throw_exactly_matched_exception exceptionsthrow_broadly_matched_exceptionr)r1r5responserKbody errorCodefeedbacks r3rAzarkham.handle_error_messages""8Y77  99X&&D((488Iw}t+H  0 01I9V^ _ _ _  0 01I7T\ ] ] ]  0 01I7T\ ] ] ]#  455 5ur4rl)/__name__ __module__ __qualname__rr0rrNrdictrSrrbrBrgr rlistr}rCrr rrDrrrrErrrrrFrrr rrGrrrr rrHr r rA __classcell__)r2s@r3rrsW #      @$V$$$$: `3 `C ` `RU ` ` ` `68\\\F\\\\$"4F"4"4"4"4N22228<$]ajlHHHCHWZHquvzq{HHHH6!6!!!!F//D////@DB!!S!!S\!!!!*7=7=7=7=7=r$$$<@d[]SSSSSSbfglbmSSSS.3F33334////)+00008*,&IEVIEIEIEIEV+++8<$]ajl__W_C_WZ_quv~q____6>6>6>6@MQY[PPDIPS P`dem`nPPPP555504$UYbdUUUCUsUimnsitUUUU@/56/5/5/5/5b//E////6r4r)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_supportrr4r3r)s, AAAAAAAAAAAAmmmmmmmmmmmmmmmmmmmmmmmmmm444444******_ _ _ _ _ T  &_ _ _ _ _ r4