
    g                        d Z ddlZddlZddlZddlmZ ddlmZ ddlm	Z	 ddl
mZmZmZmZmZmZ ddlmZ  ee          Zed	eeddf         fd
            Z	 	 ddeeee         f         deeee	f                  d	ej        fdZe	 ddeeee         f         deeee	f                  d	eeee         ee         f         ddf         fd            ZdS )zFContains utilities to easily handle subprocesses in `huggingface_hub`.    N)contextmanager)StringIO)Path)IO	GeneratorListOptionalTupleUnion   )
get_loggerreturnc               #   v   K   t                      } t          j        }| t          _        | V  |t          _        dS )a  Capture output that is printed to terminal.

    Taken from https://stackoverflow.com/a/34738440

    Example:
    ```py
    >>> with capture_output() as output:
    ...     print("hello world")
    >>> assert output.getvalue() == "hello world
"
    ```
    N)r   sysstdout)outputprevious_outputs     ]/var/www/html/ai-engine/env/lib/python3.11/site-packages/huggingface_hub/utils/_subprocess.pycapture_outputr      s3       ZZFjOCJ
LLL CJJJ    Tcommandfolderc           
         t          | t                    r|                                 } t          |t                    rt          |          }t	          j        | ft          j        t          j        |dd|pt          j                    d|S )aX  
    Method to run subprocesses. Calling this will capture the `stderr` and `stdout`,
    please call `subprocess.run` manually in case you would like for them not to
    be captured.

    Args:
        command (`str` or `List[str]`):
            The command to execute as a string or list of strings.
        folder (`str`, *optional*):
            The folder in which to run the command. Defaults to current working
            directory (from `os.getcwd()`).
        check (`bool`, *optional*, defaults to `True`):
            Setting `check` to `True` will raise a `subprocess.CalledProcessError`
            when the subprocess has a non-zero exit code.
        kwargs (`Dict[str]`):
            Keyword arguments to be passed to the `subprocess.run` underlying command.

    Returns:
        `subprocess.CompletedProcess`: The completed process.
    utf-8replace)stderrr   checkencodingerrorscwd)	
isinstancestrsplitr   
subprocessrunPIPEosgetcwd)r   r   r   kwargss       r   run_subprocessr*   3   s    4 '3 "--//&$ V>	!bikk	 	 	 	 	r   c           
   +     K   t          | t                    r|                                 } t          j        | ft          j        t          j        t          j        dd|pt          j                    d|5 }|j	        
J d            |j
        
J d            |j	        |j
        fV  ddd           dS # 1 swxY w Y   dS )a  Run a subprocess in an interactive mode in a context manager.

    Args:
        command (`str` or `List[str]`):
            The command to execute as a string or list of strings.
        folder (`str`, *optional*):
            The folder in which to run the command. Defaults to current working
            directory (from `os.getcwd()`).
        kwargs (`Dict[str]`):
            Keyword arguments to be passed to the `subprocess.run` underlying command.

    Returns:
        `Tuple[IO[str], IO[str]]`: A tuple with `stdin` and `stdout` to interact
        with the process (input and output are utf-8 encoded).

    Example:
    ```python
    with _interactive_subprocess("git credential-store get") as (stdin, stdout):
        # Write to stdin
        stdin.write("url=hf.co
username=obama
".encode("utf-8"))
        stdin.flush()

        # Read from stdout
        output = stdout.read().decode("utf-8")
    ```
    r   r   )stdinr   r   r   r   r    Nz'subprocess is opened as subprocess.PIPE)r!   r"   r#   r$   Popenr&   STDOUTr'   r(   r,   r   )r   r   r)   processs       r   run_interactive_subprocessr0   _   s     @ '3 "--//			
o !bikk	
 	
 	
 	
 , 
}((*S(((~))+T)))mW^++++, , , , , , , , , , , , , , , , , ,s   63B66B:=B:)NT)N)__doc__r'   r$   r   
contextlibr   ior   pathlibr   typingr   r   r   r	   r
   r   loggingr   __name__loggerr   r"   CompletedProcessr*   r0    r   r   <module>r;      s   M L 				     



 % % % % % %             > > > > > > > > > > > > > > > >       
H		 !	(D$"67 ! ! ! !* *.
) )3S	>")U39%&)
  ) ) ) )X  *.., .,3S	>".,U39%&., uRWbg%&d23	., ., ., ., ., .,r   