Jj$ dZddlZddlZddlZddlmZddlZddlZddlm Z m Z m Z GddZ de ded eefd Zdd Z ddee d ed eed eeeeeffdZdS)zProcess log management utilities. Handles writing, reading, and capping JSONL log files for background processes. Extracted from ``main.py`` to keep the route module focused. N)Optional)MAX_PROCESS_LOG_SIZELOG_FLUSH_INTERVALLOG_FLUSH_BUFFERcReZdZdZdZddddededefdZd ed d fd Z dd Z ddZ d S)BoundedLogWriteruAsync wrapper that rotates the log file when it exceeds a size limit. When the total bytes written surpass *MAX_PROCESS_LOG_SIZE*, the file is truncated to its newest half and a ``log_rotated`` marker is inserted. Writing then continues, so the most recent output is always available. Flushing behaviour is controlled by *flush_interval* and *flush_buffer*: * ``flush_interval=0`` (default) — flush after every write (original behaviour, safest for low-throughput commands). * ``flush_interval>0`` — flush at most once per *flush_interval* seconds, **or** when the unflushed buffer exceeds *flush_buffer* bytes (if set). This dramatically reduces I/O pressure for high-output commands. )_file _log_path_bytes_writtenrotated_flush_interval _flush_buffer _unflushed _last_flushrflush_interval flush_bufferlog_pathrrc||_||_d|_d|_||_||_d|_tj|_ dS)NrF) r r r r r rrtime monotonicr)selffilerrrs k/home/rurouni/.cache/uv/archive-v0/6mr0qdqUAO9GXgnL/lib/python3.11/site-packages/open_terminal/utils/log.py__init__zBoundedLogWriter.__init__'sL ! -)>++datareturnNczKt|dd}|j|ztkr|d{V|j|d{V|xj|z c_|xj|z c_|jdkr(|j d{Vd|_dStj }||j z |jk}|s|j dkr|j|j k}|r/|j d{Vd|_||_ dSdS)Nutf-8replaceerrorsr)lenencoder r_rotater writerr flushrrrr)rr encoded_lennow should_flushs rr'zBoundedLogWriter.write1sw$++gi+@@AA   ,/C C C,,.. jt$$$$$$$$$ {* ;&  1 $ $*""$$ $ $ $ $ $ $ $DO Fnd..43GG  A 2Q 6 6?d.@@L  #*""$$ $ $ $ $ $ $ $DO"D    # #rcK|jd{Vd|_tj|_dS)Nr)r r(rrrr)rs rr(zBoundedLogWriter.flushHsIj         >++rchKd|_|jd{V|jd{Vt j|jdd4d{V}|d{V}dddd{Vn#1d{VswxYwY|t|dzd}t j|jdd4d{V}| tj dtj d d zd{V|D]}| |d{V dddd{Vn#1d{VswxYwYt j|jd dd{V|_td |D|_dS) z:Keep the newest half of the log file and continue writing.TNrr encodingw log_rotated)typets ac3^K|](}t|ddV)dS)r r!r"N)r$r%).0ls r z+BoundedLogWriter._rotate..cs:!Y!Yq#ahhwyh&I&I"J"J!Y!Y!Y!Y!Y!Yr)r r r(closeaiofilesopenr readlinesr$r'jsondumpsrsumr )rflineskeeplines rr&zBoundedLogWriter._rotateMs j         j         =wGGG ( ( ( ( ( ( (1++--''''''E ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (SZZ1_&&'=wGGG $ $ $ $ $ $ $1'' MEEFFM        $ $ggdmm######## $  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $$=wOOOOOOOOO !!Y!YTX!Y!Y!YYYs%*B B!$B!$A%E E&)E&rN) __name__ __module__ __qualname____doc__ __slots__strfloatintrr'r(r&rrrrs  I HI^_,,,s,u,X[,,,,######.,,,, ZZZZZZrrrnrc Kd}g}tj|d4d{V}|ddd{V|d{V}d}|dkrNt ||kr:t ||}||z}||d{V||d{V}||z}|d} | d}t| ddD]} | } | s tj | } n#tj tf$rYGwxYw| d d vr9|| d | d d t ||krn|dkrt ||k:| rt ||krm tj |} | d d vr$|| d | d d n#tj tf$rYnwxYwdddd{Vn#1d{VswxYwY||| dS) zRead the last *n* output entries from a JSONL log without loading the whole file. Uses a reverse-read strategy: read chunks from the end of the file until enough newline-delimited records have been collected. i rbNrr1r r4stdoutstderroutputrr4r)r=r>seektellr$minreadsplitreversedstripr@loadsJSONDecodeErrorUnicodeDecodeErrorgetappendreverse) rrQCHUNKentriesrC remainingbuffer read_sizechunkrDraw_linerecords rtail_logrpfsP EG}Xt,,"""""""ffQll&&((NNNNNN !mmG q 0 0E9--I  "I&&## # # # # # # #&&++++++++EV^FLL''E1XF$U122Y//  #>>++!Z11FF,.@AH::f%%)GGGNNF6NF6N#S#STTT7||q(()!mmG q 0 0. <<>> c'llQ.. F++::f%%)GGGNNF6NF6N#S#STTT(*<=    C"""""""""""""""""""""""""""H OO A233<s\C1ID)(I)E?IEBIAH('I(I>III I #I c JKd}d} |jrtjtj|jdd{Vtj|jddd{V}|tj d|j |j j tj d d zd{V|d{Vn#t$rd}YnwxYw|r"t!||jt"t$ nd} |j |d{V|r|jnd}|j d{V}||_d |_tj |_|j |r|d{V|rg|tj d |j|tj dd zd{V|d{VdSdS#|r|jnd}|j d{V}||_d |_tj |_|j |r|d{V|rf|tj d |j|tj dd zd{V|d{VwwxYw)zRead process output and persist to a log file. When the file exceeds *MAX_PROCESS_LOG_SIZE*, the oldest half is discarded so the most recent output is always available. NFT)exist_okr7r r/start)r4commandpidr5r6rdoneend)r4 exit_coder3r5)rr=osmakedirspathdirnamer>r'r@rArtrunnerrurr(OSErrorrrr read_outputr waitrxstatus finished_atr<)background_processlog_filer3writerrxs r log_processrs> HK  & #+&& 2 ;<r?rar@rbrcrerf) rrrri tail_entries truncatedrCrDrFrototals rread_logrs|G !!1!8!8!B!BBBBBBB!5   FaKK%h55555555  %%- S.. 99}X888$$$$$$$Akkmm######$$$$$$$$$$$$$$$$$$$$$$$$$$$ M Mzz||   Z%%FF#    H  ::f  !? ? ? NNF6NF6NKK L L L LLEfggGI CLL4//4%&&/ E9 $$s$C C C /DDDrG)rN)rKr@ryrtypingrr= aiofiles.osopen_terminal.envrrrrrMrOlistdictrprtupleboolrrPrrrsX  XXXXXXXXXXQZQZQZQZQZQZQZQZh.S.S.T$Z....bA#A#A#A#L.%.%sm.% .% 3-.% 4:sD ! .%.%.%.%.%.%r