
    Bhݏ              	         d Z ddlm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	Z	ddl
Z
ddl
m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 ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ erddlmZ ddl m!Z! ddl m"Z" ddl#m$Z$ ddl%m&Z& ddl'm(Z( ddl'm)Z) ddl*m+Z+ ddl*m,Z, ddl*m-Z- ddl.m/Z/ ed    Z0dVd!Z1dWd"Z2dWd#Z3dXd$Z4 e"d%&      dYd'       Z5 G d( d)e
jl                        Z7 G d* d+e
jl                        Z8 G d, d-e8      Z9 G d. d/e      Z: G d0 d1ejv                  ee         Z<d2d3d4d5Z= G d6 d7e<e>         Z? G d8 d9e<e         Z@ G d: d;e@eA         ZB G d< d=e@e>         ZC G d> d?e<e         ZD G d@ dAeDeA         ZE G dB dCeDe>         ZFej                  dDk\  sere G dE dFeee                ZHn" G dG dF ej                  dFdHdIg      ee         ZH G dJ dKee         ZJdZdLZK G dM dN      ZL G dO dPee         ZMe(d[dQ       ZNe(d[dR       ZOe(d\dS       ZPe(d[dT       ZQe(d\dU       ZRy)]z+Per-test stdout/stderr capturing mechanism.    )annotationsN)	Generator)Iterable)IteratorUnsupportedOperation)TemporaryFile)TracebackType)Any)AnyStr)BinaryIO)cast)Final)final)Generic)Literal)
NamedTuple)TextIO)TYPE_CHECKING)Self)Config)hookimpl)Parser)check_ispytest)fixture)
SubRequest)	Collector)File)Item)CollectReportfdsysnotee-sysc                    | j                  d      }|j                  ddddg dd       |j                  d	d
ddd       y )Ngeneralz	--capturestorer"   methodr!   z3Per-test capturing method: one of fd|sys|no|tee-sys)actiondefaultmetavarchoiceshelpz-sstore_constr$   capturezShortcut for --capture=no)r*   constdestr.   )getgroup	addoption
_addoption)parsergroups     Z/var/www/html/Telegram-Engagement-Pod-/env/lib/python3.12/site-packages/_pytest/capture.pypytest_addoptionr9   1   sW    OOI&E	OO.B   
(      c                 l    t         j                  j                  d      r	 ddl} yy# t        $ r Y yw xY w)a  Ensure colorama is imported so that it attaches to the correct stdio
    handles on Windows.

    colorama uses the terminal on import time. So if something does the
    first import of colorama while I/O capture is active, colorama will
    fail in various ways.
    win32r   N)r#   platform
startswithcoloramaImportError)r?   s    r8   _colorama_workaroundrA   D   s7     ||w'	 (  		s   ' 	33c                 ,    	 ddl } y# t        $ r Y yw xY w)a  Ensure readline is imported early so it attaches to the correct stdio handles.

    This isn't a problem with the default GNU readline implementation, but in
    some configurations, Python uses libedit instead (on macOS, and for prebuilt
    binaries such as used by uv).

    In theory this is only needed if readline.backend == "libedit", but the
    workaround consists of importing readline here, so we already worked around
    the issue by the time we could check if we need to.
    r   N)readliner@   rC   s    r8   _readline_workaroundrE   S   s     s    	c                    t         j                  j                  d      rt        t         d      ryt         d      syt         j                  d      r j                  j
                  n j                  }t        |t        j                        sy fd} |t         j                  d      t         _	         |t         j                  d      t         _
         |t         j                  d      t         _        y)	a  Workaround for Windows Unicode console handling.

    Python 3.6 implemented Unicode console handling for Windows. This works
    by reading/writing to the raw console handle using
    ``{Read,Write}ConsoleW``.

    The problem is that we are going to ``dup2`` over the stdio file
    descriptors when doing ``FDCapture`` and this will ``CloseHandle`` the
    handles used by Python to write to the console. Though there is still some
    weirdness and the console handle seems to only be closed randomly and not
    on the first call to ``CloseHandle``, or maybe it gets reopened with the
    same handle value when we suspend capturing.

    The workaround in this case will reopen stdio with a different fd which
    also means a different handle by replicating the logic in
    "Py_lifecycle.c:initstdio/create_stdio".

    :param stream:
        In practice ``sys.stdout`` or ``sys.stderr``, but given
        here as parameter for unittesting purposes.

    See https://github.com/pytest-dev/py/issues/103.
    r<   pypy_version_infoNbufferrawc                $   t        j                  d      s|d   dk(  rd}nd}t        j                  t	        t        j                  | j                               ||      | j                  | j                  | j                  | j                        S )NrI   r   w)hasattrrH   ioTextIOWrapperopenosdupfilenoencodingerrorsnewlinesline_buffering)fmode	bufferingstreams      r8   _reopen_stdioz3_windowsconsoleio_workaround.<locals>._reopen_stdio   sq    v}}e,aCII
#T95JJHHJJ
 	
