":hmddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZGddej,j.Zy) N) ArrayCacheArrayCacheBySymbolById) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) NotSupportedc eZdZdeffd ZifdefdZifdefdZifdede fdZ difdede fd Z ddifded e d e deefd Zddifdeed e d e deefd Zdifded e defdZdddifded e d e deefdZdefdZdefdZdefdZdefdZifdZifdZdddifded e d e deefdZdddifded e d e deefdZ defdZ!d$dZ"d$dZ#defdZ$defdZ%defd Z&ifde'fd!Z(defd"Z)defd#Z*xZ+S)%upbitreturncr|jtt|ddddddddddd dddiiddidS) NT) wswatchOrderBook watchTicker watchTickers watchTradeswatchTradesForSymbols watchOHLCV watchOrders watchMyTrades watchBalanceapirzwss://{hostname}/websocket/v1 tradesLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s H/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/upbit.pyr(zupbit.describesleT ; ="&# $#)-"#!% $ 9 t%@   symbolc0K|jd{|j|}|d}|d}|j|jddd|ji}|j |j |i|j |<d|j ||<t|j |j}|j|}d|ji||dg} |d z|z} |j|| | | d{S77w) Nr-idr rhostnameTtickettypecodes:) load_marketsmarketimplode_paramsr$r0 safe_valuer%listkeys market_idsuuidwatch) r)r-channelparamsr7marketIdurlsymbols marketIdsrequest messageHashs r+ watch_publiczupbit.watch_public(s!!!V$!$<!!$))E"24"8  ;  !% gr J W(, Wf%t||G,1134OOG, $))+  "   mh. ZZ[';GGG/ ".Hs"DDC6D DDDrCcK|jd{| |j}|j|}|j|}|j |j ddd|j i}g}tdt|D]}|j|dz||zd|ji||dg}|j||||d{S77w)Nr rr0rr5r1r2) r6rCmarket_symbolsr<r8r$r0rangelenappendr=watch_multiple) r)rCr?r@rDrB messageHashesirEs r+watch_public_multiplezupbit.watch_public_multipleBs!!! ?llG%%g.OOG, !!$))E"24"8  ;   q#i.) ?A  31!= > ?$))+  "   ((mWmTTT- ",Us"C&C"CC&C$C&$C&cBK|j|dd{S7w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://global-docs.upbit.com/reference/websocket-ticker :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 ` tickerN)rG)r)r-r@s r+ watch_tickerzupbit.watch_ticker[s!&&vx8888s NcK|j|dd{}|jr i}|||d<|S|j|jd|S79w)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://global-docs.upbit.com/reference/websocket-ticker :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 ` rRNr-)rP newUpdatesfilter_by_arraytickers)r)rCr@ newTickersrWs r+ watch_tickerszupbit.watch_tickersgs\ 55gxHH ??G,6GJx( )N##DLL(GDD IsAA:AsincelimitcHK|j|g|||d{S7w)a get the list of most recent trades for a particular symbol https://global-docs.upbit.com/reference/websocket-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_symbols)r)r-rZr[r@s r+ watch_tradeszupbit.watch_tradesxs'22F8UE6RRRRs " "cnK|jd{|j|dddd}d}g}|j|jddd|ji}|t dt |D]s}|j||} | d } | d } |j|j|i|j|<d|j|| <|j|d z| zut|j|j} |j| } d |ji|| d g}|j||||d{}|j r6|j|d}|j#|d }|j%||}|j'|||ddS77^w)a get the list of most recent trades for a list of symbols https://global-docs.upbit.com/reference/websocket-trade :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 ` NFTtrader rr0rr/r-r5r1r2 timestamp)r6rIr8r$r0rJrKr7r9r%rLr:r;r<r=rMrU safe_stringgetLimitfilter_by_since_limit)r)rCrZr[r@r?rNrBrOr7rAr- optionSymbolsrDrEtradesfirst tradeSymbols r+r]zupbit.watch_trades_for_symbolss!!!%%gtUD$G !!$))E"24"8  ;    1c'l+ ?WQZ0!$<)(, gr(R W%04 W%f-$$Ws]X%=>  ?T\\'2779: OOM2 $))+  "   **3 w VV ??OOFA.E**5(;KOOK7E))&% TRRC "8Ws#F5F0D=F5F3AF53F5cbK|j|dd{}|jS7w)a9 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://global-docs.upbit.com/reference/websocket-orderbook :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 orderbookN)rGr[)r)r-r[r@rjs r+watch_order_bookzupbit.watch_order_books0++FK@@   As /-/1scK|dk7rt|jdz|zdzd|z}|j||d{S7w)a8 watches information an OHLCV with timestamp, openingPrice, highPrice, lowPrice, tradePrice, baseVolume in 1s. https://docs.upbit.com/kr/reference/websocket-candle for Upbit KR https://global-docs.upbit.com/reference/websocket-candle for Upbit Global :param str symbol: unified market symbol of the market orders were made in :param str timeframe: specifies the OHLCV candle interval to watch. As of now, Upbit only supports 1s candles. :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 :returns OHLCV[]: a list of `OHLCV structures ` rlz watchOHLCV does not supportz candle.zcandle.N)rr/rG)r)r- timeframerZr[r@timeFrameOHLCVs r+ watch_ohlcvzupbit.watch_ohlcvsS  tww)GG)SV``a a"Y.&&v~>>>>s>AAAclientc|j|d}d|z}|j|}|d}||j|<|j||y)Ncodezticker:r-)rb parse_tickerrWresolve)r)rqmessagerArFrRr-s r+ handle_tickerzupbit.handle_tickersWJ##GV4(* ""7+!% Vv{+r,c<|j|d}|j|dd}|j|d}|j|jdi}|j |dd}|dk(r|j i||j |<|j |}|ji||d<|d } |d } |j|d g} td t| D]s} | | } |j| d }|j| d}|j| d}|j| d}| j||| j||u|j |d}|j|}||d<||d<d|z}|j||y)Nrs- stream_typerr[SNAPSHOTr-bidsasksorderbook_unitsr ask_priceask_size bid_pricebid_sizeradatetimez orderbook:)rb safe_symbolr9r% safe_integer order_book orderbooksresetrJrK safe_floatstoreiso8601ru)r)rqrvrAr-r3r%r[rjr}r~datarOentryrrrrrarrFs r+handle_order_bookzupbit.handle_order_books(##GV4!!(D#67//$,,0@"E!!'7B7 : &*oob%&@DOOF #OOF+ $ (  w(92>q#d)$ ,AGE{;Iuj9H{;Iuj9H JJy( + JJy( + ,%%g{; << *!* + ( *"X- y+.r,cN|j|}|d}|j|j|}|7|j|jdd}t |}||j|<|j ||j|d}d|z}|j||y)Nr-r!r"rsztrade:) parse_trader9rfrr%rrLrbru) r)rqrvr`r-storedr[rArFs r+ handle_tradeszupbit.handle_trades6s  )xf5 >%%dllM4HE&F"(DKK  e##GV4) v{+r,cx|j|d}d|z}|j|}|j||y)Nrsz candle.1s:)rb parse_ohlcvru)r)rqrvrArFohlcvs r+ handle_ohlcvzupbit.handle_ohlcvQs>##GV4"X-   )uk*r,cK|j|j|jdi}|j|d}|j|j|j d}|j ||j|jdd}||d<ddd|zii|d <||jd<|jd dd z}|j|}|Sw) Nrtoken) access_keynoncesha256Fheaders authorizationzBearer r%r /private) check_required_credentials safe_dictr%rbapiKeyr=jwtencodesecretr$rq)r)r@ wsOptions authenticatedauthrrBrqs r+ authenticatezupbit.authenticatees '')..tR@ ((G<  "kkDHHT4;;t{{#;XuME!&Ig #Y%6$Ii "+DLL iit$z1S! sCCcK|jd{d|i}|O|jd{|j|}|d}|g}|j|}||d<|dz|z}|j |j ddd|j i} | dz } d |ji|g} |j| || |d{S777w) Nr3r-r4r5r rr0rr1) rr6r7r<r8r$r0r=r>) r)r-r?rFr@rEr7rCrDrBrvs r+ watch_privatezupbit.watch_privatezs!!! G   ##% % %[[(FH%FhG0I(GG %+f4K!!$))E"24"8  ;   z$))+     ZZ[';GGG- " &"Hs2CCCCBCCCCCcK|jd{d}d}|j|||d{}|jr|j||}|j ||||dS7V79w)a0 watches information on multiple orders made by the user https://global-docs.upbit.com/reference/websocket-myorder :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 :returns dict[]: a list of `order structures ` NmyOrderTr6rrUrcfilter_by_symbol_since_limit)r)r-rZr[r@r?rForderss r+ watch_orderszupbit.watch_orderssw!!! ))&';GG ??OOFE2E00tTT "HA1A-A1A/8A1/A1cK|jd{d}d}|j|||d{}|jr|j||}|j ||||dS7V79w)a0 watches information on multiple trades made by the user https://global-docs.upbit.com/reference/websocket-myorder :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 :returns dict[]: a list of `trade structures ` NrmyTradesTr)r)r-rZr[r@r?rFrfs r+watch_my_tradeszupbit.watch_my_tradessw!!! ))&';GG ??OOFE2E00tTT "Hrstatusc8dddddd}|j|||S)Nopenclosedcanceled)waitdonecancelr>r`)rb)r)rstatusess r+parse_ws_order_statuszupbit.parse_ws_order_statuss/   &&99r,c B|j|d}|j|d}|dk(rd}nd}|j|j|d}|j|j|d}|j|d}|j ||}d}|j|d } | |d | d }|j id |d |ddd|d|j |d|j|dd|dd|j|dd|j|dddd|d|j|dddddd|j|dd|j|d d!|j|d"|j|d#|j|d$||dd%S)&Nr=ask_bidbidbuysellorder_timestampstaterspaid_feequotecurrencycostinfor/ clientOrderIdrarlastTradeTimestamptrade_timestampr-r3 order_type timeInForce time_in_forcepostOnlysideprice stopPrice triggerPricerexecuted_fundsaverage avg_priceamountvolumeexecuted_volumeremaining_volume)filled remainingrfeerf)rbsafe_string_lower parse8601r safe_market safe_orderr) r)orderr7r/rrarrArfeeCosts r+parse_ws_orderzupbit.parse_ws_ordersA2  eV ,%%eY7 5=DDNN4#3#3E;L#MN ++D,<,` NmyAsset)r6r)r)r@r?rFs r+ watch_balancezupbit.watch_balanceWsH!!! ''g{CCC "Ds>:><>>cb|j|dg}|j|d}||jd<|j||jd<t dt |D]}||}|j |d}|j|}|j |d} |j |d} |j} | | d<| | d <| |j|<|j|j|_|j |d } |j|j| y) Nassetsrarrrbalancelockedfreeusedr3) safe_listrrrrJrKrbsafe_currency_codeaccount safe_balanceru) r)rqrvrrarOr currencyIdrs availablefrozenrrFs r+handle_balancezupbit.handle_balancees"~~gx4%%g{; $- [!#'<< #: Z q#d)$ ;A1gG))':>J**:6D(()rs9 Offf4)F $D   $ $F $r,