iAddlZddlmZddlmZmZmZmZm Z m Z ddl m Z ddl mZddlmZGddejjZdS) N) ArrayCache)Int OrderBookStringsTickerTickersTrade)Client)List) ExchangeErrorc eZdZfdZifdedefdZdifdedefdZ de fd Z dd Z difded e defd Zde fd ZdZdZddifdede d e deefdZdZddZde fdZde fdZxZS)bithumbc |tt|dddddddddddiiiiidS)NTF)ws watchBalance watchTicker watchTickers watchTradeswatchOrderBook watchOHLCVapirzwss://pubwss.bithumb.com/pub/ws)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s V/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/bithumb.pyrzbithumb.describes~gt 4 4 = = ? ? %# $#"&#; #B B    symbolreturncbK|jdd}|d{V||}d|dz}d|ddz|d zg||d d gd }|||||||d{VS) a. 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 :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$paramsurlr2 messageHashrequests r" watch_tickerzbithumb.watch_ticker%sit$!!!!!!!!!V$$&"22 v,vg>?**6;FFG   ZZ[$++gv2N2NP[\\\\\\\\\r#Nr0cK|d{V|jdd}g}g}||dddd}tdt |D]d}||}||}||ddz|d z|d |d zed |||d dgd} || |} | ||| |d{V} |j ri} | | | 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 :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.) r1rmarket_symbolsrangelenr2appendr3r5watch_multiple newUpdatesfilter_by_arraytickers) r r0r6r7 marketIds messageHashesir$r2r9message newTickerresults r" watch_tickerszbithumb.watch_tickers8s!!!!!!!!!it$  %%gtUD$GGq#g,,'' ? ?AQZF[[((F   VF^c1F7OC D D D  VH-=!= > > > > **6;FFG   ++gv..--c='=YYYYYYYY ? F*3F9X& 'M##DL(GDDDr#clientc||di}||d}||dd}||}d|z}||j|<||j||dS)Ncontentr$r*r') safe_dictr3 safe_symbolparse_ws_tickerrCresolve)r rKrGrMmarketIdr$r(r8s r" handle_tickerzbithumb.handle_tickerVs0..)R88##GX66!!(D#66%%g..&( % Vt|F+[99999r#c ||dd}||dd}|dddz|ddzdz|ddzd z|dd zd z|d dzd z|ddz}||d }|id |||d d||d|d||dd||dddd||dddd||dddd||dd||dddd ||d!d"||d#d$||d%d&d||d'||d(|d)|S)*Ndatetimer-T:r$r* timestampdatetimehigh highPricelowlowPricebid bidVolume buyVolumeask askVolume sellVolumevwapopen openPriceclose closePricelast previousCloseprevClosePricechangechgAmt percentagechgRateaveragevolumevalue) baseVolume quoteVolumeinfo)r3 safe_tickerrO parse8601)r r(r2rUrWr`rRs r"rPzbithumb.parse_ws_tickervs*3333!9s?T!A#Y.4tAaCy@3FaPQcRUXX[_`abc`c[ddgjjmqrsturumvv##FH55! d&&x==! 11!  !  D$$V[99 ! 4##FJ77 ! 4 !  ))&+>>!  4!  ))&,??!  D!  D$$V[99!  T%%fl;;!  D!  T--f6FGG!  d&&vx88! $**69==!! " t#! $**68<<++FG<<)! ! ! * + r#limitc`K|d{V|jdd}||}|d}d|z}d|ddz|d zgd }|||||||d{V}|S) a 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+r/r0)r1rr2r4r5r) r r$rr6r7r2r8r9 orderbooks r"watch_order_bookzbithumb.watch_order_books!!!!!!!!!it$V$$!'&0 $v,vg>?  **S+t{{7F7S7SU`aaaaaaaa    r#c^||di}||dg}||di}||d}||dd}||d}||dd} ||jvr#|} || d<| |j|<|j|} || || | d<|| | d<d |z} | | | dS) NrMlistrr$r*r` r_r) rN safe_listr3rO parse_to_int orderbooks order_book handle_deltasiso8601rQ) r rKrGrMrfirstrRr$ timestampStrr_obrr8s r"handle_order_bookzbithumb.handle_order_books70..)R88~~gvr22tQ++##E844!!(D#66''<< %%l1R4&899 $/))""B!BxL&(DOF #OF+  9d+++!* + $ Y 7 7 *'&0 y+.....r#c||d}|dkrdnd}||dd}||}||dS)N orderTyperebidsaskspricequantity)r3 parse_bid_ask storeArray)r rdeltasideIdsidebidAsk orderbookSides r" handle_deltazbithumb.handle_deltasd!!%55 E//vv##E7J??!$   (((((r#c~tdt|D]}||||dS)Nr)r=r>r)r rdeltasrFs r"rzbithumb.handle_deltassHq#f++&& 4 4A   i 3 3 3 3 4 4r#sincecK|d{V|jdd}||}|d}d|z}d|ddz|d zgd }|||||||d{V} |jr| ||}|| ||d d S) a get the list of most recent trades for a particular symbol :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)r1rr2r4r5rAgetLimitfilter_by_since_limit) r r$rrr6r7r2r8r9tradess r" watch_tradeszbithumb.watch_tradess!!!!!!!!!it$V$$!' !v,vg>?  zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E))&% TRRRr#c,||di}||dg}tdt|D]}||}||d}||dd}||jvr5||jdd} t| } | |j|<|j|} | |} | | d|z} | | | dS) NrMrrr$r* tradesLimitir) rNrr=r>r3rOr safe_integerrrparse_ws_trader?rQ)r rKrGrM rawTradesrFrawTraderRr$rstoredrparsedr8s r" handle_tradeszbithumb.handle_tradess&..)R88NN7FB77 q#i..)) 0 0A |H''(;;H%%hc::Fdk))))$, tLL#E**&, F#[(F((22F MM& ! ! !'&0K NN6; / / / / 0 0r#c||d}||d}||d}|d|||||||ddd|dkrdndd||d||d ||d dd |S) Nr$contDtm buySellGbr*1buysell contPricecontQtycontAmt) idr|r_r`r$orderr/r takerOrMakerramountcostfee)r3 safe_trader~rO)r trader2rRr`rs r"rzbithumb.parse_ws_trade2s##E844##E955!!%5511 &&x==$mmEE& %%e[99&&ui88$$UI66    r#cd|vrdS||d} |dkr0||d}t|jdz|zdS#t$r}||Yd}~nd}~wwxYwdS)NstatusT0000resmsg )r3r r Exceptionreject)r rKrG errorCodemsges r"handle_error_messagezbithumb.handle_error_messageQsG##4$$Wh77  F""&&w99#DGcMC$78884    MM!         ts6A A? A::A?c|||sdS||d}|;|j|j|jd}|||}||||dSdSdS)Nr/)r(rr)rr3rSrr safe_value)r rKrGtopicmethodsmethods r"handle_messagezbithumb.handle_messageds((99  F  &11  ,"&"8#1G __We44F!vw'''''  "!r#)N)__name__ __module__ __qualname__rstrrr:rrrJr rSrPrrrrrrr r rrrrr __classcell__)r!s@r"rrs     *68]]]F]]]]&6:"EE7EEEEE<:F::::@....`@DB!!S!!S\!!!!((/(/(/(/(/T))) 444<@d[]SSSSSSbfglbmSSSS.!0!0!0F>6& (V ( ( ( ( ( ( ( (r#r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrrrr !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrr#r"rs 777777KKKKKKKKKKKKKKKK444444******b(b(b(b(b(d (b(b(b(b(b(r#