o Th @sdZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z e eZGdddZzddl mZeedZed WdSeyhZzed eeZed WYdZ[dSdZ[ww) u Client Hyperliquid pour récupérer les balances et positions réelles Version améliorée avec patterns éprouvés de l'archive N)DictListOptional)MASTER_ACCOUNT_ADDRESSBASE_URLDEFAULT_HEADERSc@seZdZdZdbdedefddZdedeefd d Zdeefd d Z deee ffd dZ de efddZ deefddZdedee fddZdedefddZdeeeffddZdefddZdede fddZdeeeffddZdefdd Zdcded"ed#e d$ed%ed&edefd'd(Zddd*ed+ede efd,d-Zdeded/e d0edee fd1d2Zd3e ede efd4d5Zd6e d7e defd8d9Zd:e d;e d#e dZdfd:e d@e d#e d      zHyperliquidClient.get_positionscCsddi}||S)u>Récupère les informations meta (leverages disponibles, etc.)r8meta)r5)r#r*r'r'r( get_meta_infos zHyperliquidClient.get_meta_inforfc CszK|dd}|j}t|dkrWdS|dd}|d}d}t|D]\}}|d|kr3|}nq%|durI|t|krIt||d } | WSWdStyi} ztd |d | WYd} ~ dSd} ~ ww) u2Récupère le mark price actuel depuis HyperliquidUSDTrMNruniversenamemarkPxu!Erreur récupération mark price rO) replacermeta_and_asset_ctxsr< enumeraterQrrr) r#rf clean_symbol meta_and_ctxsry asset_ctxs symbol_indexiasset mark_pricer$r'r'r(get_current_market_prices,     z*HyperliquidClient.get_current_market_pricecCsH|}|r d|vr dS|dD]}|d|kr!|ddSqdS)uKRécupère le nombre de décimales autorisées pour un symbole (szDecimals)ryr{ szDecimals)rvrP)r#rf meta_info token_infor'r'r(get_symbol_decimalss  z%HyperliquidClient.get_symbol_decimalscCsZ|}|r d|vr iSi}|dD]}d|vr*d|vr*|d}t|d}|||<q|S)u>Récupère les leverages maximum disponibles pour chaque tokenryr{ maxLeverage)rvint)r#r leveragesrrf max_leverager'r'r(get_available_leveragess   z)HyperliquidClient.get_available_leveragesc Csz%|}|s WdSd}|D]}tt|dd}|dkr"|d7}q|WSty?}ztd|WYd}~dSd}~ww)u9Récupère le nombre de positions actives sur Hyperliquidrrhrzu9Erreur lors de la récupération du nombre de positions: N)rtrnrQrPrr3)r#ro active_countrqrhr$r'r'r(get_active_positions_counts z,HyperliquidClient.get_active_positions_countc Csz^|jd}ddi}tj||d}|jdkrWdS|}t|dkr'WdS|dd }|d }d }t|D]\} } | d |krF| }nq7|d ksQ|t|krTWdSt||d } | WSt y{} zt d|d| WYd} ~ dSd} ~ ww)u/Récupère le mark price actuel pour un symboler,r8metaAndAssetCtxs)r.rxrryrzr{r|u&Erreur récupération mark price pour rON) rr0r1 status_coder.r<rrPrQrr3) r#rfurlr*r4rryrrrrrr$r'r'r(rs4    c Csz\|}|s iWSi}|D]K}tt|dd}|dkrY|dddd}|dd}|d|}|||t|ddt|d dt|d id d |d ||<q|WStyw}ztd|iWYd}~Sd}~ww)uGRécupère les détails des positions actives groupées par symbol_siderhrrfrMrbrg_rirjravaluerz)rfrgrhrirjraraw_datau<Erreur lors de la récupération des détails de positions: N) rtrnrQrPr}upperrrr3) r#roactive_positionsrqrhrfrgkeyr$r'r'r(get_active_positions_details9s4  z.HyperliquidClient.get_active_positions_detailsc CszG|}|}|}|dd}|dd}||}tdd|D}tdd|D}||||||||j|rC|ddd WSdd WStym} ztd | dddddgit | d WYd } ~ Sd } ~ ww) u+Récupère un résumé complet du portfoliorDrrIcss|]}|dVqdS)rjNr').0rqr'r'r( dsz:HyperliquidClient.get_portfolio_summary..cSsg|] }|ddkr|qS)rhrr')rpr'r'r( gsz;HyperliquidClient.get_portfolio_summary..time) rTavailable_balance margin_usedrjrrorKr timestampzErreur portfolio summary: )rTrrrjrrorKrN) rZrtr=rPsumr<rrr3str) r#rKror:total_account_valuerrtotal_unrealized_pnlactive_positions_countr$r'r'r(get_portfolio_summaryWsD    z'HyperliquidClient.get_portfolio_summaryFis_buyrh reduce_onlyra order_tagc Csxz|jsd}t|d|dWS|dkr&d|}t|d|dWS|dddd}td |d |r:d nd d ||rHd |dnd|rNdnd|r|dkr|sz6td|d|d|jjt||dd} td| | r| ddkrtd| ddWnt y} ztd| WYd} ~ nd} ~ ww| |} t || } | |krtd|d|d| d | d! |s|rd nd } d"| d#|}|rd$| d#|}td%|d |d&| d'|d(| td)|d |d(|d*z |jj ||| d+|d,}Wn%t y:}ztd-||jj ||| d+d.}WYd}~nd}~wwtd/||rt |tr|ddkrv|dd}d0t|vrgd1|d2}td3|d||d4WS|dd5kr|d6idid7i}|d8g}|D]"}|d9r|d9}td:|dd;||d4WSq|did7i}|d8g}d}|r|dd<p|dd=}td>|d?d@|||||rd nd |tdAWSWdS|did9t|}dB|}t|d||d4WSt y;} zdC| }t|d|t| dDWYd} ~ Sd} ~ ww)Eu6 Place un ordre au marché sur Hyperliquid avec gestion d'erreurs améliorée Args: symbol: Symbole du token (ex: "BTC", "ETH") is_buy: True pour acheter, False pour vendre size: Taille de l'ordre reduce_only: True pour fermer une position seulement leverage: Effet de levier à appliquer (ex: 3, 5, 10) order_tag: Tag/label pour identifier l'ordre (ex: "AUTO_BUY_SIGNAL", "CLOSE_TP") Returns: Dict avec le résultat de l'ordre u>Exchange API non initialisé - impossible de passer des ordresFsuccessrrzTaille d'ordre invalide: rbrMz-USDuLIVE: Passage ordre marché  BUYSELLz leverage xz (reduce_only)rzuDéfinition leverage zx pour z en mode ISOLATED)rar{is_crossuLeverage défini: statuserrzErreur leverage: r4Erreur inconnueuErreur définition leverage: NzTaille arrondie rOz -> z (u décimales)AUTO_rCLOSE_zEnvoi ordre Hyperliquid: z taille=z tag=z reduce_only=zOrdre z": market_open() avec slippage 0.5%g{Gzt?)r{rszslippagecloidu#Tag non supporté, ordre sans tag: )r{rrruRésultat ordre: zdoes not existuAPI Wallet non autorisé: z4 - Veuillez enregistrer l'API wallet sur HyperliquidzErreur API Hyperliquid: rrresultokrdatastatusesrzErreur ordre Hyperliquid: zErreur ordre: restingfilledu*SUCCES: Ordre exécuté avec succès (ID: rGT)rorder_idrrrfrgrhruOrdre rejeté: z)Erreur critique lors du passage d'ordre: rr exception)rrrr}rupdate_leveragerrPr"rrround market_open isinstancedictrr)r#rfrrhrrar error_msgrleverage_resultr$decimals rounded_sizeaction order_result tag_error response_datarrr error_detailsr'r'r(place_market_orders        $ (          #    z$HyperliquidClient.place_market_orderd user_addresslimitc Csz=|js tdgWS|p|j}|j|}|r6t|dddd}|d|}tdt|d|WStd gWStyY}ztd |gWYd}~Sd}~ww) u? Récupère les informations de fills (ordres exécutés) récents Args: user_address: Adresse utilisateur (utilise self.account_address par défaut) limit: Nombre maximum de fills à récupérer Returns: List des fills récents r6cSs |ddS)NrrrPrr'r'r(:s z1HyperliquidClient.get_fill_info..TrreverseN Récupéré u fills récentsuAucun fill trouvéuErreur récupération fills: ) rrrr user_fillssortedr;r<r)r#rr user_addrfills fills_sorted fills_limitedr$r'r'r( get_fill_info#s$      zHyperliquidClient.get_fill_info order_timetolerance_secondsc Csz?|}|D].}|d|kr5t|ddd||kr5t|dd}td|d||WSqtd|Wd StyY}ztd |WYd }~d Sd }~ww) uh Récupère le prix d'exécution réel depuis les fills récents Args: symbol: Symbole recherché order_time: Timestamp de l'ordre (epoch) tolerance_seconds: Tolérance en secondes pour trouver le fill Returns: Prix d'exécution réel ou None si non trouvé rLrrpxuPrix d'exécution trouvé:  à $u.WARNING: Aucun prix d'exécution trouvé pour Nu0ERROR: Erreur récupération prix d'exécution: )rrPrnrQr3r)r#rfrrrfillexecution_pricer$r'r'r(get_execution_price_from_fillsGs   z0HyperliquidClient.get_execution_price_from_fillstradesc Csg}i}t|ddd}|D]}|d}|dd}|dks(dt|d dvr8||vr0g||<|||q|d ksFd t|d dvr||vr||r||d }d |dd|d||ddkridnd|d|d|d|d|d||d|d|dd p|j|d|d|d|ddkrdnddd|dd |dd dd } || q|D]=\}}|D]6}d|d||ddkrdnd|dd|d|dd||dtd |dd ddd } || qq|S) u Regroupe les trades individuels en positions complètes Une position = un trade OPEN + un trade CLOSE sur le même symbole cSs|dS)Nrr'rr'r'r(rosz=HyperliquidClient.group_trades_to_positions..)rrf operationrMOPENOpendirCLOSECloserpos_idrrgrrcrdpricerhrpnl)ri current_pricerhrg pnl_dollarfee HYPERLIQUID) rrfrgri exit_pricerh open_time close_timedurationrfeessource pos_open_N) rrfrgrirrhrrrrrrr) rrPrrmpop_calculate_durationcalculate_position_pnlitemsr) r#rro open_trades sorted_tradestraderfr open_trader\r'r'r(group_trades_to_positionsfsl     z+HyperliquidClient.group_trades_to_positions start_timeend_timecCsVt||}|d}|dd}|d}|dkr#|d|d|dS|d|dS)u'Calcule la durée entre deux timestampsi<rzh zm s)r)r#rrduration_secondshoursminutessecondsr'r'r(r s  z%HyperliquidClient._calculate_durationrirrgcCs |dkr |||S|||S)zCalcule le PnL d'une positionrr')r#rirrhrgr'r'r(_calculate_pnls  z HyperliquidClient._calculate_pnlrzrc Cs||dks|dkrddddS|dkr|||}n|||}|dkr,|||d}n|||d}||}|||dS)u Calcule le PnL d'une position de manière centralisée Utilisé par ProfitTaker et l'historique pour garantir la cohérence Args: entry_price: Prix d'entrée current_price: Prix actuel (ou de sortie) size: Taille de la position side: 'LONG' ou 'SHORT' leverage: Levier utilisé Returns: dict avec pnl_dollar, pnl_percent, etc. rr)r pnl_percentpnl_percent_leveragedrcrr') r#rirrhrgrarrrr'r'r(r s  z(HyperliquidClient.calculate_position_pnlc Cstz|j|dd}||}|jdddd|d|WSty9}ztd|gWYd}~Sd}~ww) u Récupère l'historique des positions (trades regroupés) Returns: Liste des positions fermées et ouvertes rxrcSs|dp |ddS)Nrrrrrr'r'r(rsz8HyperliquidClient.get_position_history..TrNu,Erreur récupération historique positions: )sync_trade_historyrsortrrr)r#rrror$r'r'r(get_position_historys z&HyperliquidClient.get_position_history1hintervallookback_hoursc Cs zddl}ddl}ddl}t|d}||ddd}d||||dd} |jd| d d } | jd krLtd |d |d|jd| d d } | jdkr`t d| jd|WdS| } | rj| dkrutd|WdSg} | D]g} t | t r| t| ddt| ddt| ddt| ddt| ddt| dddqyt | trt| dkr| t| dt| dt| dt| dt| dt| ddqytdt| d || WSty}zt d!|d"|WYd}~dSd}~ww)#u Récupère les données de chandeliers pour un symbole Args: symbol: Symbole (ex: 'BTC', 'ETH') interval: Intervalle de temps ('1m', '5m', '15m', '1h', '4h', '1d') lookback_hours: Nombre d'heures à récupérer Returns: Liste des chandeliers avec 'time', 'open', 'high', 'low', 'close', 'volume' rNrrcandleSnapshot)rLr# startTimeendTime)r8reqz https://api.hyperliquid.xyz/infor-)r.r/izRate limit atteint pour z, pause de 2 secondesrxrz Erreur HTTP z pour uAucune donnée chandelier pour tohlcv)ropenhighlowclosevolumerrzrz chandeliers pour u"Erreur récupération chandeliers rO)rr0r.rr1rrr"sleeprrrrmrPrQlistr<r;r)r#rfr#r$ time_moduler0r.rrr*r4candlesformatted_candlescandler$r'r'r(get_candles_datasj              z"HyperliquidClient.get_candles_datasymbol1symbol2c sLz|j|d|d}|j|d|d}|r|s$td|d|WdSii|D] }|d|d<q*|D] }|d|d<q7ttt@}t|dkrdtd |d|WdSfd d |Dfd d |Dfd d tdtDfdd tdtDtdkrWdSddl}| | t fddttD} t fddttD} t fddttD} | | d} | dkrWdS| | } t d|d|d| ddtd | WSt y%}zt d|d|d|WYd}~dSd}~ww)uG Calcule la corrélation entre deux symboles Args: symbol1: Premier symbole (ex: 'BTC') symbol2: Second symbole (ex: 'ETH') lookback_hours: Période de calcul en heures Returns: Corrélation entre -1 et 1, ou None si erreur r!)r#r$u&Données manquantes pour corrélation -Nr2rrxu$Pas assez de données communes pour cg|]}|qSr'r'rr))prices1r'r(r|z;HyperliquidClient.calculate_correlation..crAr'r'rB)prices2r'r(r}rDc,g|]}||d|dqSrzr'rr)aligned_prices1r'r(r$rzcrFrGr'rH)aligned_prices2r'r(rrJrc3s(|]}||VqdSNr'rH)mean1mean2returns1returns2r'r(rs&z:HyperliquidClient.calculate_correlation..c3 |] }|dVqdSrxNr'rH)rMrOr'r(rc3rQrRr'rH)rNrPr'r(rrSg?ru Corrélation rOz.3fz sur u périodesuErreur calcul corrélation )r=rr"rsetkeysr<range statisticsmeanrr;rr)r#r>r?r$candles1candles2r< common_timesrW numeratorsum_sq1sum_sq2 denominator correlationr$r')rIrKrMrNrCrErOrPr(calculate_correlationUsV         $   *z'HyperliquidClient.calculate_correlationcCs|dkrdS|d||S)u Calcule la corrélation entre BTC et un autre symbole Args: symbol: Symbole à comparer avec BTC lookback_hours: Période de calcul Returns: Corrélation avec BTC (-1 à 1) ou None BTCg?)ra)r#rfr$r'r'r(get_btc_correlations z%HyperliquidClient.get_btc_correlationc CsPz|j|d}|stdgWSg}|D]h}|ddd}|ddkr(dnd }|d d }d |vr6d nd}d|dd|dd ||t|ddt|dd|t|dd|drjt|ddnd|d|dd|d } || qtdt|d|WSty} ztd| gWYd} ~ Sd} ~ ww)u  Récupère l'historique des trades Hyperliquid et les convertit au format du système Args: limit: Nombre maximum de fills à récupérer Returns: Liste des trades au format du système ru&Aucun fill Hyperliquid à synchroniserrrrrgBrrrrMrrrhl_oidrLrrr closedPnlNhashr) rrfrgrrhrrrrrrhrraw_fillu Synchronisé z trades depuis Hyperliquidz#Erreur synchronisation historique: ) rrrrPrQrmr<rr) r#rr synced_tradesrrrg directionoperation_typerr$r'r'r(rsB     z$HyperliquidClient.sync_trade_historyc CsZz|}|stdWdS|WSty,}ztd|WYd}~dSd}~ww)u Récupère l'état complet du compte Hyperliquid Compatible avec l'API dashboard Returns: Dict avec marginSummary, positions, etc. r>Nu$Erreur récupération état compte: )r=rr"rr)r#r:r$r'r'r(get_account_states z#HyperliquidClient.get_account_statestop_loss_pricec Csz|js dddWS|dd}tt|d}td|d|d |}d }|D]}|d ddd|kr>|}nq,|sKdd |d dWSt|dd}|dkradd |ddWS|dkrjd} d} nd} d} t|} td| d| d|d|zZ|jr|j |j ng} | r| D]G} | d|kr| ddr| d}|rz|j |t |td|Wqt y}ztd|d|WYd }~qd }~wwqWnt y}ztd|WYd }~nd }~wwz|jj|| | |dt|ddd idd!}td"||r,|d#d$kr,d||| | |d%d&WWSd}|rWd'|vrWd(|d'vrW|d'd(}d)|vrW|d)rW|d)dd*d+}td,|td-|d.|d d||| | dd/d0|d1WWSt y}z&td2|td-|d.|d d||| | dd/d3d1WYd }~WSd }~wwt y}z$t|d4d5d6d7}d8|}t|d|t|d9WYd }~Sd }~ww):uv Met à jour le stop loss d'une position en créant un ordre stop limit Utilise exchange.order() pour créer un ordre de protection Args: symbol: Symbole du token (ex: "BTC", "ETH") stop_loss_price: Nouveau prix de stop loss Returns: Dict avec le résultat de la mise à jour FExchange API non disponiblerrbrMrxuCréation ordre stop loss: z stop=$rFNrfr`u non trouvéerhru ferméeSellTBuyz Ordre stop: rz @ $rL reduceOnlyrfuAnnulé ordre stop existant: uÉchec annulation ordre rOu'Échec vérification ordres existants: triggersl) triggerPxisMarkettpsl)r{rrlimit_px order_typeruRésultat ordre stop: rrstop_trigger_order)rrnrf order_side order_sizermethodr4rrrruÉchec ordre stop: z"Activation stop loss virtuel pour rtrailing_stop_fallbackuFallback - ordre échoué: )rrnrfr{r|virtualr}notezException ordre stop: zFallback - exception ordre{z{{}z}}zErreur update stop loss: r)rr}rrQrrrtrPrn open_ordersrcancelrrr"orderrr)r#rfrnr rounded_pricerotarget_positionrq position_sizerr{r|existing_ordersrrcancel_er$rrrorder_esafe_err'r'r(update_position_stop_losss   "  "        z+HyperliquidClient.update_position_stop_lossr new_pricenew_sizec Cs(zo|js dddWS|sdddWStd|d|d|dt|i}|d ur0t||d <|d ur:t||d <|j|}td ||rZ|d dkrZd||||dWS|didt|}dd||dWSty}zd|}t|d|t|dWYd }~Sd }~ww)u8 Modifie un ordre existant sur Hyperliquid Args: order_id: ID de l'ordre à modifier new_price: Nouveau prix (optionnel) new_size: Nouvelle taille (optionnel) Returns: Dict avec le résultat de la modification FrorzOrder ID requiszModification ordre z: prix=z , taille=rfNrruRésultat modification: rrT)rrrrrr4ruÉchec modification ordre: rzErreur modification ordre: r) rrrrr modify_orderrPrr)r#rrr modificationsrrr$r'r'r(rsF        zHyperliquidClient.modify_orderrc Cs z`|js dddWS|s|sdddWStd|d||r(dt|i}nd|i}|j|}td ||rK|d d krKd |||d WS|didt|}dd||dWSty}zd|}t|d|t|dWYd}~Sd}~ww)u Annule un ordre sur Hyperliquid Args: order_id: ID de l'ordre à annuler cloid: Client Order ID (alternative à order_id) Returns: Dict avec le résultat de l'annulation FrorzOrder ID ou CLOID requiszAnnulation ordre: ID=z, CLOID=rfruRésultat annulation: rrT)rrrrr4ruÉchec annulation ordre: rzErreur annulation ordre: rN) rrrr cancel_orderrPrrr)r#rrcancel_requestrrr$r'r'r(rs>      zHyperliquidClient.cancel_orderc sz+|jsgWS|j|j}|r|ddfdd|D}tdt||WStyG}ztd|gWYd}~Sd}~ww)u Récupère les ordres ouverts Args: symbol: Symbole spécifique (optionnel) Returns: Liste des ordres ouverts rbrMcsg|] }|dkr|qS)rLr)rrrr'r(r sz5HyperliquidClient.get_open_orders..uOrdres ouverts trouvés: u&Erreur récupération ordres ouverts: N) rrrr}rr;r<rr)r#rfrr$r'rr(get_open_orderss  z!HyperliquidClient.get_open_orders)NN)FNN)Nr)rrG)r)r!r")r"rL))__name__ __module__ __qualname____doc__rr)rrr5r=rQrZrrtrvrrrrrrrboolrrrrr rrr r r=rarcrrmrrrrr'r'r'r(rsD2.- $(+" $H $+$ QL7 =7rr)r u;Client Hyperliquid global initialisé avec support Exchangeu#Initialisation Exchange échouée: u;Client Hyperliquid global initialisé en mode lecture seule)rr0r.rloggingtypingrrrrrrr getLoggerrrrrhyperliquid_clientrrr$r"r'r'r'r(s: