iFddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddl$m%Z%Gddej&j'Z'dS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) IntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)PermissionDenied)AccountSuspended) BadRequest) BadSymbol)InsufficientFunds) InvalidOrder) OrderNotFound) NotSupported)RateLimitExceeded)ExchangeNotAvailable) InvalidNonce)PrecisecJeZdZfdZdifdededededede f d Z d Z difd edededededede fd Z difd e edefdZdifd edede fdZdZdifdefdZdZdZdefdZdefdZdZifdZifdedefdZdifdedefdZddifdededede e fdZ!ddifde ededede e fdZ"difdedede#fd Z$difde edede#fd!Z%d"ddifdededede e&fd#Z'd$iffd% Z(ifd&Z)defd'Z*defd(Z+d)Z,d=d*Z-defd+Z.ifd,Z/dddifdededefd-Z0dddifdededede e fd.Z1d=defd/Z2d=d0Z3dddifdededede e fd1Z4d=defd2Z5d=d3Z6ddifd4ed5edefd6Z7d>d7ed8edefd9Z8defd:Z9defd;Z:defd<Z;xZ d?id@S)ANwsT watchBalanceF watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker watchTickers watchTradeswatchTradesForSymbols createOrderWs editOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWsapizwss://ws.kraken.comzwss://ws-auth.kraken.comzwss://beta-ws.kraken.comzwss://beta-ws-auth.kraken.com)publicprivatebetaz beta-private) tradesLimit OHLCVLimit ordersLimitsymbolsByOrderIdchecksumzEvent(s) not foundzAlready subscribedz'Currency pair not in ISO 4217-A3 formatzMalformed 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 exceededzEOrder:Rate limit exceeded) z&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 request)exactbroad)hasurlsoptions exceptions) deep_extendsuperr"describerrrrrrrrrrrr)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/kraken.pyrFzkraken.describes^fd 3 3 < < > >d d  !$  +D ttt( t !$ $T!*"7#= :(G   $"#$& ,j-,j-A9-,Z-6z - LZ - ,Y -Ej-;J-? -4Z-@-H-CJ->z-78H- ;G ?-@7 A-B:J=I0D2` Nr4r$r6addOrderwsId)eventtokenreqid ordertyperLpairvolumer/ load_markets authenticatemarketrA request_idamount_to_precision orderRequestwatchextend) rGrKrLrMrNrOparamsrUr]url requestId messageHashrequests rIcreate_order_wszkraken.create_order_ws~s!!!!!!!!!''))))))))V$$it$Y/OO%%  6N..vv>>  ++OVT7TY[abbZZ[$++gv2N2NP[\\\\\\\\\rJc||}||d}|||dSNrV) parse_order safe_valueresolve)rGclientmessageorderrfs rIhandle_create_edit_orderzkraken.handle_create_edit_ordersD(  ))oogw77 uk*****rJidc K|d{V|d{V}||} |jddd} |} | } d|| || d|||d} |d||| ||\} }|| | || || d{VS) a edit a trade order :see: https://docs.kraken.com/websockets/#message-editOrder :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 fullfilled, 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 ` Nr4r$r6 editOrderrS)rTrUrVorderidrXrYr0rZ)rGrrrKrLrMrNrOrcrUr]rdrerfrgs rI edit_order_wszkraken.edit_order_wss!!!!!!!!!''))))))))V$$it$Y/OO%%   6N..vv>>   ++M64RWY_``ZZ[$++gv2N2NP[\\\\\\\\\rJidsc>K|d{V|d{V}|jddd}|}|}d|||d}|||||||d{VS)a :see: https://docs.kraken.com/websockets/#message-cancelOrder cancel multiple orders :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 ` Nr4r$r6 cancelOrderrTrUrVtxid)r[r\rAr^rarb) rGrwrKrcrUrdrerfrgs rIcancel_orders_wszkraken.cancel_orders_wss!!!!!!!!!''))))))))it$Y/OO%%  "    ZZ[$++gv2N2NP[\\\\\\\\\rJcK|d{V|d{V}|jddd}|}|}||dd|}||ddg}d|||gd} ||||| ||d{VS) a :see: https://docs.kraken.com/websockets/#message-cancelOrder cancels an open 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 ` Nr4r$r6userref clientOrderIdryrz)r[r\rAr^ safe_value_2omitrarb) rGrrrKrcrUrdrerfrrgs rIcancel_order_wszkraken.cancel_order_wss!!!!!!!!!''))))))))it$Y/OO%%  ))&)_bQQ 6I#?@@""O    ZZ[$++gv2N2NP[\\\\\\\\\rJc^||d}|||dSrjrlrmrGrnroreqIds rIhandle_cancel_orderzkraken.handle_cancel_order111w&&&&&rJcnK|t|jdz|d{V|d{V}|jddd}|}|}d||d}|||||||d{VS)a :see: https://docs.kraken.com/websockets/#message-cancelAll cancel all open orders :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.r4r$r6 cancelAll)rTrUrV)rrrr[r\rAr^rarb)rGrKrcrUrdrerfrgs rIcancel_all_orders_wszkraken.cancel_all_orders_ws s  tw)xxyy y!!!!!!!!!''))))))))it$Y/OO%%      ZZ[$++gv2N2NP[\\\\\\\\\rJc^||d}|||dSrjrrs rIhandle_cancel_all_orderszkraken.handle_cancel_all_orders"rrJc|d}||jd|}|d}|dd|}|d}||dd} d} ||dd} | | t j| | } ||d d} |id|d dd dd ||d dd||ddd||ddd||ddd||ddd||ddd| d||ddd| d| dddddddd| | |d } | |j|<|| |dS)!NmarketsByWsNamerKtickerprvc timestampdatetimehighhlowlbidb bidVolumeaska askVolumevwapopenocloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) rlrBget_message_hash safe_stringr string_mul safe_tickertickersrm)rGrnro subscriptionwsNamer]rKrfrrrrrresults rI handle_tickerzkraken.handle_ticker.so&.?!@&II!++HdFCC s Q// %%fSk155  !d&6!,Z>>Ks Q//!!# f# #  #  D$$VC[!44 # 4##F3K33 # 4##F3K33 #  ))&+q99#  4##F3K33#  ))&+q99#  D#  D$$VC[!44#  T#  D#  T#  d# $!# " t## $%&)# # #   , & Vv{+++++rJrnc~||d}||d}||jd|}|d}||d|}||j|} | 5||jdd} t | } | |j|<||dg} || |} tdt| D]} | | | | | |dS) NrrrrKr9r8rr) rrlrBrtrades safe_integerr parse_tradesrangelenappendrm)rGrnrorrnamer]rKrfstoredlimitrparsedis rI handle_tradeszkraken.handle_tradeses2!!'1--++.?!@&II!++D$?? f55 >%%dlM4HHE&&F"(DK !R00""6622q#f++&& % %A MM&) $ $ $ $v{+++++rJc H||di}||d}||d}||d}||jd|}|d} ||} || } | r||d} |dz| zdz|z} || d}|| z}||d z}||| d || d|| d || d || d g}||j| i|j| <||j| | }|;||jdd }t|}||j| | <| || || dSdS)NrintervalrrrrKr:r8rr:) rlrrrBfind_timeframeparse_timeframe safe_float parse_to_intohlcvsrrrm)rGrnrorrrrrr]rK timeframedurationcandlerfrtsrrrs rI handle_ohlcvzkraken.handle_ohlcvs&|^R@@$$T:66f--!!'1--.?!@&II!''11 '' 22  __Wa00F*y036?K22I  !I""9t#344B********** F#'//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! ! NN6; / / / / /+ ! rJcz|||jddd}||jd<|S)NrVrr)sumrrB)rGrVs rIr^zkraken.request_ids:**4<!DDaHH % W rJcK|d{V||}||dd}|dz|z}|jddd}|}d||gd|id } || |} |||| |d{VS) Nrwsnamerr4r$r5 subscriberrTrVrXr)r[r]rlrAr^rDra) rGrrKrcr]rrfrdrerrgs rI watch_publiczkraken.watch_publics!!!!!!!!!V$$::Sj6) it$X.OO%%     ""9f55ZZ[';GGGGGGGGGrJcK|d{V||}||g|d{V}||S) watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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 ` N)r[rK watch_tickers)rGrKrcrs rI watch_tickerzkraken.watch_tickersp!!!!!!!!!V$$**F8V<<<<<<<<vrJsymbolsc K|d{V||dd}|dd|d|d{V}|jri}|||d<|S||jd|S)rNFrrK)r[market_symbolswatch_multi_helper newUpdatesfilter_by_arrayr)rGrrcrrs rIrzkraken.watch_tickerss!!!!!!!!!%%gtU;;..x7DRXYYYYYYYY ? F'-F6(# $M##DL(GDDDrJsincercDK||g|||d{VS)a get the list of most recent trades for a particular symbol :see: https://docs.kraken.com/websockets/#message-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_symbolsrGrKrrrcs rI watch_tradeszkraken.watch_tradess622F8UE6RRRRRRRRRrJcK|dd|d|d{V}|jrB||d}||d}|||}||||ddS)a :see: https://docs.kraken.com/websockets/#message-trade get the list of most recent trades for a list of symbols :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 ` tradeNrrKrT)rr safe_listrgetLimitfilter_by_since_limit)rGrrrrcrfirst tradeSymbols rIrzkraken.watch_trades_for_symbolss..w$PVWWWWWWWW ? 8NN61--E**5(;;KOOK77E))&% TRRRrJcBK||g||d{VS)a2 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.kraken.com/websockets/#message-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)rGrKrrcs rIwatch_order_bookzkraken.watch_order_books466xOOOOOOOOOrJc Ki}|7||gdrd|i|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 :see: https://docs.kraken.com/websockets/#message-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) dir8depthrzF watchOrderBook accepts limit values of 10, 25, 100, 500 and 1000 only orderbookbookr)in_arrayrrrrrbr)rGrrrcrgrs rIrz#kraken.watch_order_book_for_symbolss  }}U$<$<$<== wU+''#47-u#uvvv11+vwQXZ_P`bfbmbmnuw}b~b~    rJ1mc DK|d{Vd}||}|d}||dd}|dz|zdz|z} |jddd } |} d | |g|||j||d d } || |} || | | | d{V}|jr| ||}| |||d dS)aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 NohlcrKrrrr4r$r5r)rrrrT) r[r]rlrAr^ timeframesrDrarrr)rGrKrrrrcrr]rrfrdrerrgohlcvs rI watch_ohlcvzkraken.watch_ohlcv%sW!!!!!!!!!V$$!::Sj9,s2V; it$X.OO%%   OODOY RR   ""9f55jjk7KHHHHHHHH ? 2NN6511E))%q$GGGrJFcHKtt|||d{V}||jd}||ri}t dt |jD]}|j|}|j|}|drK||di}| |d} | dddz| ddz} ||| <o||di}| |d} ||| <||jd<|S) Nrrdarkpoolraltnamer/r) rEr"r[rlrBrrrmarketsr) rGreloadrcrrrrKr]rrrrHs rIr[zkraken.load_marketsHsDfd++88HHHHHHHH//$,8IJJ  # # O1c$,//00 5 5af-*%5??662>>D"..tY??G$QqS\C/'!""+=F.4OF++??662>>D!--dH==F.4OF++.=DL* +rJcK|d{Vd}|jddd}|||d{VS)N heartbeatr4r$r5)r[rAra)rGrcrTrds rIwatch_heartbeatzkraken.watch_heartbeat\sk!!!!!!!!!it$X.ZZU+++++++++rJc^||d}|||dS)NrT)rrm)rGrnrorTs rIhandle_heartbeatzkraken.handle_heartbeatbs3   '22w&&&&&rJcH t|}||dz }||dz }|d}||dd}||jd|} | d} d} |dd| } d|dvr|i||j| <|j| } d d d }t| }td t|D]N}||}||}| |}||d|g}| ||| } O| | d<| | d <| | | d<| | | dS|j| } d}d}d}|dkrt||ddg}||ddg}||dd}||dd|}na||dd}d|dvr||ddg}n||ddg}| d }| d }d}|-| ||| } ||d }|-| ||| } ||d }| ||jdd}|r||d }||d}|d}|d}t|dd z } t|dd z }!g}"|td dD]\}|||d | |||d|!z}#|"|#]td dD]\}|||d | |||d|!z}#|"|#]d|"}$||$d}%|%|kr/t+|jdz}&||&| dS| | d<| | d <| | | d<| | | dS)Nrr-rrrKrasasksbids)rbsrrrrrrrr=T.Fz invalid checksum)rsplitrrlrBr order_book orderbookslistkeysrcustom_handle_deltasiso8601rmr safe_boolr format_numberrjoincrc32rrrreject)'rGrnror messageLengthrbookDepthStringpartsrr]rKrrfrsidesrrkeyrMbooksidedeltasrrr storedAsks storedBidsexampler= priceString amountString priceParts amountParts priceLength amountLength payloadArray formattedpayload localChecksumerrors' rIhandle_order_bookzkraken.handle_order_bookks^RG *+!-!"34%%c**!!%B//.?!@&II! ++KvFF 71:  &*oob%&@&@DOF #/IE %%D1c$ii(( S S1gSz$T?S"== 55h RR "(Ih %.Ik "$(LL$;$;Ij ! NN9k 2 2 2 2 2/IAAA!!OOGAJR88OOGAJR88%%gaj#66%%gaj#q99%%gaj#66'!*$$ C<22Q6 ! ="1b\\77$($6$6z!}Q7G$U$UX\XjXjkuvwkxyzk{~JYKYK%K $++I6666"1b\\77$($6$6z!}Q7G$U$UX\XjXjkuvwkxyzk{~JYKYK%K $++I6666'',// $ 7E : :  A%%(3F)FGGEMM%555F"(Ih %.Ik "$(LL$;$;Ij ! NN9k 2 2 2 2 2rJcH||}|d}||d}||dd}||d}||z}d} || dkr| dz } || dk| dkr || dS|S)Nrrrr0)number_to_stringrrljust) rGnlength stringNumberr$integerdecimalspaddedDecimalsjoinedrs rIrzkraken.format_numbers,,Q// ""3''""5!,,##E1b11!44>) Qi3 FAQi3 q55!"": MrJc ltdt|D]}||}||d}||d}|r|nd}t||t |ddz}||||S)Nrrrr8)rr parse_numbermaxrfloatstore) rGr'r(rjdeltarOrN oldTimestamps rIrzkraken.custom_handle_deltassq#f++&& * *A1IE%%eAh//E&&uQx00F(1899qLL$*;*;E%(OOd>L2>F  / g666rJcK|d{V|d{V}|}|}|||}|d|zz }|jddd} |} d| ||dd} || |} || || |d{V} |jr| ||}| | |||S)Nrr4r$r6r)rrU)rTrVr) r[r\rKrAr^rDrarrfilter_by_symbol_since_limit)rGrrKrrrcrUsubscriptionHashrfrdrerrgrs rI watch_privatezkraken.watch_private$s<!!!!!!!!!''))))))))  [[((F 3< 'Kit$Y/OO%%    ""9f55zz#{G=MNNNNNNNN ? 3OOFE22E00NNNrJcDK|d||||d{VS)a watches information on multiple trades made by the user :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]{@link https://docs.ccxt.com/#/?id=trade-structure ownTradesNrWrs rIwatch_my_tradeszkraken.watch_my_trades<s6'' VUE6RRRRRRRRRrJc||dg}t|}|dkr|j0||jdd}t ||_|j}i}t dt|D]} ||| i} t| } t dt| D]_} | | } | | }| | d| i|}| ||d}d||<`d}| |j|t|}t dt|D]-} |dz|| z}| |j|,dSdS) Nrr9r8rrrKTrYr) rlrmyTradesrrBrrrrparse_ws_traderbrrm)rGrnror allTradesallTradesLengthrrrrrrwrHrrrrrKrrrfs rIhandle_my_tradeszkraken.handle_my_tradesGsNOOGQ33 i.. Q  }$))$, tLL *5 1 1 ]FG1c)nn-- + +Ar::6;;==))q#c((++++AQB"2JE!00dBZ1O1OPPFMM&)))#H-F&*GFOO +D NN4=$ / / / ''D1c$ii(( ; ;"Sj472 t}k::::+  & ; ;rJcr||d}||jd||}d}||d}||dd}||d}||d}||d} ||d } ||d } d} d} d |vr%d}||d }||d |d } ||d}| | | | z} |||||||| |d| | | | d S)NrXr ordertxidrrpostxidtimerLrWrOvolfeequote)costcurrencyrK) rrrprrrrKrLrM takerOrMakerrOrNrirg)rrlrB safe_string_2safe_timestamprr)rGrr]rrKorderIdrrrrMrLrOrNrirgrjs rIr^zkraken.parse_ws_trades}B!!%00.?!@&&QQ""5+66   tY 7 7''v66 v..{33w//.. E>>H!!'?u55$C  H%F  !v~" Y//    rJcDK|d||||d{VS)a1 :see: https://docs.kraken.com/websockets/#message-openOrders watches information on multiple orders made by the user :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 orde structures to retrieve :param dict [params]: maximum number of orderic to the exchange API endpoint :returns dict[]: a list of `order structures ` openOrdersNrZrs rI watch_orderszkraken.watch_orderss6'' feUFSSSSSSSSSrJc`||dg}t|}|dkr~||jdd}|jt ||_|j}i}t dt|D]} ||| i} t| } t dt| D]>} | | } | | }| |}| |d<d}||jdi}|d|d}||| <||jd<n| || }||j |}||| }|}|<| |d|d}| |}| |d<t|}||kr||d}|d|vr ||d=| |d||<@d }||j|t|}t dt|D]-} |d z|| z}||j|,dSdS) Nrr;r8rrr<rKrTrpr)rlrrrBordersrrrrparse_ws_orderrhashmaprbrrm)rGrnror allOrdersallOrdersLengthrrrrrsrwrHrrrprrKr<previousOrders previousOrdernewOrder newRawOrderr=rrrrfs rI handle_orderszkraken.handle_orderss\OOGQ33 i.. Q  %%dlM4HHE{"4U;; [FG1c)nn-- + +Ar::6;;==))q#c((++++AQB"2JE!0077F#%F4L!F'+t|EWY['\'\$h'3!'!1/5(,;K %788!%!1!12BB!G!G%)__V^V%L%LN$(OONB$G$GM%H$0&*kk-2GRXIY&Z&Z #'#6#6{#C#C)+ [[FM,A &q  ;*::: 0t =MM(+++&*GFOO5+6 D NN4; - - - ''D1c$ii(( 9 9"Sj472 t{K8888S  N 9 9rJc j||di}||d}d}d}d}d}d} ||d} || d}|| d} || d}|| d}|| d}||d |}||d |}||d |}||jd ||}d} ||d } ||d| } ||d} d}||d}||d|}|t j|dr||d}|t j|dr||d|}||dd}|x|d} d|vrl|d}||d}|dd}|ddkr |d|d<n$|ddkr |d|d<| ||d}||d}|,||d }||d}||d!}||d"}d}|| ||ddd|i}| |d#}| id|d$|d%|d&| d'| | d(dd|d| d |d)dd*dd+|d|d,|d-|d|d.| | |d||d/S)0Ndescrrp rrrrrrLrWrXropentmrfvol_execrirOz0.0price2 avg_pricerKrgoflags)riratefciqrhrjfcibbasestatusrrr{r~r stoppricerrrrlastTradeTimestamp timeInForcepostOnlyrM stopPrice triggerPricerN)filledr remainingrgr)rlrrrBrmr string_eqrlfindparse_order_statusr safe_number safe_orderr)rGrpr] descriptionorderDescriptionrMrLrrOrNr$rKrrrgrirflagsfeeCostrrrr{r rawTradesrrs rIrtzkraken.parse_ws_orderXs@ooeWb99 ++KAA  '$**3//E##E1--D%%eQ//F%%eQ//F##E1--D$$UA..E VT:: [$??!!+vv>>.?!@&&QQ''x88 !!%77!!%44v..  gu== Mw0>>M$$[(;;E Mw0>>M$$UGU;;E$$UKAA  H%F~~h**5%88# ::f%%**&,WoC OOZZ''1,,&,VnC O(()9)9%)J)JKK   eT * * :??5&11D!!$**B(( :: OOE844   &&y&$wPRmTTF$$UK88  " ]  E     Y//  !$   f  f  D  4    D  U    I D! " f# $-      rJ unifiedName channelNamec K|d{V||dddd}g}tdt|D]E}|||d|||F||}g} tdt|D]9}|||dd} | | :d| | d|id} |j d d d } | | || | |||d{VS) NFTrrrrrrr4r$r5) r[rrrrrrKmarkets_for_symbolsrr^rAwatch_multiplerb) rGrrrsubscriptionArgsrc messageHashesrr wsMarketIds wsMarketIdrgrds rIrzkraken.watch_multi_helpers!!!!!!!!!%%gtUD%HH q#g,,'' d dA  !6!6{D$++V]^_V`JaJa!b!b c c c c**733 q#g,,'' + +A))'!*V*;>;v>;>;>;>;@H H H H T04$UYbd T T TC Ts Timnsit T T T Ty9y9Fy9y9y9y9vm m m m ^_cuyCE||C|c|T[||||0  3  \_    66666@64#,V#,#,#,#,#,#,#,#,rJr")(ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrrrrrrrrccxt.base.preciser async_supportr"rMrJrIrs ffffffffffrrrrrrrrrrrrrrrrrrrrrrrrrr444444******000000------------''''''&&&&&&......))))))******))))))......111111))))))%%%%%%n,n,n,n,n,T  &n,n,n,n,n,rJ