ivddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)BalancesIntOrder OrderBookStrTickerTrade)Client)List)AuthenticationError)ArgumentsRequiredc eZdZfdZifdZddifdedededeefdZ dddifde dededee fd Z d!d e fd Zifdedefd Zd e fd Zd e fdZdddifdedededeefdZd e fdZdifdededefdZdZdZd e fdZd e fdZifdZifdefdZifdZd e fdZ d e fdZ!d e fdZ"dZ#d e fdZ$d e fdZ%d e fd Z&xZ'S)"okcoinc |tt|dddddddddddidddd d d d gd dd ddd ddid|jdddS)NTF)ws watchTicker watchTickerswatchOrderBook watchOrders watchTrades watchBalance watchOHLCVrz wss://real.okcoin.com:8443/ws/v3zchttps://user-images.githubusercontent.com/1294454/27766791-89ffb502-5ee5-11e7-8a5b-c5950b68ac65.jpgzhttps://www.okcoin.comzhttps://www.okcoin.com/docs/en/z https://www.okcoin.com/coin-feeszIhttps://www.okcoin.com/account/register?flag=activity&channelId=600001513)apilogowwwdocfeesreferralspotorder depth_l2_tbt)limittypedepthinflate) fetchMarketsrrrri N)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber+)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/okcoin.pyr3zokcoin.describesfd 3 3 < < > ># %"&## $"  <~/8:g  "(& "+## !'t    " E(A (A ( ( ( c.K|d{V||}|jdd}|ddz|zdz|dz}d|gd}|||||||d{VS) Nrrr'/:id subscribeopargs) load_marketsmarketr.watchr1)r4channelsymbolparamsrAurl messageHashrequests r6r<zokcoin.subscribe=s!!!!!!!!!V$$it$Vns*W4s:VD\I  M  ZZ[$2B2B7F2S2SU`aaaaaaaaar7NrDsincer&returnc K|d{V||}|d||d{V}|jr|||}||||ddS)a get the list of most recent trades for a particular symbol :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)r@rDr< newUpdatesgetLimitfilter_by_since_limit)r4rDrIr&rEtradess r6 watch_tradeszokcoin.watch_tradesHs!!!!!!!!!V$$~~gvv>>>>>>>> ? 3OOFE22E))&% TRRRr7czK|d{V|d{V|||}||jdd}||||d{V}|jr|||}||||ddS)a watches information on multiple orders made by the user :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#rMT) r@ authenticaterD safe_stringr/r<rNrOrP)r4rDrIr&rE orderTyperQs r6 watch_orderszokcoin.watch_ordersXs!!!!!!!!!!!!!!!!!!  [[((F$$T\='JJ ~~i@@@@@@@@ ? 3OOFE22E))&% TRRRr7clientc||d}||dg}t|}|dkr$||jdd}|jt ||_|j}i} ||} tdt| D]G} | | } | | | d} | | }d| |d<Ht| }tdt|D]-} |d z|| z}| |j|,dSdS) Ntabledatar ordersLimitrDTr;r:)rU safe_valuelen safe_integerr/ordersr parse_ordersrangeappendrAlistkeysresolve)r4rXmessage subscriptionrZra ordersLengthr&stored marketIdsparsedir#rDrArfrGs r6 handle_orderszokcoin.handle_orderskslL  '22&"556{{ !  %%dlM4HHE{"4U;; [FI&&v..F1c&kk** / /q  e$$$xV,,*. &,'' (())D1c$ii(( 9 9#ckDG3 t{K8888!   9 9r7c@K|d||d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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<)r4rDrEs r6 watch_tickerzokcoin.watch_tickers0^^Hff=========r7c(||d}||dg}||jdd}t dt |D]}|||}|d}||dd} |d z| z} ||j|} | t|} | |j|<| || | | |S) NrZr[ tradesLimitr]rrDinfo instrument_idr:) rUr^r`r/rcr_ parse_traderQrrdrg) r4rXrhrZr[rtrnrLrDmarketIdrGrks r6 handle_tradezokcoin.handle_trades   '22w33'' mTJJ q#d))$$ 0 0A$$T!W--E8_F''f GGH#+0K__T[&99F~#K00&, F# MM% NN6; / / / /r7cn||d}||dg}tdt|D]i}|||}|d}||dd}|dz|z} ||j|<||| j|S)NrZr[rrDrurvr:)rUr^rcr_ parse_tickertickersrg) r4rXrhrZr[rnrqrDrxrGs r6 handle_tickerzokcoin.handle_tickers.  '22w33q#d))$$ 0 0A&&tAw//FH%F''vHHH#+0K#)DL NN6; / / / /r71mcRK|d{V||}||j||}d|zdz}||||d{V}|jr|||}||||ddS)aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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)r@rDrU timeframesr<rNrOrP) r4rD timeframerIr&rEintervalnameohlcvs r6 watch_ohlcvzokcoin.watch_ohlcvs!!!!!!!!!V$$##DOY JJ("S(nnT66:::::::: ? 2NN6511E))%q$GGGr7c||d}||dg}|d}||d}|dd}|dd}||}t dt |D]#} ||| d } ||| d} || } | d } || | }||j | i|j | <||j | |}|;| |j d d }t|}||j | |<| ||d z| z}|||%dS)NrZr[r9rrrrvrD OHLCVLimitr]r:)rUr^splitreplacefind_timeframercr_ safe_market parse_ohlcvohlcvsr`r/rrdrg)r4rXrhrZr[partspart1rrrnrxrrArDrmrkr&rGs r6 handle_ohlcvzokcoin.handle_ohlcvs&  '22w33 C    **==2..##C,,''11 q#d))$$ 0 0A''QAAH__T!Wh77F%%h//FH%F%%ff55F"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! !#+0K NN6; / / / / 0 0r7cK||jdi}||dd}||||d{V}|S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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^r/rUr<r&)r4rDr&rEr/r( orderbooks r6watch_order_bookzokcoin.watch_order_book/sn//$,0@"EE  '>BB..????????    r7c||d}||d}|||dS)Nrr) safe_floatstore)r4booksidedeltapriceamounts r6 handle_deltazokcoin.handle_delta<sBq))**uf%%%%%r7c~tdt|D]}||||dS)Nr)rcr_r)r4rdeltasrns r6 handle_deltaszokcoin.handle_deltasAsHq#f++&& 3 3A   hq 2 2 2 2 3 3r7c^||dg}||dg}||d|||d||||d}||d<|||d<|S)NasksbidsrMdatetime)r^r parse8601rUiso8601)r4rXrhrrrrMs r6handle_order_book_messagez okcoin.handle_order_book_messageEs$w33w33 9V,d333 9V,d333NN4#3#3G[#I#IJJ !* + $ Y 7 7 *r7c||d}||dg}||d}|dkrtdt|D]}||}||d}||} | d} ||jdi} || d d } |i| } | |j| <| ||| |d z|z}| | |ntdt|D]}||}||d}||} | d} | |jvrB|j| } | ||| |d z|z}| | ||S) Nactionr[rZpartialrrvrDrr&r$r:) rUr^rcr_rr/r` order_book orderbooksrrg)r4rXrhrr[rZrnupdaterxrArDr/r&rrGs r6handle_order_bookzokcoin.handle_order_book`sd!!'844w33  '22 Y  1c$ii(( 7 7a++FODD))(33)//$,8H"MM))'7C@@ OOB66 *3'..vvyIII#ckH4 y+6666 71c$ii(( ; ;a++FODD))(33)T_,, $ 7I22669MMM"'#+"8KNN9k:::r7cNK||jdd}d}||}||j|}||d}t |}d}d}||z|z} || | | |j tj d} ||j |j|| gd} ||j||| |||d{VS) Nrrlogin authenticatedGETz/users/self/verifybase64r=)check_required_credentialsr.rXr^ subscriptionsfuturestrsecondshmacencodesecrethashlibsha256apiKeypasswordspawnrB) r4rErFrGrXrrMmethodpathauth signaturerHs r6rTzokcoin.authenticates# '')))it$ S!!!5{CC >]]?33FDLLNN++IF'Dv%,D $++d"3"3T[[5M5Mw~_ghhI!KM G JJtz3 Wk6 R R R||||||r7c K||jdd}||d|}|t|jdz|d{V}|||d{VS)a watch balance and get the amount of funds available for trading or funds locked in orders :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_2r/rUrr;rTsubscribe_to_user_account)r4rErr' negotiations r6 watch_balancezokcoin.watch_balances ((~}UU  << <#DG/D%DEE E --//////// 33KHHHHHHHHHr7c$K||jdd}||d|}|t|jdz|d{V||d}||d||}d}|||}||d}||} | du} |du} |dkr | rt|jd z|zd znY|d ks |d ks|d kr | rt|jdz|zd zn'|dkr!| r| rt|jdz|zd zd} | s |d} n | s| d} |d krdn|} |d krdnd}| dz|z}|dz| z}|j dd}d|gd}| |gd}| ||| |||d{VS)Nrrr'rcurrencycoderDr"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_accountaccountr9r:rrr<r=)rrrvrDr') rr/rUrr;r@safe_currency_coderrAr.omitrBr1)r4rrErr' currencyIdrrrDrAmarketUndefinedcurrencyUndefinedsuffix accountTyperrGsubscriptionHashrFrHquerys r6rz okcoin.subscribe_to_user_accounts((~}UU  << <#DG/D%DEE E!!!!!!!!!%%fj99 0G0G 0S0STT  }}T**H!!&(33V$$!T>%- 6>>  U'2~(~BF)FIT)TUUU UhDFNN8H8H \'3F)FIM)MP[)[\\\ \ Y    A_ A'3k)knr)ru@)@AAA  "d^FF  "D\F!%!1!1ff '+x'7'7""i!C''1 &,v5it$%&   &"Y"Y"YZZZZ[$2B2B7E2R2RTdeeeeeeeeer7c^||d}|d}||dg}||jd<||d}|dkr||d}|dkrd }t dt |D]}|||} ||j|i} || | } || |j|<| |j||dS) NrZr9r[rurr"rrr) rUrr^balancercr_parseBalanceByTyper1 safe_balancerg) r4rXrhrZrr[r'rrnr oldBalance newBalances r6handle_balancezokcoin.handle_balances2B  '22 C  w33# Vq)) 6>>$$UA..E(((q#d))$$ 6 6A--dD99GtR@@J))*g>>J!%!2!2:!>!>DL  NN4<-u 5 5 5 5  6 6r7c|SNr4rXrhs r6handle_subscription_statusz!okcoin.handle_subscription_status1s r7c2||d|S)Nr)rgrs r6handle_authenticatezokcoin.handle_authenticate9s w000r7cdS)Nr+r)r4rXs r6r+z okcoin.ping@s vr7c8||_|Sr) millisecondslastPongrs r6 handle_pongzokcoin.handle_pongEs++--r7c||d} |||jdz||z}||jd||||d}|"||jd||n[#t$rN}t|tr/| |dd}||j vr|j |=Yd}~dSYd}~nd}~wwxYw|S) N errorCode exactrhbroadrrF) rUr;jsonthrow_exactly_matched_exception exceptionsr^throw_broadly_matched_exception Exception isinstancerrejectr)r4rXrhrfeedback messageStringers r6handle_error_messagezokcoin.handle_error_messageIs, $$Wk::  $7S=499W+=+==44T_W5MyZbccc $ C C  ,889QS`bjkkk   !011  a111 V111,V4uuuuu       sA>B C/!>C**C/c |||sdS|dkr|||dS||d}|Q||d}|5|j|jd}|||}||||dSdSdS|d}||d}|j|j|j|j|j |j |j |j d}|||}| dd kr|j }||||dSdS) NpongrZevent)rr<r9r)r(depth5r%rqrLrrr#rr)rrrUrrr^rrr}ryrrofindr) r4rXrhrZrmethodsrrrs r6handle_messagezokcoin.handle_message`s((99  Fl f     VW - - - F  '22 =$$Wg66E "5!%!@  %88%F67+++++! &%KK$$E##E1--D/0 $ 6,*."&"5+  G__Wd33Fyy""a''*!vw'''''"!r7r)(__name__ __module__ __qualname__r3r<rrrr rRr rrWr ror rrryr}rerrr rrrrrrTrrrrrrr+rrr  __classcell__)r5s@r6rrs) ) ) ) ) V79 b b b b<@d[]SSSSSSbfglbmSSSS 04$UYbdSSSCSsSimnsitSSSS&9999F99999999v68>>>F>>>>6@ F    D8<$]ajlHHHCHWZHquvzq{HHHH&)06)0)0)0)0V@DB ! !S ! !S\ ! ! ! !&&& 3336NNNNN`)+2*, I I I I I ICE'f'f'f'fR/6V/6/6/6/6b& &6.Z(VZ(Z(Z(Z(Z(Z(Z(Z(r7r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrr async_supportrrr7r6rs ffffffffffOOOOOOOOOOOOOOOOOO444444000000......j (j (j (j (j (T  &j (j (j (j (j (r7