eixddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z dd lm!Z!dd lm"Z"ddl#m$Z$Gddej%j&Z&dS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntMarketOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) NotSupported)RateLimitExceeded) ChecksumError)UnsubscribeError)Precisec eZdZdeffd ZdZifdZifdZifdZifdZ ifdZ d e fd Z ifd Z ifd ed ededefdZdefdZdDdeded e defdZifd edefdZifd edefdZdifdedefdZd e fdZdDdZdddifd ededededeef dZdifd ededefd Z d e fd!Z!dDdedefd"Z"difd edede#fd#Z$ifd edefd$Z%difdeedede#fd%Z&d e fd&Z'd e d ed'efd(Z(d)Z)d*Z*ddifd edededee+fd+Z,ddifdeedededee+fd,Z-ifd edefd-Z.d e fd.Z/dDde+fd/Z0ifde1fd0Z2d e fd1Z3dddifd edededee4fd2Z5d e fd3Z6dDd4e7dede4fd5Z8dddifdedededee9fd6Z:defd7Z;d e fd8Zfd:Z?d e fd;Z@d e fd<ZAd e fd=ZBd e fd>ZCd e fd?ZDd e fd@ZEd e fdAZFd e fdBZGd e fdCZHxZIS)E coincatchreturnc||tt|dddddddddddddd dddddiid d d d d ddddddd ddidd|jidt t t t t ttt t t t t d ididS)NTF) ws watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTrades watchTicker watchTickers watchBalancewatchPositionsapir#z'wss://ws.coincatch.com/public/v1/streamz(wss://ws.coincatch.com/private/v1/stream)publicprivate1m5m15m30m1H4H12H1D1W) r5r6r7r81h4h12h1d1wchecksum) tradesLimit OHLCVLimittimeframesForWsr&ping) 300013000230003300043000530006300073001130012300133001430015)exactbroad)hasurlsoptions streaming exceptions) deep_extendsuperr describerGrrr)self __class__s P/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/coincatch.pyr]zcoincatch.describes0i 6 6 ? ? A A#)-"&,0"(-#!&# $ $"& "K#M $!    $ $#& !+!4!+!4!4!2!2!4!4!4!+!4   [@D @D @ @ @ cP||d}||d}||}|d}|d}d}|dkr |dkrd}nd }||||z|z}||S) NinstIdinstTypebaseIdquoteId_SPBLmcUSD_DMCBL_UMCBL) safe_stringparseSpotMarketIdsafe_currency_codesafeMarketCustom) r^entryrcrd baseAndQuotererfsuffixmarketIds r`get_market_from_argzcoincatch.get_market_from_arg\s!!%22##E:66--f55 h'y) t  %!!**622T5L5LW5U5UUX^^$$X...racxK||jddd}||}d}||}||j|}|t |}|dzdz}|| || |j tj d} d} | |j |j|| d gd } || |} |||| ||d{VS) Nr0r#r2 authenticatedGETz /user/verifybase64login)apiKey passphrase timestampsignopargs)check_required_credentialsrWclientreusableFuture safe_value subscriptionsstrsecondshmacencodesecrethashlibsha256rzpasswordextendwatch) r^paramsurlr messageHashfuturervr|auth signature operationrequestmessages r` authenticatezcoincatch.authenticateks? '')))it$Y/S!!% &&{33( > >||||||racK|jddd}d|gd}|||}|||||d{VSNr0r#r1 subscriber~rWrrr^r subscribeHashrrrrrs r` watch_publiczcoincatch.watch_publicsoit$X.F  ++gv..ZZ['=IIIIIIIIIracK|jddd}d|gd}|||}|||||d{VS)Nr0r#r1 unsubscriber~r)r^rrrrrrs r`un_watch_publiczcoincatch.un_watch_publicsoit$X.F  ++gv..ZZ[';GGGGGGGGGracK|d{V|jddd}d|gd}|||}|||||d{VSNr0r#r2rr~)rrWrrrs r` watch_privatezcoincatch.watch_privates!!!!!!!!!it$Y/F  ++gv..ZZ['=IIIIIIIIIracK|d{V|jddd}d|d}|||}|||||d{VSr)rrWrwatch_multiple)r^ messageHashessubscribeHashesrrrrrs r`watch_private_multiplez coincatch.watch_private_multiples!!!!!!!!!it$Y/  ++gv..((mWoVVVVVVVVVrarcjd}||j|}|ddS)NrvT)rfuturesresolve)r^rrrrs r`handle_authenticatezcoincatch.handle_authenticates6& ==tracK|jddd}d|d}|||}|||||d{VSr)rWrr)r^rr argsArrayrrrrs r`watch_public_multiplezcoincatch.watch_public_multiplesoit$X.  ++gv..((mWoVVVVVVVVVrasymbolchannelmessageHashTopiccK|d{V||}||\}}d|zdz|z}|||d} ||| |d{VS)Nz unsubscribe::rdrrc) load_marketsmarketget_public_inst_type_and_idr) r^rrrrrrdrcrrs r`un_watch_channelzcoincatch.un_watch_channels!!!!!!!!!V$$;;FCC&$'77#=F     ))+tVDDDDDDDDDrarc|d|dz}d}|drd}n"|drd}nt|jdz||gS)NrerfspotSPswapMCz$ supports only spot and swap markets)rid)r^rrcrds r`rz%coincatch.get_public_inst_type_and_idsd!F9$55 &> QHH F^ QHHtw)OOPP P&!!raNhash timeframec0|d}|||}||j|g}d}|d|z}tdt |D]4} || }|d} || z|z} || |r|cS5|S)Nrrrr)find_message_hashes safe_list markets_by_idrangelenin_array) r^rrrrrsrmarketsWithCurrentIdrrirrs r`%handle_dmcbl_market_by_message_hashesz/coincatch.handle_dmcbl_market_by_message_hashess$<00>>  $~~d.@(BOO  9_Fq#23344  A)!,FH%F-&0K}}[-88    racK|d{V||}||\}}d}|dz|z}|||d}|||||d{VS)ar watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://coincatch.github.io/github.io/en/spot/#tickers-channel :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.instType]: the type of the instrument to fetch the ticker for, 'SP' for spot markets, 'MC' for futures markets(default is 'SP') :returns dict: a `ticker structure ` Ntickerrr)rrrr) r^rrrrdrcrrrs r` watch_tickerzcoincatch.watch_tickers!!!!!!!!!V$$;;FCC&mf,     &&{KvNNNNNNNNNracvK|d{V||dd|d{VS)aX unsubscribe from the ticker channel https://coincatch.github.io/github.io/en/mix/#tickers-channel :param str symbol: unified symbol of the market to unwatch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request Nrrrr^rrs r`un_watch_tickerzcoincatch.un_watch_tickersX!!!!!!!!!**68XvNNNNNNNNNrasymbolscK|d{V||j}g}g}tdt|D]j}||}||}||\}} |d| d} || |d|zk|||||d{V} |jri} | | | d<| S| |j d|S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://coincatch.github.io/github.io/en/mix/#tickers-channel :param str[] symbols: unified symbol of the market to watch the tickers for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nrrrticker:r) rrrrrrappendr newUpdatesfilter_by_arraytickers) r^rrtopicsrrrrrdrcrrresults r` watch_tickerszcoincatch.watch_tickers sB!!!!!!!!! ?lG q#g,,'' 5 5AQZF[[((F#??GG Hf$# D MM$     V!3 4 4 4 422=-QWY_```````` ? F(/F78$ %M##DL(GDDDrac||di}||}|d}d}|ddkr||||}||dg}|||di|}|d} ||j| <|| z} ||j| | dS)Nargrrrjrdatar) safe_dictrtfindrrparse_ws_tickerrr) r^rrrrrsrrrrrs r` handle_tickerzcoincatch.handle_ticker+s2nnWeR00))#..$< == " "a ' '??fUUF~~gvr22%%dnnT1b&A&A6JJ!% VVm t|F+[99999rac 8||d}||dd}|id|dd|d||d||dd ||d d ||d d ||dd||dd||dddd||ddd|d|dddddt j||dddd||d||d||d ||d!|d"|S)#Nlastts systemTimerr|datetimehighhigh24hlowlow24hbidbestBid bidVolumebidSzaskbestAsk askVolumeaskSzvwapopenopen24hopenUtcclose previousClosechange percentagechgUTC100average baseVolume quoteVolume indexPrice markPrice)rrrrinfo)rlsafe_integer_2 safe_tickeriso8601 safe_string_2r string_mul safe_number)r^rrrr|s r`rzcoincatch.parse_ws_tickerQs^//''lCC ! fX&! !   Y//!  D$$VY77 ! 4##FH55 ! 4##FI66 !  ))&'::!  4##FI66!  ))&'::!  D!  D&&vy)DD!  T!  D!  T!  d! ',T-=-=fh-O-OQVWW!! " t#! $**6<@@++FMBB**6<@@))&+>>-! ! ! . / rar5sincelimitcK|d{V||}|jd}d|||z}||\} } | || d} d|zdz|z} || | | |d{V} |jr| ||}|| ||ddS) a] watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://coincatch.github.io/github.io/en/spot/#candlesticks-channel :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(not including) :param int [limit]: the maximum amount of candles to fetch(not including) :param dict [params]: extra parameters specific to the exchange API endpoint :param bool [params.instType]: the type of the instrument to fetch the OHLCV data for, 'SP' for spot markets, 'MC' for futures markets(default is 'SP') :returns int[][]: A list of candles ordered, open, high, low, close, volume NrFcandlerohlcv:rrT) rrrXrlrrrgetLimitfilter_by_since_limit)r^rrrrrr timeframesrrdrcrrohlcvs r` watch_ohlcvzcoincatch.watch_ohlcvs !!!!!!!!!V$$\"34 T--j)DDD;;FCC&    '#- 9 '' [$OOOOOOOO ? 2NN6511E))%q$GGGracK|d{V|jd}|||}d|z}|||d|z|d{VS)a unsubscribe from the ohlcv channel https://www.bitget.com/api-doc/spot/websocket/public/Candlesticks-Channel :param str symbol: unified symbol of the market to unwatch the ohlcv for @param timeframe :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrFrr)rrXrlr)r^rrrrintervalrs r`un_watch_ohlcvzcoincatch.un_watch_ohlcvs!!!!!!!!!\"34 ##J ::X%**67Hx` indexed by market symbols N)watch_order_book_for_symbols)r^rrrs r`watch_order_bookzcoincatch.watch_order_books466xOOOOOOOOOracK|d{Vd}||d}|dks|dkr(||d}|t|z }|||||d{VS)a unsubscribe from the orderbook channel https://coincatch.github.io/github.io/en/spot/#depth-channel :param str symbol: unified symbol of the market to fetch the order book for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols Nbooksrr+)rr omitrr)r^rrrrs r`un_watch_order_bookzcoincatch.un_watch_order_books!!!!!!!!!!!&'22 QJJERKKYYvw//F s5zz !G**67GVLLLLLLLLLracK|d{V||}d}g}g}tdt|D]m}||}||} || \} } | || d} || ||dz|zn|||||d{V} | S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://coincatch.github.io/github.io/en/spot/#depth-channel @param 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 Nr0rrr) rmarket_symbolsrrrrrrr)r^rrrrrrrrrrdrcr orderbooks r`r-z&coincatch.watch_order_book_for_symbols(s%!!!!!!!!!%%g.. q#g,,'' 9 9AQZF[[((F#??GG Hf$" D MM$     3!7 8 8 8 844]MSY[abbbbbbbb    rac||di}||}|d}d}|ddkr||||}|d}||d}||z} ||dg} || d} || d } |} | rK||jvr$|i}||d<||j|<|j|}|| d g}|| d g}| |d || |d || |d <| | |d <| |j dd}||ddk}|sT|rQ|d }|d }t|}t|}g}tddD]}||krN|||dd|||dd||krN|||dd|||ddd|}||d}|| d}||kr||j||| dSnK|i}|| || }||||j|<||j|| dS)Nrrzbooks:rjrrrrrasksbidsr|rrCTactionsnapshotr(r'r)rrtrrrlrr  orderbookscounted_order_book handle_deltasr  safe_boolrXrrrjoincrc32spawnhandle_check_sum_error order_bookparse_order_bookresetr)r^rrrrrsrrrrr rawOrderBookr|incrementalBookobstoredOrderBookr8r9rC isSnapshot storedAsks storedBids asksLength bidsLength payloadArrayrpayloadcalculatedChecksumresponseChecksumr6parsedOrderbooks r`handle_order_bookzcoincatch.handle_order_bookFs nnWeR00))#..$< == " "a ' '??fUUF!""3 22Vm ~~gvr22~~dA.. %%lD99 ! % 0do--,,R00%8 *,'"of5O>>,;;D>>,;;D   v6 = = =   v6 = = =+4OK (*.,,y*A*AOJ '~~dlJEEH))'8<< JJ ( ,V4 ,V4  __  __ ! q"AAA:~~$++JqM!,%>"#'#4#4\:#N#N %)999JJt:FFKXXXF++I"33L&)TTO OOO , , ,&/DOF #tv. <<<<` N)watch_trades_for_symbols)r^rrrrs r` watch_tradeszcoincatch.watch_tradess622F8UE6RRRRRRRRRracKt|}|dkrt|jdz|d{V||}g}g}t dt|D]j}||} || } || \} } | d| d} || |d| zk| ||||d{V}|j rB| |d}| |d}| ||}||||dd S) a watches information on multiple trades made in a market https://coincatch.github.io/github.io/en/spot/#trades-channel @param symbols :param int [since]: the earliest time in ms to fetch orders 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 ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNtradertrade:rr|T)rrrrr5rrrrrrrrlrr)r^rrrr symbolsLengthrrrrrrdrcrtradesfirst tradeSymbols r`rfz"coincatch.watch_trades_for_symbolssG A  #DG.n$noo o!!!!!!!!!%%g.. q#g,,'' 4 4AQZF[[((F#??GG Hf$" D MM$     F!2 3 3 3 311-PVX^________ ? 8NN61--E**5(;;KOOK77E))&% TRRRracvK|d{V||dd|d{VS)aX unsubscribe from the trades channel https://coincatch.github.io/github.io/en/spot/#trades-channel :param str symbol: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request Nrirrs r`un_watch_tradeszcoincatch.un_watch_tradessX!!!!!!!!!**67GVLLLLLLLLLrac||di}||}|d}d}|ddkr||||}|d}||jvr3||jdd}t||j|<|j|} ||d g} | w| | d} tdt| D]C} || | } | | |} | | D||z}|| |dS) NrrrjrjrrrDr3r)rrtrrrlr rXrrsort_byrrparse_ws_traderr)r^rrrrrsrrrr#rrrir$rs r` handle_tradeszcoincatch.handle_tradessennWeR00))#..$< == " "a ' '??fUUF!$+%%%%dlM4HHE",U"3"3DK V$~~gvr22  <<a((D1c$ii(( & &tQ//,,UF;; f%%%%Vm v{+++++rac ||d}|d||||d||d||d||dddddd|d |S)Nrrr)r'r() rr|rrsidepriceamountcost takerOrMakertypeorderfeer)r  safe_trader safe_string_lowerrl)r^rirr|s r`rszcoincatch.parse_ws_trades%%eQ// " Y//X&**5!44%%eQ//&&ua00     racKd}|dd|\}}d}|dkrd}d}||dd|\}}||dd }d |z}|||||d{VS) aI watch balance and get the amount of funds available for trading or funds locked in orders https://coincatch.github.io/github.io/en/spot/#account-channel https://coincatch.github.io/github.io/en/mix/#account-channel :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: 'spot' or 'swap'(default is 'spot') :param str [params.instType]: *swap only* 'umcbl' or 'dmcbl'(default is 'umcbl') :returns dict: a `balance structure ` Nr.spblrumcblaccountrddefaultrbalance:)handle_market_type_and_paramshandle_option_and_paramslowerr)r^rr{rdrrrs r` watch_balancezcoincatch.watch_balances99.$PVWW f 6>>H88Q[]eff&    !8>>#3#33 '' [$OOOOOOOOOrac||dg}tdt|D]}||}||dd}||}||jvr |j|n|}d|vrdnd} ||| |d<||d|d <||d |d <||j|<||j|_| |d } | | d } d| z} | |j| dS)NrrcoinName marginCoinmaxTransferOut availablefreeequitytotalfrozenusedrrdr) rrrr rnbalancerrl safe_balancerrr) r^rrrr rawBalance currencyIdcoder freeQueryrrdrs r`handle_balancezcoincatch.handle_balance,sgJ~~gvr22q#d))$$ ) )AaJ++J LQQJ**:66D-1T\-A-Adl4(( G-=-K-K((R]I"..z9EEGFO#// HEEGG "..z8DDGFO!(DL  ((66 nnWe,,))#z:: 8+ t|[11111racKd}|d{Vd}d}|%||}|d}|d}d}||||\}}d} |} |dkr&|#t|jdz|zdz|zd zn=d } d } ||||d | \} }n|d dkrd} d} ||d} | rd} ||d}| | | d} d}||d|zz }| ||| |d{V}|j r| ||}| ||||dS)a watches information on multiple orders made by the user https://coincatch.github.io/github.io/en/spot/#order-channel https://coincatch.github.io/github.io/en/mix/#order-channel https://coincatch.github.io/github.io/en/mix/#plan-order-channel :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 :param str [params.type]: 'spot' or 'swap' :param str [params.instType]: *swap only* 'umcbl' or 'dmcbl'(default is 'umcbl') :param bool [params.trigger]: *swap only* whether to watch trigger orders(default is False) :returns dict[]: a list of `order structures ` r*NrrrrrXz"() requires a symbol argument for z markets.rrrdrjrdmcblorderstrigger ordersAlgorrT) rrrrrrrr@r2rrrfilter_by_symbol_since_limit)r^rrrr methodNamerrs marketTyperdrcr isTriggerrrrs r` watch_orderszcoincatch.watch_ordersbs"# !!!!!!!!!  [[((FH%Fd|H !?? FTZ[[ F   ~'# (BEi(ilv(vzE)EFFFFH~#'#@#@U_ai#j#j &&==**a//&HNN6955  2"GYYvy11F       3< 'K))+{D&QQQQQQQQ ? 3OOFE22E00tTTTrac||di}||d}||d}d}|dkrd}nd}||dg}|j0||jdd }t ||_d } |j} d} td t|D]} || } || d|}| |dd|}| | |}| ||d } d | z}| | || | | dS)Nrrdrcrrrr ordersLimitr3rrrzorders:) rrlrrr rXrrr safe_marketparse_ws_orderrr)r^rrrrd argInstIdrrrrr#rrr|rsrr$rs r` handle_orderzcoincatch.handle_orderszBnnWeR00##C44$$S(33  v  JJJ~~gvr22 ; %%dlM4HHE077DKq#d))$$ 0 0AGE''xCCH%%hdJGGF((77F MM& ! ! !H%F#f,K NN6; / / / /vt$$$$$rar|c P||d}||d}||||}||d}|d}||d}||dg}||d} t j|| dd } || d } |||d } |||d } | | } ||d }| id||dd||dd|d| |ddd||dd| |d|d|d| ||dd||dd| d||d d||dd||d d!dd"ddd||d#d| | d$| |d%d|d&|S)'NrctgtCcycTimerstatusorderFeerr}z-1feeCcypxavgPxordTyperordId clientOrderIdclOrdIdr|rlastTradeTimestamplastUpdateTimestampuTimer{ timeInForceforcervrwrrxszfilled accFillSz remaining triggerPricenotional)currencyryr)takeProfitPrice stopLossPriceryrlr} reduceOnlypostOnlyr)rlror rrrr  omit_zeror safe_orderr parse_order_statusparseOrderTimeInForcer@)r^r|rrssettleIdr|r rawStatusrr}feeCost feeCurrencyrwpriceAvgr{s r`rzcoincatch.parse_ws_orders!`##E844##E844&&xBB%%eW55 !$$UH55 >>%R88nnXq))$T%5%5c5%A%A4HH&&sH55 t//t<<==>>$"2"25'"B"BCC =E%%eY77 $""5'22 T--eY??     Y//  !$  "4#4#4UG#D#D   d--i88  f  D  455d6L6LUT[6\6\]]  D**5&99  U  t''w77  d&&ud33  d&&uk:: ! " D# $ $!$$UJ77'..669   : ; racK|d{V||d}g}d}g}|tdt|D]z}||} || } || } || |s|| ||dz| z{nddg}||g} g} tdt|D]@}||} | |dd }| |dz| z| |A||| | |d{V}|j r|S| ||||d S) a watch all open positions https://coincatch.github.io/github.io/en/mix/#positions-channel :param str[]|None symbols: list of unified market symbols @param since @param limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr positionsr::rrrrT) rr5rrrget_private_inst_typerrrrfilter_by_symbols_since_limit)r^rrrrrr instTypesrrrrdrrr newPositionss r`watch_positionszcoincatch.watch_positionsUs!!!!!!!!!%%gv66   1c'll++ ; ; V,,55f==}}Xy99/$$X...$$TD[6%9::::  ;!'*I   & & &q#i..))  A |H$#C  " "4$;#9 : : : KK    !88Y]_effffffff ?  11,PUW[\\\racL|d}|ddkrdSdS)Nrrjrrr)r)r^rrss r`rzcoincatch.get_private_inst_types,$< == " "a ' '7wrac|jt|_|j}||dg}t|}|dkrdSg}g}t dt|D]d}||} || } || d|| || ed} ||| } t dt| D]}| |} | d}|d}| ||rag}t dt|D]+}||} | d|kr|| ,| || | || dS)Nrrrrrr') rrrrrparse_ws_positionrrsplitrr)r^rrcache rawPositions dataLengthrrr rawPositionpositionrrrpartsrpositionsForSymboljs r`handle_positionszcoincatch.handle_positionssF > !577DNw;; && ?? F q#l++,, # #A&q/K--k::H NN8H- . . .    ) ) ) LL " " " "00>> q#m,,-- @ @A'*K%%d++E1XF}}VW-- @%'"q#l"3"344<>#  4++H6GHH#  $#  $**85GHH#  ))(K@@#   0 07 C C# *!# " h## $"&+/+;+;HFV+W+W#'+++HlCC#'#4#4Xw#G#G!#$9# # #    racp||d} |dkr||d}|jdz||z}||jdd||||dd}||jdd ||t |d S#t$r_}t|tr*d }| ||||j vr|j |=n| |Yd}~d Sd}~wwxYw) Neventr[rrXr#rTmsgrrUFrvT) rlrjsonthrow_exactly_matched_exceptionrZthrow_broadly_matched_exceptionr Exception isinstancerrZr) r^rrr rfeedbackr ers r`handle_error_messagezcoincatch.handle_error_messagesT  '22 ''887S=499W+=+==44T_T5J75SUY[cddd&&wr::44T_T5J75SUXZbccc#H---5   !011 !-  a---&"666,[9 a   44444 sB2C D5AD00D5c|||rdS||d}|dkr|||dS|dkr|||dS||d}|dkr|||dS|dkr|||dS|dkr|||dS||di}||d}|d kr||||d d kr| |||d d kr| |||d kr| |||dkr| |||dks|dkr| |||dkr|||dSdS)Nrpongr ryrrrrrrrr0rirrrr)rrl handle_pongrhandle_subscription_statushandle_un_subscription_statusrrrr%rVrtrrr)r^rrcontentr rrs r`handle_messagezcoincatch.handle_message-sH  $ $VW 5 5  F""7I66 f     VW - - - F f     VW - - - F  '22 G    $ $VW 5 5 5 F K    + +FG < < < F M ! !  . .vw ? ? ? F~~gub11""433 h     vw / / / << ! !Q & &   fg . . . << A % %  " "67 3 3 3 g     vw / / / i      0 0 0 x  W %<%<   fg . . . k ! !  ! !&' 2 2 2 2 2 " !racdS)NrG)r^rs r`rGzcoincatch.pingSsvrac8||_|SN) millisecondslastPongr^rrs r`rzcoincatch.handle_pongVs++--rac|Srrr"s r`rz$coincatch.handle_subscription_statusZsrac||d}|||dig}tdt|D]}||}||d}|dkr|||=|dkr|||Z|dkr|||w|dr| |||S) Nrrrrr0rirr) rrrrrl!handle_order_book_un_subscriptionhandle_trades_un_subscriptionhandle_ticker_un_subscription startswithhandle_ohlcv_un_subscription)r^rrargsListrrrs r`rz'coincatch.handle_un_subscription_status]s>>'622  wr::;Hq#h--(( C CA1+C&&sI66G'!!66vwGGGGG##2267CCCCH$$2267CCCC##H-- C11&'BBBrac||di}||d}|dkrdnd}||d}||dd|}|d}d|dz} d |z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} || | | d | dS) Nrrdsprrrcrzunsubscribe:orderbook:z orderbook:z orderbook T) rrrlrr=rrrrZr r^rrrrdr{rcrrrsubMessageHashr[s r`r%z+coincatch.handle_order_book_un_subscriptionns nnWeR00))#z::"d**vv!!#x00!!&$d;;!.1AA %. T_ $ $' V1 1 1$^4 &. . .$[1 =!86!ABB e^,,,t[)))))rac||di}||d}|dkrdnd}||d}||dd|}|d}d|dz} d |z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} || | | d | dS) Nrrdr,rrrcrzunsubscribe:trade:rjz trades T) rrrlrrlrrrrZrr-s r`r&z'coincatch.handle_trades_un_subscriptions nnWeR00))#z::"d**vv!!#x00!!&$d;;!*VH-== !F* T[  F# V1 1 1$^4 &. . .$[1 :!5!>?? e^,,,t[)))))rac||di}||d}|dkrdnd}||d}||dd|}|d}d|dz} d |z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} || | | d | dS) Nrrdr,rrrcrzunsubscribe:ticker:rz ticker T) rrrlrrrrrrZrr-s r`r'z'coincatch.handle_ticker_un_subscriptions nnWeR00))#z::"d**vv!!#x00!!&$d;;!+fX.>> "V+ T\ ! ! V$ V1 1 1$^4 &. . .$[1 :!5!>?? e^,,,t[)))))racL||di}||d}|dkrdnd}||d}||d}|dd }||jd } ||| } ||dd|} | d } d | zd z| d z} d| zd z| z}| |jvr| |j| vr|j| | =|||| dS)Nrrdr,rrrcrrrrFrzunsubscribe:ohlcv:rr) rrrlreplacerXrrrclean_unsubscription)r^rrrrdr{rcrrrrrrrr.s r`r)z&coincatch.handle_ohlcv_un_subscriptionsCnnWeR00))#z::"d**vv!!#x00""3 22??8R00^^DL2CDD ''*== !!&$d;;!*Y6rCs AAAAAAAAAAAA~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~444444******000000......''''''))))))......******------%%%%%%`G`G`G`G`G",`G`G`G`G`Gra