a i\K  dZddlmZddlZddlmZmZddlmZm Z m Z ddl m Z m Z mZmZdZdZd>d Zd?dZGddZGddZd@dZdddAdZd ddd!ddd"d#d$d#d% dBd6Zddd7dCd:Zd ddd!ddd"d#d$d#d% dDd<Zddd7dEd=ZdS)Fz> B  B datar c|jr8|js3|jtjd|ddSdSdS)z'Send stdin data to the running command.inputrGrQNr3r4rJrKrLr7rQs r send_inputz_WSStreamControl.send_inputls[ 8 GDL G HMM$*gt%D%DEE F F F F F G G G Gr&Nr!r/r:rr!r/r!rBrQr r!r/ __name__ __module__ __qualname____doc__r8r>rApropertyrErPrWr+r&rr.r.?s    X    GGGGGGr&r.cReZdZdZddZddZddZedd Zdd Z ddZ dS)_AsyncWSStreamControlz%Async equivalent of _WSStreamControl.r!r/c0d|_d|_d|_dSr1r2r6s rr8z_AsyncWSStreamControl.__init__ur9r&r:rc||_dSNr<r=s rr>z_AsyncWSStreamControl._bindzs r&c"d|_d|_dS)NTr@r6s rrAz_AsyncWSStreamControl._unbind}s r&rBc|jSrfrDr6s rrEz_AsyncWSStreamControl.killeds |r&cBKd|_|jr|js |jt jddid{Vn#t $rYnwxYw d|j_|jd{VdS#t $rYdSwxYwdSdS)NTrGrHrrIr6s rrPz_AsyncWSStreamControl.send_kills 8 DL  hmmDJ/?$@$@AAAAAAAAAA     )*&hnn&&&&&&&&&&&        s#4A AA+B BBrQr cK|jr>|js9|jtjd|dd{VdSdSdS)NrSrTrUrVs rrWz _AsyncWSStreamControl.send_inputsq 8 MDL M(-- GT+J+J K KLL L L L L L L L L L M M M Mr&NrXrYrZr[r\r+r&rrcrcrs// X    MMMMMMr&rcexcrMr$r/ctt|dddd}|dkrtd|d|td|d||) uRaise a clear error when the server rejects the WebSocket upgrade. The most common case is HTTP 404 — the server doesn't have the /execute/ws endpoint, meaning it doesn't support WebSocket streaming. responseN status_codeizJThe sandbox server does not support WebSocket command execution (endpoint z returned 404). Ensure the server is updated to a version that supports the /execute/ws endpoint, or use run() without wait=False or callbacks.z+WebSocket upgrade rejected by server (HTTP z): )getattrr )rkr$statuss r_raise_for_invalid_statusrqs WS*d33]D I IF }}$ 6 6 6 6     !FfFFFF   r& command_idmsgdictrtc<|dd}|dd}|dkrt||dkrt|rd|n||rdnd | |d krt|rd |n||rdnd | t||rdnd | ) zkkY!    %%%#0: I , , , , %/>kkY!    !+:++   r&<z /bin/bashi,FiX) timeoutenvcwdshell on_stdout on_stderr idle_timeoutkill_on_disconnect ttl_secondsptyr~rintrOptional[dict[str, str]]rrrOptional[Callable[[str], Any]]rrrrBrr'tuple[Iterator[dict], _WSStreamControl]c  t\t|t|td   fd } | fS)aPExecute a command over WebSocket, yielding raw message dicts. Returns a tuple of (message_iterator, control). The control object provides send_kill() and send_input() methods for the CommandHandle. The iterator yields dicts with a "type" field: - {"type": "started", "command_id": "...", "pid": N} - {"type": "stdout", "data": "...", "offset": N} - {"type": "stderr", "data": "...", "offset": N} - {"type": "exit", "exit_code": N} If on_stdout/on_stderr callbacks are provided, they are invoked as data arrives in addition to yielding the messages. r!Iterator[dict]c 3K  dddd5} |d d} r |d< r |d<rd |d <|tj||D]}tj|}|d }|d kr|V6|d krr|d|VT|dkrr|d|Vr|dkr&|Vddd dS|dkrt| dddn #1swxYwYn#$r}t|Yd}~njd}~w$r?}|j r |j j dkrtd|td||d}~wt$r}td||d}~wwxYw dS# wxYwN radditional_headers open_timeoutrN ping_interval ping_timeoutexecute)rGr~timeout_secondsridle_timeout_secondsrrrrTrrGstartedstdoutrQstderrexitrz(Server is reloading, reconnect to resume*WebSocket connection closed unexpectedly: Failed to connect to sandbox: r>rJrKrLloadsrrArrqrcvdcoder r OSError)r:payloadraw_msgrumsg_typeerrr~controlrrheadersrrrrrrrrrr$s r_streamzrun_ws_stream.._streams8C #*   3 3 b!!!&&'.",8*<#.++)%(GEN)%(GEN*%)GEN 7++,,, "33G*W--C"wwvH9,,! !X--$3%Ic&k222! !X--$3%Ic&k222! !V++! a3 33 33 33 33 33 3D OO     !"W,,-c222-3;3 33 33 33 33 33 33 33 33 33 33 33 33 33 33 3j 1 1 1 %a 0 0 0 0 0 0 0 0   v !&+--.>)@Q@@  V V V()M!)M)MNNTU U V OO     GOO    swECD51 ED5) E5D99E<D9=EGGEGG#:F G*F==GGG1r!rrr%r,r.)rr'r~rrrrrrrrrrrrrrrrr$s ``````````` @@@@@@r run_ws_streamrs<3E2F2F/J - = ) )F!'**G  GDDDDDDDDDDDDDDDDDDDDDDL 799g r&) stdout_offset stderr_offsetrrc  t\ t| t| td  f d }|fS)aYReconnect to an existing command over WebSocket. Returns a tuple of (message_iterator, control), same as run_ws_stream. The iterator yields stdout, stderr, exit, and error messages. No 'started' message is sent on reconnection. With the ring buffer reader server model, there is no replay/live phase distinction and no deduplication needed. The server reads from its ring buffer starting at the requested offsets and streams output from there. If the requested offset is older than the buffer's earliest data, the server sends from the earliest available offset. r!rc 3< K  dddd5}||tjd d|D]w}tj|}|d}|dvr|V4|d kr&|VddddS|d krt| x dddn #1swxYwYn#$r}t| Yd}~njd}~w$r?}|j r |j j d krtd |td||d}~wt$r}td||d}~wwxYwdS#wxYwNrrrrr})rGrtrrrG)rrrrzrsrrrrr)r:rrurrrrrtrrrrrr$s rrz$reconnect_ws_stream.._streamUs3 #*   # J b!!!J$/*4-:-:     " J JG*W--C"wwvH#777! !V++! A# J# J# J# J# J# Jd OO     !"W,,-cjIIII J/# J# J# J# J# J# J# J# J# J# J# J# J# J# J# JJ 1 1 1 %a 0 0 0 0 0 0 0 0   v !&+--.>)@Q@@  V V V()M!)M)MNNTU U V OO     GOO    swC+BC C+:C C+C##C+&C#'C+*F+E,0DFE, :E E,E''E,,FFrr) rr'rtrrrrrrrrr$s ``` @@@@@@rreconnect_ws_streamr<s(3E2F2F/J - = ) )F!'**G  G44444444444444l 799g r&1tuple[AsyncIterator[dict], _AsyncWSStreamControl]c  Kt\t|t|td   fd } | fS)z]Async equivalent of run_ws_stream. Returns (async_message_iterator, async_control). r!AsyncIterator[dict]c :K  dddd4d{V } |d d} r |d< r |d<rd |d <|tj|d{V|23d{V}tj|}|d }|d kr|WV<|d krr|d|WV[|dkrr|d|WVz|dkr-|WVdddd{V dS|dkrt|6 dddd{Vn#1d{VswxYwYn#$r}t|Yd}~njd}~w$r?}|j r |j j dkrtd|td||d}~wt$r}td||d}~wwxYw dS# wxYwrr)r:rrrurrrrr~rrrrrrrrrrrrrr$s rrz$run_ws_stream_async.._streams= ''#*   - 3- 3- 3- 3- 3- 3- 3- 3 b!!!&&'.",8*<#.++)%(GEN)%(GEN*%)GENggdj11222222222%'3333333'*W--C"wwvH9,,! !X--$3%Ic&k222! !X--$3%Ic&k222! !V++! W- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3x OO     !"W,,-c222%&(R7- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3- 3^ 1 1 1 %a 0 0 0 0 0 0 0 0   v !&+--.>)@Q@@  V V V()M!)M)MNNTU U V OO     GOO    sE*A$EEBEE*.EE* E""E*%E"&E*)H*G+/F?HG+ :G G+G&&G++HHr!rrr%r,rc)rr'r~rrrrrrrrrrrrrrrrr$s ``````````` @@@@@@rrun_ws_stream_asyncrs(9Q8R8R5& = ) )F!'**G#%%G>>>>>>>>>>>>>>>>>>>>>>@ 799g r&c  Kt\ t| t| td  f d }|fS)z(Async equivalent of reconnect_ws_stream.r!rc  K  dddd4d{V }||tjd dd{V|23d{V}tj|}|d}|dvr|WV:|d kr-|WVdddd{VdS|d krt| 6 dddd{Vn#1d{VswxYwYn#$r}t| Yd}~njd}~w$r?}|j r |j j d krtd |td||d}~wt$r}td||d}~wwxYwdS#wxYwrr)r:rrurrrrrtrrrrrr$s rrz*reconnect_ws_stream_async.._streams/ ''#*    J J J J J J J J b!!!ggJ$/*4-:-:          &( J J J J J J J'*W--C"wwvH#777! !V++! ; J J J J J J J J J J J J\ OO     !"W,,-cjIIII&(R+ J J J J J J J J J J J J J J J J J J J J J J J J J J JB 1 1 1 %a 0 0 0 0 0 0 0 0   v !&+--.>)@Q@@  V V V()M!)M)MNNTU U V OO     GOO    sDA D'C,-AD-DD.D D  D D DF,FD,'F,,F4:E.. F;FFF,,Grr) rr'rtrrrrrrrrr$s ``` @@@@@@rreconnect_ws_stream_asyncrs9Q8R8R5& = ) )F!'**G#%%G00000000000000d 799g r&)rr r!r )r'r(r!r))rkrMr$r r!r/)rurvrtr r!r/)rr r'r(r~r rrrrrr(rr rrrrrrrrBrrrrBr!r) rr r'r(rtr rrrrr!r)rr r'r(r~r rrrrrr(rr rrrrrrrrBrrrrBr!r) rr r'r(rtr rrrrr!r)r` __future__rrKcollections.abcrrtypingrrrlangsmith.sandbox._exceptionsr r r r rrr%r,r.rcrqrrrrrr+r&rrsgBB"""""" 33333333**********      """" 0G0G0G0G0G0G0G0Gf"M"M"M"M"M"M"M"MT(;=J$(0404$iiiiiib OOOOOOx$(0404$YYYYYYB @@@@@@@@r&