r:   rbwb)r#   r=   r>   rM   rH   rI   
isinstancerN   _WindowsConsoleIOstdinstdoutstderr)r[   
raw_stdoutr\   s   `  r8   _windowsconsoleio_workaroundre   d   s    0 <<""7+ws<O/P 68$&-fmmU&C""Jj""6"67
 cii.CIszz40CJszz40CJr:   Twrapperc              #  l  K   | j                   }|j                  dk(  rt        t        j                         t                t                | j                  }t        |j                        }|j                  |d       | j                  |j                         |j                          	 	 d  |j                          y # |j                          w xY w# t        $ rS |j                         \  }}t        j                  j!                  |       t        j"                  j!                  |        w xY ww)Nr"   capturemanager)known_args_namespacer0   re   r#   rb   rA   rE   pluginmanagerCaptureManagerregisteradd_cleanupstop_global_capturingstart_global_capturingsuspend_global_captureBaseExceptionread_global_capturewriterc   )early_confignsrk   capmanouterrs         r8   pytest_load_initial_conftestsrz      s     		*	*B	zzT$SZZ0 ..MBJJ'F6#34 V99: !!#		,))+F))+ --/S



	s1   B'D4+C  /C ?D4 CC AD11D4c                  4    e Zd ZdZedd       Zedd       Zy)EncodedFile c                ,    t        | j                        S N)reprrH   selfs    r8   namezEncodedFile.name   s     DKK  r:   c                    t        | j                  d      sJ t        t        | j                  j                  j                  dd            S )NrY   b )rM   rH   r   strrY   replacer   s    r8   rY   zEncodedFile.mode   s<     t{{F+++C))11#r:;;r:   Nreturnr   )__name__
__module____qualname__	__slots__propertyr   rY   r}   r:   r8   r|   r|      s-    I! !
 < <r:   r|   c                  (     e Zd Zd fdZddZ xZS )	CaptureIOc                P    t         |   t        j                         ddd       y )NUTF-8r   T)rT   newlinewrite_through)super__init__rN   BytesIO)r   	__class__s    r8   r   zCaptureIO.__init__   s     SWXr:   c                    t        | j                  t        j                        sJ | j                  j	                         j                  d      S )Nr   )r_   rH   rN   r   getvaluedecoder   s    r8   r   zCaptureIO.getvalue   s8    $++rzz222{{##%,,W55r:   r   Noner   )r   r   r   r   r   __classcell__r   s   @r8   r   r      s    Y6r:   r   c                  ,     e Zd Zd fdZd fdZ xZS )TeeCaptureIOc                0    || _         t        | 	          y r   )_otherr   r   )r   otherr   s     r8   r   zTeeCaptureIO.__init__   s    r:   c                X    t         |   |       | j                  j                  |      S r   )r   rt   r   )r   sr   s     r8   rt   zTeeCaptureIO.write   s$    a{{  ##r:   )r   r   r   r   )r   r   r   int)r   r   r   r   rt   r   r   s   @r8   r   r      s    $ $r:   r   c                      e Zd Zedd       ZdddZeZddZdddZddZ	ddZ
ddZddZdd	Zdd
ZdddZddZddZd d!dZd"dZd#dZddZd$dZ	 	 	 	 	 	 	 	 d%dZed&d       Zy)'DontReadFromInputc                Z    t         j                  J t         j                  j                  S r   )r#   	__stdin__rT   r   s    r8   rT   zDontReadFromInput.encoding   s"    }}(((}}%%%r:   c                    t        d      NzJpytest: reading from stdin while output is captured!  Consider using `-s`.OSErrorr   sizes     r8   readzDontReadFromInput.read       X
 	
r:   c                "    | j                         S r   rD   r   s    r8   __next__zDontReadFromInput.__next__   s    }}r:   c                    t        d      r   r   )r   hints     r8   	readlineszDontReadFromInput.readlines   r   r:   c                    | S r   r}   r   s    r8   __iter__zDontReadFromInput.__iter__       r:   c                    t        d      )Nz/redirected stdin is pseudofile, has no fileno()r   r   s    r8   rS   zDontReadFromInput.fileno   s    "#TUUr:   c                    t        d      )Nz.redirected stdin is pseudofile, has no flush()r   r   s    r8   flushzDontReadFromInput.flush   s    "#STTr:   c                     yNFr}   r   s    r8   isattyzDontReadFromInput.isatty       r:   c                     y r   r}   r   s    r8   closezDontReadFromInput.close       r:   c                     yr   r}   r   s    r8   readablezDontReadFromInput.readable  r   r:   c                    t        d      )Nz0redirected stdin is pseudofile, has no seek(int)r   )r   offsetwhences      r8   seekzDontReadFromInput.seek  s    "#UVVr:   c                     yr   r}   r   s    r8   seekablezDontReadFromInput.seekable  r   r:   c                    t        d      )Nz-redirected stdin is pseudofile, has no tell()r   r   s    r8   tellzDontReadFromInput.tell  s    "#RSSr:   Nc                    t        d      )Nzcannot truncate stdinr   r   s     r8   truncatezDontReadFromInput.truncate      "#:;;r:   c                    t        d      )Nzcannot write to stdinr   r   datas     r8   rt   zDontReadFromInput.write  r   r:   c                    t        d      )NzCannot write to stdinr   )r   liness     r8   
writelineszDontReadFromInput.writelines  r   r:   c                     yr   r}   r   s    r8   writablezDontReadFromInput.writable  r   r:   c                    | S r   r}   r   s    r8   	__enter__zDontReadFromInput.__enter__  r   r:   c                     y r   r}   )r   typevalue	tracebacks       r8   __exit__zDontReadFromInput.__exit__  s     	r:   c                    | S r   r}   r   s    r8   rH   zDontReadFromInput.buffer%  s	     r:   r   )rL   )r   r   r   r   )r   
int | Noner   z	list[str])r   zIterator[str])r   r   r   r   bool)r   )r   r   r   r   r   r   r   )r   r   r   r   )r   r   r   r   )r   zIterable[str]r   r   )r   r   )r   ztype[BaseException] | Noner   zBaseException | Noner   zTracebackType | Noner   r   )r   r   )r   r   r   r   rT   r   rC   r   r   r   rS   r   r   r   r   r   r   r   r   rt   r   r   r   r   rH   r}   r:   r8   r   r      s    & &

 H

VUWT<<<( $ (	
 
  r:   r   c                  "   e Zd ZU ded<   ej
                  dd       Zej
                  dd       Zej
                  dd       Zej
                  dd       Z	ej
                  dd       Z
ej
                  dd       Zej
                  dd	       Zy
)CaptureBaser   EMPTY_BUFFERc                    t               r   NotImplementedErrorr   r"   s     r8   r   zCaptureBase.__init__1      !##r:   c                    t               r   r   r   s    r8   startzCaptureBase.start5  r   r:   c                    t               r   r   r   s    r8   donezCaptureBase.done9  r   r:   c                    t               r   r   r   s    r8   suspendzCaptureBase.suspend=  r   r:   c                    t               r   r   r   s    r8   resumezCaptureBase.resumeA  r   r:   c                    t               r   r   r   s     r8   writeorgzCaptureBase.writeorgE  r   r:   c                    t               r   r   r   s    r8   snapzCaptureBase.snapI  r   r:   Nr"   r   r   r   r   )r   r   r   r   )r   r   )r   r   r   __annotations__abcabstractmethodr   r   r   r   r   r   r   r}   r:   r8   r   r   .  s    $ $ 	$ $ 	$ $ 	$ $ 	$ $ 	$ $ 	$ $r:   r   ra   rb   rc   )r         c                  H    e Zd ZdZd
dZddZddZddZddZddZ	ddZ
y	)	NoCapturer   c                     y r   r}   r   s     r8   r   zNoCapture.__init__T  r   r:   c                     y r   r}   r   s    r8   r   zNoCapture.startW  r   r:   c                     y r   r}   r   s    r8   r   zNoCapture.doneZ  r   r:   c                     y r   r}   r   s    r8   r   zNoCapture.suspend]  r   r:   c                     y r   r}   r   s    r8   r   zNoCapture.resume`  r   r:   c                     yNr   r}   r   s    r8   r   zNoCapture.snapc  s    r:   c                     y r   r}   r   s     r8   r   zNoCapture.writeorgf  r   r:   Nr   r   r   r   r   r   r   )r   r   r   r   r   r   r   r   r   r   r   r}   r:   r8   r  r  Q  s*    Lr:   r  c                  d    e Zd Z	 ddd	 	 	 	 	 	 	 ddZddZddZddZddZdd	Zdd
Z	ddZ
y)SysCaptureBaseNFteec                   t         |   }t        t        |      | _        || _        |1|dk(  rt               }n!|s
t               nt        | j                        }|| _        d| _	        y )Nra   initialized)
patchsysdictgetattrr#   _oldr   r   r   r   tmpfile_state)r   r"   r  r  r   s        r8   r   zSysCaptureBase.__init__k  sY     B#C.		?w+--0)+l4996M#r:   c                    dj                  || j                  t        | d      xr t        | j                        xs d| j
                  | j                        S Nz(<{} {} _old={} _state={!r} tmpfile={!r}>r  z<UNSET>)formatr   rM   r   r  r  r  )r   
