E#inZSSKrSSKJrJr SSKJrJrJrJ r J r J r J r J r Jr SSKJr SSKJr SSKJr SSKJr "SS \R,R.5rg) N) ArrayCacheArrayCacheBySymbolById) AnyBalancesBoolIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError) NotSupportedc ^\rSrSrS\4U4Sjjr04S\4SjjrS\4Sjr Sr 04S\ S\ 4S jjr S\4S jrS S 04S\ S \S \S\\4SjjrS\4SjrS S S 04S\S \S \S\\4SjjrS\4SjrS S S 04S\S \S \S\\4SjjrS\4SjrS 04S\ S \S\4SjjrSr04S\ S\ 4SjjrS\4SjrSrSr S\S\!4Sjr"S\4Sjr#S\4Sjr$S\4Sjr%04Sjr&S r'U=r($)!probitreturnc>UR[[U]5SSSSSSSSSSS. SS0SS0S.SS S S .00S .5$) NTF) ws watchBalance watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOrderswatchOrderBook watchOHLCVrz'wss://api.probit.com/api/exchange/v1/wsz,wss://demo-api.probit.com/api/exchange/v1/ws)apitestrorder_books_l2d)filterinterval)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s I/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/probit.pyr-probit.describesfd < > $# %#).!%#"&# CH !. ## 7A   c~# URU5IShvN SnURUSU5IShvN $N!N7f)a. watch balance and get the amount of funds available for trading or funds locked in orders https://docs-en.probit.com/reference/balance-1 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nbalance) authenticatesubscribe_private)r.params messageHashs r0 watch_balanceprobit.watch_balance1s@''' ++KFKKK (Ks=9=;==clientcbSnURU5 URURU5 g)Nr4)parse_ws_balanceresolver4)r.r;messager8s r0handle_balanceprobit.handle_balance>s)  g&t||[1r2cURUSS5nURUS05n[UR55nU(a0Ul[ S[ U55HdnXEnX6nURU5nUR5n URUS5U S'URUS5U S'XRU'Mf URUR5Ulg)NresetFdatar availablefreetotal) safe_bool safe_valuelistkeysr4rangelensafe_currency_codeaccount safe_string safe_balance) r.r?rCrD currencyIdsi currencyIdentrycoderOs r0r=probit.parse_ws_balanceOsw7w3499;' DLq#k*+A$J$E**:6DllnG"..ukBGFO#//w?GG !(LL ,((6 r2symbolcJ# SnURSUSX25IShvN $N7f)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs-en.probit.com/reference/marketdata :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 int [params.interval]: Unit time to synchronize market information(ms). Available units: 100, 500 :returns dict: a `ticker structure ` tickerrN)subscribe_public)r.rXr7channels r0 watch_tickerprobit.watch_tickerks)**=&(G\\\\s #!#cURUS5nURU5nURUS05nURU5nUR XV5nSU-nXpR U'UR Xx5 g)N market_idrZzticker:)rP safe_symbolrI safe_market parse_tickertickersr>) r.r;r?marketIdrXrZmarket parsedTickerr8s r0 handle_tickerprobit.handle_tickerysz&##G[9!!(+(B7!!(+((8 &( + V|1r2Nsincelimitc# SnURU5nURSUSXT5IShvN nUR(aURX5nUR XaX#S5$N97f)aB get the list of most recent trades for a particular symbol https://docs-en.probit.com/reference/trade_history :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 :param int [params.interval]: Unit time to synchronize market information(ms). Available units: 100, 500 :returns dict[]: a list of `trade structures ` recent_tradesrtradesNT)rar[ newUpdatesgetLimitfilter_by_symbol_since_limit)r.rXrjrkr7r\rns r0 watch_tradesprobit.watch_tradesse"!!&),,]FHg^^ ??OOF2E00tTT_s+A)A':A)cVURUS5nURU5nURU5nURUS/5nUR USS5(agSU-nURUR U5nUc6UR URSS5n [U 5nXR U'[S[U55H)n Xjn URX5n URU 5 M+ XR U'URUR UU5 g) Nr`rmrCFztrades: tradesLimitr)rPrarbrIrHrn safe_integerr)rrLrM parse_tradeappendr>) r.r;r?rerXrfrnr8storedrkrStradeparseds r0 handle_tradesprobit.handle_tradess *##G[9!!(+!!(+/2> >>'7E 2 2 &( f5 >%%dllM4HE&F"(KK q#f+&AIE%%e4F MM& !'% Ft{{6*K8r2cT# UR5IShvN URU5IShvN SnUbURU5nUS-U-nURUSU5IShvN nUR(aUR X5nUR XaX#S5$NNtN=7f)a get the list of trades associated with the user https://docs-en.probit.com/reference/trade_history :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 ` Nrn: trade_historyT) load_marketsr5rar6rorprq)r.rXrjrkr7r8rns r0watch_my_tradesprobit.watch_my_tradess!!!'''  %%f-F%+f4K--k?FSS ??OOF2E00tTT "' Ts1B(B"B(B$8B((B&):B($B(&B(cURUS/5n[U5nUS:XagURUSS5(agSnURnUc.UR UR SS5n[ U5nX`lURU5n0n [S[U55H:n Xn URU SS 5S :XaM"S XS 'URU 5 M< [U R55n [U 5n U S:Xag[S[U 55H!nXnUS -U-nURUU5 M# URXe5 g)NrDrrCFrnrurvinfostatusexecutedTrXr)rIrMrHmyTradesrwr)r parse_tradesrLrPryrJrKr>)r.r;r? rawTradeslengthr8rzrkrn tradeSymbolsjr{unique uniqueLengthrSrXsymbolSpecificMessageHashs r0handle_my_tradesprobit.handle_my_tradessP(OOGVR8 Y Q;  >>'7E 2 2   >%%dllM4HE+E2F"M""9- q#f+&AIEf x8JF,0Lx ) MM% 'l'')*6{ 1  q#f+&AYF(3c(9F(B % NN6#< =' v+r2c # URU5IShvN SnUbURU5nUS-U-nURUSU5IShvN nUR(aUR X5nUR XaX#S5$NrN;7f)a  watches information on an order made by the user https://docs-en.probit.com/reference/open_order :param str symbol: unified symbol of the market the order was made in :param int [since]: timestamp in ms of the earliest order to watch :param int [limit]: the maximum amount of orders to watch :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: choose what channel to use. Can open_order or order_history. :returns dict: An `order structure ` Nordersr open_orderT)r5rar6rorprq)r.rXrjrkr7r8rs r0 watch_ordersprobit.watch_orderss'''  %%f-F%+f4K--k<PP ??OOF2E00tTT ( Qs!BB 8BB :B Bc\URUS/5n[U5nUS:XagSnURUSS5nURnUbU(a.UR UR SS5n[ U5nXpl0n [S[U55H0n X:n URU 5n SXS 'URU 5 M2 [U R55n [S[U 55H n XnUS -U-nURX5 M" URXu5 g) NrDrrrCF ordersLimitrvTrXr) rIrMrHrrwr)rrL parse_orderryrJrKr>)r.r;r? rawOrdersrr8rCrzrk orderSymbolsrSrawOrderorderrrXrs r0 handle_ordersprobit.handle_orders2s2OOGVR8 Y Q;  w7 >U%%dllM4HE+E2F K q#i.)A |H$$X.E,0Lx ) MM% * l'')*q#f+&AYF(3c(9F(B % NN6 =' v+r2c# SnURUSSS5upCURSUSXC5IShvN nUR5$N7f)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs-en.probit.com/reference/marketdata :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 Nrr% order_books orderbook)handle_option_and_paramsr[rk)r.rXrkr7r\rs r0watch_order_bookprobit.watch_order_bookcsU77@PRZ\ij//0@&+W^gg   hs0A AA c# URSSnSUS.nURXS5nUnURXAXg5IShvN $N7f)Nr!r subscribe)typer\)r(extendwatch)r.r8r\r7urlrrequest subscribeHashs r0r6probit.subscribe_privatessQiit$ ++i0# ZZ'IIIIsAA AA  methodNamec# UR5IShvN URU5nUSnURSSnURU5nSU-n US-U-n 0n XR;a!URU n XK;a URU SX'[ U R 55n Sn URXQSS5upS S US U U S .nURX5nURXzXU 5IShvN $NN7f) NrXr!rz marketdata:rTr&r$r marketdataid)rr\r`r%r&) rrfr(r; subscriptionsrJrKrrr)r.rrXdataTyper%r7rfrr;rr8filtersrKr&rs r0r[probit.subscribe_public}s!!!V$!iit$S!%. nv-  00 0**=9G%((7GLLN#88ZY\]#  ++g.ZZ''RRR5 "4Ss"DC>C"D9D:DDc URUS5nURU5nURUS5nSU-nXPR;aUR 05URU'URUnUR USS5n U (a(UR XeSSSSS 5n URU 5 OURX5 URX5 g) Nr`sidez orderbook:rCFbuysellpricequantity) rPragroup_by orderbooks order_bookrHparse_order_bookrC handle_deltar>) r.r;r? orderBookrerX dataBySider8rrCsnapshots r0handle_order_bookprobit.handle_order_books##G[9!!(+]]9f5 "V+ //)&*oob&9DOOF #OOF+ w7 ,,ZufV]_ijH OOH %   i 4y.r2c[S[U55H+nX#nURUSS5nURU5 M- g)Nrrr)rLrM parse_bid_ask storeArray)r.bookSidebidAsksrSbidAskr|s r0handle_bid_asksprobit.handle_bid_askss@q#g,'AZF''DF    '(r2cUSnUSnURUS/5nURUS/5nURX65 URXE5 g)Nbidsasksrr)rIr)r.rdelta storedBids storedAsksrrs r0rprobit.handle_deltasVv& v& ufb1ueR0 Z. Z.r2cURUS5nURUSS5nURUS5nURS-U-S-U-S-URU5-nSUR;aUR URSX65 SUR;aUR URSXF5 [U5e)N errorCoder?details exactbroad)rPrIrjson exceptionsthrow_exactly_matched_exceptionthrow_broadly_matched_exceptionr)r.r;r?rV errMessagerfeedbacks r0handle_error_messageprobit.handle_error_messages5%%gy"= //'9577S=4'#- :S@499WCUU doo %  0 01I4 Z doo %  0 01I: `H%%r2cURUS5nURSnUS:XaSnURX%5 gURU5 URS g)Nresult authenticatedok)rPrr>reject)r.r;r?rfuturer8s r0handle_authenticateprobit.handle_authenticatesX!!'84%%o6 T>)K NN7 0 MM' "$$_5r2c0URUS5nUbURX5 URUS/5n[U5nU(aURX5 UR U/SQ/5n[U5nU(aUR XU5 gg)NrZrm)rorder_books_l1r#order_books_l3order_books_l4)rIrhrMr} safe_value_nr)r.r;r?rZrn tradesLengthrorderBookLengths r0handle_market_dataprobit.handle_market_datas(3     v //2>6{    v /%%g0GIKL i.   " "6I > r2cURUS5nUbURX5 gURUS5nUS:XaURX5 gURURUR UR UR S.nURUS5nURXV5nUb U"X5 g[URS-URU5-5nURU5 g)Nrr authorization)rr4rr order_historyr\z! handleMessage: unknown message: ) rPrrrr@rrrIrrrr) r.r;r?rrhandlersr\handlererrors r0handle_messageprobit.handle_messages$$Wk:   % %f 6 0 ? "  $ $V 5 11**!22,,!//  ""7I6//(4   F $ TWW'JJTYYW^M__` er2c# URSSnURU5nSnURURSS5nUR UR U5nUbUR 5U:agUR5IShvN nURUS5nSUS.n URX$URX5U5IShvN nXcR U'U$NUN7f) Nr!rrexpiresr access_tokenr)rtoken) r(r;rwr)rIr millisecondssign_inrPrr) r.r7rr;r8rrresponse accessTokenrs r0r5probit.authenticatesiit$S!% ##DLL)Q?!5!5{C N 1 1 3g =!\\^+H**8^DK'$G ::c G8TVabbF06  - ,cs%B C% C! AC% C# C%#C%)r4rr))__name__ __module__ __qualname____firstlineno__rr-rr9rr@r=strr r]rhrrr rrr}r rrr rrr rr6r[rrrrrrrrr5__static_attributes__ __classcell__)r/s@r0rrs # @*, L L2V2"7868 ] ]F ]2F28<@d[]UUSUUbfglbmU(&9F&9P37TX\egUCUsURUUlpqvlwU.1,v1,f04$UYbdUUCUsUimnsitU./,F/,b@DB!S!!S\! J]_SScS://<( /&6&t&( 6& 6 ? ?"V"H)+r2r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r r !ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrr2r0rs< OZZZ4*)_T   & &_r2