U W[e.ã@s<dZddlZddlZzddlZWnek r8dZYnXddlmZddlmZddl m Z ddlmZddl mZmZmZmZmZddlmZdd lmZdd lmZmZddlmZGdd „d e jƒZGdd„de jejƒZe eje¡Gdd„dƒZ!Gdd„dej"ƒZ#Gdd„de j$ej%ƒZ&Gdd„dej"ƒZ'dS)z¬ Distributed web servers. This is going to have to be refactored so that argument parsing is done by each subprocess and not by the main web server (i.e. GET, POST etc.). éN)ÚBytesIO)ÚgetDOMImplementation)Úpb)Ú SIZE_LIMIT)ÚhttpÚresourceÚserverÚutilÚstatic)ÚHeaders)Ústyles)ÚaddressÚreactor)ÚLoggerc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) Ú_ReferenceableProducerWrappercCs ||_dS©N)Úproducer)Úselfr©rú5/usr/lib/python3/dist-packages/twisted/web/distrib.pyÚ__init__!sz&_ReferenceableProducerWrapper.__init__cCs|j ¡dSr)rZresumeProducing©rrrrÚremote_resumeProducing$sz4_ReferenceableProducerWrapper.remote_resumeProducingcCs|j ¡dSr)rZpauseProducingrrrrÚremote_pauseProducing'sz3_ReferenceableProducerWrapper.remote_pauseProducingcCs|j ¡dSr)rZ stopProducingrrrrÚremote_stopProducing*sz2_ReferenceableProducerWrapper.remote_stopProducingN)Ú__name__Ú __module__Ú__qualname__rrrrrrrrr src@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d„ZdS) ÚRequestzn A request which was received by a L{ResourceSubscription} and sent via PB to a distributed node. csâdD]H}||‰dddœˆd‰‡‡fdd„‡fdd„d œˆƒ}|||<qtt|d ƒƒ|d <tj ||¡t|jƒ|_|j d¡|_ |j d¡|_|j d ¡|_|j d¡|_ |j d¡|_|j d¡|_|j d¡|_dS)z Initialize this L{twisted.web.distrib.Request} based on the copied state so that it closely resembles a L{twisted.web.server.Request}. )ÚhostZclientÚTCPÚUNIX)ZINETr!rcst ˆˆdˆd¡S)Néé)r ZIPv4Addressr©ZaddrdescÚtuprrÚ;sÿz*Request.setCopyableState..cst ˆd¡S)Nr")r ZUNIXAddressr)r%rrr&=ó)r r!ZrequestHeadersÚfinishÚ setHeaderÚ addCookieÚsetETagÚsetResponseCodeÚsetLastModifiedÚwriteN)rÚdictrÚ RemoteCopyÚsetCopyableStaterZcontent_dataZcontentÚremoteZremoteMethodr(r)r*r+r,r-Ú_write)rÚstateÚkZaddrrr$rr13s& þþ zRequest.setCopyableStatecCs>d}t}| |||…¡|t7}|t7}|t|ƒkrq:qdS)z» Write the given bytes to the response body. @param bytes: The bytes to write. If this is longer than 640k, it will be split up into smaller pieces. rN)rr3Úlen)rÚbytesÚstartÚendrrrr.Osz Request.writecCs |j dt|ƒ|¡ |j¡dS)NÚregisterProducer)r2Ú callRemoterÚ addErrbackÚfail)rrZ streamingrrrr:`sþþzRequest.registerProducercCs|j d¡ |j¡dS)NÚunregisterProducer)r2r;r<r=rrrrr>eszRequest.unregisterProducercCs|jjd|ddS)NÚ)Úfailure)Ú_logr@©rr@rrrr=hszRequest.failN) rrrÚ__doc__r1r.r:r>r=rrrrr.src@s*eZdZeƒZdd„Zdd„Zdd„ZdS)ÚIssuecCs ||_dSr)Úrequest)rrErrrrqszIssue.__init__cCs6|tjkr2t|tƒstdƒ‚|j |¡|j ¡dS)Nzreturn value not a string)rÚNOT_DONE_YETÚ isinstanceÚstrÚAssertionErrorrEr.r()rÚresultrrrÚfinishedts zIssue.finishedc CsLt|ƒ}|j t tjddt |¡¡ |j¡¡|j ¡|j |¡dS)NzServer Connection Lostz&Connection to distributed server lost:) rHrEr.rZ ErrorPagerZINTERNAL_SERVER_ERRORr Z_PREÚrenderr(rAÚinforBrrrÚfailedzsÿþüÿ zIssue.failedN)rrrrrArrKrNrrrrrDnsrDc@sJeZdZdZdZeƒZdd„Zdd„Zdd„Z d d „Z dd„Zd d„ZdS)ÚResourceSubscriptionr"rcCs(tj |¡||_||_g|_d|_dSr)rÚResourcerrÚportÚpendingÚ publisher)rrrQrrrrŒs zResourceSubscription.__init__cCs(t |j¡}d|d<d|d<g|d<|S)z| |¡| ¡tjS)zK Look up the resource for the given request and render it. ) rbZgetResourceForrArMrLrrFr.r()rrEÚresrJrrrÚremote_requestós z ResourcePublisher.remote_requestN)rrrrCrrArZpersistenceVersionrdrfrhrrrrraÙsrac@s>eZdZdZdZdZdZddd„Zdd „Zd d„Z dd „Z dS)Ú UserDirectoryzÆ A resource which lists available user resources and serves them as children. @ivar _pwd: An object like L{pwd} which is used to enumerate users and their home directories. Zpublic_htmlz.twistd-web-pbaæ twisted.web.distrib.UserDirectory

