E#iQSSKrSSKJrJr SSKJrJrJrJ r J r J r J r J r SSKJr SSKJr SSKJr SSKJr "SS \R*R,5rg) N) ArrayCacheArrayCacheByTimestamp)AnyBoolInt OrderBookStringsTickerTickersTrade)Client)List) ExchangeError) BadRequestc ^\rSrSrS\4U4Sjjr04S\S\4SjjrSSS04S \S \S \S \S\ \ 4 S jjr 04S \S\ 4Sjjr S04S\S\4SjjrSS04S \S \S \S\ \4SjjrSS04S\ \S \S \S\ \4SjjrS04S \S \S\4SjjrS\4SjrS\4SjrS\4SjrS\4SjrS\4SjrS\S\4SjrS\4SjrS\4SjrS\4U4Sjjr S\4U4Sjjr!Sr"U=r#$) p2breturnc >UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSS.ESSS00SSSSSSS.SS0SS0UR 5S.S UR 0S!.5$)"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_dictionaryr5)self __class__s F/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/p2b.pyr< p2b.describeskc4 9 ;d#U!%      u !%$U  d!$u"t#$%& $)-).3 ## G G!#99;$ [0> 0 0 r/ messageHashc# URSSnUUUR5S.nURXd5nURXRXr5IShvN $N7f)aS @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)r7 millisecondsextendwatch)r>r/rCrequestrGurl subscribequerys r@rN p2b.subscribeDsZiit$##%  I.ZZ%EEEEsA AAAr+Nsymbol timeframesincelimitc# UR5IShvN URURS05nURXb5nUc[ UR S-U-5eUR U5nUSU/n SUS-n URSXU5IShvN n UR(aU RX5nURXUSS 5$NN<7f) 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 Nr3z' watchOHLCV cannot take a timeframe of rHzkline::rQzkline.subscriberT) load_markets safe_valuer8 safe_integerrrHmarketrN newUpdatesgetLimitfilter_by_since_limit) r>rQrRrSrTrGr3channelrYrLrCohlcvs r@ watch_ohlcvp2b.watch_ohlcvWs!!!__T\\<D ##J: ?TWW'PPS\\] ]V$ 4L   &"22 nn%6 fUU ??NN61E))%q$GG "Vs"CCBCC;CCc# UR5IShvN URURS5nURUSS5nUR USSU5upBUR U5nUSnSURSUS 'URSn[ UR55nUS -US-nURUS -XU5IShvN $NN7f) aP 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/r0rFrQTr4rH:: .subscribe) rV safe_dictr8 safe_stringhandle_option_and_paramsrYlistkeysrN) r>rQrGwatchTickerOptionsr/rYr4rLrCs r@ watch_tickerp2b.watch_tickerts!!!!^^DLL-H 2FGD44VXvtT V$!37 \"6$<0\\,/ z()TkF8$44 ^^D<$7vVVV "Ws"C CCC CC C symbolsc# UR5IShvN URUSS5nURURS5nUR USS5nUR USSU5upB/n/n[ S[U55HDnURX5nURUS-US -5 URUS 5 MF URS S n US -UUR5S.n URXURX5U5IShvN URURS U5$GN.N$7f)ab 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/r0rFrrbrQrHr)rrcrE)rVmarket_symbolsrdr8rerfrangelenrYappendr7rIwatch_multiplerJfilter_by_arraytickers) r>rlrGrir/ messageHashesargsirYrMrLs r@ watch_tickersp2b.watch_tickerssE!!!%%gtU;!^^DLL-H 2FGD44VXvtT  q#g,'A[[,F  vh/?!? @ KKt %(iit$\)##%  !!#dkk'6RTabbb##DLL(GDD% "" cs"E ED E "E#"E E cF# URU/X#U5IShvN $N7f)a 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>rQrSrTrGs r@ watch_tradesp2b.watch_tradess$22F8U6RRRRs !!cT# UR5IShvN URUSSSS5n/nUb2[S[U55HnUR SX-5 M UR U5nUR SSnSUUR5S .n URX5n URXX5IShvN n UR(a5URU S5n URU S 5n U RX5nURXUS S5$GN Na7f) a 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.subscriberErQ timestamp)rVrnrorprq market_idsr7rIrJrrrZrWrer[r\)r>rlrSrTrGrurw marketIdsrMrNrOtradesfirst tradeSymbols r@r{p2b.watch_trades_for_symbolss!!!%%gtUD$G  1c'l+$$Y%;<,OOG, iit$'##%  I.**3uTT ??OOFA.E**5(;KOOK7E))& TRR' "Us#D(D#B-D(D&AD(&D(c # UR5IShvN URU5nSnSUS-nURUSS5nUcSnUSUU/nURXVX5IShvN n U R 5$NiN7f) 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::rQintervalz0.001drH)rVrYrerNrT) r>rQrTrGrYr/rCrrL orderbooks r@watch_order_bookp2b.watch_order_books!!!V$ #fX&66 ##FJ@ =E 4L    ..GLL    "Ms"BBAB+B,BBclientcURUS5nURUS5nURUS5nURS5nURUS5nURUS5nURU5nUR UR S05n UR Xi5n URUS5n US-U -n URX85n URURU 05URU 'URURU U 5nU b^Uc9URUR S S 5n[U5nXRU U 'URU 5 URX5 U$) NrGrrF.r3rQrbr1r*) safe_listresplit safe_marketrdr8find_timeframe parse_ohlcvrWohlcvsrXrrqresolve)r>rmessagedatarF splitMethodr]marketIdrYr3rRrQrCparsedstoredrTs r@ handle_ohlcvp2b.handle_ohlcvsa&~~gx0~~dA&!!'84ll3' "";2##D!,!!(+^^DLL,C ''< !!&(3nv- !!$/"oodkk62F FV!4i@  ~))$,, dK.u517 F#I. MM& ! NN6 /rBcURUS/5nURUS5nURUS5nURU5nURUS5nURURU5nUc6UR UR SS5n [U 5nXRU'[S[U55H)n XJn URX5n URU 5 M+ SU-n URX5 U$)NrGrrQr2r*r) rrerrWrrXr8rrorp parse_traderqr)r>rrrrrrYrQ tradesArrayr2rwitemtraderCs r@ handle_tradep2b.handle_trade s(~~gx4a(##D!,!!(+!!&(3oodkk6:  ++DLL-NK$[1K"-KK q#f+&A9D$$T2E   u %' &( {0rBcURUS/5nURUS5nURU5nURUS5nURS5nURUS5nUR US5n Sn US:Xa+URUS5n UR U U USS.5n OUR X5n U Sn XRU 'US -U -n URX5 U$) NrGrrFrr price.updaterQ)lastcloserQrb) rrerrrd safe_ticker parse_tickerrtr)r>rrrrrYrFrmessageHashStart tickerDataticker lastPricerQrCs r@ handle_tickerp2b.handle_tickerFsB~~gx4##D!,!!(+!!'84ll3' ++K;^^D!,  ^ #((q1I%%!" *'F &&z:F!% V&-6 v+rBcURUS/5nURUS5nURUS5nURUS5nURUS5nURU5nUSn SUS-n UR UR U 05n UR U S5n UR URU 5n U c.UR0U 5URU 'URU n Ubh[S [U55HOnUR Xn5nURUS 5nURUS5nU SnURUU5 MQ Ubh[S [U55HOnUR X^5nURUS 5nURUS5nU SnURUU5 MQ XS'URX5 g) NrGrasksbidsrQrrTr)rrdrerrW subscriptionsrX orderbooks order_bookrorp safe_numberstorer)r>rrrGrrrrrYrQrC subscriptionrTrrwbidpriceamountbookSideaskbooksides r@handle_order_bookp2b.handle_order_book~s&26~~fa(~~dF+~~dF+##FA.!!(+!#fX&66 v';';["M !!,8OODOOV<  &*oob%&@DOOF #/I  1c$i(ood.((a0))#q1$V,uf- )  1c$i(ood.((a0))#q1$V,uf- ) %(y.rBcXURX5(agURUS5nUS:XaURX5 gURUS5nURURUR URUR S.nURXT5nUb U"X5 gg)NresultpongrF)z depth.updaterz kline.updatez state.updatez deals.update)handle_error_messagere handle_pongrrrrrW)r>rrrrFmethodsendpoints r@handle_messagep2b.handle_messages  $ $V 5 5 !!'84 V    V - !!'84 22 .. -- .. --  ??73   V % rBcURUS5nUb*[URS-URU5-5eg)Nerrorz error: F)rerrHjson)r>rrrs r@rp2b.handle_error_messages?  '2  * 4tyy7G GH HrBc*S/UR5S.$)zl https://github.com/P2B-team/P2B-WSS-Public/blob/main/wss_documentation.md#ping @param client z server.pingrE)rI)r>rs r@r5p2b.pings $##%  rBc4URUS5UlU$)NrH)rXlastPong)r>rrs r@rp2b.handle_pongs++GT:rBcf>UR5URS'[[U]X5 gNr4)r=r8r;ron_errorr>rrr?s r@r p2b.on_error)%)%@%@%B \" c4!&0rBcf>UR5URS'[[U]X5 gr)r=r8r;ron_closers r@r p2b.on_closerrB)$__name__ __module__ __qualname____firstlineno__rr<strrNrrrgr_r rjr r rxr r|r{rrr rrrrrrrr5rrr__static_attributes__ __classcell__)r?s@r@rrs1 #1 fLNFCFcF&?DRVeirtHHHCH_bHy}CzDH:68WWFW06:"E7EE@<@d[] S SS S Sbfglbm SOSaenpSd3iSS[^SuyzvASB@DB!S!!S\!6(6(T$6$L6F6p0/0/d&V&&6t  6   & 1v11v11rBr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrr async_supportrrrBr@rs< NVVV4*'V1$   V1rB