ó [³XMc@sadZddlmZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZddlZdd lmZddlZddlZddlZddlZd dd „ƒYZd efd „ƒYZddddded„Zd„Zidd6Zdejfd„ƒYZddd„ƒYZde j fd„ƒYZ dS(sDL{twisted.manhole} L{PB} service implementation. iÿÿÿÿ(t copyright(tpb(tlogtfailure(tportal(tservice(t implementst InterfaceN(tStringIOt FakeStdIOcBs,eZd„Zd„Zd„Zd„ZRS(cCs||_||_dS(N(ttypetlist(tselfttype_R ((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt__init__s cCsFtjd|jtjt|ƒƒfƒ|jj|j|fƒdS(Ns%s: %s(RtmsgR tstringtstriptstrR tappend(R ttext((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytwrite"s)cCsdS(N((R ((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytflush&sc Csã|js dS|j}g}|d}d}x°tdt|jƒƒD]–}||\}}||krmqEqE||dkr‘|j||ƒn>td„|||!ƒ}tj|dƒ}|j||fƒ|}|}qEWdS(s³Concatenate adjacent messages of same type into one. Greatly cuts down on the number of elements, increasing network transport friendliness considerably. NiicSs|dS(Ni((tl((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt>st(R txrangetlenRtmapRtjoin( R tinlisttoutlistt last_typet block_begintitmtypetmessagetmessages((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt consolidate)s$     (t__name__t __module__RRRR&(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR s   tIManholeClientcBs#eZd„Zd„Zd„ZRS(cCsdS(sOTakes a list of (type, message) pairs to display. Types include: - "stdout" -- string sent to sys.stdout - "stderr" -- string sent to sys.stderr - "result" -- string repr of the resulting value of the expression - "exception" -- a L{failure.Failure} N((tlist_of_messages((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytconsoleGscCsdS(s&Receives an explorer.Explorer N((txplorer((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytreceiveExplorerUscCsdS(scList what manholey things I am capable of doing. i.e. C{"Explorer"}, C{"Failure"} N((((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytlistCapabilitiesYs(R'R(R+R-R.(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR)Fs  cCsâg}td|ƒ} td|ƒ} td|ƒ} d} d} |dkrZt|ƒ}n|dkrod}n|dkr„i}n|dkr™|}n|dkrÁt|ƒ rÁtdƒ‚ny°tj}tj}| t_| t_zrt|ƒr t|||ƒ} nMyt ||dƒ} Wnt ||dƒ} nX| rYt | ||ƒ} nWd|t_|t_XWnMtj ƒ\}}}t j |||ƒ}~| jtj||ƒƒnX|rÞ| jƒ||ƒn| S( s€Run this, directing all output to the specified console. If command is callable, it will be called with the args and keywords provided. Otherwise, command will be compiled and eval'd. (Wouldn't you like a macro?) Returns the command's return value. The console is called with a list of (type, message) pairs for display, see L{IManholeClient.console}. tstdouttstderrt exceptions,Need a namespace to evaluate the command in.tevaltsingleN((R tNoneRtcallablet ValueErrortsysR/R0tapplytcompileR2texc_infoRtFailureRRtfailure2CopyableR&(tcommandR+tglobalNStlocalNStfilenametargstkwtunsafeTracebackstoutputtfakeouttfakeerrterrfiletcodetvaltoutterrteTypeteValttbtfail((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt runInConsole_sR                c Csƒddl}g}xJ|jD]?}|j|d|d|d|j|d|dƒfƒqWi|d6tj|j|jƒd6S(sòPre-Failure manhole representation of exceptions. For compatibility with manhole clients without the "Failure" capability. A dictionary with two members: - 'traceback' -- traceback.extract_tb output; a list of tuples (filename, line number, function name, text) suitable for feeding to traceback.format_list. - 'exception' -- a list of one or more strings, each ending in a newline. (traceback.format_exception_only output) iÿÿÿÿNiiit tracebackR1(t linecachetframesRtgetlineRQtformat_exception_onlyR tvalue(RORRRNtf((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt_failureOldStyle s =tSettExplorert PerspectivecBsƒeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „ZRS(icCs4i|d6|d6dd6|_i|_||_dS(NRtavatart_(R4tlocalNamespacetclientsR(R R((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyRÁs   cCs>|jjƒ}i|d<|djdƒr:|dd=n|S(NR_R^t __builtins__(t__dict__tcopythas_key(R tstate((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt __getstate__Ês  cCsÆ||j|>> %sR]iÿÿÿÿ(tDeferrediR„sWaiting for Deferred #%s... s s<<|j|ƒ}|r:tjj||ƒ}|j|ƒndS(s¬Browse the object obtained by evaluating the identifier. The resulting ObjectLink is passed back through the client's receiveBrowserObject method. N(RPtexplorert explorerPoolt getExplorerR-(R t identifiertobjecttexpl((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytperspective_exploreAscCsit‚|j|ƒ}|re|j|jj||ƒ}|j|ƒ|j|jj|||jƒndS(sÜWatch the object obtained by evaluating the identifier. Whenever I think this object might have changed, I will pass an ObjectLink of it back to the client's receiveBrowserObject method. N(tNotImplementedErrorRPtbrowsert browseObjectR-t watchObject(R R•R–toLink((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pytperspective_watchLs  (R'R(RRReRzR|RPR+R-R†RvRwR‘R˜Rž(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR[¿s          tRealmcBs'eZeejƒd„Zd„ZRS(cCs||_i|_dS(N(Rt_cache(R R((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyRds cstj|krtdƒ‚nˆ|jkr=|jˆ‰nt|jƒ‰ˆjˆˆƒ‡‡‡fd†}tjˆ|fS(Ns no interfacecsˆjˆˆƒdS(N(R|((tptavatarIdtmind(s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR|ps(Rt IPerspectiveR™R R[RRz(R R¢R£t interfacesR|((R£R¡R¢s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyt requestAvatarhs(R'R(RRtIRealmRR¦(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyRŸ`s  tServicecBs&eZdZedd„Zd„ZRS(sB Hello %(you)s, welcome to Manhole on %(host)s. %(longversion)s. cCsJ||_idt|ƒfd6td6|_|rF|jj|ƒndS(Ns __manhole%x__R'R7(RCR‡R7R}tupdate(R RCR}((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR|s   cCsF|jjƒ}|djƒ}||d<|jdƒrB|d=n|S(sAThis returns the persistent state of this shell factory. R}R`(RaRbRc(R tdicttns((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyRe…s   N(R'R(RptFalseR4RRe(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyR¨us (((!t__doc__ttwistedRttwisted.spreadRttwisted.pythonRRt twisted.credRttwisted.applicationRtzope.interfaceRRR’t cStringIORRR7RQttypesR R)R4R¬RPRXRstAvatarR[RŸR¨(((s;/usr/lib/python2.7/dist-packages/twisted/manhole/service.pyts,     )@  ¡