":hddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej8j:Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List)AuthenticationError) NotSupported)Precisec eZdZdeffd ZdZdZdifdedede fdZ d e fd Z ifdede fd Zd2d Zd e fd ZdifdedefdZd e fdZdifdedefdZd e fdZd2dZdddifdedededeefdZd e fdZddifdedededeefdZd e fdZd2dZd e fdZ ifdZ!ifdZ"ifdZ#dddifde$dededee%fdZ&dddifde$dededeefd Z'd2d!Z(d e fd"Z)d e fd#Z*d e fd$Z+dddifdedededee,fd%Z-d2d e defd&Z.d'Z/d(Z0d2d)Z1ifde2fd*Z3d+Z4d e fd,Z5d e fd-Z6d e fd.Z7d e fd/Z8d e fd0Z9d e fd1Z:xZ;S)3woofiproreturnc|jtt|ddddddddddddd ddddiddd did dddd d d iddd d|jdddddt iiidS)NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbolswatchPositionsrz"wss://ws-evm.orderly.org/ws/streamz5wss://ws-private-evm.orderly.org/v2/ws/private/stream)publicprivatez*wss://testnet-ws-evm.orderly.org/ws/streamz=wss://testnet-ws-private-evm.orderly.org/v2/ws/private/stream)apitest)apiKeysecret accountId)fetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit ordersLimit requestIdr&i')ping keepAliveexactzAuth is needed.)hasurlsrequiredCredentialsoptions streaming exceptions) deep_extendsuperrdescriber4r)self __class__s K/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/woofipro.pyr?zwoofipro.describesh > @ $!%""&## $!%#)."&  "F#Z"N#b !$ $#.2.2#  " )+>_6C 6 6 c|j|jdi}|j||d}|j|d}||jd|<|S)Nr3r) safe_dictr: safe_integersum)r@urlr: previousValuenewValues rB request_idzwoofipro.request_idKsT..{B?))'3: 88M1-)1 [!#&rCcKd}|j |j}|jddddz|z}|j|}d|i}|j||}|j |||||d{S7w)N(OqdphuyCtYWxwzhxyLLjOWNdFP7sQt8RPWzmb5xYr)rr'/id)r-r8rLextendwatch)r@ messageHashmessagerPrIr3 subscriberequests rB watch_publiczwoofipro.watch_publicRs 7 >> %Biit$X.4r9OOC( ) ++i1ZZ['; RRRRsA5A>7A<8A>NsymbollimitcK|jd{d}|j|}|ddz|z}d|d}|j||}|j||d{} | j S7c7w)aO https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/orderbook watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: the maximum amount of order book entries to return. :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols N orderbookrP@rUeventtopic) load_marketsmarketrQrWrY) r@rXrYparamsnamerar_rVrTr[s rBwatch_order_bookzwoofipro.watch_order_book_s!!!V$t s"T)  ++gv.++E7;;    "A:AA>%A<&A><A>clientc|j|di}|j|d}|j|}|d}|j|d}||jvr|j |j|<|j|}|j |d} |j ||| dd} |j| |j||y)NdatarXr_tsbidsasks) rF safe_string safe_market orderbooks order_bookrGparse_order_bookresetresolve) r@rerTrgmarketIdrarXr_r[ timestampsnapshots rBhandle_order_bookzwoofipro.handle_order_bookvs,~~gvr2##D(3!!(+!  '2$//)&*oo&7DOOF #OOF+ %%gt4 ((vy&&Q!y%(rCcK|jd{d}|j|}|d}|ddz|z}d|d}|j||}|j||d{S7X7w)a https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/24-hour-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 :returns dict: a `ticker structure ` NtickerrXrPr\rUr])r`rarQrW)r@rXrbrcrar_rVrTs rB watch_tickerzwoofipro.watch_tickers!!!V$!t s"T)  ++gv.&&ug666 "7s"A3A/AA3*A1+A31A3cx|jid|jd|ddddd|j|dd|j|dddddddd dd dd |j|d d |j|d d ddddddddd|j|d|j|d|d|S)NrXrsdatetimehighlowbid bidVolumeask askVolumevwapopencloselast previousClosechange percentageaveragevolumeamount) baseVolume quoteVolumeinfo) safe_ticker safe_symbolrk)r@rwras rBparse_ws_tickerzwoofipro.parse_ws_tickersT! d&&tV4! !  !  D$$VV4 ! 4##FE2 ! 4 !  !  4!  !  D!  D$$VV4!  T%%fg6!  D!  T!  d! $!! " t#! $**68<++FH=)! * + rCc@|j|di}|j|d}|j|d}|j|}|j|d}||d<|j ||}|d|d<||j |d<|j |||S)Nrgr_rXrhdate)rFrkrlrGrtickersrq) r@rerTrgr_rrrarsrws rB handle_tickerzwoofipro.handle_tickers"~~gvr2  '2##D(3!!(+%%gt4  V %%dF3!(+x)/ VH%&vu%rCsymbolscK|jd{|j|}d}|}d|d}|j||}|j||d{}|j |d|S7]7w)a https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/24-hour-tickers 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 :returns dict: a `ticker structure ` NrrUr]rXr`market_symbolsrQrWfilter_by_arrayr@rrbrcr_rVrTrs rB watch_tickerszwoofipro.watch_tickerss!!!%%g.  ++gv.))%99##GXw?? ":"A8A4AA8A6A86A8c|j|d}|j|dg}|j|d}g}tdt |D]r}|j||d}|j |} |j |j||d|i| } | |j| d<|j| t|j||y)Nr_rgrhrrXr) rk safe_listrGrangelenrlrrQrappendrq) r@rerTr_rgrsresultirrrarws rBhandle_tickerszwoofipro.handle_tickerss(  '2~~gvr2%%gt4 q#d)$ "A''Q:H%%h/F))$++d1g ?R*SU[\F-3DLL) * MM& !  " vu%rCcK|jd{|j|}d}|}d|d}|j||}|j||d{}|j |d|S7]7w)a https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/bbos 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 ` NbbosrUr]rXrrs rBwatch_bids_askszwoofipro.watch_bids_asks&s!!!%%g.  ++gv.))%99##GXw?? ":rc`|j|d}|j|dg}|j|d}g}tdt |D]K}|j |j ||d|i}||j|d<|j|M|j||y)Nr_rgrhrrX) rkrrGrrparse_ws_bid_askrQrrrq) r@rerTr_rgrsrrrws rBhandle_bid_askzwoofipro.handle_bid_ask<s   '2~~gvr2%%gt4 q#d)$ "A**4;;tAwy@Q+RSF-3DLL) * MM& ! " vu%rCc f|j|d}|j||}|j|d}|j|d}|j|||j ||j|d|j|d|j|d|j|d|d|S)NrXrhraskSizer}bidSize)rXrsrzrrr}r~r)rkrlrGriso8601)r@rwrarrrXrss rBrzwoofipro.parse_ws_bid_askVs##FH5!!(F3!!&(3%%fd3 " Y/##FE2))&)<##FE2))&)< !    rC1msincecK|jd{|dk7r;|dk7r6|dk7r1|dk7r,|dk7r'|dk7r"|dk7r|d k7rt|jd z|j|}|j |j ||}d }|d d z|zdz|z} d| d} |j | |} |j| | d{} |jr| j|d|}|j| ||ddS77<w)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/k-line :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :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 Nr5m15m30m1h1d1w1MzG watchOHLCV timeframe argument must be 1m, 5m, 15m, 30m, 1h, 1d, 1w, 1MklinerPr\_rUr]rXrT) r`rrPrark timeframesrQrW newUpdatesgetLimitfilter_by_since_limit) r@rX timeframerrYrbraintervalrcr_rVrTohlcvs rB watch_ohlcvzwoofipro.watch_ohlcvfsR!!!  I$5I%%dllL$GE*51F-3DKK  *[[(3 &!z5)rCcLK|jd{|j|}|d}|ddz}d|d}|j||}|j||d{} |jr| j |d|}|j | |||dS77<w)aC watches information on multiple trades made in a market https://orderly.network/docs/build-on-evm/evm-api/websocket-api/public/trade :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrXrPz@traderUr]T)r`rarQrWrrfilter_by_symbol_since_limit) r@rXrrYrbrar_rVrTtradess rB watch_tradeszwoofipro.watch_tradess!!!V$!t x'  ++gv.((88 ??OOF8$4e||sD:E<E=EcK|j|d{|jddddz|jz}|j|}d|i}|j ||}|j |||||d{S7m7wNr)rr(rOrP)rr8r-rLrQrR)r@rSrTrbrIr3rUrVs rB watch_privatezwoofipro.watch_private`s'''iit$Y/#5FOOC( ) ++i1ZZ['; RRR (S"B BA(B BB B cK|j|d{|jddddz|jz}|j|}d|i}|j ||}|j |||||d{S7m7wr )rr8r-rLrQwatch_multiple)r@ messageHashesrTrbrIr3rUrVs rBwatch_private_multiplezwoofipro.watch_private_multiplejs'''iit$Y/#5FOOC( ) ++i1((mWmU^___ (`r cK|jd{|j|ddd}|rdnd}|j|ddg}|}||j|}|d}|d|zz }d |d } |j | |} |j || d{} |j r| j||}|j| |||d S779w) a watches information on multiple orders made by the user https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/execution-report https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/algo-execution-report :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 bool [params.trigger]: True if trigger order :returns dict[]: a list of `order structures ` NstoptriggerFalgoexecutionreportexecutionreportrX:rUr]T r` safe_bool_2omitrarQr rrr r@rXrrYrbrr_rSrarVrTorderss rB watch_orderszwoofipro.watch_ordersts!!!""669eD*1%8I6FI#67  [[(FH%F 3< 'K  ++gv.))+w?? ??OOFE2E00tTT# "@s"CCBCC8CCcK|jd{|j|ddd}|rdnd}|j|d}d}||j|}|d}|d |zz }d |d } |j | |} |j || d{} |j r| j||}|j| |||d S779w) a watches information on multiple trades made by the user https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/execution-report https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/algo-execution-report :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 bool [params.trigger]: True if trigger order :returns dict[]: a list of `order structures ` NrrFrrmyTradesrXrrUr]Trrs rBwatch_my_tradeszwoofipro.watch_my_tradess!!!""669eD*1%8I66*  [[(FH%F 3< 'K  ++gv.))+w?? ??OOFE2E00tTT# "@s"CC A>CC8CCc |j|d}|j|d}|j|}|d}|j|d}|j|d|j|dd}|j|d}|j|d} |j|d} t j |d r| | } |j|d } |j |d } |j |d } |j|d }|j|d }| }t j| |rt j||}|j|d}|j|}d}|j|d}|j|d}|jid|d|d|d|d|d|j|d|d | ddddd | d| d|d|d| dddd|||||dS)NrrXrstotalFeerrravgPrice0quantityrrtotalExecutedQuantitystatus clientOrderId triggerPricerrPrzlastTradeTimestamp timeInForcepostOnly stopPricerrr)filled remainingr&rr) rkrarGrr string_eqr string_ge string_subparse_order_status safe_orderr)r@rrarrrrXrsr priceStringrr"rrrr-totalExecQuantityr. rawStatusr&rr'r(s rBparse_ws_orderzwoofipro.parse_ws_ordersD""5)4##E84X&!%%e[9 $$UJ7(( ; &&ug6   0##E:6   [# .H4HE!!%4%%eV4%%eV4!!%)@A ,,U4KL   V%6 7**96GHI$$UH5 ((3((@ ''~>  E f  '  ]     Y/   !)  D  4    D  U    L  f D! " t# $"-   rCc|j|d}|j|d}t|trht dt |D]O}||}|j |j|d}||j|||j|||Qy|j |j|d}||j|||j|||y)Nr_rgrr) rkr isinstancelistrr omit_zerohandle_my_trade handle_order)r@rerTr_rgrrrs rBhandle_order_updatezwoofipro.handle_order_update,s:  '2w/ dD !1c$i( 8Q..)9)9$ )JK&((7!!&%7  8nnT%5%5dI%FGG"$$VT2   fdE 2rCc|j|}|j|d}|j|d}|9|j-|j|jdd}t ||_|j}|j |j|i} |j | |} | q|j| d} | | |d<|j| d} | | |d<|j| d|d<|j| d|d<|j| d |d <|j||j|j||d z|z} |j|j| yy) NrXrPr2r.rfeesrrsrzr) r7rkrrGr:rrFhashmaprrrrq)r@rerTr_rrXrrY cachedOrdersrrrr@messageHashSymbols rBr=zwoofipro.handle_orderZsh$$W-!!&(3""640  {{"))$,, tL4U; ;;L^^L$8$8&"EFNN673E ooeU3?$'F5M~~eV4#%)F6N#'>>%#Bx &*&7&7{&K{#%)%5%5eZ%Hz"    ' NN4;; . % f 4  NN4;;(9 :) rCcpd}|j|d}|j|}|d}|j||}|j}|/|j |j dd} t | }||_|j||j|||dz|z} |j|| y)NrrXr1r.r) rkrlrrrGr:rrrq) r@rerTrSrrrarXrrrYsymbolSpecificMessageHashs rBr<zwoofipro.handle_my_tradets:! ##GX6!!(+!##GV4 >%%dllM4HE+E2F"DM ev{+$/#$5$>!v89rCc K|jd{g}|j|}|j|s4tdt |D]}||}|j d|zn|j d|j ddddz|jz}|j|} |j| ||jd d d } |jd d d } | r<| r:|j.| jd d{} |j| |||d Sd dd} |j|| |d{}|jr|S|j|j|||d S7g7i76w)a  https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/position-push watch all open positions :param str[] [symbols]: list of unified market symbols @param since timestamp in ms of the earliest position to fetch @param limit the maximum number of positions to fetch :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr positions:: positionsr)rr(rOr&r/Tr0rUpositionr])r`ris_emptyrrrr8r-reset_positions_cache handle_optionrHrfilter_by_symbols_since_limitrr)r@rrrYrbrrrXrIrer/r0rtrV newPositionss rBwatch_positionszwoofipro.watch_positionss!!! %%g.}}W%1c'l+ = $$]V%;< =   -iit$Y/#5FS!   1!%!3!34DF^`d!e!%!3!34DF^`d!e !&<AW#]]+CDDH55hPUW[\ \  "88QWXX ?? 11$..'5RWY]^^1 "E Ys4FE=C?FF4F F 2FFFc|jddd}|r@d}||jvr/|j||j|j||yyt |_y)Nr&r/F)rLrrspawnload_positions_snapshotrrH)r@rerrr/rSs rBrKzwoofipro.set_positions_cachesa!%!3!34DF^`e!f !2K6>>1 k* 477M267DNrCcK|jd{}t|_|j}tdt |D]B}||}|j |dd}t j|ds2|j|D|j|}|j||j|dy7w)Nr contractsr#rH) fetch_positionsrrHrrrkr string_gtrrrq) r@rerSrHcacherrIrTrs rBrRz woofipro.load_positions_snapshots..00 13q#i.) 'A |H((;DI  C0 X&  '  ,uuk*1sCCA%C=ACc|j|di}|j|dg}|jt|_|j}g}t dt |D]x}||}|j |d} |j| } |j|| } |j| |j| d| dz} |j| | z|j|dy)NrgrHrrXrG) rFrrHrrrrkrlparse_ws_positionrrq) r@rerTrg rawPositionsrWrNr rawPositionrrrarIrSs rBhandle_positionszwoofipro.handle_positionssB~~gvr2~~dK< >> !57DN q#l+, 2A&q/K'' X>H%%h/F--k6BH    ) LL "'&*::K NN8[ 1 2 |[1rCch|j|d}|j||}|j|d}d}tj|drd}nd}|j|d}|j|d}|j |d}|j|d } |j|d } tj |}tj ||} |jid |d dd|j|dd|d |j|ddddddddddd|j| d|j| ddd|j| d|j|d|j|dd|j|d|j|dddd|ddddd S)NrX positionQtyr#longshort contractSize markPricersaverageOpenPrice unsettledPnlrrPrzlastUpdateTimestamp initialMargininitialMarginPercentagemaintenanceMarginmaintenanceMarginPercentage entryPricenotionalleverage unrealizedPnlrT marginRatio estLiqPricecross) liquidationPricerb lastPrice collateral marginMode marginTyperrhedged stopLossPricetakeProfitPrice) rkrlrrVrG string_absr safe_positionr parse_numberr) r@rIracontractrrrarbrsrj unrealisedPnlrks rBrYzwoofipro.parse_ws_positionsC2##Hh7!!(F3-8   T3 'DD''? $$X{; %%h < %%h0BC ((>B !!$'%%dI6!!# H# $#  d&&vx8#   #  Y/ # "4 #  T#  &t#  #  *4#  $++J7#  ))(3#  #  T..}=#  **40# D--l;!# " 4## $!% 0 0= I**95!!#9#   rCcK|jd{d}|}d|d}|j||}|j||d{S797w)aw watch balance and get the amount of funds available for trading or funds locked in orders https://orderly.network/docs/build-on-evm/evm-api/websocket-api/private/balance :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` NbalancerUr])r`rQr )r@rbr_rSrVrTs rB watch_balancezwoofipro.watch_balanceWsd!!!   ++gv.'' W=== ">s!AA4A A AAc|j|di}|j|di}t|j}|j|d}||jd<||jd<|j ||jd<t dt|D]}||}||} |j|} | |jvr|j| n|j} |j| d} |j| d } | | d <| | d <tj| | | d <| |j| <|j|j|_|j|jd y)Nrgbalancesrhrrsrzrholdingfrozentotalusedfreer)rFr:keysrGrrrrraccountrkrr1 safe_balancerq)r@rerTrgrrrhrkeyvaluecoderrrs rBhandle_balancezwoofipro.handle_balancejs_8~~gvr2>>$ B7HMMO$   w -# V$& [!#'<<#3 Z q#d)$ )Aq'CSME**3/D-1T\\-Adll4( G$$UI6E##E84D$GG "GFO%00=GFO!(DLL  )((6 t||Y/rCcd|vry|j|d}|ry|j|d} |A|jdz|j|z}|j |j d||y#t $r[}t|tr0d}|j||||jvr|j|=n|j|Yd}~yd}~wwxYw)NrFerrorMsg r6rT) rrkrPrthrow_exactly_matched_exceptionr< Exceptionr9rrr)r@rerTr errorMessagefeedbackrrSs rBhandle_error_messagezwoofipro.handle_error_messagesW$..)4 ''<  '77S=499W+==44T__W5M|]ef %!45-  e[1&"6"66,,[9 e$ sAA22 C;ACCcn|j||ry|j|j|j|j|j |j |j|j|j|j|j|j|j|jd}|j|d}|j||}| |||y|j|d}||j||}| |||y|j!d}t#|}|dk(r|j|d} |j|| }| |||y| j!d} t#|} | dk(r/|j||j| d}| |||yyyyy) N)r4pongrUr[rwrrrrrrrIrrr^r_r\rErr)r handle_ping handle_ponghandle_subscriberurrrrrr>r\rrrkrrr) r@rerTmethodsr^methodr_ splitTopic splitLengthrc splitNamesplitNameLengths rBhandle_messagezwoofipro.handle_messages  $ $VW 5 $$$$..//((**&&&&$$#77#'#;#;--**''    '2%0   67 #   '2  __We4F!vw'S)Jj/Ka'' A6$7%67+ JJsO "%j/"a'!__Wd6F6FyRS6TUF)vw/*(  rCc ddiS)Nr^r4)r@res rBr4z woofipro.ping   rCc ddiS)Nr^rrr@rerTs rBrzwoofipro.handle_pingrrCc0|j|_|SN) millisecondslastPongrs rBrzwoofipro.handle_pongs++-rCc|Srrrs rBrzwoofipro.handle_subscribes rCr)<__name__ __module__ __qualname__rr?rLrWrr r rdrrurrxrrrrrrrrrrr:rrrrrrrrr rr r rrr7r>r=r<r rOrKrRr\rYrrrrrr4rrr __classcell__)rAs@rBrrs7 #7 r S@DB!S!!S\!.!)!)F6877F7,"HF:6:"@7@@,&V&@8>&/0b62+0V+0Z!6!!&!& v rCr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrccxt.base.preciser async_supportrrrCrBrsK AApppp40)%gt!!**grC