ei0ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej j!Z!dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesIntMarketNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) BadRequestcHeZdZdeffd ZifdZddifdedededee fdZ ddifd eedededee fd Z d e fd Z d6de fd Zdddifdededededeef dZddifdeeededefdZd e fdZd6dedefdZdifdededefdZdifd eededefdZd e fdZifdedefdZdifd edefdZd e fdZdifd edefdZd e fdZ d6dZ!ifde"fdZ#d Z$dddifd edededee%fd!Z&d e fd"Z'd6defd#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)fd0Z5ifd1Z6d e fd2Z7d e fd3Z8d e fd4Z9d e fd5Z:xZ;S)7oxfunreturnc&|tt|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 L/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/oxfun.pyrSzoxfun.describes~eT 2 2 ; ; = =dt(!$  +D  d 't t  t  !"!$#(9>   !"!!""#"  w#& "Y0@ 0@ 0 0 0 cK|jdd}d|d}|||||||d{VS)Nr0r subscribeopargs)rNwatch_multipleextend)rT messageHashes argsArrayparamsurlrequests rVsubscribe_multiplezoxfun.subscribe_multipleFsgit$  ((mT[[RX=Y=Y[hiiiiiiiiirWNsymbolsincelimitcDK||g|||d{VS)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_tradesNs622F8UE6RRRRRRRRRrWsymbolscRK|d{V||dd}g}g}tdt|D]S}||}d|z} || ||} d| z} || T||||d{V} |jrC|| di} | | d}| ||}| | ||ddS) aA 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]sO!!!!!!!!!%%gtU;; q#g,,''  AQZF(61K   - - -~~f--HX%C KK    ..}dFKKKKKKKK ? 8NN61b11E**5(;;KOOK77E))&% TRRRrWclientc||dg}tdt|D]}|||i}||}||d}d|z}||jvr3||jdd} t| |j|<|j|} | || | |dS)Ndatarrerm tradesLimit) safe_listrqrrrvparse_ws_traderwr~ safe_integerrOrrsresolve) rTrmessagerrztrade parsedTraderer{rstoreds rV handle_tradeszoxfun.handle_trades|s"~~gvr22q#d))$$ 0 0ANN4B//E--e44K%%k8<` indexed by market symbols N)watch_order_book_for_symbols)rTrergras rVwatch_order_bookzoxfun.watch_order_book>s466xOOOOOOOOOrWc`K|d{V||}d}||jdi}||d}||}n||dkrd}n|dkrd}n|d krd }g}g}t d t |D]V} || } d | z} || || } |d z| z} || W| |||d{V}| S)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_symbolsLso!!!!!!!!!%%g..../?DD))'9==  %$GG  zz#"$"$ q#g,,''  AQZF&/K   - - -~~f--HC-(*C KK    11-vNNNNNNNN    rWc||di}||d}||}||d}d|z}||jvr|i|j|<|j|}||||dd} || ||d|d<||j|<|||dS) NrrrnrasksbidsseqNumnonce) rvrwrr orderbooks order_bookparse_order_bookresetr) rTrrrr|rernr{rsnapshots rVhandle_order_bookzoxfun.handle_order_bookss*~~gvr22##D,77!!(++%%dK88 "V+ $/))&*oob&9&9DOF #OF+ ((vy&&QQ!!!!..tX>> '"+y+.....rWclK||g|d{V}|||S)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_tickersE))6(F;;;;;;;;vv...rWc K|d{V|du}|}g}|r|j}|dg}tdt |D]S}||}d|z} || ||} |s|d| zT||||d{V} |jri} | | | d<| S||j d|S)a6 https://docs.ox.fun/?json#ticker 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 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 ` Nz ticker:allrtickers:zticker:re) rorkrsrqrrrtrdrufilter_by_arraytickers) rTrkra allSymbolsrr\r_rzrer{r| newTickerresults rVrzoxfun.watch_tickerssB!!!!!!!!!o   &,C KK % % % q#c((## 2 2AVF)F2K   - - -~~f--H 2 I011111-vNNNNNNNN ? F*3F9X& 'M##DL(GDDDrWc&||dg}tdt|D][}|||i}||}|d}d|z}||j|<|||\dS)Nrrrer)rrqrrrv parse_tickerrr) rTrrrrz rawTickerrrer{s rV handle_tickerzoxfun.handle_tickers0~~gvr22q#d))$$ 0 0AtQ33I&&y11FH%F$v-K#)DL NN6; / / / /  0 0rWcK|d{V||dd}g}g}tdt|D]Y}|||}|d|dz|d|dzZ||||d{V}|jri}|||d<|S||j d|S)af 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 5 5  VH-=!= > > > >22=$OOOOOOOO ? G,6GJx( )N##DM8WEEErWc||di}||}|d}||j|<d|z}|||dS)Nrrer)rvparse_ws_bid_askrr)rTrrr parsedTickerrer{s rVhandle_bid_askzoxfun.handle_bid_asksf&~~gvr22,,T22 h' , f&( |[11111rWc ||d}|||}||d}||d}||dg}||dg}|||||||d||d||d||d|d|S) Nrrernaskbidrr)rernrr askVolumer bidVolumer)rwrrr safe_tickerrr)rTrrr|rernrrs rVrzoxfun.parse_ws_bid_asks ##FL99!!(F33!!&(33%%fk:: nnVUB//nnVUB//" Y//##C++))#q11##C++))#q11 ! !     rWcK|d{V|d}d}|jdd}d|gd}|||||||d{VS)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!!!!!!!!!  it$F  ZZ[$++gv2N2NP[\\\\\\\\\rWc||d}||d}||jd<||jd<|||jd<t dt |D]}|||i}||d}||}||jvr| |j|<|j|} ||d| d<||d| d <||d | d <| |j|<| |j|_| |jd dS) Nrrnrrr instrumentIdtotalreservedused availablefreer) rrrrrqrrrvrwsafe_currency_codeaccount safe_balancer) rTrrbalancesrnrzr currencyIdcoders rVhandle_balancezoxfun.handle_balance@ss(>>'622%%g{;; & V$- [!#'<< #:#: Z q#h--(( ) )AnnXq"55G))'>BBJ**:66DDL((%)\\^^ T"l4(G#//AAGG "..w CCGFO"..w DDGFO!(DL  ((66 t|Y/////rWc(K|d{V|d{V|du}|}g}|r|j}|dg}t dt |D]S} || } d| z} || || } |s|d| zT||||d{V} |jr| S| |j |||dS)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_positionsgsY!!!!!!!!!!!!!!!!!!o   (,C KK ' ' ' q#c((## 4 4AVF+f4K   - - -~~f--H 4 K(2333!44]D&QQQQQQQQ ?  11$.'5RWY]^^^rWc~|jt|_|j}||dg}tdt |D]f}|||i}||}|d}d|z} ||||| gdS)Nrrrer) rrrrqrrrvparse_ws_positionrsr) rTrrcacherrz rawPositionpositionrer{s rVhandle_positionszoxfun.handle_positionss* > !577DN~~gvr22q#d))$$ 2 2A..q"55K--k::Hh'F&/K LL " " " NN8[ 1 1 1 1  2 2rWc||d}|||}|id|ddd|dddddd||d d ||d d ||d d dddd||dddddddddddddd||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_positions##Hn==!!(F33!!# H# $#  fX&#   # ' #  0 0;P Q Q #  $**8\BB#  T--h FF#  4#  $#  ))(J??#  D#  #  #  D# d!# " ## $#'#4#4X}#M#M!%+/!'+!#9# # #    rWcK|d{V|d{Vd}d}||}||dz }n|d|zz }|d|dzz }d|gd}|jd d } || |||d{V} |jr| ||}|| |||d S) 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*!!!!!!!!!!!!!!!!!! !!&)) > EMDD 3< 'K C&,& &D   it$zz#{G[IIIIIIII ? 3OOFE22E00tTTTrWc||dg}d}|j0||jdd}t ||_|j}t dt |D]l}|||i}||} | | |d| dzz }| |j|mdS)NrrA ordersLimitrrrre) rrArrOrrqrrrv parse_orderrsr) rTrrrr{rgrArzr parsedOrders rV handle_orderszoxfun.handle_orderss6~~gvr22 ; %%dlM4HHE077DKq#d))$$ 5 5ANN4B//E**511K MM+ & & & 3X!66 6K NN4; 4 4 4 4  5 5rWrrrrcK|d{V|d{Vt|}d|d}||d}|||||||} || d} | || d<| |d<|jdd} | | |||d{VS) 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$s 0!!!!!!!!!!!!!!!!!!$**,,''   65))!66vtT6SXZ`aa %%lK@@  (,(9(9(;(;L %&it$ZZ[';GGGGGGGGGrWrcK|d{V|d{Vt|}d|d} ||d}|||||||} || d|i} || d} | || d<| | d<|j dd } | | || |d{VS) 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_wsLs7"!!!!!!!!!!!!!!!!!!$**,,''   65))!66vtT6SXZ`aa {{<)RAA %%lK@@  (,(9(9(;(;L %&it$ZZ[';GGGGGGGGGrWc ||d}||d}|sc||d}||}||d}||d|j|i||ii ||di}||} || |dS)NrM submittedeventrrr) rw safe_booljsonr handle_errorsrbrrGr) rTrrr{rYmethod stringMsgrrrs rVhandle_place_orderszoxfun.handle_place_ordersns<&&w66 NN7K88  ]%%gw77F '**I$$Wf55D   tRVRGUWY[ \ \ \w33  &&uk*****rWcK|t|jdz|d{V|d{Vt |}|||d}d||d}|jdd}|||||d{VS)ap 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 >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!$**,,'' ..00       it$ZZ[';GGGGGGGGGrWidscdKt|}|dkrt|jdz|t|jdz|d{V|d{Vt |}||}g}td|D]"}|||d} | | #d||d} |j d d } | | || | ||d{VS) 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_wssk HH r>>TW'YYZZ Z >#DG.\$\]] ]!!!!!!!!!!!!!!!!!!$**,,'' >>&)) q)$$ # #A"QD   T " " " " "   it$ZZ[$2B2B7F2S2SU`aaaaaaaaarWcTK|jdd}||}d}||}||j|}|||}t|dz}|| || |j tj d} d|j || dd} || |} |||| ||d{VS) Nr0r authenticatedzGET/auth/self/verifybase64login)apiKeyrn signature)r[r)rNrreusableFuturerv subscriptionscheck_required_credentialsrQrNhmacencodesecrethashlibsha256rqr^r) rTrarbrr{futurernrnpayloadrrrcrs rVrzoxfun.authenticates)it$S!!% &&{33v';[II   + + - - -))++I)nn'==G $++g"6"6 DK8P8PRYR`bjkkI"k!*!*Gkk'622G JJsK+ > > >||||||rWc6||dd}d}|r2||j|}|ddSt ||}|||||jvr |j|=dSdS)NsuccessFrnT)r[rvfuturesrrr\rejectrt)rTrrrnr{r{errors rVhandle_authentication_messagez#oxfun.handle_authentication_messagesw 5AA %  6^^FNK@@F NN4 ' '(:(:;;E MM% - - -f222(55532rWcdS)NrK)rTrs rVrKz oxfun.pingsvrWc8||_|SN)rQlastPong)rTrrs rV handle_pongzoxfun.handle_pongs++--rWc|dkr|||dS||d}||dg}||d}|F|C|dkr||||dkr||||ddkr||||d dkr||||d dkr||||d dkr| |||d dkr| |||d kr| ||dSdS|dkr| |||dks |dks|dkr| ||dSdS)NpongrrrZrrrrIrr"r bestBidAskrprKrUrb)rrwrrrfindrrrr#rIrrr`)rTrrrrrZs rVhandle_messagezoxfun.handle_messages- f     VW - - - F  '22~~gvr22  '22  D$4""67333  ""67333zz)$$r))!!&'222zz'""R''&&vw777zz)$$r))##FG444zz*%%**%%fg666zz'""R''""67333 $$##FG44444%$2267CCC%%5M+A+AuP]G]G]((99999H^G]rWr)<__name__ __module__ __qualname__rrSrdrNr rrrjrirrrrrrrr rr rrrrrrrrrrrrrr rrrr#rrr rDrIrrfloatr rSrWr`rcrlrrrKrr __classcell__)rUs@rVrrs1 #1 1 1 1 1 1 fIKjjjj<@d[] S S SS S Sbfglbm S S S SOSaenpSSd3iSS[^SuyzvASSSS>0F0000<  E    >?CQUdhqsIIII3I^aIx|~ByCIIII<aeswAC"E"E$tCy/"EZ]"Emp"E"E"E"EH,I6,I,I,I,I\  F d    *@DB P PS P PS\ P P P PSW_a%!%!$s)%!C%!fo%!%!%!%!N!/!/!/!/!/F68 / / /F / / / /6:"EE7EEEEEB0F0000B8rs AAAAAAAAAAAATTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTT444444000000......''''''M:M:M:M:M:D  $M:M:M:M:M:rW