o i(@sdZddlZddlZddlmZddlZddlmZmZddl Z ej ej de e ZGdddZe dkred ed ed eZed ed Zer^ed edededZersedededegdZeD]\ZZeredededqeded ddZeduredeededegdededjdded ed!ed dSdS)"u{ Pyth Network Price Feed - Prix en temps réel depuis l'oracle Pyth Compatible avec l'oracle on-chain utilisé par ApolloX N)datetime)OptionalDict)levelc @seZdZdZdZddddddd Zd d Zd ed eefddZ dd ed ee fddZ d ed ee fddZ d d edede d eejfddZded eee ffddZdS)! PythPriceFeedu Récupère les prix depuis Pyth Network (oracle on-chain) Pyth Network est l'oracle de prix utilisé par ApolloX on-chain. En utilisant Pyth pour nos signaux, on évite les écarts de prix entre notre analyse et l'exécution on-chain. zhttps://hermes.pyth.networkB0xe62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415b43B0xff61491a931112ddf1bd8147cd1b641375f79f5825126d665480874634fd0aceB0x2f95862b045670cd22bee3114c39763a4a08beeb663b145d283c31d7d1101c4fB0xef0d8b6fda2ceba41da15d4095d1da392a0d2f8ed0c6c7bc0f4cfac8c280b56dB0x2a01deaec9e51a579277b34b122399984d0bbf57e2458a7e42fecd2829867a0dB0xca3eed9b267293f6595901c734c7525ce8ef49adafe8284606ceb307afa2ca5b)BTCUSDETHUSDBNBUSDSOLUSDADAUSDDOTUSDcCsi|_d|_d|_dS)Nzhttps://api.binance.com/api/v3)cachecache_duration binance_url)selfrK/var/www/html/HyperOracle/crypto_trader/apollo_degen_bot/pyth_price_feed.py__init__)s zPythPriceFeed.__init__symbolreturncCsB|}|dr|dd}n |dr|dd}|j|S)u Récupère le Price Feed ID Pyth pour un symbole Args: symbol: BTCUSD, ETHUSD, BNBUSD, etc. (sans T) Returns: Price Feed ID ou None USDTNBUSD)upperendswithPRICE_FEED_IDSget)rrrrrget_price_feed_id0s     zPythPriceFeed.get_price_feed_idBTCUSDTc Cs|d}||jvr|j|\}}t||jkr|S||}|s1td|d||Szg|dd}|jd}|dd}t j ||d d } | | } | r[t | d kritd |||WS| d d } t| d } t| d} | d| }t|f|j|<td|d|d|WSty}ztd|d|td||WYd}~Sd}~ww)u Récupère le prix actuel depuis Pyth Network Args: symbol: Symbole de la paire (ex: BTCUSDT, BNBUSDT) Returns: Prix en float ou None si erreur _priceu$⚠️ Pas de Price Feed Pyth pour z, utilisation Binance0x/api/latest_price_feedsfalsezids[]binaryparamstimeoutru"⚠️ Pas de données Pyth pour priceexpo u📊 Prix Pyth : $,.2fu❌ Erreur Pyth pour z: u → Fallback BinanceN)rtimerr$loggerwarning_get_binance_pricereplace HERMES_URLrequestsr#raise_for_statusjsonlenfloatintdebug Exceptionerrorinfo)rr cache_key cached_time cached_price price_feed_id feed_id_cleanurlr/responsedata price_datar1r2 actual_priceerrrget_current_priceEsD           zPythPriceFeed.get_current_pricec Cszz!|jd}d|i}tj||dd}||}t|dWSty<}ztd|WYd}~dSd}~ww)u(Fallback: récupère prix depuis Binancez /ticker/pricerr-r.r1u❌ Erreur fallback Binance: N) rr<r#r=r>r@rCr7rD)rrrKr/rLrMrPrrrr9s z PythPriceFeed._get_binance_price1mdintervallimitc Csza|jd}|||d}tj||dd}||}tj|gdd}|gd}tj|dd d |d<d D] } || t || <q9| |} | r_| |j |j d d f<t d| d|WSty|} zt d| WYd} ~ dSd} ~ ww)u Récupère les données OHLCV historiques Note: Pyth ne fournit pas de données historiques OHLCV, on utilise Binance pour ça (nécessaire pour ATR, RSI, etc.) Mais le prix actuel (close) sera mis à jour avec Pyth. Args: symbol: Paire de trading (ex: BTCUSDT) interval: Timeframe (1m, 5m, 15m, 1h, etc.) limit: Nombre de bougies Returns: DataFrame avec colonnes: timestamp, open, high, low, close, volume z/klines)rrTrUr3r.) timestampopenhighlowclosevolume close_time quote_volumetradestaker_buy_basetaker_buy_quoteignore)columns)rVrWrXrYrZr[rVms)unit)rWrXrYrZr[rrZu- ✅ Dernier close mis à jour avec Pyth: $r5u"❌ Erreur récupération klines: N)rr<r#r=r>pd DataFrame to_datetimeastyper@rQlocindexr7rBrCrD) rrrTrUrKr/rLrMdfcolcurrent_pyth_pricerPrrr get_kliness0   zPythPriceFeed.get_klinessymbolsc Cshi}g}i}|D]}||}|r|||||<q|s0td|D] }||||<q$|Sz\dd|D}|jd}|dd} tj|| dd} | | } | D])} | d }|d |}|r~| d } t | d }t | d }|d |}|||<qUt dt |dW|Sty}ztd||D] }||||<qWYd}~|Sd}~ww)u Récupère plusieurs prix en une seule requête Args: symbols: Liste de symboles ['BTCUSDT', 'ETHUSDT', ...] Returns: Dict {symbol: price} u7⚠️ Aucun Price Feed Pyth trouvé, fallback BinancecSsg|]}|ddqS)r'r()r:).0fidrrr sz5PythPriceFeed.get_multiple_prices..r)r*r+r-r.idr'r1r2r3u📊 Récupéré z prix depuis Pythu)❌ Erreur récupération multiple Pyth: N)r$appendr7r8r9r;r<r#r=r>r@rArEr?rCrD)rropricesfeed_idssymbol_to_feedrfeed_idfeed_ids_cleanrKr/rLrMitemrNr1r2rOrPrrrget_multiple_pricessR          z!PythPriceFeed.get_multiple_pricesN)r%)r%rRrS)__name__ __module__ __qualname____doc__r;r"rstrrr$r@rQr9rArerfrnlistrr{rrrrrs   ?"8r__main__zP================================================================================u🧪 TEST PYTH PRICE FEEDu$ 📊 Prix actuel BTC (Pyth Oracle):r%z BTC: $r5u$ 📊 Prix actuel BNB (Pyth Oracle):BNBUSDTz BNB: $u) 📊 Prix multiples (requête groupée):)r%ETHUSDTrz r4u' 📊 Klines 1m (Binance + Pyth close):rRr3u Récupéré: z bougies )rVrZr[z Dernier close (Pyth): $rZrzQ ================================================================================u✅ Test terminé)rr<pandasrerloggingtypingrrr6 basicConfigINFO getLoggerr|r7rrEfeedrQ btc_price bnb_pricer{ruitemsrr1rnrkr?taililocrrrrsP  z