class_names     r8   r   zSysCaptureBase.repry  sI    9@@IIT6"6tDIID9KKLL
 	
r:   c                    dj                  | j                  j                  | j                  t	        | d      xr t        | j                        xs d| j                  | j                        S r  )	r  r   r   r   rM   r   r  r  r  r   s    r8   __repr__zSysCaptureBase.__repr__  sS    9@@NN##IIT6"6tDIID9KKLL
 	
r:   c                    | j                   |v s1J dj                  || j                   dj                  |                   y Nz+cannot {} in state {!r}: expected one of {}z, r  r  joinr   opstatess      r8   _assert_statezSysCaptureBase._assert_state  =    {{f$ 	
9@@DKK6!2	
$r:   c                    | j                  dd       t        t        | j                  | j                         d| _        y )Nr   r  started)r$  setattrr#   r   r  r  r   s    r8   r   zSysCaptureBase.start  s.    7$45TYY-r:   c                    | j                  dd       | j                  dk(  ry t        t        | j                  | j
                         | `| j                  j                          d| _        y )Nr   r  r(  	suspendedr   )r$  r  r)  r#   r   r  r  r   r   s    r8   r   zSysCaptureBase.done  sR    6#RS;;& TYY		*Ir:   c                    | j                  dd       t        t        | j                  | j                         d| _        y Nr   r(  r,  r,  )r$  r)  r#   r   r  r  r   s    r8   r   zSysCaptureBase.suspend  s.    9&>?TYY		*!r:   c                    | j                  dd       | j                  dk(  ry t        t        | j                  | j
                         d| _        y Nr   r/  r(  )r$  r  r)  r#   r   r  r   s    r8   r   zSysCaptureBase.resume  s=    8%=>;;)#TYY-r:   r   )r"   r   r  zTextIO | Noner  r   r   r   )r  r   r   r   r   r"  r   r#  ztuple[str, ...]r   r   r   )r   r   r   r   r   r  r$  r   r   r   r   r}   r:   r8   r  r  j  sU    04$EJ$$ -$>B$	$


 
"
 r:   r  c                       e Zd ZdZddZddZy)SysCaptureBinaryr:   c                   | j                  dd       | j                  j                  d       | j                  j                  j	                         }| j                  j                  d       | j                  j                          |S Nr   r/  r   r$  r  r   rH   r   r   r   ress     r8   r   zSysCaptureBinary.snap  d    6#;<!ll!!&&(!
r:   c                    | j                  dd       | j                  j                          | j                  j                  j	                  |       | j                  j                  j                          y Nr   r/  )r$  r  r   rH   rt   r   s     r8   r   zSysCaptureBinary.writeorg  sO    :'?@				t$		 r:   Nr   bytesr   r>  r   r   r   r   r   r   r   r   r}   r:   r8   r4  r4    s    L!r:   r4  c                       e Zd ZdZddZddZy)
SysCapturer   c                    | j                  dd       t        | j                  t              sJ | j                  j	                         }| j                  j                  d       | j                  j                          |S r6  )r$  r_   r  r   r   r   r   r8  s     r8   r   zSysCapture.snap  s`    6#;<$,,	222ll##%!
r:   c                    | j                  dd       | j                  j                  |       | j                  j                          y r<  )r$  r  rt   r   r   s     r8   r   zSysCapture.writeorg  s1    :'?@				r:   Nr   r  r@  r}   r:   r8   rB  rB    s    Lr:   rB  c                  D    e Zd Zd	dZd
dZddZddZddZddZddZ	y)FDCaptureBasec                   || _         	 t        j                  |       d | _        t        j                  |      | _
        |dk(  r8t        t        j                  d      | _        t        |      | _        d	| _        y t        t        d      dddd      | _        |t         v r#t        || j                        | _        d	| _        y t#        |      | _        d	| _        y # t        $ r[ t        j
                  t        j                  t        j                        | _        t        j                  | j                  |       Y w xY w)
