&NjSSKrSSKrSSKJrJr SSKJr "SS\R5r"SS\5r "S S \ 5r g) N) GeneratorIterable)ResponseNotAcceptedc0\rSrSrSrS\S\\4SjrSrg) StreamWatchera% A class whose subclasses may act on seen stream data from subprocesses. Subclasses must exhibit the following API; see `Responder` for a concrete example. * ``__init__`` is completely up to each subclass, though as usual, subclasses *of* subclasses should be careful to make use of `super` where appropriate. * `submit` must accept the entire current contents of the stream being watched, as a string, and may optionally return an iterable of strings (or act as a generator iterator, i.e. multiple calls to ``yield ``), which will each be written to the subprocess' standard input. .. note:: `StreamWatcher` subclasses exist in part to enable state tracking, such as detecting when a submitted password didn't work & erroring (or prompting a user, or etc). Such bookkeeping isn't easily achievable with simple callback functions. .. note:: `StreamWatcher` subclasses `threading.local` so that its instances can be used to 'watch' both subprocess stdout and stderr in separate threads. .. versionadded:: 1.0 streamreturnc[e)z Act on ``stream`` data, potentially returning responses. :param str stream: All data read on this stream since the beginning of the session. :returns: An iterable of ``str`` (which may be empty). .. versionadded:: 1.0 )NotImplementedError)selfr s L/home/mande/repo/quber/.venv/lib/python3.13/site-packages/invoke/watchers.pysubmitStreamWatcher.submit&s "!N) __name__ __module__ __qualname____firstlineno____doc__strrr__static_attributes__rrrrrs: "S "Xc] "rrc l\rSrSrSrS\S\SS4SjrS\S\S \S\\4S jrS\S\ \SS44S jr S r g) Responder5z A parameterizable object that submits responses to specific patterns. Commonly used to implement password auto-responds for things like ``sudo``. .. versionadded:: 1.0 patternresponser Nc*XlX lSUlg)a Imprint this `Responder` with necessary parameters. :param pattern: A raw string (e.g. ``r"\[sudo\] password for .*:"``) which will be turned into a regular expression. :param response: The string to submit to the subprocess' stdin when ``pattern`` is detected. rN)rrindex)rrrs r__init__Responder.__init__>s   rr index_attrc[X5nXSn[R"X%[R5nU(a[ XU[ U5-5 U$)az Generic "search for pattern in stream, using index" behavior. Used here and in some subclasses that want to track multiple patterns concurrently. :param str stream: The same data passed to ``submit``. :param str pattern: The pattern to search for. :param str index_attr: The name of the index attribute to use. :returns: An iterable of string matches. .. versionadded:: 1.0 N)getattrrefindallSsetattrlen)rr rr$r!newmatchess rpattern_matchesResponder.pattern_matchesOsF&)Vn**W2440  Dec#h&6 7rc#n# URXRS5HnURv M g7f)Nr!)r.rr)rr _s rrResponder.submitks+%%fllGDA-- Es35)r!rr) rrrrrrr"rr.rrrrrrrr5shst"$'58 #8 S YsD$%? rrcd^\rSrSrSrS\S\S\SS4U4SjjrS \S\\SS44U4S jjrS r U=r $) FailingResponderqa Variant of `Responder` which is capable of detecting incorrect responses. This class adds a ``sentinel`` parameter to ``__init__``, and its ``submit`` will raise `.ResponseNotAccepted` if it detects that sentinel value in the stream. .. versionadded:: 1.0 rrsentinelr NcL>[TU]X5 X0lSUlSUlg)NrF)superr"r6 failure_indextried)rrrr6 __class__s rr"FailingResponder.__init__|s$ +  rr c >[TU]U5nURXRS5nUR(a8U(a1SR UR UR5n[U5eU(aSUlU$)Nr9z(Auto-response to r"{}" failed with {!r}!T)r8rr.r6r:formatrr)rr rfailederrr;s rrFailingResponder.submitsi7>&)%%fmm_M ::&<CC dmmC&c* * DJr)r9r6r:) rrrrrrr"rrr __classcell__)r;s@rr4r4qsLscd SYsD$%?rr4) r' threadingtypingrr exceptionsrlocalrrr4rrrrGs; &+*"IOO*"Z9 9 x y r