o A^h@sdZddlZddlZddlmZmZddlmZmZmZm Z ddl m Z ddl Z ddlZddlZddlZejejejeZejeddlmZddlmZddlmZe Gd d d ZGd d d ZGd ddZdddZ dS)u Système de Signaux Pragmatique pour Trading Simplifié Génère des signaux de trading basés sur des indicateurs techniques simples et fiables N)datetime timedelta)DictListOptionalTuple) dataclass)BinanceDataProviderget_max_leverage)MarketRegimeDetectorc@sveZdZUdZeed<eed<eed<eed<eed<eed<eed<eed <d Z e ed <d Z eed <d Z eed <d S) TradingSignalz Structure d'un signal de tradingsymbolsidestrength current_priceleverage quality_scorereason timestampN indicators target_pricetarget_pnl_percent) __name__ __module__ __qualname____doc__str__annotations__floatintrrrrrr!r!pragmatic_signals.pyr s   r c@s.eZdZdZddZdefddZddZd S) MarketSentimentAnalyzeru?Analyse le sentiment global du marché pour ajuster les signauxcCs,d|_d|_d|_d|_d|_gd|_dS)Ni,r)bitcoinethereumsolana binancecoin)cache_durationbackoff_duration last_updaterate_limited_untilmarket_sentiment major_coinsselfr!r!r"__init__+s z MarketSentimentAnalyzer.__init__returncCs<t}||jkr |jS||j|jkr|||_|jS)uKRetourne le sentiment du marché (-1 à +1) avec backoff automatique si 429)timer-r.r,r*_update_sentiment)r1nowr!r!r"get_market_sentiment3s z,MarketSentimentAnalyzer.get_market_sentimentc s"zsd}tj|dd}|jdkrf|}ddddd }g}|D]tfd d |Dd }|r=d |vr=|t|d q |r`t |}t |ddd|_ t d|j dd|ddWd Sd|_ Wd St d|jd|_ Wd St y}zt d|d|_ WYd }~d Sd }~ww)uSMet à jour le sentiment basé sur les variations 24h des majors via Binance tickerz*https://api.binance.com/api/v3/ticker/24hr )timeoutr&r'r(r))BTCUSDTETHUSDTSOLUSDTBNBUSDTc3s |] }|dkr|VqdS)rNr!).0trr!r" Wsz.NpriceChangePercentg$@g?u📊 Market sentiment: .3fz (avg 24h: .2fz%)r%u"⚠ Erreur sentiment Binance API: u⚠ Erreur calcul sentiment: )requestsget status_codejsonkeysnextappendrnpmeanclipr.print Exception) r1urlresponsedata major_symbolschangesticker avg_changeer!rAr"r5As8    "  z)MarketSentimentAnalyzer._update_sentimentN)rrrrr2rr7r5r!r!r!r"r#(s  r#c @seZdZdZdGddZdedeefddZde efd d Z d d Z dedefd dZ dHde e dede fddZde e dede fddZdIde e dededee e e ffddZde e dee e ffddZdHde e dede fddZdJde e dede fd d!Zde e de e d"e defd#d$Zdefd%d&Zdedeefd'd(ZdKd)e d*e dedefd+d,Zd-e d.ed/ed0e def d1d2Zd3edefd4d5Zd3ed6e fd7d8Zd3edefd9d:Zd;d<Z dedefd=d>Z!dLded@ede"fdAdBZ#de efdCdDZ$defdEdFZ%dS)MPragmaticSignalGeneratoruZ Générateur de signaux pragmatique basé sur des règles simples mais efficaces NcCs||_|p tt|_t|_|jdi|_d|_ t |_ t |jd|_ d|_d|_||_t|_d|_d|_d|_d|_d |_d |_d |_d |_d |_d|_d|_d|_d|_ d |_!i|_"d|_#|jddS)Nu<BinanceDataProvider initialisé pour les candles historiques)loggerri`Tr$i #AK r8u@PragmaticSignalGenerator initialisé avec paramètres optimisés)$hyperliquid_clientlogging getLoggerrr\r binance_providerinfoleverage_cacheleverage_cache_timer#sentiment_analyzerr regime_detectorlast_market_updatemarket_update_interval_get_tradable_symbolssymbolsr4symbols_last_updatesymbols_update_intervalmin_volume_24h rsi_oversoldrsi_overboughtrsi_extreme_oversoldrsi_extreme_overboughtema_fast ema_shortema_long bb_periodbb_std macd_fast macd_slow macd_signal price_cacher*)r1rhr\r!r!r"r2os:   z!PragmaticSignalGenerator.__init__rr3c Csz||jvr|j|\}}t||jkr|WS|js"||WS|jj|ddd}d}|r5t|dkrU|jj|ddd}d}|rHt|dkrU|j d|d Wd S|j t j ri|j d |d |nt|jd dkr||j d|ddd|D}dd|D}dd|D}dd|D} |d} t| dkrt| dd | nd} || |||| td} | tf|j|<| WSty} z|j d|d| WYd } ~ d Sd } ~ ww)u\Récupère les données de marché avec cache - utilise Binance pour les candles historiques1hd)intervallimitBinance2)rlookback_hours HyperliquiduPas assez de données pour z (Binance + Hyperliquid)Nu Données u récupérées depuis rdruDonnées récupérées depuis z pour certains symbolescSg|]}t|dqS)closerr?cr!r!r" z.cSr)highrrr!r!r"rrcSr)lowrrr!r!r"rrcSr)volumerrr!r!r"rrirrcloseshighslows volume_24hruErreur récupération données : )rr4r*rh_get_mock_datark get_candleslenget_candles_datar\debug isEnabledForriDEBUGrlsumrr6rRerror)r1r cached_datarcandles data_sourcerrrvolumesrrrUrZr!r!r"get_market_datasP  $ z(PragmaticSignalGenerator.get_market_datac s6z{|jrq|j}|rqd|vrqg|dD]}|d}|r+|dddkr+|qgdfddD}tfddD}||}|jd t|d |jd d |d dt|dkridnd|WS|j dgdWSt y}z|j d|gdWYd }~Sd }~ww)uPRécupère dynamiquement TOUS les symboles tradables disponibles sur Hyperliquiduniversename maxLeverager) BTCETHSOLBNBAVAXARBOPLINKUNIDOTcsg|]}|vr|qSr!r!r?s) all_symbolsr!r"rrzBPragmaticSignalGenerator._get_tradable_symbols..csg|]}|vr|qSr!r!r)priority_symbolsr!r"rruChargé z& symboles tradables depuis Hyperliquidz Symboles: z, Nrdz...uCClient Hyperliquid non disponible, utilisation symboles par défautu Erreur récupération symboles: )rrrr) rh get_meta_inforHrMsortedr\rlrrjoinwarningrRr)r1 meta_infotokenr prioritizedothers final_symbolsrZr!)rrr"rss0     4  z.PragmaticSignalGenerator._get_tradable_symbolscCsbt}||j|jkr-|jd|}|r/||_||_|jdt|jddSdSdS)u0Met à jour la liste des symboles si nécessaireu(Mise à jour de la liste des symboles...uListe mise à jour: z symbolesN)r4rurvr\rlrsrtr)r1r6 new_symbolsr!r!r"_update_symbols_if_neededs z2PragmaticSignalGenerator._update_symbols_if_neededc Csddl}ddddddd d }||d }d }g}g}g}td D]9} |d|} |d | } | d t|d|d} | d t|d|d} || || || q ||d||||ddtdS)u-Génère des données fictives pour les testsrNii iX(333333?g@)rrrrrrrrg{Gz?reri@Bir) randomrHrangegaussabsrMuniformrr6)r1rr base_prices base_price volatilityrrrichangepricerrr!r!r"rs<        z'PragmaticSignalGenerator._get_mock_datapricesperiodc Cst||dkr dSt|}t|dk|d}t|dk| d}t|| d}t|| d}|dkr|krNnnd }t|||d d }n||krX|krhnnd }t|||d d }nd}d}|jd |d|dd|||||dWSty}z|jd|dddWYd}~Sd}~ww)zIAnalyse la tendance macro de BTC pour filtrer les signaux contre-tendancerNEUTRALr%)rrrrrbrcr rrDr u🔍 BTC Macro: z (force: rF))rrrrema50zErreur analyse BTC macro: N)rrrrr\rlrRr) r1btc_datarrrr0rrrZr!r!r"get_btc_macro_trends@       z,PragmaticSignalGenerator.get_btc_macro_trendcCspz||}|s|jd|dWdS|d}||jkr5|jd|d|dd|jddWdS|jd|d |dd |d d d|d }|ddgt|}|d }||||}|ddkr{|jd|d|ddWdS|d}|d} |d} |jd|d|ddd|dddd|dddd|dddd|d ddd!| |j|||\} } |j || | |j | | s|j d"|d#| d$| WdS|| |dd%} |j | | | }||d}t |d&kr|jd'|d(|ddd)|dd*|d+d ||d<| | d,d-| d.d-d/}|}|dd0kr| d1kr|dd2kra|dd39<|jd"|d4|ddd5|dddnq|dd6kr|dd79<|jd"|d8|dddnQ|dd9kr| d:kr|dd2kr|dd39<|jd"|d;|ddd5|dddn|dd6kr|dd79<|jd"|d<|ddd|dd=kr|jd|d>|ddWdS|dd}|| |d?|}t|dd@}g}|D]\}}|dd2kr ||dA|dddqdBdC|ddD}||| || \}}t|| | ||||t|||dE|dF|dG|dH||d|dI|dJ|dKdL dM }g}||d-r|||jdN|dO| dP|dn |jdQ|dR|r|d-WSdWSty}z|jdS|dT|WYd}~dSd}~ww)UuBAnalyse un symbole avec le NOUVEAU SYSTÈME DE SCORING ÉQUILIBRÉu📊 u": REJETÉ (données indisponibles)Nru : REJETÉ (volume trop faible: $z,.0fz < $r/z: ANALYSE (volume OK: $z , prix: $rz.6frrrr rz: Score trop faible rEr rrz: Score z (trend: rrFz , momentum: rz, volatility: rz , volume: ru) → u⚠️ u : REJETÉ - u interdit en régime )rrr g{Gz?u🔄 u: Score ajusté par régime: u → z (z+.3f change_24hrvolatility_pct)regimeregime_change_24hregime_volatilityr rgffffff??u*: SHORT pénalisé 25% - BTC bullish fort u (score → 皙?333333?u9: SHORT pénalisé 15% - BTC bullish modéré (score → r ru): LONG pénalisé 25% - BTC bearish fort u8: LONG pénalisé 15% - BTC bearish modéré (score → ru(: Score insuffisant après filtre macro r8ffffff?(zNouveau scoring: z + rrrrr5r6r7) rrrrscoring_componentsr*r5r6r7) rrrrrrrrrrru✅  u: Signal généré avec score u❌ u(: Signal rejeté par règles de filtragezErreur analyse r)rr\rlrwrHrr-rp detect_regimelog_regime_detectionshould_trade_in_regimeradjust_signal_scorerr2_calculate_smart_leverageritemsrMr_calculate_target_pricer rr6is_signal_suitable_for_rulesrRr)r1rrUrrrrscoring_resultr rrr5 regime_paramssignal_with_regimeadjusted_score score_change regime_info btc_macrorrrdominant_components comp_name comp_datarr target_pnlsignalsuitable_signalsrZr!r!r"analyze_symbol5s  &(      0  . .   "z'PragmaticSignalGenerator.analyze_symbolrrcCsTzddlm}|r ||nd}Wn tyd}Ynwzddlm}m}m}|} |} |} Wn d} d} d} Ytt|| | } |dkrMt| d } n'|d krXt| d } n|d krct| d } n|d krnt| d} nt| d} |dkrt dt| d }n|dkrt dt| d}n|dkrt|t| d}n| }t | t||}|S)uKCalcule le leverage intelligent basé sur la force du signal et volatilitérr rd)LEVERAGE_SAFETY_FACTOR MAX_LEVERAGEMIN_LEVERAGE_THRESHOLDr;rfr:rDr8g?g?g?g333333?r rareg?) leverage_limitsr ImportErrortrading_configrVrWrXr rr)r1rrrr max_leverage_for_symbolrVrWrX safety_factor global_max min_leveragesafe_max base_leveragerr!r!r"rDsD   z2PragmaticSignalGenerator._calculate_smart_leverage entry_pricerrsignal_strengthc Csx|dkrd}n|dkrd}n |dkrd}nd}|dd|}|d kr,|d |d }n|d |d }||}||fS) z#Calcule le prix cible et PnL targetrdrr8r rarrr9rrrr!) r1rcrrrdbase_tp_percent tp_percentrrRr!r!r"rFsz0PragmaticSignalGenerator._calculate_target_pricerScCs&|jpi}|dd}|dkrdSdS)uMVérifie si le signal est adapté aux règles (simplifié pour trailing stop)rr=)FuVolatilité extrême > 15%)TzOK pour trailing stop)rrH)r1rSrrr!r!r"rGs  z5PragmaticSignalGenerator.is_signal_suitable_for_rulesr.cC|S)u/Filtre les signaux selon sentiment (simplifié)r!)r1rSr.r!r!r"_apply_market_sentiment_filter%z7PragmaticSignalGenerator._apply_market_sentiment_filtercCrh)u'Applique un biais shitcoin (simplifié)r!)r1rSrr!r!r"_apply_shitcoin_bias+rjz-PragmaticSignalGenerator._apply_shitcoin_biasc Csdzt}||j|jkrWdS||_WdSty1}z|jd|WYd}~dSd}~ww)u9Met à jour la classification des marchés si nécessaireNuErreur mise à jour marchés: )r4rqrrrRr\r)r1 current_timerZr!r!r"'_update_market_classification_if_needed1s  z@PragmaticSignalGenerator._update_market_classification_if_neededcCsXz!ddlm}m}|dd}||vrWdS||vrWdSWdSty+YdSw)u Détermine la catégorie de qualité d'un crypto Args: symbol: Symbole du crypto Returns: str: 'high', 'medium', 'shitcoin' r)HIGH_QUALITY_CRYPTOSMEDIUM_QUALITY_CRYPTOSUSDTrrmediumshitcoin)r\rnroreplacerr[)r1rrnro clean_symbolr!r!r"_get_crypto_quality_category>s  z5PragmaticSignalGenerator._get_crypto_quality_categoryrcurrent_positionsc szddlm}m}m}m}|sjd|dWdS|}|dkr2jd|dWdS|dkr\t||}||k} | rDd nd } jd|d | d |d |d | WS|dkr|dkrqjd|dWdS|dkrddlm } t fddt |D} | | krjd|d| d | dWdSjd|dWdS|dkrjd|dWdSWdSt yYdSw)u Vérifie si un crypto doit être traité selon la stratégie configurée Args: symbol: Symbole du crypto current_positions: Nombre de positions actuelles Returns: bool: True si le crypto doit être traité r)USE_QUALITY_FILTERSHITCOIN_STRATEGYMAX_MEDIUM_QUALITY_RATIOMAX_SIMULTANEOUS_POSITIONSu🔍 u): AUTORISÉ (filtre qualité désactivé)Tru: AUTORISÉ (haute qualité)rqu AUTORISÉuREJETÉru (qualité moyenne, /r/rrEXCLUDEu): REJETÉ (shitcoin exclu par stratégie)F SHORT_BIAS)SHITCOIN_MAX_POSITIONSc3s(|]}d|dkrdVqdS)DUMMY_rrrN)rurr0r!r"rBs zBPragmaticSignalGenerator._should_process_crypto..u%: REJETÉ (limite shitcoins atteinte u&: AUTORISÉ (shitcoin avec SHORT bias)ALLOWu/: AUTORISÉ (shitcoin autorisé par stratégie)) r\rwrxryrzr\rlrur r~rrr[) r1rrvrwrxryrzqualitymax_medium_positionsallowedstatusr~shitcoin_countr!r0r"_should_process_crypto\sD    &   z/PragmaticSignalGenerator._should_process_cryptoc Cs|jdt|jdg}|||j}|jd|dd}d}t|jD]\}}| |t|s@|d7}q/|dkrS|ddkrSddl }| d | |}|r| ||}|ru|||}|ru||d kru|d7}|r|j|j|j|j|j|jt|jd |j|jd } |jr|jd d| d <|jdd| d<|jdd| d<|jdi| d<|jdd| d<|jdd| d<|jdd| d<|| q/|dks|dkr|jd|d|dt|d|S)u7Génère des signaux pour tous les symboles surveillésu"🔄 generate_signals() appelé - u symboles à analyseru)🎯 Début analyse - sentiment marché: rErrraNr rrr) rrrrr r confidencerrrrrrr.r>r r5 CONSOLIDATIONr6r7u 🔍 Filtre: z exclus, z shitcoins SHORT bias, u signaux générés)r\rlrrtrrmror7 enumeraterr4sleeprUrirkrurrrrrr rr isoformatrrHrM) r1signalsr.filtered_countshitcoin_signalsrrr4rS signal_dictr!r!r"generate_signalss\        $z)PragmaticSignalGenerator.generate_signalscCshtt|jgd}|jD]}||}|r)|d|j|j|j |j dqt|d|d<|S)u(Retourne un résumé des signaux actuels)rsymbols_monitoredrr)rrrr total_signals) rr6rrrtrUrMrrrr)r1summaryrrSr!r!r"get_signal_summarys   z+PragmaticSignalGenerator.get_signal_summaryNN)r)rdre)rd)N)r)&rrrrr2rrrrrrsrrrr rrrrrrrr-r2r rUrDtuplerFrGrirkrmruboolrrrr!r!r!r"r[js6 6<% ** " _03  >Jr[cCst||}|jS)u-Crée une instance du générateur de signaux)r[r)rhr\ generatorr!r!r"create_signal_providers rr)!rrir4rrtypingrrrr dataclassesrnumpyrNrGsysospathdirnameabspath__file__ parent_dirrMbinance_data_providerr hyperliquid_leverages_cacher market_regime_detectorr r r#r[rr!r!r!r"s6     B