":hddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZddlmZGd d ej,j.Zy) N) ArrayCacheArrayCacheBySymbolById)AnyBalancesIntOrder OrderBookStrTickerTrade)Client)List)AuthenticationError) BadRequest) ChecksumErrorc eZdZdeffd ZifdZifdZdZddifdede d e fd Z fd Z d Z d efdZd efdZd efdZifd edefdZddifd edededeefdZdifd ededefdZdddifd e dededeefdZifdefdZd efdZd2dZd2dZ d efdZ!dedefdZ"d2dZ#d efd Z$d efd!Z%d efd"Z&d efd#Z'd efd$Z(d%efd&Z)d'Z*d(Z+d efd)Z,d*Z-d efd+Z.d efd,Z/d efd-Z0d efd.Z1d efd/Z2d efd0Z3d1Z4xZ5S)3poloniexfuturesreturnc|jtt|iddddddddddddd dd dd dd dd dddddddddddddddddddddiiddddiddiddddddidd d!d"d#d$S)%NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchOHLCVwatchOrderBook watchTicker watchTickers watchTradeswatchTradesForSymbols watchBalance) watchOrders watchMyTrades watchPositionwatchPositionsapiz)wss://futures-apiws.poloniex.com/endpointmethod/contractMarket/ticker/contractMarket/tradeOrders/contractMarket/level2)r- snapshotDelaysnapshotMaxRetrieschecksum) tradesLimit ordersLimitr"r'r! streamLimitstreamBySubscriptionsHash streamIndexi0ug@) keepAlivemaxPingPongMisses)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s R/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/poloniexfutures.pyrDzpoloniexfutures.describesnot E Gd#U!%      u !%$U e!$tt (!"#$ $!&!%"'+0E $#6 ; 7%&*+ $ # !-/!#(#%(a4J 4 4 cK|rdnd}|j|jdi}||vr||}|d{S|j|j||||<||jd<||}|d{S7B7w)Nprivatepublicr?) safe_valuer@spawnnegotiate_helper)rEprivateChannelparams connectIdr? storedFuturefutures rG negotiatezpoloniexfutures.negotiateIs!/IX t||VR8   ?L%% %**T%:%:NFSY# Vi|&s!2A;A7=A;2A93A;9A;cKd}|rdnd} |r|j|d{}n|j|d{}|j|di}|j|dg}|j|d}|j|d}|j |d} |j |d} | d z|j | ||d z} |j | } || _| S77#t$rJ} |j|jd |}|j| |jd |=Yd} ~ yd} ~ wwxYww) NrJrKdatainstanceServersr pingIntervalendpointtoken?)rZrOrQr?) privatePostBulletPrivatepublicPostBulletPublicrL safe_integer safe_string urlencodeclientr< Exceptionr@reject)rErOrPresponserQrVrWfirstInstanceServerrXrYrZresultraerSs rGrNz poloniexfutures.negotiate_helperXsN!/IX ' 0!%!>!>v!FF&"&!C(C$C(C&B&C(#D>$C(&C(( D;1AD61D>6D;;D>c~|j|j|jddd}||jd<|S)N requestIdr)sumr^r@)rEris rG request_idzpoloniexfutures.request_ids9HHT..t||[!LaP $- [!rHNname isPrivatesymbolcK|j|d{}||j|}|d}|d|zz }|} |j|| d{} |j} | d||d| d} d| i} || }n|j | |}|j | |}|j || ||| d{S77i7w)a @ignore Connects to a websocket channel :param str name: name of the channel and suscriptionHash :param bool isPrivate: True for the authenticated url, False for the public url :param str symbol: is required for all public channels, not required for private channels(except position) :param dict subscription: subscription parameters :param dict [params]: extra parameters specific to the poloniex api :returns dict: data from the websocket stream Nid: subscribeT)rqtypetopicrOrdtunnelId)rTmarketstreamrlextendwatch)rErmrnro subscriptionrPurlrwmarketId messageHashrvrirssubscriptionRequestrequests rGrszpoloniexfutures.subscribesNN9--  [[(Fd|H C(N "D S+66OO% '   )%   .L;;':LIL++i0ZZ['4ATUUU1. 7$Vs4CB;;CB=A"C6B?7C=C?CcLi|jd<tt|||y)Nr:)r@rCron_close)rEraerrorrFs rGrzpoloniexfutures.on_closes#46 01 ot-fe++DLL-LK//$,, FK%/K)K7O*5DLL ' $ 5 5o F !22FJPDLL4 56F G#f,K!$% G"00"L**S+w \R R R  SsCC*!C("C*rac|j|d}|j|d}|ji||j|<y)Nrolimit)r_r^ order_book orderbooks)rEramessager{rors rGhandle_order_book_subscriptionz.poloniexfutures.handle_order_book_subscriptions?!!,9!!,8"&//"e"<rHc|j|d}|j|jd}|j||i}|j|d}| |||||S)Nrqr-)r_index_by subscriptionsrL)rErarrqsubscriptionsByIdr{r-s rGhandle_subscription_statusz*poloniexfutures.handle_subscription_statussg  gt , MM&*>*>E'8"bA x8   67L 1rHcL|j|d}|j||y)Nrqr_resolve)rErarr{r~s rGrz!poloniexfutures.handle_new_streams$&&w5 w ,rHcK|jd{|j|}d}|j|d|d|d{S747w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://api-docs.poloniex.com/futures/websocket/public#get-real-time-symbol-ticker :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nr.F) load_marketsrors)rErorPrms rG watch_tickerzpoloniexfutures.watch_tickersS!!!V$'^^D%vFFF "Gs!AA /AA A AsincercK|jd{|j|jd}|j|dd}|j |dd|\}}|j |}|j |d|d|d{}|jr|j||}|j|||ddS779w) a> get the list of most recent trades for a particular symbol https://api-docs.poloniex.com/futures/websocket/public#full-matching-engine-datalevel-3 :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 ` Nr$r-z/contractMarket/executionrmF timestampT) rrLr@r_handle_option_and_paramsrors newUpdatesgetLimitfilter_by_since_limit)rErorrrPr@rmtradess rG watch_tradeszpoloniexfutures.watch_tradess!!!//$,, >3NO44VXvtT fV$~~dE64HH ??OOFE2E))&% TRR " Is"CCA3C C 8CCcK|jd{|j|jd}|j|dd}|j |dd|\}}|dk(r;|9|dk7r|dk7rt |j dz|d |j|zz }|||jd }|j|d |||d{}|jS77w) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api-docs.poloniex.com/futures/websocket/public#level-2-market-data :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: not used by poloniexfutures watchOrderBook :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.method]: the method to use. Defaults to /contractMarket/level2 can also be /contractMarket/level3v2 to receive the raw stream of orders :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr!r-r0rmr12z[ watchOrderBook limit argument must be none, 5 or 50 if using method /contractMarket/level2Depth)rorr-F) rrLr@r_rrrqrrrsr)rErorrPr@rmr{ orderbooks rGwatch_order_bookz poloniexfutures.watch_order_books!!!//$,,0@A3KL44VXvtT f + +0Azerk ,I"IJJ Gd33E:: :D99 ..uflFSS    "Ts"C"CB2C" C  C" C"cK|jd{|j|jd}|j|dd}|j |ddd|d{}|j r|j ||}|j||||}t|}|dk(r|j||||d{S|S77f7 w)a watches information on multiple orders made by the user https://api-docs.poloniex.com/futures/websocket/user-messages#private-messages :param str symbol: filter by unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.method]: the method to use will default to /contractMarket/tradeOrders. Set to /contractMarket/advancedOrders to watch stop orders :returns dict[]: a list of `order structures ` Nr'r-r/Tr) rrLr@r_rsrrfilter_by_symbol_since_limitlen watch_orders) rErorrrPr@rmorderslengths rGrzpoloniexfutures.watch_orders,s!!!//$,, >3PQ~~dD$fEE ??OOFE2E22665%PV Q;**65%HH H  "F Is5C CA C "C #AC C C  C  C cK|jd{d}|j|ddd|d{S7#7w)a| watch balance and get the amount of funds available for trading or funds locked in orders https://api-docs.poloniex.com/futures/websocket/user-messages#account-balance-events :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` N/contractAccount/walletT)rrs)rErPrms rG watch_balancezpoloniexfutures.watch_balanceEsB!!!(^^D$dFCCC "Cs>:><>>cz|j|di}|j|d}||j|}|d}d|z}|j|j|}|7|j |j dd} t | }||j|<|j||j|||S)NrVroz/contractMarket/execution:r7r,) rLr_parse_ws_traderr^r@rappendr) rErarrVr}traderor~storedr7s rG handle_tradezpoloniexfutures.handle_tradeRs*w3##D(3  ''-E8_F6AK__T[[&9F~"// mTR #K0&, F# MM% NN6; /rHc|j|d}|j||}|j|dd}|j||j|d|j|d||j ||j |ddd|j|dd|j|d|j |d d ddd |S) Nrotsư>tradeId takerOrderId makerOrderIdsideprice matchSizesize inforqrordatetimeorderrtr takerOrMakerramountcostfee)r_ safe_marketsafe_integer_product safe_tradeiso8601 safe_string_2)rErrwr}rs rGrzpoloniexfutures.parse_ws_tradevs$##E84!!(F3--eT8D ""5)4&&vx8" Y/''~~N$$UF3 %%eW5(( VD   rHc|j|d}|j|d}|j||j|d|j||||j ||j|d|j |d|j|d|j |d|j|d|j|d dd|j|d |j|d d d |S)N tradeTimerororderIdrtr matchRoler tradeAmounttradeFee feeCurrency)ratercurrencyr)r^r_r safe_symbolrsafe_string_lower)rErrwrr}s rGparse_ws_order_tradez$poloniexfutures.parse_ws_order_trades:%%e[9 ##E84""5)4&&x8" Y/%%eY7**5&9$$UF3 225+F%%eW5&&um<(( ; ,,UMB $ % rHc|j|di}|j}|.|j|jd}t |}||_d}|j |}|j ||j|||S)NrVr8r/)rLrr^r@rparse_ws_orderrr)rErarrVrrr~parseds rG handle_orderzpoloniexfutures.handle_ordersfw3 >%%dllMBE+E2F DK3 $$T* fv{+rHstatusrtcldddd}|j||}|dddd}|j|||}|S)z @ignore :param str status: "match", "open", "done" :param str type: "open", "match", "filled", "canceled", "update" :returns str: canceledclosed)rcancelfilledopen)rmatchdone)r_)rErrttypes parsedStatusstatusess rGparse_order_statusz"poloniexfutures.parse_order_status sZ#   ''t4   H  ++HffELrHc |j|d}|j|d}|j|d}|j|ddd}|j|d}|j|d}|jid |d|j||d |d |d |d |j |ddd|j|dddddd|j|dd|j |ddd|j|dddd|j|ddddd|j|d|j|d|j ||dddS)Nr clientOidro orderTimerrrrtrrq clientOrderIdrrlastTradeTimestamp orderType timeInForcepostOnlyrr orderPrice stopPrice triggerPricerrraverage filledSize remainSize)r remainingrrr)r_safe_integer_product_2 safe_orderrrrr) rErrwrqrr}rr messageTypes rGrzpoloniexfutures.parse_ws_order#sH  eY /(( < ##E84//{D(S !!%2&&uf5  E d&&x8  "  ]     Y/   !$  D$$UK8  4    D$$UF3  T''w E  ))%=  D  d&&uf5 D! " t# $&&ul;))%>--fkB-   rHc|j|di}|j|d}|j|}|2|j|}||j|<|j |||S)NrVru)rLr_get_symbol_from_topic parse_tickertickersr)rErarrVr~rotickers rG handle_tickerzpoloniexfutures.handle_tickerfspBw3&&w8 ++K8  &&t,F#)DLL NN6; /rHc||j|d}|j|d}|dk(ry|j||y)Nrusubjectreceivedr)rErarr~rs rGhandle_l3_order_bookz$poloniexfutures.handle_l3_order_booksBX&&w8 ""7I6 j w ,rHc|j|d}|jddk\}|r|j||y|j||y)Nrurr)r_findhande_l2_snapshothandle_l2_order_book)rErarru isSnapshots rGhandle_level_2zpoloniexfutures.handle_level_2sO  '2ZZ(A-   " "67 3  !!&'2rHc|j|di}|j|dd}|j|}|j|j|}|2|j i|j|<|j|}||d<|j |d}|kt |j}|jddd} || k(r"d } |j|j|||| i|jj|y |j|||j||y#t$r)} |j|=|j| |Yd} ~ yd} ~ wwxYw) NrVrurononcer!r3r1r)rLr_rrrr^rcache handle_optionrMload_order_bookr handle_deltarrbrc) rErarrVr~ro orderBookr cacheLengthr3rrgs rGr z$poloniexfutures.handle_l2_order_booksM(w3&&w< ++K8OODOOV<  &*oob&9DOOF #/I"(Ih !!)W5 =ioo.K ../?RSTMm+ 4//feUWX OO " "4 (  *   i . NN9k 2 *' MM![ ) ) *s$D-- E6EEc$|j|di}|j|dd}|j|}|j|d}|j |||dd}|j |}||j |<|j||y)NrVrurrbidsasks)rLr_rr^parse_order_bookrrr) rErarrVr~rorsnapshotrs rGr z!poloniexfutures.hande_l2_snapshots2w3&&w< ++K8%%dK8 ((vy&&QOOH- "+y+.rHrucj|jd}|j|d}|j|S)Nrrrj)splitr_r)rEru splitTopicr}s rGrz%poloniexfutures.get_symbol_from_topic#s3[[% ##J2))rHc|j|d}|j|d}|j|d}||dzkDrytdt|D]%}||}|j|d}||dz k(s#|cSt|S)Nrrsequencerjr6)rLr^ranger) rErr firstDeltarfirstDeltaSequenceideltar"s rGget_cache_indexzpoloniexfutures.get_cache_index(s__UA. !!)W5!..z:F  )q#e*% A!HE(( ;H1 $   5zrHc|j|d}|j|d}|j|d}||kDry||k7r?|jddd}|r*t|jdz|j dz|j |d }t d t|D]o}||} | jd } |j| d } |j| d } |j| d } | dk(r|dn|d}|j| | q|j|d}||d<|j||d<||d<y)Nr" lastSequencerr!r5T rchangesr,rjbuyrrrr) r^rrrqorderbook_checksum_message safe_listr#rr safe_numberr_storer)rErr'r"r*rr5r,r&change splitChangerrr orderBookSiders rGrzpoloniexfutures.handle_delta5sc$$UJ7((? !!)W5 8   L ))*:JMH#DGGcMD4S4STV4W$WXX.. 2q#g,' -AQZF ,,s+K$$[!4E##K3D##K3D26%-If-iPVFWM   t , -%%e[9 !* + $ Y 7 *% 'rHc|j|dg}d}|j|d}|j|}|d}|j||j|<|j |j|||S)NrVrrcode)rLr_rparse_ws_balancebalancer)rErarrVr~ currencyIdrr8s rGhandle_balancezpoloniexfutures.handle_balanceVsz<w3/ %%dJ7 ==,!2248 Tt||D);7rHc |j|d}|||j|d}|j|d}|j|}|j }|j|d|d<|||<|j |S)Nr)rrrravailableBalancefree)r^rr_safe_currency_codeaccount safe_balance)rErdrrfr;r8 newAccounts rGr9z poloniexfutures.parse_ws_balance}s%%h < " Y/  %%h ; &&z2\\^ !--h8JK 6!t   ((rHc|SNrErars rGhandle_system_statusz$poloniexfutures.handle_system_statuss rHc|j|d}|j|j|j|j|j|j|j|j|j |j |j |j|jd }|j||}| |||yy)Nr) authrrupdaterlevel2rz snapshot.24hr orderChange stopOrderzavailableBalance.changezorderMargin.change) r_handle_authenticater rrrrr<rL)rErarrmethodsr-s rGhandle_subjectzpoloniexfutures.handle_subjects""7I6,,11--//--))(( ..&&,,**'+':':"&"5"5 '2   67 # rHc>t|j}|ddS)Nping)rqrt)strrl)rErarqs rGrSzpoloniexfutures.pings# " #  rHc0|j|_|SrE) millisecondslastPongrGs rG handle_pongzpoloniexfutures.handle_pongs++-rHc&|j|yrE)rcrGs rGhandle_error_messagez$poloniexfutures.handle_error_messages  grHc|j|d}|j|j|j|j|j d}|j ||}| |||yy)Nrt)welcomeackrpongr)r_rHrrQrXrZrL)rErarrtrPr-s rGhandle_messagezpoloniexfutures.handle_messageso00022**$$..  $/   67 # rHc,|j|d}|j|d}d}|r|j|||St|jdz|j |z}|j ||||j vr |j |=|S)NrVsuccess authenticatedr+)rLrrrqjsonrcr)rErarrVrar~rs rGrOz#poloniexfutures.handle_authenticatesw///$ 2%  NN7K 0  (#  '8J(JKE MM% -f222((5rHrE)6__name__ __module__ __qualname__rrDrTrNrlrTboolr rsrrxr rrrr rrrr rr rrrrrrrrrrrrr rr r rr(rr<r9rHrQrSrXrZr_rO __classcell__)rFs@rGrrs95 #5 n68 =?+Z IM[_hj#VC#VD#V##VJ=4=V=  --68 G GF G<@d[]SSSSSbfglbmS,@DB!S!!S\!804$UYbdCsimnsit2*, D D"6"H#J1f=6=~C,A F(F(T1-61-f3V3$**6**X / /D*3* &B%V%N)66$V$* 6 & 6  $V $rHr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrrr async_supportrrFrHrGrqs? OTTT40'*\d((88\rH