":hddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZGdd ej2j4Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc eZdZdeffd ZifdZifdZdddifdeded ede e fd Z difdedefd Z ddifd e e eded efd Z ifd e e edefdZdefdZifdedefdZifdedefdZdifdedefdZdifdedefdZdefdZdifdedefdZdefdZd-dZddifdeded ede efdZifdedefdZddifde eded ede efdZifde edefdZ defdZ!difded ede"fdZ#ifdedefd Z$difde ed ede"fd!Z%ifde edefd"Z&defd#Z'ifd$Z(ifd%Z)ifde*fd&Z+defd'Z,dddifde-ded ede e.fd(Z/defd)Z0dddifdeded ede e1fd*Z2d+Z3defd,Z4xZ5S).defxreturnc|jtt|dddddddddddddd ddddiddd did d d d dddddddddddd idiidS)NTF) ws watchBalance watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbols watchMyTrades watchOrderswatchOrderBookwatchOrderBookForSymbols watchOHLCVwatchOHLCVForSymbolsrz'wss://stream.testnet.defx.com/pricefeedzwss://ws.testnet.defx.com/user)publicprivatez'wss://marketfeed.api.defx.com/pricefeedz wss://userfeed.api.defx.com/user)testapi 6 timeframes1m3m5m15m30m1h2h4h12h1d1w1M) r,r-r.r/r0r1r2r3r4r5r6r7)listenKeyRefreshRater)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s G/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/defx.pyr@z defx.describesdD : < $# $!%#)-!&#"&,0"(,""K#C"K#E )0 """$$"""$""" #&g5? 5 5 cK|jd{|jddd}d|d}|j||}|j||||d{S7L7w)Nr)rr& SUBSCRIBEmethodtopics load_marketsr:extendwatch_multiplerArI messageHashesparamsurlrequestmessages rC watch_publiczdefx.watch_publicIsu!!!iit$X.! ++gv.((mWmTTT "U"A'A#AA'A%A'%A'cK|jd{|jddd}d|d}|j||}|j||||d{S7L7w)Nr)rr& UNSUBSCRIBErGrJrNs rCun_watch_publiczdefx.un_watch_publicSsu!!!iit$X.# ++gv.((mWmTTT "UrUr,Nsymbolsincelimitc\K|j||gg|||d{}|||S7 w)a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 N)watch_ohlcv_for_symbols)rArY timeframerZr[rPresults rC watch_ohlcvzdefx.watch_ohlcv]s@33fi5H4I5RWY_``f~i((as ,* ,cHK|j||gg|d{S7w)a" watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume N)un_watch_ohlcv_for_symbols)rArYr^rPs rCun_watch_ohlcvzdefx.un_watch_ohlcvms)44vy6I5JFSSSS " "symbolsAndTimeframescKt|}|dk(st|dtst|jdz|j d{g}g}t dt|D]}||} |j| d} |j| } |j| d} |j|j| | } |jd| dzdz| z|jd| zd z| d z|j|||d{\}}}|jr|j||}|j|||dd }|j|||S77Qw) a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :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 rzu watchOHLCVForSymbols() requires a an array of symbols and timeframes, like [['BTC/USDT', '1m'], ['LTC/USDT', '5m']]Nsymbol:id:ohlc:candles::rYT)len isinstancelistrrirKrange safe_stringmarketr+appendrT newUpdatesgetLimitfilter_by_since_limitcreate_ohlcv_object)rArerZr[rP symbolsLengthrIrOisymbolAndTimeframemarketIdrrtfintervalrYr^candlesfiltereds rCr]zdefx.watch_ohlcv_for_symbolszs01 A Z0DQ0G%N#DGG/f%fg g!!! q#234 QA!5a!8 ''(:A>H[[*F!!"4a8B''R@H MM)fTl2X=H I  h!6!H[[*F!!"4a8B''R@H MM)fTl2X=H I  h!6!` NrYrhri :24hrTickerticker:)rKrrrT)rArYrPrrtopicrs rC watch_tickerzdefx.watch_tickersw!!!V$!F4L(=8&( &&w vFFF " Gs"A"AAA"A A" A"cDK|j|g|d{S7w)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` N)un_watch_tickersrArYrPs rCun_watch_tickerzdefx.un_watch_tickers#**F8V<<<<   symbolscK|jd{|j|dd}g}g}tdt|D]C}||}|j |}|j d|zdz|j d|zE|j |||d{|j|jd|S77#w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 ` NFrrhrrrY) rKmarket_symbolsrprm market_idrsrTfilter_by_arraytickersrArrPrIrOryrYr{s rC watch_tickerszdefx.watch_tickerss!!!%%gtU; q#g,' 5AQZF~~f-H MM)h.> ?  V!3 4  5  v>>>##DLL(GDD " ?"C CB C #C$"C C c\K|jd{|j|dd}g}g}tdt|D]C}||}|j |}|j d|zdz|j d|zE|j |||d{S77w)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 ` NFrrhrr)rKrrprmrrsrXrs rCrzdefx.un_watch_tickerss!!!%%gtU; q#g,' 5AQZF~~f-H MM)h.> ?  V!3 4  5 ))&-HHH "Is"B,B(B B,#B*$B,*B,c|j|||j|di}|j|}|d}|j|d}||d<|j ||d<||j |<d|z}|j ||y)NrrY timestampdatetimer)handle_bid_askr parse_tickerriso8601rrrArrSr parsedTickerrYrrs rC handle_tickerzdefx.handle_ticker&s: FG,~~gvr2((. h'%%g{; $- [!#'<< #: Z + V&( |[1rDcK|jd{|j|dd}g}g}tdt|D]C}||}|j |}|j d|zdz|j d|zE|j |||d{|j|jd|S77#w)a watches best bid & ask for symbols https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 ` NFrrhrbidask:rY) rKrrprmrrsrTrbidsasksrs rCwatch_bids_askszdefx.watch_bids_asksNs!!!%%gtU; q#g,' 5AQZF~~f-H MM)h.> ?  V!3 4  5  v>>>##DMM8WEE " ?rc|j|di}|j|}|d}|j|d}||d<|j||d<||j|<d|z}|j ||y)NrrYrrr)rparse_ws_bid_askrrrrrs rCrzdefx.handle_bid_askds~~gvr2,,T2 h'%%g{; $- [!#'<< #: Z , f&( |[1rDc $|j|d}|j||}|j|d}|j|dd|j|d|j|d|j|d|j|d|d|S)NrY bestAskPrice bestAskQty bestBidPrice bestBidQty)rYrrask askVolumebid bidVolumeinfo)rq safe_market safe_ticker)rAtickerrrr{rYs rCrzdefx.parse_ws_bid_askos##FH5!!(F3!!&(3##FN;))&,?##FN;))&,? !    rDcHK|j|g|||d{S7w)a@ watches information on multiple trades made in a market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str symbol: unified symbol of the market to fetch the ticker for :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 `ticker structure ` N)watch_trades_for_symbols)rArYrZr[rPs rC watch_tradeszdefx.watch_trades~s'22F8UE6RRRRrdcDK|j|g|d{S7w)a unWatches from the stream channel https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` N)un_watch_trades_for_symbolsrs rCun_watch_tradeszdefx.un_watch_tradess#55vhGGGGrcXK|jd{|j|}t|}|dk(rt|jdzg}g}t dt|D]C}||} |j | } |jd| zdz|jd| zE|j|||d{} |jr6|j| d} |j| d} | j| |}|j| ||dd S77^w) a? watches information on multiple trades made in a market https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str[] symbols: unified symbol of the market to fetch trades for :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 `ticker structure ` Nrz> watchTradesForSymbols() requires a non-empty array of symbolsrh:tradestrade:rYrT)rKrrmrrirprrsrTrt safe_valuerqrurv)rArrZr[rPrxrIrOryrYr{tradesfirst tradeSymbols rCrzdefx.watch_trades_for_symbolss+!!!%%g.G A #DGG.n$no o q#g,' 4AQZF~~f-H MM)h.: ;  F!2 3  4 ((GG ??OOFA.E**5(;KOOK7E))&% TRR# "Hs#D*D%B2D* D( AD*(D*cK|jd{|j|}t|}|dk(rt|jdzg}g}t dt|D]C}||}|j |}|jd|zdz|jd|zE|j|||d{S77w)a unWatches from the stream channel https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str[] symbols: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nrz@ unWatchTradesForSymbols() requires a non-empty array of symbolsrhrr) rKrrmrrirprrsrX rArrPrxrIrOryrYr{s rCrz defx.un_watch_trades_for_symbolss!!!%%g.G A #DGG.p$pq q q#g,' 4AQZF~~f-H MM)h.: ;  F!2 3  4 ))&-HHH "I"CCB2C C CCcN|j|di}|j|}|d}||jvr7|j|jdd}t |}||j|<|j|}|j |d|z} |j|| y)NrrY tradesLimitrr)r parse_traderrr;rrsr) rArrSr parsedTraderYr[rrrs rC handle_tradeszdefx.handle_tradess~~gvr2&&t, X&$++%%%dllM4HE&F"(DKK V$ k"' v{+rDcFK|j|g||d{S7w)aS watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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)watch_order_book_for_symbols)rArYr[rPs rCwatch_order_bookzdefx.watch_order_books%66xOOOOs !!cDK|j|g|d{S7w)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str symbol: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols N)un_watch_order_book_for_symbolsrs rCun_watch_order_bookzdefx.un_watch_order_books#996(FKKKKrcK|jd{t|}|dk(rt|jdz|j |}g}g}t dt|D]C}||}|j |} |jd| zdz|jd|zE|j|||d{} | jS77w)a6 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :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 :returns dict: A dictionary of `order book structures ` indexed by market symbols NrzA watchOrderBookForSymbols() requires a non-empty array of symbolsrh:depth:20:0.001 orderbook:) rKrmrrirrprrsrTr[) rArr[rPrxrIrOryrYr{ orderbooks rCrz!defx.watch_order_book_for_symbolss!!!G A #DGG.q$qr r%%g. q#g,' 8AQZF~~f-H MM)h.1BB C  !6 7  8 ++FM6JJ    "Ks"C"CB2C" C  C" C"cK|jd{t|}|dk(rt|jdz|j |}g}g}t dt|D]C}||}|j |}|jd|zdz|jd|zE|j|||d{S77w)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.postman.com/defxcode/defx-public-apis/collection/667939a1b5d8069c13d614e9 :param str[] symbols: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrzC unWatchOrderBookForSymbols() requires a non-empty array of symbolsrhrr) rKrmrrirrprrsrXrs rCrz$defx.un_watch_order_book_for_symbolss!!!G A #DGG.s$st t%%g. q#g,' 8AQZF~~f-H MM)h.1BB C  !6 7  8 ))&-HHH "Irc |j|di}|j|d}|j|}|d}|j|d}|j |||dddd}||j vr |j |} | |j |<|j |} | j|d|z} |j| | y) NrrYrbidsaskspriceqtyr) rrqrrrparse_order_book orderbooks order_bookresetr) rArrSrr{rrrYrsnapshotobrrs rChandle_order_bookzdefx.handle_order_book5s6~~gvr2##D(3X&!%%dK8 ((vy&&RY[`a$//)*B&(DOOF #OOF+ !"V+ y+.rDcbK|j|jd}|y |jd|id{|j|jdd } |j| |j|y7?#t$r}|jddddz|z}|j |}t |jj}tdt|D]}||}|j||d|jd<d|jd<Yd}~yd}~wwxYww) N listenKeyr)rr' ?listenKey=rlastAuthenticatedTimer8r*)rqr;-v1PrivatePutApiUsersSocketListenKeysListenKey Exceptionr:rrofutureskeysrprmrejectrdelaykeep_alive_listen_key) rArPrerrorrQrrOjrr8s rCrzdefx.keep_alive_listen_key^s)$$T\\;?    DDkS\E]^ ^ ^ $00?UW^_ ')C)CVL _ ))E"4(3mCiOC[[%F !4!4!67M1c-01 2+A.  e[1 2)-DLL %45DLL0 1  s> D/A;A9A;;D/9A;; D,BD'"D/'D,,D/c|K|j}|j|jdd}|j|jdd}||z |kDrd|jd{}|j |d|jd<||jd<|j ||j |yy7Qw)Nrrr8r*r) millisecondsrr;%v1PrivatePostApiUsersSocketListenKeysrqrr)rArPtimerr8responses rC authenticatezdefx.authenticatess  " $ 1 1$,,@WYZ [#00?UW^_ ' '*> >!GGIIH(,(8(8;(ODLL %48DLL0 1 JJ+T-G-G P ?IsA&B<(B:)AB<cK|jd{|jd{|jddd}d}|dz|jdz}|j ||d|d{S7d7N7w)a query for balance and get the amount of funds available for trading or funds locked in orders https://www.postman.com/defxcode/defx-public-apis/ws-raw-request/667939b2f00f79161bb47809 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nr)rr'WALLET_BALANCE_UPDATErr)rKrr:r;watch)rArPbaseUrlrrQs rC watch_balancezdefx.watch_balance}s!!!!!!))E"4(3-  % [(AAZZ[$ DDD "!Es2BA;BA=AB6A?7B=B?Bcp|j|d}|j|dg}|j|d}|ji|_||jd<||jd<|j ||jd<|j|d}|j |}||jvr|j|n|j }|j|d|d<||j|<|j|j|_|j|j|y) Neventrrrrassetbalancefree) rqrrrrsafe_currency_codeaccount safe_balancer) rArrSrrr currencyIdcoder s rChandle_balancezdefx.handle_balances &&w8 ~~gvr2%%g{; << DL# V$- [!#'<< #: Z %%dG4 &&z2)-)=$,,t$DLLN**4;$ T((6 t||[1rDcK|jd{|jd{|jddd}d}||j|}|d|dzz }|dz|jd z}|j ||d|d{} |j r| j||}|j| |||d S777;w) aV watches information on multiple orders made by the user https://www.postman.com/defxcode/defx-public-apis/ws-raw-request/667939b2f00f79161bb47809 :param str [symbol]: unified market symbol of the market the 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 :returns dict[]: a list of `order structures ` Nr)rr'ordersrlrYrrT) rKrr:rrr;rrtrufilter_by_symbol_since_limit) rArYrZr[rPrrrrrQrs rC watch_orderszdefx.watch_orderss!!!!!!))E"4(3  [[(F 3!11 1K % [(AAzz#{D+FF ??OOFE2E00tTT "!Gs2CC CCA%CC8CCCcZd}|j|di}|j-|j|jdd}t ||_|j}|j |}|j ||dz|dz}|j|||j||y)Nrr ordersLimitrrlrY)rrrr;r parse_orderrsr) rArrSchannelrr[r parsedOrderrs rC handle_orderzdefx.handle_ordersB~~gvr2 ;; %%dllM4HE07DK&&t,  k"mk(&;; vw'v{+rDc8K|jd{|jd{|j|}|jddd}d}|dz|jdz}d}|Ug} t dt |D]} || } | j|d z| z |j|| d| d{}n|j||d|d{}|jr|S|j|j|||d S777R77w) a watch all open positions https://www.postman.com/defxcode/defx-public-apis/ws-raw-request/667939b2f00f79161bb47809 :param str[]|None symbols: list of unified market symbols :param number [since]: since timestamp :param number [limit]: limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr)rr' positionsrrrrlT) rKrrr:r;rprmrsrMrrtfilter_by_symbols_since_limitr) rArrZr[rPrrrQ newPositionrOryrYs rCwatch_positionszdefx.watch_positionss-!!!!!!%%g.))E"4(3 % [(AA  M1c'l+ = $$Ws]V%;< =!% 3 3Cm \\K $ 3w GGK ?? 11$..'5RWY]^^# "!]GsDDDDDBDDD D!2DDDDcxd}|j|di}|jt|_|j}|j|}|j |d}||d<|j ||d<|j ||dz|dz}|j|g||j|g|y)NrrrrrlrY)rrrparse_positionrrrsr) rArrSrrcacheparsedPositionrrs rChandle_positionszdefx.handle_positions s&~~gvr2 >> !35DN,,T2%%g{; &/{#%)\\)%<z" ^$mnX&>> '1'5rDc|j|d}|-|j|d}t|jdz|z|j|d}|o|j|j|j |j |j|j|jd}|j||}| |||yyy)Nrmsg r)ohlc 24hrTickerrdepthr ORDER_UPDATEPOSITION_UPDATE) rqrrirrrrrrr#r)rArrSrerrorMsgrmethods exacMethods rChandle_messagezdefx.handle_message-s  &1  ''7H#  89 9  '2  ))"00,,//)-)<)< $ 1 1#'#8#8G%8J%67+& rD)N)6__name__ __module__ __qualname__rr@rTrXstrrrror`rcr]rbrrrrrr rrrrrrrrrrrrrr rrrrrrrrrrr r rrr rr#r/ __classcell__)rBs@rCrrs6 #6 p@BUCEU8<$]ajl))C)WZ)quvzq{) ;?r T3 Tc TaeswACE$tCy/EZ]EmpE@^`IT$s)_IdgI4'@6'@R68GGFG"9; =C =s =6:"E7EE,9=RIgICI*&2F&2P8LNIcIRUI0,F,6@DB PS P PS\ P=? L L3 LSW_a!$s)!C!fo!4PRIT#YIVYI0'/'/R24M*)+Q*,EE 2V2404$UYbdUUCUsUimnsitU2+,6+,Z8<$]ajl_W_C_WZ_quv~q_>6B,V,rDr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrDrCr>sB ffpppp4*.p ,4   " "p ,rD