E#ipSSKrSSKJrJr SSKJrJrJrJ r J r J r J r J r JrJr SSKJr SSKJr SSKJr "SS\R,R.5rg) N) ArrayCacheArrayCacheBySymbolById) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) NotSupportedc V^\rSrSrS\4U4Sjjr04S\4Sjjr04S\4Sjjr 04S\S\ 4Sjjr S 04S\S\ 4S jjr S S 04S\S \S \S\\4S jjrS S 04S\\S \S \S\\4SjjrS 04S\S \S\4SjjrSS S 04S\S\S \S \S\\4 SjjrS\4SjrS\4SjrS\4SjrS\4Sjr04Sjr04SjrS S S 04S\S \S \S\\4Sjjr S S S 04S\S \S \S\\4Sjjr!S\4Sjr"S'Sjr#S'Sjr$S\4S jr%S\4S!jr&S\4S"jr'04S\(4S#jjr)S\4S$jr*S\4S%jr+S&r,U=r-$)(upbitreturncr>UR[[U]5SSSSSSSSSSS. SSS00SS0S.5$) NT) wswatchOrderBook watchTicker watchTickers watchTradeswatchTradesForSymbols watchOHLCV watchOrders watchMyTrades watchBalanceapirzwss://{hostname}/websocket/v1 tradesLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s H/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/upbit.pyr)upbit.describesleT ; ="&# $#)-"#!% $ 9 t%@   symbolc,# UR5IShvN URU5nUSnUSnURURSSSUR05nUR UR U05UR U'SUR UU'[UR UR55nURU5nSUR50UUS./n US -U-n URXjX5IShvN $NN7f) Nr/idr!rhostnameTtickettypecodes:) load_marketsmarketimplode_paramsr%r2 safe_valuer&listkeys market_idsuuidwatch) r*r/channelparamsr9marketIdurlsymbols marketIdsrequest messageHashs r, watch_publicupbit.watch_public(s!!!V$!$<!!$))E"24"8  ;  !% gr J W(, Wf%t||G,1134OOG, $))+  "   mh. ZZ'GGG/ ".Hs"DDC4D D DDrEc# UR5IShvN Uc URnURU5nURU5nUR UR SSSUR 05n/n[S[U55HnURUS-XG-5 M SUR50UUS./nURXVX5IShvN $NN7f)Nr!rr2rr7r3r4) r8rEmarket_symbolsr>r:r%r2rangelenappendr?watch_multiple) r*rErArBrFrD messageHashesirGs r,watch_public_multipleupbit.watch_public_multipleBs!!! ?llG%%g.OOG, !!$))E"24"8  ;   q#i.)A  3!= >*$))+  "   ((WTTT- ",Us"C&C"CC&C$C&$C&cB# URUS5IShvN $N7f)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)rI)r*r/rBs r, watch_tickerupbit.watch_ticker[s &&vx8888s Nc# URUS5IShvN nUR(a 0nX4US'U$URURSU5$N=7f)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 ` rVNr/)rS newUpdatesfilter_by_arraytickers)r*rErB newTickersr\s r, watch_tickersupbit.watch_tickersgsY 55gxHH ??G,6Jx( )N##DLL(GDD IsAA>AsincelimitcF# URU/X#U5IShvN $N7f)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/r`rarBs r, watch_tradesupbit.watch_tradesxs$22F8U6RRRRs !!cv# UR5IShvN URUSSSS5nSn/nURURSSSUR05nUb[ S[ U55HsnURX5n U S n U S n URURU05URU'SURUU 'URUS -U -5 Mu [URUR55n URU 5n S UR50UU S ./nURXvX5IShvN nUR (a6URUS5nUR#US 5nUR%UU5nUR'XUSS5$GNNb7f)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!rr2rr1r/r7r3r4 timestamp)r8rLr:r%r2rMrNr9r;r&rOr<r=r>r?rPrZ safe_stringgetLimitfilter_by_since_limit)r*rEr`rarBrArQrDrRr9rCr/ optionSymbolsrFrGtradesfirst tradeSymbols r,rcupbit.watch_trades_for_symbolss!!!%%gtUD$G !!$))E"24"8  ;    1c'l+WZ0!$<)(, gr(R W%04 W%f-$$Ws]X%=> ,T\\'2779: OOM2 $))+  "   **3wVV ??OOFA.E**5(;KOOK7E))& TRRC "8Ws#F9F4D=F9F7A F97F9cb# URUS5IShvN nUR5$N7f)a 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)rIra)r*r/rarBrrs r,watch_order_bookupbit.watch_order_books/++FK@@   As /-/1s timeframec# US:wa[URS-U-S-5eSU-nURX5IShvN $N7f)a 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 ` ruz watchOHLCV does not supportz candle.zcandle.N)rr1rI)r*r/rvr`rarBtimeFrameOHLCVs r, watch_ohlcvupbit.watch_ohlcvsP  tww)GG)SV``a a"Y.&&v>>>>s>AAAclientcURUS5nSU-nURU5nUSnXPRU'URXT5 g)Ncodezticker:r/)ri parse_tickerr\resolve)r*r{messagerCrHrVr/s r, handle_tickerupbit.handle_tickersSJ##GV4(* ""7+!% Vv+r.c<URUS5nURUSS5nURUS5nURURS05nUR USS5nUS:XaUR 0U5UR U'UR UnUR05 XHS'US n US n URUS /5n [S [U 55Hrn Xn URU S 5nURU S5nURU S5nURU S5nU RX5 U RUU5 Mt UR US5nURU5nUUS'UUS'SU-nURUU5 g)Nr}- stream_typerraSNAPSHOTr/bidsasksorderbook_unitsr ask_priceask_size bid_pricebid_sizerhdatetimez orderbook:)ri safe_symbolr;r& safe_integer order_book orderbooksresetrMrN safe_floatstoreiso8601r)r*r{rrCr/r5r&rarrrrdatarRentryrrrrrhrrHs r,handle_order_bookupbit.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.cLURU5nUSnURURU5nUc6URURSS5n[ U5nXPRU'UR U5 URUS5nSU-nURXX5 g)Nr/r"r#r}ztrade:) parse_trader;rmrr&rrOrir) r*r{rrgr/storedrarCrHs r, handle_tradesupbit.handle_trades6s  )xf5 >%%dllM4HE&F"(KK  e##GV4) v+r.cvURUS5nSU-nURU5nURXT5 g)Nr}z candle.1s:)ri parse_ohlcvr)r*r{rrCrHohlcvs r, handle_ohlcvupbit.handle_ohlcvQs<##GV4"X-   )u*r.c# UR5 URURS05nURUS5nUcgURUR 5S.nUR X@RUR5SS5nXRS'SSSU-00US 'X RS'URS SS -nURU5nU$7f) Nrtoken) access_keynoncesha256Fheaders authorizationzBearer r&r!/private) check_required_credentials safe_dictr&riapiKeyr?jwtencodesecretr%r{)r*rB wsOptions authenticatedauthrrDr{s r, authenticateupbit.authenticatees '')..tR@ ((G<  "kkDHHT;;t{{#;XuME!&g #Y%6$Ii "+LL iit$z1S! sCCcj# UR5IShvN SU0nUbNUR5IShvN URU5nUSnU/nURU5nXS'US-U-nUR UR SSSUR 05n U S- n URU 5n S n XR;a0U RU 'Un UbUS-U-n U RU n X;nU(aX]U '/n[U R55n[S [U55HnURU UU5 M S UR50/n[S [U55HnURUU5 M URXUU5IShvN $GNGNyN 7f) Nr5r/r6r7r!rr2rupbitPrivateSubscriptionsrr3)rr8r9r>r:r%r2r{ subscriptionsr<r=rMrNrOr?r@)r*r/rArHrBrGr9rErFrDr{subscriptionsKey channelKeyr isNewChannelrequests channelKeysrRrs r, watch_privateupbit.watch_privatezs!!! G   ##% % %[[(FH%FhG0I(G %+f4K!!$))E"24"8  ;   zS!6 $8$8857F !1 2   3/J,,-=> &7 (/* %=--/0 q#k*+A OOM+a.9 :,$))+   q#h-(A NN8A; ')ZZ';GGGS " &HHs2F3F+F3F.E0F3&F1'F3.F31F3c# UR5IShvN SnSnURXU5IShvN nUR(aURX5nUR XqX#S5$NWN;7f)a 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 ` NmyOrderTr8rrZrjfilter_by_symbol_since_limit)r*r/r`rarBrArHorderss r, watch_ordersupbit.watch_orderssm!!! ))&;GG ??OOF2E00tTT "HA2A.A2A0:A20A2c# UR5IShvN SnSnURXU5IShvN nUR(aURX5nUR XqX#S5$NWN;7f)a 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/r`rarBrArHrms r,watch_my_tradesupbit.watch_my_tradessm!!! ))&;GG ??OOF2E00tTT "Hrstatusc6SSSSSS.nURX!U5$)Nopenclosedcanceled)waitdonecancelr@rg)ri)r*rstatusess r,parse_ws_order_statusupbit.parse_ws_order_statuss-   &99r.c DURUS5nURUS5nUS:XaSnOSnURURUS55nURURUS55nURUS5nUR Xr5nSnURUS 5n U bUS U S .nUR 0S U_S U_SS_SU_SUR U5_SURUS5_SUS_SURUS5_SURUS5_SS_SU_SURUS5_SS_SS_SURUS5_SURUS 5_S!URUS"5_URUS#5URUS$5UUSS%.E5$)&Nr?ask_bidbidbuysellorder_timestampstater}paid_feequotecurrencycostinfor1 clientOrderIdrhrlastTradeTimestamptrade_timestampr/r5 order_type timeInForce time_in_forcepostOnlysideprice stopPrice triggerPricerexecuted_fundsaverage avg_priceamountvolumeexecuted_volumeremaining_volume)filled remainingrfeerm)risafe_string_lower parse8601r safe_market safe_orderr) r*orderr9r1rrhrrCrfeeCosts r,parse_ws_orderupbit.parse_ws_orders?2  eV ,%%eY7 5=DDNN4#3#3E;L#MN ++D,<,` NmyAsset)r8r)r*rBrArHs r, watch_balanceupbit.watch_balancejsD!!! ''gCCC "Ds=9=;==c\URUS/5nURUS5nX@RS'URU5URS'[ S[ U55HnX5nUR US5nURU5nUR US5n UR US5n UR5n XS'XS 'XRU'URUR5UlM UR US 5n URURU 5 g) Nassetsrhrrrbalancelockedfreeusedr5) safe_listrr rrMrNrisafe_currency_codeaccount safe_balancer) r*r{rrrhrRr  currencyIdr} availablefrozenr&rHs r,handle_balanceupbit.handle_balancexs"~~gx4%%g{; $- [!#'<< #: Z q#d)$AgG))':>J**:6D(()rCs9 Offf4)Y $D   $ $Y $r.