[jddZddlZddlZddlZddlZddlZddlZddlmZddlm Z GddZ y)z-OpenClaw Adapter - sprava worker subprocessu.N)datetime)Pathc<eZdZdZd dZdZdZd dZdZd dZ y) OpenClawAdapterct|j|_|jdz dz |_|jj ddi|_y)Nzdata-lab openclaw_runsT)parentsexist_ok)rresolvebase_dirruns_dirmkdirrunning)selfr s H/home/oem/CyberBrain26-unified/src/cyberbrain26/core/openclaw_adapter.py__init__zOpenClawAdapter.__init__ sIX..0  2_D  D48 cttjdd}|j|dz }|j|dz }|jdz dz }dt|d|d|d |d t|d t|g } t j j} | jd d t|d} tj| t|j| | tjd} ||||t|t|tjj| j | | d } | |j"|<|d| j dS)N.json.logcorezopenclaw_worker.pypython3z --task-idz --worktreez --descriptionz --max-stepsz--outputLITELLM_MASTER_KEYzsk-dummywT)cwdenvstdoutstderrstart_new_session) run_idtask_idworktree description output_filelog_file started_atpidproclog_frr!statusr()struuiduuid4r r osenvironcopy setdefaultopen subprocessPopenSTDOUTrutcnow isoformatr(r)rr" worktree_pathr$ max_stepsr!r%r& worker_scriptcmdrr*r)infos rstartzOpenClawAdapter.startsETZZ\"2A&mm&66 ==fXT?2 .1EE  s=)  - [ 3y> K(  jjoo +Z8Xs# S'S!2!2" m&s;7GH X__5F5P5P5R88TE   $ V IdhhGGrcp|jj|}|sK|j|dz }|jr( |dt j |j dSy|d}|j}| |d|dd S |d jt|d }d}|jr$ t j |j }||d k(rdnd ||d|dS#t$r}|dt|dcYd}~Sd}~wwxYw#t$rYwxYw#t$rd}YSwxYw)Nrfinished)r!r,resulterror)r!r,rCr)rr(r+r*r%rfailedr")r!r, exit_coder"rB) rgetr existsjsonloads read_text Exceptionr-pollcloser)rr!r>r%er)rcrBs rr,zOpenClawAdapter.status5sZ||'--VHE*::K!!#R&, &*jj1F1F1H&IKKF| YY[ :$ $u+N N  M   !4 ./      K$9$9$;<$&!GjY6  %!R&,#a&QQR     sB&C3 D>#D'3 D<D DD D$#D$' D54D5c|jj|}|sdddS|d}|jdddS tjtj |j tjtjd|j|j |djd|d S#t$r|jYiwxYw#t$rY/wxYw) NFz Run nenalezen)stoppedrCr)z Jiz ukonceng?r*T)rQr!)rrFrLr0killpggetpgidr(signalSIGTERMrK terminatetimesleepkillrM)rr!r>r)s rstopzOpenClawAdapter.stopUs||'$? ?F| 99; "$}= =  IIbjj*FNN ; 3 99;  IIK  M   ! 622  NN     s$AC 5C, C)(C), C87C8Nc g}t|jjddd}|D]} tj|j }|r|j d|k7r>|j|j|j d|j d|j dd|j d d d t||k\r|S|S#t$rYwxYw) Nz*.jsonc6|jjS)N)statst_mtime)xs rz+OpenClawAdapter.list_runs..ks1668CTCTrT)keyreverser"successsummarystepsr)r!r"rcrdrf) sortedr globrHrIrJrFappendstemlenrK)rr"limititemsfilesfdatas r list_runszOpenClawAdapter.list_runsist}}))(39T^bc A zz!++-0txx 2g= ff#xx 2#xx 2#xx 26!XXgq1 u:& '     s9C+A-C C+*C+c|j|dz }|jsytj|j S)Nr)r rGrHrIrJ)rr!r%s r get_resultzOpenClawAdapter.get_result~s>mm&66 !!#zz+//122rc|j|dz }|jsy|jdj}dj || dS)Nrrereplace)errors )r rGrJ splitlinesjoin)rr!tailr&liness rget_logzOpenClawAdapter.get_logsV==fXT?2 "")"4??Ayyuv''r) )N2)d) __name__ __module__ __qualname__rr?r,rZrqrsr|rrrr s( HD @3(*3 (rr) __doc__rHr0rTr5rWr.rpathlibrrrrrrs,3  }(}(r