":hddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lm Z Gd d ejBjDZ"y) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesIntMarketNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError) NetworkError) ChecksumErrorc eZdZdeffd ZdZdifdededefdZ ifdedefdZ difd e ededefd Z ifd e edefd Z d Zd ZdefdZddifdededede efdZifdede efdZddifd e ededede efdZifd e edefdZdefdZdddifdededede efdZifdedefdZifdedefdZdifd edefdZdifd edefdZ defdZ!dHde"de#defdZ$difd edefdZ%defd Z&dHd!Z'd"ddifdededede e(fd#Z)d"ifdedefd$Z*defd%Z+dddifdededede e,fd&Z-dHdefd'Z.dddifd ededede e/fd(Z0dHded efd)Z1d*Z2d+Z3ifde4fd,Z5defd-Z6difded.e7d/e8d0e9d1e:de,f d2Z;defd3Zdefd7Z?ifd8Z@ifd9ZAiifd:ed e ed;e edZBifd?ZCifd@ZDdefdAZEdefdBZFdefdCZGifdDZHdefdEZIdefdFZJdefdGZKxZLS)I cryptocomreturnc|jtt|iddddddddddddddd dd dd dd dd dddddddddddddidddddddddididS)NwsT watchBalance watchTicker watchTickers watchBidsAsks watchMyTrades watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders watchOHLCVwatchPositions createOrderWs cancelOrderWscancelAllOrdersz*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 L/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/cryptocom.pyr=zcryptocom.describes5i ? Adt       t(!$+Dtd!$   "4!("N#MLJ /3.2# # Q*D * * c K |j|j|dddd{y7#t$rE}t|jdz|j |z}|j |Yd}~yd}~wwxYww)Nidzpublic/respond-heartbeat)rCmethodz pong failed with error )send safe_integer ExceptionrrCjsonreset)r>clientmessageeerrors r@pongzcryptocom.pongAsp  ++T%6%6w%EQklm m m  +E!E RS !TUE LL   s6B'313B3 B;A<7B<BBNsymbollimitcFK|j|g||d{S7w)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>rOrPparamss r@watch_order_bookzcryptocom.watch_order_bookMs%66xOOOO !!cDK|j|g|d{S7w)aS 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>rOrSs r@un_watch_order_bookzcryptocom.un_watch_order_book\s#996(FKKKK   symbolscK|jd{|j|}g}g}|sd}|j|d}|i|d<d}d}|j|ddd\}}|j|dd|\}}||dd<d} d} |j|dd\} }|j|dd| \} }| | |dd<t d t |D]Y} || } |j | } d | d zd zt|z}d | dz}|j||j|[|j|||d{}|jS7H7w)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 N2rSr(bookSubscriptionTypeSNAPSHOT_AND_UPDATEr)bookUpdateFrequencyrbook.rC. orderbook:rO) load_marketsmarket_symbols safe_valuehandle_option_and_paramsrangelenmarketstrappendwatch_public_multiplerP)r>r[rPrStopics messageHashes topicParamsr^bookSubscriptionType2r`bookUpdateFrequency2irOrj currentTopic messageHash orderbooks r@rRz&cryptocom.watch_order_book_for_symbolsjs!!!%%g. Eoofh7  !F8 # $'+'D'DVM]_uxM(N$f(,(E(EfNhkACW)X%v3Hx/0"#&*&C&CFL\^s&t#V'+'D'DVMgi~AT(U$f  +7KF8 3 4q#g,' (AQZF[[(F'&,6` indexed by market symbols NrPr]rSr(r^r_r)r`rrarCrbrcrOz unsubscribe:rv) rdrerFrfrgrhrirjrkrlun_watch_public_multiple)r>r[rSrnsubMessageHashesrorPrpr^rqr`rrrsrOrjrtrus r@rWz)cryptocom.un_watch_order_book_for_symbolss!!!%%g. !!&'26oofh7  !F8 # $'+'D'DVM]_uxM(N$f(,(E(EfNhkACW)X%v3Hx/0"#&*&C&CFL\^s&t#V'+'D'DVMgi~AT(U$f  +7KF8 3 4q#g,' (AQZF[[(F'&,6 MM, ' (22;Xhjprxyyy9 "8zs"E;E6EE;1E92E;9E;c|j|d}|j|d}|j|d}|j|||gy)Nr) safe_floatrF storeArray)r>booksidedeltapriceamountcounts r@ handle_deltazcryptocom.handle_deltasIq)*!!%+UFE23rAcbtdt|D]}|j|||y)Nr)rhrir)r>rdeltasrss r@ handle_deltaszcryptocom.handle_deltass0q#f+& 3A   hq 2 3rArJc|j|d}|j|}|d}|j|d}|j|d}|j|d}||jvr1|j|d}|j i||j|<|j|} |j|d} |j |dd } |} | d k(r5| ji|| d<|| d <|j|| d <| | d <nn|j|di} |j|d} | d }|| k7r?|jddd}|r*t|jdz|j|z|j| d|j| dg|j| d|j| dg| | d <| |j|<d|z}|j| |y)Ninstrument_namerOdatartdepthchannelusbook timestampdatetimenonceupdatepur(r6T asksbidsrc) safe_string safe_marketrfrF orderbookscounted_order_booksafe_integer_2rIiso8601 handle_optionrrCorderbook_checksum_messagerresolve)r>rJrKmarketIdrjrOrrrPrvrrbooks previousNonce currentNoncer6rus r@handle_order_bookzcryptocom.handle_order_booksp##G->?!!(+!w/tQ'%%dC0 $//)%%gw7E&*&=&=b%&HDOOF #OOF+ ""7I6##D#s3 f  OOB "(Ih %.Ik "$(LL$;Ij !!&Ig OOD(B7E --dD9M$W-L},--.> DQ'# 8W8WX^8_(_`` 9V,dooeVR.PQ 9V,dooeVR.PQ" '"+"V+ y+.rAsincecHK|j|g|||d{S7w)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>rOrrPrSs r@ watch_tradeszcryptocom.watch_trades$s'22F8UE6RRRRs " "cDK|j|g|d{S7w)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_symbolsrXs r@un_watch_tradeszcryptocom.un_watch_trades2s#55vhGGGGrZcK|jd{|j|}g}tdt|D]1}||}|j |}d|dz} |j | 3|j |||d{} |jr6|j| d} |j| d} | j| |}|j| ||ddS77]w)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.rCrOrT) rdrerhrirjrlrm newUpdatesrfrgetLimitfilter_by_since_limit) r>r[rrPrSrnrsrOrjrttradesfirst tradeSymbols r@rz"cryptocom.watch_trades_for_symbols>s!!!%%g.q#g,' (AQZF[[(F(6$<7L MM, '  ( 11&&&II ??OOFA.E**5(;KOOK7E))&% TRR "Js#C-C)A6C- C+AC-+C-chK|jd{|j|}g}g}tdt|D]H}||}|j |}d|dz}|j d|dz|j |J|j d|||||d{S77w)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 ` NrrrCzunsubscribe:trades:rOr)rdrerhrirjrlrx) r>r[rSrnrorsrOrjrts r@rz%cryptocom.un_watch_trades_for_symbolsYs!!!%%g. q#g,' (AQZF[[(F(6$<7L  !69I!I J MM, '  ( 228WmU[]ceklll "ms"B2B.BB2)B0*B20B2c|j|d}|j|d}|j|d}|j|}|d}|j|j|}|7|j |j dd} t | }||j|<|j|dg} t| } | dk(ry|j| |} tdt| D]} |j| | |jd |zd }|j|||j||y) Nrr subscriptionrO tradesLimitrrrb) rrrfrrFr9rri parse_tradesrhrlreplacer)r>rJrKrrsymbolSpecificMessageHashrjrOstoredrPr dataLength parsedTradesjchannelReplaceds r@ handle_tradeszcryptocom.handle_tradesos2.""7I6##G->?$($4$4Wn$M!!!(+!f5 >%%dllM4HE&F"(DKK w3Y ? ((v6 q#l+, +A MM,q/ * +!//#."=v89v/rAc2K|jd{d}||j|}|d}d}| |dz|dzn|}|j||d{}|jr|j ||}|j ||||dS7|79w)aQ 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 ` NrO user.traderbrCTrdrjwatch_private_subscriberrfilter_by_symbol_since_limit)r>rOrrPrSrjrurs r@watch_my_tradeszcryptocom.watch_my_trades!!!  [[(FH%F" =C=O{S(6$<7Va 33KHH ??OOFE2E00tTT "I"BBABB8BBcK|jd{|j|}d|dz}|j||d{S777w)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.rC)rdrj watch_public)r>rOrSrjrus r@ watch_tickerzcryptocom.watch_tickersW!!!V$$vd|3 &&{F;;; "` NrrCunsubscribe:ticker:rOticker)rdrjrx)r>rOrSrjsubMessageHashrus r@un_watch_tickerzcryptocom.un_watch_tickers!!!V$'&,6+fX.>> 228fX>N=OR]Q^ao`ptBsCEKLL L "Ls"A%A!AA%A#A%#A%cK|jd{|j|dd}g}|j|}tdt |D]}||}|j d|z|j ddd}|j}dd |i|d } |j|||j| ||d{} |jr i} | | | d <| S|j|jd |S77;w) 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 ` NFrrr2r r0 subscribechannelsrDrSrrO) rdre market_idsrhrirlr8rwatch_multipleextendrfilter_by_arraytickers) r>r[rSro marketIdsrsrurlrCrequestrresults r@ watch_tickerszcryptocom.watch_tickerss"!!!%%gtU; OOG, q#i.) 7A |H  X!5 6 7iit$X. ZZ\!M  **3 t{{7TZ?[]jkk ??F'-F6(# $M##DLL(GDD+ " ls"DDB1DD :DDcfK|jd{|j|dd}g}g}|j|}tdt |D]4}||}||}|j d|z|j d|z6|j d|||||d{S77w)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[rSroryrrsrrOs r@un_watch_tickerszcryptocom.un_watch_tickerss!!!%%gtU; OOG, q#i.) AA |HQZF  # #I$8 9  !6!? @  A 228WmUegwyAA A "As"B1B-BB1(B/)B1/B1cf|j|||j|d}|j|d}|j|}|j|dg}t dt |D]?}||}|j ||} | d} | |j| <|j| |Ay)NrrrrrO) handle_bid_askrrrfrhriparse_ws_tickerrr) r>rJrKrurrjrrsrparsedrOs r@ handle_tickerzcryptocom.handle_ticker s2 FG,&&w? ##G->?!!(+w3q#d)$ 0A!WF))&&9FH%F#)DLL NN6; /  0rArrjc|j|d}|j|d}|j||d}|j|d}|j|d}|jid|dd|d|j |d |j |d d |j |d d |j |dd|j |dd|j |dd|j |dddddd|d|ddddd|j|ddd|j|d|dk(r|j|d nd|d!|S)"Nrrs_quotearOrrhighhlowlbidb bidVolumebsaskk askVolumeksvwapopencloselast previousClosechange percentagecaveragevUSDvv) baseVolume quoteVolumeinfo)rFrr safe_tickerr safe_number)r>rrjrrrrs r@rzcryptocom.parse_ws_ticker.s$%%fc2 ##FC0!!(FC8  1,! fX&! !   Y/!  D$$VS1 ! 4##FC0 ! 4##FC0 !  ))&$7!  4##FC0!  ))&$7!  D!  D!  T!  D!  T!  d! $**637!! " t#! $**637>Cun4++FD9SW)! * + rAcDK|jd{|j|dd}g}g}|j|}tdt |D]2}||}|j d||z|j d|z4|j ddd}|j} d d |i| d } |j|||j| ||d{} |jr i} | | | d <| S|j|jd |S77<w) 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.rr2r r0rrrrO) rdrerrhrirlr8rrrrrbidsasks) r>r[rSrornrrsrrrCr newTickersrs r@watch_bids_askszcryptocom.watch_bids_asks\s<!!!%%gtU; OOG, q#i.) 0A |H  WQZ!7 8 MM)h. / 0iit$X. ZZ\!F   ..sM4;;wX^C_anoo ??G,6GJx( )N##DMM8WEE/ "$ps"D DC D !D":D D c|j|dg}|j|di}|j|}|d}||j|<d|z}|j ||y)NrrrOr ) safe_list safe_dictparse_ws_bid_askrr)r>rJrKrr parsedTickerrOrus r@rzcryptocom.handle_bid_asksf~~gvr2a,,,V4 h' , f&( |[1rAc f|j|d}|j||}|j|d}|j|d}|j|||j ||j|d|j|d|j|d|j|d|d|S) NrsrOrrrrr)rOrrrrrrr )rrrFr r)r>rrjrrOrs r@rzcryptocom.parse_ws_bid_asks##FC0!!(F3!!&(3%%fc2 " Y/##FC0))&$7##FC0))&$7 !    rA1mc^K|jd{|j|}|d}|j|j||}d|zdz|dz}|j ||d{} |j r| j ||}|j| ||ddS779w)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 NrO candlestick.rbrCrT)rdrjr timeframesrrrr) r>rO timeframerrPrSrjintervalruohlcvs r@ watch_ohlcvzcryptocom.watch_ohlcvs!!!V$!##DOOY J)H4s:VD\I '' V<< ??NN651E))%q$GG " =s"B-B)AB-1B+28B-+B-c @K|jd{|j|}|d}|j|j||}d|zdz|dz}d|dzdz|z}d|d|ggi}|j d |dg|g|g|g||d{S77w) 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 NrOrrbrCzunsubscribe:ohlcv::symbolsAndTimeframesr)rdrjrrrx) r>rOrrSrjrrru subExtends r@un_watch_ohlcvzcryptocom.un_watch_ohlcvs!!!V$!##DOOY J,x7#=t L*VH-==CiO "fX&6 %B$C 227VH=MBBBBc|j|d}|j|d}|j|}|d}|j|d}|j|}|j|j|i|j|<|j|j||} | :|j |j dd} t| } | |j||<|j|d} tdt| D]*} | | } |j| |}| j|,|j| |y) NrrrOr OHLCVLimitrrr) rrfind_timeframerfohlcvsrFr9rrhri parse_ohlcvrlr)r>rJrKrurrjrOrrrrPrrstickrs r@ handle_ohlcvzcryptocom.handle_ohlcvs8&&w? ##G->?!!(+!##GZ8''1 "oodkk62F FV!4i@ >%%dllL$GE*51F-3DKK  *w/q#d)$ "A7D%%dF3F MM& ! " v{+rAc2K|jd{d}||j|}|d}d}| |dz|dzn|}|j||d{}|jr|j ||}|j ||||dS7|79w)aQ 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 ` NrO user.orderrbrCTr)r>rOrrPrSrjruorderss r@ watch_orderszcryptocom.watch_ordersrrc|j|d}|j|d}|j|dg}t|}|dkDr|j-|j |j dd}t ||_|j} |j|} tdt| D]} | j| | |j| ||j| ||j| dyy)Nrrrr ordersLimitrr,) rrfrir-rFr9r parse_ordersrhrlr) r>rJrKrrrr- ordersLengthrPrrrss r@ handle_orderszcryptocom.handle_orderss>""7I6$($4$4Wn$M!&"56{ ! {{"))$,, tL4U; [[F&&v.F1c&k* ) fQi( ) NN6#< = NN67 + NN6< 0 rAcK|jd{|jd{|jddd}|j}dddgi|d}d }|j |}|j |sd d j |z}|j|} |j| ||jd d d} |jd dd} | r<| r:|j.| jd d{} |j| |||dS|j|||j||d{} |jr| S|j|j|||dS7b7M7w79w)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 ` Nr2r r1rruser.position_balancer positions::,r,r4Tr5)rd authenticater8rreis_emptyjoinrJset_positions_cacherr6futurefilter_by_symbols_since_limitwatchrr)r>r[rrPrSrrCrrurJr4r5snapshot newPositionss r@watch_positionszcryptocom.watch_positions+s!!!!!!iit$Y/ ZZ\!45  " %%g.}}W%'!22KS!   1!%!3!34DF^`d!e!%!3!34DF^`d!e !&<AW#]]+CDDH55hPUW[\ \!ZZ[$++gv:VWW ?? 11$..'5RWY]^^3 "!&EWsDFE8FE;CFE>?FF2F;F>FFc|jddd}|r@d}||jvr/|j||j|j||yyt |_y)Nr,r4F)rfuturesr=spawnload_positions_snapshotrr6)r>rJtyper[r4rus r@r<zcryptocom.set_positions_cacheRsa!%!3!34DF^`e!f !2K6>>1 k* 477M267DNrAclK|jd{}t|_|j}tdt |D]1}||}|j |dd}|dkDs!|j |3|j|}|j||j|dy7w)Nr contractsr6) fetch_positionsrr6rhrir rlrDr) r>rJrur6cacherspositionrIr=s r@rFz!cryptocom.load_positions_snapshot\s..00 13q#i.) 'A |H((;BI1} X&  '  ,uuk*1sB4B2AB4,AB4c|j|dg}|j|di}|j|dg}|jt|_|j}g}tdt |D]:}||} |j | } |j | |j | <|j|d} tdt | D]f}| |} | jd} | d}|jd}|j|d|d }|j|rU|j|| h|j|dy) Nrrr6z positions::r7r{r8rOF) rfr6rrhriparse_positionrlfind_message_hashessplitrr:r)r>rJrKr firstData rawPositionsrKrArs rawPositionrLroruparts symbolsStringr[r6s r@handle_positionszcryptocom.handle_positionsjsL6w3OOD!R0 y+rB >> !57DN q#l+, #A&q/K**;7H    ) LL "  # 00G q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |[1rAcFKd}|j||d{S7w)at 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>rSrus r@ watch_balancezcryptocom.watch_balances&% 11+vFFFFrUc|j|d}|j|dg}|j|ddg}||jd<tdt |D]}||}|j|d}|j |} |j } |j|d| d<|j|d | d <| |j| <|j|j|_|j|j||j|d } |j|j| y) Nrrrposition_balancesr rquantitytotal reserved_qtyusedrC) rrfbalancerhrisafe_currency_codeaccount safe_balancer) r>rJrKrurpositionBalancesrsr` currencyIdcoderbmessageHashRequests r@handle_balancezcryptocom.handle_balances.\&&w? w3??474GL# Vq#./0 ;A&q)G))'3DEJ**:6DllnG#//DGG "..wGGFO!(DLL ,,T\\:DL ; t||[1!--gt<t||%78rArGsiderrcK|jd{|j||||||}d|d}|j}|j||d{S7I7w)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-orderrDrS)rdcreate_order_requestrwatch_private_request) r>rOrGrirrrSrrus r@create_order_wszcryptocom.create_order_wssp!!!**64vufU, jjl // WEEE "Fs"A$A AA$A"A$"A$c|j|d}|j|di}|j|}|j||y)NrCr)rrf parse_orderr)r>rJrKrurawOrderorders r@ handle_orderzcryptocom.handle_ordersF&&w5 ??7Hb9  *uk*rArCcK|jd{|jd|i|}d|d}|j}|j||d{S7G7w)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-orderrl)rdrrrn)r>rCrOrSrrus r@cancel_order_wszcryptocom.cancel_order_wsss!!!  - jjl // WEEE "Fs"A"AAA"A A" A"cK|jd{d}d|ji|d}||j|}|d|dd<|j}|j ||d{S7c7w)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-ordersrlrCrSr)rdrrjrrn)r>rOrSrjrrus r@cancel_all_orders_wszcryptocom.cancel_all_orders_ws%s!!!1kk"f-   [[(F39$A:AA>5A<6A><A>cL|j|d}|j||y)NrC)rr)r>rJrKrus r@handle_cancel_all_ordersz"cryptocom.handle_cancel_all_orders;s$&&w5 w ,rAcK|jddd}|j}dd|gi|d}|j||}|j||||d{S7wNr2r r0rrr)r8rrr?r>rurSrrCrrKs r@rzcryptocom.watch_publicFsqiit$X. ZZ\![M  ++gv.ZZ[';GGGGsAA!AA!cK|jddd}|j}dd|i|d}|j||}|j||||d{S7wr)r8rr;r)r>rornrSrrCrrKs r@rmzcryptocom.watch_public_multipleSssiit$X. ZZ\!F  ""7F3((mWmTTTTsAA AA topicroryrnc K|jddd}|j} dd|i| t| d} t| ||||d} |j| |} |j ||| ||j | |d{S7w)Nr2r r0 unsubscriber)rDrSrrC)rCrr[ryro)r8rrkr;rr) r>rr[roryrnrSr"rrCrrrKs r@rxz"cryptocom.un_watch_public_multiple`siit$X. ZZ\#Fb'  b' 0*  ""7F3((mWmUYU`U`amoxUyzzzzsBB B B cK|jd{|jddd}||d}|j||}|j|t ||dd{S7U7w)Nr2r r1)rCrT)r9r8rr?rk)r>rrSrrrKs r@rnzcryptocom.watch_private_requestusw!!!iit$Y/ ++gv.ZZSZ$??? "@s"A0A,AA0'A.(A0.A0cK|jd{|jddd}|j}dd|gi|d}|j||}|j ||||d{S7`7w)Nr2r r1rrr)r9r8rrr?rs r@rz!cryptocom.watch_private_subscribes!!!iit$Y/ ZZ\![M  ++gv.ZZ[';GGG "Hs"A;A7AA;2A93A;9A;c,|j|d}|j|d} |r|dk7r|jdz|j|z}|j|jd|||j |d}| |j |jd||t|y#t$r\}t|tr0d }|j||||jvr |j|=n|j||Yd}~y d}~wwxYw) NrCrf0rexactrKbroadF authenticatedT) rrCrHthrow_exactly_matched_exception exceptionsrfthrow_broadly_matched_exceptionrrG isinstancerreject subscriptions) r>rJrKrC errorCodefeedback messageStringrLrus r@handle_error_messagezcryptocom.handle_error_messages   gt ,$$Wf5  Y#-77S=499W+==44T__W5MyZbc $ C  ,889QS`bjk#H-- !01-  a-&"6"66,,[9 a$ sBB.. D7ADDc |j|j|j|j|j|j|j|j |j d }|j|dd}|j|d}|&|jddkDr|j|||#|jdr|j |||j||}| |||yy)N) candlestickrtraderz book.updater,rrXr5rr rrr,) r*rrrr3rhrV safe_value_2rfind startswithrf)r>rJrKmethodsrrrDs r@handle_subscribezcryptocom.handle_subscribes,,((''**11,,,, //%)%:%:  ""7Hf=""695  W\\,%?"%D   vv .  W%7%7 %E   vv .'2   66 " rAc V|j||ry|j|d}|j|j|j|j|j|j |j|j |jd }|j||}| |||yy)NrD) rzpublic/heartbeat public/authrkrwrzzprivate/close-positionrr) rr handle_pinghandle_authenticatertr}rhandle_unsubscriberf)r>rJrKrDr callMethods r@handle_messagezcryptocom.handle_messagesD  $ $VW 5 !!'84  $ 0 033$($5$5$($5$5)-)F)F&*&7&7..22  __Wf5  ! vw ' "rAcRK|j|jddd}|j|}d}|j|}|j |j |}|d}t |j}||z|jz|z} |j|j| |j|jtj} ||||j| d} |j| |} |j||| ||d{S7w)Nr2r r1rr)rCrrDapi_keysig)check_required_credentialsr8rJr=rfrrkrapiKeyhmacencodesecrethashlibsha256rr?) r>rSrrJrur=rrDrauth signaturerrKs r@r9zcryptocom.authenticates '')iit$Y/S!% {+(<(DKK/%7D $++d"3T[[5Mw~~^I ;; Gkk'62G JJsK+ >||sDD' D%!D'c>|j|j||yN)rErN)r>rJrKs r@rzcryptocom.handle_pings 499fg.rAc^|j|jd}|jdy)NrT)rfrDr)r>rJrKr=s r@rzcryptocom.handle_authenticates$AtrAc|j|d}t|jj}t dt |D]}||}||jvr|j ds)|j|}|j|d}||k7rP|j|dg} |j|dg} t dt | D]} | | } | | } |j|| | !|j|y)NrCrrrory) rlistrkeysrhrirrclean_unsubscription clean_cache)r>rJrKrCrrsrursubIdroryr unsubHashsubHashs r@rzcryptocom.handle_unsubscribes   gt ,F((--/0q#d)$ /Aq'K6#7#77%%m4%33K@ ((t<; $|_b Q #'>>,@RTV#W q#m"45JA -a 0I.q1G--fgyIJ  .! /rAr)M__name__ __module__ __qualname__rr=rNrkr r rTrYrrRrWrrrrrrrrrrrrrrrrrrrrdictr rrrrrrr#r*r r.r3rrBr<rFrVrrYrhrrfloatr rortrxr{r}rrmrxrnrrrrr9rrr __classcell__)r?s@r@rrs2+ #+ Z  @DB PS P PS\ P=? L L3 LSW_a)!$s))!C)!fo)!VPR)zT#Y)zV_)zV4 3X/X/t<@d[] S SS S Sbfglbm S9; HC HtE{ HOSaenpSd3iSS[^SuyzvAS6LNmcmRUm,*0F*0X37TX\egUCUsURUUlpqvlwU068 < rsc AATTTTT4*0)*Y/"",,Y/rA