eiQddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheByTimestamp)AnyBoolInt OrderBookStringsTickerTickersTrade)Client)List) ExchangeError) BadRequestc eZdZdeffd ZifdedefdZdddifded ed ed edee f d Z ifdede fd Z difde defdZddifded ed edeefdZddifdeed ed edeefdZdifded edefdZdefdZdefdZdefdZdefdZdefdZdedefdZdefdZdefdZdeffd Zdeffd Z xZ!S)p2breturnc N|tt|iddddddddddddd dd dd dd dd dddddddddddddddddddiidddddddddiddi|dd |jid!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_dictionaryr4)self __class__s J/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/p2b.pyr;z p2b.describesc4 0 0 9 9 ; ;d#U!%      u !%$U  d!$u"t#$%& $)-).3 ## G G!#99;;$ [0> 0> 0 0 0 r. messageHashcK|jdd}|||d}|||}|||||d{VS)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)r6 millisecondsextendwatch)r=r.rArequestrEurl subscribequerys r?rLz p2b.subscribeDsyit$##%%   Iv..ZZ[%EEEEEEEEEr@r*Nsymbol timeframesincelimitcK|d{V||jdi}|||}|t |jdz|z||}|d|g} d|dz} |d| | |d{V} |jr| ||}| | ||dd S) 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 Nr2z' watchOHLCV cannot take a timeframe of rFzkline::rNzkline.subscriberT) load_markets safe_valuer7 safe_integerrrFmarketrL newUpdatesgetLimitfilter_by_since_limit) r=rNrOrPrQrEr2channelrVrJrAohlcvs r? watch_ohlcvzp2b.watch_ohlcvWs!!!!!!!!!__T\<DD ##J :: ?TW'PPS\\]] ]V$$ 4L   &"22 nn%6 WfUUUUUUUU ? 2NN6511E))%q$GGGr@cK|d{V||jd}||dd}||dd|\}}||}|d}d|jd|d <|jd}t |}|d z|dz}||d z|||d{VS) 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/rDrNTr3rF:: .subscribe) rS safe_dictr7 safe_stringhandle_option_and_paramsrVlistkeysrL) r=rNrEwatchTickerOptionsr.rVr3rJrAs r? watch_tickerzp2b.watch_tickerts !!!!!!!!!!^^DL-HH 2FGDD44VXvtTT fV$$!37 \"6$<0\,/ z(())TkF8$44 ^^D<$7gvVVVVVVVVVr@symbolscK|d{V||dd}||jd}||dd}||dd|\}}g}g}t dt|D]Y}|||}| |dz|d z| |d Z|j d d } |d z|| d} | | || | ||d{V||jd |S)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/rDrr^rNrFr(rr_rC)rSmarket_symbolsr`r7rarbrangelenrVappendr6rGwatch_multiplerHfilter_by_arraytickers) r=rgrErer. messageHashesargsirVrKrJs r? watch_tickerszp2b.watch_tickerss!!!!!!!!!%%gtU;;!^^DL-HH 2FGDD44VXvtTT f q#g,,'' & &A[[,,F  vh/?!? @ @ @ KKt % % % %it$\)##%%   !!#}dkk'66R6RTabbbbbbbbb##DL(GDDDr@cDK||g|||d{VS)a4 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=rNrPrQrEs r? watch_tradeszp2b.watch_tradess622F8UE6RRRRRRRRRr@cK|d{V||dddd}g}|>tdt|D] }|d||z!||}|jdd}d||d } || |} | ||| |d{V} |j rB| | d} | | d } | | |}|| ||d dS) a5 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.subscriberCrN timestamp)rSrirjrkrl market_idsr6rGrHrmrWrTrarXrY)r=rgrPrQrErprr marketIdsrKrLrMtradesfirst tradeSymbols r?ruzp2b.watch_trades_for_symbolssu!!!!!!!!!%%gtUD$GG  1c'll++ = =$$Y%;<<<<OOG,, it$'##%%   Iv..**3 umTTTTTTTT ? 8OOFA..E**5(;;KOOK77E))&% TRRRr@c.K|d{V||}d}d|dz}||dd}|d}|d||g}|||||d{V} | S) 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::rNintervalz0.001drF)rSrVrarLrQ) r=rNrQrErVr.rArrJ orderbooks r?watch_order_bookzp2b.watch_order_books!!!!!!!!!V$$ #fX&66 ##FJ@@ =E 4L    ..{GVLLLLLLLL    r@clientc`||d}||d}||d}|d}||d}||d}||}||jdi} ||| } ||d} |dz| z} |||} ||j | i|j | <||j | | }| h|;| |jd d }t|}||j | | <| | | || |S) NrErrD.r2rNr^r0r)) safe_listrasplit safe_marketr`r7find_timeframe parse_ohlcvrTohlcvsrUrrlresolve)r=rmessagedatarD splitMethodrZmarketIdrVr2rOrNrAparsedstoredrQs r? handle_ohlcvzp2b.handle_ohlcvs&~~gx00~~dA&&!!'844ll3'' "";22##D!,,!!(++^^DL,CC ''<< !!&(33nv- !!$//"oodk62FF FV!4i@@  ~))$, dKK.u5517 F#I. MM& ! ! ! NN6; / / /r@cb||dg}||d}||d}||}||d}||j|}|5||jdd} t| }||j|<tdt|D]5} || } | | |} | | 6d|z} | || |S)NrErrNr1r)rx) rrarrTr|rUr7rrjrk parse_traderlr)r=rrrr|rrVrN tradesArrayr1rritemtraderAs r? handle_tradezp2b.handle_trade s-(~~gx44a((##D!,,!!(++!!&(33oodk6::  ++DL-NNK$[11K"-DK q#f++&& & &A!9D$$T622E   u % % % %&( {K000r@c@||dg}||d}||}||d}|d}||d}||d} d} |dkr6||d} || | |dd} n|| |} | d} | |j| <|d z| z} || | |S) NrErrDrr price.updaterN)lastcloserNr^) rrarrr` safe_ticker parse_tickerror)r=rrrrrVrDrmessageHashStart tickerDataticker lastPricerNrAs r? handle_tickerzp2b.handle_tickerFs:B~~gx44##D!,,!!(++!!'844ll3'' ++K;;^^D!,,  ^ # #((q11I%%!" *''FF &&z6::F!% V&-6 v{+++r@cf||dg}||d}||d}||d}||d}||}|d} d|dz} ||j| i} || d} ||j| } | +|i| |j| <|j| } |td t|D]b}|||}| |d }| |d}| d}| ||c|td t|D]b}|||}| |d }| |d}| d}| ||c| | d<| | | dS) NrErasksbidsrNrrQr)rr`rarrT subscriptionsrU orderbooks order_bookrjrk safe_numberstorer)r=rrrErrrrrVrNrA subscriptionrQrrrbidpriceamountbookSideaskbooksides r?handle_order_bookzp2b.handle_order_book~s+&266~~fa((~~dF++~~dF++##FA..!!(++!#fX&66 v';["MM !!,88OODOV<<  &*oob%&@&@DOF #/I  1c$ii(( . .oodA..((a00))#q11$V,uf----  1c$ii(( . .oodA..((a00))#q11$V,uf----$ (y+.....r@cX|||rdS||d}|dkr|||dS||d}|j|j|j|j|jd}|||}||||dSdS)NresultpongrD)z depth.updaterz kline.updatez state.updatez deals.update)handle_error_messagera handle_pongrrrrrT)r=rrrrDmethodsendpoints r?handle_messagezp2b.handle_messages  $ $VW 5 5  F!!'844 V     VW - - - F!!'844 2 . - . -   ??7F33   HVW % % % % % r@c||d}|-t|jdz||zdS)Nerrorz error: F)rarrFjson)r=rrrs r?rzp2b.handle_error_messagesH  '22  * 4tyy7G7G GHH Hur@c2dg|dS)zo https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#ping @param client z server.pingrC)rG)r=rs r?r4zp2b.pings( $##%%   r@cb||d||_|S)NrF)rUrGlastPong)r=rrs r?rzp2b.handle_pongs.++GT4;L;L;N;NOOr@c||jd<tt|||dSNr3)r<r7r:ron_errorr=rrr>s r?rz p2b.on_errorA%)%@%@%B%B \" c4!!&%00000r@c||jd<tt|||dSr)r<r7r:ron_closers r?rz p2b.on_closerr@)"__name__ __module__ __qualname__rr;strrLrrrcr\r rfr r rsr rvrurrr rrrrrrrr4rrr __classcell__)r>s@r?rrsY1 #1 1 1 1 1 1 fLNFFCFcFFFF&?DRVeirtHHHHCH_bHy}CzDHHHH:68WWWFWWWW06:"EE7EEEEE@<@d[] S S SS S Sbfglbm S S S SOSaenpSSd3iSS[^SuyzvASSSSB@DB!!S!!S\!!!!6(6((((T$6$$$$L6F6666p0/0/0/0/0/d&V&&&&&6t  6      &    1v1111111v1111111111r@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 NNNNNNNNVVVVVVVVVVVVVVVVVVVV444444******''''''V1V1V1V1V1$  V1V1V1V1V1r@