":hddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlm Z ddlm!Z!dd lm"Z"dd lm#Z#dd lm$Z$Gd d ejJjLZ&y)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesInt LiquidationNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickers FundingRate FundingRatesTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) InvalidNonce) ChecksumErrorceZdZdeffd ZdXdefdZdifdefdZifdZ ddifd ed e d e de e fd Z ddifde ed e d e de e fd Zifde edefdZifd edefdZdefdZifd edefdZifde edefdZdefdZifd edefdZifd edefdZdifdedefdZifd edefdZdifdedefdZdifdedefdZdefdZ difdedefdZ!defdZ"dYdZ#dddifde ed e d e de e$fdZ%defd Z&dddifde ed e d e de e$fd!Z'defd"Z(dYd#Z)dYd$Z*d%ddifd ed e d e de e+fd&Z,d%ifd edefd'Z-ddifd(e e ed e d e fd)Z.ifd(e e edefd*Z/defd+Z0difd ed e de1fd,Z2difde ed e de1fd-Z3ifde edefd.Z4ifd edefd/Z5d0Z6d1Z7dYdefd2Z8defd3Z9ifd4Z:ifde;fd5ZdYd8Z?dddifd e@d e d e de e fd9ZAdddifded e d e de eBfd:ZCd;ZDdddifd e@d e d e de eEfd<ZFdYdefd=ZGdefd>ZHd?ZIdifd ed@eJdAeKdBeLdCeMdeEf dDZNdefdEZOddifdFed ed@eJdAeKdBeMdCeMdeEfdGZPdifdFed e@deEfdHZQdifdIe ed e@fdJZRdifd e@fdKZSdefdLZTdefdMZUdefdNZVdefdOZWdefdPZXdefdQZYdefdRZZded efdSZ[ded edefdTZ\ded edefdUZ]ded efdVZ^defdWZ_xZ`S)Zokxreturnc,|jtt|iddddddddddddddd dd dd dd dd dddddddddddddddddddddd ddiddidddddddiddiddiddidd idd!iid" |jd#d$d%S)&NwsT watchTickerwatchMarkPricewatchMarkPrices watchTickers watchBidsAskswatchOrderBook watchTradeswatchTradesForSymbolswatchOrderBookForSymbols watchBalancewatchLiquidationsemulatedwatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchOHLCVwatchOHLCVForSymbols) watchOrders watchMyTradeswatchPositionswatchFundingRatewatchFundingRates createOrderWs editOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWszwss://ws.okx.com:8443/ws/v5zwss://wspap.okx.com:8443/ws/v5)apitestbooks)checksumdepthspotchanneltickerstypeANYop batch-orders amend-order) r*r.r%r(r6r7r;r<r$iPF)ping keepAlive)hasurlsoptions streaming) deep_extendsuperr!describerM)self __class__s F/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/okx.pyrUz okx.describesc4 9 ;dt!$"4      !$t(+D$Z.t&z0 d!"'#$ $!%"&$(%)!%#!%"&%)7>7: !%0%3#6!'y y!E E"."- _2l " s_> _ _ rFc|jd}|rdnd}|dk(}|dk(}|jdd}|s|jdd kDs|d k(r|d z|zS|r|d z|zS|d z|zS)N sandboxModez?brokerId=9999businesspublicr@r$candle orders-algoz /businessz/publicz/private)rQrPfind)rVrFaccess isSandbox sandboxSuffix isBusinessisPublicurls rXget_urlz okx.get_urlxsLL/ ,5(2  * h&iit$ ',,x0257m;S$}4 4 ?]2 2Z-//rYNsymbolscK|jd{| |j}|j|}|j||}g}g}t dt |D]V}|j ||} || d} |j|j| ||j|dz||zXd|d} |j||| |d{S77w)NrrFinstId:: subscriberJargs) load_marketsrjmarket_symbolsrirangelen market_idappendextendwatch_multiple) rVrcrFrjparamsrh messageHashesrqimarketIdargrequests rXsubscribe_multiplezokx.subscribe_multiples!!! ?llG%%g.ll7F+ q#g,' >A~~gaj1H""C KK C0 1  4'!*!< = > ((mWmTTT' "&Us"C#CCC#C!C#!C#cK|jd{|j||}d|i}|$|j|}|d|dzz }|d|d<d|j||gd} |j ||| |d{S7r7w)NrF:idrmrorp)rrrimarketrSwatch) rVrc messageHashrFsymbolrzrh firstArgumentrrs rXroz okx.subscribes!!!ll7F+ w   [[(F 3- -K&,TlM( #  7  ZZ[';GGG "Hs"B B A-B B B  B rsincelimitcHK|j|g|||d{S7w)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 ` N)watch_trades_for_symbols)rVrrrrzs rX watch_tradeszokx.watch_tradess'22F8UE6RRRRs " "cKt|}|dk(rt|jdz|jd{|j |}d}g}g}t dt|D]E} || } |j |dz| z|j| } || d} |j | Gd|d} |j|d }|j||| |d{}|jr6|j|d}|j|d }|j||}|j|||d d S77^w) a get the list of most recent trades for a particular symbol :param str symbols: :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 ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNtradesrrlrorpr^r timestampT)rurrrrrsrtrwrvriry newUpdates safe_value safe_stringgetLimitfilter_by_since_limit)rVrjrrrz symbolsLengthrFtopicsr{r|rr}topicrrhrfirst tradeSymbols rXrzokx.watch_trades_for_symbolssZG A #DGG.n$no o!!!%%g. q#g,' !AQZF  3!7 8~~f-H""E MM%  ! ll7H-**3 w VV ??OOFA.E**5(;KOOK7E))&% TRR1 "&Ws#` NFrrunsubscribe:trades:rl unsubscriberpr^)rrrsrtrurwrvriry rVrjrzrFrr{r|rr}rrrhs rXun_watch_trades_for_symbolszokx.un_watch_trades_for_symbolss!!!%%gtU; q#g,' !AQZF  !6!? @~~f-H""E MM%  !  ll7H-((mWmTTT' "&Us"CCB%C<C=CCcDK|j|g|d{S7w)a6 unWatches from the stream channel :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` N)rrVrrzs rXun_watch_tradeszokx.un_watch_tradess#55vhGGGG   clientc|j|di}|j|d}|j|d}|j|}|j|dg}|j|jdd}t dt |D]y} |j|| } |dz|z} |j|j|} | t|} | |j|<| j| |j| | {y) Nr~rFrmdata tradesLimitrr) rr safe_symbol safe_integerrQrtru parse_traderrrwresolve) rVrmessager~rFr}rrrr|traderstoreds rX handle_tradeszokx.handle_tradess oogub1""3 2##C2!!(+w3'' mTJ q#d)$ 0A$$T!W-E!C-&0K__T[[&9F~#K0&, F# MM% NN6; / 0rYcpK|j|}|j|g|d{}||S7 w)ar watch the current funding rate https://www.okx.com/docs-v5/en/#public-data-websocket-funding-rate-channel :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` N)rwatch_funding_rates)rVrrzfrs rXwatch_funding_ratezokx.watch_funding_rate#s<V$++VHf= =&z>s (64 6cK|jd{|j|}d}g}g}tdt|D]E}||}|j |dz|z|j |}||d} |j | Gd|d} |j |d} |j| || |d{} |jr|j| d }i} | | |<| S|j|jd |S77Jw) a watch the funding rate for multiple markets https://www.okx.com/docs-v5/en/#public-data-websocket-funding-rate-channel :param str[] symbols: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `funding rates structures `, indexe by market symbols N funding-raterrrlrorpr^r) rrrsrtrurwrvriryrrfilter_by_array fundingRates)rVrjrzrFrr{r|rr}rrrh fundingRateresults rXrzokx.watch_funding_rates1s)!!!%%g.  q#g,' !AQZF  3!7 8~~f-H""E MM%  ! ll7H- //]G][[ ??%%k8A D D c|j|dg}tdt|D]D}||}|j|}|d}||j|<|j |d|dzFy)Nrrrz funding-rate:) safe_listrtruparse_funding_raterr)rVrrrr|rawfrrrs rXhandle_funding_ratezokx.handle_funding_rateVs~(~~gvr2q#d)$ VAGE11%8K *F(3D  f % NN;(<{8?T(T U  VrYcKd}|j|ddd\}}||d<|j|}|d}|j|g|d{}|j||S7w)a} https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-tickers-channel 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 :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` Nr%rFrGr)handle_option_and_paramsr watch_tickersrrVrrzrFrtickers rX watch_tickerzokx.watch_tickerrsw77 yZcd#yV$!))6(F;;vv..` N)un_watch_tickersrs rXun_watch_tickerzokx.un_watch_tickers#**F8V<<<` NFr(rFrGr^rrrrsrrrrrGrVrjrzrF newTickerss rXrzokx.watch_tickerss!!!%%gtU;77PY[de228WgvVV ?? ##DLL(GDD "W"BBABB0BBcKd}|j|ddd\}}||d<|j|}|d}|j|g|d{}||S7 w)a  https://www.okx.com/docs-v5/en/#public-data-websocket-mark-price-channel watches a mark price :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` Nr&rF mark-pricer)rrwatch_mark_pricesrs rXwatch_mark_pricezokx.watch_mark_pricess77@PR[]ij#yV$!--vh??f~@sA A A Ac(K|jd{|j|dd}d}|j|ddd\}}|jd|||d{}|jr|S|j |j d|S7w71w)a https://www.okx.com/docs-v5/en/#public-data-websocket-mark-price-channel watches mark prices :param str[] [symbols]: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` NFr'rFrr^rrrs rXrzokx.watch_mark_pricess!!!%%gtU;77@QS\^jk228WgvVV ?? ##DLL(GDD "WrcK|jd{|j|dd}d}|j|ddd\}}g}g}tdt |D]B}||}|j d|z|j |}||d} |j | Dd |d } |j|d } |j| || |d{S77w) a https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-tickers-channel unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] [symbols]: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` NFr(rFrGrunsubscribe:ticker:rlrrpr^) rrrsrrtrurwrvriryrs rXrzokx.un_watch_tickerss!!!%%gtU;77PY[de q#g,' !AQZF  !6!? @~~f-H""E MM%  !  ll7H-((mWmTTT) "(Us"CCB` NFr)rFrGr^rrlbidask::rorpr) rrrsrrirtrurvrwrxryrrbidsasks) rVrjrzrFrhr{rqr|r}r~rrrGs rXwatch_bids_askszokx.watch_bids_askssA!!!%%gtU;77QZ\efll7H- q#g,' :A~~gaj1H""C KK C0 1  gaj!8 9 :  ..sM7MZZ ??G,6GJx( )N##DMM8WEE1 "&[s"D#DC D#$D!%:D#!D#c|j|dg}|j|di}|j|}|d}||j|<d|z}|j ||y)Nrrrr)r safe_dictparse_ws_bid_askrr)rVrrrr parsedTickerrrs rXrzokx.handle_bid_ask;sh4~~gvr2a,,,V4 h' , f 6) |[1rYc f|j|d}|j||}|j|d}|j|d}|j|||j ||j|d|j|d|j|d|j|d|d|S) NrmrtsaskPxaskSzbidPxbidSz)rrdatetimeask askVolumebid bidVolumeinfo)rrr safe_tickeriso8601)rVrrr}rrs rXrzokx.parse_ws_bid_ask]s##FH5!!(F3!!&(3%%fd3 " Y/##FG4))&':##FG4))&': !    rYcdK|jd{|j|ddd}d}g}|7tdt|D]}||}|j |dz|z n|j ||j |} d} |j d| |\} }d} | dk(rd } n| d k(rd } | j} d | | d gd} |j| d}|j||| |d{}|jr|S|j|j|||dS774w)a, watch the public liquidations of a trading pair https://www.okx.com/docs-v5/en/#public-data-websocket-liquidation-orders-channel :param str symbols: :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the okx api endpoint :returns dict: an array of `liquidation structures ` NT liquidationsrrnwatchliquidationsForSymbolsliquidation-ordersrESWAPfuturefuturesrorFinstTyperpr^) rrrsrtrurwget_market_from_symbolshandle_market_type_and_paramsupperriryrfilter_by_symbols_since_limitr)rVrjrrrzrr{r|rrrHrF uppercaseTyperrhnewLiquidationss rXwatch_liquidations_for_symbolsz"okx.watch_liquidations_for_symbolsmsi!!!%%gtT4@$   1c'l+ B $$[4%7&%@A B   ---g699:WY_agh f& 6>D X D  ' - ll7H- $ 3 3CQ^ __ ??" "11$2C2CWeUZ\`aaA ":`s"D0D+C"D09D.:2D0.D0c|j|dg}tdt|D]}||}|j|}|j |d}|j |j |}|(|j|jdd} t| }|j|||j |<|j|gd|j|gd|zy)NrrrliquidationsLimitrrzliquidations::) rrtruparse_ws_liquidationrrrrrQrrwr) rVrrrawLiquidationsr|rawLiquidation liquidationrrrs rXhandle_liquidationzokx.handle_liquidations8..&"=q#o./ EA,Q/N33NCK%%k8` NstoptriggerFrcr]privateTmyLiquidationsrrnbalance_and_positionrorFrp)rr safe_value_2omit authenticatersrtrurwriryrSrrr)rVrjrrrz isTriggerrr{r|rrFrrhrs rX!watch_my_liquidations_for_symbolsz%okx.watch_my_liquidations_for_symbolssq!!!%%ffiG 6FI#67: RSSS%%gtT4@&   1c'l+ B $$[4%7&%@A B   -(w ll7I. $ 3 3CHXHXY`bhHikx yy ??" "11$2C2CWeUZ\`aa5 " T(zs5ED9AED<B)ED>2E<E>Ec|j|dg}tdt|D]}||}|j|d}|dk7ry|j |}|j|d}|j |j |} | (|j|jdd} t| } | j|| |j |<|j|gd|j|gd |zy) Nrr eventTyperrmyLiquidationsLimitrr zmyLiquidations::) rrtrurparse_ws_my_liquidationrrrrQrrwr) rVrrrr|rrrrrrs rXhandle_my_liquidationzokx.handle_my_liquidationsF..&"=q#o./ GA,Q/N((EIM)66~FK%%k8 ,,V^D%%k7;" Y/ &  rYc |j|dg}|j|di}|j|d}|j||}|j |d}|j ||j |||j|d|j|d|j|ddd||j|d S) NdetailsrrmrszrbkPxrr#)rVrrr(liquidationDetailsr}rs rXrzokx.parse_ws_liquidationOs*..i<!^^GQ;##K:!!(F3%%&8$? $$&&x8))*+>sMSZ\i+j%j" 7 ??$$VU3E--gueQM'' 8DD3 "*&ks&AE(E#CE(E&AE(&E(c>Kt|}|dk(st|dtst|jdz|j d{g}g}t dt|D]t}||}|d}|d} |j|} |j|j| | } d| z} | | d} |j| |jd| zdz|zvd |d }|jdd }|j||||d{S77w) a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume rr9Nr:r_rlzunsubscribe:multi:rrrpr^) rur<r=rrrrrtrvrr.rwriry)rVr7rzrrr{r|r?r@rAr}r0rFrrrhs rXr5zokx.un_watch_ohlcv_for_symbolssT01 A Z0DQ0G%N#DGG/f%fg g!!! q#234 MA!5a!8 $Q'C#A&B~~c*H''R@H)G""E MM%  !5!?#!E!K L M  ll8X.((mWmTTT+ "*Us%ADDCDDDDc|j|di}|j|d}|j|dg}|j|d}|j|}|d}|jdd} |j | } t dt |D]} |j|| |} |j|j|i|j|<|j|j|| } | :|j|jd d }t|} | |j|| <| j| |d z|d z}|j| |d |zd z|z}|j|| | g|y)Nr~rFrrmrr_r\r OHLCVLimitrrrr;)rrrreplacefind_timeframertru parse_ohlcvohlcvsrrQrrwr)rVrrr~rFrr}rrr0r/r|parsedrrrmessageHashForMultis rX handle_ohlcvzokx.handle_ohlcvs"oogub1""3 2w3##C2!!(+!??8R0''1 q#d)$ MA%%d1gv6F"&//$++vr"JDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !!C-&,6K NN6; /#+W"4s":V"C  NNFIv68K L MrYcFK|j|g||d{S7w)a https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-order-book-channel 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 :param str [params.depth]: okx order book depth, can be books, books5, books-l2-tbt, books50-l2-tbt, bbo-tbt :returns dict: A dictionary of `order book structures ` indexed by market symbols N)watch_order_book_for_symbols)rVrrrzs rXwatch_order_bookzokx.watch_order_books&F66xOOOOs !!cK|jd{|j|}d}|j|ddd\}}|$|dk(rd}n|dkDr|dkrd}n|d k(rd }n|d k(rd}|d k(s|d k(rD|jd st |j dz|j ddid{g}g}tdt|D]E}||}|j|dz|z|j|} || d} |j| Gd|d} |j|d} |j| || |d{} | jS7G77w)a https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-order-book-channel watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str[] symbols: unified array of symbols :param int [limit]: 1,5, 400, 50(l2-tbt, vip4+) or 40000(vip5+) the maximum amount of order book entries to return :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.depth]: okx order book depth, can be books, books5, books-l2-tbt, books50-l2-tbt, bbo-tbt :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr*rDrBr:bbo-tbtbooks52books50-l2-tbt books-l2-tbtFz watchOrderBook/watchOrderBookForSymbols requires authentication for self depth. Add credentials or change the depth option to books or books5rcr^rrrlrorp)rrrsrcheck_required_credentialsrrrrtrurwrvriryr)rVrjrrzrDrr{r|rr}rrrh orderbooks rXrPz okx.watch_order_book_for_symbols+s!!!%%g.55f>NPWY`a v  z!uz "(# ^ #2B)B2259)$''5E+EFF##Xx$89 9 9 q#g,' !AQZF  v!5 6~~f-H "E MM%  ! ll5(+--c='=YY   E " :"Zs5E$EBE$4E 5BE$E" E$ E$"E$c`K|jd{|j|dd}d}|j|ddd\}}|j|d}|$|dk(rd}n|dkDr|d krd }n|d k(rd }n|d k(rd}g}g}g}t dt |D]Y}||} |j |dz| z|j d| z|j| } || d} |j | [d|d} |j|d} |j| || |d{S77w)a https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-order-book-channel unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str[] symbols: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: the maximum amount of order book entries to return :param str [params.depth]: okx order book depth, can be books, books5, books-l2-tbt, books50-l2-tbt, bbo-tbt :returns dict: A dictionary of `order book structures ` indexed by market symbols NFr*rDrBrr:rSrTrUrVrWrXrrunsubscribe:orderbook:rlrrpr^) rrrsrrrtrurwrvriry)rVrjrzrDrrsubMessageHashesr{r|rr}rrrhs rXun_watch_order_book_for_symbolsz#okx.un_watch_order_book_for_symbols[sn!!!%%gtU;55f>NPWY`a v!!&'2  z!uz "(# q#g,' !AQZF  # #ECK&$8 9  !9F!B C~~f-H "E MM%  !  ll5(+((mWmTTTA "@Us"D.D)D D.$D,%D.,D.cDK|j|g|d{S7w)a https://www.okx.com/docs-v5/en/#order-book-trading-market-data-ws-order-book-channel unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: the maximum amount of order book entries to return :param str [params.depth]: okx order book depth, can be books, books5, books-l2-tbt, books50-l2-tbt, bbo-tbt :returns dict: A dictionary of `order book structures ` indexed by market symbols N)r_rs rXun_watch_order_bookzokx.un_watch_order_books#996(FKKKKrcp|j|d}|j|d}|j||y)Nrr:) safe_floatstore)rVbooksidedeltar amounts rX handle_deltazokx.handle_deltas2q)*uf%rYcbtdt|D]}|j|||y)Nr)rtrurh)rVredeltasr|s rX handle_deltaszokx.handle_deltass0q#f+& 3A   hq 2 3rYc|j|dg}|j|dg}|d}|d} |j|||j| ||j|d} |j| |} |j ddd} |j |d} | r|j |d}|d }t |}t | }g}td d D]}||krL|j|j| |d |j|j| |d ||ksZ|j|j||d |j|j||d d j|}|j |d}|j|d}d}|dk7r||k7rt|jdz}||k7r*t|jdz|j| z}|,|j |=|j"| =|j%|||j |d}| |d <||d<|j'||d<|S)Nasksbidsrmr*rCTseqId prevSeqIdnoncerr:rr`z& watchOrderBook received invalid nonce rrr)rrkrr handle_optionrrurtrwnumber_to_stringjoincrc32rrrorderbook_checksum_message subscriptions orderbooksrejectr)rVrrr[rrrmrn storedAsks storedBidsr}rrCrorprq asksLength bidsLength payloadArrayr|payloadresponseChecksum localChecksumerrorrs rXhandle_order_book_messagezokx.handle_order_book_messages|(w3w3v& v&  :t, :t,##GX6!!(F3%%&6 DI!!'73 ))';?Ig&EZJZJL1b\ Qz> ''(=(=jmA>N(OP ''(=(=jmA>N(OPz> ''(=(=jmA>N(OP ''(=(=jmA>N(OP  Qhh|,G#00*E  JJw5MEB5I#5$TWW/W%WX=0%dggmd6U6UV\6]&]^ ((5OOF+ e[1%%gt4 " '!* + $ Y 7 *rYc H|j|di}|j|d}|j|d}|j|dg}|j|d}|j|}|d} ddd dd d } |j | |} |d z| z} |d k(rmt dt |D]S} || }|ji| }||j| <| |d<|j|||| |j|| U|S|dk(re| |jvrU|j| }t dt |D].} || }|j|||| ||j|| 0|S|dk(s|dk(r| |jvr|ji| |j| <|j| }t dt |D]S} || }|j |d}|j|| |dddd}|j||j|| U|S)Nr~rFactionrrmrr:rXrTrV)rSrBrUrYrWrsnapshotrupdaterUrSrrnrm) rrrrrrtru order_bookrzrrparse_order_bookreset)rVrrr~rFrrr}rrdepthsrrr|rr[rrs rXhandle_order_bookzokx.handle_order_booksYlnnWeR0""3 2!!'84~~gvr2##C2!!(+!  !!&'2mf, Z 1c$i( 7a OOB6 *3'&, (#..vvy+Vy+6  70#x ( OOF3 q#d),;A!!WF22669k[abNN9k:;!w)';doo-*.//"e*D'/I1c$i( 7a --fd; 00FTZ\]_`a)y+6  7 rYcK|j|j|dd}|j|dg}|jd|}d}|j |}|j |}|j |j|}|t|j}d} d} || z| z} |j|j| |j|jtjd} d} | |j|j || d gd }d|vr|d|d<|j#|||||d{S7w) Nrcr users authenticatedGETz/users/self/verifybase64login)apiKey passphrasersignrp)rZrrrirrrrystrsecondshmacencodesecrethashlibsha256rpasswordr)rVrzrcrhrrrrrmethodpathauth signature operationrs rXrzokx.authenticatefsA '')!!&(I>6H:.ll7F+% S!{+(<(||sEE EE cK|jd{|jd{|jdddd|d{S797#7w)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 ` Nr account)rrrro)rVrzs rX watch_balancezokx.watch_balancesS !!!!!!^^Iy)T6RRR "!Rs1AAAAA A AAAc(|j||yN)rrVrrs rXhandle_balance_and_positionzokx.handle_balance_and_positions ""673rYcL|j|di}|j|d}d}|j|}|j|j|i}|j ||}|j ||j|<|j |j||y)Nr~rFrE)rrparseTradingBalancebalancerS safe_balancer) rVrrr~rFrHr oldBalance newBalances rXhandle_balancezokx.handle_balancesXoogub1""3 2**73__T\\4< %%j': !..z: Tt||D)73rYcF|j|di}|j|d}|j|d}|j|dddk(}|j|||j ||j|d|j|d|j|d |j|d |rd nd |j|d |j |d|j |d|j |d|j |d|j |dd |S)NrfillTime fillFeeCcyexecTyper\TrtradeIdrrHtakermakersidefillPxfillSzcostfillFee)rcurrency) rrrrrorderrH takerOrMakerrr rgrfee)rrr safe_traderr%safe_currency_code)rVrrrr feeMarketIdisTakers rXorder_to_tradezokx.order_to_trades(ufb1%%dJ7 &&t\: ""4R8C?" Y/&&uh7""43%%eT2$$UF3(/Gg$$UF3%%dH5&&tX6$$UF3((y9 33K@ " # rYc Kd}|j|ddd\}}|j|ddd}|j|ddg}|jd{|j d|rd nd id{|rd nd }|d z}d} |#|j |} | d}| d}|dz|z}|dk(rd}|j } d} |jd|\} }| dk(r| d} d| i} |jd ||d|j| |d{} |jr| j||}|j| |||dS777;w)a watches information on multiple trades made by the user https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-order-channel :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 :param bool [params.trigger]: True if fetching trigger or conditional trades :param str [params.type]: 'spot', 'swap', 'future', 'option', 'ANY', 'SPOT', 'MARGIN', 'SWAP', 'FUTURES' or 'OPTION' :param str [params.marginMode]: 'cross' or 'isolated', for automatically setting the type to spot margin :returns dict[]: a list of `trade structures ` Nr7rHrIr r Frcr]r raorders ::myTradesrrnrrSPOTMARGINrT) r safe_bool_2rrrrrrhandle_margin_mode_and_paramsrorxrrfilter_by_symbol_since_limit)rVrrrrzrHrrFrrr marginModerrs rXwatch_my_tradeszokx.watch_my_tradess 44V_fV[\ f$$VYF 6Iv#67!!!: RSSS#,-( ,   [[(FH%F&>D%,v5K 8 D  !??QWX F F "% (   ~~igtT[[Y`bhMijj ??OOFE2E00tTT1 "S(ks7AEEE6E 7BEE 8E E Ec K|jd{|j|d{|j|}ddi}d}d}|Lddd}|j||g} d| d} |j |d} |j | || |d{}n,|j d|||j||d{}|jr|S|j|j|||d S777b77w) a https://www.okx.com/docs-v5/en/#trading-account-websocket-positions-channel watch all open positions :param str[]|None symbols: list of unified market symbols @param since @param limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` NrrI positionsrrorpr T) rrrrsrxrirrrrr) rVrjrrrzrrF newPositionsr~rqnonSymbolRequestrhs rXwatch_positionszokx.watch_positionss!!!'''%%g.   ?&!CKKV,-D!& ,,w 2C!%C:JG!TTL!%!8!8GWVZVaVabikqVr!ssL ?? 11$..'5RWY]^^1 "'$UssDC<C4C<C6A%C<C8,C<C:2C<6C<8C<:C<c|j|di}|j|d}|j|dd}|d}|j|dd}|j|dg}|jt |_|j} g} t dt |D]} || } |j| } | d dk(r=d | d <|j| }d |d <| j|| j|| j| | j| |}||d z|z}|j| |y)Nr~rmrrrFr\rrrlongrshortrn) rrrrrrtruparse_positionclonerwr)rVrrr~r}rrrFrcacherr| rawPositionposition shortPositionrs rXhandle_positionszokx.handle_positions5sNFoogub1##C2!!(D#6!""3 26w3 >> !57DN q#d)$ #Aq'K**;7H $)#) $ 8 4 (/ f% ]+##M2    ) LL " #  !D.61K|[1rYc Kd}|j|ddd\}}|j|ddd}|j|ddg}|jd{|j d|rd nd id{d}||j |}|d }|d}|d k(rd }|j }d} |jd|\} }|dk(r| d}d|i} |rdnd} |jd | | ||j| |d{} |jr| j||}|j| |||dS777;w)a watches information on multiple orders made by the user https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-order-channel :param str [symbol]: unified market symbol of the market the 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 :param bool [params.trigger]: True if fetching trigger or conditional orders :param str [params.type]: 'spot', 'swap', 'future', 'option', 'ANY', 'SPOT', 'MARGIN', 'SWAP', 'FUTURES' or 'OPTION' :param str [params.marginMode]: 'cross' or 'isolated', for automatically setting the type to spot margin :returns dict[]: a list of `order structures ` Nr6rHrIr r Frcr]r rrrrrrrarT) rrrrrrrrrrorxrrr) rVrrrrzrHrrrrrrFrs rX watch_orderszokx.watch_orderssr44V]FTYZ f%%ffiG 6FI#67!!!: RSSS  [[(FH%F&>D 8 D  !?? vV F F "% (   $--(~~i'64;;W^`fKghh ??OOFE2E00tTT- "S$is7AED;E6D=7B ED?8E=E?Ec|j|||j|di}|j|d}|j|dg}t|}|dkDr|j |j dd}|j t||_t||_|dk(r |jn |j } g} |j|} tdt| D]B} | | } | j| | d}|j|}| j|d D|j| |tdt| D]} |d z| | z}|j| |!yy) Nr~rFrr ordersLimitrrarrr)handle_my_tradesrrrurrQrr triggerOrders parse_ordersrtrwrr)rVrr subscriptionr~rFr ordersLengthrr marketIdsrLr|rrrrs rX handle_orderszokx.handle_ordersskn fg.oogub1""3 2&"56{ ! %%dllM4HE{{"4U; %;E%B",3},DT''4;;FI&&v.F1c&k* /q  e$xV,  .  / NN67 +1c)n- 4%mil: v{3 4 rYcz|j|di}|j|d}|j|dg}g}tdt|D]K}||}|j|dd} t| dkDs*|j |} |j | Mt|} | dk(ry|j -|j|jdd} t| |_|j } i}tdt|D]3}||}|j|}| j ||d }d ||<5|d z}|j|j |t|j}tdt|D])}|d z||z}|j|j |+y) Nr~rFrrrr\rrrTrrn)rrrtru parse_orderrwmyTradesrrQrrrr=keys)rVrrr~rF rawOrdersfilteredOrdersr|rawOrderrr tradesLengthrrrjrawTraderrr tradeSymbolssymbolMessageHashs rXrzokx.handle_my_trades snoogub1""3 2OOGVR8 q#i.) -A |H&&xB?G7|a((2%%e,  - >* 1   == %%dllM4HE259DM==q#n-. #A%a(H''1E OOE "8_F"GFO  #  , t}}k2GLLN+ q#l+, =A +d 2\!_ D  NN4==*; < =rYcvt|j}|jd}t|}||zS)N)r milliseconds rand_number)rVr randomNumber randomParts rX request_idzokx.request_idds9 ""$ %''* & JrYrHrrgr c2K|jd{|jd{|jdd}|j}d} |j |ddd\} }|j ||||||} |j | d} | dk(s| dk(s|d k(s|d k(s |d k(s|d k(rt|jd z| dk7r| dk7rt|jdz|| | gd} |j||| |d{S777w)a https://www.okx.com/docs-v5/en/#websocket-api-trade-place-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|None [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean params['test']: test order, default False :returns dict: an `order structure ` Nr r;rJrKordTyper  conditionalocomove_order_stopicebergtwapzw createOrderWs() does not support algo trading. self.options["createOrderWs"]["op"] must be either order or batch-orderrz createOrderWs() does not support algo trading. self.options["createOrderWs"]["op"] must be either order or privatePostTradeOrder or privatePostTradeOrderAlgorrJrq) rrrrirrcreate_order_requestrrrr) rVrrHrrgr rzrhrrJrqrrs rXcreate_order_wszokx.create_order_wsjsd!!!!!!ll9i0oo' 226?DR`a F((tVUFS""43 y g&>DEMW[_pWpvzHwHNRV\N\TWW(aab b 'Mn 4TWW(HHI IF  ZZ[';GGG# "! Hs2DDDDCD D DDDc |j|d}|j|dg}|j|dd}|j|rF|j|d}|j |}|j dd|j |d||dd |j|ddd}|j|di}|j||y)NrrsCode0rJr) rr filter_byis_emptyjson handle_errorsrhrrr) rVrrrrqr stringMsgrrs rXhandle_place_orderszokx.handle_place_orderss&&&w5 w3~~dGS1 == %%gt4F '*I   tT6::vtYPWY]_c d""4tT:vq"-uk*rYrc K|jd{|jd{|jdd}|j} d} |j |ddd\} }|j |||||||} | | | gd} |j || |j| || d{S777w)a6 edit a trade order https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-amend-order https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-amend-multiple-orders :param str id: order id :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 the currency you want to trade in units of the base currency :param float|None [price]: the price at which the order is to be fulfilled, 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 ` Nr r<rJrLr)rrrrirredit_order_requestrrx) rVrrrHrrgr rzrhrrJrqrs rX edit_order_wszokx.edit_order_wss !!!!!!ll9i0oo' 226=$P]^ F&&r64vufUF  ZZ[$++gv2NP[\\\ "!]s2B>B8B>B:BB>3B<4B>:B><B>cK|t|jdz|jd{|jd{|j dd}|j }|j |dd}|j|ddg}d|j|i}|||d<n||d<|d|j||gd }|j||||d{S777w) a https://okx-docs.github.io/apidocs/websocket_api/en/#cancel-order-trade cancel multiple orders :param str id: order id :param str symbol: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.clOrdId]: client order id :returns dict: an list of `order structures ` Nz+ cancelOrderWs() requires a symbol argumentr clOrdId clientOrderIdrmordId cancel-orderr) rrrrrrir safe_string_2rrvrxr) rVrrrzrhrrr~rs rXcancel_order_wszokx.cancel_order_wss >TWW'TTU U!!!!!!ll9i0oo' **69oN 6OY#?@ dnnV,   $*C NCL [[f-.  ZZ[';GGG% "!"Hs4.C/C)C/C+ BC/$C-%C/+C/-C/idscKt|}|dkDrt|jdz|t|jdz|jd{|j d{|j dd}|j }g}td|D]*}|j|||d} |j| ,|d|d } |j|||j| ||d{S777w) a https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-mass-cancel-order cancel multiple orders :param str[] ids: order ids :param str symbol: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an list of `order structures ` z0 cancelOrdersWs() accepts up to 20 ids at a timeNz, cancelOrdersWs() requires a symbol argumentr r)rmrzbatch-cancel-ordersr) rurrrrrrirrtrvrwrrS) rVrrrz idsLengthrhrrqr|r~rs rXcancel_orders_wszokx.cancel_orders_wss H r>TWW'YYZ Z >TWW'UUV V!!!!!!ll9i0oo' q)$ A..0QC KK   '  ZZ[$2B2B7F2SU`aaa! "!bs7AD DD 0D1BD ?DD D D cK|t|jdz|jd{|jd{|j |}|ddk7rt|jdz|j dd}|j }|d|jd|d d |gd }|j||||d{S777w) a https://docs.okx.com/websockets/#message-cancelAll cancel all open orders of a type. Only applicable to Option in Portfolio Margin mode, and MMP privilege is required. :param str symbol: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nz/ cancelAllOrdersWs() requires a symbol argumentrHoptionzh cancelAllOrdersWs is only applicable to Option in Portfolio Margin mode, and MMP privilege is required.r  mass-cancelOPTIONr)r instFamilyr) rrrrrrrirrxr)rVrrzrrhrrs rXcancel_all_orders_wszokx.cancel_all_orders_wss >TWW'XXY Y!!!!!!V$ &>X %TWW(RRS Sll9i0oo' [[$$Tl" ZZ[';GGG "!Hs4.CCCC B CCCCCcr|j|d}|j|dg}|j||y)Nrr)rrr)rVrrrrs rXhandle_cancel_all_orderszokx.handle_cancel_all_orders+s6&&w5 w3t[)rYc|Srrs rXhandle_subscription_statuszokx.handle_subscription_status=s rYc^|j|jd}|jdy)NrT)rrr)rVrrrs rXhandle_authenticatezokx.handle_authenticateEs$AtrYcy)NrMr*)rVrs rXrMzokx.pingLsrYc0|j|_|Sr)rlastPongrs rX handle_pongzokx.handle_pongQs++-rYc|j|d} |r1|dk7r+|jdz|j|z}|dk7r |j|jd|||j |d}|+|j |jd||t||j|dg}td t|D]p}||}|j|d }| |j|jd|||j |d }|Q|j |jd||rt||S#t$r} |j|d } | Z|j|d} | F| jd r5| jdd} |j| } |j| d } | |j| | Yd} ~ y|j| Yd} ~ yd} ~ wwxYw)Ncoder rs1exactmsgbroadrrr sMsgrzIllegal request: {zIllegal request: r\F)rrrthrow_exactly_matched_exception exceptionsrthrow_broadly_matched_exceptionrrtrur Exception startswithrH parse_jsonr{)rVrr errorCodefeedback messageStringrr|derr6stringifiedJson parsedJsons rXhandle_error_messagezokx.handle_error_messageUs $$Wf5 " Y#-77S=499W+==#889QS\^fg $ ?  ,889QS`bjk$H-- >>'62>D"1c$i0t G$($4$4Q$@ $0 @@QXAY[dfno(,(H (4 @@QXAY[hjrst$H--"! !!'40Bz&&w6?s~~6J'K&)kk2Er&JO!%!AJ))*d;B~ a$ MM!  s%DE -E G5BG0G00G5c <|j||sy|dk(r|j||y|j|dd}||j|j|j |j |j |j |j |j |jd }|j||}| |||yy|j|di}|j|d}id|jd|jd |jd |jd |jd |jd |jd|jd|jd|jd|jd|jd|jd|jd|j d|j d|j"d|j$i}|j||}|(|j'ddk(r|j)||yy|||y)NpongeventrJ) rrorrrKrLzbatch-amend-ordersrr#r~rFrSrBrUrWrYrGrrz index-tickersz sprd-tickersz block-tickersrrrrrarr r_r)rFr1rr-r+handle_unsubscriptionrr(rrrrrrrrrrrrbrN)rVrrrImethodsrr~rFs rXhandle_messagezokx.handle_messages((9 P f    VW - ""7GT:  11!<<#9911 $ 8 8#77&*&>&> $ 8 8#<< G__We4F!vw'"//'5"5C&&sI6G411//$00!$"8"8   6 6  4-- d00T22 !3!3 2 2 !3!3$,,4.. 8 8 $,,!"t11#$%d&=&=%&'(H(H'G*__Wg6F~<<)Q.%%fg6/vw'rYcvd|z}d|z}|j|||||jvr|j|=yy)Nztrades:r)clean_unsubscriptionr)rVrrsubMessageHashrs rXhandle_un_subscription_tradesz!okx.handle_un_subscription_tradessE"V++f4  !!&.+F T[[  F# !rYc||dz|z}d|z}|j|||||jvr|j|=yy)Nrr])rNrzrVrrrFrOrs rX handle_unsubscription_order_bookz$okx.handle_unsubscription_order_booksI 3/.7  !!&.+F T__ $' %rYc|jdd}|j|}d|zdz|z}d|z}|j|||||j|vr|j||=yy)Nr_r\r;rz unsubscribe:)rHrIrNrK)rVrrrFrAr/rOrs rXhandle_unsubscription_ohlcvzokx.handle_unsubscription_ohlcvsy __Xr *''+ !G+c1F:$~5  !!&.+F  F+ + F#I. ,rYc||dz|z}d|z}|j|||||jvr|j|=yy)Nrnr)rNrGrRs rXhandle_unsubscription_tickerz okx.handle_unsubscription_tickersI 4&0+f4  !!&.+F T\\ ! V$ "rYc|j|di}|j|dd}|j|d}|j|}|dk(r|j||y|j ds|j dr|j |||y|j dd kDr|j|||y|j d r|j|||yy) Nr~rFr\rmrbbobookrGr`r_) rrrrPr=rSrbrWrU)rVrrr~rFr}rs rXrJzokx.handle_unsubscriptionsnnWeR0""3 26##C2!!(+ h   . .vv >    &'*<* s + DF#Jc#J,#JJV&V868//F/&9; =C =s =6:"E7EE(:<S&:>bEwEWE(9=RUgUCUB'0F'0R8rhsk AAttttt4*0.')*A$F$   A$FrY