Nr   utf-8)rT   )rZ   r   r   T)rT   rU   r   r   r  )targetfdrQ   fstattargetfd_invalidr   rP   devnullO_RDWRdup2rR   targetfd_saver  rB  
syscapturer|   r	   r  r  r  )r   rI  s     r8   r   zFDCaptureBase.__init__  s    	)HHX  %)D!VVH-q=

W=DL0:80DDO $ '*  "DL <'",Xt||"D $ #,H"5#E  	5 13

BII0ND!GGD))84	5s   C A EEc                    d| j                   j                   d| j                   d| j                   d| j                  d| j
                  dS )N< z oldfd= _state=z	 tmpfile=>)r   r   rI  rO  r  r  r   s    r8   r  zFDCaptureBase.__repr__  sR    ''($--@R@R?S Tkk_Idll-=Q@	
r:   c                    | j                   |v s1J dj                  || j                   dj                  |                   y r  r  r!  s      r8   r$  zFDCaptureBase._assert_state   r%  r:   c                    | j                  dd       t        j                  | j                  j	                         | j
                         | j                  j                          d| _        y)z4Start capturing on targetfd using memorized tmpfile.r   r'  r(  N)	r$  rQ   rN  r  rS   rI  rP  r   r  r   s    r8   r   zFDCaptureBase.start  sI    7$45
##%t}}5r:   c                   | j                  dd       | j                  dk(  ryt        j                  | j                  | j
                         t        j                  | j                         | j                  W| j                  | j
                  k7  rt        j                  | j
                         t        j                  | j                         | j                  j                          | j                  j                          d| _        y)z_Stop capturing, restore streams, return original capture file,
        seeked to position zero.r   r+  N)r$  r  rQ   rN  rO  rI  r   rK  rP  r   r  r   s    r8   r   zFDCaptureBase.done  s     	6#RS;;& 
""DMM2
##$  ,$$5'HHT**+r:   c                    | j                  dd       | j                  dk(  ry | j                  j                          t	        j
                  | j                  | j                         d| _        y r.  )r$  r  rP  r   rQ   rN  rO  rI  r   s    r8   r   zFDCaptureBase.suspend  sQ    9&>?;;+%!
""DMM2!r:   c                    | j                  dd       | j                  dk(  ry | j                  j                          t	        j
                  | j                  j                         | j                         d| _        y r1  )	r$  r  rP  r   rQ   rN  r  rS   rI  r   s    r8   r   zFDCaptureBase.resume&  sX    8%=>;;)# 
##%t}}5r:   N)rI  r   r   r   r   r2  r   )
r   r   r   r   r  r$  r   r   r   r   r}   r:   r8   rF  rF    s&    '$R

  " r:   rF  c                  $    e Zd ZdZdZddZddZy)FDCaptureBinaryzWCapture IO to/from a given OS-level file descriptor.

    snap() produces `bytes`.
    r:   c                   | j                  dd       | j                  j                  d       | j                  j                  j	                         }| j                  j                  d       | j                  j                          |S r6  r7  r8  s     r8   r   zFDCaptureBinary.snap7  r:  r:   c                h    | j                  dd       t        j                  | j                  |       y)"Write to original file descriptor.r   r/  N)r$  rQ   rt   rO  r   s     r8   r   zFDCaptureBinary.writeorg?  s'    :'?@
