[ Root System Explorer ]
Location:
Root
/
proc
/
self
/
root
/
usr
/
local
/
lib
/
python3.9
/
site-packages
/
__pycache__
+ Folder
+ File
Upload
Editing: sh.cpython-39.pyc
a *� h�� � @ sr U d Z ddlZddlZddlmZ ddlmZ ddlmZ ze� d�Z W n ej y` dZ Y n0 de� � � � v r�ed e � d ���ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddl!Z!ddl"Z"ddl#Z#ddl$Z$ddl%Z%ddl&Z&ddl'Z'dd lm(Z) dd l*m+Z+ dd l,m-Z- ddl.m/Z/m0Z0m1Z1 ddl.m2Z3 ddl4m5Z5 ddl6m7Z7m(Z( ddl8m9Z: ddl;m<Z<m=Z= ddl>m?Z?m@Z@mAZAmBZB dZCh d�ZDddhZEe5� �p�dZFe� � dv ZGeHZIeJeKejL�Mdd ���ZNeJeKejL�Md d ���ZOe"�P� ZQd d � ZReSeTd ��ZUeVed!�ZWd"ZXdZYd#ZZd$Z[G d%d&� d&�Z\G d'd(� d(�Z]e]Z^eBeAe] eAe\ f e_d)< eW�r�eO�s�e\Z^G d*d+� d+e`�ZaG d,d-� d-eb�ZcG d.d/� d/e`�ZdG d0d1� d1ed�ZeG d2d3� d3e`�Zfe jge jhe jie jje jke jle jme jne joe jpe jqh ZrG d4d5� d5es�Zte�ud6�Zvi Zwe@exeAed f e_d7< d8d9� e jy�z� D �Z{d:d;� Z|d<d=� Z}ejZ~G d>d?� d?e�Z�d@dA� Zee_dBdC� Z�d�dDdE�Z�dFdG� Z�d�dHdI�Z�G dJdK� dK�Z�d�dLdM�Z�G dNdO� dO�Z�dPdQ� Z�dRdS� Z�dTdU� Z�dVdW� Z�dXdY� Z�dZd[� Z�d\d]� Z�d^d_� Z�d`da� Z�dbdc� Z�ddde� Z�dfdg� Z�G dhdi� di�Z�djdk� Z�d�dmdn�Z�dodp� Z�dqdr� Z�dsdt� Z�dudv� Z�dwdx� Z�dydz� Z�G d{d|� d|�Z�d}d~� Z�d�dd��Z�d�d�� Z�d�d�� Z�G d�d�� d�e`�Z�G d�d�� d�e`�Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�G d�d�� d��Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�G d�d�� d��Z�G d�d�� d��Z�d�d�� Z�e�eQ�d�d�� �Z�e+d�d�� �Z�G d�d�� d�e��Z�G d�d�� d�e=�Z�eHd� Z�e�e��Z�e�e j�e�< e�d��d�d�� �Z�e�d��d�d�� �Z�e�d��d�d�� �Z�e�d��d�d�� �Z�d�d�� Z�G d�d�� d�e=�Z�eHd�k�rZe�eà �Z�e�eă ne�e j�eH �e j�eH< dS )�zD https://sh.readthedocs.io/en/latest/ https://github.com/amoffat/sh � N)�deque)�Mapping)�metadata�sh�unknownZwindowszsh z0 is currently only supported on Linux and macOS.)�Queue��contextmanager)�partial)�BytesIO�StringIO�UnsupportedOperation)�open)�getpreferredencoding)�Emptyr )�quote)� GeneratorType� ModuleType)�Any�Dict�Type�Unionz https://github.com/amoffat/sh> �outT�err� zUTF-8)ZAIX�DarwinZSH_TESTS_RUNNING�0ZSH_TESTS_USE_SELECTc C s t t�| �j�S �N)�len�inspect�getfullargspec�args��fn� r$ �,/usr/local/lib/python3.9/site-packages/sh.py� get_num_argsf s r& � �poll� � � c @ st e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) � PollPollerc C s t �� | _i | _i | _d S r )�selectr( �_poll� fd_lookup� fo_lookup��selfr$ r$ r% �__init__t s zPollPoller.__init__c C s t | j�dkS �Nr �r r/ r1 r$ r$ r% � __nonzero__z s zPollPoller.__nonzero__c C s t | j�S r r5 r1 r$ r$ r% �__len__} s zPollPoller.__len__c C s@ t |d�r(|�� }|| j|< || j|< n|| j|< || j|< d S �N�fileno��hasattrr9 r/ r0 �r2 �f�fdr$ r$ r% �_set_fileobject� s zPollPoller._set_fileobjectc C s8 t |d�r$|�� }| j|= | j|= n| j|= | j|= d S r8 r: r< r$ r$ r% �_remove_fileobject� s z PollPoller._remove_fileobjectc C s | j �|�S r )r0 �get�r2 r= r$ r$ r% �_get_file_descriptor� s z PollPoller._get_file_descriptorc C s | j �|�S r )r/ rA )r2 r> r$ r$ r% �_get_file_object� s zPollPoller._get_file_objectc C s& | � |� | �|�}| j�||� d S r )r? rC r. �register)r2 r= �eventsr> r$ r$ r% � _register� s zPollPoller._registerc C s | � |tjtjB � d S r )rG r- �POLLIN�POLLPRIrB r$ r$ r% � register_read� s zPollPoller.register_readc C s | � |tj� d S r )rG r- �POLLOUTrB r$ r$ r% �register_write� s zPollPoller.register_writec C s | � |tjtjB tjB � d S r )rG r- �POLLERR�POLLHUP�POLLNVALrB r$ r$ r% �register_error� s zPollPoller.register_errorc C s$ | � |�}| j�|� | �|� d S r )rC r. � unregisterr@ r< r$ r$ r% rQ � s zPollPoller.unregisterc C s� |d ur|d9 }| j �|�}g }|D ]�\}}| �|�}|tjtjB @ rV|�|tf� q$|tj@ rp|�|t f� q$|tj @ r�|�|t f� q$|tj tj B @ r$|�|tf� q$|S )Ni� )r. r( rD r- rH rI �append�POLLER_EVENT_READrK �POLLER_EVENT_WRITErN �POLLER_EVENT_HUPrM rO �POLLER_EVENT_ERROR)r2 �timeout�changes�resultsr> rF r= r$ r$ r% r( � s zPollPoller.pollN)�__name__� __module__� __qualname__r3 r6 r7 r? r@ rC rD rG rJ rL rP rQ r( r$ r$ r$ r% r, s s r, c @ sd e Zd Zdd� Zdd� Zdd� Zedd� �Zed d � �Zd d � Z d d� Z dd� Z dd� Z dd� Z dS )� SelectPollerc C s g | _ g | _g | _d S r )�rlist�wlist�xlistr1 r$ r$ r% r3 � s zSelectPoller.__init__c C s" t | j�t | j� t | j� dkS r4 �r r^ r_ r` r1 r$ r$ r% r6 � s zSelectPoller.__nonzero__c C s t | j�t | j� t | j� S r ra r1 r$ r$ r% r7 � s zSelectPoller.__len__c C s | |vr|� | � d S r )rR �r= rF r$ r$ r% rG � s zSelectPoller._registerc C s | |v r|� | � d S r )�removerb r$ r$ r% � _unregister� s zSelectPoller._unregisterc C s | � || j� d S r )rG r^ rB r$ r$ r% rJ � s zSelectPoller.register_readc C s | � || j� d S r )rG r_ rB r$ r$ r% rL � s zSelectPoller.register_writec C s | � || j� d S r )rG r` rB r$ r$ r% rP � s zSelectPoller.register_errorc C s. | � || j� | � || j� | � || j� d S r )rd r^ r_ r` rB r$ r$ r% rQ � s zSelectPoller.unregisterc C sl t � | j| j| j|�\}}}g }|D ]}|�|tf� q$|D ]}|�|tf� q<|D ]}|�|tf� qT|S r )r- r^ r_ r` rR rS rT rV )r2 rW �_in�_outZ_errrY r= r$ r$ r% r( � s zSelectPoller.pollN)rZ r[ r\ r3 r6 r7 � staticmethodrG rd rJ rL rP rQ r( r$ r$ r$ r% r] � s r] �Pollerc @ s e Zd Zdd� ZdS )� ForkExceptionc C s$ dt �|d�� d�}t�| |� d S )Nz+ Original exception: =================== z � )�textwrap�indent� Exceptionr3 )r2 Zorig_exc�msgr$ r$ r% r3 � s �zForkException.__init__N�rZ r[ r\ r3 r$ r$ r$ r% ri � s ri c @ s e Zd ZdZdd� ZdS )�ErrorReturnCodeMetaa� a metaclass which provides the ability for an ErrorReturnCode (or derived) instance, imported from one sh module, to be considered the subclass of ErrorReturnCode from another module. this is mostly necessary in the tests, where we do assertRaises, but the ErrorReturnCode that the program we're testing throws may not be the same class that we pass to assertRaises c C s& dd� |j D �}| j|v p$|j| jkS )Nc S s h | ] }|j �qS r$ )rZ )�.0�br$ r$ r% � <setcomp> � z8ErrorReturnCodeMeta.__subclasscheck__.<locals>.<setcomp>)� __bases__rZ )r2 �o� other_basesr$ r$ r% �__subclasscheck__ s z%ErrorReturnCodeMeta.__subclasscheck__N)rZ r[ r\ �__doc__rx r$ r$ r$ r% rp s rp c s. e Zd ZeZdZdd� Zd� fdd� Z� ZS )�ErrorReturnCodei� c C s | j | j| j| j| jffS r )� __class__�full_cmd�stdout�stderr�truncater1 r$ r$ r% � __reduce__, s zErrorReturnCode.__reduce__Tc s� | j | _ || _|| _|| _|| _| j}|rb|d | j� }t| j�t|� }|rb|d|� d��� 7 }| j}|r�|d | j� }t| j�t|� }|r�|d|� d��� 7 }d| j� d|�t d�� d|�t d�� �} t � � | � d S )Nz... (z more, please see e.stdout)z more, please see e.stderr)z RAN: z STDOUT: �replacez STDERR: ) � exit_coder| r} r~ r � truncate_capr �encode�decode�DEFAULT_ENCODING�superr3 ) r2 r| r} r~ r Z exc_stdoutZ out_deltaZ exc_stderrZ err_deltarn �r{ r$ r% r3 / s0 � ��zErrorReturnCode.__init__)T) rZ r[ r\ rp � __metaclass__r� r� r3 � __classcell__r$ r$ r� r% rz s rz c @ s e Zd ZdS )�SignalExceptionN�rZ r[ r\ r$ r$ r$ r% r� M s r� c s e Zd ZdZ� fdd�Z� ZS )�TimeoutExceptionzvthe exception thrown when a command is killed because a specified timeout (via _timeout or .wait(timeout)) was hitc s || _ || _tt| ��� d S r )r� r| r� rm r3 )r2 r� r| r� r$ r% r3 U s zTimeoutException.__init__)rZ r[ r\ ry r3 r� r$ r$ r� r% r� Q s r� c @ s e Zd ZdS )�CommandNotFoundNr� r$ r$ r$ r% r� m s r� z6(ErrorReturnCode|SignalException)_((\d+)|SIG[a-zA-Z]+)� rc_exc_cachec C s" i | ]\}}t �d |�r||�qS )z SIG[a-zA-Z]+)�re�match�rq �k�vr$ r$ r% � <dictcomp>t s r� c C s� d}z t | W S ty� t�| �}|r�|�d�}|�d�}|dkrvzt|� }W q~ tyr tt|� }Y q~0 nt|�}t |�}Y n0 |S )a takes an exception name, like: ErrorReturnCode_1 SignalException_9 SignalException_SIGHUP and returns the corresponding exception. this is primarily used for importing exceptions from sh into user code, for instance, to capture those exceptionsNr) r r� ) r� �KeyError� rc_exc_regexr� �group�int� ValueError�getattr�signal� get_rc_exc)�name�exc�m�baseZrc_or_sig_name�rcr$ r$ r% �get_exc_from_namey s r� c C sj z t | W S ty Y n0 | dkr6d| � �}t}ndtt| � � �}t}t||fd| i�}|t | < |S )aG takes a exit code or negative signal number and produces an exception that corresponds to that return code. positive return codes yield ErrorReturnCode exception, negative return codes yield SignalException we also cache the generated exception so that only one signal of that type exists, preserving identityr ZErrorReturnCode_ZSignalException_r� )r� r� rz �SIGNAL_MAPPING�absr� rp )r� r� r� r� r$ r$ r% r� � s r� c @ s e Zd Zdd� ZdS )� GlobResultsc C s || _ t�| |� d S r )�path�listr3 )r2 r� rY r$ r$ r% r3 � s zGlobResults.__init__Nro r$ r$ r$ r% r� � s r� c O s t | t| g|�R i |���}|S r )r� � _old_glob)r� r! �kwargsZexpandedr$ r$ r% �glob� s r� c C s t j�t j�| ��S r )�osr� �abspath� expanduser)r� r$ r$ r% � canonicalize� s r� c C s� dd� }d}t j�| �\}}|r6t| �} || �r�| }njg }t|ttf�rT|�|� n t j� dd��t j �}|�|� |D ]&}t j� t|�| �} || �rx| } q�qx|S )a+ takes a program name or full path, plus an optional collection of search paths, and returns the full path of the requested executable. if paths is specified, it is the entire list of search paths, and the PATH env is not used at all. otherwise, PATH env is used to look for the programc S s. t j�| �o,t �| t j�o,t j�t j�| ��S r )r� r� �exists�access�X_OK�isfile�realpath)� file_pathr$ r$ r% �is_exe� s ��z_which.<locals>.is_exeN�PATHr' ) r� r� �splitr� � isinstance�tupler� �extend�environrA �pathsep�join) �program�pathsr� Z found_pathZfpath�fnameZpaths_to_searchZ env_pathsr� Zexe_filer$ r$ r% �_which� s$ r� c C s0 t | �}|s,d| v r$t | �dd��}|s,d S |S )N�_�-)r� r� )r� r� r$ r$ r% �resolve_command_path s r� c C s0 t | �}d }|r,||�}|r,|jf i |��}|S r )r� �bake)r� � command_cls� baked_argsr� �cmdr$ r$ r% �resolve_command s r� c @ sV e Zd ZdZddd�Zdd� Zedd� �Zd d � Zd d � Z d d� Z dd� Z dd� Z dS )�LoggeraF provides a memory-inexpensive logger. a gotcha about python's builtin logger is that logger objects are never garbage collected. if you create a thousand loggers with unique names, they'll sit there in memory until your script is done. with sh, it's easy to create loggers with unique names if we want our loggers to include our command arguments. for example, these are all unique loggers: ls -l ls -l /tmp ls /tmp so instead of creating unique loggers, and without sacrificing logging output, we use this class, which maintains as part of its state, the logging "context", which will be the very unique name. this allows us to get a logger with a very general name, eg: "command", and have a unique name appended to it via the context, eg: "ls -l /tmp" Nc C s, || _ t�t� d|� ��| _| �|�| _d S �N�.)r� �logging� getLogger�SH_LOGGER_NAME�log�sanitize_context�context)r2 r� r� r$ r$ r% r3 * s zLogger.__init__c G s | j r| j � d|� �}|| S )N�: �r� �r2 rn �ar$ r$ r% � _format_msg/ s zLogger._format_msgc C s | r| � dd�} | pdS )N�%z%%r' )r� r� r$ r$ r% r� 4 s zLogger.sanitize_contextc C s& | j d | }| jd | }t||�S r� )r� r� r� )r2 r� r� �new_nameZ new_contextr$ r$ r% � get_child: s zLogger.get_childc G s | j �| j|g|�R � � d S r )r� �infor� r� r$ r$ r% r� ? s z Logger.infoc G s | j �| j|g|�R � � d S r )r� �debugr� r� r$ r$ r% r� B s z Logger.debugc G s | j �| j|g|�R � � d S r )r� �errorr� r� r$ r$ r% r� E s z Logger.errorc G s | j �| j|g|�R � � d S r )r� � exceptionr� r� r$ r$ r% r� H s zLogger.exception)N) rZ r[ r\ ry r3 r� rg r� r� r� r� r� r� r$ r$ r$ r% r� s r� c C s( |rd| �d|� d�}n d| �d�}|S )N� <Command z, pid �>r$ )r� � call_args�pid�sr$ r$ r% �default_logger_strL s r� c @ s� e Zd ZdZh d�Zdd� Zd2dd�Zdd � Zd d � Ze d d � �Z e dd� �Z e dd� �Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Z dS )3�RunningCommanda� this represents an executing Command object. it is returned as the result of __call__() being executed on a Command instance. this creates a reference to a OProc instance, which is a low-level wrapper around the process that was exec'd this is the class that gets manipulated the most by user code, and so it implements various convenience methods and logical mechanisms for the underlying process. for example, if a user tries to access a backgrounded-process's stdout/err, the RunningCommand object is smart enough to know to wait() on the process to finish first. and when the process finishes, RunningCommand is smart enough to translate exit codes to exceptions.> �ctty� signal_groupZoutput_thread_exc�pgid�kill� kill_groupZinput_thread_excZ bg_thread_excr� � terminater� �sidc C s2 d� dd� |D ��| _|| _|| _d | _d| _d}d}d| _z t�� W n t y` d | _ Y n 0 t� � | _ d| _ |d r�d}t � �| � |d s�|d s�|d r�d}|d r�d}|d r�d}|d r�tj}|d }|r�t|| �|d < tj} |d dk�s|d du �rtj} n|d dk�r$tj} |d dk�s@|d du �rHtj} n|d dk�r\tj} d| _|�r.|d �ptt} | | j|�} td| �| _| j�d� |�r�d| _t�� } | �. t| | j||||| j| | � | _W d � n1 �s�0 Y | | j|| jj�} | j�| �| j_ | j� d� |�r.| � � d S )N� c S s g | ]}t t|���qS r$ )� shlex_quote�str)rq �argr$ r$ r% � <listcomp>v rt z+RunningCommand.__init__.<locals>.<listcomp>FT�with�piped�iter� iter_noblock�async�bg� err_to_out�doner r �log_msg�commandzstarting processzprocess started) r� �ranr� r� �process�_waited_until_completion�_force_noblock_iter�asyncio�get_running_loop� RuntimeError�aio_output_complete�Event�_stopped_iteration�get_prepend_stackrR �OProc�STDOUTr �STDERR�_spawned_and_waitedr� r� r� r� � threading�Lockr� r� r� r� �wait) r2 r� r� �stdinr} r~ Z should_waitZ spawn_process� done_callback�pipeZlog_str_factoryZ logger_str�process_assign_lockr$ r$ r% r3 r s~ �& zRunningCommand.__init__Nc C s� | j s�|durxd}d}d}d}|dk r.td��||kr`| j�� \}}|r`t�|� ||7 }q.q`q.|rptd| j��d| _ n| j�� }d| _ | jj r�t| | j��n | � |� | jj r�| jj j �� | j �d� | S )a� waits for the running command to finish. this is called on all running commands, eventually, except for ones that run in the background if timeout is a number, it is the number of seconds to wait for the process to resolve. otherwise block on wait. this function can raise a TimeoutException, either because of a `_timeout` on the command itself as it was launched, or because of a timeout passed into this method. Nr 皙�����?Fztimeout cannot be negativeTzprocess completed)r� r r� �is_alive�time�sleepr� r� r � timed_out�handle_command_exit_code�_stdin_processr� r� r� )r2 rW Z waited_forZ sleep_amt�aliver� r$ r$ r% r � s4 zRunningCommand.waitc C s | j �� d S )zUreturns whether or not we're still alive. this call has side-effects on OProcr )r� r r1 r$ r$ r% r ( s zRunningCommand.is_alivec C sB | j }t||d |d �}|r>|| j| jj| jj|d �}|�dS )z�here we determine if we had an exception, or an error code that we weren't expecting to see. if we did, we create and raise an exception �ok_coder� � truncate_excN)r� � get_exc_exit_code_would_raiser� r� r} r~ )r2 �code�ca� exc_classr� r$ r$ r% r - s �z'RunningCommand.handle_command_exit_codec C s | � � | jjS r )r r� r} r1 r$ r$ r% r} 9 s zRunningCommand.stdoutc C s | � � | jjS r )r r� r~ r1 r$ r$ r% r~ > s zRunningCommand.stderrc C s | � � | jjS r )r r� r� r1 r$ r$ r% r� C s zRunningCommand.exit_codec C s t t| ��S r )r r� r1 r$ r$ r% r7 H s zRunningCommand.__len__c C s dS )z�we don't actually do anything here because anything that should have been done would have been done in the Command.__call__ call. essentially all that has to happen is the command be pushed on the prepend stack.Nr$ r1 r$ r$ r% � __enter__K s zRunningCommand.__enter__c C s | S r r$ r1 r$ r$ r% �__iter__R s zRunningCommand.__iter__c C s� | j r t� �| jj}| j }z|�|| jd �}W n, ty^ | jd sP| jrZtj Y S Y q 0 |du r|| � � d| _ t� �z|� | jd | jd �W S t y� | Y S 0 q dS )z2allow us to iterate over the output of our command�iter_poll_timer� NT�encoding� decode_errors) r � StopIterationr� � _pipe_queuer rA r� r �errno� EWOULDBLOCKr r� �UnicodeDecodeError)r2 ZpqZ block_pq_read�chunkr$ r$ r% �__next__U s& � zRunningCommand.__next__c s � fdd�}|� � � S )Nc � s2 � j �� I d H � jd r&� �� � S t� �S d S )N� return_cmd)r r r� r� r$ r1 r$ r% �wait_for_completionz s z5RunningCommand.__await__.<locals>.wait_for_completion)� __await__)r2 r. r$ r1 r% r/ y s zRunningCommand.__await__c s4 t dd�� _d� _� fdd�}t�|� �}|� _� S )Nr) )�maxsizeTc � sh zN� D ]2} | t jkr&t�d�I d H q� j�| �I d H qW � j�d �I d H n� j�d �I d H 0 d S )Ng{�G�z�?)r( r) r r � _aio_queue�put�r+ r1 r$ r% �queue_connector� s z1RunningCommand.__aiter__.<locals>.queue_connector)�AQueuer1 r r � create_task� _aio_task)r2 r4 �taskr$ r1 r% � __aiter__� s zRunningCommand.__aiter__c � s: | j �� I d H }|d ur |S | j�� }|d ur2|�t�d S r )r1 rA r7 r� �StopAsyncIteration)r2 r+ r� r$ r$ r% � __anext__� s zRunningCommand.__anext__c C s | j d rt� rt� �� d S )Nr� )r� r �pop�r2 �exc_type�exc_val�exc_tbr$ r$ r% �__exit__� s zRunningCommand.__exit__c C s* | j r&| jr&| j�| jd | jd �S dS )Nr$ r% r' )r� r} r� r� r1 r$ r$ r% �__str__� s �zRunningCommand.__str__c C s t | �t |�kS r )�id�r2 �otherr$ r$ r% �__eq__� s zRunningCommand.__eq__c C s |t | �v S r �r� )r2 �itemr$ r$ r% � __contains__� s zRunningCommand.__contains__c C s> || j v r | jr t| j|�S t�|tv r6tt| �|�S t�d S r )�_OProc_attr_allowlistr� r� �AttributeError�_unicode_methodsr� )r2 �pr$ r$ r% � __getattr__� s zRunningCommand.__getattr__c C sD z t | �W S ty> | jr2| jr2t| j� Y S td� Y S 0 d S �Nr' )r� r* r� r} �reprr1 r$ r$ r% �__repr__� s zRunningCommand.__repr__c C s t t| ��� �S r �r� r� �stripr1 r$ r$ r% �__long__� s zRunningCommand.__long__c C s t t| ��� �S r )�floatr� rS r1 r$ r$ r% � __float__� s zRunningCommand.__float__c C s t t| ��� �S r rR r1 r$ r$ r% �__int__� s zRunningCommand.__int__)N) rZ r[ r\ ry rJ r3 r r r �propertyr} r~ r� r7 r! r" r, r/ r9 r; rA rB rF rI rN rQ rT rV rW r$ r$ r$ r% r� T s8 n H $ r� c C s t | t�pt| d�S )N� __fspath__)r� r� r; )r r$ r$ r% �output_redirect_is_filename� s rZ c C s t j} t| d�sg | _| jS )N�_prepend_stack)�Command� thread_localr; r[ )�tlr$ r$ r% r � s r c C s` t | �� �}g }|D ]F}t|�r:|}|| |�}|�|� q|\}}|�|�r|�||f� q|S r )�set�keys�callabler� � issupersetrR ) � passed_kwargs� merged_kwargsZ invalid_list�s1Z invalid_args�elemr# �ret� error_msgr$ r$ r% �special_kwarg_validator� s ri c C sP t | dd �}d }|r4z |� }W qL ty0 Y qL0 nt| tf�rL| dkrL| }|S )Nr9 r )r� r r� r� )�obZ fileno_methr9 r$ r$ r% � get_fileno� s rk c C s t | �d uS r )rk )rj r$ r$ r% �ob_is_fd_based s rl c C s" t | �}d}|dur t�|�}|S )z7checks if an object (like a file-like object) is a tty.FN)rk r� �isatty)rj r9 �is_ttyr$ r$ r% � ob_is_tty s ro c C s* t | �}d}|r&t�|�}t�|j�}|S �NF)rk r� �fstat�stat�S_ISFIFO�st_mode)rj r9 Zis_pipeZfd_statr$ r$ r% � ob_is_pipe s ru c C s2 g }| � d�r.| � d�dv r.d}|�d|f� |S )N�no_outr� )Tr z4You cannot iterate over output if there is no output)rv r� )rA rR )rc rd �invalidr� r$ r$ r% �output_iterator_validator& s rx c C sx d}g }|D ]D\}}|| v r t | �|d ��r d|� d|� d�}|�||f|f� q |d rt|d rj|d st|�d� |S ) N))�tty_in�in)�tty_outr z`_zG` is a TTY already, so so it doesn't make sense to set up a TTY with `_�`� unify_ttysry r{ ))r} ry r{ zC`_tty_in` and `_tty_out` must both be True if `_unify_ttys` is True)ro rA rR )rc rd �pairsrw Ztty_typeZstdr� r$ r$ r% �tty_in_validator. s$ �����r c C sF g }d}h d�}t | �� �| }d| v rB| d rB|rB|�d|f� |S )z1fg is not valid with basically every other optionz�_fg is invalid with nearly every other option, see warning and workaround here: https://sh.readthedocs.io/en/latest/sections/special_arguments.html#fg> r �cwd�fg�envr� )r_ r` rR )rc rd rw rn � allowlistZ offendingr$ r$ r% � fg_validatorI s r� c C s� g }| � dd�}| � dd�}| � dd�}| � dd�}t|�}t|�}d} |rj|durj|�d| jdd�f� |r�|dur�|�d | jdd�f� |S ) a; a validator to prevent a user from saying that they want custom buffering when they're using an in/out object that will be os.dup'ed to the process, and has its own buffering. an example is a pipe or a tty. it doesn't make sense to tell them to have a custom buffering, since the os controls this.rz Nr � in_bufsize� out_bufsizezICan't specify an {target} bufsize if the {target} target is a pipe or TTY)rz r� )�target)r r� )rA rl rR �format) rc rd rw Zin_obZout_obZin_bufZout_bufZ in_no_bufZ out_no_bufr r$ r$ r% �bufsize_validatorY s r� c C s� g }| � dd�}|du r |S t|t�s>|�dd|��f� |S | d �� D ]N\}}t|t�sr|�dd|�d�f� t|t�sJ|�dd|�d|�d�f� qJ|S )z�a validator to check that env is a dictionary and that all environment variable keys and values are strings. Otherwise, we would exit with a confusing exit code 255.r� Nzenv must be dict-like. Got zenv key z must be a strzvalue z of env key )rA r� r rR �itemsr� )rc rd rw r� r� r� r$ r$ r% � env_validatoru s r� c . @ s� e Zd ZU dZe�� ZeZdddddddddddddddddddd d ddde d de j dddddd dddddddde � ddd �-Z eeef ed< dddedeeeef Zd'dd�Zdd� Zedd� �Zdd� Z dd � Z d d � Z d d � Z d!d"� Z d#d$� Z!d%d&� Z"dS )(r\ a� represents an un-run system program, like "ls" or "cd". because it represents the program itself (and not a running instance of it), it should hold very little state. in fact, the only state it does hold is baked arguments. when a Command object is called, the result that is returned is a RunningCommand object, which represents the Command put into an execution state.FTNr r) i 0 r �=z--�strict�� �P )-r� r� �bg_excr� rz r r r� r� r� � err_bufsize�internal_bufsizer� r� r� r� r# r r� �long_sep� long_prefixry r{ r} r$ r% rW �timeout_signalrv �no_err�no_pipe�teer� �tty_sizer � preexec_fn�uid� new_session� new_group�arg_preprocessr� � close_fds�pass_fdsr- r� � _call_args))r r� z"Stderr is already being redirected))r� r� z3You cannot iterate when this command is being piped))r� r� z;Using a pipe doesn't make sense if you've disabled the pipe))r� r� z0Passing `pass_fds` forces `close_fds` to be Truec C sL t ||�}d| _d| _g | _i | _t| �| _|s8t|��|| _t| �| _d S )Nr' F)r� �_path�_partial�_partial_baked_args�_partial_call_argsr� rZ r� )r2 r� Z search_paths�foundr$ r$ r% r3 s zCommand.__init__c C sd t tj| �}d }|�d�r$||�}n(|dkr6|d�}n|�d�rL|d d� }|d u r`|d�|�}|S )Nr� r� ���)r �object�__getattribute__� startswith�endswith)r2 r� Zget_attr�valr$ r$ r% r� ' s zCommand.__getattribute__c C s� |� � }i }| j�� D ]*\}}d| }||v r|| ||< ||= q| j� � }|�|� t||| j�}|r�g }|D ] \} } |�d| �d| � �� qpd�|�}td|� d���||fS )z�takes kwargs that were passed to a command's __call__ and extracts out the special keyword arguments, we return a tuple of special keyword args, and kwargs that will go to the exec'ed commandr� z r� rj z Invalid special arguments: ) �copyr� r� �updateri �_kwarg_validatorsrR r� � TypeError) �clsr� r� Zparg�default�keyZ merged_argsZinvalid_kwargsZexc_msg�kwargrh r$ r$ r% �_extract_call_args= s& � zCommand._extract_call_argsc O s� t | �| j�}d|_| �|�\}}|j�| j� |j�|� |j�| j� |�d| j d �}|�d| j d �}|j�t ||||�� |S )a. returns a new Command object after baking(freezing) the given command arguments which are used automatically when its exec'ed special keyword arguments can be temporary baked and additionally be overridden in __call__ or in subsequent bakes (basically setting defaults)Tr� r� ) �typer� r� r� r� r� r� r� rA r� � compile_args)r2 r! r� r# r� �sep�prefixr$ r$ r% r� [ s z Command.bakec C s" d� | j�}|rd| }| j| S )Nr� )r� r� r� )r2 r� r$ r$ r% rB q s zCommand.__str__c C s t | �t |�kS r rG rD r$ r$ r% rF w s zCommand.__eq__c C s dt | ��d�S )Nr� r� rG r1 r$ r$ r% rQ z s zCommand.__repr__c C s | dd� d S )NT)�_withr$ r1 r$ r$ r% r! } s zCommand.__enter__c C s t � �� d S r )r r< r= r$ r$ r% rA � s zCommand.__exit__c O s| |� � }t|�}g }| jj� � }t� D ]<}|j� � }|�dd � |�|� |�dd�s&|� |j � q&|� | j � | j �dd �}|r�|||�\}}| �|�\}}|�| j � |�|� |d d u r�d|d< t|d dd �s�|d g|d< |d } t| t��r| jd �r| j} n| jj} t|||d |d �} | j| } | } |� | � |d �r|d �p^t�� } t| ��N |d d u �r�t�tj|d |�}nt�tj|d ||d �}W d � n1 �s�0 Y t ||d |d �}|�rd� |�}||dd|d �}|�d S |d }t |��r&t t |�d�}|d }t |��rFt t |�d�}| j�!||| ||�}|j"�rt|d �stt |�S |S d S )Nr� r� Fr� r r r" rz r� r� r� r� r� r� r� rt r r �wbr r- )#r� r� r{ r� r r� r< r� rA r� r� rR r� r� r� r� r� r� r� r' r� r� r� �getcwd�pushd�spawnv�P_WAIT�spawnver r� rZ r r� �RunningCommandClsr )r2 r! r� r� r� �prependZ pcall_args� preprocessorZextracted_call_argsr �processed_argsZ split_argsZ final_argsr� r� r r� r� r} r~ r� r$ r$ r% �__call__� sp � :� zCommand.__call__)N)#rZ r[ r\ ry r �localr] r� r� r� r� �SIGKILLr_ r� r r� r �__annotations__rx r r� r� r� r� r3 r� � classmethodr� r� rB rF rQ r! rA r� r$ r$ r$ r% r\ � s� �h� r\ c C s� g }| D ]~}t |ttf�rFt |t�r0|s0|jg}|D ]}|�|� q4qt |t�rf|t|||dd�7 }q|du s�|du rxq|�t|�� q|t|||�7 }|S )a� takes args and kwargs, as they were passed into the command instance being executed with __call__, and compose them into a flat list that will eventually be fed into exec. example: with this call: sh.ls("-l", "/tmp", color="never") this function receives args = ['-l', '/tmp'] kwargs = {'color': 'never'} and produces ['-l', '/tmp', '--color=geneticnever'] T)�rawNF) r� r� r� r� r� rR �dict�_aggregate_keywordsr� )r� r� r� r� r� r� Zsub_argr$ r$ r% r� � s r� Fc C s� g }| � � D ]�\}}|g}t|ttf�r,|}|D ]�}t|�dkrn|dur�|�d| � |dur�|�t|�� q0|s~|�dd�}|du r�|�|| � q0|du r�q0|du s�|dkr�|�|| � |�t|�� q0|� |� |� |� �} |�| � q0q |S )a take our keyword arguments, and a separator, and compose the list of flat long (and short) arguments. example {'color': 'never', 't': True, 'something': True} with sep '=' becomes ['--color=never', '-t', '--something'] the `raw` argument indicates whether or not we should leave the argument name alone, or whether we should replace "_" with "-". if we pass in a dictionary, like this: sh.command({"some_option": 12}) then `raw` gets set to True, because we want to leave the key as-is, to produce: ['--some_option=12'] but if we just use a command's kwargs, `raw` is False, which means this: sh.command(some_option=12) becomes: ['--some-option=12'] essentially, using kwargs is a convenience, but it lacks the ability to put a '-' in the name, so we do the replacement of '_' to '-' for you. but when you really don't want that to happen, you should use a dictionary instead with the exact names you want r) Fr� Tr� Nr� )r� r� r� r� r rR r� r� ) �keywordsr� r� r� � processedr� Zmaybe_list_of_vZ list_of_vr� r� r$ r$ r% r� s. # r� c s0 � �fdd�}t j|||d�}d|_|�� |S )Nc sH z�| i |�� W n0 t yB } z� �|� � W Y d }~n d }~0 0 d S r )rm r2 )Zrgsr� �e�� exc_queuer# r$ r% �wraph s z"_start_daemon_thread.<locals>.wrap)r� r� r! T)r �Thread�daemon�start)r# r� r� r� r� �threadr$ r� r% �_start_daemon_threadg s r� c C s8 |\}}t tdd�}t�d||dd�}t�| ||� dS )zSset the terminal size of a tty file descriptor. borrowed logic from pexpect.py� TIOCSWINSZigt�ZHHHHr N)r� �termios�struct�pack�fcntl�ioctl)r> Z rows_cols�rows�colsZwinsizer� r$ r$ r% � setwinsizeu s r� c s� d}d}� }t � t�r&t� j�}� j}t�|�r>d}t|�}n"t�|�rRt|�}nd}t|j �}|| | }d�|dkr|d�|dkr�| j f�n|dkr�| j t � | �f�� �fdd�}|S )a^ here we're constructing a closure for our streamreader callback. this is used in the case that we pass a callback into _out or _err, meaning we want to our callback to handle each bit of output we construct the closure based on how many arguments it takes. the reason for this is to make it as easy as possible for people to use, without limiting them. a new user will assume the callback takes 1 argument (the data). as they get more advanced, they may want to terminate the process, or pass some stdin back, and will realize that they can pass a callback of more argsr r) r$ r � c s2 �}t |�dkr"�d �d � f}� | g|�R � S )Nr r r) )r )r+ r� ��handlerZ handler_argsr$ r% r# � s z+construct_streamreader_callback.<locals>.fn) r� r r r! �funcr �ismethodr& � isfunctionr� r �weakref�ref)r� r� Z implied_arg� partial_argsZhandler_to_inspect�num_argsZnet_argsr# r$ r� r% � construct_streamreader_callback s. r� c sT d }| � v }� fdd�t D �}| |v }|r@| tjkr@d}d}|rH|rPt| �}|S )Nc s g | ]}| � vr|�qS r$ r$ )rq �sig��ok_codesr$ r% r� � s z1get_exc_exit_code_would_raise.<locals>.<listcomp>FT)�#SIGNALS_THAT_SHOULD_THROW_EXCEPTIONr� �SIGPIPEr� )r� r� Z sigpipe_okr� �successZ#signals_that_should_throw_exceptionZbad_sigr$ r� r% r � s � r c C s: t �| �rt �| � } n t �| �r.t �| �} ntd��| S )z;this should only ever be called once for each child processzUnknown child exit status!)r� � WIFSIGNALED�WTERMSIG� WIFEXITED� WEXITSTATUSr �r� r$ r$ r% �handle_process_exit_code� s r� c O s` d}z| |i |��}W q\ t yV } z(|jtjkr@W Y d}~qn� W Y d}~qd}~0 0 q\q|S )z0a helper for making system calls immune to EINTRN)�OSErrorr( ZEINTR)Zsyscallr! r� rg r� r$ r$ r% � no_interrupt� s r� c @ s� e Zd ZdZdZdZdZdd� Zdd� Zd d � Z d d � Z d d� Z e dd� �Z e dd� �Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)S )*r a" this class is instantiated by RunningCommand for a command to be exec'd. it handles all the nasty business involved with correctly setting up the input/output to the child process. it gets its name for subprocess.Popen (process open) but we're calling ours OProc (open process)r� r� ���c = s |�_ |�_�j� � d durPt�� dkr2td��� d } t�� d �} | j} nd\} } � d rhd� d< d�_t |�} t |�}t |�}t � d t t t f�s�� d du r�� d h}n t� d �}t�|�}t�|�}� d o� d o� d }|�r<t�� \�_�_t��j��_t��j��_t��j��_t��j��_�n:t |t��rj|jd �rj|j �_d�_|�_nJ| �r�t�t |���_d�_n,� d �r�t�� \�_�_nt� � \�_�_|�r�|�s�t�t |���_d�_n,� d �r�t�� \�_�_nt� � \�_�_|tj u �rB|�r$|�s$d�_nt��j��_t��j��_n4|�rf|�sft�t |���_d�_nt� � \�_�_� d }d�_ |�r��j}|d k�r��j}t�|��_ � d }� d }� d }|�r�d}d�_ |�r�t�!�j��_ t"�#� }|�r�t"�$� t� � \}}t� � \} } t%�r*t� � \} } nd\} } d�_&d�_'t�(� �_)�j)dk�r�t%�rzt�*| d� t�+| � t�+| � t,�,| t,j-�} | t,j.O } t,�,| t,j/| � �z�� d du �r�t0�0t0j1t0j2� t0�0t0j3t0j4� |�r�t�5� n|�r�t�6dd� t�7d�}!t�8d�}"|!� d|"� ��9t:�}#t�;||#� � d �rL|�sL|�sLt<�=�j� �j�r`t�+�j� �j�rtt�+�j� �j�r�t�+�j� t�+|� t�+| � � d }$|$�r�t�>|$� t�?�jd� t�?�jd� t�?�jd� |�rt�@t�!d�tjA�}%t�+|%� � d �r |�s tBd� d � � d du�rBt�C| � t�D| � � d }&tE|&��rZ|&� � d }'� d �rpd}'|'�r ddd| h}(|(�F� d � zt�Gd�})W n tH�y� t�Gd�})Y n0 dd � |)D �|( })|)D ]*}*zt�+|*� W n tH�y� Y n0 �qԇ fd d �|D �}+� d du �r2t�I|+d |+� nt�J|+d |+� d � W n� tK�y� tL�M� �9d d!�},zZzt�;| |,� W n: tK�y� }- z tNjO�;d"|-� d#�� W Y d}-~-n d}-~-0 0 W t�Pd$� n t�Pd$� 0 Y n0 �n(|�r�t"�Q� t�+�j� t�+�j� t�+�j� t%�r>t�+| � t�;| t d��9t:�� t�+| � t�+| � t�*| d%�}.t�+| � |.�rv|.�Rt:�}.tS|.��t�+|� t�*|d&��Rt:��Td�\}!}"t�+|� t |!��_&t |"��_'d�_UtV�V� �_W|�_Xd�_Y|�_ZtE� d' ��r��jZdu �r�t[� �_Zt[� �_\t]�^� �__t`� d( d)��_at`� d( d)��_b� d �rP| �sPtB�j� d � |�cd*td����_e�je�fd+� � d �r�| �s�tg�h�j�}/|/d, tgji M < tg�j�jtgjk|/� d�_l�j�r�je�cd-d.�}0tm|0�j�jZ� d/ � d0 � d ��_ld}1|tj u � r� d1 � s�j\}1� d2 � o(|� p(|du }2� d d3v }3� d d4v }4d�_n|3� s��j� r�tE|�� rjto�|�}tp�je�cd5d6��j|�ja� d7 � d0 � d8 |1|2d9� �_nn�j� r�t�+�j� d�_q|tj u� r\|� s\|4� s\�j� r\d}5|tjru � r�� d1 � s��j\}5� d: � o|� p|du }6tE|�� r*to�|�}tptsd5��j|�jb� d; � d0 � d8 |5|6d9� �_qn�j� rpt�+�j� � �fd<d=�}7d�_td�_u� d> � r�t]�v� �_tt]�w� d> �jtj��_u�ju�x� d}8�j jy� s� d? � r� d@ � s��fdAdB�}9|9}8t]�v� �_zdC�j)� �}:t[d��_{t|t}|:�j{|7�jt|8�j~�jz��_d�_�t[d��_��jl� r~| };dD�j)� �}:t|t�|:�j��je�jl�j~�jz|;��_�t]�v� �_�z t���� �W n t� y� dEdF� }<Y n0 ��fdGdF�}<t[d��_�dH�j)� �}:t|t�|:�j��je�jn�jq�jt�j~�jz�j�|<� �_�dS )IaK cmd is the full list of arguments that will be exec'd. it includes the program name and all its arguments. stdin, stdout, stderr are what the child will use for standard input/output/err. call_args is a mapping of all the special keyword arguments to apply to the child process. r� Nr z$UID setting requires root privileges)NNr� Fr{ r� ry r} r r� r� Tr) r� �,r� r r� r� r� r� z/dev/fdz /proc/self/fdc S s h | ] }t |��qS r$ )r� )rq r> r$ r$ r% rs 6 rt z!OProc.__init__.<locals>.<setcomp>c s g | ]}|� � d ��qS )r$ )r� )rq �c)r r$ r% r� @ rt z"OProc.__init__.<locals>.<listcomp>r� �utf8�ignorez FATAL SH ERROR: rj � i � r r� ��maxlenr� zstarted processr� � streamwriterr r� r$ r� rv )r T)r � streamreaderr} r� r% )� save_datar� r� c s d�_ ��� d � d S )NTr� )r r� r$ )r r2 r$ r% � timeout_fn s z"OProc.__init__.<locals>.timeout_fnrW r� r� c s4 � � �j �| �W d � S 1 s&0 Y d S r )r� r r� )r r2 r$ r% r# s zOProc.__init__.<locals>.fnzbackground thread for pid zSTDIN thread for pid c S s d S r r$ r$ r$ r$ r% �output_completeW s z'OProc.__init__.<locals>.output_completec s � � �jjj� d S r )�call_soon_threadsafer� r r_ r$ )�loopr2 r$ r% r \ s zSTDOUT/ERR thread for pid )�r� r� r� �getuidr �pwd�getpwuid�pw_gidr rl r� r� �boolr� r_ � TEE_STDOUT� intersection� TEE_STDERR�pty�openpty�_stdin_parent_fdZ_stdin_child_fd�dupZ_stdout_parent_fdZ_stdout_child_fdZ_stderr_parent_fdZ_stderr_child_fdr Z_pipe_fdrk r r r� �ttyname�gc� isenabled�disable�IS_MACOSr� r� �forkr� �read�closer� ZF_GETFDZ FD_CLOEXECZF_SETFDr� �SIGHUP�SIG_IGNr� �SIG_DFL�setsid�setpgid�getsid�getpgidr� r� �write�ttyZsetraw�chdir�dup2r �O_RDWRr� �setgid�setuidra r� �listdirr� �execv�execverm � traceback� format_exc�sysr~ �_exit�enabler� ri r� r r �startedr� r� r r r' r r � _wait_lockr �_stdout�_stderrr� rP r� r� r� � tcgetattr�ECHO� tcsetattr�TCSANOW� _stdin_stream� StreamWriter�_stdout_streamr� � StreamReader�_stderr_streamr r� Z_timeout_event�_timeout_timerr �Timerr� r � _quit_threadsZ_bg_thread_exc_queuer� �background_threadr �_background_thread� _input_threadZ_input_thread_exc_queue� input_thread�_stop_output_eventr r Z_output_thread_exc_queue� output_thread�_output_thread)=r2 r� Z parent_logr� r r} r~ r� r r Z target_uidZpwrecZ target_gidZstdin_is_fd_basedZstdout_is_fd_basedZstderr_is_fd_basedr� Ztee_outZtee_errZ single_ttyr� Z fd_to_user� r� Z needs_cttyZ gc_enabledZsession_pipe_readZsession_pipe_writeZ exc_pipe_readZexc_pipe_writeZclose_pipe_readZclose_pipe_write�flagsr� r� �payloadr� Ztmp_fdr� r� r� Z inherited_fdsr> Z bytes_cmd�tbr� Zfork_exc�attrr� Z stdout_pipeZ save_stdoutZpipe_outZpipe_errZ stderr_pipeZ save_stderrr �handle_exit_coder# Z thread_name�close_before_termr r$ )r r r r2 r% r3 s� ," � � � ���� � � ��� � � �zOProc.__init__c C s d| j � d| jd d� �d�S )Nz <Process r� i� r� )r� r� r1 r$ r$ r% rQ o s zOProc.__repr__c C s | j j�|� d S r )r= �stream_bufferer�change_buffering�r2 �bufr$ r$ r% �change_in_bufsizer s zOProc.change_in_bufsizec C s | j j�|� d S r )r? rR rS rT r$ r$ r% �change_out_bufsizeu s zOProc.change_out_bufsizec C s | j j�|� d S r )rA rR rS rT r$ r$ r% �change_err_bufsizex s zOProc.change_err_bufsizec C s d� | jd ��| j�S �Nr' r$ )r� r� r� r7 r1 r$ r$ r% r} { s z OProc.stdoutc C s d� | jd ��| j�S rY )r� r� r� r8 r1 r$ r$ r% r~ s z OProc.stderrc C s t �| j�S )z�return the CURRENT group id of the process. this differs from self.pgid in that this reflects the current state of the process, where self.pgid is the group id at launch)r� r% r� r1 r$ r$ r% �get_pgid� s zOProc.get_pgidc C s t �| j�S )z�return the CURRENT session id of the process. this differs from self.sid in that this reflects the current state of the process, where self.sid is the session id at launch)r� r$ r� r1 r$ r$ r% �get_sid� s z OProc.get_sidc C s" | j �d|� t�| �� |� d S )Nzsending signal %d to group)r� r� r� �killpgrZ �r2 r� r$ r$ r% r� � s zOProc.signal_groupc C s | j �d|� t�| j|� d S )Nzsending signal %d)r� r� r� r� r� r] r$ r$ r% r� � s z OProc.signalc C s | j �d� | �tj� d S )Nz killing group)r� r� r� r� r� r1 r$ r$ r% r� � s zOProc.kill_groupc C s | j �d� | �tj� d S )NZkilling)r� r� r� r� r1 r$ r$ r% r� � s z OProc.killc C s | j �d� | �tj� d S )NZ terminating)r� r� r� �SIGTERMr1 r$ r$ r% r� � s zOProc.terminatec C s2 | j durd| j fS | jjdd�}|sD| j dur:d| j fS d| j fS d}z�zVttj| jtj�\}}|| jkr�t|�| _ d}d| j fW W | j� � |r�| � � S W n4 t y� d| j f Y W | j� � |r�| � � S 0 d| j fW | j� � |r�| � � S W | j� � |�r.| � � n| j� � |�r,| � � 0 dS )z�polls if our child process has completed, without blocking. this method has side-effects, such as setting our exit_code, if we happen to see our child exit while this is runningNFg�h㈵��>)rW T) r� r6 �acquirer� r� �waitpidr� �WNOHANGr� �release�_process_just_endedr� )r2 Zacquired� witnessed_endr� r� r$ r$ r% r � sF � � � � zOProc.is_alivec C sV | j r| j �� | jd }|r:| j| jd v }||| j� | jrR| jsRt�| j� d S )Nr� r )rB �cancelr� r� r r= r� r )r2 r r� r$ r$ r% rc � s zOProc._process_just_endedc C s� | j �d� | j�j | j �d� d}| jdu r^| j �d� ttj| jd�\}}t|�| _d}n| j �d| j� W d � n1 s�0 Y | j |d � | jS ) z8waits for the process to complete, handles the exit codez*acquiring wait lock to wait for completionz got wait lockFNz!exit code not set, waiting on pidr Tz+exit code already set (%d), no need to wait)rd ) r� r� r6 r� r� r� r` r� r� �_process_exit_cleanup)r2 rd r� r� r$ r$ r% r � s �" z OProc.waitc C s^ | j �� | jr| j�� t�d| jj�}|�� | j�� |� � | j �� |rZ| � � d S )Ng @) rD r_ rG r� r rC rI r� rK re rF rc )r2 rd �timerr$ r$ r% rf � s zOProc._process_exit_cleanupN)rZ r[ r\ ry Z_default_window_sizer r r3 rQ rV rW rX rX r} r~ rZ r[ r� r� r� r� r� r rc r rf r$ r$ r$ r% r � s8 q 3r c C s� d}d}t � }|�|� |r�|r�|�d�}|D ]F\} } | ttB @ r.| �d|� |�� } | r.|�|� |r.|�� d}q.|� \}} q|r�|� d� |� \}} q�|s�|�� dS )z�this is run in a separate thread. it writes into our process's stdin (a streamwriter) and waits the process to end AND everything that can be written to be writtenFTr) z%r ready for more inputN) rh rL r( rT rU r� r& rQ r r ) r� r r � quit_threadrQ �closedr �poller�changedr> rF r� r� r$ r$ r% rH s* rH c C s | � |�}|S r )r )ZevrW Z triggeredr$ r$ r% � event_wait7 s rl c C sZ |r$|� � s$t|d�}|r| � q$q|rVtsVd}d}|rN|�d� |� \}}q4||� dS )zhandles the timeout logicr TNr) )�is_setrl � RUNNING_TESTSr )r � timeout_eventrP r rh r r r� r$ r$ r% rE < s rE c C s� t � }|dur|�|� |dur*|�|� |r�t|jd�} | D ]@\} } | ttB @ rv| �d| � | �� } | r~|�| � q>| t @ r>q>|r�|� � r�q�|� � r*q�q*|� \} }| r�|� d� |� \} }q�|r�|� � |r�|� � |� dS )z�this function is run in a separate thread. it reads from the process's stdout stream (a streamreader), and waits for it to claim that its doneNr z%r ready to be read fromr) ) rh rJ r� r( rS rU r� r rQ rV rm r r )r� r} r~ ro r rh Zstop_output_eventr rj rk r= rF r� r r� r$ r$ r% rJ Z s8 rJ c @ s e Zd ZdS )�DoneReadingForeverNr� r$ r$ r$ r% rp � s rp c @ s e Zd ZdS )�NotYetReadyToReadNr� r$ r$ r$ r% rq � s rq c C s� t | t�rd}t| �}n�t| �r.d}t| �}n�t| d�rFd}t| �}n�t | t�r^d}t| �}n�t | t �rvd}t| �}njt | t �r�d}t t | ��}nN| du r�d }d d � }|}n4z t | �}W n t y� td ��Y n0 d }t |�}||fS )a� given some kind of input object, return a function that knows how to read chunks of that input object. each reader function should return a chunk and raise a DoneReadingForever exception, or return None, when there's no more data to read NOTE: the function returned does not need to care much about the requested buffering type (eg, unbuffered vs newline-buffered). the StreamBufferer will take care of that. these functions just need to return a reasonably-sized chunk of data.�queuera r zfile descriptor�string�bytes� generatorN�Nonec S s t �d S r �rp r$ r$ r$ r% �raise_� s z+determine_how_to_read_input.<locals>.raise_zunknown input objectzgeneral iterable)r� r �get_queue_chunk_readerra �get_callable_chunk_readerr; �get_file_chunk_readerr� �get_iter_string_readerrt r �get_iter_chunk_readerr� r� rm )Z input_objr� � get_chunkrx �itr$ r$ r% �determine_how_to_read_input� s: r� c s � fdd�}|S )Nc s8 z� � dd�} W n ty& t�Y n0 | d u r4t�| S )NTr )rA r rq rp r3 �r r$ r% r# � s z"get_queue_chunk_reader.<locals>.fnr$ �r r# r$ r� r% ry � s ry c s � fdd�}|S )Nc s, z � � } W n t y � Y n0 | s(t �| S r rw )�datar� r$ r% r# � s z%get_callable_chunk_reader.<locals>.fnr$ r� r$ r� r% rz � s rz c s, d� � �fdd�t dt��� �D �}t|�S )a+ return an iterator that returns a chunk of a string every time it is called. notice that even though bufsize_type might be line buffered, we're not doing any line buffering here. that's because our StreamBufferer handles all buffering. we just need to return a reasonable-sized chunk.r c 3 s | ]}�||� � V qd S r r$ )rq �i��bufsizer r$ r% � <genexpr>� rt z)get_iter_string_reader.<locals>.<genexpr>r )�ranger r} )r Ziter_strr$ r� r% r| � s r| c s � fdd�}|S )Nc s* z� � � } | W S ty$ t�Y n0 d S r )r, r& rp r3 r� r$ r% r# � s z!get_iter_chunk_reader.<locals>.fnr$ r� r$ r� r% r} � s r} c s d� � �fdd�}|S )Nr c s� d} z �� � W n ty& d} Y n0 | rzt�d�rzt� }|��� |�d�}d}|D ]\}}|ttB @ rXd}qX|szt��� � �}|s�t �n|S d S )NTFr9 r ) r9 r r; rh rJ r( rS rU rq r rp )Z is_real_filerj rk �readyr> rF r+ r� r$ r% r# s& z!get_file_chunk_reader.<locals>.fnr$ r� r$ r� r% r{ s r{ c C s$ | dkrd}n| dkr d}n| }|S )a for a given bufsize type, return the actual bufsize we will read. notice that although 1 means "newline-buffered", we're reading a chunk size of 1024. this is because we have to read something. we let a StreamBufferer instance handle splitting our chunk on newlinesr) r r r$ )Zbf_typer� r$ r$ r% �bufsize_type_to_bufsize, s r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) r> z�StreamWriter reads from some input (the stdin param) and writes to a fd (the stream param). the stdin may be a Queue, a callable, something with the "read" method, a string, or an iterablec C sL || _ || _|| _|| _|| _t|| j�| _t|�\| _}| j� d|� d S )Nzparsed stdin as a %s) �streamr r� r$ ry �StreamBuffererrR r� r~ r� )r2 r� r� r � bufsize_typer$ ry r� r$ r$ r% r3 D s zStreamWriter.__init__c C s | j S �zGdefining this allows us to do poll on an instance of this class�r� r1 r$ r$ r% r9 P s zStreamWriter.filenoc C s: z| � � }|du rt�W n� ty� | j�d� | jr�zt�| j�d tj }W n t d�� � }Y n0 t � | j|� t � | j|� Y dS t y� | j�d� Y dS 0 t|t�s�|� | j�}| j�|�D ]d}| j�dt|�|dd � � | j�d � zt � | j|� W q� t�y2 | j�d � Y dS 0 q�dS ) z�attempt to get a chunk of data to write to our child process's stdin, then write it. the return value answers the questions "are we done writing forever?" Nz done reading� r* Tzreceived no dataF�got chunk size %d: %r� zwriting chunk to processzOSError writing stdin chunk)r~ rp r� r� ry r� r9 r� �VEOF�chrr� r� r& rq r� rt r$ rR r� r r� )r2 r+ �charZ proc_chunkr$ r$ r% r& U s6 zStreamWriter.writec C sl | j �d� | j�� }| j �dt|�|d d� � z|rFt�| j|� W n tyZ Y n0 t� | j� d S )Nzclosing, but flushing first� got chunk size %d to flush: %rr� ) r� r� rR �flushr r� r& r� r� r �r2 r+ r$ r$ r% r � s zStreamWriter.closeN)rZ r[ r\ ry r3 r9 r& r r$ r$ r$ r% r> ? s =r> c C s� t | �rt| ||�\}}n�t| t�r2t| �\}}nxt| t�rNt| ||�\}}n\t| d�rht| |�\}}nBz t | �} W n& t t fy� dd� }dd� }Y n0 t | |�\}}||fS )Nr& c S s dS rp r$ r3 r$ r$ r% r� � s z-determine_how_to_feed_output.<locals>.processc S s d S r r$ r$ r$ r$ r% �finish� s z,determine_how_to_feed_output.<locals>.finish) ra �get_callback_chunk_consumerr� r � get_cstringio_chunk_consumerr �get_stringio_chunk_consumerr; �get_file_chunk_consumerr� r� r� �get_fd_chunk_consumer�r� r$ r% r� r� r$ r$ r% � determine_how_to_feed_output� s r� c C s t | ddd�} t| |�S )N�wF)�closefd)�fdopenr� )r� r% r$ r$ r% r� � s r� c sb t �dd �r � �fdd��ndd� �t�d�r6�j�ndd� ����fdd �}�fd d �}||fS ) Nr$ c s | � �j� �S r )r� r$ r3 )r% r� r$ r% r� � s z'get_file_chunk_consumer.<locals>.encodec S s | S r r$ r3 r$ r$ r% r� � s r� c S s d S r r$ r$ r$ r$ r% r� � s z&get_file_chunk_consumer.<locals>.flushc s �� � | �� �� dS rp �r& r3 )r� r� r� r$ r% r� � s z(get_file_chunk_consumer.<locals>.processc s � � d S r r$ r$ )r� r$ r% r� � s z'get_file_chunk_consumer.<locals>.finish)r� r; r� )r� r% r� r� r$ )r% r� r� r� r% r� � s r� c s � ��fdd�}dd� }||fS )Nc s, z| � �� �} W n ty" Y n0 �| �S r )r� r* r3 �r% r$ r� r$ r% r� � s z,get_callback_chunk_consumer.<locals>.processc S s d S r r$ r$ r$ r$ r% r� � s z+get_callback_chunk_consumer.<locals>.finishr$ r� r$ r� r% r� � s r� c s � fdd�}dd� }||fS )Nc s � � | � dS rp r� r3 �r� r$ r% r� � s z-get_cstringio_chunk_consumer.<locals>.processc S s d S r r$ r$ r$ r$ r% r� � s z,get_cstringio_chunk_consumer.<locals>.finishr$ )r� r� r� r$ r� r% r� � s r� c s � ��fdd�}dd� }||fS )Nc s �� | ��� �� dS rp )r& r� r3 r� r$ r% r� s z,get_stringio_chunk_consumer.<locals>.processc S s d S r r$ r$ r$ r$ r% r� s z+get_stringio_chunk_consumer.<locals>.finishr$ r� r$ r� r% r� � s r� c @ s: e Zd ZdZddd�Zdd� Zdd � Zd d � Zd d � ZdS )r@ zSreads from some output (the stream) and sends what it just read to the handler.NTc C st || _ || _| | _|| _|| _d | _|r4t�|�| _|| _t || j| j�| _ t |�| _ t |||�\| _| _d| _d S rp )r� �bufferr r$ r% � pipe_queuer� r� r� r� rR r� r� r� � process_chunk�finish_chunk_processor� should_quit) r2 r� r� r� r� r� r$ r% r� r r$ r$ r% r3 s" � � zStreamReader.__init__c C s | j S r� r� r1 r$ r$ r% r9 1 s zStreamReader.filenoc C sf | j �� }| j�dt|�|d d� � |r4| �|� | �� | jrV| jrV| �� � d � t � | j � d S )Nr� r� ) rR r� r� r� r � write_chunkr� r� r r2 r� r r� r� r$ r$ r% r 6 s zStreamReader.closec C sR | j s| �|�| _ | jrN| j�|� | jrN| j�d|d d� � | �� �|� d S )Nzputting chunk onto pipe: %rr� ) r� r� r r� rR r� r� r� r2 r� r$ r$ r% r� C s zStreamReader.write_chunkc C s� zt tj| j| j�}W n6 tyL } z | j�d|j� W Y d }~dS d }~0 0 |sb| j�d� dS | j�dt |�|d d� � | j � |�D ]}| � |� q�d S )Nzgot errno %d, done readingTzgot no chunk, done readingr� r� ) r� r� r r� r� r� r� r� r( r rR r� r� )r2 r+ r� r$ r$ r% r P s zStreamReader.read)NT) rZ r[ r\ ry r3 r9 r r� r r$ r$ r$ r% r@ s � # r@ c @ s6 e Zd ZdZedfdd�Zdd� Zdd� Zd d � Zd S ) r� a� this is used for feeding in chunks of stdout/stderr, and breaking it up into chunks that will actually be put into the internal buffers. for example, if you have two processes, one being piped to the other, and you want that, first process to feed lines of data (instead of the chunks however they come in), OProc will use an instance of this class to chop up the data and feed it as lines to be sent down the piper� c C s< || _ g | _d| _|| _|| _d| _t�� | _t d�| _ d S )Nr FrR ) r� r� �n_buffer_countr$ r% �_use_up_buffer_firstr �RLock�_buffering_lockr� r� )r2 Z buffer_typer$ r% r$ r$ r% r3 i s zStreamBufferer.__init__c C sn | j �d� | j�� | j �d� z.|dkr2d| _|| _W | j�� | j �d� n| j�� | j �d� 0 d S )Nz/acquiring buffering lock for changing bufferingz)got buffering lock for changing bufferingr Tz.released buffering lock for changing buffering)r� r� r� r_ r� r� rb )r2 �new_typer$ r$ r% rS ~ s � z StreamBufferer.change_bufferingc C sT | j �d| j� | j�� | j �d| j� �z| jdkr�| jrzd| _| j}g | _|�|� |W | j�� | j �d| j� S |gW | j�� | j �d| j� S | jdk�rbg }d� | j �}|� |�}|dkrΐq |d |d � }| j�rd � | j�| }g | _d| _ ||d d � }|�|� q�|�rB| j�|� | j t|�7 _ |W | j�� | j �d| j� S g }| j t|� | j }|dk�r�d � | j �� | j�| }|d | j� }|| jd � }|�|� g | _d| _ n"| j�|� | j t|�7 _ �q��qf|W | j�� | j �d| j� S W | j�� | j �d| j� n | j�� | j �d| j� 0 d S ) Nz9acquiring buffering lock to process chunk (buffering: %d)z3got buffering lock to process chunk (buffering: %d)r Fz<released buffering lock for processing chunk (buffering: %d)r) rj r� rt r' )r� r� r� r� r_ r� r� rR rb r� r$ �findr� r� r ) r2 r+ Zto_writeZtotal_to_write�nl�newlineZchunk_to_writeZoveragerg r$ r$ r% r� � s� � . ��, �� �� �� �� �zStreamBufferer.processc C sv | j �d� | j�� | j �d� z6d�| j��| j�}g | _|W | j�� | j �d� S | j�� | j �d� 0 d S )Nz,acquiring buffering lock for flushing bufferz&got buffering lock for flushing bufferr' z+released buffering lock for flushing buffer) r� r� r� r_ r� r$ r� r� rb )r2 rg r$ r$ r% r� � s � � zStreamBufferer.flushN) rZ r[ r\ ry r� r3 rS r� r� r$ r$ r$ r% r� a s Fr� c s � fdd�}|S )Nc s t � �� t � �fdd��}|S )Nc ? s\ ��D � | i |��� d V W d � n1 s00 Y W d � n1 sN0 Y d S r r$ )r! r� )r# �lockr$ r% �wrapped2� s z,with_lock.<locals>.wrapped.<locals>.wrapped2r )r# r� �r� r" r% �wrapped� s zwith_lock.<locals>.wrappedr$ )r� r� r$ r� r% � with_lock� s r� c c s8 t �� }t �| � zdV W t �|� n t �|� 0 dS )z�pushd changes the actual working directory for the duration of the context, unlike the _cwd arg this will work with other built-ins such as sh.glob correctlyN)r� r� r( )r� � orig_pathr$ r$ r% r� � s r� c K s2 d� dd� | �� D ��}td|� d|� d���dS )zZallows us to temporarily override all the special keyword parameters in a with contextr� c S s g | ]\}}|� d |���qS )r� r$ r� r$ r$ r% r� rt z_args.<locals>.<listcomp>zl sh.args() has been deprecated because it was never thread safe. use the following instead: sh2 = sh(z+) sh2.your_command() or sh2 = sh(z7) from sh2 import your_command your_command() N)r� r� �DeprecationWarning)r� Z kwargs_strr$ r$ r% �_args� s � ��r� c s@ e Zd ZdZh d�Zd � fdd� Zdd� Zed dd ��Z� Z S ) � Environmenta� this allows lookups to names that aren't found in the global scope to be searched for as a program name. for example, if "ls" isn't found in this module's scope, we consider it a system program and try to find it. we use a dict instead of just a regular object as the base class because the exec() statement used in the run_repl requires the "globals" argument to be a dictionary> r� � __version__r� �contribr� rq r� �__file__rp r� r� �__project_url__r\ r� r� r� rz r� ri Nc s" t t| ��� || _|pi | _dS )z�baked_args are defaults for the 'sh' execution context. for example: tmp = sh(_out=StringIO()) 'out' would end up in here as an entry in the baked_args dictN)r� r� r3 �globsr� )r2 r� r� r� r$ r% r3 8 s zEnvironment.__init__c C s� |dkr d}|| j v r | j| S |dkr6t�d� g S t|�}|rF|S |�d�r^|�d�r^t�t|| jt j | j �}|r||S t | d| d �}|r�|S z t j| W S ty� Y n0 t|��d S )Nr! r� �__all__zJCannot import * from sh. Please import sh or import programs individually.�__Zb_)r� r� �warnings�warnr� r� r� rK r� r\ rZ r� r� r� r� r� r� )r2 r� r� r� �builtinr$ r$ r% � __getitem__C s2 � zEnvironment.__getitem__c C s t | |�S r )r� )r� r� r$ r$ r% �b_whichx s zEnvironment.b_which)N)N) rZ r[ r\ ry r� r3 r� rg r� r� r$ r$ r� r% r� s 5r� c @ s e Zd Zedd� �ZdS )�Contribc s � �fdd�}|S )Nc s" t � �fdd��}t��|� � S )Nc s" t �t�}|st���� |�}|S r )r� r\ r� )r2 r� Znew_cmd)r# r� r$ r% � cmd_getter� s z6Contrib.__call__.<locals>.wrapper1.<locals>.cmd_getter)rX �setattr)r# r� �r� r� r" r% �wrapper1� s z"Contrib.__call__.<locals>.wrapper1r$ )r� r� r� r$ r� r% r� ~ s zContrib.__call__N)rZ r[ r\ r� r� r$ r$ r$ r% r� } s r� z.contrib�gitc C s | j dd�}|S )z*most git commands play nicer without a TTYF)Z_tty_out�r� ��origr� r$ r$ r% r� � s �bashc C s | � d�}|S )Nz-cr� r� r$ r$ r% r� � s �sudoc s: dt �� � d�� � fdd���fdd�}| jd|d�}|S ) zya nicer version of sudo that uses getpass to ask for a password, or allows the first argument to be a string passwordz[sudo] password for r� c 3 s t j � d�d } | V d S )N��promptrj ��getpass)�pwr� r$ r% r � s zsudo.<locals>.stdinc s: |� dd �}|d u r � � }n|�d�d }||d< | |fS )N�passwordrj re )r< �rstrip)r� r� r� � pass_getterr� r$ r% r� � s zsudo.<locals>.processz-S)�_arg_preprocess)r� �getuserr� �r� r� r� r$ )r� r r% r� � s �sshc sB G dd� d��G �fdd�d�� � fdd�}| j ddd|d �}|S ) z+An ssh command for automatic password loginc @ s( e Zd Zdd� Zdd� Zedd� �ZdS )zssh.<locals>.SessionContentc S s. t dd�| _t dd�| _g | _d| _d| _d S )NiP� r i� r' )r �chars�lines� line_chars� last_line�cur_charr1 r$ r$ r% r3 � s z$ssh.<locals>.SessionContent.__init__c S sJ |dkr(| j }|| _| j�|� g | _n | j�|� | j�|� || _d S �Nrj )�cur_liner� r� rR r� r� r� )r2 r� �liner$ r$ r% � append_char� s z'ssh.<locals>.SessionContent.append_charc S s d� | j�}|S rO )r� r� )r2 r� r$ r$ r% r� � s z$ssh.<locals>.SessionContent.cur_lineN)rZ r[ r\ r3 r� rX r� r$ r$ r$ r% �SessionContent� s r� c s e Zd Z� fdd�Zdd� ZdS )zssh.<locals>.SSHInteractc s0 || _ || _|| _|| _� � | _d| _d| _d S rp )� prompt_matchr� � out_handler� login_success�content� pw_enteredr� )r2 r� r� r� r� �r� r$ r% r3 � s z!ssh.<locals>.SSHInteract.__init__c S sf | j �|� | jr&| js&| �| j �| _| jr:| �| j |�S | �| j �rb| �� }|�|d � d| _d S )Nrj T) r� r� r� r� r� r� r� r� r2 )r2 r� r r� r$ r$ r% r� � s z!ssh.<locals>.SSHInteract.__call__N)rZ r[ r\ r3 r� r$ r� r$ r% � SSHInteract� s r� c s� |� d�}|� dd �� |� dd �}|� dd �}d�|d u rBdd� }� d u rX�fdd �}n � fd d �}|d u rtd d � }�||||�|d < | |fS )NZinteractr� r� r� zPlease enter SSH password: c S s | j �d�S )Nz password: )r� r� �r� r$ r$ r% r� � s z*ssh.<locals>.process.<locals>.prompt_matchc s t j � d�S )Nr� r� r$ r� r$ r% r� s z)ssh.<locals>.process.<locals>.pass_getterc s � � d�S r� )r� r$ )r� r$ r% r� s c S s dS )NTr$ r� r$ r$ r% r� s z+ssh.<locals>.process.<locals>.login_successrf )r< )r� r� Zreal_out_handlerr� r� r� )r� )r� r� r% r� � s �zssh.<locals>.processr T)Z _out_bufsizeZ_tty_inZ _unify_ttysr� r� r� r$ )r� r� r% r� � s �c C s� t dt� d�� z td�}W n ttfy6 Y q�Y n0 ztt|dd�| | � W q tyf Y q�Y q t t� � � Y q0 qt d� d S )Nz >> sh vz" >> https://github.com/amoffat/sh zsh> z<dummy>�singler' ) �printr� �inputr� �EOFError�exec�compile� SystemExitr0 r1 )r� r� r$ r$ r% �run_repl s r� c s. e Zd Zd� fdd� Zdd� Zdd� Z� ZS ) � SelfWrapperNc s� t � jt|dd �t|dd �d� dD ]}t| |t||d �� q$g | _|| _t}|j�� }|� dd � |r�|� |�\}}|d �� |d< |d � |� t � �� }t |j|j|�||j< t||d�| _d S )NrZ ry )r� �doc)� __builtins__r� � __package__�__dict__r� )r� )r� r3 r� r� �__path__�_SelfWrapper__self_moduler\ r� r� r< r� r� �globalsr� rZ ru r� �_SelfWrapper__env) r2 � self_moduler� rO r� Z cls_attrsr� r� r� r� r$ r% r3 4 s( � � zSelfWrapper.__init__c C s | j | S r )r )r2 r� r$ r$ r% rN T s zSelfWrapper.__getattr__c K s( | j j�� }|�|� | �| j|�}|S r )r r� r� r� r{ r )r2 r� r� Znew_shr$ r$ r% r� W s zSelfWrapper.bake)N)rZ r[ r\ r3 rN r� r� r$ r$ r� r% r� 3 s r� �__main__)N)N)N)F)N)�ry r �platform� collectionsr �collections.abcr � importlibr �versionr� ZPackageNotFoundError�system�lower� ImportErrorr( r� r r� r� Z glob_moduler r� r� r r r� r- r� rr r� r2 r� rk r r r0 r' r� r� r r5 � contextlibr � functoolsr �ior r r r r� �localer rr r �shlexr r� �typesr r �typingr r r r r� r r r� r rZ r� r r� r� rA rn ZFORCE_USE_SELECTr� Z PUSHD_LOCKr& r_ �dirrL r; ZHAS_POLLrS rT rU rV r, r] rh r� rm ri r� rp rz r� r� �SIGABRT�SIGBUS�SIGFPE�SIGILL�SIGINTr� r� �SIGQUIT�SIGSEGVr^ �SIGSYSr� rK r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rZ r ri rk rl ro ru rx r r� r� r� r\ r� r� r� r� r� r r� r� r rH rl rE rJ rp rq r� ry rz r| r} r{ r� r> r� r� r� r� r� r� r@ r� r� r� r� r� r� r� �mod_namer� �modulesr� r� r� r� r� r� r r� r$ r$ r$ r% �<module> sn � L5 : � � ' + 4 d, M C &! =9 #a W~ h \+
SAVE CHANGES
[ CANCEL ]
Name
Type
Actions
.. (Parent Directory)
📄 sh.cpython-39.pyc
FILE
Ren
[EDIT]
DEL