"j9 6 d Z dZddlZddlZddlZddlZddlZddlZddlZddl m
Z ddl m Z
ddlmZ ddlmZ ddlmZ ej( e Zd Zd
Z G d d e
j2 Z G d
dej6 e
j8 Z d Z edk( r e d y)ae
ext_wsgiutils_server.py is an extension of the wsgiutils server in Paste.
It supports passing all of the HTTP and WebDAV (rfc 2518) methods.
It includes code from the following sources:
``wsgiServer.py`` from wsgiKit under PSF license,
``wsgiutils_server.py`` from Paste under PSF license,
flexible handler method
under public domain.
Running as standalone server
----------------------------
To run as a standalone server using the bundled ext_wsgiutils_server.py::
usage: python ext_wsgiutils_server.py [options] [config-file]
config-file:
The configuration file for WsgiDAV. if omitted, the application
will look for a file named 'WsgiDAV.conf' in the current directory
options:
--port=PORT Port to serve on (default: 8080)
--host=HOST Host to serve from (default: localhost, which is only
accessible from the local computer; use 0.0.0.0 to make your
application public)
-h, --help show this help message and exit
Running using other web servers
-------------------------------
To run it with other WSGI web servers, you can::
from wsgidav.mainappwrapper import PyFileApp
publish_app = PyFileApp('WsgiDAV.conf')
# construct the application with configuration file
# if configuration file is omitted, the application
# will look for a file named 'WsgiDAV.conf'
# in the current directory
where ``publish_app`` is the WSGI application to be run, it will be called with
``publish_app(environ, start_response)`` for each incoming request, as described in
`WSGI `_
Note: if you are using the paster development server (from Paste ), you
can copy ``ext_wsgi_server.py`` to ``/paste/servers`` and use this server to
run the application by specifying ``server='ext_wsgiutils'`` in the ``server.conf`` or appropriate
paste configuration.
reStructuredText N)client)server)StringIO)urlparse)utilg ?z
Server Error
Server Error
A server error has occurred. Please contact the system administrator for
more information.
c e Zd Zg dZdZej de dej j Z
d Z d Z d Z
d Zd Zd
Zd Zdd
Zd Zy )
ExtHandler)HEADGETPUTPOSTOPTIONSTRACEDELETEPROPFIND PROPPATCHMKCOLCOPYMOVELOCKUNLOCKzHTTP/1.1z ExtServer/ c y N selfargss R/srv/dav/.venv/lib/python3.12/site-packages/wsgidav/server/ext_wsgiutils_server.py log_messagezExtHandler.log_messageq c y r r r s r log_requestzExtHandler.log_requestv r" r# c J t d| j d \ }}}}}}| j j D ]i \ }}|j | s|t | d } t | dkD r| j d sd| z } |j
d r|d d }
n|}
||
| |fc S y)Nzhttp://dummyhostF)allow_fragmentsr /)NNNN)r pathr wsgiApplications
startswithlenendswith) r _protocol_hostr* _parametersquery _fragmentappPathapp path_info script_names r getAppzExtHandler.getApp{ s @H tyyk *EA
= 5$ UI !KK 8 8 :LGSw' W 0 y>A%$//4$')O ##C(")#2,K")KKE99 : &r# c fd}|S )Nc & j y r ) do_method)r kwargsr s r handlerFunctionz:ExtHandler.handlerFunctionClosure..handlerFunction s
NN r# r )r namer= s ` r handlerFunctionClosurez!ExtHandler.handlerFunctionClosure s r# c | j \ }}}}|s| j dd y | j |||| y )Ni zApplication not found.)r8
send_error
runWSGIApp)r r5 r7 r6 r2 s r r; zExtHandler.do_method s= -1[[]*[)U OOC!9 : [)U;r# c t | dkD r*|dd dk( r"|dd | j v r| j | S |dk( rt | j dd y )N r do__headers_bufferi zMethod Not Implemented.)r- _SUPPORTED_METHODSr? AttributeErrorrA )r r> s r __getattr__zExtHandler.__getattr__ s_ t9q=T!AY% /DH@W@W4W..t4 4
&
& 67r# c | j dk( r i ddddd| j dt j dd d
d d d d
| j d|d|d|d| j j dd d| j j dd d| j d d| j j d dt j | j j d d| j }| j j D ]J \ }}|j dvs||dj |j d d j! < L d | _ g | _ t& j) d ||| j* } |D ]+ } | r| j- | t& j) d - t& j) d t/ |d! r|j1 | j" s| j- d& y # t& j) d t/ |d! r|j1 w w xY w# t2 $ r t& j) d" t5 }
t7 j8 |
# t; j< |
j? | j" s| j+ d$d%g | j- t@ Y w xY w)'Nr
z wsgi.version) r zwsgi.url_schemehttpz
wsgi.inputz wsgi.errorszwsgi.multithreadrK zwsgi.multiprocessr z
wsgi.run_onceREQUEST_METHOD SCRIPT_NAME PATH_INFO QUERY_STRING CONTENT_TYPEz Content-Type CONTENT_LENGTHzContent-Length REMOTE_ADDR SERVER_NAME SERVER_PORTSERVER_PROTOCOL)z content-typezcontent-lengthzHTTP_{}-_zrunWSGIApp application()...zrunWSGIApp empty datazrunWSGIApp finally.closez runWSGIApp caught exception...filez500 Server Error)z Content-typez text/htmlr# )!commandrfilesysstderrheadersgetclient_addressr server_addressr to_strrequest_versionitemslowerformatreplaceupperwsgiSentHeaders wsgiHeaders_loggerdebugwsgiStartResponse
wsgiWriteDatahasattrrZ Exceptionr traceback print_excloggingerrorgetvalue SERVER_ERROR) r applicationr7 r6 r2 env
httpHeader httpValueresultdataerrorMsgs r rB zExtHandler.runWSGIApp s <<5
F
v
$**
3::
Q
dll
;
E
DLL , ,^R @
dll . ./? D
4..q1
4;;55a8
4;;t{{'A'A!'DE!
"
t 3 3#
& &*\\%7%7%9 X !J !)KKNWI$$Z%7%7S%A%G%G%IJK X
! - MM7 8 d&<&<=F
# " ?D **40
&=> ?
3467+LLN ##
s #'
3467+LLN , - MM: ; zH X . MM(++- .''&&&)F(G
| , -s+ *(I 0H 2I 4II BK#"K#Nc t j d| d| d| d | j r t d ||f| _ | j
S )NzwsgiStartResponse(z, )z5Headers already sent and start_response called again!)rn ro rl rs rm rq )r response_statusresponse_headersexc_infos r rp z ExtHandler.wsgiStartResponse s[
14D3ERzQR S
ST T +-=>!!!r# c
X | j s| j \ }}|d |j d }||j d dz d }t j d|d| | j t
| | |D ] \ }}| j || | j d| _ t | t u sJ t j dt | dt j |d d d t j | r-t j d | t j | } | j" j% | y # t& $ rC}|j( d
d v r't j d |t* j,
n Y d }~y d }~ww xY w)Nr rK z wsgiWriteData: send headers 'z', zwsgiWriteData: write z bytes: '2 z'...z(ext_wsgiutils_server: Got unicode data: r iE' iF' z*** Caught socket.error: %sr[ )rl rm findrn ro
send_responseint send_header end_headerstypebytesr- r re is_strinfoto_byteswfilewriteOSErrorr r_ r` ) r r statusra
statusCode statusMsgheadervaluees r rq zExtHandler.wsgiWriteData s~ ## " . .OFG 2&++c"23J v{{3 /! 3 56I MM 9&3wkR S s: :!(
0
/
0 #$D DzU"""
#CI;i D"I8N7QQU V
;;t LLCD8L M==&D JJ T " vvayN* :ACJJ O P s E F)&9F$$F)r )__name__
__module__ __qualname__rG protocol_versionr public_wsgidav_info_versionBaseHTTPServerBaseHTTPRequestHandlerserver_versionr! r% r8 r? r; rI rB rp rq r r# r r
r
Z sk $ " 001XJaHmHmH|H|G}~N
&* <@D" r# r
c & e Zd Zd Zd Zd ZddZy) ExtServerc H t j }|d }|j d dv rt j d| yt j dt j
t j dt
j j d | t j |t j
t j t j dt j
t j |t j
y)
z{Handle an error gracefully. May be overridden.
The default is to _logger.info a traceback and continue.
rK r r z*** Caught socket.error: Nz(----------------------------------------r[ Exception happened during processing of request from ) r_ r r rn rw r` threadingcurrent_threadidentrt ru )r requestrc eir s r handle_errorzExtServer.handle_error s \\^ qE
66!9 & MM 5aS9 :
hSZZ
0
((*0011hiwhx y
n3::
6
hSZZ
0
gCJJ
/r# c t | d sJ d | j rJ d d| _ t j d | j ryd }t t
d s |t
_ | j \ }}t j | d | }|j d
d |j | j sJ y) z Stop serve_forever_stoppable(). stop_requestz/serve_forever_stoppable() must be called beforez-stop_serve_forever() must only be called onceTg?Nc h | j d | j d| j _ y)zSend 200 OK response, and set server.stop_request to True.
http://code.activestate.com/recipes/336012/
TN)r r r r r s r _shutdownHandlerz6ExtServer.stop_serve_forever.._shutdownHandler? s*
s # '+DKK $r# do_SHUTDOWN:SHUTDOWNr( ) rr r timesleepstoppedr
r rd http_clientHTTPConnectionr getresponse)r r hostportconns r stop_serve_foreverz ExtServer.stop_serve_forever0 s t^,
=
, $$U&UU$ !
3 << , z=1%5J " ** t))TF!D6*:; Z% r# c d| _ d| _ | j s | j | j s d| _ y)zvHandle one request at a time until stop_serve_forever().
http://code.activestate.com/recipes/336012/
FTN)r r handle_requestr s r serve_forever_stoppablez!ExtServer.serve_forever_stoppableV s<
" ## ! ## r# c t j j | |t g }|j D ] \ }}|j ||f || _ || _ d| _ y )Nr ) r
HTTPServer__init__r
rg appendr+
serveFilesserverShuttingDown)r
serverAddressr+ r appListurlPathwsgiApps r r zExtServer.__init__d sd !!**4
K 0 6 6 8 / GW NNGW- . / ' $"# r# N)rK )r r r r r r r r r# r r r s 06$!L $r# r c | j dd }t | j dd }t ||fd|i }t j }| j d dk\ rt
j
d| |d v rNt j t j \ }}}t
j
d
| d | d |d
| d n t
j
d
| d | d |j y )Nr localhostr i rR verboserK zRunning )rR z0.0.0.0z Serving at z, port z (host=r z)...z...) rb r r r
r rn r socketgethostbyname_ex gethostname
serve_forever) confr5 r r r r hostname
_aliaslist
ipaddrlists r server n s 88FK (D txx% &D
d|b#Y
/F ..N xx a x /01 ? "171H1H""$2 .Xz:
LL dV74&|1ZLPTU
LL;tfGD6= >
r# __main__zUse run_server.py) __doc__
__docformat__rv r socketserverr_ r r rt rL r r r r ior urllib.parser wsgidavr get_module_loggerr rn r ry r r
ThreadingMixInr r r RuntimeErrorr r# r r s 2h #
& ) !
$
* w 66 wtW$ ++^-F-F W$t( z
*
++ r#