##T*r:   Nr=  r?  r   r   r   __doc__r   r   r   r}   r:   r8   r\  r\  /  s    
 L+r:   r\  c                  $    e Zd ZdZdZddZddZy)	FDCapturezTCapture IO to/from a given OS-level file descriptor.

    snap() produces text.
    r   c                    | j                  dd       | j                  j                  d       | j                  j                         }| j                  j                  d       | j                  j	                          |S r6  )r$  r  r   r   r   r8  s     r8   r   zFDCapture.snapM  s^    6#;<!ll!!
r:   c                    | j                  dd       t        j                  | j                  |j	                  d             y)r_  r   r/  rH  N)r$  rQ   rt   rO  encoder   s     r8   r   zFDCapture.writeorgU  s0    :'?@
##T[[%9:r:   Nr   r  r`  r}   r:   r8   rc  rc  E  s    
 L;r:   rc  )      c                  &    e Zd ZU dZded<   ded<   y)CaptureResultOThe result of :method:`caplog.readouterr() <pytest.CaptureFixture.readouterr>`.r   rx   ry   N)r   r   r   ra  r   r}   r:   r8   rj  rj  b  s    ]r:   rj  c                      e Zd ZdZdZy)rj  rk  r}   N)r   r   r   ra  r   r}   r:   r8   rj  rj  k  s     	^	r:   rx   ry   c                  n    e Zd ZdZdZ	 	 	 	 	 	 	 	 ddZddZddZddZdddZ	ddZ
