E#iSSKrSSKJrJrJr SSKrSSKJrJ r J r J r J r J r JrJrJrJrJrJrJrJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr "S S \R@RB5r!g) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesBoolIntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequired) BadRequest)Precisec^\rSrSrS\4U4SjjrSr04S\4SjjrS\ 4Sjr SS04S \ S \ S \ S\ \4S jjrS\ 4S jrSASjrS\ 4Sjr04S \ S\4SjjrS04S\S\4Sjjr04S \ S\4SjjrS\ 4SjrSASjr04S\4SjjrSSS04S \S \ S \ S\ \4SjjrSSS04S \S \ S \ S\ \4SjjrS\ 4Sjr S\ 4Sjr!SASjr"S\ 4Sjr#SASjr$Sr%Sr&S\ 4S jr'S04S \ S \ S\(4S!jjr)S\ 4S"jr*S#r+S\ 4S$jr,S%r-S&r.S'SS04S \ S(\ S \ S \ S\ \/4 S)jjr0S\ 4S*jr1S\ 4S+jr2S\ 4S,jr3S\ 4S-jr4S04S.\ S \4S/jjr5SSS04S \S \ S \ 4S0jjr6S04S \ S1\7S2\8S3\9S4\:S\4 S5jjr;SS04S.\ S \ S1\7S2\8S3\:S4\:S\4S6jjrS\ 4S:jr?S\ 4S;jr@S\ S\A4S<jrBS\ 4S=jrCS\ 4S>jrD04S?jrES@rFU=rG$)Bcexreturnc >UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSS.ESSS00S0000S.5$)NwsT watchBalance watchTicker watchTickers watchTradeswatchTradesForSymbolsF watchMyTrades watchOrderswatchOrderBook watchOHLCV watchPosition createOrderWs editOrderWs cancelOrderWscancelOrdersWs fetchOrderWsfetchOpenOrdersWs) fetchTickerWsfetchBalanceWsapizwss://ws.cex.io/ws orderbook)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s F/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/cex.pyr; cex.describes-c4 9 ;dt  t  (  t!$d  t !$ !"$T#$"&"&',. RA"> " " cURURURSS5S5nXRS'[U5$)N requestIdr)sum safe_integerr6str)r<rBs r> request_idcex.request_id9s;HHT..t||[!LaP $- [!9~r@c# URU5IShvN UR5nURSSnS0UR5S.nURXA5nUR X2XRU5IShvN $NfN7f)a( watch balance and get the amount of funds available for trading or funds locked in orders https://cex.io/websocket-api#get-balance :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nr2r get-balanceedataoid) authenticaterGr5r9watch)r<params messageHashurl subscriberequests r> watch_balancecex.watch_balance>s'''oo' iit$??$ ""95ZZ'PPP (Qs"BA>A!B9B:BBclientcURUS05nURUS05nURUS05nSU0n[UR55n[S[ U55HTnXxn UR 5n UR XI5U S'UR XY5U S'URU 5n XU 'MV URU5Ul UR US5n URURU 5 g) NrMbalanceobalanceinforfreeusedrN) safe_valuelistkeysrangelenaccount safe_stringsafe_currency_code safe_balancerZresolve) r<rXmessagerM freeBalance usedBalanceresult currencyIdsi currencyIdrdcoderRs r>handle_balancecex.handle_balanceRs*w3oodIr: oodJ; D ;++-. q#k*+A$JllnG"..{GGFO"..{GGFO**:6D"4L ,((0 &&w6 t||[1r@Nsymbolsincelimitc# UR5IShvN URU5nUSnURSSnSnSU-nXRS'UR UR U5n U bm[ U RR55n [S[U 55H1n Xn X:XaMU SS n U S :XdM[URS -5e S S US-S-US-/S.n URX5nURXgX5IShvN n[S[U55H n XU S'M URXUSS5$GNEN>7f)a get the list of most recent trades for a particular symbol. Note: can only watch one symbol at a time. https://cex.io/websocket-api#old-pair-room :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 ` Nrsr2rtradeszold:currentWatchTradeSymbolroldz; watchTrades() only supports watching one symbol at a time.rTpair-base-quoterLrooms timestampT) load_marketsmarketr5r6r_clientsr` subscriptionsrarbrcridr9rPfilter_by_since_limit)r<rsrtrurQrrSrRsubscriptionHashrXsubscriptionKeysrnsubscriptionKeyrirUrws r> watch_tradescex.watch_tradesysv!!!V$!iit$ !F?28 ./s3  #F$8$8$=$=$?@ 1c"234"2"5"6"1!A"6"e+'2o(opp 5v.4vgFG ""73zz#GNNq#f+&A"(1Ih '))& TRR5 ",Os)E EB/E  AE E handle_trades_snapshotcex.handle_trades_snapshots~~gvr2!!$,, tDE"!!$,,0IJ > V$Y q*%ANQ&E{H,,X>F MM& ! &   t{{K0r@c[U[5(dURS5nURUS5nUR US5nURUS5nURUS5nURUS5nUR UUUUR U5URUS5SUSSUUSSS. U5$) N:rrCryrs) r\rrdatetimerstypesideorder takerOrMakerpriceamountcostfee) isinstancer`splitrerE safe_tradeiso8601)r<traderrrrrrs r>rcex.parse_ws_old_trades%&&KK$Eq)%%eQ/ !!%+  *   eQ '" Y/&&vx8    r@c"URUS/5nURn[U5n[SU5H1nUS- U- nX7nUR U5n UR U 5 M3 Sn X@lUR URU 5 g)NrMrrCrw)r_rwrcrbrrrh) r<rXrirMrrrnrrrrRs r> handle_tradecex.handle_tradesw3Y q*%ANQ&E{H,,X6F MM& ! &   t{{K0r@c# UR5IShvN URU5nUSnURSSnSU-nURUSS5nSS /S .nS nUS:Xa9UR 5IShvN S US US /UR 5S.nSU-nUR Xr5n URXEX5IShvN $NNRN7f)a https://cex.io/websocket-api#ticker-subscription 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 :param str [params.method]: public or private :returns dict: a `ticker structure ` Nrsr2rticker:methodprivaterTtickersrtickerbaseIdquoteIdrK)rrr5rerOrGr9rP) r<rsrQrrSrRrrirrUs r> watch_tickercex.watch_tickers!!!V$!iit$&( !!&(I>  % Y ##% % %8$fY&7( G )61 ""73ZZ'LLL1 " &Ms5CC A%C<C=A CC CCCsymbolsc# UR5IShvN URU5nURSSnSnSS/S.nURXR5nUR X4Xd5IShvN nUSnUb/UR X5(dUR X5IShvN $UR(a0n XyU'U $URURSU5$NNsN>7f)a https://cex.io/websocket-api#ticker-subscription watches price tickers for multiple markets, statistical information calculated over the past 24 hours for each market :param str[]|None symbols: unified symbols of the markets to fetch the ticker for, all market tickers are returned if not assigned :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `ticker structures ` Nr2rrrTrrs) rmarket_symbolsr5r9rPin_array watch_tickers newUpdatesfilter_by_arrayr) r<rrQrSrRrirUr tickerSymbolrls r>rcex.watch_tickerss!!!%%g.iit$   ""73zz#GIIh'  t}}\'K'K++G<< < ??F#)< M##DLL(GDD' "J=s4C$CAC$,C -6C$#C"$;C$ C$"C$c# UR5IShvN URU5nURSSnUR5nUR SUUSUS/S.U5nUR XEXe5IShvN $NoN7f)a https://docs.cex.io/#ws-api-ticker-deprecated fetches 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 cex api endpoint :returns dict: a `ticker structure ` Nr2rrr|r~rLrNrM)rrr5rGextendrP)r<rsrQrrSrRrUs r>fetch_ticker_wscex.fetch_ticker_ws5s!!!V$iit$oo' ++F^VG_5    ZZ'GGG "Hs"B BA*B BB B cURUS05nURU5nUSnUcgX@RU'SU-nURXF5 URUS5 UR US5nUbURXF5 gg)NrMrsrrrN)r_parse_ws_tickerrrhre)r<rXrirMrrsrRs r> handle_tickercex.handle_tickerJsw3%%d+! > % V&( v+vy)&&w6  " NN6 / #r@c "URUS/5nURUS5nUcURUS5nURUS5nUcURUS5nURU5nURU5nUS-U-nURUS5n U bU S-n UR 0S U_SU _S UR U 5_S URUS 5_S URUS 5_S URUS 5_SS_SURUS5_SS_SS_SURUS5_SS_SUR USS5_SS_SURUS5_SURUS5_SS_SURUS5US.EU5$)Npairsymbol1rsymbol2rC/rrrsrhighlowbid bidVolumeask askVolumevwapopenopen24closelastr previousClosechange priceChange percentagepriceChangePercentageaveragevolume) baseVolume quoteVolumer\)r_rerfrE safe_tickerr safe_string_2) r<rrrrrr|r~rsrs r>rcex.parse_ws_tickerds.0vvr2!!&)4 >%%dA.F""695 ?&&tQ/G&&v.''0e#%%fk:  !D(I! f! !   Y/!  D$$VV4 ! 4##FE2 ! 4##FE2 !  !  4##FE2!  !  D!  D$$VX6!  T!  D&&vw?!  T!  d&&v}=! $**63JK!! " t#! $++FH=)! * + r@c# UR5IShvN UR5IShvN URSSnUR5nUR SUS.U5nUR X#XC5IShvN $NmNWN7f)a& https://docs.cex.io/#ws-api-get-balance query for balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the cex api endpoint :returns dict: a `balance structure ` Nr2rrJ)rLrN)rrOr5rGrrP)r<rQrSrRrUs r>fetch_balance_wscex.fetch_balance_wss!!!!!!iit$oo' ++  ZZ'GGG "!Hs2B BB BAB ?BB B B c# Uc[URS-5eUR5IShvN URU5IShvN URSSnUR U5nUSnSU-nSSUS US /0US .nUR X5n URXWXU 5IShvN n UR(aU RX5nURXX#S 5$NNN=7f) a get the list of orders associated with the user. Note: In CEX.IO system, orders can be present in trade engine or in archive database. There can be time periods(~2 seconds or more), when order is done/canceled, but still not moved to archive database. That means, you cannot see it using calls: archived-orders/open-orders. https://docs.cex.io/#ws-api-open-orders :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 ` Nz) watchOrders() requires a symbol argumentr2rrsorders: open-ordersrrrrKT) rrrrOr5rr9rPrgetLimitfilter_by_symbol_since_limit) r<rsrtrurQrSrrRrirUorderss r> watch_orderscex.watch_orderss >#DGG.Y$YZ Z!!!'''iit$V$!&( 8$9%   ""73zz#G'RR ??OOF2E00tTT) "' Ss4/C3C-C3 C/ A(C33C14:C3/C31C3c# Uc[URS-5eUR5IShvN URU5IShvN URSSnUR U5nSUS-nSUS-nSS US US /0USS .n UR X5n URXWXU 5IShvN n URXSX#5$NNN7f) a get the list of trades associated with the user. Note: In CEX.IO system, orders can be present in trade engine or in archive database. There can be time periods(~2 seconds or more), when order is done/canceled, but still not moved to archive database. That means, you cannot see it using calls: archived-orders/open-orders. https://docs.cex.io/#ws-api-open-orders :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 ` Nz+ watchMyTrades() requires a symbol argumentr2r myTrades:rsrrrrrrK) rrrrOr5rr9rPr) r<rsrtrurQrSrrRrrirUrs r>watch_my_tradescex.watch_my_tradess >#DGG.[$[\ \!!!'''iit$V$!F8$44 $vh'778$9% (#  ""73zz#GwWW009I5XX% "' Xs4/CCC C A1C<C=CCCcURUS5nURUS5nUcgURX5 URX5 g)NrMr)r_rehandle_order_updatehandle_my_trades)r<rXrirMrs r>handle_transactioncex.handle_transactionsHw/""43 ?    1 f.r@cURUS05nURnUc.URURSS5n[ U5nX@lUR U5nUR U5 SUS-nURXG5 g)NrMrrrrs)r_myTradesrEr6rparse_ws_traderrh)r<rXrirMrrurrRs r>rcex.handle_my_tradessVw3 >%%dllM4HE+E2F"M##D) e!E(O3 v+r@cRURUS5nURUS5nURUS5nURUS5nURUS5nURU5nURU5n US-U -n URUS5n US:XaU S-U-n [R"X5n URUS 5URUS 5UUR U5UU SUSUSU SS . n URUS 5n U b U U SS .U S'UR X5$)Nrrtimersrrrsellrr) rrr\rrrsrrrrrrr fee_amountrcurrencyrater)rerfr string_div parse8601r)r<rrrrrrrr|r~rsr parsedTraders r>rcex.parse_ws_trade7sS0v.  0##E62!!%2""5)4&&v.''0e#!!%2 6>S[4'F''6F""5$/%%eW51   ul3 ?!"K  {33r@cfURUS05nURUS5S:HnURUSS5nURUS5nURUS5nURUS5nURUS 5n U b$URU S 5nURU S5nURU5n URU5n U S -U -n UR U 5n UR X5nUR c-URURS S 5n[U5UlUR nURURU 05nURUU5nUcURX=5nUUS'URUSS5nU(aSUS'U(aSUS'URUS5nUb UU SS.US'URUS5nUUS'URU5US'URU5nUR!U5 SU -nUR#UU5 g)NrMrLtxrrremainsrsrrrr ordersLimitr remainingcancelFcanceledstatusclosedrrrrrr)r_rerrf safe_marketcurrency_from_precisionrrEr6rhashmapparse_ws_order_update safe_bool safe_numberr safe_orderrrh)r<rXrirM isTransactionorderIdr rrrr|r~rsrru storedOrdersordersBySymbolrrrrrRs r>rcex.handle_order_updatess8Jw3((#6$> $$T49""43!!$1""43tV,  %%dI6F&&tY7G&&v.''0e#!!&)..t= ;; %%dllM4HE07DK{{ )=)=vrJ8 =..t>$%8 (E(O &E(OtU+ ?!E%L %%dF3 &k LL3j&E"&( |[1r@c bURUS5SLnURUS5nSnUbURUSU5nURUS5nU(dURUSU5 URUS5nURUS5nURUS5n U b$URUS5nURUS5nURU5n URU5n Sn U b U bU S -U -n UR X5nUR US UR 55n U nU(aURU 5nURUS S 5nS nU(aSnO U(aSn0SURUSS5_SS_SU_SU_SURU5_SS_SU_SU _SS_SS_SS_SURUS5_SURUS5_SS_SS_SS_S S_USUURUS!S"5U SS#.SS$.EnU(aURX5US%'URUU5$)&Ndr r|rrsrrrrrrFrrrrr clientOrderIdr\rrlastTradeTimestamprr timeInForcepostOnlyrr stopPrice triggerPricerrrrr)rfilledrrrwrw)r_rerrfrrE millisecondsrrrrr safe_number_2rr)r<rrrremainsPrecisionrrrrrr|r~rsrrrr parsedOrders r>rcex.parse_ws_order_updatesJs34? ++E9=  '44VF^EUVI!!%2  ( ( @!!%2""5)4uf-  %%eY7F&&ui8G&&v.''0   1CZ%'F!!&1  0A0A0CD t,I>>%59 F F $$$UD': T  E     Y/  !$   f  f  D  4    D$$UF3  T%%eW5    D t! " D# $"**5%F! 5 8 $($7$7$FK !{F33r@cUcg[U5nURURU5UlUR5 [ U5$N)rrDdecimalsreducerF)r<rscaleprecises r>from_precisioncex.from_precisionGs@ >&/88G$4$4e<7|r@cdURURUSS5nURX#5$)N precisionr)rE currenciesr4)r<rrr2s r>rcex.currency_from_precisionOs0!!$//(";[!L""611r@cURUS5nURUS/5nURnURc(URURSS5n[ U5n[ S[U55H?nXGnURU5n URX5n SU S'URU 5 MA XPlSU-n [U5n U S:aURX[5 gg) NrNrMrrrrrr) rer_rrEr6rrbrcr parse_orderrrh) r<rXrirs rawOrdersmyOrdersrurnrawOrderrrrR ordersLengths r>handle_orders_snapshotcex.handle_orders_snapshotSs !!'51OOGVR8 ;; ;; %%dllM4HE-e4Hq#i.)A |H%%f-F$$X6E$E(O OOE " *  &( 8} !  NN8 1 r@c# UR5IShvN UR5IShvN URU5nUSnURSSnSU-nUcSOUnSUSUS /S US .UR 5S .nUR X5n UR XVX5IShvN n U R5$NNN7f) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://cex.io/websocket-api#orderbook-subscribe :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 Nrsr2r orderbook:rorder-book-subscriberrT)rrTdepthrK)rrOrr5rGr9rPru) r<rsrurQrrSrRrErTrUr3s r>watch_order_bookcex.watch_order_bookus!!!!!!V$!iit$"V+ m%'8$9%" ??$  ""95**SwLL   + "!&Ms2CCCCA>C-C.CCCcURUS05nURUS5nURU5nSU-nURUSS5nUR US5nUR 05n UR X5USS5n XS 'U RU 5 S U0URS U'XRU'URX5 g) NrMrrC timestamp_msrrbidsasksnonce incrementalIdr3) r_repair_to_symbolsafe_integer_2rE order_bookparse_order_bookresetr6 orderbooksrh) r<rXrirMrrsrRrrMr3snapshots r>handle_order_book_snapshotcex.handle_order_book_snapshots.w3f-$$T*"V+ ''nkJ ))$5 OOB' ((y&&Q)! ]-  [!&)#,y.r@cURS5nURUS5nURUS5nURU5nURU5nUS-U-nU$)NrrrCr)rrerf)r<rpartsrrr|r~rss r>rNcex.pair_to_symbolsf 3!!%+""5!,&&v.''0e# r@cfURUS05nURUS5nURUSS5nURU5nURURU5nSU-nXGSS-:wa-UR U UR URS-U5 gURUS 5n URUS /5n URUS /5n URUS U 5 URUS U 5 XS 'URU 5US 'XGS'URXx5 g)NrMrrrCrLrCz# watchOrderBook() skipped a messagerrKrJrr) r_rErerNrSrrejectr handle_deltasrrh) r<rXrirMrMrrsstoredOrderBookrRrrKrJs r>handle_order_book_updatecex.handle_order_book_updates2w3))$5 fb1$$T*//$//6B"V+ G4q8 8$$[1 MM$''$II; W %%dF3 tVR0tVR0 ?62D9 ?62D9'0 $&*ll9&= ##0 4r@cLURUSS5nURU5 g)NrrC) parse_bid_ask storeArray)r<booksidedeltabidAsks r> handle_deltacex.handle_deltas$##E1a0F#r@cd[S[U55HnURXU5 M g)Nr)rbrcrg)r<rddeltasrns r>r]cex.handle_deltass)q#f+&A   hq 2'r@1m timeframec# UR5IShvN URU5nUSnSU-nURSSnSUSUS-S -US -/S .n URXUR X5U5IShvN n UR (aU R X5nURXUS S 5$NN<7f)a https://cex.io/websocket-api#minute-data watches historical candlestick data containing the open, high, low, and close price, and the volume of a market. It will return the last 120 minutes with the selected timeframe and then 1m candle updates after that. :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 Nrsohlcv:r2rz init-ohlcvr{rr}r)rLrnrrT)rrr5rPrrrr) r<rsrmrtrurQrrRrSrUohlcvs r> watch_ohlcvcex.watch_ohlcvs!!!V$!' iit$&**S06)3DD jj4;;w3OQ\]] ??NN61E))%q$GG "^s"CB>A,CC;CCcURUS5nURS5nURUS5nURUS5nURU5nURU5nUS-U-n URU 5n SU -n UR US/5n UR UR SS 5n [U 5nURU S5n[S[U55H'nURURUUU 55 M) XR;a0URU 'XRU S 'URX5 g) NrrrrCrrorM OHLCVLimitrunknown)rerrfrr_rEr6rsort_byrbrcr parse_ohlcvohlcvsrh)r<rXrirrXrrr|r~rsrrRrMrursortedrns r>handle_init_ohlcvcex.handle_init_ohlcvs:$0 3!!%+""5!,&&v.''0e#!!&)' w3!!$,, dC&u-dA&q#f+&A MM$**6!9f= >'++%"$DKK )/ FI&v+r@cU$r/r<rXris r>handle_ohlcv24cex.handle_ohlcv246s r@c URUS05nURUS5nURU5nSU-nURUS5UR US5UR US5UR US5UR US5UR US 5/nURUR U5nUR U5 URX5 g) NrMrrorohlcv)r_rerNsafe_timestamprrxrrh) r<rXrirMrrsrRrprs r>handle_ohlcv1mcex.handle_ohlcv1m@s w3f-$$T*'   f -   T3 '   T3 '   T3 '   T3 '   T3 '  f5 ev+r@c &URUS/5nURUS5nURU5nSU-nURUSn[ S[ U55HnUR X8S5URX8S5URX8S5URX8S5URX8S 5URX8S 5/n URU 5 M [ U5n U S:aURXv5 gg) NrMrrorurrCrryr) r_rerNrxrbrcrrrrh) r<rXrirMrrsrRrrnrprs r> handle_ohlcvcex.handle_ohlcv`sw30$$T*' V$Y/q#d)$A##DGQ/  !,  !,  !,  !,  !, E MM% %Y > NN6 / r@rc# UR5IShvN UR5IShvN SnUbURU5nURS[ U50U5nUR SSnUR 5nSUUS.nURXgX5IShvN n URX5$NNN7f)a> fetches information on an order made by the user https://docs.cex.io/#ws-api-get-order :param str id: the order id :param str symbol: not used by cex fetchOrder :param dict [params]: extra parameters specific to the cex api endpoint :returns dict: An `order structure ` Norder_idr2r get-orderr) rrOrrrFr5rGrPr;) r<rrsrQrrMrSrRrUresponses r>fetch_order_wscex.fetch_order_ws~s!!!!!!  [[(F{{ B iit$oo'   CgKK11! "!Ls2B?B9B?B;A4B?#B=$B?;B?=B?c# Uc[URS-5eUR5IShvN UR5IShvN UR U5nUR SSnUR 5nURSUSUS/0U5nSUUS .n URXgX5IShvN n URXX#U5$NNN7f) a https://docs.cex.io/#ws-api-open-orders fetch all unfilled currently open orders :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 cex api endpoint :returns Order[]: a list of `order structures ` Nz% fetchOpenOrdersWs requires a symbol.r2rrrrrr) rrrrOrr5rGrrP parse_orders) r<rsrtrurQrrSrRrMrUrs r>fetch_open_orders_wscex.fetch_open_orders_wss >#DGG.U$UV V!!!!!!V$iit$oo' {{ VH%vi'89   CgKK  5HH "!Ls4/CCC C A.C8C9CCCrrrrc# Uc[URS-5eUR5IShvN UR5IShvN UR U5nUR SSnUR 5n URUSUS/UUUS.U5n SU U S .n URXX5IShvN n URX5$NNN7f) a, https://docs.cex.io/#ws-api-order-placement create a trade order :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 currency you want to trade in units of 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 kraken api endpoint :param boolean [params.maker_only]: Optional, maker only places an order only if offers best sell(<= max) or buy(>= max) price for self pair, if not order placement will be rejected with an error - "Order is not maker" :returns dict: an `order structure ` Nz( createOrderWs requires a price argumentr2rrr)rrrr place-orderr) rrrrOrr5rGrrPr;) r<rsrrrrrQrrSrRrMrUr>s r>create_order_wscex.create_order_wss =TWW'QQR R!!!!!!V$iit$oo' {{H%vi'89     CgKK11# "!Ls4/CCC C A1C;C<CCCc# Uc[URS-5eUc[URS-5eUR5IShvN UR5IShvN UR U5nUR USUS/UUUUS.U5n UR 5n URSSn S U U S .n URXXU 5IShvN n URX5$NNN7f) ar edit a trade order https://docs.cex.io/#ws-api-cancel-replace :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|None [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 cex api endpoint :returns dict: an `order structure ` Nz' editOrder() requires a amount argumentz& editOrder() requires a price argumentrr)rrrrrr2rcancel-replace-orderr) rrrrOrrrGr5rPr;)r<rrsrrrrrQrrMrRrSrUrs r> edit_order_wscex.edit_order_wss  >#DGG.W$WX X =#DGG.V$VW W!!!!!!V${{H%vi'89   oo' iit$'  CgKXX11% "! Ys7A C4 C. C4$C0%A3C4C2C40C42C4cr# UR5IShvN UR5IShvN SnUbURU5nURSU0U5nUR 5nUR SSnSUUS.nUR XvXU5IShvN n URX5$NNN7f)a% https://docs.cex.io/#ws-api-order-cancel cancels an open order :param str id: order id :param str symbol: not used by cex cancelOrder() :param dict [params]: extra parameters specific to the cex api endpoint :returns dict: An `order structure ` Nrr2r cancel-orderr)rrOrrrGr5rPr;) r<rrsrQrrMrRrSrUrs r>cancel_order_wscex.cancel_order_wss!!!!!!  [[(F{{  oo' iit$  CgKXX11! "!Ys2B7B1B7B3A,B7B5B73B75B7idsc# Ub[URS-5eUR5IShvN UR5IShvN UR 5nUR SU0U5nUR SSnSUUS.nURXdXtU5IShvN nURUS5n URU SSSU5$NNN/7f)a8 cancel multiple orders https://docs.cex.io/#ws-api-mass-cancel-place :param str[] ids: order ids :param str symbol: not used by cex cancelOrders() :param dict [params]: extra parameters specific to the cex api endpoint :returns dict: a list of `order structures ` Nz1 cancelOrderWs does not allow filtering by symbolz cancel-ordersr2rmass-cancel-place-ordersr) rrrrOrGrr5rPr_r) r<rrsrQrRrMrSrUrcanceledOrderss r>cancel_orders_wscex.cancel_orders_ws!s  TWW'ZZ[ [!!!!!!oo' {{ S iit$+  CgKXX?C  tT6JJ1 "!Ys4/CC C C AC C!,CCCcnURUS5nURUS5nURX45 g)NrMrN)r_rerh)r<rXrirMrRs r> resolve_datacex.resolve_dataHs2$w/&&w6 t)r@cU$r/r}r~s r>handle_connectedcex.handle_connected^s r@cURUS05nURUS5nURUSS5nURS-U-S-U-nURURSXF5 UR URSXF5 [ U5e![aGnURUS5nURUS U5nUbURXG5 SnAg UeSnAff=f) NrMerrorrLr[ exactbroadrNfuturesT) r_rerthrow_exactly_matched_exceptionr8throw_broadly_matched_exceptionr Exceptionr\) r<rXrirMreventfeedbackrRfutures r>handle_error_messagecex.handle_error_messagefs ??7FB7D$$T73E$$Wc26Eww}u,s2U:H  0 01I5 [  0 01I5 [) ) **7E:K__VI%6 DF! e1  sBB C,%;C'%C''C,cURUS5nUS:XaURX5 gURUS5n0SUR_SUR_SUR_SUR_SUR _S UR _S UR_S UR_S UR_S UR_SUR_SUR_SUR_SUR_SUR_SUR _SUR_URURURURS.EnUR#XT5nUb U"X5 gg)NokrrLauth connectedtickrzinit-ohlcv-dataohlcv24ohlcv1mrprJrD md_updaterrzhistory-updatehistoryr r)rrrr)rerhandle_authentication_messagerrrzrrrrqrUr_rrrrrr_)r<rXrirrhandlershandlers r>handle_messagecex.handle_messages   gt , =  % %f 6   #. D66 ..  D&&  d((  t55  t**   t**  T&&  4..  #D$C$C  66  4,,  T--  d//  t22 $))! " 4,,# $%)$5$5 --(,(9(9**+ .//(2   F $ r@cfURURS5nUbURS5 gg)N authenticatedT)r_rrh)r<rXrirs r>r!cex.handle_authentication_messages/A   NN4  r@cR# URSSnURU5nSnURS5nURURU5nUcUR 5 [ UR55nXpR-nURURU5URUR5[R5n SURU R5US.S.n URX$UR!X5U5 UIShvN $N7f)Nr2rrr)key signaturer)rLr)r5rXreusableFuturer_rcheck_required_credentialsrFsecondsapiKeyhmacencodesecrethashlibsha256upperrPr) r<rQrSrXrRrrrLrrrUs r>rOcex.authenticatesiit$S!% &&7(<(rrs# ## J *,QQ(%2V%2N<@d[]&S&SS&S&Sbfglbm&SP1V1:<161*68#M#MF#MJ6:"E7EE>9;HCHvH*0F04:x-/H8H&04$UYbd"U"UC"Us"Uimnsit"UH37TX\eg YC Ys YRU Ylpqvlw YD//4,v4,l:4xo2&o2ba4F2 2V 2D@DB !S ! !S\ !D%/%/N!5v!5F$3?CQUdhqsHHH3H^aHx|~ByCH<$,$,LV,V,@060<;?r2s2C2:8<$]ajlIICIWZI<pt|~"2C"2y"2 "2[`"2il"2DI"2Him{IK%2c%23%2i%2y%2be%2ux%2PU%2N<@22S2:DHPR%K$s)%KS%KN*6*,v6t4%V%B !F !)+r@r)"ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r r rrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrr}r@r>rsW ffHHHH4*.'%r$   rr@