":hDddlZddlmZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZGddej$j&Zy) N) ArrayCache)AnyInt OrderBookStringsTickerTickersTrade)Client)List) ExchangeErrorc eZdZdeffd ZifdedefdZdifdede fdZ de fd Z dd Z difded edefd Zde fd ZdZdZddifdeded edeefdZdZddZde fdZde fdZxZS)bithumbreturnc l|jtt|dddddddddddiiiiidS)NTF)ws watchBalance watchTicker watchTickers watchTradeswatchOrderBook watchOHLCVapirzwss://pubwss.bithumb.com/pub/ws)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s J/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/bithumb.pyr!zbithumb.describesbgt = ? %# $#"&#; #B   symbolc:K|jdd}|jd{|j|}d|dz}d|ddz|d zg|j|d d gd }|j |||j |||d{S7n7w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://apidocs.bithumb.com/v1.2.0/reference/%EB%B9%97%EC%8D%B8-%EA%B1%B0%EB%9E%98%EC%86%8C-%EC%A0%95%EB%B3%B4-%EC%88%98%EC%8B%A0 :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.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` rrNticker:r&tickerbase_quote tickTypes24Htypesymbolsr-)r load_marketsmarket safe_stringwatchextend)r"r&paramsurlr3 messageHashrequests r$ watch_tickerzbithumb.watch_ticker%siit$!!!V$&"22 v,vg>?**6;FG  ZZ[$++gv2NP[\\\ "]s"&BBA)BBBBNr1cXK|jd{|jdd}g}g}|j|dddd}tdt |D]L}||}|j |}|j |ddz|d z|j d |d zNd ||j|d dgd} |j| |} |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://apidocs.bithumb.com/v1.2.0/reference/%EB%B9%97%EC%8D%B8-%EA%B1%B0%EB%9E%98%EC%86%8C-%EC%A0%95%EB%B3%B4-%EC%88%98%EC%8B%A0 :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 ` NrrFTrr*r+r,r(r&r)r-r.r/) r2rmarket_symbolsrangelenr3appendr4r6watch_multiple newUpdatesfilter_by_arraytickers) r"r1r7r8 marketIds messageHashesir&r3r:message newTickerresults r$ watch_tickerszbithumb.watch_tickers;sL!!!iit$  %%gtUD$Gq#g,' ?AQZF[[(F   VF^c1F7OC D  VH-=!= >  ?  **6;FG  ++gv.--c='=YY ??F*3F9X& 'M##DLL(GDD+ " Zs"D*D%CD*+D(,:D*(D*clientc|j|di}|j|d}|j|dd}|j|}d|z}||j|<|j |j||y)Ncontentr&r+r() safe_dictr4 safe_symbolparse_ws_tickerrDresolve)r"rLrHrNmarketIdr&r)r9s r$ handle_tickerzbithumb.handle_ticker\s{0..)R8##GX6!!(D#6%%g.&( % Vt||F+[9r%c  |j|dd}|j|dd}|dddz|ddzdz|ddzd z|dd zd z|d dzd z|ddz}|j|d }|jid |j||d d|j|d|d|j|dd|j|dddd|j|dddd|j|dddd|j|dd|j|dddd |j|d!d"|j|d#d$|j|d%d&d|j|d'|j|d(|d)|S)*Ndatetimer-T:r&r+ timestampdatetimehigh highPricelowlowPricebid bidVolume buyVolumeask askVolume sellVolumevwapopen openPriceclose closePricelast previousCloseprevClosePricechangechgAmt percentagechgRateaveragevolumevalue) baseVolume quoteVolumeinfo)r4 safe_tickerrP parse8601)r"r)r3rVrXrarSs r$rQzbithumb.parse_ws_ticker|s@*33!9s?T!AY.4tAay@3FaPQRUXX[_`abc[ddgjjmqrstumvv##FH5! d&&x=! 1!  !  D$$V[9 ! 4##FJ7 ! 4 !  ))&+>!  4!  ))&,?!  D!  D$$V[9!  T%%fl;!  D!  T--f6FG!  d&&vx8! $**69=!! " t#! $**68<++FG<)! * + r%limitc8K|jd{|jdd}|j|}|d}d|z}d|ddz|d zgd }|j|||j |||d{}|j S77w) a https://apidocs.bithumb.com/v1.2.0/reference/%EB%B9%97%EC%8D%B8-%EA%B1%B0%EB%9E%98%EC%86%8C-%EC%A0%95%EB%B3%B4-%EC%88%98%EC%8B%A0 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 Nrrr& orderbook:orderbookdepthr*r+r,r0r1)r2rr3r5r6r) r"r&rr7r8r3r9r: orderbooks r$watch_order_bookzbithumb.watch_order_books!!!iit$V$!'&0 $v,vg>? **S+t{{7F7SU`aa    "bs"BBA*BBBBc|j|di}|j|dg}|j|di}|j|d}|j|dd}|j|d}|j |dd} ||j vr$|j } || d<| |j |<|j |} |j| || | d<|j| | d<d |z} |j| | y) NrNlistrr&r+ra r`r) rO safe_listr4rP parse_to_int orderbooks order_book handle_deltasiso8601rR) r"rLrHrNrfirstrSr& timestampStrr`obrr9s r$handle_order_bookzbithumb.handle_order_books 0..)R8~~gvr2tQ+##E84!!(D#6''< %%l1R&89 $//)"B!BxL&(DOOF #OOF+  9d+!* + $ Y 7 *'&0 y+.r%c|j|d}|dk(rdnd}|j|dd}||}|j|y)N orderTyperfbidsaskspricequantity)r4 parse_bid_ask storeArray)r"rdeltasideIdsidebidAsk orderbookSides r$ handle_deltazbithumb.handle_deltasN!!%5 E/v##E7J?!$   (r%cbtdt|D]}|j|||y)Nr)r>r?r)r"rdeltasrGs r$rzbithumb.handle_deltass0q#f+& 4A   i 3 4r%sincec~K|jd{|jdd}|j|}|d}d|z}d|ddz|d zgd }|j|||j |||d{} |j r| j ||}|j| ||d d S779w) au get the list of most recent trades for a particular symbol https://apidocs.bithumb.com/v1.2.0/reference/%EB%B9%97%EC%8D%B8-%EA%B1%B0%EB%9E%98%EC%86%8C-%EC%A0%95%EB%B3%B4-%EC%88%98%EC%8B%A0 :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 ` Nrrr&trade: transactionr*r+r,rr`T)r2rr3r5r6rBgetLimitfilter_by_since_limit) r"r&rrr7r8r3r9r:tradess r$ watch_tradeszbithumb.watch_tradess!!!iit$V$!' !v,vg>? zz#{DKK4PR]^^ ??OOFE2E))&% TRR "_s"B=B9A*B=B;8B=;B=c|j|di}|j|dg}tdt|D]}||}|j |d}|j |dd}||j vr7|j|jdd} t| } | |j |<|j |} |j|} | j| d|z} |j| | y) NrNrrr&r+ tradesLimitir) rOrr>r?r4rPr safe_integerrrparse_ws_trader@rR)r"rLrHrN rawTradesrGrawTraderSr&rstoredrparsedr9s r$ handle_tradeszbithumb.handle_tradess&..)R8NN7FB7 q#i.) 0A |H''(;H%%hc:Fdkk)))$,, tL#E*&, F#[[(F((2F MM& !'&0K NN6; / 0r%c|j|d}|j|d}|j|dz }|j|d}|jd|||j||j ||ddd|dk(rdndd|j|d |j|d |j|d dd |S) Nr&contDtmib buySellGbr+1buysell contPricecontQtycontAmt) idr}r`rar&orderr0r takerOrMakerramountcostfee)r4r safe_traderrP)r"trader3rSrar`rs r$rzbithumb.parse_ws_trade>s##E84##E95NN8,x7 !!%5" Y/&&x=$mE& %%e[9&&ui8$$UI6   r%cd|vry|j|d} |dk7r-|j|d}t|jdz|zy#t$r}|j |Yd}~yd}~wwxYw)NstatusT0000resmsg )r4r r Exceptionreject)r"rLrH errorCodemsges r$handle_error_messagezbithumb.handle_error_message_s}G#$$Wh7  F"&&w9#DGGcMC$788  MM!   s2A A0A++A0c|j||sy|j|d}|C|j|j|jd}|j ||}| |||yyy)Nr0)r)rr)rr4rTrr safe_value)r"rLrHtopicmethodsmethods r$handle_messagezbithumb.handle_messagers{((9   &1  ,,"&"8"8#11G __We4F!vw'" r%)N)__name__ __module__ __qualname__rr!strrr;rr rKr rTrQrrrrrrr r rrrrr __classcell__)r#s@r$rrs # *68]]F],6:"E7EEB:F:@.`@DB!S!!S\!.(/(/T) 4<@d[]SSSSSbfglbmS4!0FB6& (V (r%r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrrrr r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrr%r$rs9 7PPP4*p(d  ((p(r%