dd	Zdd
ZddZy)MultiCaptureNFc                .    || _         || _        || _        y r   in_rx   ry   )r   rq  rx   ry   s       r8   r   zMultiCapture.__init__x  s     03/2/2r:   c                    d| j                   d| j                  d| j                  d| j                  d| j                  dS )Nz<MultiCapture out=z err=z in_=rT  z _in_suspended=rU  )rx   ry   rq  r  _in_suspendedr   s    r8   r  zMultiCapture.__repr__  sJ     E$((U488, Okk_OD4F4F3IL	
r:   c                    d| _         | j                  r| j                  j                          | j                  r| j                  j                          | j                  r| j                  j                          y y )Nr(  )r  rq  r   rx   ry   r   s    r8   start_capturingzMultiCapture.start_capturing  sM    88HHNN88HHNN88HHNN r:   c                    | j                         \  }}|r)| j                  J | j                  j                  |       |r)| j                  J | j                  j                  |       ||fS )z?Pop current snapshot out/err capture and flush to orig streams.)
readouterrrx   r   ry   r   rx   ry   s      r8   pop_outerr_to_origzMultiCapture.pop_outerr_to_orig  se    ??$S88'''HHc"88'''HHc"Cxr:   c                   d| _         | j                  r| j                  j                          | j                  r| j                  j                          |r/| j                  r"| j                  j                          d| _        y y y )Nr,  T)r  rx   r   ry   rq  rs  r   rq  s     r8   suspend_capturingzMultiCapture.suspend_capturing  s_    !88HH88HH488HH!%D 3r:   c                "   d| _         | j                  r| j                  j                          | j                  r| j                  j                          | j                  r0| j
                  J | j
                  j                          d| _        y y )Nr(  F)r  rx   r   ry   rs  rq  r   s    r8   resume_capturingzMultiCapture.resume_capturing  sg    88HHOO88HHOO88'''HHOO!&D r:   c                ,   | j                   dk(  rt        d      d| _         | j                  r| j                  j                          | j                  r| j                  j                          | j
                  r| j
                  j                          yy)z+Stop capturing and reset capturing streams.stoppedzwas already stoppedN)r  
ValueErrorrx   r   ry   rq  r   s    r8   stop_capturingzMultiCapture.stop_capturing  sb    ;;)#23388HHMMO88HHMMO88HHMMO r:   c                     | j                   dk(  S )z7Whether actively capturing -- not suspended or stopped.r(  )r  r   s    r8   
is_startedzMultiCapture.is_started  s    {{i''r:   c                    | j                   r| j                   j                         nd}| j                  r| j                  j                         nd}t        ||      S r	  )rx   r   ry   rj  rx  s      r8   rw  zMultiCapture.readouterr  s=    !%dhhmmor!%dhhmmorS#&&r:   )rq  CaptureBase[AnyStr] | Nonerx   r  ry   r  r   r   r   r   )r   ztuple[AnyStr, AnyStr]Frq  r   r   r   r   r   zCaptureResult[AnyStr])r   r   r   r  rs  r   r  ru  ry  r|  r~  r  r  rw  r}   r:   r8   rn  rn  t  s_    FM3'3 (3 (	3
 
3
	&	'
('r:   rn  c                N   | dk(  r)t        t        d      t        d      t        d            S | dk(  r)t        t        d      t        d      t        d            S | dk(  rt        d d d       S | dk(  r$t        d t        dd	
      t        dd	
            S t        d|       )Nr"   r   r   r   rp  r#   r$   r%   Tr  zunknown capturing method: )rn  rc  rB  r  )r)   s    r8   _get_multicapturer    s    ~	!)A,IaLQQ	5
1:a=jQRmTT	4$D99	9	*QD1z!7N
 	
 1&<
==r:   c                     e Zd ZdZddZd dZd!dZd"dZd#dZd#dZ	d#dZ
d$d%d	Zd$d%d
Zd#dZd&dZd'dZd#dZd#dZd#dZd#dZd#dZej,                  d(d       Zej,                  d)d       Z ed      	 	 	 	 d*d       Z ed      d+d       Z ed      d+d       Z ed      d+d       Z ed      d#d       Z ed      d#d       Zy),rl   a  The capture plugin.

    Manages that the appropriate capture method is enabled/disabled during
    collection and each test phase (setup, call, teardown). After each of
    those points, the captured output is obtained and attached to the
    collection/runtest report.

    There are two levels of capture:

    * global: enabled by default and can be suppressed by the ``-s``
      option. This is always enabled/disabled during collection and each test
      phase.

    * fixture: when a test function or one of its fixture depend on the
      ``capsys`` or ``capfd`` fixtures. In this case special handling is
      needed to ensure the fixtures take precedence over the global capture.
    c                .    || _         d | _        d | _        y r   _method_global_capturing_capture_fixture)r   r)   s     r8   r   zCaptureManager.__init__  s    $;?<@r:   c                V    d| j                   d| j                  d| j                  dS )Nz<CaptureManager _method=z _global_capturing=z _capture_fixture=rU  r  r   s    r8   r  zCaptureManager.__repr__  s:    &t||&66I$J`J`Ic d  $ 5 58;	
r:   c                    | j                         ry| j                  r#d| j                  j                  j                   S y)Nglobalzfixture F)is_globally_capturingr  requestfixturenamer   s    r8   is_capturingzCaptureManager.is_capturing  s=    %%'  d33;;GGHIIr:   c                     | j                   dk7  S )Nr$   )r  r   s    r8   r  z$CaptureManager.is_globally_capturing   s    ||t##r:   c                    | j                   J t        | j                        | _         | j                   j                          y r   )r  r  r  ru  r   s    r8   rp   z%CaptureManager.start_global_capturing  s7    %%---!24<<!@..0r:   c                    | j                   <| j                   j                          | j                   j                          d | _         y y r   )r  ry  r  r   s    r8   ro   z$CaptureManager.stop_global_capturing  s?    !!-""557""113%)D" .r:   c                R    | j                   | j                   j                          y y r   )r  r~  r   s    r8   resume_global_capturez$CaptureManager.resume_global_capture  s'     !!-""335 .r:   c                V    | j                   | j                   j                  |       y y )Nrq  )r  r|  r{  s     r8   rq   z%CaptureManager.suspend_global_capture  s*    !!-""444= .r:   c                F    | j                          | j                  |       y r   )suspend_fixturerq   r{  s     r8   r   zCaptureManager.suspend  s    ##C(r:   c                D    | j                          | j                          y r   )r  resume_fixturer   s    r8   r   zCaptureManager.resume  s    ""$r:   c                R    | j                   J | j                   j                         S r   )r  rw  r   s    r8   rs   z"CaptureManager.read_global_capture!  s)    %%111%%0022r:   c                    | j                   rX| j                   j                  j                  }|j                  j                  }|j                  j                  d| d| d       || _         y )Nzcannot use z and z at the same time)r  r  r  
raiseerror)r   capture_fixturecurrent_fixturerequested_fixtures       r8   set_fixturezCaptureManager.set_fixture'  sh      "33;;GGO / 7 7 C C##../0o5FFWX !0r:   c                    d | _         y r   )r  r   s    r8   unset_fixturezCaptureManager.unset_fixture0  s
     $r:   c                R    | j                   r| j                   j                          yy)z|If the current item is using ``capsys`` or ``capfd``, activate
        them so they take precedence over the global capture.N)r  _startr   s    r8   activate_fixturezCaptureManager.activate_fixture3  s$       !!((* !r:   c                R    | j                   r| j                   j                          yy)zDDeactivate the ``capsys`` or ``capfd`` fixture of this item, if any.N)r  r   r   s    r8   deactivate_fixturez!CaptureManager.deactivate_fixture9  s"      !!'') !r:   c                R    | j                   r| j                   j                          y y r   )r  _suspendr   s    r8   r  zCaptureManager.suspend_fixture>  s"      !!**, !r:   c                R    | j                   r| j                   j                          y y r   )r  _resumer   s    r8   r  zCaptureManager.resume_fixtureB  s"      !!))+ !r:   c              #    K   | j                   xr | j                   j                         }|r| j                          | j                  xr | j                  j	                         }|r| j                          	 d |r| j                          |r| j                          yy# |r| j                          |r| j                          w w xY ww)zLContext manager to temporarily disable global and current fixture capturing.N)r  _is_startedr  r  r  rq   r  r  )r   
do_fixture	do_globals      r8   global_and_fixture_disabledz*CaptureManager.global_and_fixture_disabledH  s      **Rt/D/D/P/P/R
  "**Rt/E/E/P/P/R	'')	&**,##%  **,##% s   A5C8B" <&C"'C		Cc              #    K   | j                          | j                          	 d  | j                          | j                  d       | j	                         \  }}|j                  |d|       |j                  |d|       y # | j                          | j                  d       | j	                         \  }}|j                  |d|       |j                  |d|       w xY ww)NFr  rb   rc   )r  r  r  rq   rs   add_report_section)r   whenitemrx   ry   s        r8   item_capturezCaptureManager.item_captureY  s     ""$	9##%''E'2//1HC##D(C8##D(C8 ##%''E'2//1HC##D(C8##D(C8s   !C$B AC$AC!!C$Trf   c              #  P  K   t        |t              rx| j                          	 d }| j                          | j	                         \  }}|r|j
                  j                  d|f       |r|j
                  j                  d|f       |S d }|S # | j                          w xY ww)NzCaptured stdoutzCaptured stderr)r_   r   r  rq   rs   sectionsappend)r   	collectorreprx   ry   s        r8   pytest_make_collect_reportz)CaptureManager.pytest_make_collect_reporti  s      i&&&(.++-//1HC##%6$<=##%6$<= 
 C
 ++-s   !B&B A)B&B##B&c              #  b   K   | j                  d|      5  d cd d d        S # 1 sw Y   y xY ww)Nsetupr  r   r  s     r8   pytest_runtest_setupz#CaptureManager.pytest_runtest_setup|  s$     w- .--   /#
/,/c              #  b   K   | j                  d|      5  d cd d d        S # 1 sw Y   y xY ww)Ncallr  r  s     r8   pytest_runtest_callz"CaptureManager.pytest_runtest_call  s$     vt, -,,r  c              #  b   K   | j                  d|      5  d cd d d        S # 1 sw Y   y xY ww)Nteardownr  r  s     r8   pytest_runtest_teardownz&CaptureManager.pytest_runtest_teardown  s$     z40 100r  )tryfirstc                $    | j                          y r   ro   r   s    r8   pytest_keyboard_interruptz(CaptureManager.pytest_keyboard_interrupt      ""$r:   c                $    | j                          y r   r  r   s    r8   pytest_internalerrorz#CaptureManager.pytest_internalerror  r  r:   N)r)   _CaptureMethodr   r   r   )r   z
str | boolr   r   r  r  )r   zCaptureResult[str])r  zCaptureFixture[Any]r   r   r   Generator[None])r  r   r  r   r   r  )r  r   r   z-Generator[None, CollectReport, CollectReport])r  r   r   r  ) r   r   r   ra  r   r  r  r  rp   ro   r  rq   r   r   rs   r  r  r  r  r  r  
contextlibcontextmanagerr  r  r   r  r  r  r  r  r  r}   r:   r8   rl   rl     s7   $A

$1
*6>)
30%+*
-, & &  9 9 d"	6 $ d  d  d  t% % t% %r:   rl   c                      e Zd ZdZddd	 	 	 	 	 	 	 	 	 ddZddZddZddZdd	Zdd
Z	ddZ
ej                  dd       Zy)CaptureFixturez|Object returned by the :fixture:`capsys`, :fixture:`capsysbinary`,
    :fixture:`capfd` and :fixture:`capfdbinary` fixtures.NFconfig	_ispytestc                   t        |       || _        || _        |r|ni | _        d | _        | j                  j
                  | _        | j                  j
                  | _        y r   )r   captureclassr  _config_capturer   _captured_out_captured_err)r   r  r  r  r  s        r8   r   zCaptureFixture.__init__  sU     	y!7C!'vR59%)%6%6%C%C%)%6%6%C%Cr:   c           	         | j                   bt        d  | j                  di | j                   | j                  di | j                        | _         | j                   j	                          y y )Nrp  )r   )r   )r  rn  r  r  ru  r   s    r8   r  zCaptureFixture._start  s`    == (%D%%84<<8%D%%84<<8DM
 MM))+ !r:   c                    | j                   i| j                   j                         \  }}| xj                  |z  c_        | xj                  |z  c_        | j                   j	                          d | _         y y r   )r  ry  r  r  r  rx  s      r8   r   zCaptureFixture.close  s`    ==$}}779HC#%#%MM((* DM %r:   c                   | j                   | j                  }}| j                  '| j                  j                         \  }}||z  }||z  }| j                  j
                  | _         | j                  j
                  | _        t        ||      S )zRead and return the captured output so far, resetting the internal
        buffer.

        :returns:
            The captured content as a namedtuple with ``out`` and ``err``
            string attributes.
        )r  r  r  rw  r  r   rj  )r   captured_outcaptured_errrx   ry   s        r8   rw  zCaptureFixture.readouterr  s     &*%7%79K9Kl==$}}//1HCCLCL!..;;!..;;\<88r:   c                R    | j                   | j                   j                          yy)z1Suspend this fixture's own capturing temporarily.N)r  r|  r   s    r8   r  zCaptureFixture._suspend  s!    ==$MM++- %r:   c                R    | j                   | j                   j                          yy)z0Resume this fixture's own capturing temporarily.N)r  r~  r   s    r8   r  zCaptureFixture._resume  s!    ==$MM**, %r:   c                P    | j                   | j                   j                         S y)z5Whether actively capturing -- not disabled or closed.F)r  r  r   s    r8   r  zCaptureFixture._is_started  s"    ==$==++--r:   c              #     K   | j                   j                  j                  j                  d      }|j	                         5  d ddd       y# 1 sw Y   yxY ww)z>Temporarily disable capturing while inside the ``with`` block.ri   N)r  r  rk   	getpluginr  )r   
capmanagers     r8   disabledzCaptureFixture.disabled  sG      &*\\%8%8%F%F%P%P&

 335 655s   A AA	AAA)
r  ztype[CaptureBase[AnyStr]]r  r   r  zdict[str, Any] | Noner  r   r   r   r   r  r   r  )r   r   r   ra  r   r  r   rw  r  r  r  r  r  r  r}   r:   r8   r  r    s    = )-D/D D
 &D D 
D ,!9".
-
  r:   r  c              #    K   | j                   j                  j                  d      }t        t        | d      }|j                  |       |j                          | |j                          |j                          yw)a  Enable text capturing of writes to ``sys.stdout`` and ``sys.stderr``.

    The captured output is made available via ``capsys.readouterr()`` method
    calls, which return a ``(out, err)`` namedtuple.
    ``out`` and ``err`` will be ``text`` objects.

    Returns an instance of :class:`CaptureFixture[str] <pytest.CaptureFixture>`.

    Example:

    .. code-block:: python

        def test_output(capsys):
            print("hello")
            captured = capsys.readouterr()
            assert captured.out == "hello\n"
    ri   Tr  N)	r  rk   r  r  rB  r  r  r   r  r  rw   r  s      r8   capsysr    si     & %^^99CCDTUF$ZDIO
'

   A>B c              #    K   | j                   j                  j                  d      }t        t        | t        d      d      }|j                  |       |j                          | |j                          |j                          yw)a  Enable simultaneous text capturing and pass-through of writes
    to ``sys.stdout`` and ``sys.stderr`` as defined by ``--capture=``.


    The captured output is made available via ``capteesys.readouterr()`` method
    calls, which return a ``(out, err)`` namedtuple.
    ``out`` and ``err`` will be ``text`` objects.

    The output is also passed-through, allowing it to be "live-printed",
    reported, or both as defined by ``--capture=``.

    Returns an instance of :class:`CaptureFixture[str] <pytest.CaptureFixture>`.

    Example:

    .. code-block:: python

        def test_output(capteesys):
            print("hello")
            captured = capteesys.readouterr()
            assert captured.out == "hello\n"
    ri   Tr  r  N)
r  rk   r  r  rB  dictr  r  r   r  r  s      r8   	capteesysr    st     0 %^^99CCDTUF$GDTNdO '

s   B	Bc              #    K   | j                   j                  j                  d      }t        t        | d      }|j                  |       |j                          | |j                          |j                          yw)a'  Enable bytes capturing of writes to ``sys.stdout`` and ``sys.stderr``.

    The captured output is made available via ``capsysbinary.readouterr()``
    method calls, which return a ``(out, err)`` namedtuple.
    ``out`` and ``err`` will be ``bytes`` objects.

    Returns an instance of :class:`CaptureFixture[bytes] <pytest.CaptureFixture>`.

    Example:

    .. code-block:: python

        def test_output(capsysbinary):
            print("hello")
            captured = capsysbinary.readouterr()
            assert captured.out == b"hello\n"
    ri   Tr  N)	r  rk   r  r  r4  r  r  r   r  r  s      r8   capsysbinaryr  &  sj     & %^^99CCDTUF$%5w$OO
'

r  c              #    K   | j                   j                  j                  d      }t        t        | d      }|j                  |       |j                          | |j                          |j                          yw)a  Enable text capturing of writes to file descriptors ``1`` and ``2``.

    The captured output is made available via ``capfd.readouterr()`` method
    calls, which return a ``(out, err)`` namedtuple.
    ``out`` and ``err`` will be ``text`` objects.

    Returns an instance of :class:`CaptureFixture[str] <pytest.CaptureFixture>`.

    Example:

    .. code-block:: python

        def test_system_echo(capfd):
            os.system('echo "hello"')
            captured = capfd.readouterr()
            assert captured.out == "hello\n"
    ri   Tr  N)	r  rk   r  r  rc  r  r  r   r  r  s      r8   capfdr   B  si     & %^^99CCDTUF$Y4HO
'

r  c              #    K   | j                   j                  j                  d      }t        t        | d      }|j                  |       |j                          | |j                          |j                          yw)a-  Enable bytes capturing of writes to file descriptors ``1`` and ``2``.

    The captured output is made available via ``capfd.readouterr()`` method
    calls, which return a ``(out, err)`` namedtuple.
    ``out`` and ``err`` will be ``byte`` objects.

    Returns an instance of :class:`CaptureFixture[bytes] <pytest.CaptureFixture>`.

    Example:

    .. code-block:: python

        def test_system_echo(capfdbinary):
            os.system('echo "hello"')
            captured = capfdbinary.readouterr()
            assert captured.out == b"hello\n"

    ri   Tr  N)	r  rk   r  r  r\  r  r  r   r  r  s      r8   capfdbinaryr  ^  si     ( %^^99CCDTUF$_gNO
'

r  )r6   r   r   r   r   )r[   r   r   r   )ru   r   r   r  )r)   r  r   zMultiCapture[str])r  r   r   zGenerator[CaptureFixture[str]])r  r   r   z Generator[CaptureFixture[bytes]])Sra  
__future__r   r   collectionscollections.abcr   r   r   r  rN   r   rQ   r#   tempfiler	   typesr
   typingr   r   r   r   r   r   r   r   r   r   r   typing_extensionsr   _pytest.configr   r   _pytest.config.argparsingr   _pytest.deprecatedr   _pytest.fixturesr   r   _pytest.nodesr   r   r   _pytest.reportsr    r  r9   rA   rE   re   rz   rO   r|   r   r   r   ABCr   r  r   r  r  r>  r4  rB  rF  r\  rc  version_inforj  
namedtuplern  r  rl   r  r  r  r  r   r  r}   r:   r8   <module>r     s   1 " 
  % $ $  	 # 	 
 "              & ! # , - $ ' #   ) 56&"41n 
$ <<""" <"6   6$9 $J J`$#''76? $@ xH5C  2@ [( @ F!~e, !$$ "\ K' \ ~+mE* +,;c" ;6 w-

GFO  ?Q'76? Q'h>"x% x%vMWV_ Mf 	 	6 	 	D 	 	6 	 	6 	 	r:   