i$=ddlZddlmZddlmZmZmZmZm Z ddl m Z ddl m Z ddlmZGddejjZdS) N) ArrayCache)IntMarket OrderBookTickerTrade)Client)List)AuthenticationErrorc eZdZfdZdifdededefdZdZdZ ifdede fd Z d e fd Z dd ede fd ZddifdedededeefdZd e fdZdd edefdZd e fdZd e fdZdZd e fdZxZS)coinonec |tt|dddddddddddiiddddd d d d d d dtii|jdddS)NTF)wswatchOrderBook watchOrders watchTrades watchOHLCV watchTicker watchTickersapirzwss://stream.coinone.co.kr) snapshotDelaysnapshotMaxRetries) expiresInuserIdwsSessionTokenr tradesLimit OHLCVLimitexact4009i N)ping keepAlive)hasurlsoptions exceptions streaming) deep_extendsuperr describer r$)self __class__s V/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/coinone.pyr-zcoinone.describesgt 4 4 = = ? ?"&$### %6  "$%&*+## $"  /  "?#B #B # # # NsymbollimitreturncZK|d{V||}d|dz}|jdd}dd|d|d d d }|||}|||||d{V} | S) aA watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.coinone.co.kr/reference/public-websocket-orderbook :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 orderbook:r2rr SUBSCRIBE ORDERBOOKquotebasequote_currencytarget_currency request_typechanneltopic) load_marketsmarketr'extendwatchr3) r.r2r3paramsrC messageHashurlrequestmessage orderbooks r0watch_order_bookzcoinone.watch_order_book6s!!!!!!!!!V$$"VH%55 it$'""(/#)&>  ++gv..**S+w LLLLLLLL    r1c(||di}||d}||d}||}||}||dz|z}||d} ||j|} | |} n| || d<||dg} ||dg} || d| || d| | | d<| | | d <d |z} | |j|<| | | dS) Ndatar=r</ timestampr2asksbidsdatetimer6) safe_valuesafe_string_uppersafe_currency_coder2 safe_integer orderbooks order_bookreset handle_deltasiso8601resolve)r.clientrJrNbaseIdquoteIdr:r9r2rPrKrQrRrGs r0handle_order_bookzcoinone.handle_order_bookOs2w33''.?@@((/?@@&&v..''00TCZ%/00%%dK88 OODOV<<  ))II OO   $ (tVR00tVR00 9V,d333 9V,d333!* + $ Y 7 7 *"V+ "+y+.....r1c^||dd}||dS)Npriceqty) parse_bid_ask storeArray)r.booksidedeltabidAsks r0 handle_deltazcoinone.handle_deltas3##E7E::F#####r1c2K|d{V||}d|dz}|jdd}dd|d|d d d }|||}|||||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://docs.coinone.co.kr/reference/public-websocket-ticker :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:r2rrr7TICKERr9r:r;r>)rBrCr'rDrE)r.r2rFrCrGrHrIrJs r0 watch_tickerzcoinone.watch_tickers!!!!!!!!!V$$&"22 it$'"(/#)&>  ++gv..ZZ[';GGGGGGGGGr1r^c||di}||}|d}||j|<d|z}||j||dS)NrNr2rl)rTparse_ws_tickertickersr])r.r^rJrNtickerr2rGs r0 handle_tickerzcoinone.handle_tickersm<w33%%d++!% V&( t|F+[99999r1rCch||d}||d}||d}||d}||}||}||dz|z} |id| d|d||d||dd ||d d ||d d ||d d||dd||dddd||dd|d|dddddddd||d||d|d|S)NrPlastr=r<rOr2rShighlowbidbid_best_price bidVolume bid_best_qtyaskask_best_price askVolume ask_best_qtyvwapopenfirstclose previousClosechange percentageaverage target_volume quote_volume) baseVolume quoteVolumeinfo)rW safe_stringrVr2 safe_tickerr\ safe_number) r.rrrCrPrur_r`r:r9r2s r0rpzcoinone.parse_ws_tickers<4%%fk:: //!!&*;<<""6+;<<&&v..''00TCZ%/00! f! !   Y//!  D$$VV44 ! 4##FE22 ! 4##F,<== !  ))&.AA!  4##F,<==!  ))&.AA!  D!  D$$VW55!  T!  D!  T!  d! $!! " t#! $**6?CC++FNCC)! ! ! * + r1sincecK|d{V||}d|dz}|jdd}dd|d|d d d }|||} |||| |d{V} |jr| |d|}|| ||d d S)a: watches information on multiple trades made in a market :see: https://docs.coinone.co.kr/reference/public-websocket-trade :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 Ntrade:r2rrr7TRADEr9r:r;r>rPT)rBrCr'rDrE newUpdatesgetLimitfilter_by_since_limit) r.r2rr3rFrCrGrHrIrJtradess r0 watch_tradeszcoinone.watch_tradess!!!!!!!!!V$$!11 it$'"(/#)&>  ++gv..zz#{G[IIIIIIII ? =OOF8$4e<%%dlM4HHE&&F"(DK  e' v{+++++r1cP||d}||d}||}||}|dz|z}||d}|||}||d} d} | | rdnd} ||d} ||d } |||d ||||d|d d| d| | ddd |S) Nr=r<rOrPis_seller_makersellbuyrcrdidr2) rrrPrSorderr2typeside takerOrMakerrcamountcostfee)rUrVrW safe_marketrTr safe_trader\) r.rrCr_r`r:r9r2rP isSellerMakerr priceString amountStrings r0rzcoinone.parse_ws_trade/sR''/@AA((0@AA&&v..''00e#%%e[99 !!&&11/@AA   $*566D&&ug66 ''u55 ""5$//" Y//X&  "    r1cD||dd}|dkrdSdS)N response_typerERRORTF)r)r.r^rJrs r0handle_error_messagezcoinone.handle_error_messageXs."== 7??4ur1cP|||rdS||d}|dkr|||dS|dkr||dd}|j|j|jd}|||}||||dSt|}tdt|D]B}||} | ||dkr|| } | ||dSAdSdS)NrPONGDATAr@r)r8rmrr) rr handle_pongrarsrrTlistkeysrangelenfind) r.r^rJrrAmethods exacMethodrikeymethods r0handle_messagezcoinone.handle_messageesX  $ $VW 5 5  F99 6>>   VW - - - F 6>>$$Wi<  r1c ddiS)Nr?PING)r.r^s r0r$z coinone.pings F  r1c8||_|SN) millisecondslastPong)r.r^rJs r0rzcoinone.handle_pongs ++--r1r)__name__ __module__ __qualname__r-strrrrLrarjrrnr rsrrpr rrrrrrr$r __classcell__)r/s@r0r r s$ $ $ $ $ L@DB!!S!!S\!!!!2./././`$$$68HHHFHHHH.#:F#:#:#:#:J66f66666p<@d[]SSSSSSbfglbmSSSS8,F,,,,8''F'e''''R 6    V4   &r1r )ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrrr!ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportr rr1r0rs 777777AAAAAAAAAAAAAA444444000000}}}}}d (}}}}}r1