eiddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlm Z dd lm!Z!Gd d ej"j#Z#dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesBoolIntMarketNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError) NetworkError) ChecksumErrorceZdZdeffd ZdZdifdededefdZ ifdedefdZ difd e ededefd Z ifd e edefd Z d Zd ZdefdZddifdededede efdZifdede efdZddifd e ededede efdZifd e edefdZdefdZdddifdededede efdZifdedefdZifdedefdZdifd edefdZdifd edefdZ defdZ!dJde"de#defdZ$difd edefdZ%defd Z&dJd!Z'd"ddifded#ededede e(f d$Z)d"ifded#edefd%Z*defd&Z+dddifdededede e,fd'Z-dJdefd(Z.dddifd ededede e/fd)Z0dJded efd*Z1d+Z2d,Z3ifde4fd-Z5defd.Z6difded/e7d0e8d1e9d2e:de,f d3Z;ddifd4eded/e7d0e8d1e:d2e:de,fd5Zdifdefd8Z?defd9Z@ifd:ZAifd;ZBiifde ed?e ef d@ZCifdAZDifdBZEdedeFfdCZGdefdDZHdefdEZIifdFZJdefdGZKdefdHZLdefdIZMxZNS)K cryptocomreturnc|tt|iddddddddddddddd dd dd dd dd dddddddddddddddidddddddddididS)NwsT watchBalance watchTicker watchTickers watchBidsAsks watchMyTrades watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders watchOHLCVwatchPositions createOrderWs cancelOrderWscancelAllOrders editOrderWsz*wss://stream.crypto.com/exchange/v1/marketz(wss://stream.crypto.com/exchange/v1/user)publicprivatez+wss://uat-stream.3ona.co/exchange/v1/marketz)wss://uat-stream.3ona.co/exchange/v1/user)apitest)fetchPositionsSnapshotawaitPositionsSnapshotchecksum)r-r))hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s P/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/cryptocom.pyr?zcryptocom.describesqi 6 6 ? ? A Adt       t(!$+Dtd!$   "4!"t#*"N#MLJ  /3.2## # S+D +D + + + c$K |||dddd{VdS#t$rM}t|jdz||z}||Yd}~dSd}~wwxYw)Nidzpublic/respond-heartbeat)rEmethodz pong failed with error )send safe_integer ExceptionrrEexception_messagereset)r@clientmessageeerrors rBpongzcryptocom.pongBs  ++T%6%6w%E%EQkllmm m m m m m m m m m    +E!EH^H^_`HaHa!abbE LL          s28 BAB  BNsymbollimitcBK||g||d{VS)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#book-instrument_name :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 :param str [params.bookSubscriptionType]: The subscription type. Allowed values: SNAPSHOT full snapshot. This is the default if not specified. SNAPSHOT_AND_UPDATE delta updates :param int [params.bookUpdateFrequency]: Book update interval in ms. Allowed values: 100 for snapshot subscription 10 for delta subscription :returns dict: A dictionary of `order book structures ` indexed by market symbols N)watch_order_book_for_symbols)r@rQrRparamss rBwatch_order_bookzcryptocom.watch_order_bookNs466xOOOOOOOOOrCc@K||g|d{VS)aQ unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#book-instrument_name :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 :param str [params.bookSubscriptionType]: The subscription type. Allowed values: SNAPSHOT full snapshot. This is the default if not specified. SNAPSHOT_AND_UPDATE delta updates :param int [params.bookUpdateFrequency]: Book update interval in ms. Allowed values: 100 for snapshot subscription 10 for delta subscription :returns dict: A dictionary of `order book structures ` indexed by market symbols N)un_watch_order_book_for_symbolsr@rQrUs rBun_watch_order_bookzcryptocom.un_watch_order_book]s2996(FKKKKKKKKKrCsymbolscFK|d{V||}g}g}|sd}||d}|i|d<d}d}||ddd\}}||dd|\}}||dd<d} d} ||dd\} }||dd| \} }| | |dd<t d t |D]r} || } || } d | d zd zt|z}d | dz}||||s| |||d{V}| S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#book-instrument_name :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 :param str [params.bookSubscriptionType]: The subscription type. Allowed values: SNAPSHOT full snapshot. This is the default if not specified. SNAPSHOT_AND_UPDATE delta updates :param int [params.bookUpdateFrequency]: Book update interval in ms. Allowed values: 100 for snapshot subscription 10 for delta subscription :returns dict: A dictionary of `order book structures ` indexed by market symbols N2rUr)bookSubscriptionTypeSNAPSHOT_AND_UPDATEr*bookUpdateFrequencyrbook.rE. orderbook:rQ) load_marketsmarket_symbols safe_valuehandle_option_and_paramsrangelenmarketstrappendwatch_public_multiplerR)r@r[rRrUtopics messageHashes topicParamsr^bookSubscriptionType2r`bookUpdateFrequency2irQrj currentTopic messageHash orderbooks rBrTz&cryptocom.watch_order_book_for_symbolsks&!!!!!!!!!%%g..  Eoofh77  !F8 # $'+'D'DVM]_uxM(N(N$f(,(E(EfNhkACW)X)X%v3Hx/0"#&*&C&CFL\^s&t&t#V'+'D'DVMgi~AT(U(U$f  +7KF8 3 4q#g,,'' ( (AQZF[[((F'&,6` indexed by market symbols NrRr]rUr)r^r_r*r`rrarErbrcrQz unsubscribe:rv) rdrerHrfrgrhrirjrkrlun_watch_public_multiple)r@r[rUrnsubMessageHashesrorRrpr^rqr`rrrsrQrjrtrus rBrXz)cryptocom.un_watch_order_book_for_symbolssI!!!!!!!!!%%g.. !!&'266oofh77  !F8 # $'+'D'DVM]_uxM(N(N$f(,(E(EfNhkACW)X)X%v3Hx/0"#&*&C&CFL\^s&t&t#V'+'D'DVMgi~AT(U(U$f  +7KF8 3 4q#g,,'' ( (AQZF[[((F'&,6 > > MM, ' ' ' '22;XhjprxyyyyyyyyyrCc||d}||d}||d}||||gdS)Nr) safe_floatrH storeArray)r@booksidedeltapriceamountcounts rB handle_deltazcryptocom.handle_deltas^q))**!!%++UFE233333rCc~tdt|D]}||||dS)Nr)rhrir)r@rdeltasrss rB handle_deltaszcryptocom.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3rCrLc||d}||}|d}||d}||d}||d}||jvr4||d}|i||j|<|j|} ||d} ||dd } |} | d kr=| i|| d<|| d <||| d <| | d <n||di} ||d} | d }|| krF| ddd}|r-t|j dz| |z| | d|| dg| | d|| dg| | d <| |j|<d|z}|| |dS)Ninstrument_namerQdatartdepthchannelusbook timestampdatetimenonceupdatepur)r8T asksbidsrc) safe_string safe_marketrfrH orderbookscounted_order_booksafe_integer_2rKiso8601 handle_optionrrEorderbook_checksum_messagerresolve)r@rLrMmarketIdrjrQrrrRrvrrbooks previousNonce currentNoncer8rus rBhandle_order_bookzcryptocom.handle_order_booksZp##G->??!!(++!w//tQ''%%dC00 $/))%%gw77E&*&=&=b%&H&HDOF #OF+ ""7I66##D#s33 f   OOB   "(Ih %.Ik "$(LL$;$;Ij !!&Ig  OOD(B77E --dD99M$W-L},,--.> DQQa'# 8W8WX^8_8_(_``` 9V,dooeVR.P.PQQQ 9V,dooeVR.P.PQQQ" '"+"V+ y+.....rCsincecDK||g|||d{VS)a: get the list of most recent trades for a particular symbol https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#trade-instrument_name :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_symbols)r@rQrrRrUs rB watch_tradeszcryptocom.watch_trades%s622F8UE6RRRRRRRRRrCc@K||g|d{VS)a get the list of most recent trades for a particular symbol https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#trade-instrument_name :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)un_watch_trades_for_symbolsrYs rBun_watch_tradeszcryptocom.un_watch_trades3s255vhGGGGGGGGGrCc K|d{V||}g}tdt|D]?}||}||}d|dz} || @||||d{V} |jrB|| d} | | d} | | |}| | ||ddS)a= get the list of most recent trades for a particular symbol https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#trade-instrument_name :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 ` Nrtrade.rErQrT) rdrerhrirjrlrm newUpdatesrfrgetLimitfilter_by_since_limit) r@r[rrRrUrnrsrQrjrttradesfirst tradeSymbols rBrz"cryptocom.watch_trades_for_symbols?s*!!!!!!!!!%%g..q#g,,'' ( (AQZF[[((F(6$<7L MM, ' ' ' '11&&&IIIIIIII ? 8OOFA..E**5(;;KOOK77E))&% TRRRrCcK|d{V||}g}g}tdt|D]]}||}||}d|dz}|d|dz||^|d|||||d{VS)a get the list of most recent trades for a particular symbol https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#trade-instrument_name :param str[] [symbols]: list of unified market symbols to unwatch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrrrEzunsubscribe:trades:rQr)rdrerhrirjrlrx) r@r[rUrnrorsrQrjrts rBrz%cryptocom.un_watch_trades_for_symbolsZs!!!!!!!!!%%g.. q#g,,'' ( (AQZF[[((F(6$<7L  !69I!I J J J MM, ' ' ' '228WmU[]ceklllllllllrCc||d}||d}||d}||}|d}||j|}|5||jdd} t | }||j|<||dg} t| } | dkrdS|| |} tdt| D]} | | | | d |zd }| ||| ||dS) Nrr subscriptionrQ tradesLimitrrrb) rrrfrrHr;rri parse_tradesrhrlreplacer)r@rLrMrrsymbolSpecificMessageHashrjrQstoredrRr dataLength parsedTradesjchannelReplaceds rB handle_tradeszcryptocom.handle_tradespsq.""7I66##G->??$($4$4Wn$M$M!!!(++!f55 >%%dlM4HHE&&F"(DK w33YY ?? F((v66 q#l++,, + +A MM,q/ * * * *!//#."==v8999v/////rCcHK|d{Vd}|||}|d}d}||dz|dzn|}|||d{V}|jr|||}|||||dS)aO watches information on multiple trades made by the user https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#user-trade-instrument_name :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 ` NrQ user.traderbrETrdrjwatch_private_subscriberrfilter_by_symbol_since_limit)r@rQrrRrUrjrurs rBwatch_my_tradeszcryptocom.watch_my_trades!!!!!!!!!  [[((FH%F" =C=O{S(6$<77Va 33KHHHHHHHH ? 3OOFE22E00tTTTrCcK|d{V||}d|dz}|||d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#ticker-instrument_name :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 ` Nticker.rE)rdrj watch_public)r@rQrUrjrus rB watch_tickerzcryptocom.watch_tickerss!!!!!!!!!V$$$vd|3 &&{F;;;;;;;;;rCcK|d{V||}d|dz}d|dz}|d|dg|g|g|g|d{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#ticker-instrument_name :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 ` NrrEunsubscribe:ticker:rQticker)rdrjrx)r@rQrUrjsubMessageHashrus rBun_watch_tickerzcryptocom.un_watch_tickers!!!!!!!!!V$$'&,6+fX.>> 228fX>N=OR]Q^ao`ptBsCEKLLLLLLLL LrCcHK|d{V||dd}g}||}tdt |D]"}||}|d|z#|jddd}|}dd |i|d } |||| | ||d{V} |j ri} | | | d <| S| |j d |S) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#ticker-instrument_name :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 ` NFrrr4r!r2 subscribechannelsrFrUrrQ) rdre market_idsrhrirlr:rwatch_multipleextendrfilter_by_arraytickers) r@r[rUro marketIdsrsrurlrErequestrresults rB watch_tickerszcryptocom.watch_tickerssX!!!!!!!!!%%gtU;; OOG,, q#i..)) 7 7A |H  X!5 6 6 6 6it$X. ZZ\\!M   **3 t{{7TZ?[?[]jkkkkkkkk ? F'-F6(# $M##DL(GDDDrCcK|d{V||dd}g}g}||}tdt |D]B}||}||}|d|z|d|zC|d|||||d{VS)a unWatches a price ticker https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#ticker-instrument_name :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 ` NFrrrr)rdrerrhrirlrx) r@r[rUroryrrsrrQs rBun_watch_tickerszcryptocom.un_watch_tickerss!!!!!!!!!%%gtU;; OOG,, q#i..)) A AA |HQZF  # #I$8 9 9 9  !6!? @ @ @ @228WmUegwyAAAAAAAA ArCc|||||d}||d}||}||dg}t dt |D]H}||}|||} | d} | |j| <|| |IdS)NrrrrrQ) handle_bid_askrrrfrhriparse_ws_tickerrr) r@rLrMrurrjrrsrparsedrQs rB handle_tickerzcryptocom.handle_ticker s2 FG,,,&&w?? ##G->??!!(++w33q#d))$$ 0 0A!WF))&&99FH%F#)DL NN6; / / / /  0 0rCrrjc(||d}||d}|||d}||d}||d}|id|dd|d||d ||d d ||d d ||dd||dd||dd||dddddd|d|ddddd||ddd||d|dkr||d nd|d!|S)"Nrrs_quotearQrrhighhlowlbidb bidVolumebsaskk askVolumeksvwapopencloselast previousClosechange percentagecaveragevUSDvv) baseVolume quoteVolumeinfo)rHrr safe_tickerr safe_number)r@rrjrrrrs rBrzcryptocom.parse_ws_ticker/s"$%%fc22 ##FC00!!(FC88  11,,! fX&! !   Y//!  D$$VS11 ! 4##FC00 ! 4##FC00 !  ))&$77!  4##FC00!  ))&$77!  D!  D!  T!  D!  T!  d! $**6377!! " t#! $**6377>Cunn4++FD999SW)! ! ! * + rCcK|d{V||dd}g}g}||}tdt |D]@}||}|d||z|d|zA|jddd}|} d d |i| d } |||| | ||d{V} |j ri} | | | d <| S| |j d |S) a https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#ticker-instrument_name 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 ` NFrbidask.rr4r!r2rrrrQ) rdrerrhrirlr:rrrrrbidsasks) r@r[rUrornrrsrrrEr newTickersrs rBwatch_bids_askszcryptocom.watch_bids_asks]sx!!!!!!!!!%%gtU;; OOG,, q#i..)) 0 0A |H  WQZ!7 8 8 8 MM)h. / / / /it$X. ZZ\\!F    ..sM4;;wX^C_C_anoooooooo ? G,6GJx( )N##DM8WEEErCc||dg}||di}||}|d}||j|<d|z}|||dS)NrrrQr ) safe_list safe_dictparse_ws_bid_askr r)r@rLrMrr parsedTickerrQrus rBrzcryptocom.handle_bid_asksy~~gvr22a,,,,V44 h' , f&( |[11111rCc ||d}|||}||d}||d}|||||||d||d||d||d|d|S) NrsrQrrrrr)rQrrrrrrr)rrrHr r)r@rrjrrQrs rBrzcryptocom.parse_ws_bid_asks##FC00!!(F33!!&(33%%fc22 " Y//##FC00))&$77##FC00))&$77 ! !     rC1m timeframecrK|d{V||}|d}||j||}d|zdz|dz}|||d{V} |jr| ||}|| ||ddS)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#candlestick-time_frame-instrument_name :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 NrQ candlestick.rbrErT)rdrjr timeframesrrrr) r@rQrrrRrUrjintervalruohlcvs rB watch_ohlcvzcryptocom.watch_ohlcvs!!!!!!!!!V$$!##DOY JJ)H4s:VD\I '' V<<<<<<<< ? 2NN6511E))%q$GGGrCc `K|d{V||}|d}||j||}d|zdz|dz}d|dzdz|z}d|d|ggi}|d |dg|g|g|g||d{VS) a5 unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#candlestick-time_frame-instrument_name :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume NrQrrbrEzunsubscribe:ohlcv::symbolsAndTimeframesr)rdrjrrrx) r@rQrrUrjrrru subExtends rBun_watch_ohlcvzcryptocom.un_watch_ohlcvs!!!!!!!!!V$$!##DOY JJ,x7#=t L*VH-==CiO "fX&6 %B$C 227VH=M??!!(++!##GZ88''11 "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *w//q#d))$$ " "A7D%%dF33F MM& ! ! ! !v{+++++rCcHK|d{Vd}|||}|d}d}||dz|dzn|}|||d{V}|jr|||}|||||dS)aO watches information on multiple orders made by the user https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#user-order-instrument_name :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 ` NrQ user.orderrbrETr)r@rQrrRrUrjruorderss rB watch_orderszcryptocom.watch_ordersrrCcZ||d}||d}||dg}t|}|dkr|j0||jdd}t ||_|j} ||} tdt| D]} | | | | | || | || | ddSdS)Nrrrr ordersLimitrr+) rrfrir,rHr;r parse_ordersrhrlr) r@rLrMrrrr, ordersLengthrRrrrss rB handle_orderszcryptocom.handle_orderss'>""7I66$($4$4Wn$M$M!&"556{{ !  {"))$, tLL4U;; [F&&v..F1c&kk** ) ) fQi(((( NN6#< = = = NN67 + + + NN6< 0 0 0 0 0  rCcBK|d{V|d{V|jddd}|}dddgi|d}d }||}||sd d |z}||} || || d d d} | d dd} | r=| r;|j 4| d d{V} | | |||dS| |||||d{V} |jr| S| |j |||dS)a? watch all open positions https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#user-position_balance :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 ` Nr4r!r3rruser.position_balancer positions::,r-r6Tr7)rd authenticater:rreis_emptyjoinrLset_positions_cacherr5futurefilter_by_symbols_since_limitwatchrr)r@r[rrRrUrrErrurLr6r7snapshot newPositionss rBwatch_positionszcryptocom.watch_positions,s!!!!!!!!!!!!!!!!!!it$Y/ ZZ\\!45   " %%g..}}W%% 3'!2!22KS!!   111!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e ! ]&< ]AW#]]+CDDDDDDDDH55hPUW[\\ \!ZZ[$++gv:V:VWWWWWWWW ?  11$.'5RWY]^^^rCc|ddd}|r@d}||jvr3||||j||dSdSt |_dS)Nr-r6F)rfuturesr<spawnload_positions_snapshotrr5)r@rLtyper[r6rus rBr;zcryptocom.set_positions_cacheSs!%!3!34DF^`e!f!f ! 82K6>11 k*** 47MMMMM21677DNNNrCcK|d{V}t|_|j}tdt |D]<}||}||dd}|dkr||=||jvr:|j|}||||ddSdS)Nr contractsr5) fetch_positionsrr5rhrir rlrCr) r@rLrur5cacherspositionrHr<s rBrEz!cryptocom.load_positions_snapshot]s..00000000 133q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5+ . . . . . ) (rCc6||dg}||di}||dg}|jt|_|j}g}tdt |D]I}||} || } || || J||d} tdt | D]}| |} | d} | d}|d}| |d|d }| |s| || | |ddS) Nrrr5z positions::r6r{r7rQF) rfr5rrhriparse_positionrlfind_message_hashessplitrr9r)r@rLrMr firstData rawPositionsrJr@rs rawPositionrKroruparts symbolsStringr[r5s rBhandle_positionszcryptocom.handle_positionsls6w33OOD!R00 y+rBB > !577DN q#l++,, # #A&q/K**;77H    ) ) ) LL " " " "00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111rCcBKd}|||d{VS)ar watch balance and get the amount of funds available for trading or funds locked in orders https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#user-balance :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` user.balanceN)r)r@rUrus rB watch_balancezcryptocom.watch_balances5% 11+vFFFFFFFFFrCc||d}||dg}||ddg}||jd<tdt |D]}||}||d}||} |} ||d| d<||d | d <| |j| <||j|_||j|||d } ||j| dS) Nrrrposition_balancesrrquantitytotal reserved_qtyusedrE) rrfbalancerhrisafe_currency_codeaccount safe_balancer) r@rLrMrurpositionBalancesrsr_ currencyIdcoderamessageHashRequests rBhandle_balancezcryptocom.handle_balancesY\&&w?? w33??474GLL# Vq#.//00 ; ;A&q)G))'3DEEJ**:66DllnnG#//DDGG "..wGGGFO!(DL ,,T\::DLLt|[111!--gt<<t|%788888rCrFsiderrcK|d{V|||||||}d|d}|}|||d{VS)a https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#private-create-order 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 exchange API endpoint :returns dict: an `order structure ` Nprivate/create-orderrFrU)rdcreate_order_requestrwatch_private_request) r@rQrFrhrrrUrrus rBcreate_order_wszcryptocom.create_order_wss!!!!!!!!!**64vufUU,  jjll // WEEEEEEEEErCrEcK|d{V||||||}d|d}|} || |d{VS)ar edit a trade order https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#private-amend-order :param str id: order id :param str symbol: unified market symbol of the order to edit :param str [type]: not used by cryptocom editOrder :param str [side]: not used by cryptocom editOrder :param float amount:(mandatory) how much of the currency you want to trade in units of the base currency :param float price:(mandatory) the price for the order, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.clientOrderId]: the original client order id of the order to edit, required if id is not provided :returns dict: an `order structure ` Nprivate/amend-orderrk)rdedit_order_requestrrm) r@rErQrFrhrrrUrrus rB edit_order_wszcryptocom.edit_order_wss !!!!!!!!!((VVUFKK+  jjll // WEEEEEEEEErCc||d}||di}||}|||dS)NrEr)rrf parse_orderr)r@rLrMrurawOrderorders rB handle_orderzcryptocom.handle_orders[&&w55 ??7Hb99  **uk*****rCcK|d{V|d|i|}d|d}|}|||d{VS)a cancels an open order https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#private-cancel-order :param str id: the order id of the order to cancel :param str [symbol]: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` Norder_idprivate/cancel-orderrk)rdrrrm)r@rErQrUrrus rBcancel_order_wszcryptocom.cancel_order_ws*s!!!!!!!!!  -  jjll // WEEEEEEEEErCc K|d{Vd}d|i|d}|&||}|d|dd<|}|||d{VS)a cancel all open orders https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#private-cancel-all-orders :param str symbol: unified market symbol of the orders to cancel :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict} Returns exchange raw message {@link https://docs.ccxt.com/?id=order-structure: Nprivate/cancel-all-ordersrkrErUr)rdrrjrrm)r@rQrUrjrrus rBcancel_all_orders_wszcryptocom.cancel_all_orders_ws@s!!!!!!!!!1kk"f--    [[((F39$r@rurUrrErrMs rBrzcryptocom.watch_publicasit$X. ZZ\\![M   ++gv..ZZ[';GGGGGGGGGrCcK|jddd}|}dd|i|d}|||}|||||d{VSr)r:rr=r)r@rornrUrrErrMs rBrmzcryptocom.watch_public_multiplensit$X. ZZ\\!F   ""7F33((mWmTTTTTTTTTrCtopicroryrnc HK|jddd}|} dd|i| t| d} t| ||||d} || |} |||| ||| |d{VS)Nr4r!r2 unsubscriber)rFrUrrE)rErr[ryro)r:rrkr=rr) r@rr[roryrnrUr!rrErrrMs rBrxz"cryptocom.un_watch_public_multiple{sit$X. ZZ\\#Fb''   b'' 0*   ""7F33((mWmUYU`U`amoxUyUyzzzzzzzzzrCcK|d{V|jddd}||d}|||}||t ||dd{VS)Nr4r!r3)rErT)r8r:rr>rk)r@rrUrrrMs rBrmzcryptocom.watch_private_requests!!!!!!!!!it$Y/  ++gv..ZZSZZ$?????????rCcK|d{V|jddd}|}dd|gi|d}|||}|||||d{VS)Nr4r!r3rrr)r8r:rrr>rs rBrz!cryptocom.watch_private_subscribes!!!!!!!!!it$Y/ ZZ\\![M   ++gv..ZZ[';GGGGGGGGGrCc`||d}||d} |r|dkr|jdz||z}||jd||||d}|"||jd||t|dS#t$r`}t|tr*d }| ||||j vr|j |=n| ||Yd}~d Sd}~wwxYw) NrEre0rexactrMbroadF authenticatedT) rrEjsonthrow_exactly_matched_exception exceptionsrfthrow_broadly_matched_exceptionrrI isinstancerreject subscriptions) r@rLrMrE errorCodefeedback messageStringrNrus rBhandle_error_messagezcryptocom.handle_error_messagesT  gt , ,$$Wf55   .Y#--7S=499W+=+==44T_W5MyZbccc $ C C  ,889QS`bjkkk#H---5   !011 %-  a---&"666,[9 a$$$44444 sBC D- AD((D-c |j|j|j|j|j|j|j|j|jd }||dd}||d}|/| ddkr||||+| dr|||| ||}||||dSdS)N) candlestickrtraderz book.updater+rrWr4rrrrr+) r)rrrr2rgrU safe_value_2rfind startswithrf)r@rLrMmethodsrrrFs rBhandle_subscribezcryptocom.handle_subscribes ,('*1,, /%)%:   ""7Hf==""6955  W\\,%?%?"%D%D   vv . . .  W%7%7 %E%E    vv . . .'22   F66 " " " " "  rCc ,|||rdS||d}|j|j|j|j|j|j|j|j|j|jd }|||}||||dSdS)NrF) rzpublic/heartbeat public/authrjrprzr}zprivate/close-positionrr) rr handle_pinghandle_authenticaterwrrhandle_unsubscriberf)r@rLrMrFr callMethods rBhandle_messagezcryptocom.handle_messagesD  $ $VW 5 5  F!!'844 $ 03$($5#'#4$($5)-)F&*&7.2   __Wf55  ! Jvw ' ' ' ' ' " !rCcvK||jddd}||}d}||}||j|}|d}t |}||z|jz|z} | | | | |j tj } ||||j| d} || |} |||| ||d{VS)Nr4r!r3rr)rErrFapi_keysig)check_required_credentialsr:rLreusableFuturerfrrkrapiKeyhmacencodesecrethashlibsha256rr>) r@rUrrLrur<rrFrauth signaturerrMs rBr8zcryptocom.authenticates/ '')))it$Y/S!!% &&{33(DK/%7D $++d"3"3T[[5M5Mw~^^I ; Gkk'622G JJsK+ > > >||||||rCc>||j||dSN)rDrP)r@rLrMs rBrzcryptocom.handle_ping*s  49fg.....rCcf||jd}|ddS)NrT)rfrCr)r@rLrMr<s rBrzcryptocom.handle_authenticate-s1AAtrCct||d}t|j}t dt |D]}||}||jvr|dr|j|}||d}||krS||dg} ||dg} t dt | D])} | | } | | } ||| | *| |dS)NrErrrory) rlistrkeysrhrirrclean_unsubscription clean_cache)r@rLrMrErrsrursubIdroryr unsubHashsubHashs rBrzcryptocom.handle_unsubscribe4sN   gt , ,F(--//00q#d))$$ / /Aq'K6#777%%m44 /%3K@ ((t<<;; $|_b Q Q #'>>,@RTV#W#W q#m"4"455JJA -a 0I.q1G--fgyIIII  ...! / /rCr)O__name__ __module__ __qualname__rr?rPrkr rrVrZrrTrXrrrrrrrrrrrrrrrrrrrrdictr rrrrrrr"r)r r-r2rrAr;rErUrrXrgrrfloatr rnrrrwr{r~rrrmrxrmrr rrrr8rrr __classcell__)rAs@rBrrs , #, , , , , , \    @DB P PS P PS\ P P P P=? L L L3 L L L LSW_a)!)!$s))!C)!fo)!)!)!)!VPR)z)zT#Y)zV_)z)z)z)zV444 333X/X/X/X/X/t<@d[] S S SS S Sbfglbm S S S S9; H HC HtE{ H H H HOSaenpSSd3iSS[^SuyzvASSSS6LNmmcmRUmmmm,*0F*0*0*0*0X37TX\egUUCUsURUUlpqvlwUUUU068 < < rs AAAAAAAAAAAAZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZZ444444******000000))))))******u/u/u/u/u/",u/u/u/u/u/rC