ei~=ddlZddlmZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZGddejjZdS) N) ArrayCache)AnyBoolIntMarket OrderBookTickerTrade)Client)List)AuthenticationErrorc eZdZdeffd ZdifdededefdZdZ dZ ifdede fd Z d e fd Zdd ede fd ZddifdedededeefdZd e fdZdded edefdZd e defdZd e fdZd e fdZd e fdZxZS)coinonereturnc |tt|ddddddddddddiiddddd d d d d d dtii|jdddS)NTF)wswatchOrderBook watchOrders watchTradeswatchTradesForSymbols watchOHLCV watchTicker watchTickersapirzwss://stream.coinone.co.kr) snapshotDelaysnapshotMaxRetries) expiresInuserIdwsSessionTokenr tradesLimit OHLCVLimitexact4009i N)ping keepAlive)hasurlsoptions exceptions streaming) deep_extendsuperrdescriber r()self __class__s N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/coinone.pyr1zcoinone.describesgt 4 4 = = ? ?"&$#).## %  6  "$%&*+## $"  /  "A$B $B $ $ $ NsymbollimitcZK|d{V||}d|dz}|jdd}dd|d|d d d }|||}|||||d{V} | S) a; watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data 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:r6rr SUBSCRIBE ORDERBOOKquotebasequote_currencytarget_currency request_typechanneltopic) load_marketsmarketr+extendwatchr7) r2r6r7paramsrF messageHashurlrequestmessage orderbooks r4watch_order_bookzcoinone.watch_order_book7s!!!!!!!!!V$$"VH%55 it$'""(/#)&>  ++gv..**S+w LLLLLLLL    r5c(||di}||d}||d}||}||}||dz|z}||d} ||j|} | |} n| || d<||dg} ||dg} || d| || d| | | d<| | | d <d |z} | |j|<| | | dS) Ndatar@r?/ timestampr6asksbidsdatetimer9) safe_valuesafe_string_uppersafe_currency_coder6 safe_integer orderbooks order_bookreset handle_deltasiso8601resolve)r2clientrMrQbaseIdquoteIdr=r<r6rSrNrTrUrJs r4handle_order_bookzcoinone.handle_order_bookRs2w33''.?@@((/?@@&&v..''00TCZ%/00%%dK88 OODOV<<  ))II OO   $ (tVR00tVR00 9V,d333 9V,d333!* + $ Y 7 7 *"V+ "+y+.....r5c^||dd}||dS)Npriceqty) parse_bid_ask storeArray)r2booksidedeltabidAsks r4 handle_deltazcoinone.handle_deltas3##E7E::F#####r5c2K|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 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:r6rrr:TICKERr<r=r>rA)rErFr+rGrH)r2r6rIrFrJrKrLrMs r4 watch_tickerzcoinone.watch_tickers!!!!!!!!!V$$&"22 it$'"(/#)&>  ++gv..ZZ[';GGGGGGGGGr5rac||di}||}|d}||j|<d|z}||j||dS)NrQr6ro)rWparse_ws_tickertickersr`)r2rarMrQtickerr6rJs r4 handle_tickerzcoinone.handle_tickersm<w33%%d++!% V&( t|F+[99999r5rFch||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)NrSlastr@r?rRr6rVhighlowbidbid_best_price bidVolume bid_best_qtyaskask_best_price askVolume ask_best_qtyvwapopenfirstclose previousClosechange percentageaverage target_volume quote_volume) baseVolume quoteVolumeinfo)rZ safe_stringrYr6 safe_tickerr_ safe_number) r2rurFrSrxrbrcr=r<r6s r4rszcoinone.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)! ! ! * + r5sincecK|d{V||}d|dz}|jdd}dd|d|d d d }|||} |||| |d{V} |jr| |d|}|| ||d d S)a0 watches information on multiple trades made in a market 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 ` Ntrade:r6rrr:TRADEr<r=r>rArST)rErFr+rGrH newUpdatesgetLimitfilter_by_since_limit) r2r6rr7rIrFrJrKrLrMtradess r4 watch_tradeszcoinone.watch_tradess!!!!!!!!!V$$!11 it$'"(/#)&>  ++gv..zz#{G[IIIIIIII ? =OOF8$4e<%%dlM4HHE&&F"(DK  e' v{+++++r5rcP||d}||d}||}||}|dz|z}||d}|||}||d} d} | | rdnd} ||d} ||d } |||d ||||d|d d| d| | ddd |S) Nr@r?rRrSis_seller_makersellbuyrfrgidr6) rrrSrVorderr6typeside takerOrMakerrfamountcostfee)rXrYrZ safe_marketrWr safe_trader_) r2rrFrbrcr=r<r6rS isSellerMakerr priceString amountStrings r4rzcoinone.parse_ws_trade6sR''/@AA((0@AA&&v..''00e#%%e[99 !!&&11/@AA   $*566D&&ug66 ''u55 ""5$//" Y//X&  "    r5cD||dd}|dkrdSdS)N response_typerERRORTF)r)r2rarMrs r4handle_error_messagezcoinone.handle_error_message_s."== 7??4ur5cP|||rdS||d}|dkr|||dS|dkr||dd}|j|j|jd}|||}||||dSt|}tdt|D]B}||} | ||dkr|| } | ||dSAdSdS)NrPONGDATArCr)r;rprr) rr handle_pongrdrvrrWlistkeysrangelenfind) r2rarMrrDmethods exacMethodrikeymethods r4handle_messagezcoinone.handle_messagelsX  $ $VW 5 5  F99 6>>   VW - - - F 6>>$$Wi<  r5c ddiS)NrBPING)r2ras r4r(z coinone.pings F  r5c8||_|SN) millisecondslastPong)r2rarMs r4rzcoinone.handle_pongs ++--r5r)__name__ __module__ __qualname__rr1strrrrOrdrmr rqr rvrrsr r rrdictrrrrr(r __classcell__)r3s@r4rrs % #% % % % % % N@DB!!S!!S\!!!!6./././`$$$68HHHFHHHH2#:F#:#:#:#:J66f66666p<@d[]SSSSSSbfglbmSSSS<,F,,,,8''D'&'E''''R 6 t    V4 6    &r5r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherccxt.base.typesrrrrrr r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrrr5r4rs 777777LLLLLLLLLLLLLLLLLL444444000000DDDDDd (DDDDDr5