":h`ZddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZGdd ej*j,Zy) N) ArrayCacheArrayCacheBySymbolById)AnyBalancesIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError) NotSupportedc eZdZdeffd ZifdefdZdefdZdZ ifde de fdZ defd Z d d ifde d ed edeefd ZdefdZd d d ifded ed edeefdZdefdZd d d ifded ed edeefdZdefdZd ifde d edefdZdZifde de fdZdefdZdZdZdefdZ defdZ!defdZ"defdZ#ifdZ$xZ%S)probitreturnc|jtt|ddddddddddd ddiddiddd d d iid S) 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/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/probit.pyr+zprobit.describesfd < > $# %#).!%#"&# CH !. ## 7A   c~K|j|d{d}|j|d|d{S7!7w)aV 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 r. watch_balancezprobit.watch_balance1sB''' ++KFKKK (Ks=9=;==clientcbd}|j||j|j|y)Nr1)parse_ws_balanceresolver1)r,r7messager5s r.handle_balancezprobit.handle_balance>s)  g&t||[1r/c|j|dd}|j|di}t|j}|ri|_t dt |D]f}||}||}|j|}|j} |j|d| d<|j|d| d<| |j|<h|j|j|_y)NresetFdatar availablefreetotal) safe_bool safe_valuelistkeysr1rangelensafe_currency_codeaccount safe_string safe_balance) r,r;r>r? currencyIdsi currencyIdentrycoderJs r.r9zprobit.parse_ws_balanceOsw7w3499;' DLq#k*+ )A$QJ$E**:6DllnG"..ukBGFO#//w?GG !(DLL  )((6 r/symbolcLKd}|jd|d||d{S7w)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,rRr4channels r. watch_tickerzprobit.watch_tickerks-**=&(GU[\\\\s $"$c|j|d}|j|}|j|di}|j|}|j ||}d|z}||j |<|j ||y)N market_idrTzticker:)rK safe_symbolrD safe_market parse_tickertickersr:) r,r7r;marketIdrRrTmarket parsedTickerr5s r. handle_tickerzprobit.handle_tickerys&##G[9!!(+(B7!!(+((8 &( + V|[1r/NsincelimitcKd}|j|}|jd|d||d{}|jr|j||}|j ||||dS77w)a 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)rZrU newUpdatesgetLimitfilter_by_symbol_since_limit)r,rRrbrcr4rVrfs r. watch_tradeszprobit.watch_tradesso"!!&),,]FHgW]^^ ??OOFE2E00tTT_s,A(A&8A(cN|j|d}|j|}|j|}|j|dg}|j |ddryd|z}|j|j |}|7|j |jdd} t| }||j |<tdt|D]*} || } |j| |} |j| ,||j |<|j|j ||y) NrYrer>Fztrades: tradesLimitr)rKrZr[rDrCrf safe_integerr'rrGrH parse_tradeappendr:) r,r7r;r^rRr_rfr5storedrcrNtradeparseds r. handle_tradeszprobit.handle_tradess*##G[9!!(+!!(+/2> >>'7E 2 &( f5 >%%dllM4HE&F"(DKK q#f+& "A1IE%%eV4F MM& ! "% Ft{{6*K8r/cNK|jd{|j|d{d}||j|}|dz|z}|j|d|d{}|jr|j ||}|j ||||dS77q7;w)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 ` Nrf: trade_historyT) load_marketsr2rZr3rgrhri)r,rRrbrcr4r5rfs r.watch_my_tradeszprobit.watch_my_tradess!!!'''  %%f-F%+f4K--k?FSS ??OOFE2E00tTT "' Ts1B%BB%B!7B%'B#(8B%!B%#B%c|j|dg}t|}|dk(ry|j|ddryd}|j}|/|j |j dd}t |}||_|j|}i} tdt|D]9} || } |j| dd d k(r!d | | d <|j| ;t| j} t| } | dk(rytdt| D]!}| |}|d z|z}|j||#|j||y)Nr?rr>FrfrlrminfostatusexecutedTrRrv)rDrHrCmyTradesrnr'r parse_tradesrGrKrprErFr:)r,r7r; rawTradeslengthr5rqrcrf tradeSymbolsjrrunique uniqueLengthrNrRsymbolSpecificMessageHashs r.handle_my_tradeszprobit.handle_my_tradessa(OOGVR8 Y Q;  >>'7E 2   >%%dllM4HE+E2F"DM""9- q#f+& !A1IEf x8JF,0Lx ) MM%  !l'')*6{ 1  q#f+& >AAYF(3c(9F(B % NN6#< = > v{+r/cK|j|d{d}||j|}|dz|z}|j|d|d{}|jr|j ||}|j ||||dS7o79w)ah 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 ` Nordersrv open_orderT)r2rZr3rgrhri)r,rRrbrcr4r5rs r. watch_orderszprobit.watch_orderss'''  %%f-F%+f4K--k<PP ??OOFE2E00tTT ( Qs!B B7B B 8B  B cR|j|dg}t|}|dk(ryd}|j|dd}|j}||r/|j |j dd}t |}||_i} tdt|D]1} || } |j| } d| | d <|j| 3t| j} tdt| D]!} | | }|d z|z}|j||#|j||y) Nr?rrr>F ordersLimitrmTrRrv) rDrHrCrrnr'rrG parse_orderrprErFr:)r,r7r; rawOrdersrr5r>rqrc orderSymbolsrNrawOrderorderrrRrs r. handle_orderszprobit.handle_orders2s22OOGVR8 Y Q;  w7 >U%%dllM4HE+E2F DK q#i.) !A |H$$X.E,0Lx ) MM%  ! l'')*q#f+& >AAYF(3c(9F(B % NN6#< = > v{+r/cKd}|j|ddd\}}|jd|d||d{}|jS7w)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_paramsrUrc)r,rRrcr4rVrs r.watch_order_bookzprobit.watch_order_bookcs[77@PRZ\ij//0@&+W^`fgg   hs2A A A cK|jdd}d|d}|j||}|}|j||||d{S7w)Nrr subscribe)typerV)r&extendwatch)r,r5rVr4urlrrequest subscribeHashs r.r3zprobit.subscribe_privatessXiit$ ++i0# ZZ['=IIIIsAA A A  methodNamecK|jd{|j|}|d}|jdd}|j|}d|z} |dz|z} i} | |jvr |j| } || vr |j| =d| |<t | j } d} |j||dd\} }d d |d | | d }|j||}|j|| || | d{S77w) NrRrrz marketdata:rvTr$r"r marketdataid)rrVrYr#r$) rxr_r&r7 subscriptionsrErFrrr)r,rrRdataTyper#r4r_rr7rr5filtersrFr$rs r.rUzprobit.subscribe_public}s.!!!V$!iit$S!%. nv-  F00 0**=9Gg%((7GLLN#88ZY\]&#  ++gv.ZZ['='RRR5 "4Ss"DDC&D=D>DDc |j|d}|j|}|j|d}d|z}||jvr|j i|j|<|j|}|j |dd} | r)|j ||ddddd } |j| n|j|||j||y) NrYsidez orderbook:r>Fbuysellpricequantity) rKrZgroup_by orderbooks order_bookrCparse_order_bookr> handle_deltar:) r,r7r; orderBookr^rR dataBySider5rr>snapshots r.handle_order_bookzprobit.handle_order_books##G[9!!(+]]9f5 "V+ $//)&*oob&9DOOF #OOF+ w7 ,,ZufV]_ijH OOH %   i 4y+.r/ctdt|D]+}||}|j|dd}|j|-y)Nrrr)rGrH parse_bid_ask storeArray)r,bookSidebidAsksrNbidAskrss r.handle_bid_askszprobit.handle_bid_askssGq#g,' (AQZF''DF    ' (r/c|d}|d}|j|dg}|j|dg}|j|||j||y)Nbidsasksrr)rDr)r,rdelta storedBids storedAsksrrs r.rzprobit.handle_deltasZv& v& ufb1ueR0 Z. Z.r/c|j|d}|j|dd}|j|d}|jdz|zdz|zdz|j|z}d|jvr |j |jd||d|jvr |j |jd||t|)N errorCoder;details exactbroad)rKrDrjson exceptionsthrow_exactly_matched_exceptionthrow_broadly_matched_exceptionr)r,r7r;rQ errMessagerfeedbacks r.handle_error_messagezprobit.handle_error_messages5%%gy"= //'9577S=4'#- :S@499WCUU doo %  0 01I4QY Z doo %  0 01I:W_ `H%%r/c|j|d}|jd}|dk(rd}|j||y|j||jd=y)Nresult authenticatedok)rKrr:reject)r,r7r;rfuturer5s r.handle_authenticatezprobit.handle_authenticatesZ!!'84%%o6 T>)K NN7K 0 MM' "$$_5r/c |j|d}||j|||j|dg}t|}|r|j|||j |gdg}t|}|r|j |||yy)NrTre)rorder_books_l1r!order_books_l3order_books_l4)rDrarHrt safe_value_nr)r,r7r;rTrf tradesLengthrorderBookLengths r.handle_market_datazprobit.handle_market_datas(3     vw //2>6{    vw /%%g0GIKL i.   " "67I > r/c|j|d}||j||y|j|d}|dk(r|j||y|j|j|j |j |j d}|j|d}|j||}| |||yt|jdz|j|z}|j|y)Nrr authorization)rr1rwr order_historyrVz! handleMessage: unknown message: ) rKrrrr<rrrDrrrr) r,r7r;rrhandlersrVhandlererrors r.handle_messagezprobit.handle_messages$$Wk:   % %fg 6 0 ? "  $ $VW 5 11**!22,,!//  ""7I6//(G4   FG $ TWW'JJTYYW^M__` er/cK|jdd}|j|}d}|j|jdd}|j |j |}||j |kDrj|jd{}|j|d}d|d} |j|||j| ||d{}||j |<|S7X7w) Nrrrexpiresr access_tokenr)rtoken) r&r7rnr'rDr millisecondssign_inrKrr) r,r4rr7r5rrresponse accessTokenrs r.r2zprobit.authenticatesiit$S!% ##DLL)Q?!5!5{C N 1 1 3g =!\\^+H**8^DK'$G ::c; GV8TVabbF06F  - ,cs%BC& C" AC& C$ C&$C&)&__name__ __module__ __qualname__rr+rr6r r<r9strr rWrarrr rjrtr ryrrrrr rr3rUrrrrrrrr2 __classcell__)r-s@r.rrs # @*, L L2V2"7868 ] ]F ]2F28<@d[]UUSUUbfglbmU(&9F&9P37TX\egUCUsURUUlpqvlwU.1,v1,f04$UYbdUUCUsUimnsitU./,F/,b@DB!S!!S\! J]_SScS://<( /&6&( 6& 6 ? ?"V"H)+r/r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrr async_supportrr/r.rs< OTTT4*)_T   & &_r/