a mzfe@s<dZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddl mZddl mZdd lmZdd lmZdd lmZdd lmZmZmZdd lmZgdZGdddZddZGdddeZeZ GdddeZ!ddZ"ddZ#d!ddZ$GdddZ%e&d kr8ddl'Z'e'(dS)"z Web application (from web.py) N)isclass)BytesIO)browser httpserverutils)webapi)wsgi) debugerror) iteritems)lstrips)urlparse urlencodeunquote)reload) applicationauto_applicationsubdir_applicationsubdomain_applicationloadhook unloadhook autodelegatec@seZdZdZdidfddZddZdd Zd d Zd d ZddZ ddZ d6ddZ ddZ ddZ ddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zgfd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5ZdS)7ra Application to delegate requests based on path. >>> urls = ("/hello", "hello") >>> app = application(urls, globals()) >>> class hello: ... def GET(self): return "hello" >>> >>> app.request("/hello").data 'hello' Ncs|durtjdd}||_g_tjt j |rddfdd}t ||||fdd}tt rr|t|rd tjvrztWntyYn0dS) NdebugFcSs2tjd}t|dd}|o0tjtj|dS)N__main____file__r)sysmodulesgetattrospathsplitextbasename)modfilerr=/var/www/media/lib/python3.9/site-packages/web/application.pymain_module_name@s  z.application.__init__..main_module_namecs<|d|d}}|dus&|dur*dS|dkr8}|S)z(find name of the module name from fvars.r__name__Nr)get)fvarsr$name)r&rr%modnameGs z%application.__init__..modnamecs6tdddg}t|d}|r2|j_|dS)z%loadhook to reload mapping and fvars.N) __import__r__dict__r) init_mapping)r#mapping) mapping_name module_nameselfrr%reload_mappingVs  z,application.__init__..reload_mappingr)webconfigr(r/r) processors add_processorr_loadr_unloadrZdictfindReloaderrargvr- ImportError)r3r0r)Z autoreloadr+r4r)r&r1r2r3r%__init__4s,   zapplication.__init__cCstjj|dSN)r5ctx app_stackappendr3rrr%r9nszapplication._loadcCsXtjjddtj_tjjrTtjd}|rT|jtj_|jtj_|jtj_|jtj_dS)N_oldctx)r5r@rAr(homehomepathr fullpath)r3Zoldctxrrr%r:qs    zapplication._unloadcCstjdSr?)rZ ThreadedDictZ clear_allrCrrr%_cleanup}szapplication._cleanupcCstt|d|_dS)N)listrgroupr0)r3r0rrr%r/szapplication.init_mappingcCs|j||fdSr?)r0rB)r3pattern classnamerrr% add_mappingszapplication.add_mappingcCs|j|dS)a Adds a processor to the application. >>> urls = ("/(.*)", "echo") >>> app = application(urls, globals()) >>> class echo: ... def GET(self, name): return name ... >>> >>> def hello(handler): return "hello, " + handler() ... >>> app.add_processor(hello) >>> app.request("/web.py").data 'hello, web.py' N)r7rB)r3 processorrrr%r8szapplication.add_processor/GET 0.0.0.0:8080Fc s(t|}|j} |j} | pd} d|vr.|d} ni} t| ||| | t|d} |pPi}|D] \} }|| d| dd<qZd| vr| d| d<d | vr| d | d <|d vr|pd}t |trt |}n|}t | d | d <d| vrt || d<tfdd}|| |}d|_S)aMakes request to this application for the specified path and method. Response will be a storage object with data, status and headers. >>> urls = ("/hello", "hello") >>> app = application(urls, globals()) >>> class hello: ... def GET(self): ... web.header('Content-Type', 'text/plain') ... return "hello" ... >>> response = app.request("/hello") >>> response.data 'hello' >>> response.status '200 OK' >>> response.headers['Content-Type'] 'text/plain' To use https, use https=True. >>> urls = ("/redirect", "redirect") >>> app = application(urls, globals()) >>> class redirect: ... def GET(self): raise web.seeother("/foo") ... >>> response = app.request("/redirect") >>> response.headers['Location'] 'http://0.0.0.0:8080/foo' >>> response = app.request("/redirect", https=True) >>> response.headers['Location'] 'https://0.0.0.0:8080/foo' The headers argument specifies HTTP headers as a mapping object such as a dict. >>> urls = ('/ua', 'uaprinter') >>> class uaprinter: ... def GET(self): ... return 'your user-agent is ' + web.ctx.env['HTTP_USER_AGENT'] ... >>> app = application(urls, globals()) >>> app.request('/ua', headers = { ... 'User-Agent': 'a small jumping bean/1.0 (compatible)' ... }).data 'your user-agent is a small jumping bean/1.0 (compatible)' r,env) HTTP_HOSTREQUEST_METHOD PATH_INFO QUERY_STRINGHTTPSZHTTP_-_ZHTTP_CONTENT_LENGTHCONTENT_LENGTHZHTTP_CONTENT_TYPE CONTENT_TYPE)HEADrRutf-8z wsgi.inputcs|_t|_|_dSr?)statusdictheaders header_items)r`rbresponserr%start_responses z+application.request..start_response)r r queryrastritemsupperreplacepop isinstancerrencodelenr5storagewsgifuncjoindata)r3Z localpartmethodrthostrbhttpskw_pr Z maybe_queryrhrTkvqrfrrdr%requestsF;      zapplication.requestcCs t|Sr?)rZ AppBrowserrCrrr%r szapplication.browsercCs&||jtjj\}}|||j|Sr?)_matchr0r5r@r _delegater))r3fnargsrrr%handle szapplication.handlecsfddjS)Nc sz<r0ddd}|fddWSWSWnPtjyRYn<ttfyhYn&tttjd Yn0dS)NrrcsSr?rr)processr7rr%rgzEapplication.handle_with_processors..process..)r$) rr5 HTTPErrorKeyboardInterrupt SystemExitprint traceback format_excr internalerror)r7prr3r7r%rsz3application.handle_with_processors..processrrCrrr%handle_with_processorssz"application.handle_with_processorscs,ddfdd}|D] }||}q|S)z8Returns a WSGI-compatible function for this application.cSs2z t|}Wnty"d}Yn0t|g|S)ziPeeps into an iterator by doing an iteration and returns an equivalent iterator. r,)next StopIteration itertoolschain)iteratorZ firstchunkrrr%peep's    z"application.wsgifunc..peepc s|zFtjjtjjkr0t}|rPt|drP|}n|g}Wn.tj y}z|j g}WYd}~n d}~00dd}||}tjj tjj }}|||fdd}t ||S)N__next__css0|D]&}t|tr|Vqt|dVqdS)Nr_)rnbytesriro)resultrrrr% build_resultGs z8application.wsgifunc..wsgi..build_resultc3sdVdS)Nrg)rIrrCrr%cleanupSsz3application.wsgifunc..wsgi..cleanup)rIloadr5r@rurknomethodrhasattrrrtr`rbrr)rTZ start_resprerr`rbrrr3rr%r 5s"     z"application.wsgifunc..wsgir)r3 middlewarer mrrr%rr$s $ zapplication.wsgifunccGst|j|S)a Starts handling requests. If called in a CGI or FastCGI context, it will follow that protocol. If called from the command line, it will start an HTTP server on the port named in the first command line argument, or, if there is no argument, on port 8080. `middleware` is a list of WSGI middleware which is applied to the resulting WSGI function. )r Zrunwsgirr)r3rrrr%run^s zapplication.runcCstjrtjdt_dS)z%Stops the http server started by run.N)rserverstoprCrrr%rjs zapplication.stopcGsH|j|}zddlm}||WStyBtj|YS0dS)z Return a CGI handler. This is mostly useful with Google App Engine. There you can just do: main = app.cgirun() r run_wsgi_appN)rr google.appengine.ext.webapp.utilrr=wsgirefhandlers CGIHandlerr)r3rwsgiapprrrr%cgirunps     zapplication.cgiruncGs|j|}zftjdd}|d}|d}|dkr:td|dkrH|WS|dkrfddlm}||WStd Wn"tytj |YS0dS) aI Starts the program in a way that will work with Google app engine, no matter which version you are using (2.5 / 2.7) If it is 2.5, just normally start it with app.gaerun() If it is 2.7, make sure to change the app.yaml handler to point to the global variable that contains the result of app.gaerun() For example: in app.yaml (where code.py is where the main code is located) handlers: - url: /.* script: code.app Make sure that the app variable is globally accessible NrJrrz2Google App Engine only supports python 2.5 and 2.7rz/Not a supported platform, use python 2.5 or 2.7) rrr version_infoEnvironmentErrorrrr=rrrr)r3rrversionmajorminorrrrr%gaeruns&    zapplication.gaeruncCstj}|d|_g|_d|_||_|_|d|_ |ddvrR|d|_ n"|dd dvrnd|_ nd |_ |j d |dd |_ t jd |d d|_|j |j|_|j|_|d|_|d|_zt|ddd|_Wn ty|d|_Yn0|dddrNt|ddd|j|_t|j|_|drnd|dd|_nd|_|j|j|_t|D]&\}}t|tr|dd||<qd|_g|_dS)zInitializes ctx using env.z200 OKr,rUzwsgi.url_scheme)httprwrY)ontrue1rwrz://z [unknown]ZREAL_SCRIPT_NAMEZ SCRIPT_NAMEZ REMOTE_ADDRrVrWlatin1utf8SERVER_SOFTWARE)z lighttpd/znginx/Z REQUEST_URI?rrXr_rlN) r5r@clearr`rboutputenvironrTr(rvprotocollowerZ homedomainrrGrFZrealhomeiprurdecoder UnicodeDecodeError startswithr splitrrhrHr rnrA)r3rTr@rzr{rrr%rsD        zapplication.loadc sfdd}|durtnt|tr0|St|r@||St|tr|dr|ddd}tj j dkrtj j dd}|r|d |7}t |n.handle_classz redirect  rrRrXr,r.__call__)r5notfoundrnrrrrirrr@rurTr(redirectrsplitr-rr) r3fr)rrurlxr#rrrr%rs0          zapplication._delegatecs|D]\ttr@|rfdd}|dfSqn:ttrdtdf|\}ntdf|}|rdd|DfSqdS)Ncs Sr?)_delegate_sub_applicationrpatr3whatrr%rrgz$application._match..z^%s\ZcSsg|]}|qSrr.0rrrr% rgz&application._match..NN) rnrrrirre_subm re_compilematchgroups)r3r0valuerrrrr%r~ s     zapplication._matchcCshttjtj_tjj|7_tjj|7_tjjt|dtj_tjjt|dtj_| S)aDeletes request to sub application `app` rooted at the directory `dir`. The home, homepath, path and fullpath values in web.ctx are updated to mimic request to the subapp and are restored after it is handled. @@Any issues with when used with yield? N) r5rqr@rErFrGr rprHr)r3dirZapprrr%rs z%application._delegate_sub_applicationcCs6|tjjvr2tjj|}|dkr2tjj|dSdS)Nrr)r5r@rAindex)r3rrrr%get_parent_app*s zapplication.get_parent_appcCs |}|r|StSdS)z.Returns HTTPError with '404 not found' messageN)rrr5Z _NotFoundr3parentrrr%r0szapplication.notfoundcCs2|}|r|Stjdr&tStSdS)z3Returns HTTPError with '500 internal error' messagerN)rrr5r6r(r Z_InternalErrorrrrr%r8s  zapplication.internalerror)rQrRNrSNF)r' __module__ __qualname____doc__r>r9r:rIr/rOr8r}rrrrrrrrrrrr~rrrrrrrr%r%s<:  o: /7 $rcsfdd}|S)Ncs4t|}|dd|dd|j|j|S)Nr. __weakref__)varscopyrmr' __bases__)rbodymclsrr% decoratorDs   z!with_metaclass..decoratorr)rrrrr%with_metaclassCs rc@seZdZdZddZdS)raApplication similar to `application` but urls are constructed automatically using metaclass. >>> app = auto_application() >>> class hello(app.page): ... def GET(self): return "hello, world" ... >>> class foo(app.page): ... path = '/foo/.*' ... def GET(self): return "foo" >>> app.request("/hello").data 'hello, world' >>> app.request('/foo/bar').data 'foo' cs>tGfdddt}t|Gddd}|_dS)NcseZdZfddZdS)z+auto_application.__init__..metapagecs8t|||||dd|}|dur4||dS)Nr rQ)typer>r(rO)klassr*basesattrsr rCrr%r>fsz4auto_application.__init__..metapage.__init__N)r'rrr>rrCrr%metapageesrc@seZdZdZdS)z'auto_application.__init__..pageN)r'rrr rrrr%pageosr)rr>rrr)r3rrrrCr%r>bs   zauto_application.__init__N)r'rrrr>rrrr%rNsrc@s eZdZdZddZddZdS)raM Application to delegate requests based on the host. >>> urls = ("/hello", "hello") >>> app = application(urls, globals()) >>> class hello: ... def GET(self): return "hello" >>> >>> mapping = (r"hello\.example\.com", app) >>> app2 = subdomain_application(mapping) >>> app2.request("/hello", host="hello.example.com").data 'hello' >>> response = app2.request("/hello", host="something.example.com") >>> response.status '404 Not Found' >>> response.data 'not found' cCs4tjjdd}||j|\}}|||j|S)N:r)r5r@rvrr~r0rr))r3rvrrrrr%rszsubdomain_application.handlecCsn|D]d\}}t|tr2td|d||\}}ntd|d|}|r|dd|DfSqdS)N^$cSsg|]}|qSrrrrrr%rrgz0subdomain_application._match..r)rnrirrrrr)r3r0rrrrrrr%r~s  zsubdomain_application._matchN)r'rrrrr~rrrr%rzsrcsfdd}|S)z Converts a load hook into an application processor. >>> app = auto_application() >>> def f(): "something done before handling request" ... >>> app.add_processor(loadhook(f)) cs |Sr?r)handlerhrr%rPszloadhook..processorrrrPrrr%rs rcsfdd}fdd|S)z Converts an unload hook into an application processor. >>> app = auto_application() >>> def f(): "something done after handling request" ... >>> app.add_processor(unloadhook(f)) csDz |}WnYn0|r6t|dr6|S|SdS)Nr)r)rrrwraprr%rPs zunloadhook..processorc3s>fdd}tz |VWqty6YdS0qdS)Ncs$z tWSYn0dSr?)rr)rrrr% next_hooks  z+unloadhook..wrap..next_hook)iterr)rrr)rr%rs   zunloadhook..wraprrrrr%rs  rr,csfdd}|S)a0 Returns a method that takes one argument and calls the method named prefix+arg, calling `notfound()` if there isn't one. Example: urls = ('/prefs/(.*)', 'prefs') class prefs: GET = autodelegate('GET_') def GET_password(self): pass def GET_privacy(self): pass `GET_password` would get called for `/prefs/password` while `GET_privacy` for `GET_privacy` gets called for `/prefs/privacy`. If a user visits `/prefs/password/change` then `GET_password(self, '/change')` is called. cs|d|vr,|dd\}}|}d|g}n |}g}t||rpzt|||WStyltYqx0ntdS)NrQr)rrr TypeErrorr5r)r3argfirstrestfuncrprefixrr%internals   zautodelegate..internalr)r r rr r%rs rc@s>eZdZdZejdrdZndZddZddZ d d Z d S) r;z[Checks to see if any loaded modules have changed on disk and, if so, reloads them. javaz $py.classz.pyccCs i|_dSr?)mtimesrCrrr%r>szReloader.__init__cCs&ttj}|D]}||qdSr?)rKrrvaluescheck)r3Z sys_modulesr#rrr%rszReloader.__call__c Cs|rt|dr|jsdSzt|jj}WnttfyBYdS0|j|jj rtj |jddrt t|jddj|}||j vr||j |<n8|j ||krzt|||j |<WntyYn0dS)NrrD)rrrstatst_mtimeOSErrorIOErrorendswith __class__SUFFIXr existsmaxr rr=)r3r#mtimerrr%rs$    zReloader.checkN) r'rrrrplatformrrr>rrrrrr%r;s r;r)r,))rrrrrZwsgiref.handlersrinspectriorr,rrrrr5r r Z py3helpersr r urllib.parser rr importlibr__all__rrrrrrrrr;r'doctesttestmodrrrr%s@         " )(+ ',