iddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) BalancesIntNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTrade)Client)List)AuthenticationError) NetworkError) InvalidNoncec eZdZfdZdZdifdededefdZdifde ededefd Z d Z d Z d e fd Zddifdededede efdZddifde ededede efdZd e fdZdddifdededede efdZifdedefdZd e fdZdddifdededede efdZd e fdZdddifdededede efdZd4d e fdZdddifdededede efdZ d4d e defdZ!dZ"dZ#ifde$fdZ%d e fdZ&difded e'd!e(d"e)d#e*def d$Z+d e fd%Z,difd&ededefd'Z-difdefd(Z.d e fd)Z/ifd*Z0ifd+Z1ifd,Z2ifd-Z3d e fd.Z4d e fd/Z5d e fd0Z6ifd1Z7d e fd2Z8d e fd3Z9xZ:S)5 cryptocomc|tt|ddddddddddddddddddddidd dd d ddd iid S)NTF)ws watchBalance watchTicker watchTickers watchMyTrades watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders watchOHLCVwatchPositions createOrderWs cancelOrderWscancelAllOrdersrz*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)apitestr&)fetchPositionsSnapshotawaitPositionsSnapshot)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s X/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/cryptocom.pyr6zcryptocom.describesi 6 6 ? ? A A $# %!%#)-"&,0#""&!%!%#'&"N#MLJ  !.2.2## I&D &D & & & c$K |||dddd{VdS#t$rM}t|jdz||z}||Yd}~dSd}~wwxYw)Nidzpublic/respond-heartbeat)r<methodz pong failed with error )send safe_integer Exceptionrr<jsonreset)r7clientmessageeerrors r9pongzcryptocom.pong<s  ++T%6%6w%E%EQkllmm m m m m m m m m m    +E!E RS !TUUE LL          s28 BAB  BNsymbollimitreturncBK||g||d{VS)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: 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)r7rHrIparamss r9watch_order_bookzcryptocom.watch_order_bookHs466xOOOOOOOOOr:symbolscK|d{V||}g}g}|sd}||d}|i|d<d}||dddd\}}| ||dd<d}||ddd\}}| ||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 :see: 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 N2rMr"r#bookSubscriptionTypeSNAPSHOT_AND_UPDATEbookUpdateFrequencyrzbook.r<. orderbook:rH) load_marketsmarket_symbols safe_valuehandle_option_and_params_2rangelenmarketstrappendwatch_public_multiplerI)r7rOrIrMtopics messageHashes topicParamsrRrTirHr] currentTopic messageHash orderbooks r9rLz&cryptocom.watch_order_book_for_symbolsUs!!!!!!!!!%%g..  Eoofh77  !F8 #'+'F'FvO_a{~TVk(l(l$f  +7KF8 3 4"&*&E&EfN^`z}R'S'S#V  *7KF8 3 4q#g,,'' ( (AQZF[[((F'&,6p##G->??!!(++!w//tQ''%%dC00 OODOV<<  %%gw77E//E::I""7I66##D#s33 f   OOB   "(Ih %.Ik "$(LL$;$;Ij !!&Ig  OOD(B77E --dD99M$W-L},,"47-A#AF#JS#PS`#`ci#ilq#qrrr 9V,dooeVR.P.PQQQ 9V,dooeVR.P.PQQQ" '"+"V+ y+.....r:sincecDK||g|||d{VS)@ get the list of most recent trades for a particular symbol :see: 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)r7rHrrIrMs r9 watch_tradeszcryptocom.watch_tradess622F8UE6RRRRRRRRRr:c K|d{V||}g}tdt|D]?}||}||}d|dz} || @||||d{V} |jrB|| d} | | d} | | |}| | ||ddS)rNrztrade.r<rHrT) rWrXr[r\r]r_r` newUpdatesrYrgetLimitfilter_by_since_limit) r7rOrrIrMrardrHr]retradesfirst tradeSymbols r9rz"cryptocom.watch_trades_for_symbolss*!!!!!!!!!%%g..q#g,,'' ( (AQZF[[((F(6$<7L MM, ' ' ' '11&&&IIIIIIII ? 8OOFA..E**5(;;KOOK77E))&% TRRRr:c||d}||d}||d}||}|d}||j|}|5||jdd} t | }||j|<||dg} t| } | dkrdS|| |} tdt| D]} | | | | d |zd }| ||| ||dS) Nr{rw subscriptionrH tradesLimitrxrrU) rrrYrr?r2rr\ parse_tradesr[r_replacer)r7rCrDr{rsymbolSpecificMessageHashr]rHstoredrIrx dataLength parsedTradesjchannelReplaceds r9 handle_tradeszcryptocom.handle_tradessq.""7I66##G->??$($4$4Wn$M$M!!!(++!f55 >%%dlM4HHE&&F"(DK w33YY ?? F((v66 q#l++,, + +A MM,q/ * * * *!//#."==v8999v/////r:cHK|d{Vd}|||}|d}d}||dz|dzn|}|||d{V}|jr|||}|||||dS)aY watches information on multiple trades made by the user :see: 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]{@link https://docs.ccxt.com/#/?id=trade-structure NrH user.traderUr<TrWr]watch_private_subscriberrfilter_by_symbol_since_limit)r7rHrrIrMr]rfrs r9watch_my_tradeszcryptocom.watch_my_trades.!!!!!!!!!  [[((FH%F" =C=O{S(6$<77Va 33KHHHHHHHH ? 3OOFE22E00tTTTr:cK|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 :see: 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 ` Nzticker.r<)rWr] watch_public)r7rHrMr]rfs r9 watch_tickerzcryptocom.watch_tickerDss!!!!!!!!!V$$$vd|3 &&{F;;;;;;;;;r:c||d}||d}||}||dg}tdt |D]H}||}|||} | d} | |j| <|| |IdS)NrrwrxrrH)rrrYr[r\ parse_tickertickersr) r7rCrDrfrr]rxrdtickerparsedrHs r9 handle_tickerzcryptocom.handle_tickerQs.&&w?? ##G->??!!(++w33q#d))$$ 0 0A!WF&&vv66FH%F#)DL NN6; / / / /  0 0r:1mcrK|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 :see: 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 NrHz candlestick.rUr<rT)rWr]r timeframesrrrr) r7rH timeframerrIrMr]intervalrfohlcvs r9 watch_ohlcvzcryptocom.watch_ohlcvss!!!!!!!!!V$$!##DOY JJ)H4s:VD\I '' V<<<<<<<< ? 2NN6511E))%q$GGGr:c||d}||d}||}|d}||d}||}||j|i|j|<||j||} | ;||jdd} t| } | |j||<||d} tdt| D]5} | | } | | |}| |6| | |dS) NrrwrHr OHLCVLimitrrxr) rrfind_timeframerYohlcvsr?r2rr[r\ parse_ohlcvr_r)r7rCrDrfrr]rHrrrrIrxrdtickrs r9 handle_ohlcvzcryptocom.handle_ohlcvsg&&w?? ##G->??!!(++!##GZ88''11 "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *w//q#d))$$ " "A7D%%dF33F MM& ! ! ! !v{+++++r:cHK|d{Vd}|||}|d}d}||dz|dzn|}|||d{V}|jr|||}|||||dS)aU watches information on multiple orders made by the user :see: 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 ` NrH user.orderrUr<Tr)r7rHrrIrMr]rforderss r9 watch_orderszcryptocom.watch_ordersrr:cZ||d}||d}||dg}t|}|dkr|j0||jdd}t ||_|j} ||} tdt| D]} | | | | | || | || | ddSdS)Nr{rrxr ordersLimitrr) rrYr\rr?r2r parse_ordersr[r_r) r7rCrDrr{rr ordersLengthrIrrrds r9 handle_orderszcryptocom.handle_orderss'>""7I66$($4$4Wn$M$M!&"556{{ !  {"))$, tLL4U;; [F&&v..F1c&kk** ) ) fQi(((( NN6#< = = = NN67 + + + NN6< 0 0 0 0 0  r:cBK|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 :see: https://exchange-docs.crypto.com/exchange/v1/rest-ws/index.html#user-position_balance :param str[]|None symbols: list of unified market symbols :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr,rr+ subscribechannelsuser.position_balancer=rMr positions::,r&r.Tr/)rW authenticater1rrXis_emptyjoinrCset_positions_cache handle_option safe_boolrfuturefilter_by_symbols_since_limitwatchextendr)r7rOrrIrMurlr<requestrfrCr.r/snapshot newPositionss r9watch_positionszcryptocom.watch_positionss!!!!!!!!!!!!!!!!!!it$Y/ ZZ\\!45   " %%g..}}W%% 3'!2!22KS!!   111!%!3!34DF^`d!e!e!%0@BZ\`!a!a ! ]&< ]AW#]]+CDDDDDDDDH55hPUW[\\ \!ZZ[$++gv:V:VWWWWWWWW ?  11$.'5RWY]^^^r:c|ddd}|r@d}||jvr3||||j||dSdSt |_dS)Nr&r.F)rfuturesrspawnload_positions_snapshotrr)r7rCtyperOr.rfs r9rzcryptocom.set_positions_caches!%!3!34DF^`e!f!f ! 82K6>11 k*** 47MMMMM21677DNNNr:cK|d{V}t|_|j}tdt |D]<}||}||dd}|dkr||=|j|}||||ddS)Nr contractsr) fetch_positionsrrr[r\ safe_numberr_rr) r7rCrfrcacherdpositionrrs r9rz!cryptocom.load_positions_snapshots..00000000 133q#i..)) ' 'A |H((;BBI1}} X&&& ,uuk*****r:c6||dg}||di}||dg}|jt|_|j}g}tdt |D]I}||} || } || || J||d} tdt | D]}| |} | d} | d}|d}| |d|d }| |s| || | |ddS) Nrxrrz positions::rrirrHF) rYrrr[r\parse_positionr_find_message_hashessplitfilter_by_arrayrr)r7rCrDrx firstData rawPositionsrrrd rawPositionrrbrfparts symbolsStringrOrs r9handle_positionszcryptocom.handle_positions's6w33OOD!R00 y+rBB > !577DN q#l++,, # #A&q/K**;77H    ) ) ) LL " " " "00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111r:cBKd}|||d{VS)ax watch balance and get the amount of funds available for trading or funds locked in orders :see: 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)r7rMrfs r9 watch_balancezcryptocom.watch_balanceYs5% 11+vFFFFFFFFFr:c||d}||dg}||ddg}||jd<tdt |D]}||}||d}||} |} ||d| d<||d | d <| |j| <||j|_||j|||d } ||j| dS) Nrrxrposition_balancesinforwquantitytotal reserved_qtyusedr<) rrYbalancer[r\safe_currency_codeaccount safe_balancer) r7rCrDrfrxpositionBalancesrdr  currencyIdcoder messageHashRequests r9handle_balancezcryptocom.handle_balancecsY\&&w?? w33??474GLL# Vq#.//00 ; ;A&q)G))'3DEEJ**:66DllnnG#//DDGG "..wGGGFO!(DL ,,T\::DLLt|[111!--gt<<t|%788888r:rsiderprocK|d{V|||||||}d|d}|}|||d{VS)a :see: 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 fullfilled, 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-orderr=rM)rWcreate_order_requestrwatch_private_request) r7rHrrrprorMrrfs r9create_order_wszcryptocom.create_order_wss!!!!!!!!!**64vufUU,  jjll // WEEEEEEEEEr:c||d}||di}||}|||dS)Nr<result)rrY parse_orderr)r7rCrDrfrawOrderorders r9 handle_orderzcryptocom.handle_orders[&&w55 ??7Hb99  **uk*****r:r<cK|d{V|d|i|}d|d}|}|||d{VS)a cancels an open order :see: 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-orderr)rWrrr)r7r<rHrMrrfs r9cancel_order_wszcryptocom.cancel_order_wss!!!!!!!!!  -  jjll // WEEEEEEEEEr:c K|d{Vd}d|i|d}|&||}|d|dd<|}|||d{VS)a cancel all open orders :see: 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-ordersrr<rMrw)rWrr]rr)r7rHrMr]rrfs r9cancel_all_orders_wszcryptocom.cancel_all_orders_wss!!!!!!!!!1kk"f--    [[((F39$  $ $VW 5 5  F!!'844 $ 03$($5$($5)-)F&*&7.   __Wf55  ! Jvw ' ' ' ' ' " !r:cvK||jddd}||}d}||}||j|}|d}t |}||z|jz|z} | | | | |j tj } ||||j| d} || |} |||| ||d{VS)Nr,rr+r5rJ)r<rr=api_keysig)check_required_credentialsr1rCrrYr;r^rapiKeyhmacencodesecrethashlibsha256rr) r7rMrrCrfrr5r=rauth signaturerrDs r9rzcryptocom.authenticates- '')))it$Y/S!!% {++(DK/%7D $++d"3"3T[[5M5Mw~^^I ; Gkk'622G JJsK+ > > >||||||r:c>||j||dSN)rrG)r7rCrDs r9rKzcryptocom.handle_pings  49fg.....r:cf||jd}|ddS)Nr5T)rYrr)r7rCrDrs r9rLzcryptocom.handle_authenticates1AAtr:r\);__name__ __module__ __qualname__r6rGr^rr rNrrLrrrurrrrrrrrrrrlistrrr rrrrrrrrrrrr r floatr rr r$r'r)rr`rrr?rHrNrrKrL __classcell__)r8s@r9rrsB' ' ' ' ' R    @DB P PS P PS\ P P P PSW_a$!$!$s)$!C$!fo$!$!$!$!L--- 333V/V/V/V/V/p<@d[] S S SS S Sbfglbm S S S SOSaenpSSd3iSS[^SuyzvASSSS2*0F*0*0*0*0X37TX\egUUCUsURUUlpqvlwUUUU,68 < < rmsV AAAAAAAAAAAA}}}}}}}}}}}}}}}}}}}}}}}}}}}}444444000000))))))))))))_____",_____r: