o  j^V @sdZddlZeeZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZmZmZdd l m!Z!ddl"m#Z#ddl$m%Z%ddl$m&Z&ddl'm(Z(ddl'm)Z)ddl'm*Z*zddl+m,Z,Wne-yZ.z e.Z/ddZ,WYdZ.[.ndZ.[.wwzddl0m1Z1Wne-yZ2z e2Z3ddZ1WYdZ2[2ndZ2[2ww  d)ddZ4ddZ5dd Z6d!d"Z7Gd#d$d$eZ8Gd%d&d&eZ9Gd'd(d(eZ:dS)*zU A server that uses http as transport via wsgi. It doesn't contain any server logic. N) isgenerator)chain)AddressFileFault) SimpleCookie)unquotequote)get_fault_string_from_exception)process_contexts)RequestTooLongError)HttpRpc)HttpBaseHttpMethodContextHttpTransportContext)odict)address_parser) LIGHT_GREEN) END_COLOR)HTTP_200)HTTP_404)HTTP_500) apply_mtomcOtN)_local_import_error_1argskwargsrQ/var/www/html/LicenciasMiG/venv/lib/python3.10/site-packages/spyne/server/wsgi.pyr;r)parse_form_datacOrr)_local_import_error_2rrrr r"Cr!r"TcCs8d}|r |dd}|rA|dr||d7}n)||d7}|ddkr3|ddkr2|d |d7}n|dd krA|d |d7}|rt|d dd krZt|d ddd krZn't|d ddddkrw|t|d ddd7}n |t|d d7}|t|d d7}|r|dr|d|d7}|S)zRebuilds the calling url from values found in the environment. This algorithm was found via PEP 333, the wsgi spec and contributed by Ian Bicking. zwsgi.url_schemez:// HTTP_HOST SERVER_NAMEhttps SERVER_PORT443:80 SCRIPT_NAME/ PATH_INFOrz//N QUERY_STRING?)getr )environprotocol server_namepath query_stringurlrrr _reconstruct_urlGs2        r:cCsdd|dD}t}|D]O}|dust|dkrq|dd}t|dkr-|dt|ddd }d}|ddurIt|ddd }||d}|durYg}||<||q|S) Ncss$|] }|dD]}|Vq qdS);N)split).0s1s2rrr ys"z_parse_qs..&r=r0r/+ )r<rlenappendrreplacer3)qspairsretval name_valuenvnamevaluelrrr _parse_qsxs"       rPcCsPi}|D]\}}|dr%|dd}|g}|||<td||q|S)NHTTP_zAdd http header %r = %r)items startswithlowerloggerdebug)req_envrJkvkeyvalrrr _get_http_headerss r]cCsPg}|D]\}}t|ttfr|D] }|||fqq|||fq|Sr)rS isinstancelisttuplerF)headersrJrYrZv2rrr _gen_http_headerssrccsXeZdZdZfddZddZddZdd Zd d Zd d Z ddZ ddZ Z S)WsgiTransportContextz^The class that is used in the transport attribute of the :class:`WsgiMethodContext` class.cs@tt||||||j|_ |dd|_ t|j|_dSNREQUEST_METHOD) superrd__init__reqrXr3 req_methodr]ra)selfparent transportrX content_type __class__rr rhszWsgiTransportContext.__init__cCs t|jSr)r:rXrkrrr get_url zWsgiTransportContext.get_urlcCs |jdS)Nr.)rXrqrrr get_pathrszWsgiTransportContext.get_pathcCs8t|jdd}|jdd}|dur|d|7}|S)Nr.r$r1r2)r rXr3)rkrJrHrrr get_path_and_qss  z$WsgiTransportContext.get_path_and_qscCs8|jdd}|dur dSt}||||djS)N HTTP_COOKIE)rXr3rloadrN)rkr[ cookie_stringcookierrr get_cookies  zWsgiTransportContext.get_cookiecCs|jdSre)riupperrqrrr get_request_methodz'WsgiTransportContext.get_request_methodcCs|jddS)N CONTENT_TYPE)rir3rqrrr get_request_content_typer}z-WsgiTransportContext.get_request_content_typecCsRt|jt|j}}t|rttj||dSt|r'ttj||dSdS)N)typehostport) rget_ipriget_port is_valid_ipv4rTCP4 is_valid_ipv6TCP6)rkaddrrrrr get_peers    zWsgiTransportContext.get_peer) __name__ __module__ __qualname____doc__rhrrrtrurzr|rr __classcell__rrror rds   rdc@seZdZdZdZeZdS)WsgiMethodContextzThe WSGI-Specific method context. WSGI-Specific information is stored in the transport attribute using the :class:`WsgiTransportContext` class. N)rrrrTransportContextrdrrrrr rsrcspeZdZdZ  dfdd Zddd Zd d Zd d ZddZddZ ddZ ddZ ddZ ddZ ZS)WsgiApplicationaA `PEP-3333 `_ compliant callable class. If you want to have a hard-coded URL in the wsdl document, this is how to do it: :: wsgi_app = WsgiApplication(...) wsgi_app.doc.wsdl11.build_interface_document("http://example.com") This is not strictly necessary -- if you don't do this, Spyne will get the URL from the first request, build the wsdl on-the-fly and cache it as a string in memory for later requests. However, if you want to make sure you only have this url on the WSDL, this is how to do it. Note that if your client takes the information in the Wsdl document seriously (not all do), all requests will go to the designated url above even when you get the Wsdl from another location, which can make testing a bit difficult. Use in moderation. Supported events: * ``wsdl`` Called right before the wsdl data is returned to the client. * ``wsdl_exception`` Called right after an exception is thrown during wsdl generation. The exception object is stored in ctx.transport.wsdl_error attribute. * ``wsgi_call`` Called first when the incoming http request is identified as a rpc request. * ``wsgi_return`` Called right before the output stream is returned to the WSGI handler. * ``wsgi_exception`` Called right before returning the exception to the client. * ``wsgi_close`` Called after the whole data has been returned to the client. It's called both from success and error cases. T csHtt|||||t|_d|_|jjdur"|jj |_dSdSr) rgrrh threadingLock_mtx_build_interface_document_wsdldocwsdl11get_interface_document)rkappchunkedmax_content_length block_lengthrorr rhs  zWsgiApplication.__init__NcCsZ|}|durt|dd}||r'|dddd}||||S|||S)a+This method conforms to the WSGI spec for callable wsgi applications (PEP 333). It looks in environ['wsgi.input'] for a fully formed rpc message envelope, will deserialize the request parameters and call the method on the object returned by the get_handler() method. N.wsdlrr2)r:r<is_wsdl_requesthandle_wsdl_request handle_rpc)rkrXstart_responsewsgi_urlr9rrr __call__%s  zWsgiApplication.__call__cCs@|ddkod|vo|ddddkp|ddS) NrfGETr1rBrwsdlr.r)r{r<rUendswith)rkrXrrr r8s  zWsgiApplication.is_wsdl_requestc Cszt||d}|jjdur|tt|jjtgS|jdur$|jj|_|j|j_ |jj durz`z$|j |j|j_ |jj durS|jj ||jj|j_ |_Wn4t y}z(t|||j_|jd||tt|jjtgWYd}~W|j Sd}~wwW|j n|j w|jd|tt|jj |jjd<|tt|jj|jj }||gS)Nztext/xml; charset=utf-8wsdl_exceptionrContent-Length)rrrrrcrm resp_headersrrrracquirebuild_interface_document ExceptionrV exception wsdl_error event_manager fire_eventrreleasestrrErclose)rkrXrr9ctxerJrrr rHsL                z#WsgiApplication.handle_wsdl_requestc Cs|jjdur|j||j_||t|j|_ttdd|jD|jj d<|j d|||jjt |jj z t ||||dWnty\}z t|WYd}~nd}~wwt|j||S)a)Serialize errors to an iterable of strings and return them. :param p_ctx: Primary (non-aux) context. :param others: List if auxiliary contexts (can be empty). :param error: One of ctx.{in,out}_error. :param start_response: See the WSGI spec for more info. Ncss|]}t|VqdSrrE)r=srrr r@sz/WsgiApplication.handle_error..rwsgi_exceptionerror)rm resp_code out_protocolfault_to_http_response_codeget_out_stringr_ out_stringrsumrrrrcr rrVrr_WsgiApplication__finalize)rkp_ctxothersrrrrrr handle_errorzs$     zWsgiApplication.handle_errorc Cst|||jjj}|jd|||\|_}|||}|d|dd}}d|_ |j r8| |||j |S| ||j rOt |j | |||j |S|||jr`| |||j|S|jdusgJtt|j}t|jdkoxt|} | rt|} t| f|f|_|jjdurt|j_z||Wn(ty} zt | tdt| |_| |||j|WYd} ~ Sd} ~ wwt|jt r|j!dur|jj"#|j!|j$r|j$j%r|j$j&j'} t| dkr|jg|_t(|jj"|j)|j$j&j'*|j\|j_"|_)|jd||j+rd|jj"vr|jj"d=nd,|j)g|_)zt|j)t-t.d d |j)D|jj"d<Wn t/yCYnw||jjt0|jj"t|j)|1|} z t2|||dd W| Sty|} z t | WYd} ~ | Sd} ~ ww) N wsgi_callrr0TServer wsgi_returnrr$cSsg|]}t|qSrr)r=arrr sz.WsgiApplication.handle_rpc..r)3rrr mime_typerr*_WsgiApplication__reconstruct_wsgi_request in_stringgenerate_contextsactivein_errorr get_in_objectrVrget_out_object out_error out_objectnextiterrErrrmrrrrrrr r^r out_header_docrupdate descriptormtom out_message _type_inforrvaluesrjoinrr TypeErrorrcrr )rkrXr initial_ctxin_string_charsetcontextsrrg is_generator first_objr out_type_inforJrrr rs                    zWsgiApplication.handle_rpccCs||jd|dS)N wsgi_closer)rrr)rkrrrr __finalizeszWsgiApplication.__finalizecCs>|d}d}|durt|}|ddd}|||fS)z>Reconstruct http payload using information in the http header.r~Nr0charset)r3cgi parse_header(_WsgiApplication__wsgi_input_to_iterable)rkhttp_envrnrrrr __reconstruct_wsgi_request s  z*WsgiApplication.__reconstruct_wsgi_requestccs|d}t|d|j}t|dkrd}nt|}||jkr$td}||kr\t|j||}|||jkrsZ                1  8