o 0i" @s,dZddlZddlZddlmZddlmZmZddlZddlm Z e e Z dZ GdddZe d krejejd d eZeed eeeed eeZeredeedeD] ZedrrdndZededdededddqinededSdS)u Position Sync - Synchronisation positions.json avec sources on-chain Réconcilie les positions locales avec les données réelles (The Graph + Etherscan) N)datetime)DictList)PositionMonitorzpositions.jsonc@s^eZdZdZefdefddZdefddZdefd d Z defd d Z de efd dZ dS) PositionSyncz> Synchronise positions.json avec les sources on-chain positions_filecCs||_t|_dS)N)rrmonitor)selfrr I/var/www/html/HyperOracle/crypto_trader/apollo_degen_bot/position_sync.py__init__s zPositionSync.__init__returnc Cstj|jstd|jd|jjt idSz/t |jd }t |}Wdn1s4wY|di}tdt|d|WStyq}ztd |jd ||jjid WYd}~Sd}~ww) z' Charge positions.json u⚠️ u n'existe pas, création...)wallet last_updated positionsrNru📂 u positions locales chargéesu❌ Erreur chargement : )rr)ospathexistsrloggerwarningrrrnow isoformatopenjsonloadgetinfolen Exceptionerror)r fdatarer r r load_local_positionss$   z!PositionSync.load_local_positionsr#c Cst|d<z0t|jd}tj||ddWdn1s"wYtdt | didWdSt yW}zt d |jd |WYd}~dSd}~ww) z+ Sauvegarde positions.json rw)indentNu💾 ru positions sauvegardéesu❌ Erreur sauvegarde r) rrrrrrdumprrrrr r!)r r#r"r$r r r save_local_positions6s$&z!PositionSync.save_local_positionsc Cs.tdtdtd|}|di}tdt||jjdd}tdt|d}d}d}t|D]\}}|d } | d kr`||v} td |d d d| ||vr||} | d } | | krtd|d d dtd| d| || | | d| d| d krt nd t d|d7}q@| d krtd|d d dtd|| dt t d|d7}q@t dd|D}|D]7\}} ||vr"td|d d dtd| dd | d!rd"nd#d$| d | ||<|d7}q||d<||tdtd%tdtd&|td'|td(|d)d*|D} td+t| | r| D]$}|d!rtd"nd#}td|dd |d |d,d-|d.d/qktd|S)0uB Synchronise positions locales avec sources on-chain Process: 1. Charge positions.json locales 2. Récupère état réel depuis The Graph (Arbitrum) 3. Met à jour statut des positions locales 4. Ajoute nouvelles positions on-chain manquantes 5. Sauvegarde zP================================================================================u🔄 SYNCHRONISATION POSITIONSru📂 Positions locales: )limitu🔗 Positions on-chain: rstatusOPENu"🔍 DEBUG: Position locale OPEN: Nz | Dans onchain: u🔄 Position z...z Status: u → close_pricepnl)r-r0r1 closed_at synced_atz... (PAS dans onchain)u3 Status: OPEN → CLOSED (n'existe plus on-chain)CLOSED)r-r2r3css"|] }|ddkrdVqdS)r-r.r4Nr.0pr r r s z.PositionSync.sync_positions..u#➕ Nouvelle position découverte:  symbol is_longLONGSHORTz | Status: u📊 RÉSUMÉ SYNCuPositions mises à jour: uPositions ajoutées: zPositions actives locales: cSsg|] }|ddkr|qSr-r.r r7r r r sz/PositionSync.sync_positions..u ✅ Positions actives on-chain: leveragezx @ $ entry_price,.2f)rrr%rrrget_all_positionslistitemsupdaterrrsumvaluesr*)r local_datalocal_positionsonchain_positions updated_count added_countlocal_open_count trade_hash local_pos local_status in_onchain onchain_posonchain_status onchain_openpossider r r sync_positionsFs         2    4 zPositionSync.sync_positionscCs:|}|di}dd|D}|stdgStdt|dg}|D]Q\}}|j|}|dkrN||td|d d d q-|rqt d |d d d |d|||d<t ||d<q-t d|d d dq-t|t|kr||d<| |tdt|d|S)u_ Vérifie uniquement les positions actives et retourne celles réellement OPEN rcSs$i|]\}}|ddkr||qSrAr6)r8thrYr r r s z8PositionSync.verify_active_positions..u"📊 Aucune position active localeu🔍 Vérification de z positions actives...r.u ✅ Nr/z... toujours OPENu ⚠️ u... fermée (status: )r-r3u ❓ u... non trouvée on-chainu✅ u positions réellement actives)r%rrHrrrrcheck_position_statusappendrrrrr*)r rLrM local_open verified_openrRrSr-r r r verify_active_positionss2       z$PositionSync.verify_active_positionsN) __name__ __module__ __qualname____doc__POSITIONS_FILEstrr rr%r*r[rrcr r r r rsnr__main__z %(message)s)levelformatu&🔄 Test 1: Synchronisation complèteu,🔍 Test 2: Vérification positions activesu ✅ u$ position(s) active(s) vérifiée(s)r>r?r@r;r<r=z @ $rDrEu ✅ Aucune position active)rgrrrtypingrrloggingposition_monitorr getLoggerrdrrhr basicConfigINFOsyncprintr[rcactiverrYrrZr r r r s>   R,