":h# %"&##). $" <~/8:g "(& "+# !'t   " G)A ) ) cK|jd{|j|}|jdd}|ddz|zdz|dz}d|gd}|j|||j |||d{S7m7w) Nrrr*/:id subscribeopargs) load_marketsmarketr1watchr4)r7channelsymbolparamsrDurl messageHashrequests r9r?zokcoin.subscribe>s!!!V$iit$Vns*W4s:VD\I  M ZZ[$2B2B7F2SU`aaa "bs"BBA(B?BBBNrGsincer)cK|jd{|j|}|jd||d{}|jr|j ||}|j |||ddS7c79w)a5 get the list of most recent trades for a particular symbol https://www.okcoin.com/docs-v5/en/#websocket-api-public-channel-trades-channel :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 ` Ntrade timestampT)rCrGr? newUpdatesgetLimitfilter_by_since_limit)r7rGrLr)rHtradess r9 watch_tradeszokcoin.watch_tradesIsv!!!V$~~gvv>> ??OOFE2E))&% TRR ">s!A>A:+A>A<8A><A>crK|jd{|jd{||j|}|j|jdd}|j |||d{}|j r|j||}|j|||ddS777;w)aE watches information on multiple orders made by the user https://www.okcoin.com/docs-v5/en/#websocket-api-private-channel-order-channel :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 ` Nrr&rOT) rC authenticaterG safe_stringr2r?rPrQrR)r7rGrLr)rH orderTyperSs r9 watch_orderszokcoin.watch_orders\s!!!!!!  [[(F$$T\\='J ~~i@@ ??OOFE2E))&% TRR "!As2B7B1B7B3A B79B5:8B73B75B7clientcr|j|d}|j|dg}t|}|dkDr|j|jdd}|j t ||_|j }i} |j|} tdt| D]6} | | } |j| | d} |j| }d| |d<8t| j}tdt|D])} |d z|| z}|j|j |+yy) Ntabledatar ordersLimitrGTr>r=)rW safe_valuelen safe_integerr2ordersr parse_ordersrangeappendrDlistkeysresolve)r7rZmessage subscriptionr\rc ordersLengthr)stored marketIdsparsedir&rGrDrhrJs r9 handle_orderszokcoin.handle_ordersrs0L  '2&"56{ ! %%dllM4HE{{"4U; [[F I&&v.F1c&k* /q  e$xV,*. &,'  /  ()D1c$i( 9#ckDG3 t{{K8 9 r:cDK|jd||d{S7w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.okcoin.com/docs-v5/en/#websocket-api-public-channel-tickers-channel :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 ` tickerN)r?)r7rGrHs r9 watch_tickerzokcoin.watch_tickers!^^Hff====s   c|j|d}|j|dg}|j|jdd}t dt |D]}|j ||}|d}|j|dd} |d z| z} |j|j|} | t|} | |j|<| j||j| | |S) Nr\r] tradesLimitr_rrGinfo instrument_idr=) rWr`rbr2rera parse_traderSrrfri) r7rZrjr\r]rvrprNrGmarketIdrJrms r9 handle_tradezokcoin.handle_trades   '2w3'' mTJ q#d)$ 0A$$T!W-E8_F''f GH#+0K__T[[&9F~#K0&, F# MM% NN6; / 0r:c2|j|d}|j|dg}tdt|D]Y}|j ||}|d}|j|dd}|dz|z} ||j |<|j || [|S)Nr\r]rrGrwrxr=)rWr`rera parse_tickertickersri) r7rZrjr\r]rprsrGrzrJs r9 handle_tickerzokcoin.handle_tickers.  '2w3q#d)$ 0A&&tAw/FH%F''vHH#+0K#)DLL NN6; /  0r:1mcJK|jd{|j|}|j|j||}d|zdz}|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://www.okcoin.com/docs-v5/en/#websocket-api-public-channel-candlesticks-channel :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 NcandlesrT)rCrGrW timeframesr?rPrQrR) r7rG timeframerLr)rHintervalnameohlcvs r9 watch_ohlcvzokcoin.watch_ohlcvs!!!V$##DOOY J("S(nnT66:: ??NN651E))%q$GG ";s"B#BAB#'B!(8B#!B#c:|j|d}|j|dg}|jd}|j|d}|jdd}|jdd}|j |}t dt |D]} |j|| d } |j|| d} |j| } | d } |j| | }|j|j| i|j| <|j|j| |}|:|j|jd d }t|}||j| |<|j||d z| z}|j||y)Nr\r]r<rrrrxrG OHLCVLimitr_r=)rWr`splitreplacefind_timeframerera safe_market parse_ohlcvohlcvsrbr2rrfri)r7rZrjr\r]partspart1rrrprzrrDrGrormr)rJs r9 handle_ohlcvzokcoin.handle_ohlcvs&  '2w3 C   *==2.##C,''1 q#d)$ 0A''QAH__T!Wh7F%%h/FH%F%%ff5F"&//$++vr"JDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !#+0K NN6; / 0r:cK|j|jdi}|j|dd}|j|||d{}|j S7w)aP watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.okcoin.com/docs-v5/en/#websocket-api-public-channel-order-book-channel :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 rr+r(N)r`r2rWr?r))r7rGr)rHr2r+ orderbooks r9watch_order_bookzokcoin.watch_order_book<s[//$,,0@"E  '>B..??   @sAA  A A cp|j|d}|j|d}|j||y)Nrr) safe_floatstore)r7booksidedeltapriceamounts r9 handle_deltazokcoin.handle_deltaLs0q)*uf%r:cbtdt|D]}|j|||y)Nr)rerar)r7rdeltasrps r9 handle_deltaszokcoin.handle_deltasQs0q#f+& 3A   hq 2 3r:c|j|dg}|j|dg}|j|d||j|d||j|j|d}||d<|j ||d<|S)NasksbidsrOdatetime)r`r parse8601rWiso8601)r7rZrjrrrrOs r9handle_order_book_messagez okcoin.handle_order_book_messageUs$w3w3 9V,d3 9V,d3NN4#3#3G[#IJ !* + $ Y 7 *r:c0|j|d}|j|dg}|j|d}|dk(rtdt|D]}||}|j|d}|j |} | d} |j|j di} |j | d d } |ji| } | |j| <|j||| |d z|z}|j| ||Stdt|D]z}||}|j|d}|j |} | d} | |jvs?|j| } |j||| |d z|z}|j| |||S) Nactionr]r\partialrrxrGrr)r'r=) rWr`rerarr2rb order_book orderbooksrri)r7rZrjrr]r\rpupdaterzrDrGr2r)rrJs r9handle_order_bookzokcoin.handle_order_bookpsd!!'84w3  '2 Y 1c$i( 7a++FOD))(3)//$,,8H"M))'7C@ OOB6 *3'..vvyI#ckH4 y+6 701c$i( ;a++FOD))(3)T__, $ 7I22669M"'#+"8KNN9k: ;r:cBK|j|jdd}d}|j|}|j|j|}||j d}t |j}d}d}||z|z} |j|j| |j|jtjd} ||j|j|| gd} |j|j ||| |||d{S7w) Nrrlogin authenticatedGETz/users/self/verifybase64r@)check_required_credentialsr1rZr` subscriptionsfuturestrsecondshmacencodesecrethashlibsha256apiKeypasswordspawnrE) r7rHrIrJrZrrOmethodpathauth signaturerKs r9rVzokcoin.authenticates '')iit$ S!!5!5{C >]]?3FDLLN+IF'Dv%,D $++d"3T[[5Mw~~_ghI!KKMM G JJtzz3 Wk6 R||sDDDDc K|j|jdd}|j|d|}|t|jdz|j d{}|j ||d{S77w)ax watch balance and get the amount of funds available for trading or funds locked in orders https://www.okcoin.com/docs-v5/en/#websocket-api-private-channel-account-channel :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` r defaultTyper*NS watchBalance requires a type parameter(one of 'spot', 'margin', 'futures', 'swap')) safe_string_2r2rWrr>rVsubscribe_to_user_account)r7rHrr* negotiations r9 watch_balancezokcoin.watch_balances((~}U  < <#DGG/D%DE E --// 33KHHH0Hs$AB A?!B:B;BBcK|j|jdd}|j|d|}|t|jdz|j d{|j|d}|j|d|j |}d}||j|}|j|d}|j|} | du} |du} |dk(r | rtt|jd z|zd z|d k(s |d k(s|d k(r | rEt|jdz|zd z|dk(r"| r | rt|jdz|zd zd} | s|d} n| s| d} |d k(rdn|} |d k(rdnd}| dz|z}|dz| z}|jdd}d|gd}|j|gd}|j|||j|||d{S77w)Nrrr*rcurrencycoderGr%zJ watchBalance requires a 'currency'(id) or a unified 'code' parameter for z accountsmarginswapoptionzQ watchBalance requires a 'instrument_id'(id) or a unified 'symbol' parameter for futureszv watchBalance requires a 'currency'(id), or unified 'code', or 'instrument_id'(id), or unified 'symbol' parameter for r>margin_accountaccountr<r=rrr?r@)rrrxrGr*) rr2rWrr>rCsafe_currency_coderrDr1omitrEr4)r7rrHrr* currencyIdrrrGrDmarketUndefinedcurrencyUndefinedsuffix accountTyperrJsubscriptionHashrIrKquerys r9rz okcoin.subscribe_to_user_accounts((~}U  < <#DGG/D%DE E!!!%%fj9 0G0G 0ST  }}T*H!!&(3V$!T>%- 6> '2~(~BF)FIT)TUUhDFN8H'3F)FIM)MP[)[\\ Y  _'3k)knr)ru@)@AA d^F D\F!%!1f '+x'7"i!C''1 &,v5iit$%&  &"YZZZ[$2B2B7E2RTdeeeE "Dfs%AG$ G!E9G$G"G$"G$c|j|d}|jd}|j|dg}||jd<|j|d}|dk(r|j|d}|dk(rd }t dt |D]}|j ||} |j|j|i} |j| | } |j| |j|<|j|j||y) Nr\r<r]rwrr%rrr) rWrr`balancereraparseBalanceByTyper4 safe_balanceri) r7rZrjr\rr]r*rrpr oldBalance newBalances r9handle_balancezokcoin.handle_balancesB  '2 C w3# Vq) 6>$$UA.E((q#d)$ 6A--dD9GtR@J))*g>J!%!2!2:!>DLL  NN4<<-u 5  6r:c|SNr7rZrjs r9handle_subscription_statusz!okcoin.handle_subscription_statusDs r:c*|j|d|S)Nr)rirs r9handle_authenticatezokcoin.handle_authenticateLs w0r:cy)Nr.r)r7rZs r9r.z okcoin.pingSsr:c0|j|_|Sr) millisecondslastPongrs r9 handle_pongzokcoin.handle_pongXs++-r:c|j|d} |u|jdz|j|z}|j|jd|||j |d}| |j |jd|||S#t$rO}t|tr4|j|dd}||jvr |j|=Yd}~yYd}~|Sd}~wwxYw) N errorCode exactrjbroadrrF) rWr>jsonthrow_exactly_matched_exception exceptionsr`throw_broadly_matched_exception Exception isinstancerrejectr)r7rZrjrfeedback messageStringers r9handle_error_messagezokcoin.handle_error_message\s $$Wk:  $77S=499W+==44T__W5MyZbc $ C  ,889QS`bjk !01 a1 V111,,V4 2  sA7B C%?C  C%c |j||sy|dk(r|j||y|j|d}|M|j|d}|8|j|jd}|j ||}| |||yyy|j d}|j|d}|j|j|j|j|j|j|j|jd}|j ||}|jdd k\r |j}| |||yy) Npongr\event)rr?r<r)r+depth5r(rsrNrrr&rr)rrrWrrr`rrrr{rrqfindr) r7rZrjr\rmethodsrrrs r9handle_messagezokcoin.handle_messagess]((9 l f    VW -   '2 =$$Wg6E "55!%!@!@ ! %8%67+&!KK$E##E1-D//00 $ 6 6,,**.."&"5"5++ G__Wd3Fyy"a'**!vw'"r:r))__name__ __module__ __qualname__rr6r?rrrr rTr r rYrrqr rtr{rrgrrr rrrrrrVrrrrrrr.rrr  __classcell__)r8s@r9rrs* #* X79 b<@d[]SSSSSbfglbmS&04$UYbdSSCSsSimnsitS,99F99v68 > >F >6@ F D8<$]ajlHHCHWZHquvzq{H,)06)0V@DB!S!!S\! & 36NN`)+2*,II"CE'fR/6V/6b&6 &6.Z(VZ(r:r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r r !ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrr:r9rsB ffTTT40.} (T   & &} (r: