E#i#SSKrSSKJrJrJrJr SSKrSSKJ r J r J r J r J r JrJrJrJrJrJrJrJr SSKJr SSKJr SSKJr SSKJr SSKJr "S S \R<R>5rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolInt LiquidationOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)RateLimitExceededc ^\rSrSrS\4U4Sjjr04S\S\4SjjrS04S\ S\ 4Sjjr S \ 4S jr SS04S\S \S \S\\4S jjrSS04S\\S \S \S\\4SjjrS \ 4Sjr04S\4SjjrS \ 4SjrS \ 4SjrSS04S\S \S \S\\4Sjjr04SjrS \ 4SjrSSS04S\ S \S \S\\4SjjrSrSSS04S\S \S \S\\ 4Sjjr!S \ 4Sjr"SSS04S\S \S \S\\4Sjjr#S \ 4Sjr$S04S\S \S\%4Sjjr&S04S\\S \S\%4Sjjr'SS04S\\S \S \S\\4Sjjr(SSS04S\S \S \S \S\\)4 S!jjr*S \ 4S"jr+04S#jr,S \ 4S$jr-S \ 4S%jr.S \ 4S&jr/S \ S\04S'jr1S \ 4S(jr2S)r3U=r4$)*bitmexreturnc >UR[[U]50SS_SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS0SS0S.SSSS.S0S[0S.0S.5$)NwsT watchBalancewatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchPostions watchTicker watchTickers watchTradeswatchTradesForSymbolsz$wss://ws.testnet.bitmex.com/realtimezwss://ws.bitmex.com/realtime)testapi orderBookL2)watchOrderBookLevel tradesLimit OHLCVLimitzRate limit exceeded)exactbroad)hasurlsoptions exceptions) deep_extendsuperrdescriber)self __class__s I/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/bitmex.pyr=bitmex.describes:fd < >d$T.t  &t  0  d!$+Dt tt (!(@8 (5#" ./@G,A , , symbolc# UR5IShvN URU5nURU/U5IShvN nX1$N4N 7f)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.bitmex.com/app/wsAPI#Subscriptions :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 ` N) load_marketsrC watch_tickers)r>rCparamstickerss r@ watch_tickerbitmex.watch_tickerBsN!!!V$**F8V<< "` NT instrumentr/rr:idticker: alltickers subscribeopargsrC) rEmarket_symbolsr8rangelenmarketappendwatch_multipleextend newUpdatesfilter_by_arrayrH)r>rKrGnameurl messageHashesrawSubscriptionsirCrY subscription messageHashrequesttickerresults r@rFbitmex.watch_tickersQsH!!!%%gtT:iit$   1c'l+ V,#czF4L8  '' 5'&0 $$[1 ,  # #D )   .$ **3t{{7?[]mnn ??F'-6(# $M##DLL(GDD5 "*os"D<D7C"D<9D::>D<:D<clientcURUS/5n0n[S[U55HnX5nURUS5nUR U5nXR ;aUR 05UR U'UR U5n URUR UU 5n XU'XR U'SU-n URX5 URU S5 M U$)NdatarrCrPrQ) safe_listrWrX safe_string safe_symbolrH parse_tickerr;resolve) r>rjmessagerlrHrcupdatemarketIdrC updatedTickerfullParsedTickerres r@ handle_tickerbitmex.handle_tickerwsF~~gvr2q#d)$AWF''9H%%h/Fll*'+'8'8'< V$ --f5M#// V0DmT .FO#3LL #f,K NN+ 9 NN+\ :%rBsincelimitc2# URU/X#U5$7f)a watch the public liquidations of a trading pair https://www.bitmex.com/app/wsAPI#Liquidation :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_liquidations_for_symbolsr>rCryrzrGs r@watch_liquidationsbitmex.watch_liquidationsks22F8U6RRsc# UR5IShvN URUSSS5n/n/nURU5(a#URS5 URS5 O\[ S[ U55HCnXnUR U5n URSU S-5 URSU-5 ME URS S n S US .n URXURX5U5IShvN n UR(aU $URURXUS5$GN$N87f) a watch the public liquidations of a trading pair https://www.bitmex.com/app/wsAPI#Liquidation :param str[] 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 bitmex api endpoint :returns dict: an array of `liquidation structures ` NT liquidation liquidationsrz liquidation:rOliquidations::r/rrRrS) rErVis_emptyrZrWrXrYr8r[r;r]filter_by_symbols_since_limitr) r>rKryrzrGrasubscriptionHashesrcrCrYr`rfnewLiquidationss r@r|%bitmex.watch_liquidations_for_symbolsys9!!!%%gtT4@  == ! !  % %m 4   01c'l+ V,")).6$<*GH$$%5%>? , iit$& !% 3 3CHXHXY`Hik} ~~ ??" "11$2C2CWUZ\`aa+ "$s"D?D:C-D?D=6D?=D?cpURUS/5n/n[S[U55HnX5nURU5nUSnURURU5n U c(UR UR SS5n [U 5n U RU5 XRU'URU5 M URUS5 URUS5n [U R55n [S[U 55HnXnURXSU-5 M g)NrlrrCliquidationsLimitr1rr) safe_valuerWrXparse_liquidationr safe_integerr9rrZrqindex_bylistkeys) r>rjrrrawLiquidationsrrcrawLiquidationrrCrrzliquidationsBySymbolrKs r@handle_liquidationbitmex.handle_liquidations%6//'62>q#o./A,/N00@K *F??4+<+` Nmarginr/rrRrS)rE authenticater8watchr\)r>rGrer`rfs r@ watch_balancebitmex.watch_balances!!!!!! iit$  ZZ$++g2NP[\\\ "!]s2A=A7A=A9AA=2A;3A=9A=;A=cURUS5nURU5nURURU5UlUR US5nUR URU5 g)Nrltable)r parse_balancer\balancernrq)r>rjrrrlrres r@handle_balancebitmex.handle_balances_Fw/$$T*{{4<<9 &&w8 t||[1rBcRSnURUS/5nURUS5n[UR55n[ S[ U55HnXgnUR U5n U Sn US-U -n URXXU 5n URURU 5n U c6URURSS5n[U5n XRU '[ S[ U 55HnU RX5 M URX5 M g)NtraderlrCrrNr3r1)rgroup_byrrrWrX safe_market parse_tradestradesrr9rrZrq)r>rjrrrrldataByMarketIds marketIdsrcrtrYrCrerstoredrzjs r@ handle_tradesbitmex.handle_tradesIsxw3--h7--/0 q#i.)A |H%%h/FH%F#+.K&&'@&IF__T[[&9F~))$,, tL#E*&, F#1c&k* fi(+ NN6 /*rBcF# URU/X#U5IShvN $N7f)a get the list of most recent trades for a particular symbol https://www.bitmex.com/app/wsAPI#Subscriptions :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_symbolsr}s r@ watch_tradesbitmex.watch_tradess$22F8U6RRRRs !!c$# URSSnURU5nSnURU5nURURU5nUcUR 5 UR 5nS[U5-nURURU5URUR5[R5n SURUU /S.n URX5n URX$X5 UIShvN $N7f)Nr/r authenticatedz GET/realtimeauthKeyExpiresrS)r8rjreusableFuturer subscriptionscheck_required_credentials millisecondsstrhmacencodesecrethashlibsha256apiKeyr\r) r>rGr`rjrefuturer timestamppayload signaturerfrrs r@rbitmex.authenticatesiit$S!% &&{3(<(||sDD D Dc(URUSS5nSnU(a.URURU5nURS5 g[ UR U55nUR Xd5 XAR;aURU gg)NsuccessFrT) safe_boolrfuturesrqrjsonrejectr)r>rjrrrrererrors r@handle_authentication_message$bitmex.handle_authentication_messageszw 5A % __V^^[AF NN4 ' '(:;E MM% -222((53rBc# UR5IShvN UR5IShvN SnSnURU5(dSSRU5-nURSSnSU/S .nUR XvX5IShvN n UR (aU $URURXUS 5$NNN97f) a watch all open positions https://www.bitmex.com/app/wsAPI#Subscriptions :param str[]|None symbols: list of unified market symbols :param int [since]: the earliest time in ms to watch 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 ` Nposition positions::,r/rrRrST) rErrjoinr8rr]rr) r>rKryrzrGsubscriptionHashrer`rf newPositionss r@watch_positionsbitmex.watch_positionss!!!!!!%! }}W%%'!22Kiit$   "ZZ'TT ?? 11$..'RWY]^^! "!Us2C CC CAC C6C C C ctURc[5UlURnURUS/5n/n[S[ U55H:nXFnUR U5nUR U5 UR U5 M< URUS5n [S[ U 55HknXn U RS5n U Sn U RS5n URUSU S5nURU5(aMZURX5 Mm URUS 5 g) Nrlrz positions::rrrCFr) rrrrWrXparse_positionrZfind_message_hashessplitr^rrq)r>rjrrcache rawPositionsrrc rawPositionrrareparts symbolsStringrKrs r@handle_positionsbitmex.handle_positionssj >> !57DNw;  q#l+,A&/K**;7H    ) LL " - 00G q#m,-A'*K%%d+E!!HM#))#.G,,\8WeTI==++y6. |[1rBc# UR5IShvN UR5IShvN SnUnUnUbURU5nUSU-- nURSSnSU/S.n UR XX5IShvN n UR (aU R X5nURXX#S5$NNN=7f) a watches information on multiple orders made by the user https://www.bitmex.com/app/wsAPI#Subscriptions :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 dict[]: a list of `order structures ` NorderrNr/rrRrSTrErrCr8rr]getLimitfilter_by_symbol_since_limit) r>rCryrzrGr_rrer`rforderss r@ watch_ordersbitmex.watch_orderss!!!!!!  [[(F 3< 'Kiit$   zz#GNN ??OOF2E00tTT% "!O2CB<CB>ACC:C>CCcURUS/5nSn[U5nUS:GaKURc-URURSS5n[ U5UlURn0n[ SU5Hzn X9n URU S5n URURU 5n U n U bURU SU 5n URU 5nURU5 USnS X'M| URURU5 [UR55n[ S[U55H*n UU nURURUS -U-5 M, gg) Nrlrr ordersLimitr1orderIDinforCTrN)rrXrrr9rrWrnhashmapr\ parse_orderrZrqrr)r>rjrrrlre dataLengthrzrrKrc currentOrderorderId previousOrderrawOrderrrCrs r@ handle_ordersbitmex.handle_orderssUlw3 Y >{{"))$,, tL4U; [[FG1j)#w **<C $ H ' ,#{{=+@,OH((2 e$x"&* NN4;; 4 'D1c$i(at{{K#,=,FG)' rBc# UR5IShvN UR5IShvN SnUnUnUbURU5nUSU-- nURSSnSU/S.n UR XX5IShvN n UR (aU R X5nURXX#S5$NNN=7f) a watches information on multiple trades made by the user https://www.bitmex.com/app/wsAPI#Subscriptions :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 ` N executionrNr/rrRrSTr) r>rCryrzrGr_rrer`rfrs r@watch_my_tradesbitmex.watch_my_tradescs!!!!!!  [[(F 3< 'Kiit$   zz#GNN ??OOF2E00tTT% "!OrcURUS5nURUS/5nURUS5nURUS/5nURU5nURc-UR UR SS5n[U5UlURn 0n [S[U55H!n X{n U Sn U RU 5 XU 'M# [U5nUS:aURX5 [U R55n[S[U55HnURXS -UU-5 M g) NrrlexecTyperr3r1rrCrN)rnrrrmyTradesrr9rrWrXrZrqrr)r>rjrrrerldataByExecType rawTradesrrzrrKrrrC numTradesrrcs r@handle_my_tradesbitmex.handle_my_tradess,t&&w8 w3tZ8OONGR@ ""9- == %%dllM4HE259DMq#f+&AIE8_F MM% #FO ' K q= NN6 /GLLN#q#d)$A NN6#4tAw#> ?%rBcD# URU/X#5IShvN $N7f)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.bitmex.com/app/wsAPI#OrderBookL2 :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)r>rCrzrGs r@watch_order_bookbitmex.watch_order_books"66xOOOOs   ct# SnUcURURSS5nO*US:XaSnO!US:XaSnO[URS-5eUR 5IShvN UR U5n/n/n[ S [U55HMnXnURU5n US -U S -n URU 5 US -U-n URU 5 MO URS S n SUS.n URXURX5U5IShvN nUR5$NN7f)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.bitmex.com/app/wsAPI#OrderBookL2 :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 Nr2r0orderBookL2_25 orderBookL10zK watchOrderBookForSymbols limit argument must be None(L2), 25(L2) or 10(L3)rrNrOr/rrRrS)rnr9rrOrErVrWrXrYrZr8r[r;rz)r>rKrzrGrtopicsrarcrCrYtopicrer`rf orderbooks r@r#bitmex.watch_order_book_for_symbolssG =$$T\\3H-XE b[$E b["E*w wx x!!!%%g. q#g,'AZF[[(FCK&,.E MM% #+.K   - (iit$ --c$BRBRSZBcekll   # " ms%A!D8#D4$B;D8D6 D86D8cz# UR5IShvN URUSS5nSn/n/n[S[U55HMnXn UR U 5n US-U S-n UR U 5 US-U -n UR U 5 MO UR SSn S US .nURXURX5U5IShvN nUR(a6URUS5nURUS 5nURUU5nURXUS S 5$GN Nb7f)a get the list of most recent trades for a list of symbols https://www.bitmex.com/app/wsAPI#Subscriptions :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 ` NFrrrNrOr/rrRrSrCrT)rErVrWrXrYrZr8r[r;r]rrnrfilter_by_since_limit)r>rKryrzrGrrrarcrCrYrrer`rfrfirst tradeSymbols r@rbitmex.watch_trades_for_symbolssC!!!%%gtU; q#g,'AZF[[(FCK&,.E MM% #+.K   - (iit$ **3t?O?OPW?`bhii ??OOFA.E**5(;KOOK7E))& TRR- ""js#D;D6B?D;D9A D;9D;1m timeframec# UR5IShvN URU5nUSnSURURX"5-nUS-US-nURSSn SU/S .n UR XUR X5U5IShvN n UR(aU RX5nURXUS S 5$NN<7f) aB watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.bitmex.com/app/wsAPI#Subscriptions :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 NrCtradeBinrNrOr/rrRrSrT) rErYrn timeframesr8rr\r]rr) r>rCrryrzrGrYrrer`rfohlcvs r@ watch_ohlcvbitmex.watch_ohlcv+s!!!V$!T--dooyTTckF4L0 iit$  jj4;;w3OQ\]] ??NN61E))%q$GG "^s"CCBCC;CCc URUS5nURSS5nURU5nURU5nUR US/5n0n[ S[ U55GHCn Xyn URU S5n URU 5n U Sn US-U S-nURURU S 55US -- SURU S 5URU S 5URU S 5URU S5/nUR URU 05URU 'UR URU U5nUc:URURSS 5n[U5nUURU U'URU5 UX'GMF [UR!55n[ S[ U55Hn UU nUR#XU5 M g)NrrrlrrCrNrOrr1highlowclosevolumer4)rnreplacefind_timeframeparse_timeframerrWrXr parse8601 safe_floatohlcvsrr9rrZrrrq)r>rjrrrintervalrdurationcandlesresultsrccandlertrYrCrerhrrzras r@ handle_ohlcvbitmex.handle_ohlcvIsD  '2==R0''1 '' 2//'626q#g,'AZF''9H%%h/FH%F#+t 4Kt// DESWW/.01 F#'//$++vr"JDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !#)G +(,W\\^, q#m,-A'*K NN7/ =.rBc# UR5IShvN SnURSSnURX25IShvN $N1N7f)N heartbeatr/r)rEr8r)r>rGeventr`s r@watch_heartbeatbitmex.watch_heartbeatsK!!!iit$ZZ+++ ",s!A A,A A A  A c ,URUS5nURUS5nUcgURUS/5nUS:XGaURUS05nURUS5nUcgURU5nUSn US:XaUR 5UR U 'OKUS:Xa UR 0S 5UR U 'O%US :XaUR 0S 5UR U 'UR U n XS'[ S [U55Hn URX[S 5n URXRX[S55n URX[S5nURX[S5nUS:XaSOSnXnURXU/5 URX[S5nURU5U S'UU S'M US-U -nURU U5 g0n[ S [U55GHn URX[S5nUc gUU;aS UU'URUS5UU'URU5nUSn UR U n URX[S 5n US:XaS O#URXRX[SS55n URX[S5nURX[S5nUS:XaSOSnXnURXU/5 URX[S5nURU5U S'UU S'GM [UR!55n[ S [U55HGn UU nURU5nUSn US-U -nUR U n URU U5 MI g)NactionrrlpartialfilterrCr0r r  orderBook10r rpricesizerOsideBuybidsasksrdatetimerNrdelete0)rnr safe_dictrindexed_order_book orderbooksrWrXr*convertFromRawQuantity storeArrayr)rqsum safe_numberrr)r>rjrrr9rrlr;rtrYrCrrcr=r>rOr?booksiderCrenumUpdatesByMarketIdrs r@handle_order_bookbitmex.handle_order_booksd!!'84  '2 = w3 Y ^^GXr:Fvx8H%%h/FH%F %*.*A*A*C'***.*A*A"b*I'-'*.*A*A"b*I'/I"(h 1c$i(9226;K;KDGU[;\]%%dgt4''8"&%-vf$?##U"$56++DG[A)-)A +&(0 *%) #+.K NN9k 2)+ 1c$i(??47H=# $8856(215:NPQ1R$X.))(3) OOF3 ((':#x/qd6Q6QRXZjZjkokrtz|[A7B%%dgt4''8"&%-vf$?##U"$56++DG[A)-)A +&(0 *%')(16689I1c)n-$Q<))(3)#ckF2  OOF3 y+6 .rBcU$Nr>rjrrs r@handle_system_statusbitmex.handle_system_status%s rBcU$rRrSrTs r@handle_subscription_status!bitmex.handle_subscription_status5s rBcFURUS5nUbURUS05nURUS/5n[U5nUS:aUUSnURSSnUR X5n Sn U c [ U5n O X"U5n UR X5 gg) NrrfrUrrr6FT)rnrrXr:find_broadly_matched_keyrr) r>rjrrrrfrUnumArgsrer6broadKey exceptions r@handle_error_messagebitmex.handle_error_message?s"  '2  oogy"=G??7FB7D$iG{"1g -g688F # -e 4I % 6I i5rBcFURX5(Ga URUS5nURURURURURUR UR UR UR UR URURURURS.nURXC5nUc>URUS05nURUS5nUS:XaURX5 ggU"X5 gg)Nr)r0r r<rMr tradeBin1m tradeBin5m tradeBin1h tradeBin1drrrrrrfrTr) r_rnrOrwrr1rrrrrrr)r>rjrrrmethodsmethodrfrTs r@handle_messagebitmex.handle_messagebsF  $ $V 5 5$$Wg6E#55"&"8"8#55"00++"//"//"//"//++!22--#66 11G __W4F~//'9bA__Wd3))66vG*v'3 6rB)rrrr)5__name__ __module__ __qualname____firstlineno__rr=rrrIrrrFrrwr rr r~r|rrrrrrrrrrrrrr rrrrr rrrrrr1r6rOrUrXr r_rh__static_attributes__ __classcell__)r?s@r@rrs- #- ^68  F 6:"$E7$E$ELrFrhBFTXac Ss S3 Sc Shlmxhy SUYgktv!bDI!bc!bad!b{AL|M!bF-T-T^*,]]*g2Vg2RM0FM0^<@d[] S SS S Sbfglbm S)+. 6F 68<$]ajl_W_C_WZ_quv~q_6a>F,., q7q7f6 !6!t!F<(V<(<(rBr) ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrccxt.base.typesrrr r r r r rrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrSrBr@rxsZ AADDDD4*0.M(T   & &M(rB