eioddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById)AnyBoolIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationError)UnsubscribeErrorc eZdZdeffd ZdZdZdifdedede fdZ d e fd Z ifdede fd Zd e fd Zifdedefd ZifdedefdZdZd e fdZd e fdZd e fdZddifdedededeefdZd e fdZifdZdZdddifdedededeefdZd e fdZdddifdedededeefdZ d e fdZ!d e de"fdZ#d e fdZ$d e fdZ%xZ&S)derivereturnc|tt|ddddddddddddd ddiddidddid d d idd iiid S)NFT) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbolswatchPositionsrzwss://api.lyra.finance/wszwss://api-demo.lyra.finance/ws)apitest) tradesLimit ordersLimit requestId keepAlivei(#exact)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/derive.pyr1zderive.describesfd 3 3 < < > > %!%#"&## %!&#)."'   5:  $# TR?$A $A $ $ $ c||jdi}|||d}||d}||jd|<|S)Nr'r) safe_valuer, safe_integersum)r2urlr, previousValuenewValues r4 request_idzderive.request_id9sY//$, R@@))'3:: 88M1--)1 [!#&r5cK|jdd}||}||d|i}|||dd}||||||d{VSNr"rid subscriberAmethodr+r>extendwatchr2 messageHashmessage subscriptionr;r'requests r4 watch_publiczderive.watch_public@sit$OOC(( ++g )(   {{<!2 2   ZZ['; UUUUUUUUUr5Nsymbollimitc4K|d{V|d}||}d|dzdz||z}dd|gid}||||d }||||d{V}|S) aD https://docs.derive.xyz/reference/orderbook-instrument_name-group-depth 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 orderbook.rA.10.rBchannelsrDparams)namerNrOrV) load_marketsmarketnumber_to_stringrMrO) r2rNrOrVrYtopicrLrK orderbooks r4watch_order_bookzderive.watch_order_bookLs!!!!!!!!! =EV$$vd|+f4t7L7LU7S7SS!     ++E7LIIIIIIII    r5clientc||d}||d}||d}||}|d}||d}||jvr^||jdd} |j|} || d| } |i| |j|<|j|} ||d } |||| d d }| || | |dS) NrVdatainstrument_namerNchannelwatchOrderBookLimitr$rO timestampbidsasks) safe_dict safe_string safe_market orderbooksr9r, subscriptions order_bookparse_order_bookresetresolve)r2r^rJrVr`marketIdrYrNr[ defaultLimitrKrOr\rdsnapshots r4handle_order_bookzderive.handle_order_bookms@ 22~~ff--##D*;<<!!(++!  33$/)),,T\;PRVWWL!/6L%%lG\JJE&*oob%&@&@DOF #OF+ %%dK88 ((vy&&QQ!!!y%(((((r5cK|d{V||}d|dzdz}dd|gid}|||d}||||d{VS) a https://docs.derive.xyz/reference/ticker-instrument_name-interval 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 ` Nzticker.rAz.100rBrTrUrWrNrV)rXrYrM)r2rNrVrYr[rLrKs r4 watch_tickerzderive.watch_tickers!!!!!!!!!V$$F4L(61!    &&ug|DDDDDDDDDr5c,||d}||d}||d}||d}||}||j|d<||||S)NrVr`instrument_tickerrbrN)rgr8 parse_tickertickersro)r2r^rJrVrawDatar`r[tickers r4 handle_tickerzderive.handle_tickersB22..00~~g':;; 22""4(()/ VH%&vu%%%r5c<K|d{V||d}|d}||}d|dzdz||z}d|z}dd |gid }d |i}||||d{VS) a unsubscribe from the orderbook channel :param str symbol: unified symbol of the market to fetch the order book for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols NrOrQrRrArSunwatch unsubscriberTrUrW)rXr9rYrZun_watch_public) r2rNrVrOrYr[rIrLrKs r4un_watch_order_bookzderive.un_watch_order_books!!!!!!!!!!!&'22 =EV$$vd|+f4t7L7LU7S7SS%' #   E ))+w MMMMMMMMMr5cK|d{V||}d|dz}d|z}dd|gid}d|i}||||d{VS) a unsubscribe from the trades channel :param str symbol: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request Ntrades.rArrrTrUrW)rXrYr)r2rNrVrYr[ messageHahrLrKs r4un_watch_tradeszderive.un_watch_tradess!!!!!!!!!V$$F4L(& #   E ))*g|LLLLLLLLLr5cK|jdd}||}||d|i}|||dd}||||||d{VS)Nr"rrArrCrErHs r4rzderive.un_watch_public(sit$OOC(( ++g )(   {{<#2 2   ZZ['; UUUUUUUUUr5cl|d}||d}||}|d}||jvr|j|=||jvr|j|=t |jdz|z}|||||d|zdS)N.r7rNz orderbook r) splitrhrirjrkrrArejectror2r^r[ parsedTopicrprYrNerrors r4!handle_order_book_un_subscriptionz(derive.handle_order_book_un_subscription4skk#&& ##K33!!(++! T_ $ $' F( ( ($U+ =!86!ABB eU###ui%/00000r5cl|d}||d}||}|d}||jvr|j|=||jvr|j|=t |jdz|z}|||| |d|zdS)Nrr7rNz trades r) rrhrirjtradesrkrrArrors r4handle_trades_un_subscriptionz$derive.handle_trades_un_subscriptionAskk#&& ##K33!!(++! T_ $ $ F# F( ( ($U+ :!5!>?? eU###ui%/00000r5c||d}||d}|t|}tdt |D]i}||}|ddkr|||:|ddkr|||j|S)Nresultstatusrr\r)rglistkeysrangelenfindrr)r2r^rJrrtopicsir[s r4handle_un_subscribezderive.handle_un_subscribeNs2211  &++--((F1c&kk** F Fq ::k**a//::65IIIIZZ))Q..66vuEEEr5sincecHK|d{V||}d|dz}dd|gid}|||d}||||d{V} |jr| |d|}|| |||d S) a- watches information on multiple trades made in a market https://docs.derive.xyz/reference/trades-instrument_name :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 ` NrrArBrTrUrurNT)rXrYrM newUpdatesgetLimitfilter_by_symbol_since_limit) r2rNrrOrVrYr[rLrKrs r4 watch_tradeszderive.watch_tradesds!!!!!!!!!V$$F4L(!    ((FFFFFFFF ? =OOF8$4e<str milliseconds signMessage privateKeyrhr,rFrG) r2rVr;r^rIfuturerr'nowrrrLrJs r4 authenticatezderive.authenticates. '')))it$S!!% &&{33(>I"&"2"24rFrGrHs r4 watch_privatezderive.watch_privates!!!!!!!!!it$OOC(( ++g )(   {{<!2 2   ZZ['; UUUUUUUUUr5cK|d{Vd}|d|\}}||dz}|}|%||}|d}|d|zz }dd|gid} ||d } || |} ||| | d{V} |jr| ||}|| |||d S) as https://docs.derive.xyz/reference/subaccount_id-orders 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 :param str [params.subaccount_id]: *required* the subaccount id :returns dict[]: a list of `order structures ` Nrz.ordersrN:rBrTrUrWrVT rXhandleDeriveSubaccountIdrZrYrFrrrr) r2rNrrOrV subaccountIdr[rIrYrLrKrJorderss r4 watch_orderszderive.watch_orderssA!!!!!!!!! #<<]FSS f%%l33i?  [[((FH%F 3< 'K!    ++gv..))+w MMMMMMMM ? 3OOFE22E00tTTTr5c||d}||d}||d}tdt |D]~}||}||}||d} ||d} | /|j0||jdd} t| |_|j} | | j | i} | | | }|| |d }|||d <| |d }|||d <| |d |d <||d |d <||d |d <| ||dz| z}| |j|| |j|dS)NrVrbr`rrNrAr&r$feefeesrrddatetimer)rgrh safe_listrr parse_orderrr9r,rr8hashmaprro)r2r^rJrVr[ rawOrdersrr`parsedrNorderIdrO cachedOrdersrorderrrmessageHashSymbols r4 handle_orderzderive.handle_ordersT22  33NN6622 q#i..)) ? ?AQ>>t{E*****r5cK|d{Vd}|d|\}}||dz}|}|%||}|d}|d|zz }dd|gid} ||d } || |} ||| | d{V} |jr| ||}|| |||d S) as https://docs.derive.xyz/reference/subaccount_id-trades watches information on multiple trades 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 :param str [params.subaccount_id]: *required* the subaccount id :returns dict[]: a list of `trade structures ` Nrz.tradesrNrrBrTrUrTr) r2rNrrOrVrr[rIrYrLrKrJrs r4watch_my_tradeszderive.watch_my_trades4sA!!!!!!!!! #<<_fUU f%%l33i?  [[((FH%F 3< 'K!    ++gv..))+w MMMMMMMM ? 3OOFE22E00tTTTr5c|j}|+||jdd}t|}||d}||d}||d}tdt|D]c}| |} | | | |||| dz} | || ddS)Nr%r$rVrbr`rrN) myTradesr9r,rrgrhrrrrrro) r2r^rJrrOrVr[ rawTradesrrrIs r4handle_my_tradezderive.handle_my_trade\s=  %%dlM4HHE-e44H22  33NN6622 q#i..)) 2 2A$$W--E OOE " " " NN8U + + +%/1K NN8[ 1 1 1 1  2 2r5cd|vrdS||d}||d} |Q|jdz||z}||jd||t |dS#t$r_}t|tr*d}| ||||j vr|j |=n| |Yd}~dSd}~wwxYw)NrFcode r)rT) rgrhrAjsonthrow_exactly_matched_exceptionr.r Exception isinstancerrrk)r2r^rJ errorMessage errorCodefeedbackrrIs r4handle_error_messagezderive.handle_error_messagems7""5~~gw77 $$\6::  $7S=499W+=+==44T_W5MyZbccc#H---5   %!455 %-  e[111&"666,[9 e$$$44444 sAB C2AC--C2cX|||rdS|j|j|j|j|jd}d}||d}|||d}|||d}| ddks| ddkr||d}|dkrd }n||d}| ||}||||dSd |vr||d } | |j d } | | | i} d | vrJ| d d kr| ||dS| d d kr|||dSdSdSdS)N)r\r|rrmytradesrVrbrrrrr7rrArDrr)rrsr}rrrrgrhrrr8index_byrk handle_authr) r2r^rJmethodseventrVrb parsedChannelrDrAsubscriptionsByIdrKs r4handle_messagezderive.handle_messages  $ $VW 5 5  F/('',   22  &&vy99G" ' c 2 2 LL**a//GLL4J4JQ4N4N ,,]A>>E(( * ,,]A>>E%00   F67 # # # F 7??!!'400B $ f.BD I I ??+rMrrr r]r rsr rvr}rrrrrrrr rrrrr rrrrrrrrr __classcell__)r3s@r4rrs% #% % % % % % N V V V@DB!!S!!S\!!!!B)))))B68EEEFEEEE8HFHHHHT=?NNN3NNNN89;MMCMsMMMM0 V V V 1 1 1 1 1 1F 1 1 1 1&,<@d[]UUUSUUbfglbmUUUUB+6++++()+< V V V04$UYbd&U&U&UC&Us&Uimnsit&U&U&U&UPF+6F+F+F+F+P37TX\eg&U&UC&Us&URU&Ulpqvlw&U&U&U&UP2f2222"6t6#>V#>#>#>#>L:&::::::::r5r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrrr async_supportrr5r4rs OOOOOOOOPPPPPPPPPPPPPPPPPPPP444444******000000------p :p :p :p :p :T  &p :p :p :p :p :r5