codekingpro/portable-devtools
114k
1�
2 ��j;+ � � � S r SSKrSSKJr SSKrSSKrSSKJr SSKJ r SSKJ3r4 SSK J r SSK
Jr SS KJrJrJrJrJrJr SS5KJr SSKr\R0 ( a SS KJr SS KJr S
\ S\ 4S jr " S S5 r \6RB r"g)a WSGI support for the Tornado web framework.7 8WSGI is the Python standard for web servers, and allows for interoperability9between Tornado and other Python web frameworks and servers.10 11This module provides WSGI support via the `WSGIContainer` class, which12makes it possible to run applications using other WSGI frameworks on13the Tornado HTTP server. The reverse is not supported; the Tornado14`.Application` and `.RequestHandler` classes are designed for use with15the Tornado `.HTTPServer` and cannot be used in a generic WSGI16container.17 18� N)�BytesIO)�dummy_executor)�escape)�httputil)�IOLoop)�19access_log)�List�Tuple�Optional�Callable�Any�Dict)�
TracebackType)�Type)�WSGIApplication�s�returnc �R � [ U [ 5 ( d eU R S5 $ )N�latin1)�20isinstance�bytes�decode)r s �RD:\code\apps\devtools\python\user_packages\Python313\site-packages\tornado/wsgi.py� to_wsgi_strr 6 s$ � � �a�� � � � � �8�8�H� � � c � � \ rS rSrSr SSSS\\R R SS4S jjr S \21R SS4S22 jr S \23R SS4S jr
S \24R S\\\4 4S jrS
\S \25R SS4S jrSrg)�
WSGIContainer�; a� Makes a WSGI-compatible application runnable on Tornado's HTTP server.26 27.. warning::28 29 WSGI is a *synchronous* interface, while Tornado's concurrency model30 is based on single-threaded *asynchronous* execution. Many of Tornado's31 distinguishing features are not available in WSGI mode, including efficient32 long-polling and websockets. The primary purpose of `WSGIContainer` is33 to support both WSGI applications and native Tornado ``RequestHandlers`` in34 a single process. WSGI-only applications are likely to be better off35 with a dedicated WSGI server such as ``gunicorn`` or ``uwsgi``.36 37Wrap a WSGI application in a `WSGIContainer` to make it implement the Tornado38`.HTTPServer` ``request_callback`` interface. The `WSGIContainer` object can39then be passed to classes from the `tornado.routing` module,40`tornado.web.FallbackHandler`, or to `.HTTPServer` directly.41 42This class is intended to let other frameworks (Django, Flask, etc)43run on the Tornado HTTP server and I/O loop.44 45Realistic usage will be more complicated, but the simplest possible example uses a46hand-written WSGI application with `.HTTPServer`::47 48 def simple_app(environ, start_response):49 status = "200 OK"50 response_headers = [("Content-type", "text/plain")]51 start_response(status, response_headers)52 return [b"Hello world!\n"]53 54 async def main():55 container = tornado.wsgi.WSGIContainer(simple_app)56 http_server = tornado.httpserver.HTTPServer(container)57 http_server.listen(8888)58 await asyncio.Event().wait()59 60 asyncio.run(main())61 62The recommended pattern is to use the `tornado.routing` module to set up routing63rules between your WSGI application and, typically, a `tornado.web.Application`.64Alternatively, `tornado.web.Application` can be used as the top-level router65and `tornado.web.FallbackHandler` can embed a `WSGIContainer` within it.66 67If the ``executor`` argument is provided, the WSGI application will be executed68on that executor. This must be an instance of `concurrent.futures.Executor`,69typically a ``ThreadPoolExecutor`` (``ProcessPoolExecutor`` is not supported).70If no ``executor`` is given, the application will run on the event loop thread in71Tornado 6.3; this will change to use an internal thread pool by default in72Tornado 7.0.73 74.. warning::75 By default, the WSGI application is executed on the event loop's thread. This76 limits the server to one request at a time (per process), making it less scalable77 than most other WSGI servers. It is therefore highly recommended that you pass78 a ``ThreadPoolExecutor`` when constructing the `WSGIContainer`, after verifying79 that your application is thread-safe. The default will change to use a80 ``ThreadPoolExecutor`` in Tornado 7.0.81 82.. versionadded:: 6.383 The ``executor`` parameter.84 85.. deprecated:: 6.386 The default behavior of running the WSGI application on the event loop thread87 is deprecated and will change in Tornado 7.0 to use a thread pool by default.88N�wsgi_application� WSGIAppType�executorr c �< � Xl Uc [ U l g UU l g �N)r r r! )�selfr r! s r �__init__�WSGIContainer.__init__} s � �89 !1� �*2�*:���
���
r �requestc �b � [ R " 5 R U R U5 g r# )r �current�spawn_callback�handle_request)r$ r' s r �__call__�WSGIContainer.__call__� s � �����'�'��(;�(;�W�Er c � � ^^^# � 0 m/ m SS[ S[ [ [ [ 4 S[ [ S[ [ [ [90 4 S[ [ /[ 4 4UU4S jjjn[ R " 5 nUR U R U R U R U5 U5 I S h v�N n [ U5 mS[ [ 4U4S jjn UR U R U5 I S h v�N nUc OTR! U5 M; [# US5 ( a UR% 5 S R' T5 nT( d [) S915 eTS R+ S S 5 u p�[- U5 n92TS n U V V
s1 s H u p�U R/ 5 iM nn n
[0 R2 " U5 nU93S
:w aB SU; a% U R! S[ [5 U5 5 45 SU; a U R! S5 SU; a$ U R! SS[6 R8 - 45 [: R< " SX�5 n[: R> " 5 nU H u nnURA UU5 M URB c eURB RE UUUS9 URB RG 5 U RI X�5 g GN GN�! [# US5 ( a UR% 5 f f = fs sn
n f 7f)N�status�headers�exc_infoz Optional[Type[BaseException]]r c �0 >� U TS' UTS' TR $ )Nr/ r0 )�append)r/ r0 r1 �data�responses ��r �start_response�4WSGIContainer.handle_request.<locals>.start_response� s! �� � $�D��N� %�D��O��?�?� "r c �< >� [ T 5 $ ! [ a g f = fr# )�next�
StopIteration)�app_response_iters �r �94next_chunk�0WSGIContainer.handle_request.<locals>.next_chunk� s( �� � � � 1�2�2��$� � � �s �95 �96��closer z$WSGI app did not call start_response� � i0 zcontent-length�Content-Lengthz content-type)� Content-Typeztext/html; charset=UTF-8�server�ServerzTornadoServer/%szHTTP/1.1)�chunkr# )%�strr r97 r �
BaseExceptionr r r r
r r) �run_in_executorr! r �environ�iterr3 �hasattrr> �join� Exception�split�int�lowerr �utf8�len�tornado�versionr �ResponseStartLine� HTTPHeaders�add�98connection�
write_headers�finish�_log)r$ r' r6 �loop� app_responser< rE �body�status_code_str�reason� status_coder0 �k�v�99header_set�100start_line�101header_obj�key�valuer; r4 r5 s @@@r r+ � WSGIContainer.handle_request� s� �� � ����� �
#��
#��%��S��/�*�
#� ��3� �]�+� �]�+�-���
#� �u�g�s�l�
#�
#�
#� �~�~� �� !� 1� 1� �M�M� � !� !� �L�L�� !� � 102� 103� � %� $�\� 2� �
����
� � "� 2� 2�4�=�=�*� M�M���=������&� � �|�W�-�-� �"�"�$��x�x��!���� B�C� C�"&�x�.�"6�"6�s�A�">� ���/�*� ��y�/��.5�6�g�F�Q�a�g�g�i�g�104�6��{�{�4� �� �#� � �z�1���� 0�#�c�$�i�.� A�B� �Z�/���� K�L� �:� %� �N�N�H�&8�7�?�?�&J�K� L� �/�/�105�K�P�106� �)�)�+�107�!�J�C�� �N�N�3�� &� "��!�!�-�-�-����(�(��Z�t�(�L����!�!�#� � � �+�'�c108�$ N��109 �|�W�-�-� �"�"�$� .�� 7�sK �B=L�K�L�A K! �K � K! �$A0L� L�0D,L� K! �!$L� Lc �| � UR R S5 n[ U5 S:X a US n[ US 5 nO UR nUR S:X a SOSnUR110 S[
[ R " UR S S111S 95 UR UR U[ U5 UR S UR [ [ R " UR 5 5 [" R$ U R& [( LS
S112S.nSUR* ; a UR* R- S5 US' SUR* ; a UR* R- S5 US' UR* R/ 5 H* u pgXuSUR1 SS5 R3 5 - ' M, U$ )z~Converts a `tornado.httputil.HTTPServerRequest` to a WSGI environment.113 114.. versionchanged:: 6.3115 No longer a static method.116�:� r r@ �httpsi� �P � NF)�encoding�plus)r@ r T)�REQUEST_METHOD� SCRIPT_NAME� PATH_INFO� QUERY_STRING� REMOTE_ADDR� SERVER_NAME� SERVER_PORT�SERVER_PROTOCOLz wsgi.versionzwsgi.url_schemez117wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz
wsgi.run_oncerB � CONTENT_TYPErA �CONTENT_LENGTH�HTTP_�-�_)�hostrN rR rO �protocol�methodr r � url_unescape�path�query� remote_iprF rT r rQ r^ �sys�stderrr! r r0 �pop�items�replace�upper)r$ r' �hostportr �portrI rg rh s r rI �WSGIContainer.environ� sq � � �<�<�%�%�c�*�� �x�=�A� ��A�;�D��x��{�#�D��<�<�D�!�*�*�g�5�3�2�D� %�n�n� �$��#�#�G�L�L�4�e�L�� $�M�M�"�,�,� � �t�9� &��� "� &� /� /�!�&�+�+�g�l�l�";�<� �:�:� $�
�
�^� C�!%� "�#118��& �W�_�_� ,�&-�o�o�&9�&9�.�&I�G�N� #� �w��� .�(/���(;�(;�<L�(M�G�$� %�!�/�/�/�/�1�J�C�?D�G�c�k�k�#�s� 3� 9� 9� ;�;� <� 2��r ra c �T � US: a [ R nO'US: a [ R nO[ R nSUR 5 - nUR119 c eUR c eUR120 S- UR - S- UR - S- nU" SXU5 g )Ni� i� g @�@r? z (�)z %d %s %.2fms)r �info�warning�error� request_timer� �urir� )r$ ra r' �121log_methodr� �summarys r r[ �WSGIContainer._log� s� � � �� �#� � �J�
�3�
�#�+�+�J�#�)�)�J� �� 4� 4� 6�6� ��~�~�)�)�)��{�{�&�&�&� �N�N��
��k�k�
� �
� � � �
�122 �
� � �>�;� �Fr )r! r r# )�__name__�123__module__� __qualname__�__firstlineno__�__doc__r �124concurrent�futures�Executorr% r �HTTPServerRequestr, r+ r rF r
rI rO r[ �__static_attributes__� r r r r ; s� � �?�H ;?�I�'�I� �:�-�-�6�6�7�I� 125� I�F�� :� :� F�t� F�E(�H�,F�,F� E(�4� E(�N&�x� 9� 9� &�d�3��8�n� &�PG�� G�h�.H�.H� G�T� Gr r )#r� �concurrent.futuresr� �ior rS r� �tornado.concurrentr r r �tornado.ioloopr � tornado.logr �typingr r126 r r r
r �typesr �
TYPE_CHECKINGr �_typeshed.wsgir r r rF r r r� � HTTPRequestr� r r �<module>r� sq �� � � � � 127� -� � � !� "� =� =� �
� ����=� �5� �S� �128NG� NG�b �(�(� r