":hf)ddlZddlmZddlmZmZmZmZddl m Z ddl m Z GddejjZy)N) ArrayCache)AnyInt OrderBookTrade)Client)Listc eZdZdeffd ZdifdededefdZde fdZ d Z d Z d Z ddifded ededeefd Zddifdeed ededeefdZde fdZddZdZde fdZxZS) tradeogrereturnc|jtt|iddddddddddddd dd dd dd dd ddddddddddddddddiiiidS)NwsT watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbolsF watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTrades watchTicker watchTickers watchBidsAsks watchBalance createOrderWs editOrderWs cancelOrderWscancelOrdersWsapizwss://tradeogre.com:8443)hasurlsoptions streaming) deep_extendsuperr describe)self __class__s L/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/tradeogre.pyr&ztradeogre.describesi ? Adt(!$  +E  e 'u u  u  !"!%#(4 7D   Nsymbollimitc"K|jd{|j|}|jdd}d|dz}dd|dd }|j|||j |||d{}|j S7t7w) a6 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://tradeogre.com/help/api :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(not used by the exchange) :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrr orderbook:r+ subscribebookidaet) load_marketsmarketr!watchextendr,) r'r+r,paramsr7url messageHashrequest orderbooks r)watch_order_bookztradeogre.watch_order_book/s!!!V$iit$'&*::   **S+t{{7F7SU`aa    "bs"BB AB6B 7B Bclientc<|j|d}|j|}||jvr|ji|j|<|j|}|j |d}|j |d}d|z}|it |j } |jddd} | | k(r |j|j|||di|j j|y||k\ry|j|||j||y)Nr5noncesr.r snapshotDelay) safe_string safe_symbol orderbooks order_book safe_integerlencache handle_optionspawnload_order_bookappend handle_deltaresolve) r'r@messagemarketIdr+storedOrderBookrB deltaNoncer< cacheLengthrDs r)handle_order_bookztradeogre.handle_order_bookFs##GS1!!(+$//)&*oob&9DOOF #//&1!!/7;&&w4 "V+ =o334K ../?RSTMm+ 4//fdTVW  ! ! ( ( 1  j  /73 4r*c|j|d|d<|j|di}|j|di}|j|di}|d}|d}|j|||j||y)NrCrBdbidsasks)rJ safe_dicthandle_bid_asks)r'r>deltadatar[r\ storedBids storedAskss r)rQztradeogre.handle_deltais"..uc: '~~eS"-~~dFB/~~dFB/v& v&  Z. Z.r*ct|j}tdt|D]J}|j ||}|j ||}|j ||g}|j|Ly)Nr)listkeysrangerKrF safe_number parse_number storeArray)r'bookSidebidAsksreipriceamountbidAsks r)r^ztradeogre.handle_bid_asksvssGLLN#q#d)$ (A$$T1-E%%gu5F''.7F    '  (r*c|d}|j|d}|j|d}||krytdt|D]%}||}|j|d}||k(s |dzcSt|S)NrrCrB)rJrfrK) r'r>deltas firstElementfirstElementNoncerBrlr_rVs r)get_cache_indexztradeogre.get_cache_indexsay  --lC@!!)W5 $ $q#f+& A1IE**5#6JU"1u   6{r*sincecK|jd{|j|}|d}|j|g|||d{S777w)a watches information on multiple trades made in a market https://tradeogre.com/help/api :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 ` Nr+)r6r7watch_trades_for_symbols)r'r+rwr,r:r7s r) watch_tradesztradeogre.watch_tradessZ!!!V$!22F8UE6RRR "Ss!AA2A A AAsymbolsc`K|jd{|j|dd}g}d}| t|}|dkDr6tdt|D]}||}d|z} |j | nd} |j | dddd } |j d d } |j | ||j| |dgd{} |jr6|j| d} |j| d }| j||}|j| ||d dS77^w)a% https://tradeogre.com/help/api get the list of most recent trades for a list of symbols :param str[] symbols: unified symbol of the market to fetch trades for(empty array means all markets) :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 ` NTrtrades:tradesr/trade*r2rrr+ timestamp) r6market_symbolsrKrfrPr!watch_multipler9 newUpdatesr]rFgetLimitfilter_by_since_limit)r'r{rwr,r: messageHashes symbolsLengthrlr+r<r=r;r~first tradeSymbols r)ryz"tradeogre.watch_trades_for_symbolssK!!!%%gtT:   LM 1 1c'l+ 2 '&0 $$[1 2 #K   -  iit$**3 t{{7TZ?[^f]ghh ??NN61-E**5(;KOOK7E))&% TRR3 "(is#D.D)B6D. D,AD.,D.c|j|d}|j|}|j|di}|d}||jvr7|j |j dd}t |}||j|<|j|} |j||} | j| d|z} |j| | |j| dy)Nr5rZr+ tradesLimitr}r~) rF safe_marketr]r~rJr"rparse_ws_traderPrR) r'r@rSrTr7r`r+r,storedrLrr<s r) handle_tradeztradeogre.handle_trades##GS1!!(+~~gsB/!$++%%%dllM4HE&F"(DKK  F###D&1 U&( uk*uh'r*c.|j|dd}|j|d}|j|d||j||j|ddd|j |d|j|d|j|dddddd |S) NrZrr5r+pq)currencycost) infor1rdatetimer+ordertypeside takerOrMakerrmrnrfee)safe_integer_productrF safe_tradeiso8601parse_ws_trade_side)r'rr7rsideEnums r)rztradeogre.parse_ws_trades--eS$? ##E3/" Y/&&vx8,,X6 %%eS1&&uc2  " # r*c2ddd}|j|||S)Nbuysell)01)rF)r'rsidess r)rztradeogre.parse_ws_trade_sides& tT22r*c|j|jd}|j|d}|j||}| |||yy)N)r0rr4)rXrrF safe_value)r'r@rSmethodseventmethods r)handle_messageztradeogre.handle_messagesT**&&   #.%0   67 # r*)N)__name__ __module__ __qualname__rr&strrrr?rrXrQr^rvr rrzryrrrr __classcell__)r(s@r)r r s # @@DB!S!!S\!.!5!5F /( <@d[]SSSSSbfglbmS"OSaenp%Sd3i%S%S[^%SuyzvA%SN(6(8<3$V$r*r )ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrr!ccxt.async_support.base.ws.clientrtypingr async_supportr r*r)rs3 7664C$"",,C$r*