":hCddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej@jBZ!y) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesIntMarketNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) BadRequestceZdZdeffd ZifdZddifdedededee fdZ ddifd eedededee fd Z d e fd Z d5de fd ZdddifdedededeefdZddifdeeededefdZd e fdZd5dedefdZdifdededefdZdifd eededefdZd e fdZifdedefdZdifd edefdZd e fdZdifd edefdZd e fdZ d5dZ!ifde"fdZ#dZ$dddifd edededee%fd Z&d e fd!Z'd5defd"Z(dddifde)dededee*fd#Z+d e fd$Z,difded%e-d&e.d'e/d(e0de*f d)Z1ddifd*eded%e-d&e.d'e0d(e0de*fd+Z2d e fd,Z3difd*ede)de*fd-Z4difd.eede)fd/Z5ifd0Z6d e fd1Z7d e fd2Z8d e fd3Z9d e fd4Z:xZ;S)6oxfunreturnc|jtt|iddddddddddddddd dd d d dd dddddddddddddddddiddddddddd d!d"d# d$d%id&|jd'd(d)S)*NwsT watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTradesF watchTicker watchTickers watchBidsAsks watchBalance createOrderWs editOrderWs cancelOrderWscancelOrdersWsapizwss://api.ox.fun/v2/websocketz wss://stgapi.ox.fun/v2/websocket)rtest60s180s300s900s1800s3600s7200s14400s21600s43200s86400s) 1m3m5m15m30m1h2h4h6h12h1dchanneldepth) timeframesr"iP)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriberK)self __class__s H/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/oxfun.pyrSzoxfun.describesUeT ; =dt(!$  +D  d 't t  t  !"!$#(9>   !"!!""#" w#& "Y0@ 0 0 cK|jdd}d|d}|j|||j|||d{S7w)Nr0r subscribeopargs)rNwatch_multipleextend)rT messageHashes argsArrayparamsurlrequests rVsubscribe_multiplezoxfun.subscribe_multipleFsRiit$ ((mT[[RX=Y[hiiiis?AAANsymbolsincelimitcHK|j|g|||d{S7w)a watches information on multiple trades made in a market https://docs.ox.fun/?json#trade :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param int|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict[]: a list of `trade structures ` N)watch_trades_for_symbols)rTrerfrgras rV watch_tradeszoxfun.watch_tradesNs'22F8UE6RRRRs " "symbolscK|jd{|j|dd}g}g}tdt|D]D}||}d|z} |j | |j |} d| z} |j | F|j |||d{} |jr7|j| di} |j| d}| j||}|j| ||ddS77^w) aC get the list of most recent trades for a particular symbol https://docs.ox.fun/?json#trade :param str[] symbols: :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|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict[]: a list of `trade structures ` NFrtrades:ztrade:re timestampT) load_marketsmarket_symbolsrangelenappend market_idrd newUpdates safe_dict safe_stringgetLimitfilter_by_since_limit)rTrkrfrgrar\r_ire messageHashmarketIdargtradesfirst tradeSymbols rVrizoxfun.watch_trades_for_symbols]s!!!%%gtU; q#g,' AQZF(61K   -~~f-HX%C KK   ..}dFKK ??NN61b1E**5(;KOOK7E))&% TRR! "Ls#DDB D$D%ADDclientc|j|dg}tdt|D]}|j||i}|j |}|j |d}d|z}||j vr5|j|jdd} t| |j |<|j |} | j||j| |y)Ndatarrerm tradesLimit) safe_listrqrrrvparse_ws_traderwr~ safe_integerrOrrsresolve) rTrmessagerrztrade parsedTraderer{rstoreds rV handle_tradeszoxfun.handle_trades|s"~~gvr2q#d)$ 0ANN4B/E--e4K%%k8` indexed by market symbols N)watch_order_book_for_symbols)rTrergras rVwatch_order_bookzoxfun.watch_order_book>s%66xOOOOs !!cK|jd{|j|}d}|j|jdi}|j |d}||}n||dkrd}n|dkrd}n|d krd }g}g}t d t |D]G} || } d | z} |j| |j| } |d z| z} |j| I|j|||d{}|jS77w)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.ox.fun/?json#fixed-size-order-book https://docs.ox.fun/?json#full-order-book :param str[] symbols: unified array of symbols :param int [limit]: the maximum amount of order book entries to return :param dict [params]: extra parameters specific to the exchange API endpoint :param int|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict: A dictionary of `order book structures ` indexed by market symbols NrIr"rHdepthL5 depthL10depthL25r orderbook:r) rorprvrOrwrqrrrsrtrdrg)rTrkrgrarHrOdefaultChannelr\r_rzrer{r|r} orderbooks rVrz"oxfun.watch_order_book_for_symbolsLs,!!!%%g.../?D))'9=  %$G  z#"$"$ q#g,' AQZF&/K   -~~f-HC-(*C KK   11-vNN   1 ".Os"D D CD 4D 5D  D c|j|di}|j|d}|j|}|j|d}d|z}||jvr|j i|j|<|j|}|j |||dd} |j| |j|d|d<||j|<|j||y) NrrrnrasksbidsseqNumnonce) rvrwrr orderbooks order_bookparse_order_bookresetr) rTrrrr|rernr{rsnapshots rVhandle_order_bookzoxfun.handle_order_bookss*~~gvr2##D,7!!(+%%dK8 "V+ $//)&*oob&9DOOF #OOF+ ((vy&&Q!!..tX> '"+y+.rWchK|j|g|d{}|j||S7w)a& https://docs.ox.fun/?json#ticker watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict: a `ticker structure ` N) watch_tickers safe_value)rTreratickers rV watch_tickerzoxfun.watch_tickers5))6(F;;vv..` Nz ticker:allrtickers:zticker:re) rorkrsrqrrrtrdrufilter_by_arraytickers) rTrkra allSymbolsrr\r_rzrer{r| newTickerresults rVrzoxfun.watch_tickerss!!!o  ,,C KK % q#c(# 2AVF)F2K   -~~f-H I01  211-vNN ??F*3F9X& 'M##DLL(GDD) "Os(C5C1A3C5 ,C57C38:C53C5c|j|dg}tdt|D]Q}|j||i}|j |}|d}d|z}||j |<|j ||Sy)Nrrrer)rrqrrrv parse_tickerrr) rTrrrrz rawTickerrrer{s rV handle_tickerzoxfun.handle_tickers0~~gvr2q#d)$ 0AtQ3I&&y1FH%F$v-K#)DLL NN6; /  0rWcK|jd{|j|dd}g}g}tdt|D]D}|j ||}|j d|dz|j d|dzF|j |||d{}|jr i}|||d<|S|j|jd|S77;w)ah https://docs.ox.fun/?json#best-bid-ask watches best bid & ask for symbols :param str[] symbols: 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 ` NFrz bestBidAsk:rbidask:re) rorprqrrrrsrdrurbidsasks) rTrkrar_r\rzr newTickersrs rVwatch_bids_askszoxfun.watch_bids_askss!!!%%gtU; q#g,' ?A[[,F KK t 4 5  VH-=!= > ? 22=$OO ??G,6GJx( )N##DMM8WEE "Ps"C"CB C"$C %:C" C"c|j|di}|j|}|d}||j|<d|z}|j||y)Nrrer)rvparse_ws_bid_askrr)rTrrr parsedTickerrer{s rVhandle_bid_askzoxfun.handle_bid_asksV&~~gvr2,,T2 h' , f&( |[1rWc |j|d}|j||}|j|d}|j|d}|j|dg}|j|dg}|j |||j ||j |d|j |d|j |d|j |d|d|S) Nrrernaskbidrr)rernrr askVolumer bidVolumer)rwrrr safe_tickerrr)rTrrr|rernrrs rVrzoxfun.parse_ws_bid_asks##FL9!!(F3!!&(3%%fk: nnVUB/nnVUB/" Y/##C+))#q1##C+))#q1 !    rWcK|jd{|jd}d}|jdd}d|gd}|j|||j |||d{S7\7w)a https://docs.ox.fun/?json#balance-channel watch balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the exchange API endpoint :param int|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict: a `balance structure ` Nz balance:allbalancer0rrYrZ)ro authenticaterNrr^)rTrar\r{rbrcs rV watch_balancezoxfun.watch_balance+s!!!  iit$F ZZ[$++gv2NP[\\\ "]s"A7A3AA7.A5/A75A7c|j|d}|j|d}||jd<||jd<|j||jd<t dt |D]}|j ||i}|j|d}|j|}||jvr|j|j|<|j|} |j|d| d<|j|d| d <|j|d | d <| |j|<|j|j|_|j|jd y) Nrrnrrr instrumentIdtotalreservedused availablefreer) rrrrrqrrrvrwsafe_currency_codeaccount safe_balancer) rTrrbalancesrnrzr currencyIdcoders rVhandle_balancezoxfun.handle_balance@sP(>>'62%%g{; & V$- [!#'<< #: Z q#h-( )AnnXq"5G))'>BJ**:6DDLL(%)\\^ T"ll4(G#//AGG "..w CGFO"..w DGFO!(DLL  )((6 t||Y/rWcK|jd{|jd{|du}|}g}|r|j}|jdg}t dt |D]E} || } d| z} |j| |j | } |r2|jd| zG|j|||d{} |jr| S|j|j|||dS7775w)a https://docs.ox.fun/?json#position-channel watch all open positions :param str[]|None symbols: list of unified market symbols @param since @param limit :param dict params: extra parameters specific to the exchange API endpoint :param int|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict[]: a list of `position structure ` Nz position:allr positions:z position:T) rorrkrsrqrrrtrdrufilter_by_symbols_since_limit positions)rTrkrfrgrarrr\r_rzrer{r| newPositionss rVwatch_positionszoxfun.watch_positionsgs!!!!!!o  ,,C KK ' q#c(# 4AVF+f4K   -~~f-H K(23  4"44]D&QQ ?? 11$..'5RWY]^^' "!Rs8DDDDA3D#,DD2DDDcN|jt|_|j}|j|dg}tdt |D]S}|j ||i}|j |}|d}d|z} |j||j|| Uy)Nrrrer) rrrrqrrrvparse_ws_positionrsr) rTrrcacherrz rawPositionpositionrer{s rVhandle_positionszoxfun.handle_positionss* >> !57DN~~gvr2q#d)$ 2A..q"5K--k:Hh'F&/K LL " NN8[ 1  2rWc|j|d}|j||}|jid|ddd|dddddd|j|d d |j|d d |j|d d dddd|j|dddddddddddddd|j |ddddddddddd S)Nr rrrenotional marginModecrossliquidationPriceestLiquidationPrice entryPrice unrealizedPnl positionPnl realizedPnl percentage contractsr contractSize markPrice lastPricerhedgedrn lastUpdated) rlastUpdateTimestampmaintenanceMarginmaintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio stopLossPricetakeProfitPrice)rwr safe_positionrr)rTr"rr|s rVrzoxfun.parse_ws_positionsw##Hn=!!(F3!!# H# $#  fX&#   # ' #  0 0;P Q #  $**8\B#  T--h F#  4#  $#  ))(J?#  D#  #  #  D# d!# " ## $#'#4#4X}#M!%+/!'+!#9#   rWcK|jd{|jd{d}d}|j|}||dz }n|d|zz }|d|dzz }d|gd}|jd d } |j | |||d{} |j r| j ||}|j| |||d S777;w) a watches information on multiple orders made by the user https://docs.ox.fun/?json#order-channel :param str symbol: 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 int|str [params.tag]: If given it will be echoed in the reply and the max size of tag is 32 :returns dict[]: a list of `order structures ` Norderszorder:allrrrYrZr0rT)rorrrNrrurxfilter_by_symbol_since_limit) rTrerfrgrar{r\rrcrbrAs rV watch_orderszoxfun.watch_orderss!!!!!! !!&) > EMD 3< 'K C&,& &D  iit$zz#{G[II ??OOFE2E00tTT) "! Js2CC CC A#CC8C CCc|j|dg}d}|j-|j|jdd}t ||_|j}t dt |D]^}|j||i}|j|} |j| |d| dzz }|j|j|`y)NrrA ordersLimitrrrre) rrArrOrrqrrrv parse_orderrsr) rTrrrr{rgrArzr parsedOrders rV handle_orderszoxfun.handle_orderss6~~gvr2 ;; %%dllM4HE07DKq#d)$ 5ANN4B/E**51K MM+ & 3X!66 6K NN4;; 4  5rWrrrrcK|jd{|jd{t|j}d|d}|j |d}|j ||||||} |j | d} | |j| d<| |d<|jdd} |j| |||d{S777w) a` https://docs.ox.fun/?json#order-commands create a trade order :param str symbol: unified symbol of the market to create an order in :param str type: 'market', 'limit', 'STOP_LIMIT' or 'STOP_MARKET' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.clientOrderId]: a unique id for the order :param int [params.timestamp]: in milliseconds. If an order reaches the matching engine and the current timestamp exceeds timestamp + recvWindow, then the order will be rejected. :param int [params.recvWindow]: in milliseconds. If an order reaches the matching engine and the current timestamp exceeds timestamp + recvWindow, then the order will be rejected. If timestamp is provided without recvWindow, then a default recvWindow of 1000ms is used. :param float [params.cost]: the quote quantity that can be used alternative for the amount for market buy orders :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param float [params.limitPrice]: Limit price for the STOP_LIMIT order :param bool [params.postOnly]: if True, the order will only be posted if it will be a maker order :param str [params.timeInForce]: GTC(default), IOC, FOK, PO, MAKER_ONLY or MAKER_ONLY_REPRICE(reprices order to the best maker only price if the specified price were to lead to a taker trade) :param str [params.selfTradePreventionMode]: NONE, EXPIRE_MAKER, EXPIRE_TAKER or EXPIRE_BOTH for more info check here {@link https://docs.ox.fun/?json#self-trade-prevention-modes} :param str [params.displayQuantity]: for an iceberg order, pass both quantity and displayQuantity fields in the order request :returns dict: an `order structure ` N placeorderr[tagrMrnrr0r) rorstrromitcreate_order_requestr millisecondsrNr) rTrerrrrrar{rc orderRequestrnrbs rVcreate_order_wszoxfun.create_order_ws$s0!!!!!!$**,'  65)!66vtT6SXZ`a %%lK@  (,(9(9(;L %&iit$ZZ[';GGG "!Hs2CCCCBCCCCCrcK|jd{|jd{t|j}d|d} |j |d}|j ||||||} |j | d|i} |j| d} | |j| d<| | d<|jdd } |j| || |d{S777w) a edit a trade order https://docs.ox.fun/?json#modify-order :param str id: order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of the currency you want to trade in units of the base currency :param float|None [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.timestamp]: in milliseconds. If an order reaches the matching engine and the current timestamp exceeds timestamp + recvWindow, then the order will be rejected. :param int [params.recvWindow]: in milliseconds. If an order reaches the matching engine and the current timestamp exceeds timestamp + recvWindow, then the order will be rejected. If timestamp is provided without recvWindow, then a default recvWindow of 1000ms is used. :returns dict: an `order structure ` N modifyorderrLrMorderIdrnrr0r) rorrNrrOrPr^rrQrNr) rTrrerrrrrar{rcrRrnrbs rV edit_order_wszoxfun.edit_order_wsLs"!!!!!!$**,'  65)!66vtT6SXZ`a {{<)RA %%lK@  (,(9(9(;L %&iit$ZZ[';GGG "!Hs2C-C'C-C)B3C-"C+#C-)C-+C-c l|j|d}|j|d}|sX|j|d}|j|}|j|d}|j |d|j |d||dd |j |di}|j|} |j| |y)NrM submittedeventrr) rw safe_booljsonr handle_errorsrbrrGr) rTrrr{rYmethod stringMsgrrrs rVhandle_place_orderszoxfun.handle_place_ordersns<&&w6 NN7K8 %%gw7F '*I$$Wf5D   tT6::vtYPWY]_c dw3  &uk*rWclK|t|jdz|jd{|jd{t |j }|j ||d}d||d}|jdd}|j||||d{S7}7g7w)ar https://docs.ox.fun/?json#cancel-order cancels an open order :param str id: order id :param str symbol: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an list of `order structures ` Nz+ cancelOrderWs() requires a symbol argument)rrV cancelorder)r[rMrr0r) rrrorrNrrtrNr)rTrrerar{rrcrbs rVcancel_order_wszoxfun.cancel_order_wss >#DGG.[$[\ \!!!!!!$**,' ..0     iit$ZZ[';GGG "!Hs4.B4B.B4B0 A B4)B2*B40B42B4idsc.Kt|}|dkDrt|jdz|t|jdz|j d{|j d{t |j}|j|}g}td|D]}|||d} |j| d||d} |jd d } |j| ||j| ||d{S777w) a https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-mass-cancel-order cancel multiple orders :param str[] ids: order ids :param str symbol: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an list of `order structures ` z0 cancelOrdersWs() accepts up to 20 ids at a timeNz, cancelOrdersWs() requires a symbol argumentr)instIdordId cancelorders)r[rM dataArrayr0r)rrrrrrorrNrrtrqrsrNrrQ) rTrdrera idsLengthr{r|rjrzrrcrbs rVcancel_orders_wszoxfun.cancel_orders_wss" H r>TWW'YYZ Z >#DGG.\$\] ]!!!!!!$**,' >>&) q)$ #A"QD   T "  #!"  iit$ZZ[$2B2B7F2SU`aaa# "! bs7ADDD0D1BD D DDDc,K|jdd}|j|}d}|j|}|j|j|}||j |j }t|dz}|j|j||j|jtjd} d|j|| dd} |j| |} |j||| ||d{S7w) Nr0r authenticatedzGET/auth/self/verifybase64login)apiKeyrn signature)r[r)rNrfuturerv subscriptionscheck_required_credentialsrQrNhmacencodesecrethashlibsha256rqr^r) rTrarbrr{rsrnrnpayloadrrrcrs rVrzoxfun.authenticatesiit$S!% {+v';';[I   + + -))+I)n'==G $++g"6 DKK8PRYR`R`bjkI"kk!*!*Gkk'62G JJsK+ >||sD D DDc|j|dd}d}|r.|j|j|}|jdyt |j |}|j ||||jvr|j|=yy)NsuccessFrnT)r[rvfuturesrrr\rejectrt)rTrrrnr{rserrors rVhandle_authentication_messagez#oxfun.handle_authentication_messages~w 5A % ^^FNNK@F NN4 ' '(:;E MM% -f222((53rWcy)NrK)rTrs rVrKz oxfun.pingsrWc0|j|_|SN)rQlastPong)rTrrs rV handle_pongzoxfun.handle_pongs++-rWc*|dk(r|j||y|j|d}|j|dg}|j|d}|||dk(r|j|||dk(r|j |||j ddkDr|j |||j d dkDr|j|||j d dkDr|j|||j d dkDr|j|||j d dkDr|j|||d k(r|j||yy|dk(r|j|||dk(s |dk(s|dk(r|j||yy)NpongrrrZrrrrIrr"r bestBidAskrprKrUrb)rrwrrrfindrrrr#rIrrr`)rTrrrrrZs rVhandle_messagezoxfun.handle_messages f    VW -   '2~~gvr2  '2  D$4""673 ""673zz)$r)!!&'2zz'"R'&&vw7zz)$r)##FG4zz*%*%%fg6zz'"R'""673 $##FG4%2267C%5M+AuP]G]((9H^rWr)<__name__ __module__ __qualname__rrSrdrNr rrrjrirrrrrrrr rr rrrrrrrrrrrrrr rrrr#rrr rDrIrrfloatr rSrWr`rcrlrrrKrr __classcell__)rUs@rVrrs1 #1 fIKj<@d[] S SS S Sbfglbm SOSaenpSd3iSS[^SuyzvAS>0F0< E >8<$]ajlIICIWZIquvzq{I<aeswAC"E$tCy/"EZ]"Emp"EH,I6,I\ F d *@DB PS P PS\ PSW_a%!$s)%!C%!fo%!N!/!/F68 / /F /6:"E7EEB0F0B8rs` AATTTTT40.'M:D   $ $M:rW