twisted.web.distrib.UserDirectory

%(users)s NcCs"tj |¡|dkrt}||_dSr)rrPrÚpwdÚ_pwd)rZuserDatabaserrrr7szUserDirectory.__init__c Cs g}|j ¡D]Œ}|\}}}}}}} | d¡d} | s:|} tj tj ||j¡¡rd| || df¡tj ||j ¡}tj |¡r|d}| || df¡q|S)z| Return a list of two-tuples giving links to user resources and text to associate with those links. ú,rz (file)ú.twistdz (twistd)) rkÚgetpwallÚsplitÚosÚpathÚexistsÚjoinÚuserDirNamer^ÚuserSocketName) rÚusersÚuserreZpasswdZuidÚgidZgecosÚdirÚshellZrealnameÚ twistdsockZlinkNamerrrÚ_users>szUserDirectory._userscCs”tƒ}| ddd¡}|j}| ¡D]T\}}| d¡}| d|d¡| |¡}| |¡| d¡} | |¡| | ¡q"|jd| ¡i} | d¡S) zm Render as HTML a listing of all known users with links to their personal resources. NZulÚaZhrefú/Zlirvzutf-8)rZcreateDocumentZdocumentElementr|Z createElementZsetAttributeZcreateTextNodeZappendChildÚtemplateZtoxmlÚencode)rrEZdomImplZnewDocZlistingÚlinkÚtextZlinkElementZtextNodeÚitemZhtmlDocrrrÚ render_GETRs zUserDirectory.render_GETcCsâ|dkr|Sd}|t|ƒd…|kr>|dt|ƒ…}d}n|}d}z|j |¡\}}}} } }}Wntk r€t ¡YSX|r°tj ||j ¡} t d| ƒ}| ||¡|Stj ||j¡}tj |¡sÔt ¡St |¡SdS)Nr?rmr"rr])r6rkÚgetpwnamÚKeyErrorrZ NoResourcerprqrsrurOZputChildrtrrr ZFile)rrerEZtdZusernameÚsubÚpw_nameÚ pw_passwdÚpw_uidÚpw_gidÚpw_gecosÚpw_dirÚpw_shellr{ZrsrqrrrÚgetChildhs, ÿ zUserDirectory.getChild)N)rrrrCrtrurrr|r„rrrrrris* ri)(rCrprUrjÚImportErrorÚiorZxml.dom.minidomrZtwisted.spreadrZtwisted.spread.bananarZtwisted.webrrrr r Ztwisted.web.http_headersrZtwisted.persistedrZtwisted.internetr rZtwisted.loggerrZ Referenceablerr0rZsetUnjellyableForClassrDrPrOZRootZ VersionedrarirrrrÚs* >R(