":hn*ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z dd lm!Z!dd lm"Z"ddl#m$Z$GddejJjLZ&y)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 edededeefdZdifd edefd 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 fd8Zd e fd;Z?d e fd<Z@d e fd=ZAd e fd>ZBd e fd?ZCd e fd@ZDd e fdAZEd e fdBZFd e fdCZGxZHS)E coincatchreturnc<|jtt|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 L/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/coincatch.pyr]zcoincatch.describesi ? A#)-"&,0"(-#!&# $ $"& "K#M $!    $#& !+!4!+!4!4!2!2!4!4!4!+!4  [@D @ @ c|j|d}|j|d}|j|}|d}|d}d}|dk(r |dk(rd}nd }|j||j|z|z}|j|S) NinstIdinstTypebaseIdquoteId_SPBLmcUSD_DMCBL_UMCBL) safe_stringparseSpotMarketIdsafe_currency_codesafeMarketCustom) r^entryrcrd baseAndQuotererfsuffixmarketIds r`get_market_from_argzcoincatch.get_market_from_arg\s!!%2##E:6--f5 h'y) t %!!**62T5L5LW5UUX^^$$X..racTK|j|jddd}|j|}d}|j|}|j |j |}|t |j}|dzdz}|j|j||j|jtjd} d} | |j|j|| d gd } |j| |} |j!||| ||d{S7w) Nr0r#r2 authenticatedGETz /user/verifybase64login)apiKey passphrase timestampsignopargs)check_required_credentialsrWclientfuture safe_value subscriptionsstrsecondshmacencodesecrethashlibsha256rzpasswordextendwatch) r^paramsurlr messageHashrrvr|auth signature operationrequestmessages r` authenticatezcoincatch.authenticateks '')iit$Y/S!% {+(<(||sDD(!D&"D(cK|jddd}d|gd}|j||}|j||||d{S7wNr0r#r1 subscriber~rWrrr^r subscribeHashrrrrrs r` watch_publiczcoincatch.watch_publicsZiit$X.F ++gv.ZZ['=IIIIAAA AcK|jddd}d|gd}|j||}|j||||d{S7w)Nr0r#r1 unsubscriber~r)r^rrrrrrs r`un_watch_publiczcoincatch.un_watch_publicsZiit$X.F ++gv.ZZ[';GGGGrcK|jd{|jddd}d|gd}|j||}|j||||d{S7M7wNr0r#r2rr~)rrWrrrs r` watch_privatezcoincatch.watch_privatesu!!!iit$Y/F ++gv.ZZ['=III "Js"A(A$AA(A& A(&A(cK|jd{|jddd}d|d}|j||}|j||||d{S7L7wr)rrWrwatch_multiple)r^ messageHashessubscribeHashesrrrrrs r`watch_private_multiplez coincatch.watch_private_multiplesu!!!iit$Y/ ++gv.((mWoVVV "Ws"A'A#AA'A%A'%A'rcbd}|j|j|}|jdy)NrvT)rfuturesresolve)r^rrrrs r`handle_authenticatezcoincatch.handle_authenticates)& =tracK|jddd}d|d}|j||}|j||||d{S7wr)rWrr)r^rr argsArrayrrrrs r`watch_public_multiplezcoincatch.watch_public_multiplesZiit$X. ++gv.((mWoVVVVsAA A A symbolchannelmessageHashTopiccK|jd{|j|}|j|\}}d|zdz|z}|||d} |j|| |d{S7U7w)Nz unsubscribe::rdrrc) load_marketsmarketget_public_inst_type_and_idr) r^rrrrrrdrcrrs r`un_watch_channelzcoincatch.un_watch_channels!!!V$;;FC&$'77#=F    ))+tVDDD "E"A0A,AA0'A.(A0.A0rcx|d|dz}d}|drd}||gS|drd}||gSt|jdz)NrerfspotSPswapMCz$ supports only spot and swap markets)rid)r^rrcrds r`rz%coincatch.get_public_inst_type_and_idsf!F9$55 &>H &!! F^H&!!tww)OOP PraNhash timeframec|d}|j||}|j|j|g}d}|d|z}tdt |D]*} || }|d} || z|z} |j | |s(|cS|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.@.@(BO  9_Fq#234 A)!,FH%F-&0K}}[-8    racK|jd{|j|}|j|\}}d}|dz|z}|||d}|j||||d{S7U7w)at 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$;;FC&mf,    &&{KvNNN "OrczK|jd{|j|dd|d{S7 7w)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_tickers=!!!**68XvNNN "N;7;9;;symbolscK|jd{| |j}g}g}tdt|D]W}||}|j |}|j |\}} |d| d} |j | |j d|zY|j||||d{} |jr i} | | | d<| S|j|jd|S77;w)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 s !!! ?llG q#g,' 5AQZF[[(F#??G Hf$# D MM$   V!3 4 522=-QWY_`` ??F(/F78$ %M##DLL(GDD+ " as"C1C-BC13C/4:C1/C1c|j|di}|j|}|d}d}|jddk\r|j|||}|j |dg}|j |j|di|}|d} ||j | <|| z} |j|j | | y)Nargrrrjrdatar) safe_dictrtfindrrparse_ws_tickerrr) r^rrrrrsrrrrrs r` handle_tickerzcoincatch.handle_ticker+s2nnWeR0))#.$< == "a '??fUF~~gvr2%%dnnT1b&A6J!% VVm t||F+[9rac |j|d}|j|dd}|jid|dd|d|j|d|j|dd |j|d d |j|d d |j|dd|j|dd|j|dddd|j |ddd|d|dddddt j |j|dddd|j|d|j|d|j|d |j|d!|d"|S)#Nlastts systemTimerr|datetimehighhigh24hlowlow24hbidbestBid bidVolumebidSzaskbestAsk askVolumeaskSzvwapopenopen24hopenUtcclose previousClosechange percentagechgUTC100average baseVolume quoteVolume indexPrice markPrice)rrrr info)rlsafe_integer_2 safe_tickeriso8601 safe_string_2r string_mul safe_number)r^rrrr|s r`rzcoincatch.parse_ws_tickerQs^/''lC ! fX&! !   Y/!  D$$VY7 ! 4##FH5 ! 4##FI6 !  ))&':!  4##FI6!  ))&':!  D!  D&&vy)D!  T!  D!  T!  d! ',,T-=-=fh-OQVW!! " t#! $**6<@++FMB**6<@))&+>-! . / rar5sincelimitcK|jd{|j|}|jd}d|j||z}|j |\} } | || d} d|zdz|z} |j | | | |d{} |j r| j||}|j| ||ddS779w) 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)DD;;FC&   '#- 9 '' [$OO ??NN651E))%q$GG "Ps"CCA5C C 8CCcK|jd{|jd}|j||}d|z}|j||d|z|d{S7I7w)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_ohlcvsq!!!\\"34 ##J :X%**67Hx` indexed by market symbols N)watch_order_book_for_symbols)r^rrrs r`watch_order_bookzcoincatch.watch_order_books%66xOOOOs !!cK|jd{d}|j|d}|dk(s|dk(r |j|d}|t|z }|j ||||d{S7^7w)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!!!!!&'2 QJERKYYvw/F s5z !G**67GVLLL " Ms"A9A5AA90A71A97A9cK|jd{|j|}d}g}g}tdt|D]Z}||}|j |} |j | \} } | || d} |j | |j |dz|z\|j||||d{} | jS77w)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 Nr2rrr) rmarket_symbolsrrrrrrr)r^rrrrrrrrrrdrcr orderbooks r`r/z&coincatch.watch_order_book_for_symbols(s!!!%%g. q#g,' 9AQZF[[(F#??G Hf$" D MM$   3!7 8 944]MSY[abb   # " cs"CCB$C;C<CCc|j|di}|j|}|d}d}|jddk\r|j|||}|d}|j |d}||z} |j |dg} |j| d} |j | d } |} | r||jvr%|ji}||d<||j|<|j|}|j | d g}|j | d g}|j|d ||j|d || |d <|j| |d <|j|jdd}|j |ddk(}|sF|rC|d }|d }t|}t|}g}tddD]u}||kr4|j||dd|j||dd||ksB|j||dd|j||ddwdj!|}|j#|d}|j | d}||k7rc|j%|j&||| y|j)i}|j+| || }|j-|||j|<|j/|j|| y)Nrrzbooks:rjrrrrrasksbidsr|rrCTactionsnapshotr*r)r)rrtrrrlrr" orderbookscounted_order_book handle_deltasr  safe_boolrXrrrjoincrc32spawnhandle_check_sum_error order_bookparse_order_bookresetr)r^rrrrrsrrrrr rawOrderBookr|incrementalBookobstoredOrderBookr:r;rC isSnapshot storedAsks storedBids asksLength bidsLength payloadArrayrpayloadcalculatedChecksumresponseChecksumr8parsedOrderbooks r`handle_order_bookzcoincatch.handle_order_bookFs nnWeR0))#.$< == "a '??fUF!""3 2Vm ~~gvr2~~dA. %%lD9 ! doo-,,R0%8 *,'"oof5O>>,;D>>,;D   v6 =   v6 =+4OK (*.,,y*AOJ '~~dllJEH))'8< JJ(,V4 ,V4  _  _ ! q"AA:~$++JqM!,"#'#4#4\:#N %)99JJt::FFKX+I"33L&)TO OOO ,&/DOOF #tv. ` N)watch_trades_for_symbols)r^rrrrs r` watch_tradeszcoincatch.watch_tradess'22F8UE6RRRRs " "cKt|}|dk(rt|jdz|jd{|j |}g}g}t dt|D]W}||} |j | } |j| \} } | d| d} |j| |jd| zY|j||||d{}|jr6|j|d}|j|d}|j||}|j|||dd S77]w) 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)rrrrr7rrrrrrrrlrr)r^rrrr symbolsLengthrrrrrrdrcrtradesfirst tradeSymbols r`rhz"coincatch.watch_trades_for_symbolssLG A #DGG.n$no o!!!%%g. q#g,' 4AQZF[[(F#??G Hf$" D MM$   F!2 3 411-PVX^__ ??NN61-E**5(;KOOK7E))&% TRR) "`s#D:BD>D<AD><D>czK|jd{|j|dd|d{S7 7w)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 Nrkrrs r`un_watch_tradeszcoincatch.un_watch_tradess=!!!**67GVLLL "Lrcp|j|di}|j|}|d}d}|jddk\r|j|||}|d}||jvr5|j |j dd}t||j|<|j|} |j|d g} | a|j| d} tdt| D]7} |j| | } |j| |} | j| 9||z}|j| |y) NrrrlrjrrrDr3r)rrtrrrnr"rXrrsort_byrrparse_ws_traderr)r^rrrrrsrrrr%rrrkr&rs r` handle_tradeszcoincatch.handle_tradess1nnWeR0))#.$< == "a '??fUF!$++%%%dllM4HE",U"3DKK V$~~gvr2  <<a(D1c$i( &tQ/,,UF; f% &Vm v{+rac|j|d}|jd||j||d|j|d|j |d|j |dddddd|d |S)Nrrr+r)r*) rr|rrsidepriceamountcost takerOrMakertypeorderfeer )r" safe_trader safe_string_lowerrl)r^rkrr|s r`ruzcoincatch.parse_ws_trades%%eQ/ " Y/X&**5!4%%eQ/&&ua0    racKd}|jdd|\}}d}|dk(rd}d}|j|dd|\}}||dd }d |jz}|j||||d{S7w) aK 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.$PVW f 6>H88Q[]ef&   !8>>#33 '' [$OOOOsA+A4-A2.A4c|j|dg}tdt|D]}||}|j|dd}|j |}||j vr|j |n|j }d|vrdnd} |j|| |d<|j|d|d <|j|d |d <||j |<|j|j |_|j|d } |j| d } d| z} |j|j | y)NrrcoinName marginCoinmaxTransferOut availablefreeequitytotalfrozenusedrrdr) rrrrrnbalancerrl safe_balancerrr) r^rrrr rawBalance currencyIdcoder freeQueryrrdrs r`handle_balancezcoincatch.handle_balance,s6J~~gvr2q#d)$ )AaJ++J LQJ**:6D-1T\\-Adll4( G-=-K(R]I"..z9EGFO#// HEGG "..z8DGFO!(DLL  )((6 nnWe,))#z: 8+ t||[1racKd}|jd{d}d}||j|}|d}|d}d}|j|||\}}d} |} |dk(r&|Xt|jdz|zdz|zd zd } d } ||j ||d | \} }n|j d dk\rd} d} |j|d} | rd} |j|d}| | | d} d}||d|zz }|j||| |d{}|jr|j||}|j||||dS7,7:w)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*NrrrrrZz"() requires a symbol argument for z markets.rrrdrjrdmcblorderstrigger ordersAlgorrT) rrrrrrrrBr4rrrfilter_by_symbol_since_limit)r^rrrr methodNamerrs marketTyperdrcr isTriggerrrrs r` watch_orderszcoincatch.watch_ordersbs"# !!!  [[(FH%Fd|H !?? FTZ[ F  ~'# (BEi(ilv(vzE)EFFFH~#'#@#@U_ai#j &==*a/&HNN695 "GYYvy1F      3< 'K))+{D&QQ ??OOFE2E00tTTM "FRs"E EC3E  E 8E E cp|j|di}|j|d}|j|d}d}|dk(rd}nd}|j|dg}|j-|j |j dd }t ||_d } |j} d} td t|D]m} || } |j| d|}|j|dd|}|j| |}| j||d } d | z}|j| |o|j| | y)Nrrdrcrrrr ordersLimitr3rrrzorders:) rrlrrr"rXrrr safe_marketparse_ws_orderrr)r^rrrrd argInstIdrrrrr%rrr~rsrr&rs r` handle_orderzcoincatch.handle_ordersBBnnWeR0##C4$$S(3  v JJ~~gvr2 ;; %%dllM4HE07DKq#d)$ 0AGE''xCH%%hdJGF((7F MM& !H%F#f,K NN6; / 0 vt$rar~c l|j|d}|j|d}|j|||}|j|d}|d}|j|d}|j|dg}|j |d} t j |j| dd } |j| d } |j|j|d } |j|j|d } | | } |j|d }|jid|j|dd|j|dd|d|j|ddd|j|dd|j|d|d|d|j|j|dd|j|dd| d|j|d d|j|dd|j|d d!dd"ddd|j|d#d| | d$|j|d%d|d&|S)'NrctgtCcycTimerstatusorderFeerrz-1feeCcypxavgPxordTyperordId clientOrderIdclOrdIdr|rlastTradeTimestamplastUpdateTimestampuTimer} timeInForceforcerxryrrzszfilled accFillSz remaining triggerPricenotional)currencyr{r)takeProfitPrice stopLossPricer{rnr reduceOnlypostOnlyr )rlror"rrrr omit_zeror safe_orderr parse_order_statusparseOrderTimeInForcerB)r^r~rrssettleIdr|r rawStatusrrfeeCost feeCurrencyrypriceAvgr}s r`rzcoincatch.parse_ws_orders`##E84##E84&&xB%%eW5 !$$UH5 >>%R8nnXq)$$T%5%5c5%A4H&&sH5 t//t<=>>$"2"25'"BC =E%%eY7 $""5'2 T--eY?     Y/  !$  "4#4#4UG#D   d--i8  f  D  455d6L6LUT[6\]  D**5&9  U  t''w7  d&&ud3  d&&uk: ! " D# $ $!$$UJ7'..69 : ; racK|jd{|j|d}g}d}g}||tdt|D]c}||} |j | } |j | } |j | |s|j| |j|dz| zenddg}|j|g} g} tdt|D]5}||} | |dd }| j|dz| z| j|7|j|| | |d{}|jr|S|j||||d S7@7*w) 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) rr7rrrget_private_inst_typerrrrfilter_by_symbols_since_limit)r^rrrrrr instTypesrrrrdrrr newPositionss r`watch_positionszcoincatch.watch_positionsUs!!!%%gv6   1c'l+ ; V,55f=}}Xy9$$X.$$TD[6%9:  ;!'*I   &q#i.) A |H$#C  " "4$;#9 : KK  "88Y]_eff ?? 11,PUW[\\= "6gs"EEDE.E/(EEc8|d}|jddk\ryy)Nrrjrrr)r)r^rrss r`rzcoincatch.get_private_inst_types"$< == "a 'rac|jt|_|j}|j|dg}t|}|dk(ryg}g}t dt|D]N}||} |j | } |j | d|j | |j | Pd} |j|| } t dt| D]}}| |} | jd}|d}|j||s1g}t dt|D]!}||} | d|k(s|j | #|j|| |j|| y)Nrrrrrr)) rrrrrparse_ws_positionrrsplitrr)r^rrcache rawPositions dataLengthrrr rawPositionpositionrrrpartsrpositionsForSymboljs r`handle_positionszcoincatch.handle_positionss~F >> !57DNw; & ?  q#l+, #A&q/K--k:H NN8H- .    ) LL "  # 00> q#m,- @A'*K%%d+E1XF}}VW-%'"q#l"34#  4++H6GH#  $#  $**85GH#  ))(K@#   0 07 C# *!# " h## $"&+/+;+;HFV+W#'+++HlC#'#4#4Xw#G!#$9#   rac0|j|d} |dk(r|j|d}|jdz|j|z}|j|jdd|||j|dd}|j |jdd ||t |y #t$r[}t|tr0d }|j||||jvr|j|=n|j|Yd}~y d}~wwxYw) Neventr]rrZr#rTmsgrrUFrvT) rlrjsonthrow_exactly_matched_exceptionrZthrow_broadly_matched_exceptionr Exception isinstancerr\r) r^rrr rfeedbackrers r`handle_error_messagezcoincatch.handle_error_messages  '2 ''877S=499W+==44T__T5J75SUY[cd&&wr:44T__T5J75SUXZbc#H-- !01-  a-&"6"66,,[9 a  sBB11 D:ADDc6|j||ry|j|d}|dk(r|j||y|dk(r|j||y|j|d}|dk(r|j||y|dk(r|j ||y|dk(r|j ||y|j |di}|j|d}|d k(r|j|||jd d k\r|j|||jd d k\r|j|||d k(r|j|||dk(r|j|||dk(s|dk(r|j|||dk(r|j||yy)Nrpongr ryrrrrrrrr2rkrrrr)rrl handle_pongrhandle_subscription_statushandle_un_subscription_statusrrrr'rXrvrrr)r^rrcontentr rrs r`handle_messagezcoincatch.handle_message-s  $ $VW 5 ""7I6 f    VW -  f    VW -   '2 G   $ $VW 5  K   + +FG <  M !  . .vw ? ~~gub1""43 h    vw / << !Q &   fg . << A %  " "67 3 g    vw / i     0 x W %<   fg . k !  ! !&' 2 "racy)NrG)r^rs r`rGzcoincatch.pingSsrac0|j|_|SN) millisecondslastPongr^rrs r`rzcoincatch.handle_pongVs++-rac|Sr!rr$s r`rz$coincatch.handle_subscription_statusZsrac|j|d}||j|dig}tdt|D]}||}|j |d}|dk(r|j ||2|dk(r|j ||J|dk(r|j||b|jdst|j|||S) Nrrrrr2rkrr) 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>>'62  wr:;Hq#h-( CA1+C&&sI6G'!66vwGG#2267CH$2267C##H-11&'B Crac|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d |z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrdsprrrcrzunsubscribe:orderbook:z orderbook:z orderbook T) rrrlrr?rrrr\r r^rrrrdr}rcrrrsubMessageHashr]s r`r'z+coincatch.handle_order_book_un_subscriptionnsnnWeR0))#z:"d*v!!#x0!!&$d;!.1AA %. T__ $' V11 1$$^4 &.. .$$[1 =!86!AB e^,t[)rac|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d |z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrdr.rrrcrzunsubscribe:trade:rlz trades T) rrrlrrnrrrr\rr/s r`r(z'coincatch.handle_trades_un_subscriptionsnnWeR0))#z:"d*v!!#x0!!&$d;!*VH-== !F* T[[  F# V11 1$$^4 &.. .$$[1 :!5!>? e^,t[)rac|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d |z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrdr.rrrcrzunsubscribe:ticker:rz ticker T) rrrlrrrrrr\rr/s r`r)z'coincatch.handle_ticker_un_subscriptionsnnWeR0))#z:"d*v!!#x0!!&$d;!+fX.>> "V+ T\\ ! V$ V11 1$$^4 &.. .$$[1 :!5!>? e^,t[)rac|j|di}|j|d}|dk(rdnd}|j|d}|j|d}|jdd }|j|jd } |j || } |j |dd|} | d } d | zd z| d z} d| zd z| z}| |jvr!| |j| vr|j| | =|j||| y)Nrrdr.rrrcrrrrFrzunsubscribe:ohlcv:rr) rrrlreplacerXr rr!clean_unsubscription)r^rrrrdr}rcrrrrrrrr0s r`r+z&coincatch.handle_ohlcv_un_subscriptionsnnWeR0))#z:"d*v!!#x0""3 2??8R0^^DLL2CD ''*= !!&$d;!*Y6rEsb AA~~~~4*0.').*-%`G"",,`Gra