eiY^ddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lm Z dd lm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddl(m)Z)Gddej*j+Z+dS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesBoolIntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)PermissionDenied)AccountSuspended)ArgumentsRequired) BadRequest) BadSymbol)InsufficientFunds) InvalidOrder) OrderNotFound) NotSupported)RateLimitExceeded)ExchangeNotAvailable) ChecksumError)PreciseceZdZdeffd Zdifdededededed ef d Zdifdede d e de d ede f d Z d Zddifdedede d e ded ede fdZdifdeedefdZdifdedede fdZdZdifdedee fdZdZdZdefdZdefdZdZifdedefdZdifdedefdZ difdedefdZ!ddifdede"d e"dee#fd!Z$ddifdeede"d e"dee#fd"Z%difded e"de&fd#Z'difdeed e"de&fd$Z(d%ddifded&ede"d e"dee)f d'Z*d(iffd) Z+defd*Z,defd+Z-ifd,Z.defd-Z/defd.Z0d/Z1d0Z2defd1Z3ifd2Z4dddifdede"d e"fd3Z5dddifdede"d e"dee#fd4Z6dEdefd5Z7dEd6Z8dddifdede"d e"dee fd7Z9dEdefd8Z:dEd9Z;ddifd:ed;edefd<Zdefd>Z?dFd?ed@edefdAZ@defdBZAdedeBfdCZCdefdDZDxZES)Gkrakenreturnc|tt|iddddddddddddddd dd dd dd dd ddddddddddddddddddddiidddiddid|jdd dd!t iid"t d#t d$t d%t d&t d't d(t d)t d*t d+t d,t d-t d.t d/t d0t d1td2tid3td4td5td6td7td8t d9td:td;tdtd?td@tdAtdBtdCtttttttt t t tt tdD dEidFS)GNwsT watchBalance watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbols createOrderWs editOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWsapizwss://ws.kraken.comzwss://ws-auth.kraken.comzwss://ws-auth.kraken.com/v2zwss://ws.kraken.com/v2zwss://beta-ws.kraken.comzwss://beta-ws-auth.kraken.com)publicprivate privateV2publicV2betaz beta-privatechecksumF) tradesLimit OHLCVLimit ordersLimitsymbolsByOrderIdr-ip)ping keepAlivezEvent(s) not foundzAlready subscribedz'Currency pair not in ISO 4217-A3 formatzCurrency pair not supportedzMalformed requestzPair field must be an arrayz1Pair field unsupported for self subscription typezPair(s) not foundz*Subscription book depth must be an integerz Subscription depth not supportedz$Subscription field must be an objectzSubscription name invalidz%Subscription object unsupported fieldz-Subscription ohlc interval must be an integerz(Subscription ohlc interval not supportedz#Subscription ohlc requires intervalzEAccount:Invalid permissionsz EAuth:Account temporary disabledzEAuth:Account unconfirmedzEAuth:Rate limit exceededzEAuth:Too many requestsz+EDatabase: Internal error(to be deprecated)z EGeneral:Internal error[:]zEGeneral:Invalid argumentsz$EOrder:Cannot open opposing positionzEOrder:Cannot open positionz2EOrder:Insufficient funds(insufficient user funds)z[EOrder:Insufficient margin(exchange does not have sufficient funds to allow margin trading)zEOrder:Invalid pricez EOrder:Margin allowance exceededzEOrder:Margin level too lowzaEOrder:Margin position size exceeded(client would exceed the maximum position size for self pair)z,EOrder:Order minimum not met(volume too low)zEOrder:Orders limit exceededzEOrder:Positions limit exceeded) zEOrder:Rate limit exceededz&EOrder:Scheduled orders limit exceededzEOrder:Unknown positionzEOrder:Unknown orderzEOrder:Invalid orderzEService:Deadline elapsedz#EService:Market in cancel_only modez"EService:Market in limit_only modez!EService:Market in post_only modezEService:UnavailablezETrade:Invalid requestzESession:Invalid session)exactbroad)hasurlsoptions streaming exceptions) deep_extendsuperr&describerFrrrrrr!rrrrr"r )self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/kraken.pyrQzkraken.describesfd 3 3 < < > >d d  !$  +D tt t( t  !$!"$T#,"7#=%B$< :(G    $"#$&#  ! ,j/,j/A9/6y/,Z / 6z / LZ /,Y/Ej/;J/? /4Z/@/H/CJ/>z/ 78H!/";|~J?/@G A/B7 C/D:J=I0D2<4G]/// 446eiA iA i i i Nmethodsymboltyperequestamountpricec|d}|rK|t|jdz|||||dd<|dk} d} || d|\} }| r d|dd<||d } | | |dd <||d } | 2|||| |dd <||d i} ||di}|| d}||d}|| d}||d}|du}|du}||d}||d}|du}|du}||d}||d}||d}||d}|du}|du}|du}|du} ||dd}!||!| |znd}"||!| |znd}#||!| |znd}$||!| |znd}%|s| rdnd}&|dkrW| |d}'|'r d|dd<| |d}(|( |(|dd<| |ddg}|s |s|s|s|s| r i|dd <|s|rSi|dd!<|rJd"|dd!d#<|||||dd!d$<nK|rId%|dd!d#<|||||dd!d$<|Jd&|dd!d#<|||||dd!d<nK|Id'|dd!d#<|||||dd!d<| |d dg}n|s|r|rT|||||dd d<|r d&|dd#<nnd"|dd#<na|||||dd d<|r d'|dd#<nd%|dd#<n |s|s|s| r|&|dd d(<|s]|s|rYd)|dd#<|r&||"|dd d<n||#|dd d<n|&|dd*<d+|dd#<|r&||$|dd d<nW||%|dd d<n1|d,kr*|s|rt|jd-z|s|rh|r3|||||dd$<n|||||dd$<n|s|s|s| r|&|dd.<|sD|s|r@|r||"|dd$<ni||#|dd$<nJ|&|dd*<|r||$|dd$<n||%|dd$<| |gd/}||gS)0Nlimitz& limit orders require a price argumentparams limit_pricemarketFT post_only clientOrderId cl_ord_idcost order_qtystopLoss takeProfit triggerPricer[ stopLossPricetakeProfitPricetrailingAmounttrailingPercenttrailingLimitAmounttrailingLimitPercentoffsetpctquoter5 reduceOnly reduce_only timeInForce time_in_forcetriggers conditionalz stop-loss order_type trigger_pricez take-profitzstop-loss-limitztake-profit-limit price_typez trailing-stoplimit_price_typeztrailing-stop-limitr6zR editing the stopLoss and takeProfit on existing orders is currently not supportedtrigger_price_type) rbrdrorirjrkrlrmrn)endswithridparse_to_numericprice_to_precisionhandle_post_only safe_stringcost_to_precision safe_dictnumber_to_string safe_boolsafe_string_loweromitr ))rRrVrWrXrYrZr[r^ isLimitOrderisMarketpostOnlyrbrdrfrgpresetStopLosspresetTakeProfitpresetStopLossLimitpresetTakeProfitLimitisPresetStopLossisPresetTakeProfitrirjisStopLossPriceOrderisTakeProfitPriceOrderrkrlrmrnisTrailingAmountOrderisTrailingPercentOrderisTrailingLimitAmountOrderisTrailingLimitPercentOrderrotrailingAmountStringtrailingPercentStringtrailingLimitAmountStringtrailingLimitPercentString priceTypersrus) rTorder_request_wszkraken.order_request_wss }}W--  m}'2Z(Z[[[/3/D/DTE\E\]cejEkEk/l/lGH m ,H$005&II&  2-1GH k *((AA  $-:GH k *//  -1-B-B4CYCYZ`bfCgCg-h-hGH k *>>&*b99^^FL"== ))(NCC++JGG"..xAA $ 0 0W E E)5-T9((AA **63DEE,D8!0!<))&2BCC**63DEE"..v7LMM#//8NOO .d :!0!<%8%D"&:$&F#!!&(B77R`Rlv(=(=n(M(MMMswTcTo)>)>)O)O O Ovz\o\{FT-B-BCV-W-W$W$WCG!^r^~Vd.C.CDX.Y.Y%Y%YFJ"4a8SaEEZa _ $ $ ==J 837!-000GGK&5@!/2YYv m'DEEF# 3'= 3AV 3Zp 3uO 3Sn 302!*-+ s#5+ s35!-0#QEPGH%m4\BHLH]H]^b^u^uv|M_N_NIOIOGH%m4_EE'QERGH%m4\BHLH]H]^b^u^uv|O_P_PIQIQGH%m4_E&2EVGH%m4\BFJF[F[\`\s\stz}P]Q]QGRGRGH%m4]CC*6EXGH%m4\BFJF[F[\`\s\stz}R]S]SGTGTGH%m4]C6J +EFF% s)? s' H=A=R=RSWSjSjkqtATBTB>C>CGH%j1':#F:K),77:E),77=A=R=RSWSjSjkqtCTDTD>E>EGH%j1':#H:M),77:G),77& s*@ sD^ sb} s>G!*-l;# s)> sBX s6EGH%l3,nAEAVAVWkAlAl)*5g>>AEAVAVWlAmAm)*5g>>=FGH%&896KGH%l31sAEAVAVWpAqAq)*5g>>AEAVAVWqArAr)*5g> } $ $ C#5 C"47.B$BCCC# o'= o'A9=9N9NtOfOfgmo|O}O}9~9~GH%o669=9N9NtOfOfgmo~OO:A:AGH%o66& o*@ oD^ ob} o:C!"67# o)> oBX o,j=A=R=RSg=h=h)/::=A=R=RSh=i=i)/::` Nr:r)r= add_orderrW)ryrrerWtokenrVr^req_idr5) load_markets authenticater`rK request_idrramount_to_precisionrwatchextend) rRrWrXrrZr[r^rr`url requestId messageHashrYs rTcreate_order_wszkraken.create_order_wssJ!!!!!!!!!''))))))))V$$it$[1OO%% ++I66 !"!2243K3KFTZ3[3[\\ *     //wX^`egmnnZZ[$++gv2N2NP[\\\\\\\\\rUc||di}||}||dd}|||dS)Nresultreqidr)r parse_order safe_string_2resolve)rRclientmessagerorderrs rThandle_create_edit_orderzkraken.handle_create_edit_order%s]6266  (((('8DD uk*****rUrc K|d{V|d{V}|jddd} |} || } d||||||d| d} |d||| |||\} }|| | | | || d{VS) a edit a trade order https://docs.kraken.com/api/docs/websocket-v2/amend_order :param str id: order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of the currency you want to trade in units of the base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` Nr:r)r= amend_order)order_idrerrr6) rrrKrrrrrrr) rRrrWrXrrZr[r^rrrrrYs rT edit_order_wszkraken.edit_order_wsEs.!!!!!!!!!''))))))))it$[1OO%% ++I66 #!2243K3KFTZ3[3[\\    // vtWV\^cekllZZ[$++gv2N2NP[\\\\\\\\\rUidscK|t|jdz|d{V|d{V}|jddd}|}||}d||d|d}|||||||d{VS) a cancel multiple orders https://docs.kraken.com/api/docs/websocket-v2/cancel_order :param str[] ids: order ids :param str [symbol]: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an list of `order structures ` NzK cancelOrdersWs() does not support cancelling orders for a specific symbol.r:r)r= cancel_orderrrr r rrrrKrrrr) rRrrWr^rrrrrYs rTcancel_orders_wszkraken.cancel_orders_wses  tw)vvww w!!!!!!!!!''))))))))it$[1OO%% ++I66 $   ZZ[$++gv2N2NP[\\\\\\\\\rUcK|t|jdz|d{V|d{V}|jddd}|}||}d|g|d|d}|||||||d{VS) a cancels an open order https://docs.kraken.com/api/docs/websocket-v2/cancel_order :param str id: order id :param str [symbol]: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` NzJ cancelOrderWs() does not support cancelling orders for a specific symbol.r:r)r=rrrr) rRrrWr^rrrrrYs rTcancel_order_wszkraken.cancel_order_wss  tw)uuvv v!!!!!!!!!''))))))))it$[1OO%% ++I66 $D   ZZ[$++gv2N2NP[\\\\\\\\\rUc^||d}|||dSNrrrrRrrreqIds rThandle_cancel_orderzkraken.handle_cancel_order3  (33w&&&&&rUcK|t|jdz|d{V|d{V}|jddd}|}||}dd|i|d}|||||||d{VS) a cancel all open orders https://docs.kraken.com/api/docs/websocket-v2/cancel_all :param str [symbol]: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NzM cancelAllOrdersWs() does not support cancelling orders in a specific market.r:r)r= cancel_allrrr)rRrWr^rrrrrYs rTcancel_all_orders_wszkraken.cancel_all_orders_wss  tw)xxyy y!!!!!!!!!''))))))))it$[1OO%% ++I66 "   ZZ[$++gv2N2NP[\\\\\\\\\rUc^||d}|||dSrrrs rThandle_cancel_all_orderszkraken.handle_cancel_all_ordersrrUct||dg}|d}||d}|dd|}||d}d}||d} | |tj| |}||d} |id|ddd dd ||d d ||d d ||d d ||dd||dd||dd|ddd| d| ddd||dd||ddd| ||d} | |j|<|| |dS)NdatarrWtickervwapvolumelast timestampdatetimehighlowbid bidVolumebid_qtyask askVolumeask_qtyopenclose previousClosechange percentage change_pctaverage) baseVolume quoteVolumeinfo) safe_listrget_message_hashr$ string_mul safe_tickertickersr) rRrrrrrWrrrrrrs rT handle_tickerzkraken.handle_tickersS.~~gvr22a!!&(33++HdFCC // %%fh77  !d&6!,Z>>K//!!# f# #  #  D$$VV44 # 4##FE22 # 4##FE22 #  ))&)<<#  4##FE22#  ))&)<<#  D#  D#  T#  D#  T#  d&&vx88# $**6<@@!# " t## $%&)# # #   , & Vv{+++++rUrc:||dg}|d}||d}|dd|}||j|}|5||jdd}t|}||j|<||} | || } tdt| D]} | | | | ||dS)NrrrWtraderBr@)rrr safe_valuetrades safe_integerrLrr` parse_tradesrangelenappendr) rRrrrrrWrstoredr]r`parsedis rT handle_tradeszkraken.handle_tradess$~~gvr22Q!!%22++GT6BB f55 >%%dlM4HHE&&F"(DK V$$""400q#f++&& % %A MM&) $ $ $ $v{+++++rUc ,||dg}|d}||d}||}||jvr i|j|<||d}||}|dd|} ||j||} ||j|i|j|<| ;||jdd} t| } | |j||<t|} td| D]} || | z dz }||d }| |}|||d ||d ||d ||d ||dg}| ||| | dS)NrrrWintervalohlcvrCr@rrrrrr)rr safe_symbolohlcvsrfind_timeframerrrLrrr parse8601rr)rRrrrfirstmarketIdrWr timeframerrr] ohlcvsLengthrcandlerrrs rT handle_ohlcvzkraken.handle_ohlcv2s.~~gvr22Q##E844!!(++$+%%"$DK $$UJ77''11 ++GT6BB V!4i@@"oodk62FF F >%%dlL$GGE*511F-3DK  *4yy q,'' " "A,*Q./F'' <` N)rrW watch_tickers)rRrWr^rs rT watch_tickerzkraken.watch_tickerpsp!!!!!!!!!V$$**F8V<<<<<<<<vrUsymbolsc K|d{V||dd}|dd|d|d{V}|jri}|||d<|S||jd|S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.kraken.com/api/docs/websocket-v2/ticker :param str[] symbols: :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NFrrW)rmarket_symbolswatch_multi_helper newUpdatesfilter_by_arrayrrRrr^rrs rTrzkraken.watch_tickerss!!!!!!!!!%%gtU;;..x7DRXYYYYYYYY ? F'-F6(# $M##DL(GDDDrUcK|d{V||dd}d|d<|dd|d|d{V}|jri}|||d<|S||jd|S)at watches best bid & ask for symbols https://docs.kraken.com/api/docs/websocket-v2/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 ` NFbbo event_triggerbidaskrrW)rrrrrbidsasksrs rTwatch_bids_askszkraken.watch_bids_askss!!!!!!!!!%%gtU;;"'..x7DRXYYYYYYYY ? F'-F6(# $M##DM8WEEErUsincer]cDK||g|||d{VS)a get the list of most recent trades for a particular symbol https://docs.kraken.com/api/docs/websocket-v2/trade :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 ` N)watch_trades_for_symbolsrRrWr r]r^s rT watch_tradeszkraken.watch_tradess622F8UE6RRRRRRRRRrUcK|dd|d|d{V}|jrB||d}||d}|||}||||ddS)a get the list of most recent trades for a list of symbols https://docs.kraken.com/api/docs/websocket-v2/trade :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 :returns dict[]: a list of `trade structures ` rNrrWrT)rrrrgetLimitfilter_by_since_limit)rRrr r]r^rr tradeSymbols rTr"zkraken.watch_trades_for_symbolss..w$PVWWWWWWWW ? 8NN61--E**5(;;KOOK77E))&% TRRRrUcBK||g||d{VS)a. watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kraken.com/api/docs/websocket-v2/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 N)watch_order_book_for_symbols)rRrWr]r^s rTwatch_order_bookzkraken.watch_order_books466xOOOOOOOOOrUc Ki}|5||gdr||d<nt|jdz|dd|d|i|||d{V}|S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kraken.com/api/docs/websocket-v2/book :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 N) dir@depthzF watchOrderBook accepts limit values of 10, 25, 100, 500 and 1000 only orderbookbookr])in_arrayr rrrr])rRrr]r^requiredParamsr1s rTr*z#kraken.watch_order_book_for_symbolss "  }}U$<$<$<== w*/w''"47-u#uvvv11+vwQXZ_P`bfbmbmn|EcFcFGGGGGGGG    rU1mrcK|d{Vd}||}|d}|jddd}|} |dd|} d||g||j||d | d } || |} ||| | | d{V} |j r| ||}| | ||d d S) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.kraken.com/api/docs/websocket-v2/ohlc :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 NohlcrWr:r)r>r subscribe)channelrWrrrT) rr`rKrrr timeframesrOrrr&r')rRrWrr r]r^namer`rrrr8rYrs rT watch_ohlcvzkraken.watch_ohlcvs<!!!!!!!!!V$$!it$Z0OO%% ++GT6BB !!( OODOY RR    ""9f55jjk7KHHHHHHHH ? 2NN6511E))%{DQQQrUFcKtt|||d{V}||jd}||r}i}t dt |jD]N}|j|}|j|}||di}| |d} ||| <O||jd<|S)NmarketsByWsNamerrwsname) rPr&rrrLrrrmarketsr) rRreloadr^r@r>rrWr`rwsNamerSs rTrzkraken.load_markets sfd++88HHHHHHHH//$,8IJJ  # # O1c$,//00 1 1af-vvr::))$99*0''.=DL* +rUc`|j}i}|ddkrd|d<nd|d<|S)Nv2rrFrVevent)rfind)rRrrrYs rTrFz kraken.pings?j 88D>>Q   &GH  %GG rUc8||_|SN) millisecondslastPongrRrrs rT handle_pongzkraken.handle_pong"s++--rUcK|d{Vd}|jddd}|||d{VS)N heartbeatr:r)r>)rrKr)rRr^rErs rTwatch_heartbeatzkraken.watch_heartbeat&sk!!!!!!!!!it$Z0ZZU+++++++++rUc^||d}|||dS)Nr9r)rRrrrEs rThandle_heartbeatzkraken.handle_heartbeat,s3   )44w&&&&&rUc||d}||dg}||di}||d}||dg}||dg}||d} |dd|} d} |d kr|j|} | d} | d} ||| |||| |||d }|| d<||| d <|| d <nt|}| i||j|<|j|} ddg}tdt|D]R}||}| |}|||g}t|dkr|||S|| d<| | d dd }|rg}| | d}| d}tddD]e}|||i}||d||dz}||ftddD]e}|||i}||d||dz}||fd|}||d }|| krUt%|jdz||z}|j| =|j|=||| dS|| | dS)NrXrrrWasksbidsrAr1updaterrr-Fr-rrp )rrrrrr orderbookscustom_handle_deltasrr order_bookrr] handle_option format_numberrjoincrc32r#rorderbook_checksum_message subscriptionsrejectr) rRrrrXrrrWabcrr1 storedAsks storedBidsrr0keysrkeybooksidedeltasrA payloadArray checkAsks checkBids currentAsk formattedAsk currentBid formattedBidpayload localChecksumerrors rThandle_order_bookzkraken.handle_order_book5sp00~~gvr22tQ++!!%22 OOE62 . . OOE62 . .   eZ 0 0++KvFF  8  /I"6*J"6*J}))*a888}))*a888''{;;H"(Ih %)^^H%=%=Ik "$,Ij ! !FFE&*oob%&@&@DOF #/IF#D1c$ii(( @ @1g$S>R88v;;??--h???"(Ih %%&6 EJJ  L}%f- %f- q"66A!%Ar!B!BJ#'#5#5jm#D#DtGYGYZdefZgGhGh#hL '' 5555q"66A!%Ar!B!BJ#'#5#5jm#D#DtGYGYZdefZgGhGh#hL '' 5555ggl++G JJw66M!!%dgmd6U6UV\6]6]&]^^(5OF+ e[111y+.....rUctdt|D]L}||}||d}||d}|||MdS)Nrr[qty)rr safe_numberstore)rRrhrijdeltar[rZs rTrXzkraken.custom_handle_deltassuq#f++&& * *A1IE$$UG44E%%eU33F NN5& ) ) ) )  * *rUc|d}||d}||dd}||z}d}||dkr|dz }||dk|dkr ||d}|S)N.rrrp0)splitr)rRrpartsintegerdecimals joinedResultrs rTr[zkraken.format_numbers 3""5!,,##E1b11) 1o$$ FA1o$$ q55'+LrUc|SrHrKs rThandle_system_statuszkraken.handle_system_statuss 6rUcK|jddd}||}d}||j|}|}||d}||d}| |I||z|kr@||d{V} || d}||d<||j|<||dS) Nr:r)r< authenticatedstartexpiresrr) rKrrr_secondsrprivatePostGetWebSocketsTokenrr) rRr^rrr subscriptionnowrrresponses rTrzkraken.authenticatesit$Y/S!!' v';]KK llnn!!,88##L)<<  |'?egoZ]E]E]!??GGGGGGGGH >>(H==L$'L !2>F  / g666rUcK|d{V|d{V}d}|}|||}|d|zz }|jddd} |} dd|d| d} ||| d || d <|| || |d{V} |jr| ||}| | |||S) N executions:r:r)r=r8r9rrr^) rrrWrKrrOrrr&filter_by_symbol_since_limit) rRr;rWr r]r^rsubscriptionHashrrrr8rs rT watch_privatezkraken.watch_privatesN!!!!!!!!!''))))))))'  [[((F 3< 'Kit$[1OO%% !'     "&"2"29X3F"O"OIh zz#{I?OPPPPPPPP ? 3OOFE22E00NNNrUcNKd|d<|d||||d{VS)a- watches information on multiple trades made by the user https://docs.kraken.com/api/docs/websocket-v2/executions :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 :returns dict[]: a list of `trade structures ` T snap_tradesmyTradesN)rr#s rTwatch_my_tradeszkraken.watch_my_tradess@!%}'' FE5&QQQQQQQQQrUc||dg}t|}|dkr5|j0||jdd}t ||_|j}i}t dt|D]P} ||| i} || } | | | d} d|| <Qd} | |j| t| }t dt|D]-} | dz|| z}| |j|,dSdS) NrrrBr@rWTrr) rrrrrLrrrparse_ws_traderrlistrf)rRrrr allTradesallTradesLengthr]rrrrrrWr;rfrs rThandle_my_tradeszkraken.handle_my_trades%sf@NN7FB77 i.. Q  }$))$, tLL *5 1 1 ]FG1c)nn-- ' 'y!R88,,U33 f%%%)"&D NN4=$ / / / ''D1c$ii(( ; ;"Sj472 t}k::::#   ; ;rUc||d}||d}d}d|vr[||dg}||di}||d||dd}||d}||d}|d krd nd } |||d ||d ||||||d||d| ||d||d||d|d S)NrWfeesrrvassetrdcurrencyr liquidity_indttakermakerexec_idrryr last_pricelast_qtyrd) rrrrrrWrXr takerOrMakerr[rZrdfee)rrrrwr) rRrr`rWrrfirstFeerliquidityIndicatorrs rTrzkraken.parse_ws_tradeZs2!!%22  H%F U??>>%44D~~dAr22H((599 ,,Xw??C##E;77!--e_EE#5#<#` orders snap_ordersTN)rrr#s rT watch_orderszkraken.watch_orderssL''&% TZ]jlp\qHrHrsssssssssrUc||dg}t|}|dkr||jdd}|jt ||_|j}i}t dt|D]1} ||| i} || d} | | } || d} | |j | }| || }| }|7| |d|d}| |}t|}||kr9|7|d}| |jdi}|d |vr ||d =| || d || <3d }||j|t|}t dt|D]-} |d z|| z}||j|,dSdS) NrrrDr@rrWrrErTrr)rrrrLrrrrrparse_ws_orderrhashmaprrrrrf)rRrrr allOrdersallOrdersLengthr]rrrrrrrWpreviousOrders previousOrdernewOrder newRawOrderlengthrrEr;rfrs rT handle_orderszkraken.handle_orderssE8NN7FB77 i.. Q  %%dlM4HHE{"4U;; [FG1c)nn-- + +y!R88%%eZ88,,U33))%::!%!H!H $ C C ! ,"&++mF.CXfEU"V"VK#22;??HVU?? (="1IE'+t|EWY['\'\$T{&666,U4[9 h'''%&*GFOD NN4; - - - ''D1c$ii(( 9 9"Sj472 t{K8888?  : 9 9rUc 2||ddd}||d}||d}|id||dd||d d |d||d |d dd |||dd||dd||dd||dddd||dd||dd|d|d||dd||ddd||dd|dd S)!N fee_usd_equivUSDr stop_pricerrrrb order_userrefrrlastTradeTimestampstatus order_statusrWrXryrurvrrr[r_ stopPricerhrdcum_costrZrecum_qty avg_price)filledr remainingrr)r safe_orderrparse_order_statusr)rRrr`rrrs rTrzkraken.parse_ws_orders"R$$UO<<  $$UL99 ##E;77 $""5*55 T--e_EE  E  11    !$   d--d.>.>un.U.UVV  d&&uh77  D$$UL99  4++E?CC    D$$UF33  T%%e];;    I D$$UJ77! " d(( YGG# $''{;;-      rU unifiedName channelNamec K|d{V||dddd}g}tdt|D]}||d}|D|||d|||^|||d|||d||d|d} | | d|| d<|j d d d } | | || ||d{VS) NFTrrr8)r9rWrr^r:r)r>) rrrrrrrrWrrOrKwatch_multiple) rRrrrsubscriptionArgsr^ messageHashesr eventTriggerrYrs rTrzkraken.watch_multi_helper%s!!!!!!!!!%%gtUD%HH q#g,,'' h hA++FODDL'$$T%:%:;dkkZabcZdNeNe%f%fgggg$$T%:%:;dkkZabcZdNeNe%f%fgggg!&!oo''   !,,WX->GGit$Z0((mWmUefffffffffrUcFK|d{V|d{V}d}|jddd}|}d|d|dd}|||}|||||d{VS) a\ watch balance and get the amount of funds available for trading or funds locked in orders https://docs.kraken.com/api/docs/websocket-v2/balances :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nbalancesr:r)r=r8r)rVrr^)rrrKrrOr)rRr^rrrrr8rYs rT watch_balancezkraken.watch_balance<s!!!!!!!!!'')))))))) it$[1OO%% !%  ""9f55ZZ[';GGGGGGGGGrUc||dg}d|i}tdt|D]m}|||d}||}|}|||d} | |d<|||<nd} ||} ||j| i} | | | } || |j| <||d}| |j| |dS) Nrrrrbalancetotalspotr9) rrrrsafe_currency_codeaccount safe_balancerrrOr)rRrrrrr currencyIdcodereqrXr oldBalance newBalancer9s rThandle_balancezkraken.handle_balanceUs=,~~gvr22(q#d))$$ # #A))$q'7;;J**:66DllnnG!!$q'955B!GG "F4LL##F++__T\4<< %%j':: !..z:: T""7I66t|D)733333rUunifiedElementNamesubChannelNamecF|du}|}|s|dz }n|d|zz }||d|zz }|S)Ns@#r)rRrrrW withSymbolrs rTrzkraken.get_message_hash|sP4' (  ( 3 KK 3< 'K  % 3/ /KrUcN||d}| ||j|<dSdS)N channelID)rr_)rRrr channelIds rThandle_subscription_statusz!kraken.handle_subscription_statuss:0$$Wk::  .5F  + + + ! rUc6||dd}|||dd}|jdd}|||}d}|t|}n|||}||||dSdS) N errorMessagersrrr)rIFT)rrNfind_broadly_matched_keyrr`)rRrrrrrIbroadKey exceptions rThandle_error_messagezkraken.handle_error_messages())'>7KK  #**7GXFFIOD)'2E44ULIIHI),77 +E(OL99 $ i3335trUc ||d}||dkrN||dg}||di}||d}|dkrdnd}|j|j|j|j|j|j|j d }| ||}| |||| ||rp| |d d } |j |j|j|j|j|j|j|jd }| || }||||dSdSdS) Nr9rrr exec_typerrr)rr2r7rrrrrErV)rN systemStatussubscriptionStatusrrrrpong)rrrrrtr rrrrrrrrQrrrrrrL) rRrrr9rrexecTypemethodsrVrEs rThandle_messagezkraken.handle_messages""7I66  ,&&~~gvr::tQ33++E;??)1W)<)<**8 /.),+ 1,  G__Wg66F!vw'''  $ $VW 5 5 (&&wBBE!2 $ 9&*&E!:#< $ 8";(  G__We44F!vw''''' ( ("!rUrH)NN)F__name__ __module__ __qualname__rrQstrdictr rrr floatr rrrrrrrrrrrrrr rrrrrrrr rr$r"r r+r*rr<rrFrLrOrQrtrXr[rrrrrrrrrrrrrrrrrr __classcell__)rSs@rTr&r&sFj #j j j j j j Xnrz|w!w!sw!Cw!sw!Tw![^w!gjw!w!w!w!rpt|~ ] ]C ]y ] ][` ]il ]DI ] ] ] ]D+++@im{IK]]c]3]i]y]be]ux]PU]]]]@DHPR]]$s)]S]]]]8<@]]]S]u]]]]8''' 8rsg ffffffffffHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH444444******000000------------......''''''&&&&&&......))))))******))))))......111111******%%%%%%S(S(S(S(S(T  &S(S(S(S(S(rU