tf!4dZddlZddlZddlmZddlmZddlmZm Z ddl m Z  ddZ Gd d e ZGd d e jZdidddfd ZGdde jZdiddfdZGdde jZdidddfdZdZdZdZgdZdS)z Utility methods. Nwraps)BytesIO)deferprotocol)failurec|ddlm}tj}||g|R}||||ft |z|||S)Nr)reactor)twisted.internetr rDeferred spawnProcesstuple) r executableargsenvpathr protoArgsdps U/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/internet/utils.py_callProtocolWithDeferredrsm,,,,,, AYA J d (CS$OOO HceZdZdZdZdS)_UnexpectedErrorOutputay Standard error data was received where it was not expected. This is a subclass of L{IOError} to preserve backward compatibility with the previous error behavior of L{getProcessOutput}. @ivar processEnded: A L{Deferred} which will fire when the process which produced the data on stderr has ended (exited and all file descriptors closed). cPt|d|||_dS)Nz got stderr: )IOError__init__ processEnded)selftextrs rrz_UnexpectedErrorOutput.__init__*s/6d66777(rN)__name__ __module__ __qualname____doc__rr rrrrs-)))))rrc2eZdZdZd dZdZdZdZdZdS) _BackRelaya Trivial protocol for communicating with a process and turning its output into the result of a L{Deferred}. @ivar deferred: A L{Deferred} which will be called back with all of stdout and, if C{errortoo} is true, all of stderr as well (mixed together in one string). If C{errortoo} is false and any bytes are received over stderr, this will fire with an L{_UnexpectedErrorOutput} instance and the attribute will be set to L{None}. @ivar onProcessEnded: If C{errortoo} is false and bytes are received over stderr, this attribute will refer to a L{Deferred} which will be called back when the process ends. This C{Deferred} is also associated with the L{_UnexpectedErrorOutput} which C{deferred} fires with earlier in this case so that users can determine when the process has actually ended, in addition to knowing when bytes have been received via stderr. rcr||_t|_|r|j|_dS|j|_dSN)deferredrserrReceivedIsGood errReceivederrReceivedIsBad)r r*errortoos rrz_BackRelay.__init__Bs>    5#5D   #4D   rc |j{tj|_t ||j}|jt j|d|_|j dSdSr)) r*rr onProcessEndedrerrbackrFailure transportloseConnection)r r!errs rr.z_BackRelay.errReceivedIsBadJsu = $"'."2"2D (t/BCCC M ! !'/#"6"6 7 7 7 DM N ) ) + + + + + % $rc:|j|dSr)r+writer r!s rr,z_BackRelay.errReceivedIsGoodR  Trc:|j|dSr)r8r:s r outReceivedz_BackRelay.outReceivedUr;rc|j3|j|jdS|j|j|dSdSr))r*callbackr+getvaluer1r2r reasons rrz_BackRelay.processEndedXs` = $ M " "46??#4#4 5 5 5 5 5  ,   ' ' / / / / /- ,rN)r) r"r#r$r%rr.r,r=rr rrr'r'/sn$5555,,,00000rr'c2tfd|||||S)a Spawn a process and return its output as a deferred returning a L{bytes}. @param executable: The file name to run and get the output of - the full path should be used. @param args: the command line arguments to pass to the process; a sequence of strings. The first string should B{NOT} be the executable's name. @param env: the environment variables to pass to the process; a dictionary of strings. @param path: the path to run the subprocess in - defaults to the current directory. @param reactor: the reactor to use - defaults to the default reactor @param errortoo: If true, include stderr in the result. If false, if stderr is received the returned L{Deferred} will errback with an L{IOError} instance with a C{processEnded} attribute. The C{processEnded} attribute refers to a L{Deferred} which fires when the executed process ends. c&t|S)N)r/)r')rr/s rz"getProcessOutput..ys*Q222r)r)rrrrr r/s `rgetProcessOutputrF_s.2 %2222Jc4QX  rceZdZdZdZdS) _ValueGetterc||_dSr))r*)r r*s rrz_ValueGetter.__init__~s   rcN|j|jjdSr))r*r?valueexitCoderAs rrz_ValueGetter.processEndeds# v|455555rN)r"r#r$rrr rrrHrH}s2!!!66666rrHc4tt|||||S)z7Spawn a process and return its exit code as a Deferred.)rrH)rrrrr s rgetProcessValuerNs $\:tS$PW X XXrc"eZdZddZdZdZdS)_EverythingGetterNc||_t|_t|_|jj|_|jj|_||_dSr))r*routBuferrBufr9r=r- stdinBytes)r r*rTs rrz_EverythingGetter.__init__sD  ii ii ;,;,$rc|j;|jd|j|jdSdS)Nr)rTr4 writeToChild closeStdin)r s rconnectionMadez _EverythingGetter.connectionMadesH ? & N ' '4? ; ; ; N % % ' ' ' ' ' ' &rc|j}|j}|j}|j}|jr$|j|||jfdS|j|||fdSr)) rRr@rSrKrLsignalr*r2r?)r rBoutr6ecodes rrz_EverythingGetter.processEndedsk""$$k""$$ Lz 8 5 M ! !3QX"6 7 7 7 7 7 M " "Cd#3 4 4 4 4 4rr))r"r#r$rrXrr rrrPrPsF%%%%(((55555rrPc :tt||||||fS)a.Spawn a process and returns a Deferred that will be called back with its output (from stdout and stderr) and it's exit code as (out, err, code) If a signal is raised, the Deferred will errback with the stdout and stderr up to that point, along with the signal, as (out, err, signalNum) )r)rrP)rrrrr rTs rgetProcessOutputAndValuer_s2 %   -   rcp|D]2} tj|##t$rY/wxYw|Sr))warningsfiltersremove ValueError) passthrough addedFiltersfs r_resetWarningFiltersrhsV     # #A & & & &    D  s & 33c|D]\}}tj|i|tjdt|} ||i|}t |t jr|t|ntd||S#t$rEtj }td||d |dwxYw)a} Run the function I{f}, but with some warnings suppressed. This calls L{warnings.filterwarnings} to add warning filters before invoking I{f}. If I{f} returns a L{Deferred} then the added filters are removed once the deferred fires. Otherwise they are removed immediately. Note that the list of warning filters is a process-wide resource, so calling this function will affect all threads. @param suppressedWarnings: A list of arguments to pass to L{warnings.filterwarnings}, a sequence of (args, kwargs) 2-tuples. @param f: A callable, which may return a L{Deferred}. @param a: Positional arguments passed to I{f} @param kw: Keyword arguments passed to I{f} @return: The result of C{f(*a, **kw)} @seealso: L{twisted.python.util.runWithWarningsSuppressed} functions similarly, but doesn't handled L{Deferred}s. N) rafilterwarningsrblen isinstancerr addBothrh BaseExceptionsysexc_infowith_traceback) suppressedWarningsrgakwrkwargsrfresultrrs rrunWithWarningsSuppressedrys4+11 f00000#$=c*<&=&=$=>L A fen - - 5 NN/ > > > > | 4 4 4  666<>>T<000qk((!5556s B ACc@tfd}|S)z Wrap C{f} in a callable which suppresses the indicated warnings before invoking C{f} and unsuppresses them afterwards. If f returns a Deferred, warnings will remain suppressed until the Deferred fires. c&tg|Ri|Sr))ry)rurvrgrts rwarningSuppressingWrapperz3suppressWarnings..warningSuppressingWrappers$();QIIIIbIIIrr)rgrtr|s`` rsuppressWarningsr}sB 1XXJJJJJXJ %$r)ryr}rFrNr_)Nr )r%rqra functoolsriorr rrtwisted.pythonrrrrProcessProtocolr'rFrHrNrPr_rhryr}__all__r rrrs   ,,,,,,,,""""""DF      ) ) ) ) )W ) ) ) -0-0-0-0-0)-0-0-0`')btTTU<666668+666&(RdDYYYY 5555505558RdDT&(((V % % %   r