/usr/lib/python3/dist-packages/twisted/web/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/web/__pycache__/distrib.cpython-310.pyc (12283B)
o
bW. @ s: d Z ddlZddlZzddlZW n ey dZY nw ddlmZ ddlmZ ddl m
Z
m Z ddl m
Z
ddlmZ ddlmZ dd lmZ dd
lmZmZmZmZmZ dd lmZ G d d
d
ej Z G dd dej ej Z e ej e G dd dZ!G dd dej"Z#G dd dej$ej%Z&G dd 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)addressreactor)Logger)styles)pb)
SIZE_LIMIT)httpresourceserverstaticutil)Headersc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
_ReferenceableProducerWrapperc C
|| _ d S N)producer)selfr r 5/usr/lib/python3/dist-packages/twisted/web/distrib.py__init__$
z&_ReferenceableProducerWrapper.__init__c C | j d S r )r resumeProducingr r r r remote_resumeProducing' z4_ReferenceableProducerWrapper.remote_resumeProducingc C r r )r pauseProducingr r r r remote_pauseProducing* r z3_ReferenceableProducerWrapper.remote_pauseProducingc C r r )r
stopProducingr r r r remote_stopProducing- r z2_ReferenceableProducerWrapper.remote_stopProducingN)__name__
__module__ __qualname__r r r r! r r r r r # s
r c @ s8 e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd S )
Requestzn
A request which was received by a L{ResourceSubscription} and sent via
PB to a distributed node.
c s dD ]$}|| dddd fddfddd }|||< qt t|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}.
)hostclientTCPUNIX)INETr) r c s t d d S )N )r IPv4Addressr addrdesctupr r
@ s z*Request.setCopyableState..c s t d S )Nr+ )r UNIXAddressr )r0 r r r1 A s )r( r) requestHeadersfinish setHeader addCookiesetETagsetResponseCodesetLastModifiedwriteN)r dictr
RemoteCopysetCopyableStater content_datacontentremote remoteMethodr4 r5 r6 r7 r8 r9 _write)r statekaddrr r. r r= 7 s&
zRequest.setCopyableStatec C s> d}t } | ||| |t 7 }|t 7 }|t|kr dS q)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.
r TN)r rB len)r bytesstartendr r r r: S s z
Request.writec C s | j dt||| j d S )NregisterProducer)r@
callRemoter
addErrbackfail)r r streamingr r r rJ c s
zRequest.registerProducerc C s | j d| j d S )NunregisterProducer)r@ rK rL rM r r r r rO h s zRequest.unregisterProducerc C s | j jd|d d S )N )failure)_logrQ r rQ r r r rM k s z Request.failN) r" r# r$ __doc__r= r: rJ rO rM r r r r r% 1 s r% c @ s* e Zd Ze Zdd Zdd Zdd ZdS )Issuec C r r )request)r rV r r r r u r zIssue.__init__c C s: |t jurt|tsJ d| j| | j d S d S )Nzreturn value not a string)r NOT_DONE_YET
isinstancestrrV r: r4 )r resultr r r finishedx s
zIssue.finishedc
C sL t |}| jttjddt| | j | j
| j | d S )NzServer Connection Lostz&Connection to distributed server lost:)
rY rV r: r ErrorPager
INTERNAL_SERVER_ERRORr _PRErenderr4 rR inforS r r r failed~ s
z Issue.failedN)r" r# r$ r rR r r[ ra r r r r rU r s
rU c @ sJ e Zd ZdZdZe Zdd Zdd Zdd Z d d
Z
d d Z d
d Z dS )ResourceSubscriptionr+ r c C s( t j| || _|| _g | _d | _d S r )r Resourcer r& portpending publisher)r r& rd r r r r s
z ResourceSubscription.__init__c C s( t | j}d|d< d|d< g |d< |S )z3Get persistent state for this ResourceSubscription.Nrf r waitingre )copy__dict__)r rC r r r __getstate__ s
z!ResourceSubscription.__getstate__c C sF | j d |j| j || _d| _| jD ]}| | qg | _dS )z=I've connected to a publisher; I'll now send all my requests.zconnected to publisherr N) rR r` brokernotifyOnDisconnectbootedrf rg re r_ )r rf rV r r r connected s
z ResourceSubscription.connectedc C sD | j jd|d d| _d| _| jD ] }|d | qg | _dS )zXI can't connect to a publisher; I'll now reply to all pending
requests.
z3could not connect to distributed web service: {msg})msgr Nz(Unable to connect to distributed server.)rR r` rg rf re r: r4 )r ro rV r r r notConnected s
z!ResourceSubscription.notConnectedc C s | d d S )Nzconnection dropped)rp r r r r rm r zResourceSubscription.bootedc C s | j s<| j| | js9d| _t }d}| jdkr#t| j || n
t
| j| j || | }| | j
| j tjS t|}| j d| |j|j tjS )a: Render this request, from my server.
This will always be asynchronous, and therefore return NOT_DONE_YET.
It spins off a request to the pb client, and either adds it to the list
of pending issues or requests it immediately, depending on if the
client is already connected.
r+
unixrV )rf re appendrg r PBClientFactoryr& r connectUNIXrd
connectTCP
getRootObject addCallbacksrn rp rU rK r[ ra r rW )r rV bftimeoutdir r r r_ s"
zResourceSubscription.renderN)
r" r# r$ isLeafrg r rR r rj rn rp rm r_ r r r r rb s
rb c @ s: e Zd ZdZe Zdd ZdZdd Zdd Z d d
Z
d S ) ResourcePublisherz
L{ResourcePublisher} exposes a remote API which can be used to respond
to request.
@ivar site: The site which will be used for resource lookup.
@type site: L{twisted.web.server.Site}
c C r r )site)r r r r r r r zResourcePublisher.__init__r, c C s* | j jd | j j| j= | `| ` | `d S )Nweb) application
authorizerremoveIdentityservices serviceNameperspectiveNamer r r r upgradeToVersion2 s
z#ResourcePublisher.upgradeToVersion2c C s | S r r )r namer r r getPerspectiveNamed s z%ResourcePublisher.getPerspectiveNamedc C sD | j |}| j| ||}|tjur || | tjS )zK
Look up the resource for the given request and render it.
) r getResourceForrR r` r_ r rW r: r4 )r rV resrZ r r r remote_request s
z ResourcePublisher.remote_requestN) r" r# r$ rT r rR r persistenceVersionr r r r r r r r~ s r~ c @ s> e Zd ZdZdZdZdZdddZdd Zd
d Z d d
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.
public_htmlz.twistd-web-pba
twisted.web.distrib.UserDirectory
twisted.web.distrib.UserDirectory
%(users)s
Nc C s" t j| |d u r t}|| _d S r )r rc r pwd_pwd)r userDatabaser r r r 7 s
zUserDirectory.__init__c
C s g }| j D ]F}|\}}}}}}} |dd }
|
s |}
tjtj|| jr2|||
d f tj|| j } tj| rM|d } || |
d f q|S )z|
Return a list of two-tuples giving links to user resources and text to
associate with those links.
,r z (file).twistdz (twistd))
r getpwallsplitospathexistsjoin userDirNamers userSocketName)
r usersuserr passwduidgidgecosdirshellrealname
twistdsocklinkNamer r r _users= s zUserDirectory._usersc C s t }|ddd}|j}| D ]*\}}|d}|d|d ||}|| |d} | | || q| jd| i }
|
dS ) zm
Render as HTML a listing of all known users with links to their
personal resources.
Nulahref/lir zutf-8) r createDocumentdocumentElementr
createElement setAttributecreateTextNode appendChildtemplatetoxmlencode) r rV domImplnewDoclistinglinktext linkElementtextNodeitemhtmlDocr r r
render_GETP s
zUserDirectory.render_GETc C s |dkr| S d}|t | d |kr |d t | }d}n|}d}z| j|\}}}} }
} } W n
ty? t Y S w |rWtj| | j }
t
d|
}| || |S tj| | j }tj
|sit S t|S )NrP r r+ r rr )rF r getpwnamKeyErrorr
NoResourcer r r r rb putChildr r r
File)r r rV tdusernamesubpw_name pw_passwdpw_uidpw_gidpw_gecospw_dirpw_shellr rsr r r r getChilde s<
zUserDirectory.getChildr ) r" r# r$ rT r r r r r r r r r r r r s
* r )(rT rh r r ImportErrorior xml.dom.minidomr twisted.internetr r twisted.loggerr twisted.persistedr twisted.spreadr twisted.spread.bananar twisted.webr
r r r
r twisted.web.http_headersr
Referenceabler r< r% setUnjellyableForClassrU rc rb Root Versionedr~ r r r r r s0 >N'