iZddlZddlmZmZddlmZmZmZm Z ddl m Z ddl m Z ddlmZGddejjZdS) N) ArrayCacheArrayCacheByTimestamp)Int OrderBookTickerTrade)Client)List) ExchangeErrorc `eZdZfdZdZifdedefdZdefdZ ddifded e d e de e fd Z defd Zd ddifded e d e de efdZdefdZdifded e defdZdefdZdZdZdZdefdZdefdZdefdZdefdZdefdZdefdZdZdefdZdefdZ defdZ!xZ"S)huobijpc |tt|ddddddddddddddiiid d dd did d S) NTF)wswatchOrderBook watchTickers watchTicker watchTrades watchBalance watchOHLCVapirzwss://{hostname}/wszwss://{hostname}/ws/v2)publicprivategunzip) tradesLimit OHLCVLimitrr)hasurlsoptions) deep_extendsuperr describe)self __class__s V/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/huobijp.pyr"zhuobijp.describesgt 4 4 = = ? ?"& %## %"&;'?    $"d )B B    c|||jddd}||jd<t|S)N requestIdr)sum safe_integerrstr)r#r(s r% request_idzhuobijp.request_id/sAHHT..t|[!LLaPP $- [!9~~r&symbolreturncK|d{V||}|d}d|dzdz}||jdd}d|ji}||jdd|d |}|}||d } ||||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 ` Nr.market.idz.detailrhostnamerrsubr2r2 messageHashr.params) load_marketsmarket safe_stringrr3implode_paramsrr-watchextend) r#r.r8r:r7rr3urlr(request subscriptions r% watch_tickerzhuobijp.watch_ticker4s#!!!!!!!!!V$$!&,.: t|UE:: .!!$)E"24"8"=h"GRROO%%    &   ZZ[$++gv2N2NP[]ijjjjjjjjjr&clientc||di}||d}|d}||d}||}|||}||d} | |d<|| |d<|d} ||j| <||||S) Ntickch.r)ts timestampdatetimer.) safe_valuer;split safe_market parse_tickeriso8601tickersresolve) r#rCmessagerErFpartsmarketIdr:tickerrIr.s r% handle_tickerzhuobijp.handle_tickerPs$w33   gt , , ##E1--!!(++""400OOGT22 '{!\\)44z!% Vvr"""r&NsincelimitcRK|d{V||}|d}d|dzdz}||jdd}d|ji}||jdd|d |} |} || d } | |||d } || || | ||| d{V} |j r| ||}| | ||d d S)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 ` Nr.r1r2z .trade.detailrr3rrr4r6rIT) r9r:r;rr3r<rr-r=r> newUpdatesgetLimitfilter_by_since_limit)r#r.rWrXr8r:r7rr3r?r(r@rAtradess r% watch_tradeszhuobijp.watch_tradesps[!!!!!!!!!V$$!&,.@ t|UE:: .!!$)E"24"8"=h"GRROO%%    &   zz#{DKK4P4PR]_kllllllll ? 3OOFE22E))&% TRRRr&c||di}||di}||d}|d}||d}||}|d} ||j| } | 5||jdd} t| } | |j| <td t|D]3} | || |} | | 4| | ||S) NrEdatarFrGr)r.rrr) rKr;rLrMr]r+rrrangelen parse_tradeappendrQ)r#rCrRrEr`rFrSrTr:r. tradesCacherXitrades r% handle_tradeszhuobijp.handle_tradess9*w33tVR00   gt , , ##E1--!!(++!oodk6::  %%dlM4HHE$U++K"-DK q#d))$$ & &A$$T!Wf55E   u % % % %{B'''r&1mcK|d{V||}|d}||j||}d|dzdz|z}||jdd} d|ji} ||jdd| d | } |} || d } | ||||d }| | || | |||d{V}|j r| ||}| |||d d S)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 Nr.r1r2z.kline.rr3rrr4)r2r7r. timeframer8rT)r9r:r; timeframesrr3r<rr-r=r>rZr[r\)r#r.rkrWrXr8r:intervalr7rr3r?r(r@rAohlcvs r% watch_ohlcvzhuobijp.watch_ohlcvs|!!!!!!!!!V$$!##DOY JJ&,.:XE t|UE:: .!!$)E"24"8"=h"GRROO%%    &"   jjk4;;w3O3OQ\^jkkkkkkkk ? 2NN6511E))%q$GGGr&c||d}|d}||d}||}|d}||d}||} ||j|i|j|<||j|| } | ;||jdd} t| } | |j|| <||d} | | |} | | | | |dS) NrFrGr)r.rrrE) r;rLrMfind_timeframerKohlcvsr+rr parse_ohlcvrdrQ)r#rCrRrFrSrTr:r.rmrkstoredrXrEparseds r% handle_ohlcvzhuobijp.handle_ohlcvsJ"  gt , , ##E1--!!(++!##E1--''11 "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *w//!!$// fvr"""""r&cK||dkrt|jdz|d{V||}|d}|dn|}d|dzdzt |z}||jdd}d |ji}||j dd |d |}| } || d } | |||||j d } | ||| | ||| 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 Nz( watchOrderBook accepts limit = 150 onlyr.r1r2z.mbp.rr3rrr4r2r7r.rXr8method)r r2r9r:r,r;rr3r<rr-handle_order_book_subscriptionr=r>rX) r#r.rXr8r:r7rr3r?r(r@rA orderbooks r%watch_order_bookzhuobijp.watch_order_booksw  ESLL*T TUU U!!!!!!!!!V$$! E&,.83u::E t|UE:: .!!$)E"24"8"=h"GRROO%%    &9   **S+t{{7F7S7SU`bnoooooooo    r&c||d}||d}|j|}||d}|||}||d|d<|||j} tdt| D]} | || | | ||j|<| ||dS)Nr.r7r`seqNumnoncer) r; orderbooksrKparse_order_bookr+resetcacherarbhandle_order_book_messagerQ) r#rCrRrAr.r7r}r`snapshotmessagesrfs r%handle_order_book_snapshotz"huobijp.handle_order_book_snapshot!s*!!,99&&|]CC OF+ w//((v66 --dH==!!!?q#h--(( K KA  * *68A; J J J J"+y+.....r&cK||d} ||d}||d}||d}||jdd}d|ji} ||jdd|d| } |} || d } | |||||jd } | | | | | | d{V}| S#t$r(}|j |=| ||Yd}~nd}~wwxYwdS) Nr7r.rXr8rr3rr)reqr2rz)r;r+rKrr3r<rr-rr=rX Exception subscriptionsreject)r#rCrRrAr7r.rXr8rr3r?r(r@snapshotSubscriptionr}es r%watch_order_book_snapshotz!huobijp.watch_order_book_snapshotDs&&|]CC  *%%lH==F%%lG<>C"DM2H%%di&6t&EE'8"==  #__\8<||j||dSr)rrrs r% handle_pingzhuobijp.handle_pings  49fg.....r&cD||d}|dkr||d}||jd}|||}|||d} ||jd|||nj#t$r]}||d} ||| |||||jvr|j|=Yd}~nd}~wwxYwdS|S)Nstatuserrorr2zerr-codeexactr7F) r;rrrKthrow_exactly_matched_exception exceptionsjsonrr) r#rCrRrr2rrA errorCoderr7s r%handle_error_messagezhuobijp.handle_error_message s=!!'844 W  !!'400B $ f.BD I I ??+5B44 D>ADDcJ|||r||d|||dS||d|||dS||d|||dSdSdS)Nr2rFr)rr;rrrrs r%handle_messagezhuobijp.handle_message's  $ $VW 5 5 2..://@@@@@!!'400<##FG44444!!'622>  11111% 2 2"?>r&)#__name__ __module__ __qualname__r"r-r,rrBr rVrr rr^rhlistrorwrr~rrrrrrr|rrrrrrr __classcell__)r$s@r%r r s     > 68kkkFkkkk8F@<@d[]SSSSSSbfglbmSSSSB%F%%%%N8<$]ajl!H!H!HC!HWZ!Hquvzq{!H!H!H!HF!#6!#!#!#!#F@DB!!!!S!!!!S\!!!!!!!!F!/!/!/!/!/F>&&& 333!!!!!F!3!3!3!3!3FRVRRRR* 6    #(V#(#(#(#(JHHH /&////682V22222222r&r )ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrr!ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportr rr&r%rs NNNNNNNN999999999999444444******l2l2l2l2l2d (l2l2l2l2l2r&