i&YddlZddlmZmZddlmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolById)BalancesIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError) NotSupportedc eZdZfdZifdefdZdefdZdZifde de fdZ defd Z d d ifde d e d e deefd ZdefdZd d d ifded e d e deefdZdefdZd d d ifded e d e deefdZdefdZd ifde d e defdZifde fdZdefdZdZdZdefdZdefdZdefdZ defdZ!ifdZ"xZ#S)probitc |tt|dddddddddd ddiddiddd d d d id d iddidiidS)NTF) ws watchBalance watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVrz'wss://api.probit.com/api/exchange/v1/wsz,wss://demo-api.probit.com/api/exchange/v1/ws)apitestorder_books_l2d)filterintervalr recent_tradestickerchannel open_order)rrrr)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/probit.pyr-zprobit.describesfd 3 3 < < > > $# %#!%#"&#  CH / ### o h | K'A 'A ' ' ' returncK||d{Vd}|jdd}ddd}|||}|||||d{VS)aZ watch balance and get the amount of funds available for trading or funds locked in orders :see: https://docs-en.probit.com/reference/balance-1 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nbalancerr subscribetyper$) authenticater'extendwatch)r.params messageHashurlr5requests r0 watch_balancezprobit.watch_balance;s''''''''' it$   ++i00ZZ[';GGGGGGGGGr1clientcjd}||||j|dS)Nr4)parse_ws_balanceresolver4)r.r@messager<s r0handle_balancezprobit.handle_balanceLs9  g&&&t|[11111r1c||dd}||di}t|}|ri|_t dt |D]w}||}||}||}|} | |d| d<| |d| d<| |j|<x| |j|_dS)NresetFdatar availablefreetotal) safe_bool safe_valuelistkeysr4rangelensafe_currency_codeaccount safe_string safe_balance) r.rDrGrH currencyIdsi currencyIdentrycoderSs r0rBzprobit.parse_ws_balance]sw77w33499;;''  DLq#k**++ ) )A$QJ$E**:66DllnnG"..ukBBGFO#//w??GG !(DL  ((66 r1symbolc|Kd}||ddd\}}||d||d{VS)a? watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: 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 ` Nrr r#)handle_option_and_paramssubscribe_order_book)r.r[r;r s r0 watch_tickerzprobit.watch_tickerysW66v}hX`aa..vxPPPPPPPPPr1c*||d}||}||di}||}|||}d|z}||j|<|||dS)N market_idr#zticker:)rT safe_symbolrM safe_market parse_tickertickersrC) r.r@rDmarketIdr[r#market parsedTickerr<s r0 handle_tickerzprobit.handle_tickers&##G[99!!(++(B77!!(++((88 &( + V|[11111r1NsincelimitcKd}||ddd\}}||d||d{V}|jr|||}|||||dS)a get the list of most recent trades for a particular symbol :see: 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 ` Nrr r"tradesT)r]r^ newUpdatesgetLimitfilter_by_symbol_since_limit)r.r[rjrkr;r rms r0 watch_tradeszprobit.watch_tradess66v}hXghh0066RRRRRRRR ? 3OOFE22E00tTTTr1c||d}||}||}||dg}||dd}d|z}||j|} | |r5||jdd} t| } | |j|<tdt|D]5} || } | | |} | | 6| |j|<| |j||dS) Nrar"rGFztrades: tradesLimitr)rTrbrcrMrLrm safe_integerr(rrPrQ parse_tradeappendrC)r.r@rDrfr[rgrmrGr<storedrkrWtradeparseds r0 handle_tradeszprobit.handle_tradessB*##G[99!!(++!!(++/2>>w77&( f55 >U>%%dlM4HHE&&F"(DK q#f++&& " "A1IE%%eV44F MM& ! ! ! !$ Ft{6*K88888r1cK|d{V||d{Vd}|%||}|d}|dz|z}|jdd}d}d|d } || |} |||| |d{V} |jr| ||}|| |||d S) a get the list of trades associated with the user :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 ` NmyTradesr[:rr trade_historyr5r6T) load_marketsr8rgr'r9r:rnrorp) r.r[rjrkr;r<rgr=r$rDr>rms r0watch_my_tradeszprobit.watch_my_tradess&!!!!!!!!!'''''''''  [[((FH%F%+f4Kit$!  ++gv..zz#{GWEEEEEEEE ? 3OOFE22E00tTTTr1c||dg}t|}|dkrdS||dd}d}|j}||r2||jdd}t |}||_||} i} tdt| D]*} | | } d| | d <| | +t| } tdt| D](}| |}|d z|z}| ||)| ||dS) NrHrrGFr}rsrtTr[r~) rMrQrLr}rur(r parse_tradesrPrwrNrOrC)r.r@rD rawTradeslengthrGr<rxrkrm tradeSymbolsjryuniquerWr[symbolSpecificMessageHashs r0handle_my_tradeszprobit.handle_my_tradesso(OOGVR88 Y Q;; Fw77  NuN%%dlM4HHE+E22F"DM""9-- q#f++&& ! !A1IE,0Lx ) MM% l''))**q#f++&& > >AAYF(3c(9F(B % NN6#< = = = =v{+++++r1cK||d{V|jdd}d}|%||}|d}|dz|z}d}||ddd \}}d |d } || |} |||| |d{V} |jr| ||}|| |||d S) al watches information on an order made by the user :see: 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 ` Nrrordersr[r~rr$r%r5r6T) r8r'rgr]r9r:rnrorp) r.r[rjrkr;r=r<rgr$r5r>rs r0 watch_orderszprobit.watch_orders#s '''''''''it$  [[((FH%F%+f4K77 yZfgg  ++i00zz#{GWEEEEEEEE ? 3OOFE22E00tTTTr1c||dg}t|}|dkrdSd}||dd}|j}||r2||jdd}t |}||_i} tdt|D]?} || } || } d| | d <| | @t| } tdt| D](} | | }|d z|z}| ||)| ||dS) NrHrrrGF ordersLimitrtTr[r~) rMrQrLrrur(rrP parse_orderrwrNrOrC)r.r@rD rawOrdersrr<rGrxrk orderSymbolsrWrawOrderorderrr[rs r0 handle_orderszprobit.handle_ordersAso2OOGVR88 Y Q;; F w77 >U>%%dlM4HHE+E22F DK q#i..)) ! !A |H$$X..E,0Lx ) MM% l''))**q#f++&& > >AAYF(3c(9F(B % NN6#< = = = =v{+++++r1cKd}||ddd\}}||d||d{V}|S)a1 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: 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)r]r^rk)r.r[rkr;r rs r0watch_order_bookzprobit.watch_order_bookrsi66v?OQY[hii33FKQWXXXXXXXX    r1c2K|d{V||}|d}|jdd}||}d}||ddd\}}d|z} |dz|z}i} | |jvr|j| } || vr|j| =d | |<t | } d ||d d | d } || |} | ||| || d{VS)Nr[rrrr!rz marketdata:r~T marketdataidr5)r$r!rar7r ) rrgr'r@r] subscriptionsrNrOr9r:)r.r[r<r r;rgr=r@r!subscriptionHashfiltersrOrDr>s r0r^zprobit.subscribe_order_books]!!!!!!!!!V$$!it$S!!88AQS]_bcc&(61!C'&0  v3 3 3*+;> NN4 MM' " " "$_555r1c\||d}||||||dg}t|r|||||gdg}t|r||||dSdS)Nr#r")rorder_books_l1rorder_books_l3order_books_l4)rMrirQr{ safe_value_nr)r.r@rDr#rmrs r0handle_market_datazprobit.handle_market_datas(33     vw / / //2>> v;; 0   vw / / /%%g0G0G0GIKLL y>> ?  " "67I > > > > > ? ?r1c ||d}||||dS||d}|dkr|||dS|j|j|j|j|jd}||d}|||}||||dSt|j dz| |z}| |dS)Nrr7 authorization)rr4rr% order_historyr$z! handleMessage: unknown message: ) rTrrrrErrrMrrrr) r.r@rDrr7handlersr$handlererrors r0handle_messagezprobit.handle_messages%$$Wk::   % %fg 6 6 6 F00 ? " "  $ $VW 5 5 5 F1*!2,!/   ""7I66//(G44   GFG $ $ $ FTW'JJTYYW^M_M__`` er1cK|jdd}||}d}||jdd}||j|}|||krq|d{V}||d}d|d} | ||| | ||d{V}||j|<|S) Nrrrexpiresr access_tokenr)r7token) r'r@rur(rMr millisecondssign_inrTr:r9) r.r;r=r@r<rrresponse accessTokenr>s r0r8zprobit.authenticates it$S!!% ##DL)Q??!5{CC N 1 1 3 3g = =!\\^^++++++H**8^DDK'$G ::c; GV8T8TVabbbbbbbbF06F  - r1)$__name__ __module__ __qualname__r-rr?r rErBstrr r_rirr r rqr{r rrrrrrrr^rrrrrrrr8 __classcell__)r/s@r0rrsN( ( ( ( ( T*,HHHHHH"2V2222"777868 Q Q QF Q Q Q Q2F22228<@d[]UUUSUUbfglbmUUUU$%9F%9%9%9%9N37TX\egUUCUsURUUlpqvlwUUUU8*,v*,*,*,*,X04$UYbdUUUCUsUimnsitUUUUrs OOOOOOOOOOOOOOOOOOOOOOOOOO444444******))))))XXXXXT  &XXXXXr1