ei+iddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddl m!Z!ddl m"Z"ddl m#Z#dd l m$Z$dd l m%Z%dd l m&Z&dd l'm(Z(Gd dej)j*Z*dS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesBoolInt 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 efdZdddifdedededede ef dZdifdededefdZifdedefdZdefdZdefdZdZdZdZ 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.ddifded/ededede e1f d0Z2defd1Z3dddifdededede e+fd2Z4defd3Z5ifde6fd4Z7defd5Z8dddifd e#dedede e9fd6Z:dUded e#fd7Z;d8Zdefd;Z?ddifdededede e@fd<ZAddifd e ededede e@fd=ZBdefd>ZCdUd?ZDdedeEfd@ZFdUdefdAZGdefdBZHdefdCZIdefdDZJdEZKdFeLfdGZMdVdeNfdIZOdJefdKZPdLZQidfdMZRifdNZSifdOZTdPZUdefdQZVdUdRefdSZWdVdTZXxZYS)Wgatereturncl|tt|iddddddddddddd dd dd dd dd dddddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$did%dd&dd'dd(dd)dd*dd+dd,dd-dd.dd/dd0dd1dd2dd3dd4dd5d6d7d8d9d:d;d9dd?d@d9d?d@d9dAdBd9dCdDdEdEiiidFdGidHdIdJddKdLdMdNdddOdP dttt t t dQidRidSS)TNwsTcancelAllOrdersWs cancelOrderWscreateMarketBuyOrderWithCostWscreateMarketOrderWscreateMarketOrderWithCostWsFcreateMarketSellOrderWithCostWs createOrderWscreateOrdersWscreatePostOnlyOrderWscreateReduceOnlyOrderWscreateStopLimitOrderWscreateStopLossOrderWscreateStopMarketOrderWscreateStopOrderWscreateTakeProfitOrderWscreateTriggerOrderWs editOrderWs fetchOrderWs fetchOrdersWsfetchOpenOrdersWsfetchClosedOrdersWswatchOrderBook watchBidsAsks watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOHLCV watchBalance watchOrderswatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbolswatchPositions unWatchTickerunWatchTickers unWatchOHLCVunWatchOHLCVForSymbolsunWatchOrderBookunWatchOrderBookForSymbols unWatchTradesunWatchTradesForSymbolsunWatchMyTrades unWatchOrdersunWatchPositionsunWatchMarkPricesunWatchMarkPricezwss://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)r\r]r^)apitestnametickers100ms )interval snapshotDelaysnapshotMaxRetrieschecksumrYz spot.balances)settler[)fetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit OHLCVLimitwatchTradesSubscriptionswatchTickerSubscriptionswatchOrderBookSubscriptionsr?r=rErK)124611)exactbroad)hasurlsoptions exceptions) deep_extendsuperr$describerr)self __class__s K/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/gate.pyrz gate.describesdD 1 1 : : < <3d3#T3 31$ 3 &t 3 .u 3253 3!$3(3*43)$3(3*53$T3 *4!3"'#33$t%3&'3( )3*$T+3,&t-3.!$/30 132t334536t738(93: ;3<d=3>?3@tA3B$UC3D.uE333F&tG3H0I3J!$K3L M3N!%O3PQ3R)%S3T#DU3V-eW3X Y3Z*4[3\"5]3^ _3`#Ea3b$Uc3d#Ee33l08 B@ !LI !EB$!KH !KH !MJ  #B $",.,./1I !(%'*+ $ ##%+!! /3.2##'2''001     [y? y? y y y NsymboltypesideamountpricecK|d{V||}|d}||}|dz} ||} d|d<|||||||} || |d{V|| | | d{V} || |} | S)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 ` Nrz .order_placeTtextIsRequired) load_marketsmarketget_type_by_marketget_url_by_marketcreate_order_request authenticaterequest_private parse_order)rrrrrrparamsr messageTypechannelurlrequestrawOrderorders rcreate_order_wszgate.create_order_wss <!!!!!!!!!V$$!--f55 .$$V,,#' ++FD$vVV[111111111--c7GDDDDDDDD  622 rorderscK|d{V|||}|d}||d}|ddurt|jdz||}|dz}||}|||d{V||||d{V} | | |S)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 ` Nrrr\Tz1 createOrdersWs is not supported for swap marketsz.order_batch_place) rcreateOrdersRequestrr idrrrr parse_orders) rrrr firstOrderrrrr rawOrderss rcreate_orders_wszgate.create_orders_wss!!!!!!!!!**66::AY Z122 &> % %tw)\\]] ]--f55  44$$V,,[111111111..sGWEEEEEEEE   F333rcK|d{V|dn||}||dd}||}|dz}||dd|\}}||}||ddg}|d||\}} |dkr|||| n| ||| \} } | ||d{V| || | | |d{V} | | |S) a cancel all open orders https://www.gate.com/docs/developers/futures/ws/en/#cancel-matched-open-orders 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(rcancelAllOrdersr[)rr safe_bool_2rhandle_option_and_paramsromithandle_market_type_and_paramsmultiOrderSpotPrepareRequestprepareRequestrrextendr) rrrrrrrrrqueryr requestParamsrs rcancel_all_orders_wszgate.cancel_all_orders_wss!!!!!!!!! .t{{6/B/B""669==--f55  2277@SU^`ghh$$V,,6FI#677889JFTZ[[ e_cgm_m_m!B!B67TY!Z!Z!ZtxuHuHIOQUW\u]u][111111111..sDKK4W4WY`aaaaaaaa   F333rrcK|d{V|dn||}||gdd}||gd}|d||\}}|dks|dkr||||n||||\}} ||} | dz} ||} | | | d{Vt||d<| | | || | d{V} | | |S) 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 cancelOrderr[marginz .order_cancelorder_id)rr safe_value_nrrspotOrderPrepareRequestrrrrstrrrr)rrrrrrrrrrrrrress rcancel_order_wszgate.cancel_order_wss!!!!!!!!! .t{{6/B/B##F,P,P,PRWXX6#G#G#GHH88PVWW eZ^bhZhZhlpt|l|l|!=!=fgu!U!U!UDHDWDWX^`dfkDlDl--f55 /$$V,,[111111111!"gg ((dkk'=.Q.QSZ[[[[[[[[V,,,rc K|d{V||}||||||||} ||} | dz} ||} || | d{V|| | | d{V} || |S)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)rredit_order_requestrrrrr)rrrrrrrrrextendedRequestrrrrs r edit_order_wszgate.edit_order_ws s !!!!!!!!!V$$11"fdD&RWY_``--f55 .$$V,,[111111111--c?GLLLLLLLL&111rcK|d{V|dn||}||||\}}||}|dz}||} || |d{V|| ||||d{V} || |S)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) rrfetchOrderRequestrrrrrr) rrrrrrrrrrrs rfetch_order_wszgate.fetch_order_ws%s !!!!!!!!! .t{{6/B/B!%!7!7FF!K!K--f55 /$$V,,[111111111--c4;;w 3V3VX_````````&111rsincelimitcDK|d||||d{VS)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_wsrrrrrs rfetch_open_orders_wszgate.fetch_open_orders_ws?s733FFE5RXYYYYYYYYYrcDK|d||||d{VS)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 rfetch_closed_orders_wszgate.fetch_closed_orders_wsMs733JuV\]]]]]]]]]rstatuscxK|d{Vd}|>||}|d}|ddurt|jdz||||||\}}||dg} ||} | dz} ||} || | d{V| | | | || d{V} | | |}| ||||S)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 ` Nrr\TzX fetchOrdersByStatusWs is only supported by swap markets. Use rest API for other marketsrkz .order_list) rrr rprepareOrdersByStatusRequestrrrrrrrfilter_by_symbol_since_limit)rrrrrrrrr newRequestrrrrrs rrzgate.fetch_orders_by_status_ws[s}!!!!!!!!!  [[((FH%Ff~T))"47.H$HIII!%!B!B66SXZ_ag!h!hYYw 33 --f55  -$$V,,[111111111..sDKK M4Z4Z\cdddddddd ""9f5500NNNrc K|d{V||}|d}|d}||ddd\}}||}|dz} d|z} ||} ||g} | d }|d krd }|d r$t |} | | ||d }|| | | | ||d{V}|S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.gate.com/docs/developers/apiv4/ws/en/#order-book-channel https://www.gate.com/docs/developers/apiv4/ws/en/#order-book-v2-api https://www.gate.com/docs/developers/futures/ws/en/#order-book-api https://www.gate.com/docs/developers/futures/ws/en/#order-book-v2-api https://www.gate.com/docs/developers/delivery/ws/en/#order-book-api https://www.gate.com/docs/developers/options/ws/en/#order-book-channel :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 Nrrr=rgrd.order_book_update orderbook:dr|2contract)rr) rrrrrrappendsubscribe_publicr)rrrrrmarketIdrgrrr messageHashrpayload stringLimit subscription orderbooks rwatch_order_bookzgate.watch_order_book{sN !!!!!!!!!V$$!$<77@PR\^eff%--f55  44'&0 $$V,,X& =Ei'' *  (e**K NN; ' ' '  //['7TY[ghhhhhhhh    rc K|d{V||}|d}|d}d}||dd|\}}||}|dz}d|z}d |z} ||} ||g} ||d d } |d r$t | } | | || d |g| g|g| ||d{VS)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 Nrrrdr=rgrrzunsubscribe:orderbook:rrrr) rrrrr safe_integerrrun_subscribe_public_multiple)rrrrrrgrrsubMessageHashrrrrrs run_watch_order_bookzgate.un_watch_order_booksj!!!!!!!!!V$$!$<88AQS]_ghh&--f55  44*V33f< $$V,,X&!!&'377 *  (e**K NN; ' ' '66sK&T_S`cqbrt{~EGMNNNNNNNN Nrclientc||d}||d}|i||j|<dS)Nrr) safe_stringr order_book orderbooks)rrmessagerrrs rhandle_order_book_subscriptionz#gate.handle_order_book_subscriptionsL!!,99!!,88"&//"e"<"<rc||d}|d}||d}|dk}|rdnd}||d}||d} ||d} ||d } || dd |} d | z} ||j| |i}||d }|d}|t|j}| d dd}|r|nd}||krB|j | }||d}| |j || | |i|j |dS|| krdS|| dz kr|||nl|j | =|j| =| d dd}|rCt|jdz|| z}||| ||| dS)Nr.rr[rresultUus_rnoncer=rhrerrjT )rsplit safe_valuer safe_symbolrrlencache handle_option subscriptionsspawnload_order_bookr handle_deltar!rorderbook_checksum_messagerejectresolve)rrrr channelParts rawMarketTypeisSpot marketTypedelta deltaStartdeltaEndrrrstoredOrderBookr cacheLengthrh waitAmountrrrjerrors rhandle_order_bookzgate.handle_order_booksxl""7I66}}S)) ((q99 &(%5VV: 22&&uc22 $$UC00##E3//!!(D#zBB"V+ //$/64??SUCVCVWW!!/7;; =K*!/"788  ../?RTUUM*07aJj((%3K@ )),@@ 4/feUWXXX  ! ( ( / / / F h   F j1n $ $   ou 5 5 5 5$[1'))*:JMMH 2%dgmd6U6UV\6]6]&]^^ e[111 44444rcf||d}|d}||d}||krdStdt|D]I}||}||d}||d} ||dz kr || kr|cSJt|S)Nrrrrr)rranger) r orderBookrr firstDeltafirstDeltaStartir r r s rget_cache_indexzgate.get_cache_indexs!!)W551X ++J<< ? " "2q#e**%%  A!HE**5#66J((44Ha''eh.>.>5zzrcVtdt|D]}||}t|tr)|||H||d}||d}|||dS)Nrpr)rr isinstancelist storeArray parse_bid_ask safe_floatstore)rbookSidebidAsksrbidAskrrs rhandle_bid_askszgate.handle_bid_asks,sq#g,,'' . .AQZF&$'' .##D$6$6v$>$>????4455uf---- . .rcr||d}||d<|||d<||d|d<||dg}||dg}|d}|d }||||||dS) Nt timestampdatetimerrbabidsasks)riso8601rr$)rrr r'r+r, storedBids storedAskss rrzgate.handle_delta6s%%eS11 !* + $ Y 7 7 *!..uc:: 'uc2..uc2..v& v&  Z... Z.....rcK|d{V||}|d}d|d<||g|d{V}|||S)aj https://www.gate.io/docs/developers/apiv4/ws/en/#tickers-channel https://www.gate.com/docs/developers/futures/ws/en/#tickers-api https://www.gate.com/docs/developers/delivery/ws/en/#tickers-api 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 ` Nrr?callerMethodName)rr watch_tickersr)rrrrrs r watch_tickerzgate.watch_tickerBs!!!!!!!!!V$$!%2!"))6(F;;;;;;;;vv...rsymbolsclK||d|ddi|d{VS)az https://www.gate.io/docs/developers/apiv4/ws/en/#tickers-channel https://www.gate.com/docs/developers/futures/ws/en/#tickers-api https://www.gate.com/docs/developers/delivery/ws/en/#tickers-api 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 ` r@methodrcN%subscribe_watch_tickers_and_bids_asksrrr4rs rr2zgate.watch_tickersUsr??Y]YdYdfnpyez}CZDZDEEEEEEEE Erc4|d||dS)Ntickerhandle_ticker_and_bid_askrrrs r handle_tickerzgate.handle_tickercs"& &&xAAAAArclK||d|ddi|d{VS)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 https://www.gate.com/docs/developers/options/ws/en/#best-bid-or-ask-price 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>r6 book_tickerNr7r9s rwatch_bids_askszgate.watch_bids_asksxsr??Z^ZeZegoq~fBH[I[IJJJJJJJJ Jrc4|d||dS)Nbidaskr<r>s rhandle_bid_askzgate.handle_bid_asks"$ &&xAAAAArr1cK|d{V||d|\}}||dd}||d}||}||}d}|||d\}}||}|dz|z} |ddk} | rdnd} g} tdt|D]%} || }| | d z|z&| || || |d{V}|j ri}|||d <|S| r|jn|j}||d |d S) Nr1Frr6rr?r;rD:rT)rhandle_param_stringmarket_symbolsrr market_idsrrfindrrrsubscribe_public_multiple newUpdatesrcbidsasksfilter_by_array)rr4r1rrr marketIds channelNamerrisWatchTickersprefix messageHashesrrtickerOrBidAskitemsrs rr8z*gate.subscribe_watch_tickers_and_bids_askss!!!!!!!!!#'#;#;FDVXh#i#i &%%gtU;;WQZ((--f55 OOG,,  ";;FDTV^__ V$$V,,#k1)..}==B+9 q#g,,'' 8 8AQZF  #!6 7 7 7 7#==c=R[]dflmmmmmmmm ? E.$>ZZV (33 fd # # "nnWh;;GGw"==I kG(*q#g,,'' 4 4A I'' 377H%%hc:FFF**9f==J)F 3'1 V$$(2 f%$s*V3K NN:{ 3 3 3 3 4 4rcDK||g|||d{VS)a https://www.gate.com/docs/developers/apiv4/ws/en/#public-trades-channel https://www.gate.com/docs/developers/futures/ws/en/#trades-api https://www.gate.com/docs/developers/delivery/ws/en/#trades-api https://www.gate.com/docs/developers/options/ws/en/#public-contract-trades-channel 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 r watch_tradeszgate.watch_tradess622F8UE6RRRRRRRRRrcK|d{V||}||}||d}||}|dz}g} t dt |D]"} || } | d| z#||} | | | |||d{V} |j rB| | d}| |d}| ||}|| ||ddS)a https://www.gate.com/docs/developers/apiv4/ws/en/#public-trades-channel https://www.gate.com/docs/developers/futures/ws/en/#trades-api https://www.gate.com/docs/developers/delivery/ws/en/#trades-api https://www.gate.com/docs/developers/options/ws/en/#public-contract-trades-channel 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:rr'T)rrIrJrrrrrrrLrMrrgetLimitfilter_by_since_limit)rr4rrrrPrrrrTrrrtradesfirst tradeSymbols rrdzgate.watch_trades_for_symbolssn!!!!!!!!!%%g..OOG,, WQZ((--f55  ) q#g,,'' 5 5AQZF  V!3 4 4 4 4$$V,,55c=)U\^deeeeeeee ? 8OOFA..E**5(;;KOOK77E))&% TRRRrc K|d{V||}||}||d}||}|dz}g}g}t dt |D]:} || } |d| z|d| z;||} | | d||||||d{VS)aP 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 ` Nrrgrhzunsubscribe:trades:rk) rrIrJrrrrrrr) rr4rrPrrrsubMessageHashesrTrrrs run_watch_trades_for_symbolsz gate.un_watch_trades_for_symbolss[!!!!!!!!!%%g..OOG,, WQZ((--f55  ) q#g,,'' A AAQZF  # #I$6 7 7 7  !6!? @ @ @ @$$V,,66sHg}^npy|CEKLLLLLLLL Lrc@K||g|d{VS)aM 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)rp)rrrs run_watch_tradeszgate.un_watch_tradess255vhGGGGGGGGGrc||d}t|ts|g}||}t dt |D]}||}|d}||j|}|5||jdd} t| }||j|<| |d|z} | || dS)Nrrrrnrarh) rrr parse_tradesrrrkrr|rrr) rrrr parsedTradesrtrader cachedTradesrhashs r handle_tradeszgate.handle_tradess"(33&$'' XF((00 q#l++,, / /A OE8_F??4;??L#))$, tLL)%00 &2 F#    & & &v%D NN< . . . . / /r1m timeframecK|d{V||}|d}|d}||j||}||} | dz} d|zdz|dz} ||} ||g} || | | | |d{V}|jr|||}| |||ddS) a= https://www.gate.com/docs/developers/apiv4/ws/en/#candlesticks-channel https://www.gate.com/docs/developers/futures/ws/en/#candlesticks-api https://www.gate.com/docs/developers/delivery/ws/en/#candlesticks-api 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 Nrrz .candlestickscandles:rGrT) rrr timeframesrrrrMrirj)rrr{rrrrrrgrrrrrohlcvs r watch_ohlcvzgate.watch_ohlcv?s#!!!!!!!!!V$$!$<##DOY JJ--f55 / 8+c1F84DD $$V,,X&++CgwPVWWWWWWWW ? 2NN6511E))%q$GGGrc||d}|d}||d}|dkrdnd}||d}t|ts|g}i}t dt |D]F} || } || dd} | d } || d} || }|d z}| |d}| |dd |}| | }||j |i|j |<||j ||}|;| |j d d }t|}||j ||<|||||<Ht |}t dt |D]i} || }||}||}d |zd z|z}||j ||}|||jdS)Nrrrr[rrnrrorar}rG)rrrrrrrfind_timeframereplacer parse_ohlcvohlcvsrr|rrkeysr)rrrrrrrrrPrrrr^ timeframeIdr{rSrrparsedstoredrrrgrxs r handle_ohlcvzgate.handle_ohlcv^s"""7I66}}S)) ((q99 - 7 7VVj (33&$'' XF q#f++&& * *A1IE++E3;;L &&s++E**5!44K++K88I_F#++FB77H%%hc:FFF%%e,,F"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! ! )If  INN$$%%q#d))$$ ) )A!WF!&)I**955H"X-3f` N!allrrCr[rYr|r[rr]r\r^z .usertradesmyTradesrGinverseT) rrrhandle_sub_type_and_paramsget_supported_mappingget_url_by_market_typesubscribe_privaterMrir)rrrrrsubTyperrrrrr isInverserr requiresUidrks rwatch_my_tradeszgate.watch_my_tradess!!!!!!!!!  [[((Fd|H99/6SYZZ f99/6SYZZ00 8 8    -   3< 'K ) ))$ ::*v~ --c;RXZeffffffff ? 3OOFE22E00tTTTrc||dg}t|}|dkrdS|j}|2||jdd}t |}||_||}i}tdt|D],} || } || | d} d|| <-t| } tdt| D]%} | | } d| z}| ||&| |ddS) NrrrnrarTz myTrades:r) rrrrr|rrtrrrrr)rrrr tradesLengthrwrrrPrrvrrrrxs rhandle_my_tradeszgate.handle_my_tradessR*(B776{{ 1   F}  %%dlM4HHE1%88L(DM""6** q#f++&& % %A1IE    & & &8_F $If  INN$$%%q#d))$$ / /A!WF'D NN< . . . .|Z00000rc zK|d{Vd}d}|dd|\}}|dd|\}}|dk}|||}|dk}||dddddd}|dz}|d z} ||| d|||d{VS) aL watch balance and get the amount of funds available for trading or funds locked in orders https://www.gate.com/docs/developers/apiv4/ws/en/#spot-balance-channel https://www.gate.com/docs/developers/futures/ws/en/#balances-api https://www.gate.com/docs/developers/delivery/ws/en/#balances-api https://www.gate.com/docs/developers/options/ws/en/#balances-channel :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` NrErr[rYr|rz .balances.balance)rrrrrr) rrrrrrr channelTyperrs r watch_balancezgate.watch_balances !!!!!!!!!99.$PVWW f99.$PVWW ) ))$ ::v~ 00 8 8    +Z' ++CdGVU`aaaaaaaaarct||dg}||jd<tdt|D]}||}|}||dd}||}||dd} | |jd<|| |jd <||d |d <||d |d <| |dd|d<||j|<||d} | d} || d} | | dddd} | dz}| |j|_| |j|dS)NrinforcurrencyUSDTtime_ms timestamp_msr'r(freezeused availablefreetotalbalancerrr[r\r^)r[rYr|r)rrrraccountrsafe_currency_codesafe_integer_2r- safe_string_2rr safe_balancer)rrrrr rawBalancer currencyIdcoder'rr^rawTyperrs rhandle_balancezgate.handle_balance sB(B77% Vq#f++&& ) )AJllnnG))*j&IIJ**:66D++J >RRI(1DL %'+||I'>'>DL $"..z8DDGFO"..z;GGGFO#11*gyQQGG !(DL  ""7I66 c""""5!,,00; ;   "J. ((66 t|[11111rcK|d{Vd}||}dg}||s||}d}d}|d||\}}|dkrd}||dddd} |d z} ||s| d d |zz } | d z} d} |d||\} }| d k} ||| }| |}| |||| ddd}| ddd}| |j |}|r"|r |||dzd{VS||| || |dd{V}|jr|S||j ||||dS)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 ` NrrKr[r\rYr|r]r\r^ :positions::,z .positionsrrlTrm:fetchPositionsSnapshot)rrIis_emptyget_market_from_symbolsrrjoinrrrset_positions_cacherr positionsr]rrMfilter_by_symbols_since_limit)rr4rrrrrrrtypeIdrrrrrrrlrmrrs rwatch_positionszgate.watch_positionsgsr!!!!!!!!!%%g..-}}W%% ;11'::F889I6SYZZ e 6>>D++D3 3    \) }}W%% 4 4#((7"3"33 3K<'889I6SXYY ) ))$ ::S!!   w777!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e55 ! I&< It.G'GHHHHHHHH H00k7GUZ\`aaaaaaaa ?  11$.2FQVX]_cdddrc|ji|_||jvrdS|ddd}|rD|dz}||jvr4||||j|||dSdSt |j|<dS)NrKrlFr)rrrYr]rload_positions_snapshotr)rrrr4rlrs rrzgate.set_positions_caches > !DN 4> ! ! F!%!3!34DF^`e!f!f ! >!::K6>11 k*** 47dSSSSS21$<#=#=DN4 rcK|dd|id{V}t|j|<|j|}tdt |D]<}||}||dd}|dkr||=||jvr=|j|} | ||||dzdSdS)Nrr contractsz :position) fetch_positionsrrrr safe_numberrrYr) rrrrrrrpositionrr]s rrzgate.load_positions_snapshots..tfd^DDDDDDDD 799tt$q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5$"4 5 5 5 5 5 ) (rc||j}||dg}|j|}g}t dt |D]M}||}||} || d} || d} | ||| dz} | 5| d| d<| | | | ||| dz} | 5| d| d<| | | | | 1| /d| d<| | | | #| | | | O| ||dz}t dt |D]}||}| d}|d }| d }| |d|d }| |s||||||d zdS) Nrrrrlongshortz :positions::rrrFr)get_market_type_by_urlrrrrrparse_positionrr[rfind_message_hashesrrOrr)rrrrdatar newPositionsr rawPositionrrrprevLongPositionprevShortPositionrTrr^ symbolsStringr4rs rhandle_positionszgate.handle_positionss>**6:66w"55t$ q#d))$$ ' 'Aq'K**;77H%%h99F##Hf55D|#'>>%&#I#I #/'7'?HV$ ''111LL***$(NN5&7:J$K$K!$0'8'@HV$ ''111LL***#+0A0I'-HV$ ''111LL***##H--- X&&&&009NOO q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|TL%899999rc ^K|d{Vd}|||}|d}d}d}|d||\}}||dddddd}|dz} d } d g} || d |d zz } |d g} d} |d||\} }| d k} ||| }|dk}||| | | ||d{V}|jr|||}| |||ddS)a watches information on multiple orders made by the user https://www.gate.com/docs/developers/apiv4/ws/en/#orders-channel https://www.gate.com/docs/developers/futures/ws/en/#orders-api https://www.gate.com/docs/developers/delivery/ws/en/#orders-api https://www.gate.com/docs/developers/options/ws/en/#orders-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 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 ` NrrFr[rYr|rz.ordersrrrGrrr'T) rrrrrrrrMrirj)rrrrrrrrrrrrrrrrrs r watch_orderszgate.watch_orderss"!!!!!!!!!  [[((FH%F88PVWW e++D 3 3   9$ -   3- -Kd|nG88PUVV ) ))$ ::v~ --c;RWYdeeeeeeee ? 3OOFE22E))&% TRRRrc||dg}||jdd}|jt ||_|j}i}||}t dt|D]}||} || d} || d} | dks| dkrd | d <nA| d kr;|| d } | #|| d } | dkrd nd| d <| | | d}| |}d||d<t| }t dt|D](}d||z}| |j|)| |jddS)Nr ordersLimitrarreventputupdaterrfinishleftclosedcanceledrTrzorders:r)rrr|rrrrrrrrrrr)rrrrrrrP parsedOrdersrrrrrrrrrrs r handle_orderzgate.handle_order.sV(B77!!$, tDD ; 077DK ((00 q#l++,, + +A!!_F??6622D$$T733E~~(!2!2#)x  (""))&(;;>,,T6::D48AIIxxJF8$ MM& ! ! !H%F[[((F&*IfTl # #INN$$%%q#d))$$ 5 5A#d1g-K NN4; 4 4 4 4t{H-----rc8K||g|||S)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 rwatch_my_liquidationszgate.watch_my_liquidationsvs$55vhufUUUrcPK|d{V||ddd}||}d}d}|d||\}}||dddd}d} |d||\} }| dk} ||| } g} d} ||r7|dkr| st|j d zd } | d nRt|}|d krt|j d zd|dz} | |d|dz}| | | | ||dd{V}|j r|S||j|||dS)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 ` NTrJrYr|rrrz 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)rrIrrrrrrrrrrrrMr liquidations)rr4rrrrrrrrrrrr symbolsLengthrnewLiquidationss rrz&gate.watch_my_liquidations_for_symbolss'!!!!!!!!!%%gtT4@@--g66889XZ`bhii e++D3 3    889XZ`bghh ) ))$ :: == ! ! )""9" ,H"HIII*K NN9 % % % %LLM!! ,A"ABBB,wqz9K NN6$< ( ( (=( $ 6 6sKRY[`bf g ggggggg ? #" "11$2CWeUZ\`aaarc||dg}g}|j0||jdd}t ||_|j}t dt |D]z}||}||} || | | d} | || g} | | d| z{| |ddS)NrliquidationsLimitrarrrr) rZrrr|rrrparse_ws_liquidationrrrr) rrrrawLiquidationsrrrrrawLiquidation liquidationrsymbolLiquidationss rhandle_liquidationzgate.handle_liquidationsX..(B??   $%%dl4GNNE *5 1 1D !q#o..// L LA,Q/N33NCCK LL % % %%%k8<>'gll3.?.?!.C.C$+MM#$6$6M"nnWiDDG"1c'll33HH%21%5%? !%!1!1'!*dC!T!T,9!,>,@RTV#W#W q#m"4"455JJA -a 0I.q1G--fgyIIII  ...! / /rc P|||rdS||d}|dkr|||dS|dkr|||dS||dd}|d}||d}|j|j|j|j |j |j |j |j |j|jd }|||}| |||||d } | d kr|||dS| ^||d } || d } ||d } | dur|| | dSdSdS)Nr subscriberrrrr) usertrades candlesticksrrrcrArkorder_book_updatebalances liquidatesr authenticatedrrackT)rrrr!rrrrrrr?rEryrrrhandle_authentication_messager[ safe_boolr) rrrrrrr v4Methodsr6rrrr*s rhandle_messagezgate.handle_messagest  $ $VW 5 5  F  '22 K    + +FG < < < F M ! !  $ $VW 5 5 5 F""7Ir::}}S)) oolA66 / -'.).(!%!7+1   K88   F67 # # #$$Wl;;  ' '  . .vw ? ? ? F  >>'622D__T844F..%00C$vy11111 ! rcx|jd|d}|dr|dr|dn|dS|S)Nr_rrlinearrYrZr{)rrbaseUrls rrzgate.get_url_by_market1sE)E"6&>2 *  &,X&6J76??GEN JNrrc.|drdS|drdSdS)Nr[r^r|rY)rrs rrzgate.get_type_by_market8s* &> 6 H  99rFcl|jd}||}|dks|dkr|r|dn|dS|S)Nr_r\r]rZrYr1)rrrr_rs rrzgate.get_url_by_market_type@sFi$i FNN 0 0!*;3u::F ;Jrrcdddd}t|}tdt|D]/}||}||}||dkr|cS0dS)Nr^r]r\)zop-deliveryfxrr[)rrrrrK)rrfindByrrkeyvalues rrzgate.get_market_type_by_urlHs    FKKMM""q#d))$$  Aq'C3KExx}}!! "vrc||||jddd}||jd<||S)Nreqidrr)lock_idsumrr| unlock_id)rr=s rrzgate.request_idVsW **4<!DDaHH % W  rcBK|}|}|||d|d} |7||} || jvrt |} || j| <|| |} |||| ||d{VSNr#rtimerrr)rsecondsrrrrwatch) rrrrrrrrrDrrtempSubscriptionHashrs rrzgate.subscribe_public^sOO%% ||~~      #[[%%F6#777'*9~~$=H$%9:++gv..ZZ['; UUUUUUUUUrcK|}|}|||d|d}|||} |||| |d{VSrB)rrErwatch_multiple) rrrTrrrrrDrrs rrLzgate.subscribe_public_multipleps~OO%% ||~~    ++gv..((mWmTTTTTTTTTrc K|} |} | | |d|d} t| |d|||d} || |} |||| || d{VS)NrrCT)rtopicrrTror4)rrErrrI)rrrKr4rTrorrrrrDrsubrs rrz!gate.un_subscribe_public_multiple}sOO%% ||~~"   i..* 0   ++gv..((mWmUXYYYYYYYYYrcK|dz}||}d}||}||j|}|||i||d{VS|S)Nz.loginr))rreusableFuturerrr)rrrrrrr]r)s rrzgate.authenticates(S!!% &&{33(x3tx==A#5#5'2N(NOOOxjG!++GW==||~~%/#5@5H3NQXX[^_c[d[ddIIdkk*:;;T[[=U=UW^Weglmm ;   OO%%      !(GI S!!v333#&y>> 9DF !5 6++gv..ZZ['; TTTTTTTTTrr)F)Z__name__ __module__ __qualname__rrrrrfloatrrrrrrrrrrr rrrrrrrrrrrr$rrr3rrr2r?rBrEr8r=rrerdrprrryrrrrrrrrrrrrrrrr rrrrr rrrr!r.rr rr rrrrrLrrr+rr __classcell__)rs@rr$r$s z #z z z z z z xpt|~))C)y) )[`)il))))VIK44T,-?444408D_cln ^ ^3 ^c ^Y\ ^swx}s~ ^ ^ ^ ^JN\`os|~OOcO3OVYOilODHINDOOOOO@@DB&!&!S&!&!S\&!&!&!&!P=?NNN3NNNN2=V==== [5[5[5[5[5z   ... / / /68///F////&6:" E E7 E E E E EBFBBBB*82)62)2)2)2)h37TX\eg,U,UC,Us,URU,Ulpqvlw,U,U,U,U\*1v*1*1*1*1X*,bbbbbb@Y2VY2Y2Y2Y2v8<$]ajl0e0eW0eC0eWZ0equv~q0e0e0e0ed > >& > > > > > 6 6 6E:E:E:N04$UYbd/S/S/SC/Ss/Simnsit/S/S/S/SbF.6F.F.F.F.PEIW[dfVV#VcVQTVkop{k|VVVV X\jnwy.b.btCy.bQT.bdg.bCDOP.b.b.b.b`9:9:9:9:9:v- - - - ^S6StSSSSj&)))))"%/&%/%/%/%/N2V2222B: #    QSaeVVVV$\^ U U U UACZZZZ*F SSSSSS@$U$U$U$U$U$U$U$Urr$)+ccxt.async_supportrW ccxt.async_support.base.ws.cacherrrrr]ccxt.base.typesrrr r r r r rrrrrrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrr r!ccxt.base.preciser" async_supportr$r4rrrysP AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA444444******000000......''''''))))))******%%%%%%PUPUPUPUPU4  "PUPUPUPUPUr