o ii4 @sdZddlZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl Z e e eZeddZed Zd Zd Zd Zd Ze e eZGdddZedkre je jddeZedededeedede Z!e!re!"D]P\Z#Z$e$drdndZ%ede$dde%de$ddede#dd d!ed"e$d#d$ed%e$d&d'ed(e$d)ed*e$d+qned,eeddSdS)-u Position Monitor - Sources de données fiables Vérifie l'état réel des positions via 2 sources: 1. The Graph (Arbitrum) - Source principale 2. Etherscan V2 (BSC) - Fallback N)datetime)DictListOptional) load_dotenv)Web3WALLET_ADDRESS*0x7476737C49d55bea691e54c2c96fD39a6bAf3049BSCSCAN_API_KEYzhttps://gateway-arbitrum.network.thegraph.com/api/6edc89d15e0bffdb56057765735dfdc8/subgraphs/id/HxvztN7GmfYYDPb89K4FFYKFkRvBtscxYQqvX79D4XSQzhttps://api.etherscan.io/v2/api*0x1b6F2d3844C6ae7D56ceb3C3643b9060ba28FEb0z!https://bsc-dataseed.binance.org/c@seZdZdZddZddedeefddZd eedee effd d Z dd ededeefddZ de de e fddZ dee effddZddedee effddZde de e fddZdS)PositionMonitoru6 Monitor l'état réel des positions on-chain cCs t|_dS)N)rwallet)selfrL/var/www/html/HyperOracle/crypto_trader/apollo_degen_bot/position_monitor.py__init__+s zPositionMonitor.__init__dlimitreturnc Csd}|jd|d}zGtdtjt||ddddd d d d }||}d |vr9td|d gWS| di dg}tdt |d|WSt yl}ztd|gWYd}~Sd}~ww)uo Récupère les positions depuis The Graph (Arbitrum) Source principale la plus fiable a) query OrderAndTradeHistorys($skip: Int, $first: Int, $user: String) { orderAndTradeHistories( skip: $skip first: $first orderBy: timestamp orderDirection: desc where: { user: $user actionType_not: ADD_MARGIN } ) { id orderOrTradeHash actionType timestamp txHash limitOrder { pair { name } isLong token { symbol } amountIn limitPrice qty takeProfit stopLoss } trade { pair { name } isLong token { symbol } margin entryPrice qty openFee executionFee closeType closePrice closeFee fundingFee holdingFee pnl actualPnl } } } r)userskipfirstu*📡 Interrogation The Graph (Arbitrum)...)query variableszapplication/jsonz*/*zhttps://www.apollox.financez Mozilla/5.0)z Content-TypeAcceptOriginz User-Agent)jsonheaderstimeouterrorszGraphQL errors: dataorderAndTradeHistories✅ u( entrées récupérées depuis The Graphu❌ Erreur The Graph: N) r loggerinforequestspost THEGRAPH_URLraise_for_statusrerrorgetlen Exception)rr graphql_queryrresponser! historieserrrfetch_from_thegraph0s<1  z#PositionMonitor.fetch_from_thegraphr0cCsi}|D]9}|d}|d}|s|sq|dd}t|dd}|dd}|d d} | r4| n|} |r:|n|} | d id d } | d d} |rt|dd}t|dd}t|dd}|d}|drxt|ddnd}|drt|ddnd}|dkr|dkrt|||nd}|rd|vrd}nd}nd}t|dd}t|dd}t|dd}n,t|dd}t|dd}t|dd}d}|dkrd nd!}d}d}d}d}d}id"| d#|d$| d%d&| d|d'|d(|d|d)|d*|rt|ndd+|d,|d-|d.|d/|d0|d1d2d3ti}||| <q|S)4uJ Parse les données The Graph en positions standardisées trade limitOrder actionTypeUNKNOWN timestamprtxHashorderOrTradeHashpairnameBTCUSDisLongFmargin entryPriceqty closeType closePriceN actualPnlLIQUIDAT LIQUIDATEDCLOSEDOPENopenFeecloseFee fundingFeeamountIn limitPrice OPEN_LIMITPENDING CANCELLED trade_hashtx_hashsymbol_DEGENis_longleverage entry_pricestatus opened_at close_pricepnlopen_fee close_fee funding_fee action_typesourcethegraph_arbitrum last_checked)r+intfloatupperr fromtimestamp isoformatnow)rr0 positionsentryr3 limit_orderr_r7rRorder_trade_hashrQr! pair_namerUr?rWrA close_typerZr[rVrXr\r]r^positionrrrparse_thegraph_positionss          $         z(PositionMonitor.parse_thegraph_positionsr startblockc Cs ts tdgSddd|j|dd|dtd }zRtd tjt|d d }|}|d d krVt |dt rV|d}dd|D}tdt |dt |d|WStd|dd|dgWSt y}zt d|gWYd}~Sd}~ww)uc Récupère les TX depuis Etherscan V2 (BSC) Fallback si The Graph échoue u!⚠️ BSCSCAN_API_KEY manquante56accounttxlistidesc) chainidmoduleactionaddressrqendblockpageoffsetsortapikeyu(📡 Interrogation Etherscan V2 (BSC)...r)paramsrrX1resultcSs(g|]}|ddtkr|qS)tor9)r+lowerAPOLLOX_CONTRACT_BSC.0txrrr s z8PositionMonitor.fetch_from_etherscan..r#u TX ApolloX récupérées (sur z total)u⚠️ Etherscan V2: messagez - u❌ Erreur Etherscan V2: N)r r$warningr r%r&r+ETHERSCAN_V2_URLr isinstancelistr,r-r*) rrqrrr/r!txs apollox_txsr1rrrfetch_from_etherscans@   "z$PositionMonitor.fetch_from_etherscanrRc Csz/tj|}|dD]!}|dtkr,t|ddkr,|dd}|WSq WdStyM}zt d|d|WYd}~dSd}~ww) z@ Extrait le trade hash depuis les logs d'une TX logsrztopicsruNz$Impossible d'extraire trade hash de z: ) w3ethget_transaction_receiptrrr,hexr-r$debug)rrRreceiptlogrQr1rrrextract_trade_hash_from_txs   z*PositionMonitor.extract_trade_hash_from_txcCs|jdd}|r#||}dd|D}tdt|d|Std|jdd}|rIdd |D}tdt|d td iStd iS) u9 Récupère les positions ACTIVES (OPEN) 2rcSs"i|] \}}|ddkr||qS)rXrHr)rthposrrr ;s  z8PositionMonitor.get_active_positions..📊 u( positions actives trouvées (The Graph)u$⚠️ Fallback sur Etherscan V2...cSs$g|]}d|ddvr|qS)openMarketTrade functionNamer9)r+rrrrrrIs z8PositionMonitor.get_active_positions..u+ ouvertures récentes trouvées (Etherscan)uD⚠️ Etherscan ne peut pas déterminer si positions sont ouvertesu❌ Aucune source disponible) r2rpitemsr$r%r,rrr*)rr0 all_positionsactive_positionsropen_txsrrrget_active_positions1s&      z$PositionMonitor.get_active_positionscCsB|j|d}|r||}tdt|d|StdiS)uF Récupère TOUTES les positions (historique complet) rru positions totales trouvéesu*❌ Impossible de récupérer l'historique)r2rpr$r%r,r*)rrr0rrrrget_all_positionsYs   z!PositionMonitor.get_all_positionsrQcCs`|jdd}||vr!||d}td|ddd||Std|ddd dS) u Vérifie le statut d'une position spécifique Returns: 'OPEN', 'CLOSED', 'LIQUIDATED', 'PENDING', ou None si non trouvée rrXz Position Nz... = u⚠️ Position u... non trouvée)rr$r%r)rrQrrXrrrcheck_position_statushs  z%PositionMonitor.check_position_statusN)r)rr)__name__ __module__ __qualname____doc__rrcrrr2strrprrrrrrrrrrr &s[^0(r __main__z %(message)s)levelformatzP================================================================================u🔍 TEST POSITION MONITORu1️⃣ POSITIONS ACTIVES:zP--------------------------------------------------------------------------------rULONGSHORTu 📊 rS rVxz Trade Hash: z...z Margin: $r?z.2fz Entry: $rWz,.2fz Status: rXz Opened: rYu! ⚠️ Aucune position active)&rr&rosrtypingrrrdotenvrweb3rlogging getLoggerrr$getenvrrr r(rrBSC_RPC HTTPProviderrr basicConfigINFOmonitorprintractiverrQrsiderrrrsZ     W$