
    n\jH                    V   d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ ej	        
                    d d           d dlmZmZ  ed          Zedz  Zedz  Z ed          Z ed	          Z ed
          ZdZddZddZddZddZddZedk    r e e                      dS )    )annotationsN)Pathz2/home/agent/projects/CryptoTradingBot/Crypto_Agent)
CANDIDATESinspect_candidatez.venv/bin/pythonzruntime/experimentsz2/home/agent/.local/state/CryptoTradingBot/v78_logszE/home/agent/.local/state/CryptoTradingBot/v78_supervisor_markers.jsonz=/home/agent/.local/state/CryptoTradingBot/v78_supervisor.lock)(research_v78_2_confirmed_range_reversionstrategy_idstrreturnintc                   t                               dd           t          |          }i t          j        d| dddddd}t           |  dz                      d          5 }t          j        t          t                    d	|j
        d
| dd                    |j                  dddddgt          ||t          j        d          }d d d            n# 1 swxY w Y   |j        S )NTparentsexist_ok.truefalse)
PYTHONPATHCTB_STRATEGY_IDCTB_PAPER_TRADINGCTB_DRY_RUNCTB_LIVE_TRADING_ALLOWEDCTB_LIVE_ORDER_ALLOWEDHL_MAINNET_SIGNED_ACTIONz.logab-mz--strategy-idz--coins,z--iterations720z--interval-seconds60--json)cwdenvstdoutstderrstart_new_session)LOG_ROOTmkdirr   osenvironopen
subprocessPopenr	   PYTHONmodulejoincoinsREPOSTDOUTpid)r   specr!   logprocesss        :/home/agent/.hermes/scripts/ctb_v78_research_supervisor.pystartr7      s   NN4$N///k"D nRZ  ns{agx  ^e  AH  fm  n  n  nC
)))
)	/	/	5	5 R"CKKt{OU`bkmpmumuvz  wA  nB  nB  DR  TY  [o  qu  w  $@  FJ  PS  \_  hr  hy  MQ  R  R  RR R R R R R R R R R R R R R R;s   "A%CCCdictc           
     p   t           |          }t          j        t          t                    dddt          t
          | z            d|j        dgt          i t          j	        ddiddd	
          }|j
        dk    r#t          |j        p|j        dd                    t          j        |j                  S )Nr   zsrc.tools.v77_promotion_report--runtime-dirz--strategy-versionr   r   r   Tx   r    r!   textcapture_outputtimeoutr   )r   r*   runr	   r,   RUNTIME_ROOTstrategy_versionr0   r'   r(   
returncodeRuntimeErrorr#   r"   jsonloads)r   r3   r5   s      r6   	promotionrH   "   s   k"Dnc&kk41QSbdght  xC  iC  eD  eD  FZ  \`  \q  s{  |  BF  Lm  OQ  OY  Lm  [g  il  Lm  Lm  tx  IM  WZ  [  [  [GQGN<gndeeDEEE:gn%%%    Nonec           
     (   | dk    rd S t          j        t          t                    dddt          t          | z            gt
          i t          j        ddiddd	          }|j        d
k    r#t          |j
        p|j        dd                    d S )Nresearch_v78_regime_routerr   z#src.tools.maker_taker_shadow_reportr:   r   r   Tr;   r<   r   r@   )r*   rA   r	   r,   rB   r0   r'   r(   rD   rE   r#   r"   )r   r5   s     r6   refresh_maker_taker_reportrM   *   s    222nc&kk41VXgilmy  }H  nH  jI  jI  J  PT  Z{  ]_  ]g  Z{  iu  wz  Z{  Z{  BF  W[  eh  i  i  iGQGN<gndeeDEEE rI   c                 ~    	 t          j        t                                                    S # t          $ r i cY S w xY w)N)rF   rG   MARKER	read_text	Exception rI   r6   load_markersrS   2   sG    z&**,,---   			s   *- <<c                    t           j                            dd           t                               d          } 	 t	          j        | t          j        t          j        z             n# t          $ r Y dS w xY wg }t                      }t          D ]W}t          t          |         t                    }|j        r,t          |          }|                    d| d| d           nO|j        d	k    rD|                    d
| d|j         dd                    |j        d d                    d           	 t)          |          }t+          |           nE# t,          $ r8}|                    d| dt/          |          j                    Y d }~d }~ww xY w|                    d          du }|r.|                    |          s|                    d| d           |||<   Yt4          j                            dd           t4                              t9          j        |dd                     |r"t=          d                    |                     dS )NTr   wr   )runtime_rootu(   ⚙️ v78 Research-Supervisor startete z
 neu (PID z(); paper=true, live=false, signed=false.healthyu   ⚠️ v78 Prozesslage z: z!; kein blinder Neustart, blocker=r      r   u,   ⚠️ v78 Promotion-Report fehlgeschlagen: promotion_eligibleu(   🟢 v78 Paper-Gates erstmals erfüllt: z9; weiterhin Research-only, manueller Review erforderlich.   )indent	sort_keys
)LOCKparentr&   r)   fcntlflockLOCK_EXLOCK_NBBlockingIOErrorrS   
STRATEGIESr   r   rB   restart_allowedr7   appendstater.   blockersrH   rM   rQ   type__name__getrO   
write_textrF   dumpsprint)	lockmessagesmarkersr   
assessmentr2   reportexceligibles	            r6   mainrw   9   s   KdT22299S>>DD%-%-78888   qqHnnG! ( (&z+'>\ZZZ
% 	^$$COO  L{  L  L^a  L  L  L  M  M  M  M**OO  ]k  ]  ]ZEU  ]  ]x{  yA  yA  BL  BU  VX  WX  VX  BY  yZ  yZ  ]  ]  ]  ^  ^  ^	{++F&{3333 	 	 	OOn;nnZ^_bZcZcZlnnoooHHHH	 ::233t; 	OGKK44 	OOO  N{  N  N  N  O  O  O'
Mt444
djdCCCDDD #dii!!"""1s)   ,A* *
A87A89E
F"-FF__main__)r   r	   r
   r   )r   r	   r
   r8   )r   r	   r
   rJ   )r
   r8   )r
   r   )
__future__r   rF   r`   r'   r*   syspathlibr   pathinsert"src.tools.paper_runtime_supervisorr   r   r0   r,   rB   r%   rO   r^   re   r7   rH   rM   rS   rw   rk   
SystemExitrR   rI   r6   <module>r      sy   " " " " " "   				     



       G H H H L L L L L L L Lt@AA	"	"++4DEE	U	V	VtKLL

   & & & &F F F F      B z
*TTVV

 rI   