":hQddlZddlmZmZddlmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZGdd ej(j*Zy) N) ArrayCacheArrayCacheByTimestamp)AnyInt OrderBookStringsTickerTickersTrade)Client)List) ExchangeError) BadRequestc veZdZdeffd ZifdedefdZdddifded ed edee fd Z ifdede fd Z difd e defdZddifded ed edeefdZddifd eed ed edeefdZdifded edefdZdefdZdefdZdefdZdefdZdefdZdefdZdefdZdefdZdeffd Zdeffd ZxZ S)p2breturnc |jtt|iddddddddddddd dd dd dd dd dddddddddddddddddddiidddddddddiddi|j dd |j id!S)"NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers) watchTradeswatchTradesForSymbolsapizwss://apiws.p2pb2b.com/iiiiQ)15m30m1h1dnamestate) OHLCVLimit tradesLimit timeframesr#r$ tickerSubsping)hasurlsoptions streaming) deep_extendsuperrdescribecreate_safe_dictionaryr3)self __class__s F/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/p2b.pyr:z p2b.describeskc4 9 ;d#U!%      u !%$U  d!$u"t#$%& $)-).3 ## G G!#99;$ [0> 0 0 r- messageHashcK|jdd}|||jd}|j||}|j||||d{S7w)a[ @ignore Connects to a websocket channel :param str name: name of the channel :param str messageHash: string to look up in handler :param str[]|float[] request: endpoint parameters :param dict [params]: extra parameters specific to the p2b api :returns dict: data from the websocket stream r'rmethodparamsidN)r5 millisecondsextendwatch)r<r-r@requestrDurl subscribequerys r>rKz p2b.subscribeDsaiit$##%  Iv.ZZ[%EEEEsAAAAr)NsymbolsincelimitcK|jd{|j|jdi}|j||}|t |j dz|z|j |}|d|g} d|dz} |jd| | |d{} |jr| j||}|j| ||dd S779w) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market. Can only subscribe to one timeframe at a time for each symbol https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#kline-candlestick :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: 15m, 30m, 1h or 1d :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Nr1z' watchOHLCV cannot take a timeframe of rEzkline::rMzkline.subscriberT) load_markets safe_valuer6 safe_integerrrEmarketrK newUpdatesgetLimitfilter_by_since_limit) r<rM timeframerNrOrDr1channelrTrIr@ohlcvs r> watch_ohlcvzp2b.watch_ohlcvWs!!!__T\\<D ##J : ?TWW'PPS\\] ]V$ 4L   &"22 nn%6 WfUU ??NN651E))%q$GG "Vs"CCBCC8CCcK|jd{|j|jd}|j|dd}|j |dd|\}}|j |}|d}d|jd|d <|jd}t |j}|d z|dz}|j|d z|||d{S77w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#last-price https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#market-status :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 dict [params.method]: 'state'(default) or 'price' :returns dict: a `ticker structure ` Nr#r-r.rCrMTr2rE:: .subscribe) rQ safe_dictr6 safe_stringhandle_option_and_paramsrTlistkeysrK) r<rMrDwatchTickerOptionsr-rTr2rIr@s r> watch_tickerzp2b.watch_tickerts!!!!^^DLL-H 2FGD44VXvtT fV$!37 \"6$<0\\,/ z()TkF8$44 ^^D<$7gvVVV "Ws"C"CCC"C C" C"symbolscK|jd{|j|dd}|j|jd}|j |dd}|j |dd|\}}g}g}t dt|D]D}|j||}|j|dz|d z|j|d F|jd d } |d z||jd} |j| ||j| ||d{|j|jd |S707$w)a https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#last-price https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#market-status watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] [symbols]: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param dict [params.method]: 'state'(default) or 'price' :returns dict: a `ticker structure ` NFr#r-r.rCrr]rMrEr'rr^rB)rQmarket_symbolsr_r6r`rarangelenrTappendr5rFwatch_multiplerGfilter_by_arraytickers) r<rfrDrdr- messageHashesargsirTrJrIs r> watch_tickerszp2b.watch_tickerssT!!!%%gtU;!^^DLL-H 2FGD44VXvtT f q#g,' &A[[,F  vh/?!? @ KKt % &iit$\)##%  !!#}dkk'66RTabbb##DLL(GDD% "" cs"E ED E $E %"E  E cHK|j|g|||d{S7w)a6 get the list of most recent trades for a particular symbol https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#deals :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<rMrNrOrDs r> watch_tradeszp2b.watch_tradess'22F8UE6RRRRs " "cPK|jd{|j|dddd}g}|1tdt|D]}|j d||z|j |}|j dd}d||jd } |j| |} |j||| |d{} |jr6|j| d} |j| d } | j| |}|j| ||d dS7 7^w) a7 get the list of most recent trades for a list of symbols https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#deals :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 ` NFTrdeals::r'rzdeals.subscriberBrM timestamp)rQrhrirjrk market_idsr5rFrGrlrUrRr`rVrW)r<rfrNrOrDrorq marketIdsrJrKrLtradesfirst tradeSymbols r>rtzp2b.watch_trades_for_symbolss1!!!%%gtUD$G  1c'l+ =$$Y%;< =OOG, iit$'##%  Iv.**3 umTT ??OOFA.E**5(;KOOK7E))&% TRR' "Us#D&D!B.D&D$AD&$D&cK|jd{|j|}d}d|dz}|j|dd}|d}|d||g}|j||||d{} | j S7j7w) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#depth-of-market :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: 1-100, default=100 :param dict [params]: extra parameters specific to the exchange API endpoint :param float [params.interval]: 0, 0.00000001, 0.0000001, 0.000001, 0.00001, 0.0001, 0.001, 0.01, 0.1, interval of precision for order, default=0.001 :returns dict: A dictionary of `order book structures ` indexed by market symbols Nzdepth.subscribe orderbook::rMintervalz0.001drE)rQrTr`rKrO) r<rMrOrDrTr-r@rrI orderbooks r>watch_order_bookzp2b.watch_order_books!!!V$ #fX&66 ##FJ@ =E 4L    ..{GVLL    "Ms"BBAB,B-BBclientc|j|d}|j|d}|j|d}|jd}|j|d}|j|d}|j|}|j |j di} |j || } |j|d} |dz| z} |j||} |j|j| i|j| <|j|j| | }| _|:|j|j d d }t|}||j| | <|j| |j|| |S) NrDrrC.r1rMr]r/r() safe_listr`split safe_marketr_r6find_timeframe parse_ohlcvrRohlcvsrSrrkresolve)r<rmessagedatarC splitMethodrYmarketIdrTr1rXrMr@parsedstoredrOs r> handle_ohlcvzp2b.handle_ohlcvsi&~~gx0~~dA&!!'84ll3' "";2##D!,!!(+^^DLL,C ''< !!&(3nv- !!$/"oodkk62F FV!4i@  ~))$,, dK.u517 F#I. MM& ! NN6; /r?c|j|dg}|j|d}|j|d}|j|}|j|d}|j|j|}|7|j |j dd} t| }||j|<tdt|D]*} || } |j| |} |j| ,d|z} |j|| |S)NrDrrMr0r(rw) rr`rrRr{rSr6rrirj parse_traderkr)r<rrrr{rrTrM tradesArrayr0rqitemtrader@s r> handle_tradezp2b.handle_trade s(~~gx4a(##D!,!!(+!!&(3oodkk6:  ++DLL-NK$[1K"-DKK q#f+& &A!9D$$T62E   u % & &( {K0r?c|j|dg}|j|d}|j|}|j|d}|jd}|j|d}|j |d} d} |dk(r+|j|d} |j | | |dd} n|j | |} | d} | |j| <|d z| z} |j| | |S) NrDrrCrr price.updaterM)lastcloserMr]) rr`rrr_ safe_ticker parse_tickerrnr)r<rrrrrTrCrmessageHashStart tickerDataticker lastPricerMr@s r> handle_tickerzp2b.handle_tickerFs B~~gx4##D!,!!(+!!'84ll3' ++K;^^D!,  ^ #((q1I%%!" *'F &&z6:F!% V&-6 v{+r?c|j|dg}|j|d}|j|d}|j|d}|j|d}|j|}|d} d|dz} |j |j | i} |j | d} |j |j| } | .|ji| |j| <|j| } |gtd t|D]O}|j ||}|j|d }|j|d}| d}|j||Q|gtd t|D]O}|j ||}|j|d }|j|d}| d}|j||Q| | d<|j| | y) NrDrasksbidsrMrrOr)rr_r`rrR subscriptionsrS orderbooks order_bookrirj safe_numberstorer)r<rrrDrrrrrTrMr@ subscriptionrOrrqbidpriceamountbookSideaskbooksides r>handle_order_bookzp2b.handle_order_book~s&26~~fa(~~dF+~~dF+##FA.!!(+!#fX&66 v';';["M !!,8OODOOV<  &*oob%&@DOOF #/I  1c$i( .oodA.((a0))#q1$V,uf-  .  1c$i( .oodA.((a0))#q1$V,uf-  . % (y+.r?cR|j||ry|j|d}|dk(r|j||y|j|d}|j|j|j |j|j d}|j||}| |||yy)NresultpongrC)z depth.updaterz kline.updatez state.updatez deals.update)handle_error_messager` handle_pongrrrrrR)r<rrrrCmethodsendpoints r>handle_messagezp2b.handle_messages  $ $VW 5 !!'84 V    VW - !!'84 22 .. -- .. --  ??7F3   VW % r?c|j|d}|*t|jdz|j|zy)Nerrorz error: F)r`rrEjson)r<rrrs r>rzp2b.handle_error_messages?  '2  * 4tyy7G GH Hr?c*dg|jdS)zo https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#ping @param client z server.pingrB)rF)r<rs r>r3zp2b.pings $##%  r?c4|j|d|_|S)NrE)rSlastPong)r<rrs r>rzp2b.handle_pongs++GT:r?ch|j|jd<tt|||yNr2)r;r6r9ron_errorr<rrr=s r>rz p2b.on_error+%)%@%@%B \" c4!&%0r?ch|j|jd<tt|||yr)r;r6r9ron_closers r>rz p2b.on_closerr?)!__name__ __module__ __qualname__rr:strrKrr rbr[r rerr rrr rurtrrr rrrrrrr3rrr __classcell__)r=s@r>rrs1 #1 fLNFCFcF&8=4^bkmHHSHX[Hrvw{r|H:68WWFW06:"E7EE@<@d[] S SS S Sbfglbm SOSaenpSd3iSS[^SuyzvASB@DB!S!!S\!6(6(T$6$L6F6p0/0/d&V&&6  6   & 1v11v11r?r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsrr async_supportrr?r>rs< NPPP4*'V1$   V1r?