i ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejj Z dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) BalancesIntNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) BadRequest) InvalidNonceceZdZfdZdxZ?S)>okxcB|tt|iddddddddddddddd dd dd dd dd dddddddddddddiddiddidddidddiddiddiddiddidd iidd! |jd"d#d$S)%NwsT watchTicker watchTickerswatchOrderBook watchTradeswatchTradesForSymbolswatchOrderBookForSymbols watchBalance watchOHLCVwatchOHLCVForSymbols watchOrders watchMyTradeswatchPositions createOrderWs editOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWszwss://ws.okx.com:8443/ws/v5zwss://wspap.okx.com:8443/ws/v5)apitestdepthbooksspotchanneltickerstypeANYop batch-orders amend-order) r r$rrr'r(r*r+rchecksumi N)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber<)self __class__s R/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/okx.pyrDz okx.describesc4 0 0 9 9 ; ;dt!$  t  ( +Dd't !$ t  !"!$#$$T%,7: BW1#4!'y y!E E"."- !c22l " aV> V> V V V publicr4c|jd}|rdnd}|dk}|dk}|jdd}|s|dd ks|d kr|d z|zS|r|d z|zS|d z|zS)N sandboxModez?brokerId=9999businessrIr/rcandle orders-algoz /businessz/publicz/private)r@r?find)rEr4access isSandbox sandboxSuffix isBusinessisPublicurls rGget_urlz okx.get_urlmsL/ ,5=((2  * h&it$  3',,x002557m;S;S$}4 4  3?]2 2Z-//rHNsymbolscK|d{V||j}||}|||}|}g}|dd|zz }t dt |D]K}|||} || d} || | |Ld|d} | ||| |d{VS)N::,rr4instId subscriber8args) load_marketsrYmarket_symbolsrXjoinrangelen market_idappendextendwatch) rErRr4rYparamsrW messageHashraimarketIdargrequests rGsubscribe_multiplezokx.subscribe_multiplezs*!!!!!!!!! ?lG%%g..ll7F++ tchhw//// q#g,,'' 2 2A~~gaj11H""C KK C00 1 1 1 1  ZZ[';GGGGGGGGGrHc>K|d{V|||}d|i}|.||}|d|dzz }|d|d<d|||gd} |||| |d{VS)Nr4:idr^r_r`)rbrXmarketrBrj) rErRrlr4symbolrkrW firstArgumentrurps rGr_z okx.subscribes!!!!!!!!!ll7F++ w   [[((F 3- -K&,TlM( #  77   ZZ[';GGGGGGGGGrHrvsincelimitreturncDK||g|||d{VS) 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)rErvrxryrks rG watch_tradeszokx.watch_tradess622F8UE6RRRRRRRRRrHcKt|}|dkrt|jdz|d{V||}d}g}g}t dt|D]T} || } ||dz| z|| } || d} || Ud|d} ||d }| ||| |d{V}|j rB| |d}| |d }| ||}||||d d S) r|rz> watchTradesForSymbols() requires a non-empty array of symbolsNtradesrsr]r_r`rIrv timestampT)rfrrtrbrcrerhrgrXwatch_multiple newUpdates safe_value safe_stringgetLimitfilter_by_since_limit)rErYrxryrk symbolsLengthr4topics messageHashesrmrvrntopicrprWrfirst tradeSymbols rGr}zokx.watch_trades_for_symbolssG A  #DG.n$noo o!!!!!!!!!%%g.. q#g,,'' ! !AQZF  3!7 8 8 8~~f--H""E MM%   ll7H--**3 w VVVVVVVV ? 8OOFA..E**5(;;KOOK77E))&% TRRRrHclientcd||di}||d}||d}||}||dg}||jdd}t dt |D]} ||| } |dz|z} ||j|} | t|} | |j|<| | | | | dS) Nror4r^data tradesLimitrrs) rr safe_symbol safe_integerr@rerf parse_traderrrhresolve) rErmessageror4rnrvrrrmtraderlstoreds rG handle_tradeszokx.handle_tradess. oogub11""3 22##C22!!(++w33'' mTJJ q#d))$$ 0 0A$$T!W--E!C-&0K__T[&99F~#K00&, F# MM% NN6; / / / / 0 0rHcKd}||ddd\}}||d<||g|d{V}|||S)a :see: 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 ` Nrr4r5)handle_option_and_params watch_tickersr)rErvrkr4tickers rG watch_tickerzokx.watch_tickersr77 yZcdd#y))6(F;;;;;;;;vv...rHcK||rt|jdzd}||ddd\}}|d|||d{V}|jr|S||jd|S)a :see: 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 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 ` z( watchTickers requires a list of symbolsNrr4r5rIrv)is_emptyrrtrrqrfilter_by_arrayr5)rErYrkr4 newTickerss rGrzokx.watch_tickerss == ! ! Z#DG.X$XYY Y77PY[dee228WgvVVVVVVVV ?  ##DL(GDDDrHc||di}||d}||dg}g}tdt|D]D}|||}|d} ||j| <||E|||dz} tdt| D]}| |} | d} | d} | d}| |d|}t| }t|}|dkr| || |S) Nror4rrrvr[r\) rrrerf parse_tickerr5rhfind_message_hashessplitrlistkeysr)rErrror4rrrmrrvrrlparts symbolsStringrYr5tickersSymbols numTickerss rG handle_tickerzokx.handle_tickersz4oogub11""3 22w33 q#d))$$ & &A&&tAw//FH%F#)DL   f % % % %004HH q#m,,-- 5 5A'*K%%d++E!!HM#))#..G**:xIIG!',,..11N^,,JA~~w 444rH1mcPK|d{V||}||j||}d|z}|d||||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 NrNrIrT)rbrvr timeframesr_rrr) rErv timeframerxryrkintervalnameohlcvs rG watch_ohlcvzokx.watch_ohlcvDs!!!!!!!!!V$$##DOY JJ("nnXtT66JJJJJJJJ ? 2NN6511E))%q$GGGrHsymbolsAndTimeframesc0Kt|}|dkst|dtst|jdz|d{Vg}g}t dt|D]}||} | d} | d} || } ||j | | } d| z}|| d}| || d|zdz| zd |d }| dd }| ||||d{V\}}}|j r|||}||||dd }||||S) aj watches 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 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 rzu watchOHLCVForSymbols() requires a an array of symbols and timeframes, like [['BTC/USDT', '1m'], ['LTC/USDT', '5m']]NrrNr]multi:rsr_r`rIT)rf isinstancerrrtrbrergrrrhrXrrrrcreate_ohlcv_object)rErrxryrkrrrrmsymbolAndTimeframesymtfrnrr4rrprWrvrcandlesfiltereds rGwatch_ohlcv_for_symbolszokx.watch_ohlcv_for_symbolsWs011 A  Z0DQ0G%N%N #DG/f%fgg g!!!!!!!!! q#23344 A AA!5a!8 $Q'C#A&B~~c**H''R@@H)G""E MM%  G!3c!9C!? @ @ @ @  ll8X..+/+>+>sMSZ\i+j+j%j%j%j%j%j%j" 7 ? 4$$VU33E--gueQMM'' 8DDDrHc||di}||d}||dg}||d}||}|d}|dd} || } t dt |D]} ||| |} ||j|i|j|<||j|| } | ;| |j d d }t|} | |j|| <| | |d z|d z}| | |d |zd z|z}| || | g|dS)Nror4rr^rvrNrLr OHLCVLimitrrsrtr)rr safe_marketreplacefind_timeframererf parse_ohlcvohlcvsrr@rrhr)rErrror4rrnrurvrrrmparsedrryrlmessageHashForMultis rG handle_ohlcvzokx.handle_ohlcv~s"oogub11""3 22w33##C22!!(++!??8R00''11 q#d))$$ M MA%%d1gv66F"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! !!C-&,6K NN6; / / /#+W"4s":V"C  NNFIv68K L L L L M MrHcBK||g||d{VS)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 N)watch_order_book_for_symbols)rErvryrks rGwatch_order_bookzokx.watch_order_books4>66xOOOOOOOOOrHc K|d{V||}||jdi}||dd}|2|dkrd}n)|dkr |dkrd}n|d krd}n|d krd }n|d krd }|d ks|d kr|ddid{Vg}g}t dt|D]T}||} ||dz| z| | } || d} || Ud|d} | |d} | | || |d{V}| S)a 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 :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr r1r2rbbo-tbtbooks52books50-l2-tbti books-l2-tbtrRrIrrsr]r_r`) rbrcrr@r authenticatererfrhrgrXrry)rErYryrkr@r1rrrmrvrnrrprW orderbooks rGrz okx.watch_order_book_for_symbolss!!!!!!!!!%%g..//$,0@"EE  '7;;  zz!uzz #"($& ^ # #2B)B)B##Xx$899 9 9 9 9 9 9 9 q#g,,'' ! !AQZF  v!5 6 6 6~~f--H "E MM%   ll5(++--c='=YYYYYYYY    rHc||d}||d}|||dS)Nrr) safe_floatstore)rEbooksidedeltapriceamounts rG handle_deltazokx.handle_deltasDq))**uf%%%%%rHc~tdt|D]}||||dS)Nr)rerfr)rErdeltasrms rG handle_deltaszokx.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3rHc||dg}||dg}|d}|d}||||||||jdd} | rt |} t |} g} t ddD]} | | krh| ||| d| ||| d| | krh| ||| d| ||| dd| }| |d}| |d}||kr-t|j d z}| ||| |d }||d <|||d <|S) Nasksbidsr;Trrrsz invalid checksumtsrdatetime)rr safe_boolr@rfrerhnumber_to_stringrdrcrc32rrtrejectiso8601)rErrrrlrr storedAsks storedBidsr; asksLength bidsLength payloadArrayrmpayloadresponseChecksum localChecksumerrorrs rGhandle_order_book_messagezokx.handle_order_book_messages)"w33w33v& v&  :t,,, :t,,,>>$, DAA  2ZJZJL1b\\ Q Qz>> ''(=(=jmA>N(O(OPPP ''(=(=jmA>N(O(OPPPz>> ''(=(=jmA>N(O(OPPP ''(=(=jmA>N(O(OPPPhh|,,G#00*EE  JJw55M=00$TW/B%BCC e[111%%gt44 !* + $ Y 7 7 *rHc ||di}||d}||d}||dg}||d}||}|d} ddd dd d } || |} |d z| z} |d kr}t dt |D]]} || }|i| }||j| <| |d<||||| | || ^n@|dkrm| |jvrc|j| }t dt |D]8} || }||||| | || 9n|dks|dkr||j| }||i| }||j| <t dt |D]f} || }||d}| || |dddd}| || || g|S)Nror4actionrr^rvrrrr)rr2rrrrssnapshotrupdaterrrrr) rrrrrerf order_book orderbooksrrparse_order_bookreset)rErrror4rrrnrurvdepthsryrlrmrrrrs rGhandle_order_bookzokx.handle_order_book5sloogub11""3 22!!'844w33##C22!!(++!   !!&'22mf, Z  1c$ii(( 7 7a OOB66 *3'&, (#..vvy+VVVy+6666  7x  (( OF3 q#d)),,;;A!!WF22669kZZZNN9k::::!!w)';';@@I  OOB66 &/DOF #1c$ii(( 7 7a --fd;; 00FTZ\]_`aa)))y+6666rHcK|||dd}||dg}|d|}d}||}||}||j|}|t| }d} d} || z| z} | | | | |j tjd} d} | |j|j|| d gd }|||}||||||d{VS) NrRprivateusers authenticatedGETz/users/self/verifybase64login)apiKey passphrasersignr`)check_required_credentialsromitrXrfuturer subscriptionsstrsecondshmacencodesecrethashlibsha256r passwordrirj)rErkrRrWrlrrrrmethodpathauth signature operationrprs rGrzokx.authenticatesp '')))!!&(I>>6H:..ll7F++% S!!{++( > >||||||rHcK|d{V|d{V|dddd|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 ` Nraccount)rbrr_)rErks rG watch_balancezokx.watch_balances| !!!!!!!!!!!!!!!!!!^^Iy)T6RRRRRRRRRrHcn||di}||d}d}||}||j|i}|||}|||j|<||j||dS)Nror4r3)rrparseTradingBalancebalancerB safe_balancer) rErrror4r6r$ oldBalance newBalances rGhandle_balancezokx.handle_balancesXoogub11""3 22**733__T\4<< %%j':: !..z:: Tt|D)733333rHc||di}||d}||d}||dddk}|||||||d||d||d ||d |rd nd ||d ||d||d||d||d||dd |S)NinfofillTime fillFeeCcyexecTyperLTrvtradeIdrtr6takermakersidefillPxfillSzcostfillFee)r5currency) r*rrrvrtorderr6 takerOrMakerr2rrr5fee)rrr safe_trader safe_numbersafe_currency_code)rEr8rur*r feeMarketIdisTakers rGorder_to_tradezokx.order_to_tradesiufb11%%dJ77 &&t\:: ""4R88C?" Y//&&uh77""433%%eT22$$UF33(/=GGg$$UF33%%dH55&&tX66$$UF33((y99 33K@@  " # rHc Kd}||ddd\}}||dd}||dg}|d{V|d|rdnd id{V|rd nd }|d z}d} |-||} | d }| d}|dz|z}|dkrd}|} d} |d|\} }| dkr| d} d| i} |d ||d| | |d{V} |j r| ||}| | |||dS)a watches information on multiple trades made by the user :see: 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.stop]: 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]{@link https://docs.ccxt.com/#/?id=trade-structure Nr(r6r7stopFrRrMrrPorders ::myTradesrvr[rfuturesSPOTMARGINinstTypeT) rrrrbrruupperhandle_margin_mode_and_paramsr_rirrfilter_by_symbol_since_limit)rErvrxryrkr6isStopr4rlru uppercaseType marginModerprCs rGwatch_my_tradeszokx.watch_my_trades-s44V_fV[\\ f666F8,,!!!!!!!!!+N::Y OPPPPPPPPP#)7--x ,   [[((FH%F&>D%,v5K 8  D  !??QWXX F F " "% (   ~~igtT[[Y`bhMiMijjjjjjjj ? 3OOFE22E00tTTTrHc K|d{V||d{V||}ddi}d}d}|Bddd}|g} d| d} ||d} || || |d{V}n2|d|||||d{V}|jr|S||j |||d S) a :see: 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 dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` NrHr7 positions)r4rHr_r`rT) rbrrcrXrjrqrirfilter_by_symbols_since_limitrQ) rErYrxryrkrpr4 newPositionsroranonSymbolRequestrWs rGwatch_positionszokx.watch_positionsYs_!!!!!!!!!'''''''''%%g..   ?&!C5D!   ,,w 22C!%C:JG!T!TTTTTTTLL!%!8!8GWVZVaVabikqVrVr!s!sssssssL ?  11$.'5RWY]^^^rHc<||di}||dd}||dg}|jt|_|j}g}t dt |D]I}||} || } || || J|||dz} t dt | D]}| |} | d} | d}| d}| |d |d }| |s| || | ||dS) Nror4rLrrr[rr\rvF) rrrQrrerfparse_positionrhrrrrr)rErrror4rcacherSrm rawPositionpositionrrlrrrYrQs rGhandle_positionszokx.handle_positions{sFoogub11""3 266w33 > !577DN q#d))$$ # #Aq'K**;77H    ) ) ) LL " " " "004HH q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|W-----rHc Kd}||ddd\}}||ddd}||ddg}|d{V|d|rd nd id{Vd}|%||}|d }|d}|d krd }|}d} |d|\} }|dkr| d}d|i} |rdnd} |d | | || | |d{V} |j r| ||}| | |||dS)a watches information on multiple orders made by the user :see: 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.stop]: 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 ` Nr'r6r7rBtriggerFrRrMrrvrrErFrGrHrPrCT) r safe_value_2rrbrrurIrJr_rirrrK) rErvrxryrkr6rLrurMrNrpr4rCs rG watch_orderszokx.watch_orderss44V]FTYZZ f""669eDD6FI#677!!!!!!!!!+N::Y OPPPPPPPPP  [[((FH%F&>D 8  D  !?? vVV F F " "% (   $*7--x~~i'64;;W^`fKgKghhhhhhhh ? 3OOFE22E00tTTTrHct|||||di}||d}||dg}t|}|dkrE||jdd}|j(t||_t||_|dkr|jn|j} g} | |} tdt| D]W} | | } | | | d}| |}| |d X| | |tdt| D](} |d z| | z}| | |'dSdS) Nror4rr ordersLimitrrPrvrtrs)handle_my_tradesrrrfrr@rCr triggerOrders parse_ordersrerhrur)rErr subscriptionror4rC ordersLengthryr marketIdsrrmr8rvrurls rG handle_orderszokx.handle_orderssn fg...oogub11""3 22&"556{{ !  %%dlM4HHE{"4U;; %;E%B%B",3},D,DT''4;FI&&v..F1c&kk** / /q  e$$$xV,,  .... NN67 + + +1c)nn-- 4 4%mil: v{3333#   4 4rHc ||di}||d}||dg}g}tdt|D]^}||}||dd} t| dkr*||} || _t|} | dkrdS|j0||jdd} t| |_|j} i}tdt|D]A}||}| |}| ||d }d ||<B|d z}| |j|t| }tdt|D]+}|d z||z}| |j|,dS) Nror4rrr/rLrrrvTrDr[)rrrerf parse_orderrhmyTradesrr@rr@rrrrC)rErrror4 rawOrdersfilteredOrdersrmrawOrderr/r8 tradesLengthryrkrYrawTraderrvrl tradeSymbolssymbolMessageHashs rGrbzokx.handle_my_tradesNs noogub11""3 22OOGVR88 q#i..)) - -A |H&&xB??G7||a((22%%e,,,>** 1   F = %%dlM4HHE2599DM=q#n--.. # #A%a(H''11E OOE " " "8_F"GFOO , t}k222GLLNN++ q#l++,, ; ;A +d 2\!_ D  NN4;(9 : : : : ; ;rHr6r2rrc|K|d{V|d{V|dd}t|}d} ||ddd\} }|||||||} || d} | dks| dks|d ks|d ks |d ks|d krt|j d z| dkr| dkrt|j dz|| | gd} | ||| |d{VS)a :see: 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 fullfilled, 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 ` Nrr*r8r9ordTyper] conditionalocomove_order_stopicebergtwapzw createOrderWs() does not support algo trading. self.options["createOrderWs"]["op"] must be either order or batch-orderr8z createOrderWs() does not support algo trading. self.options["createOrderWs"]["op"] must be either order or privatePostTradeOrder or privatePostTradeOrderAlgortr8ra) rbrrXrnoncercreate_order_requestrrrtrj) rErvr6r2rrrkrWrlr8rartrps rGcreate_order_wszokx.create_order_wss!!!!!!!!!!!!!!!!!!ll9i00$**,,'' 226?DR`aa F((tVUFSS""433 y g&>&>DEMMW[_pWpWpvzHwHwHNRV\N\N\TW(aabb b 'MMn 4 4TW(HHII IF   ZZ[';GGGGGGGGGrHc ||d}||dg}||dd}||rM||d}||}|dd|j|d||dd ||ddd}||di}| ||dS)NrtrsCode0r8r) rr filter_byrjson handle_errorsrWrd safe_dictr) rErrrlrar stringMsgrCrs rGhandle_place_orderszokx.handle_place_orderss&&&w55 w33~~dGS11 ==   g%%gt44F '**I   tT6:vtYPY[_ae f f f""4tT::vq"--uk*****rHrtc K|d{V|d{V|dd}t|} d} ||ddd\} }||||||||} | | | gd} ||| || || d{VS)aA edit a trade order :see: https://www.okx.com/docs-v5/en/#order-book-trading-trade-ws-amend-order :see: 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 fullfilled, 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 ` Nrr+r8r:rz) rbrrXrr{redit_order_requestrjri) rErtrvr6r2rrrkrWrlr8rarps rG edit_order_wszokx.edit_order_wss !!!!!!!!!!!!!!!!!!ll9i00$**,,'' 226=$P]^^ F&&r64vufUUF   ZZ[$++gv2N2NP[\\\\\\\\\rHc&K|t|jdz|d{V|d{V|dd}t |}||dd}||ddg}d| |i}|||d<n||d<|d| ||gd }| ||||d{VS) a :see: 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 argumentrclOrdId clientOrderIdr^ordId cancel-orderrz) rrtrbrrXrr{ safe_string_2rrgrirj) rErtrvrkrWrlrrorps rGcancel_order_wszokx.cancel_order_wssH >TW'TTUU U!!!!!!!!!!!!!!!!!!ll9i00$**,,'' **69oNN 6OY#?@@ dnnV,,   $*C NNCL [[f--.   ZZ[';GGGGGGGGGrHidscfKt|}|dkrt|jdz|t|jdz|d{V|d{V|dd}t |}g}td|D]5}| |||d} | | 6|d|d } | ||| | ||d{VS) a :see: 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 argumentrr)r^rzbatch-cancel-ordersrz) rfrrtrbrrXrr{rergrhrjrB) rErrvrk idsLengthrWrlrarmrorps rGcancel_orders_wszokx.cancel_orders_ws!sfHH r>>TW'YYZZ Z >TW'UUVV V!!!!!!!!!!!!!!!!!!ll9i00$**,,'' q)$$  A..00QC KK    '   ZZ[$2B2B7F2S2SU`aaaaaaaaarHcK|t|jdz|d{V|d{V||}|ddkrt|jdz|dd}t |}|d|d|d d |gd }| ||||d{VS) a :see: 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 argumentr6optionzgcancelAllOrdersWs is only applicable to Option in Portfolio Margin mode, and MMP privilege is required.r mass-cancelOPTIONrt)rH instFamilyrz) rrtrbrrurXrr{rirj)rErvrkrurWrlrps rGcancel_all_orders_wszokx.cancel_all_orders_wsAsE >TW'XXYY Y!!!!!!!!!!!!!!!!!!V$$ &>X % %TW(QQRR Rll9i00$**,,'' [[$$Tl""  ZZ[';GGGGGGGGGrHc||d}||dg}|||dS)Nrtr)rrr)rErrrlrs rGhandle_cancel_all_orderszokx.handle_cancel_all_orders\sH&&w55 w33t[)))))rHc|SNrErrs rGhandle_subscription_statuszokx.handle_subscription_statusns rHcf||jd}|ddS)NrT)rrEr)rErrrs rGhandle_authenticatezokx.handle_authenticatevs1AAtrHcdS)Nr<r)rErs rGr<zokx.ping}s vrHc8||_|Sr) millisecondslastPongrs rG handle_pongzokx.handle_pongs++--rHc||d} |r||jdz||z}||jd||||d}|"||jd||np#t$rc}t|tr/d}| ||||j vr|j |=Yd}~dS| |Yd}~nd}~wwxYw|S)Ncode exactmsgbroadrF) rrtrthrow_exactly_matched_exception exceptionsrthrow_broadly_matched_exception Exceptionrrrr)rErr errorCodefeedback messageStringerls rGhandle_error_messagezokx.handle_error_messages7 %%gv66  ! l7S=499W+=+==44T_W5MyZbccc $ ? ?  ,889QS`bjkkk ! ! !!011 !-  a---&"666,[9uuuuu a         !sA>B D!>C?%C??Dc|||sdS|dkr|||dS||dd}|[|j|j|j|j|j|j|j|jd}|||}||||dSdS||di}||d}|j |j |j |j |j |j |j |j |j |j |j |j |j|jd}|||}|3|dd kr|||dSdS|||dS) Npongeventr8)r r_r8r9r:zbatch-amend-ordersrrror4)rr2rrrr5rQz index-tickersz sprd-tickersz block-tickersrr rCrPrNr)rrrrrrrrrrrr[rr(rhrQr)rErrrmethodsrror4s rGhandle_messagezokx.handle_messages((99  FP f     VW - - - F""7GT::  1!<1 $ 8#7&*&> $ 8#<  G__We44F!vw'''''"!//'5"55C&&sI66G1/0"&"8 $ 6-!2!%!3 $ 2!%!3,.,#1G"__Wg66F~<<))Q..%%fg66666/.vw'''''rH)rIr)@__name__ __module__ __qualname__rDrrXrrqr_rrrr~r}rrrrrrrrrrrr rrrrrrrrr!r(r@rrOrrUr[r r_rhrbr r floatr r}rrrrrrrrr<rrr __classcell__)rFs@rGrrsW W W W W r 0 0s 0 0 0 0LPXZHHHHHH,LNHHHH$<@d[] S S SS S Sbfglbm S S S SOSaenp$S$Sd3i$S$S[^$SuyzvA$S$S$S$SL0F0000@68 / / /F / / / /6:"EE7EEEEE$.F....`8<$]ajlHHHCHWZHquvzq{HHHH&aeswAC%E%E$tCy/%EZ]%Emp%E%E%E%EN)M6)M)M)M)MV@DBPPSPPS\PPPPBSW_a*!*!$s)*!C*!fo*!*!*!*!X & & &333,,,,,\@@@@@D)+>*,SSSSSS34V34343434j037TX\eg*U*UC*Us*URU*Ulpqvlw*U*U*U*UX8<$]ajl _ _W _C _WZ _quv~q _ _ _ _DX.X.X.t04$UYbd(U(U(UC(Us(Uimnsit(U(U(U(UTM4M4FM4M4M4M4^U;vU;U;U;U;npt|~HHCHyH H[`HilHDIHHHH@+&++++@w{DF]]c]3]i]y]bg]ps]KP]]]]8<@HHHSHuHHHH@DHPRbb$s)bSbbbb@8rs AAAAAAAAAAAAGGGGGGGGGGGGGGGGGGGGGGGGGGGGGG444444000000......''''''))))))e(e(e(e(e($  e(e(e(e(e(rH