":h]&ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"dd lm#Z#dd lm$Z$dd lm%Z%dd l&m'Z'Gd dejPjRZ)y)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesInt LiquidationMarket MarketTypeNumOrder OrderBook OrderRequest OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) NotSupported) ChecksumError)Precisec eZdZdeffd Zdifdedededede f d Z ifd e e fd Z difdefd Zdifd edefdZddifd edededede de f dZdifd edefdZdddifdededede efdZdddifdededede efdZdddifdedededefdZdifdededefdZifdedefdZdefdZdefdZdZdZdZ ifdede!fdZ"difd e#de$fd!Z%defd"Z&difd e#de$fd#Z'defd$Z(ddifd e#d%ede$fd&Z)d'edefd(Z*ddifdededede e+fd)Z,ddifd e ededede e+fd*Z-ifd e edefd+Z.ifdedefd,Z/defd-Z0d.ddifdededede e1fd/Z2defd0Z3dddifdededede e+fd1Z4defd2Z5ifde6fd3Z7defd4Z8dddifd e#dedede e9fd5Z:dUded e#fd6Z;d7Zdefd:Z?ddifdededede e@fd;ZAdddifd e ededede e@fd<ZBdefd=ZCdUd>ZDdefd?ZEdUdefd@ZFdefdAZGdefdBZHdCeIfdDZJdefdEZKdFZLdGeMfdHZNdVdeOfdIZPdJefdKZQdLZRidfdMZSifdNZTifdOZUdPZVdefdQZWdUdRefdSZXdVdTZYxZZS)Wgatereturnc|jtt|iddddddddddddd dd dd dd dd dddddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$ddddd%d&d'd(d)d*d+d,d*d-d.d*d/d0d1d*d0d1d*d2d3d*d4d5d6d6iiid7d8id9d:d;dd<d=d>d?ddd@dA dttt t t dBidCidDS)ENwsTcancelAllOrdersWs cancelOrderWscreateMarketBuyOrderWithCostWscreateMarketOrderWscreateMarketOrderWithCostWsFcreateMarketSellOrderWithCostWs createOrderWscreateOrdersWscreatePostOnlyOrderWscreateReduceOnlyOrderWscreateStopLimitOrderWscreateStopLossOrderWscreateStopMarketOrderWscreateStopOrderWscreateTakeProfitOrderWscreateTriggerOrderWs editOrderWs fetchOrderWs fetchOrdersWsfetchOpenOrdersWsfetchClosedOrdersWswatchOrderBook watchBidsAsks watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOHLCV watchBalance watchOrderswatchLiquidationswatchLiquidationsForSymbols)watchMyLiquidationswatchMyLiquidationsForSymbolswatchPositionszwss://ws.gate.io/v4zwss://api.gateio.ws/ws/v4/z wss://fx-ws.gateio.ws/v4/ws/usdtzwss://fx-ws.gateio.ws/v4/ws/btc)usdtbtcz)wss://fx-ws.gateio.ws/v4/ws/delivery/usdtz(wss://fx-ws.gateio.ws/v4/ws/delivery/btcz"wss://op-ws.gateio.live/v4/ws/usdtz!wss://op-ws.gateio.live/v4/ws/btc)r&spotswapfutureoptionz(wss://fx-ws-testnet.gateio.ws/v4/ws/usdtz'wss://fx-ws-testnet.gateio.ws/v4/ws/btcz*wss://op-ws-testnet.gateio.live/v4/ws/usdtz)wss://op-ws-testnet.gateio.live/v4/ws/btc)rNrOrP)apitestnametickers100ms )interval snapshotDelaysnapshotMaxRetrieschecksumrKz spot.balances)settlerM)fetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit OHLCVLimitwatchTradesSubscriptionswatchTickerSubscriptionswatchOrderBookSubscriptionsr>r<rDrJ)124611)exactbroad)hasurlsoptions exceptions) deep_extendsuperr#describerr)self __class__s G/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/gate.pyrrz gate.describesdD : <&d&#T& &1$ & &t & .u &25& &!$&(&*4&)$&(&*5&$T& *4!&"'#&$t%&&'&( )&*$T+&,&t-&.!$/&0 1&2t3&45&6t7&8(9&: ;&<d=&>?&@tA&B$UC&D.uE&F(,15"&K&R08 B@ !LI !EB$!KH !KH !MJ #B $",.,./1I !(%'*+ $ #%+! /3.2#'2''001    Al? l l NsymboltypesideamountpricecK|jd{|j|}|d}|j|}|dz} |j|} d|d<|j ||||||} |j | |d{|j | | | d{} |j| |} | S7757w)a https://www.gate.io/docs/developers/apiv4/ws/en/#order-place https://www.gate.io/docs/developers/futures/ws/en/#order-place Create an order on the exchange :param str symbol: Unified CCXT market symbol :param str type: 'limit' or 'market' *"market" is contract only* :param str side: 'buy' or 'sell' :param float amount: the amount of currency to trade :param float [price]: *ignored in "market" orders* the price at which the order is to be fulfilled at in units of the quote currency :param dict [params]: extra parameters specific to the exchange API endpoint :param float [params.stopPrice]: The price at which a trigger order is triggered at :param str [params.timeInForce]: "GTC", "IOC", or "PO" :param float [params.stopLossPrice]: The price at which a stop loss order is triggered at :param float [params.takeProfitPrice]: The price at which a take profit order is triggered at :param str [params.marginMode]: 'cross' or 'isolated' - marginMode for margin trading if not provided self.options['defaultMarginMode'] is used :param int [params.iceberg]: Amount to display for the iceberg order, Null or 0 for normal orders, Set to -1 to hide the order completely :param str [params.text]: User defined information :param str [params.account]: *spot and margin only* "spot", "margin" or "cross_margin" :param bool [params.auto_borrow]: *margin only* Used in margin or cross margin trading to allow automatic loan of insufficient amount if balance is not enough :param str [params.settle]: *contract only* Unified Currency Code for settle currency :param bool [params.reduceOnly]: *contract only* Indicates if self order is to reduce the size of a position :param bool [params.close]: *contract only* Set to close the position, with size set to 0 :param bool [params.auto_size]: *contract only* Set side to close dual-mode position, close_long closes the long side, while close_short the short one, size also needs to be set to 0 :param int [params.price_type]: *contract only* 0 latest deal price, 1 mark price, 2 index price :param float [params.cost]: *spot market buy only* the quote quantity that can be used alternative for the amount :returns dict|None: `An order structure ` Nrwz .order_placeTtextIsRequired) load_marketsmarketget_type_by_marketget_url_by_marketcreate_order_request authenticaterequest_private parse_order)rsrwrxryrzr{paramsr messageTypechannelurlrequestrawOrderorders rucreate_order_wszgate.create_order_wss<!!!V$!--f5 .$$V,#' ++FD$vV[111--c7GDD  62  " 2Ds4CB<A1CB> C#C$C>CCorderscK|jd{|j||}|d}|j|d}|ddurt|jdz|j |}|dz}|j |}|j||d{|j|||d{} |j| |S7737w)a create a list of trade orders https://www.gate.io/docs/developers/futures/ws/en/#order-batch-place :param Array orders: list of orders to create, each object should contain the parameters required by createOrder, namely symbol, type, side, amount, price and params :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` NrrwrNTz1 createOrdersWs is not supported for swap marketsz.order_batch_place) r~createOrdersRequestrridrrrr parse_orders) rsrrr firstOrderrrrr rawOrderss rucreate_orders_wszgate.create_orders_wss!!!**66:AY Z12 &> %tww)\\] ]--f5  44$$V,[111..sGWEE   F33 " 2Es4CCB C!C"C<C=CCCcrK|jd{|dn|j|}|j|dd}|j|}|dz}|j |dd|\}}|j |}|j |ddg}|jd||\}} |dk(r|j||| n|j||| \} } |j||d{|j||j| | |d{} |j| |S77D7w) a cancel all open orders https://www.gate.io/docs/developers/futures/ws/en/#cancel-all-open-orders-matched https://www.gate.io/docs/developers/apiv4/ws/en/#order-cancel-all-with-specified-currency-pair :param str symbol: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to use, defaults to spot.order_cancel_cp or futures.order_cancel_cp :returns dict[]: a list of `order structures ` Nstoptriggerz.order_cancel_cpr'rcancelAllOrdersrM)r~r safe_bool_2rhandle_option_and_paramsromithandle_market_type_and_paramsmultiOrderSpotPrepareRequestprepareRequestrrextendr) rsrwrrrrrrrxqueryr requestParamsrs rucancel_all_orders_wszgate.cancel_all_orders_wssc!!! .t{{6/B""669=--f5  2277@SU^`gh$$V,6FI#67889JFTZ[ e_cgm_m!B!B67TY!ZtxuHuHIOQUW\u][111..sDKK4WY`aa   F33 " 2as4D7D0CD7.D3/*D7D5D73D75D7rcnK|jd{|dn|j|}|j|gdd}|j|gd}|j d||\}}|dk(s|dk(r|j |||n|j |||\}} |j|} | dz} |j|} |j| | d{t||d<|j| |j|| | d{} |j| |S77R7w) a Cancels an open order https://www.gate.io/docs/developers/apiv4/ws/en/#order-cancel https://www.gate.io/docs/developers/futures/ws/en/#order-cancel :param str id: Order id :param str symbol: Unified market symbol :param dict [params]: Parameters specified by the exchange api :param bool [params.trigger]: True if the order to be cancelled is a trigger order :returns: An `order structure ` N) is_stop_orderrrF cancelOrderrMmarginz .order_cancelorder_id)r~r safe_value_nrrspotOrderPrepareRequestrrrrstrrrr)rsrrwrrrrxrrrrrrress rucancel_order_wszgate.cancel_order_wss\!!! .t{{6/B##F,PRWX6#GH88PVW eZ^bhZhlpt|l|!=!=fgu!UDHDWDWX^`dfkDl--f5 /$$V,[111!"g ((dkk'=.QSZ[[V,, " 2[s4D5D.CD5D18D5D3D51D53D5c rK|jd{|j|}|j|||||||} |j|} | dz} |j |} |j | | d{|j | | | d{} |j| |S7737w)a` edit a trade order, gate currently only supports the modification of the price or amount fields https://www.gate.io/docs/developers/apiv4/ws/en/#order-amend https://www.gate.io/docs/developers/futures/ws/en/#order-amend :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 [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 :returns dict: an `order structure ` Nz .order_amend)r~redit_order_requestrrrrr)rsrrwrxryrzr{rrextendedRequestrrrrs ru edit_order_wszgate.edit_order_wss !!!V$11"fdD&RWY_`--f5 .$$V,[111--c?GLL&11 " 2Ls4B7B1A(B7?B3B7B5B73B75B7cK|jd{|dn|j|}|j|||\}}|j|}|dz}|j |} |j | |d{|j | |j|||d{} |j| |S77C7w)a Retrieves information on an order https://www.gate.io/docs/developers/apiv4/ws/en/#order-status https://www.gate.io/docs/developers/futures/ws/en/#order-status :param str id: Order id :param str symbol: Unified market symbol, *required for spot and margin* :param dict [params]: Parameters specified by the exchange api :param bool [params.trigger]: True if the order being fetched is a trigger order :param str [params.marginMode]: 'cross' or 'isolated' - marginMode for margin trading if not provided self.options['defaultMarginMode'] is used :param str [params.type]: 'spot', 'swap', or 'future', if not provided self.options['defaultMarginMode'] is used :param str [params.settle]: 'btc' or 'usdt' - settle currency for perpetual swap and future - market settle currency is used if symbol is not None, default="usdt" for swap and "btc" for future :returns: An `order structure ` Nz .order_status) r~rfetchOrderRequestrrrrrr) rsrrwrrrrrrrrs rufetch_order_wszgate.fetch_order_wss !!! .t{{6/B!%!7!7FF!K--f5 /$$V,[111--c4;;w 3VX_``&11 " 2`s4C CA+C C*C -C.C C C sincelimitcHK|jd||||d{S7w)a fetch all unfilled currently open orders https://www.gate.io/docs/developers/futures/ws/en/#order-list :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch open orders for :param int [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns Order[]: a list of `order structures ` openNfetch_orders_by_status_wsrsrwrrrs rufetch_open_orders_wszgate.fetch_open_orders_ws1s(33FFE5RXYYYY " "cHK|jd||||d{S7w)a< fetches information on multiple closed orders made by the user https://www.gate.io/docs/developers/futures/ws/en/#order-list :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 :returns Order[]: a list of `order structures ` finishedNrrs rufetch_closed_orders_wszgate.fetch_closed_orders_ws?s(33JuV\]]]]rstatusc2K|jd{d}|5|j|}|d}|ddurt|jdz|j |||||\}}|j |dg} |j |} | dz} |j|} |j| | d{|j| |j| || d{} |j| |}|j||||S77W7.w)a  https://www.gate.io/docs/developers/futures/ws/en/#order-list fetches information on multiple orders made by the user by status :param str status: requested order status :param str symbol: unified market symbol of the market orders were made in :param int|None [since]: the earliest time in ms to fetch orders for :param int|None [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.orderId]: order id to begin at :param int [params.limit]: the maximum number of order structures to retrieve :returns dict[]: a list of `order structures ` NrwrNTzX fetchOrdersByStatusWs is only supported by swap markets. Use rest API for other marketsr]z .order_list) r~rrrprepareOrdersByStatusRequestrrrrrrrfilter_by_symbol_since_limit)rsrrwrrrrrr newRequestrrrrrs rurzgate.fetch_orders_by_status_wsMs7!!!  [[(FH%Ff~T)"477.H$HII!%!B!B66SXZ_ag!hYYw 3 --f5  -$$V,[111..sDKK M4Z\cdd ""9f500NN " 2ds4DDB$D;D<*D&D'+DDDcK|jd{|j|}|d}|d}|j|ddd\}}|j|}|dz} d|z} |j |} ||g} |d }|d rt |} | j | ||d }|j| | | | ||d{}|jS77w) a 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 Nrwrr<rYrV.order_book_update orderbook:dcontract)rwr) r~rrrrrappendsubscribe_publicr)rsrwrrrmarketIdrYrrr messageHashrpayload stringLimit subscription orderbooks ruwatch_order_bookzgate.watch_order_bookms!!!V$!$<77@PR\^ef%--f5  44'&0 $$V,X& =E * e*K NN; ' //['7TY[ghh   ) "&is"CCB)CCCCc K|jd{|j|}|d}|d}d}|j|dd|\}}|j|}|dz}d|z}d |z} |j |} ||g} |j |d d } |d rt | } | j| |j| d |g| g|g| ||d{S77w)a unWatches 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 dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrwrrVr<rYrrzunsubscribe:orderbook:rrrr) r~rrrr safe_integerrrun_subscribe_public_multiple)rsrwrrrrYrrsubMessageHashrrrrrs ruun_watch_order_bookzgate.un_watch_order_books$!!!V$!$<88AQS]_gh&--f5  44*V33f< $$V,X&!!&'37 * e*K NN; '66sK&T_S`cqbrt{~EGMNN N! " Ns"CCB?CCCCclientc|j|d}|j|d}|ji||j|<y)Nrwr) safe_stringr order_book orderbooks)rsrmessagerrwrs ruhandle_order_book_subscriptionz#gate.handle_order_book_subscriptions?!!,9!!,8"&//"e"<rvc*|j|d}|jd}|j|d}|dk(}|rdnd}|j|d}|j|d} |j|d} |j|d } |j | dd |} d | z} |j|j | |j i}|j|d }|d}|t|j}|jd dd}|r|nd}||k(rA|j| }|j|d}|j|j|| | |i|jj|y|| k\ry|| dz k\r|j||nk|j| =|j | =|jd dd}|r   5zrvctdt|D]n}||}t|tr!|j |j |9|j |d}|j |d}|j||py)Nrpr)rr isinstancelist storeArray parse_bid_ask safe_floatstore)rsbookSidebidAsksr bidAskr{rzs ruhandle_bid_askszgate.handle_bid_askssvq#g,' .AQZF&$'##D$6$6v$>?45uf- .rvc,|j|d}||d<|j||d<|j|d|d<|j|dg}|j|dg}|d}|d }|j|||j||y) Nt timestampdatetimerrbabidsasks)riso8601rr)rsrrrrr storedBids storedAskss rurzgate.handle_deltas%%eS1 !* + $ Y 7 *!..uc: 'uc2.uc2.v& v&  Z. Z.rvcK|jd{|j|}|d}d|d<|j|g|d{}|j||S7L7w)a https://www.gate.io/docs/developers/apiv4/ws/en/#tickers-channel 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 ` Nrwr>callerMethodName)r~r watch_tickersr)rsrwrrrs ru watch_tickerzgate.watch_ticker*sp!!!V$!%2!"))6(F;;vv.. "` r?methodrUN%subscribe_watch_tickers_and_bids_asksrrsr&rs rur$zgate.watch_tickers;sM??Y]YdYdfnpyez}CZDEE EE )202c*|jd||y)Ntickerhandle_ticker_and_bid_askrsrrs ru handle_tickerzgate.handle_tickerGs& &&xArvchK|j|d|jddi|d{S7w)a https://www.gate.io/docs/developers/apiv4/ws/en/#best-bid-or-ask-price https://www.gate.io/docs/developers/apiv4/ws/en/#order-book-channel 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 ` r=r( book_tickerNr)r+s ruwatch_bids_askszgate.watch_bids_asks\sM??Z^ZeZegoq~fBH[IJJ JJr,c*|jd||y)Nbidaskr/r1s ruhandle_bid_askzgate.handle_bid_askis$ &&xArvr#cK|jd{|j|d|\}}|j|dd}|j|d}|j |}|j |}d}|j ||d\}}|j|}|dz|z} |jddk\} | rdnd} g} tdt|D]} || }| j| d z|z |j|| || |d{}|jr i}|||d <|S| r |jn |j}|j!|d |d S7J7Mw) Nr#Frr(rr>r.r7:rwT)r~handle_param_stringmarket_symbolsrr market_idsrrfindrrrsubscribe_public_multiple newUpdatesrUbidsasksfilter_by_array)rsr&r#rrr marketIds channelNamerrisWatchTickersprefix messageHashesr rwtickerOrBidAskitemsrs rur*z*gate.subscribe_watch_tickers_and_bids_asks}s!!!#'#;#;FDVXh#i &%%gtU;WQZ(--f5 OOG,  ";;FDTV^_ V$$V,#k1)..}=B+ q#g,' 8AQZF  #!6 7 8 $==c=R[]dflmm ??E.E%E#A E%#E% objectNamecT|j|d}|jd}|j|d}|dk(rdnd}|j|d}g} t|tr|j |dg} n|j |di} | g} |dk(} tdt| D]} | | } |j| d } |j| dd |}|j| |}|d }| r||j|<n||j|<|d z|z}|j||y) NrrrfuturesrrMrr.rrrwr:)rrrr r safe_list safe_dictrr safe_market parse_tickerrUrAr)rsrJrrrpartsrrrresults rawTickerisTickerr rr parsedItemrwrs rur0zgate.handle_ticker_and_bid_asks9""7I6 c"((2 $1Y$>ZV (3 fd #nnWh;Gw"=I kG(*q#g,' 4A I'' 37H%%hc:FF**9f=J)F'1 V$(2 f%$s*V3K NN:{ 3 4rvcHK|j|g|||d{S7w)a get the list of most recent trades for a particular symbol :param str symbol: unified symbol of the market to fetch trades for :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 ` N)watch_trades_for_symbolsrs ru watch_tradeszgate.watch_tradess'22F8UE6RRRRrcPK|jd{|j|}|j|}|j|d}|j |}|dz}g} t dt |D]} || } | jd| z|j|} |j| | |||d{} |jr6|j| d}|j|d}| j||}|j| ||ddS7 7^w)a get the list of most recent trades for a particular symbol :param str[] symbols: unified symbol of the market to fetch trades for :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 ` Nr.tradestrades:rwrT)r~r<r=rrrrrrr?r@rrgetLimitfilter_by_since_limit)rsr&rrrrCrrrrGr rwrtradesfirst tradeSymbols rurWzgate.watch_trades_for_symbolss,!!!%%g.OOG, WQZ(--f5  ) q#g,' 5AQZF  V!3 4 5$$V,55c=)U\^dee ??OOFA.E**5(;KOOK7E))&% TRR! "fs#D&D!B.D&D$AD&$D&c K|jd{|j|}|j|}|j|d}|j |}|dz}g}g}t dt |D]/} || } |jd| z|jd| z1|j|} |j| d||||||d{S77w)aR get the list of most recent trades for a particular symbol :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 ` NrrZr[zunsubscribe:trades:r^) r~r<r=rrrrrrr) rsr&rrCrrrsubMessageHashesrGr rwrs ruun_watch_trades_for_symbolsz gate.un_watch_trades_for_symbolss!!!%%g.OOG, WQZ(--f5  ) q#g,' AAQZF  # #I$6 7  !6!? @ A$$V,66sHg}^npy|CEKLL L "Ls"C'C#CC'C%C'%C'cDK|j|g|d{S7w)aO get the list of most recent trades for a particular symbol :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)rc)rsrwrs ruun_watch_tradeszgate.un_watch_tradess#55vhGGGGs   c|j|d}t|ts|g}|j|}t dt |D]}||}|d}|j|j |}|7|j|jdd} t| }||j |<|j|d|z} |j|| y)Nrrrwr`rSr[) rr r parse_tradesrrr^rrnrrr) rsrrr parsedTradesr traderw cachedTradesrhashs ru handle_tradeszgate.handle_tradess"(3&$'XF((0 q#l+, /A OE8_F??4;;?L#))$,, tL)%0 &2 F#    &v%D NN< . /rv1mcK|jd{|j|}|d}|d}|j|j||}|j |} | dz} d|zdz|dz} |j |} ||g} |j | | | | |d{}|jr|j||}|j|||ddS779w) aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 Nrwrz .candlestickscandles:r:rT) r~rr timeframesrrrr@r\r])rsrw timeframerrrrrrYrrrrrohlcvs ru watch_ohlcvzgate.watch_ohlcvs!!!V$!$<##DOOY J--f5 / 8+c1F84DD $$V,X&++CgwPVWW ??NN651E))%q$GG "Xs"C CB C $C%8C C c`|j|d}|jd}|j|d}|dk(rdnd}|j|d}t|ts|g}i}t dt |D]&} || } |j| dd} | jd } |j| d} |j| }| d z}| j|d}|j|dd |}|j| }|j|j|i|j|<|j|j|| }|:|j|jd d }t|}||j||<|j|| ||<)t |j!}t dt |D]Y} || }||} |j| }d |zd z|z}|j|j||}|j#||[y)NrrrrMrrnrrarSror:)rrrr rrrfind_timeframereplacer parse_ohlcvohlcvsrrnrrkeysr)rsrrrrrrrrCr rrrrQrq timeframeIdrFrrwparsedstoredrr{rYrks ru handle_ohlcvzgate.handle_ohlcv/s'"""7I6}}S) ((q9 - 7Vj (3&$'XF q#f+& *A1IE++E3;L &&s+E((2I--i8K_F#++FB7H%%hc:FF%%e,F"&//$++vr"JDKK __T[[%8)DF~))$,, dK.u539 F#K0 MM& ! )If # *$INN$%q#d)$ )A!WF!&)I**95H"X-3f` N!allrrBrMrLrnrMrrOrNrPz .usertradesmyTradesr:inverseT) r~rrhandle_sub_type_and_paramsget_supported_mappingget_url_by_market_typesubscribe_privater@r\r)rsrwrrrsubTyperxrrrrr isInverserr requiresUidr^s ruwatch_my_tradeszgate.watch_my_tradescsO!!!  [[(Fd|H99/6SYZ f99/6SYZ00 8   -   3< 'K ) ))$ :*v~ --c;RXZeff ??OOFE2E00tTT; "4gs"DDB1DD 8DDc"|j|dg}t|}|dk(ry|j}|/|j|jdd}t |}||_|j |}i}tdt|D]"} || } |j| | d} d|| <$t|j} tdt| D]} | | } d| z}|j|| |j|dy) Nrrr`rSrwTz myTrades:r) rrrrrnrrgrrrr{r)rsrrr tradesLengthrjrr}rCr rirwr{rrks ruhandle_my_tradeszgate.handle_my_tradess*(B76{ 1  }}  %%dllM4HE1%8L(DM""6* q#f+& %A1IE    &8_F $If   % INN$%q#d)$ /A!WF'D NN< . / |Z0rvc ZK|jd{d}d}|jdd|\}}|jdd|\}}|dk(}|j||}|dk7}|j |dddddd}|dz}|d z} |j || d|||d{S77w) a 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 :returns dict: a `balance structure ` NrDrrMrLrnrz .balances.balance)r~rrrrr) rsrrxrrrr channelTyperrs ru watch_balancezgate.watch_balances !!!99.$PVW f99.$PVW ) ))$ :v~ 00 8   +Z' ++CdGVU`aaa# ""bs"B+B'B B+"B)#B+)B+c|j|dg}|j|d}||jd<||jd<|j||jd<t dt |D]u}||}|j }|j|dd}|j|} |j|d |d <|j|d d |d <||j| <w|j|d } | jd} |j| d} |j| dddd} | dz}|j|j|_|j|j|y)Nrtime_msinforrrcurrencyUSDT availablefreetotalbalancerrrMrNrP)rMrLrnr)rrrrrraccountrsafe_currency_code safe_string_2rr safe_balancer)rsrrrrr  rawBalancer currencyIdcoderrQrawTyperrs ruhandle_balancezgate.handle_balancessz(B7%%gy9 % V$- [!#'<< #: Z q#f+& )AJllnG))*j&IJ**:6D"..z;GGFO#11*gyQGG !(DLL  )""7I6 c"""5!,00;  "J. ((6 t||[1rvcK|jd{d}|j|}dg}|j|s|j|}d}d}|j d||\}}|dk(rd}|j |dddd} |d z} |j|s| d d j |zz } | d z} d} |jd||\} }| d k(} |j|| }|j|}|j||||jddd}|jddd}|j|j|}|r |r||j|dzd{S|j|| || |dd{}|j r|S|j#|j||||dS77U79w)a https://www.gate.io/docs/developers/futures/ws/en/#positions-subscription https://www.gate.io/docs/developers/delivery/ws/en/#positions-subscription https://www.gate.io/docs/developers/options/ws/en/#positions-channel watch all open positions :param str[] [symbols]: list of unified market symbols to watch positions for :param int [since]: the earliest time in ms to fetch positions for :param int [limit]: the maximum number of positions to retrieve :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` NrrJrMrNrLrnrOrNrP :positions::,z .positionsrr^Tr_:fetchPositionsSnapshot)r~r<is_emptyget_market_from_symbolsrrjoinrrrset_positions_cacherr positionsrOrr@filter_by_symbols_since_limit)rsr&rrrrrrxrtypeIdrrrrrrr^r_rrs ruwatch_positionszgate.watch_positions&s!!!%%g.-}}W%11':F889I6SYZ e 6>D++D3   \) }}W% 4#((7"33 3K<'889I6SXY ) ))$ :S!   w7!%!3!34DF^`d!e!%!3!34DF^`d!e5 !&<t.G'GHH H00k7GUZ\`aa ?? 11$..2FQVX]_cddE "<Ias4GGEG.G/G G 5GGGc(|ji|_||jvry|jddd}|rD|dz}||jvr0|j||j |j |||yyt |j|<y)NrJr^Fr)rrrLrOrload_positions_snapshotr)rsrrxr&r^rs rurzgate.set_positions_cacheXs >> !DN 4>> ! !%!3!34DF^`e!f !!::K6>>1 k* 477dS2$<#=DNN4 rvcK|jdd|id{}t|j|<|j|}tdt |D]1}||}|j |dd}|dkDs!|j |3|j|} | j||j||dzy7w)Nrxr contractsz :position) fetch_positionsrrrr safe_numberrrLr) rsrrrxrrr positionrrOs rurzgate.load_positions_snapshotfs..tfd^DD 79tt$q#i.) 'A |H((;BI1} X&  '  ,uud[01EsCCAC;A Cc&|j|j}|j|dg}|j|}g}t dt |D]}||}|j |} |j| d} |j| d} | |j|| dz} | *| d| d<|j| |j| |j|| dz} | *| d| d<|j| |j| | | d| d<|j| |j| |j| |j| |j||dz}t dt |D]f}||}|jd}|d }|jd }|j|d|d }|j|rU|j||h|j||d zy) Nrrrwrylongshortz :positions::rrrFr)get_market_type_by_urlrrrrrparse_positionrrNrfind_message_hashesrrBrr)rsrrrxdatar newPositionsr  rawPositionrrwryprevLongPositionprevShortPositionrGrrQ symbolsStringr&rs ruhandle_positionszgate.handle_positionsts>**6::6w"5t$ q#d)$ 'Aq'K**;7H%%h9F##Hf5D|#'>>%&#I #/'7'?HV$ ''1LL*$(NN5&7:J$K!$0'8'@HV$ ''1LL*#+0A0I'-HV$ ''1LL*##H- X&1 '2009NO q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |TL%89rvc K|jd{d}||j|}|d}d}d}|jd||\}}|j|dddddd}|dz} d } d g} || d |d zz } |d g} d} |j d||\} }| d k(} |j || }|dk7}|j || | | ||d{}|jr|j||}|j|||ddS779w)a watches information on multiple orders made by the user :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 str [params.type]: spot, margin, swap, future, or option. Required if listening to all symbols. :param boolean [params.isInverse]: if future, listen to inverse or linear contracts :returns dict[]: a list of `order structures ` NrwrErMrLrnrz.ordersrrr:rrrT) r~rrrrrrr@r\r])rsrwrrrrrxrrrrrrrrrrs ru watch_orderszgate.watch_orderss`!!!  [[(FH%F88PVW e++D 3  9$ -   3- -Kd|nG88PUV ) ))$ :v~ --c;RWYdee ??OOFE2E))&% TRR= "6fs"D D B:D D 8D  D c2|j|dg}|j|jdd}|jt ||_|j}i}|j |}t dt|D]}||} |j| d} |j| d} | dk(s| dk(rd | d <n7| d k(r2|j| d } | |j| d } | dk(rd nd| d <|j| | d}|j|}d||d<t|j}t dt|D]&}d||z}|j|j|(|j|jdy)Nr ordersLimitrSrreventputupdaterrfinishleftclosedcanceledrwTrzorders:r)rrrnrrrrrrrrrr{r)rsrrrrr~rC parsedOrdersr r}rrrrrwrr{rs ru handle_orderzgate.handle_ordersH(B7!!$,, tD ;; 07DK ((0 q#l+, +A!!_F??662D$$T73E~(!2#)x ("))&(;>,,T6:D48AIxJF8$ MM& !H%F[[(F&*IfTl # + INN$%q#d)$ 5A#d1g-K NN4;; 4 5 t{{H-rvc4K|j|g|||Sw)a watch the public liquidations of a trading pair https://www.gate.io/docs/developers/futures/ws/en/#liquidates-api https://www.gate.io/docs/developers/delivery/ws/en/#liquidates-api https://www.gate.io/docs/developers/options/ws/en/#liquidates-channel :param str symbol: unified CCXT market symbol :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :returns dict: an array of `liquidation structures ` )!watch_my_liquidations_for_symbolsrs ruwatch_my_liquidationszgate.watch_my_liquidations's!55vhufUUscK|jd{|j|ddd}|j|}d}d}|jd||\}}|j |dddd}d} |j d||\} }| dk(} |j || } g} d} |j|r3|dk7r| st|jd zd } | jd nDt|}|d k7rt|jd zd|dz} | j|d|dz}|j| | | ||dd{}|jr|S|j|j|||dS7e74w)a watch the private liquidations of a trading pair https://www.gate.io/docs/developers/futures/ws/en/#liquidates-api https://www.gate.io/docs/developers/delivery/ws/en/#liquidates-api https://www.gate.io/docs/developers/options/ws/en/#liquidates-channel :param str[] symbols: unified CCXT market symbols :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the gate api endpoint :returns dict: an array of `liquidation structures ` NTrIrLrnrrrvz watchMyLiquidationsForSymbols() does not support listening to all symbols, you must call watchMyLiquidations() instead for each symbol you wish to watch.myLiquidationsznot allrz watchMyLiquidationsForSymbols() only allows one symbol at a time. To listen to several symbols call watchMyLiquidationsForSymbols() several times.myLiquidations::rrz .liquidates)r~r<rrrrrrrrrrrr@r liquidations)rsr&rrrrrxrrrrrrr symbolsLengthrnewLiquidationss rurz&gate.watch_my_liquidations_for_symbols7s!!!%%gtT4@--g6889XZ`bhi e++D3   889XZ`bgh ) ))$ : == !"9 ,H"HII*K NN9 %LM! ,A"ABB,wqz9K NN6$< (=( $ 6 6sKRY[`bf gg ??" "11$2C2CWeUZ\`aaA ":hs"FE;D2F E> 2F>Fc|j|dg}g}tdt|D]}||}|j|}|j |d}|j |j |} | (|j|jdd} t| } | j|| |j |<|j| d|z|j|dy)NrrrwliquidationsLimitrSrr) rMrrparse_ws_liquidationrrrrrnrrr) rsrrrawLiquidationsrr rawLiquidation liquidationrwrrs ruhandle_liquidationzgate.handle_liquidationgsX..(B?q#o./ FA,Q/N33NCK%%k8rrMrrr)rsrrrrrrrr errorMessageer parsedChannelrr rrwmessageHashSymbols ruhandle_error_messagezgate.handle_error_messagesqh~~gv.~~dF+w6!!%9   )J K  **6+?+?DK H44T__T5J75SUY[_[d[del[mn44T__W5MtUYU^U^_cUde#//y$BRBRSWYbBcd 44T__T5J75SUacgclclmtcuv#DIIg$677&% H a-++AUAU2U,,[9**7I>'gll3.?!.C$+MM#$6M"nnWiDG"1c'l3H%21%5%? !%!1!1'!*dC!T,9!,CE IB?H;H;'H;;Ici|_yN)r)rsrrrs ruhandle_balance_subscriptionz gate.handle_balance_subscription&s  rvcb|j|d}|j|j|jd}|j|d}||vrG|j|j|}|j |j|}||}||||||jvr|j|=yy)Nr)rzspot.order_book_updatezfutures.order_book_updater)rrrrr) rsrrrmethodsrsubscriptionHashrr(s ruhandle_subscription_statuszgate.handle_subscription_status)s""7I677&*&I&I)-)L)L    gt , g #//0D0DbI ??6+?+?AQRLW%F 67L 1 %% %$$R( &rvc|j|d}t|jj}t dt |D]}||}||jvr|j ds)|j|}|j|d}||k7rP|j|dg} |j|dg} t dt | D]} | | } | | } |j|| | !|j|y)Nrr unsubscriberGrb) rrrr{rr startswithrMclean_unsubscription clean_cache)rsrrrr{r rrsubIdrGrbj unsubHashsubHashs ruhandle_un_subscribezgate.handle_un_subscribe9s&  gt ,F((--/0q#d)$ /Aq'K6#7#77%%m4%33K@ ((t<; $|_b Q #'>>,@RTV#W q#m"45JA -a 0I.q1G--fgyIJ  .! /rvrc|j|dd}|j|dg}t|}|dk(rg|j|dg}tdt|D];}||}|j|d}|j|d} |j|| ==y|dkDretdt|D]L}||}|j dr|j |='|d k(r|j|=:|d k(s@|j|=Ny|j drNt|j j} tdt| D]}|j | |=yy) Ntopicrvr&rrsymbolsAndTimeframesrrr^rr.) rrMrrrzendswithr^rrUrr{) rsrrr&rsymbolsAndTimeFramesr symbolAndTimeFramerwrqr{s rur zgate.clean_cache`so  w;..y"=G G #'>>,@VXZ#[ 1c"678 3%9!%<"))*>(+ F+k)/h& V, -~~h'DKK,,./q#d),-A DG,- (rvc *|j||ry|j|d}|dk(r|j||y|dk(r|j||y|j|dd}|j d}|j |d}|j |j|j|j|j|j|j|j|j|jd }|j ||}| ||||j|d } | d k(r|j!||y| N|j#|d } |j | d } |j%|d } | dur|j'| | yyy)Nr subscriberrrvrr) usertrades candlesticksrrrUr4r^order_book_updatebalances liquidatesr authenticatedrrackT)rrrrrrrrrrr2r8rlrrrhandle_authentication_messagerN safe_boolr) rsrrrrrr v4Methodsr(rrrrs ruhandle_messagezgate.handle_message|st  $ $VW 5   '2 K   + +FG <  M !  $ $VW 5 ""7Ir:}}S) oolA6 // --''..))..((!%!7!7++11  K8   67 #$$Wl;  '  . .vw ?   >>'62D__T84F..%0C$vy1 !rvcX|jd|d}|dr|dr|dS|dS|S)NrQrxrlinearrKrLrm)rsrbaseUrls rurzgate.get_url_by_markets@))E"6&>2 * &,X&676? JGEN JNrvrc|dry|dryy)NrMrPrnrL)rsrs rurzgate.get_type_by_markets &> H rvcZ|jd}||}|dk(s|dk(r |r|dS|dS|S)NrQrNrOrLrKr%)rsrxrrQrs rurzgate.get_url_by_market_type sAii$i FN 0!*3u: ;F ;Jrvrcdddd}t|j}tdt|D]$}||}||}|j |dk\s"|cSy)NrPrOrN)zop-deliveryfxrrM)rr{rrr>)rsrfindByr{r keyvalues rurzgate.get_market_type_by_urlsj   FKKM"q#d)$ Aq'C3KExx}!   rvc~|j|j|jddd}||jd<|S)Nreqidrr)sumrrn)rsr1s rurzgate.request_id"s8**4<<!DaH % W rvc2K|j}|j}|||d|d} |9|j|} || jvrt |} || j| <|j | |} |j ||| ||d{S7wNrrtimerrr)rsecondsrrrrwatch) rsrrrrrrrr6rrtempSubscriptionHashrs rurzgate.subscribe_public(sOO% ||~     #[[%F6#7#77'*9~$=H$$%9:++gv.ZZ['; UUUUsBBBBcK|j}|j}|||d|d}|j||} |j||| |d{S7wr4)rr7rwatch_multiple) rsrrGrrrrr6rrs rur?zgate.subscribe_public_multiple:sbOO% ||~   ++gv.((mWmTTTTsAAAAc K|j} |j} | | |d|d} t| |d|||d} |j| |} |j ||| || d{S7w)Nrr5T)rrrrGrbr&)rr7rrr;)rsrrr&rGrbrrrrr6rsubrs rurz!gate.un_subscribe_public_multipleGsOO% ||~"  i.* 0  ++gv.((mWmUXYYYYsA%A.'A,(A.cK|dz}|j|}d}|j|}|j|j|}||j |i||d{S|S7w)Nz.loginr)rrOrrr)rsrrrrrrOrs rurzgate.authenticate\sr(S!% {+(<( 9DF !5 6++gv.ZZ['; TTTTsFF FF r)F)[__name__ __module__ __qualname__rrrrrrfloatr rrrrrrrrrr rrrrrrrrrrr rrrr%rrr$r2r5r8r*r0rrXrWrcrerlrrsrrrrrrrrrrrrrr rrrrrrrrdictr r"rr rr rrrrr?rrrrr __classcell__)rts@rur#r#s=m #m ^pt|~)C)y) )[`)il)VIK4T,-?4.8D_cln ^3 ^c ^Y\ ^swx}s~ ^JN\`os|~OcO3OVYOilO@@DB!S!!S\!<=?NN3N2=V= [5[5z . /68//F/"6:" E7 E EBFB*8& > > 2E:N04$UYbd)S)SC)Ss)Simnsit)SV?.6?.BEIW[dfV#VcVQTVkop{k|V LP^bquA.btCy.bX[.bkn.bFJKVFW.b`9:9:v- ^S6Sj&)) %/&%/N--82V2B: #  QSaeV$\^ UACZ*F SS@$Urvr#)*ccxt.async_supportrG ccxt.async_support.base.ws.cacherrrrrMccxt.base.typesrrr r r r r rrrrrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrr ccxt.base.preciser! async_supportr#r(rvrurjsn AA{{{{{4*0.')*%ZU4   " "ZUrv