관리-도구
편집 파일: twisted.cpython-311.pyc
� �܋f � � � d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z m Z m Z m Z mZ ddlmZ dZn # e$ r d ZY nw xY w G d � d ee� � Zd S ) z� raven.transport.twisted ~~~~~~~~~~~~~~~~~~~~~~~~ :copyright: (c) 2010-2012 by the Sentry Team, see AUTHORS for more details. :license: BSD, see LICENSE for more details. � )�absolute_import)�BytesIO)�AsyncTransport)� HTTPTransport)�Agent�FileBodyProducer�HTTPConnectionPool�ResponseNeverReceived�readBody)�HeadersTFc �, � � e Zd ZddgZ� fd�Zd� Z� xZS )�TwistedHTTPTransportz twisted+httpz twisted+httpsc �� �� t st d� � � t t | � � j |i |�� ddlm} t |t |� � �� � | _ d S )Nz*TwistedHTTPTransport requires twisted.web.r )�reactor)�pool) � has_twisted� ImportError�superr �__init__�twisted.internetr r r �_agent)�self�args�kwargsr � __class__s ��N/opt/cloudlinux/venv/lib64/python3.11/site-packages/raven/transport/twisted.pyr z TwistedHTTPTransport.__init__ su �� �� L� � J�K�K� K�2��"�D�)�)�2�D�C�F�C�C�C� -�,�,�,�,�,� �G�*<�W�*E�*E�F�F�F�� � � � c �L ��� | j � d|t t |� � � � t t d� |� � � D � � � � � � �� � }�fd�}��fd�}|� |� � � |� � d S )Ns POSTc 3 �& K � | ] \ }}||gfV � � d S �N� )�.0�k�vs r � <genexpr>z2TwistedHTTPTransport.async_send.<locals>.<genexpr>- s, � � � � F� F�d�a��!�a�S�� F� F� F� F� F� Fr )� bodyProducer�headersc � �� | � t � � }|r! �d� | j j D � � � � d S �| j � � d S )Nc � � g | ] }|j �� S r! )�value)r" �fs r � <listcomp>zGTwistedHTTPTransport.async_send.<locals>.on_failure.<locals>.<listcomp>4 s � �C�C�C��A�G�C�C�Cr )�checkr r* �reasons)�failure�ex� failure_cbs �r � on_failurez3TwistedHTTPTransport.async_send.<locals>.on_failure0 s_ �� �� � � 4�5�5�B�� *�� �C�C�W�]�-B�C�C�C�D�D�D�D�D�� �7�=�)�)�)�)�)r c � �� � � j dk r �� � dS �� fd�}t � � � � |� � S )z� Success only means that the request succeeded, *not* that the actual submission was successful. �� c �P �� �t �j �j | � � � � d S r )� Exception�code�phrase)�bodyr1 �responses ��r � on_error_bodyzJTwistedHTTPTransport.async_send.<locals>.on_success.<locals>.on_error_body@ s) �� � �J�y�� ���� N� N�O�O�O�O�Or N)r7 r � addCallback)r: r; r1 � success_cbs ` ��r � on_successz3TwistedHTTPTransport.async_send.<locals>.on_success8 sk ��� � �}��#�#�� � � � � � �P� P� P� P� P� P� ��)�)�5�5�!�� � r ) r �requestr r r �dict�itemsr< � addErrback) r �url�datar' r= r1 �dr2 r> s `` r � async_sendz TwistedHTTPTransport.async_send) s� ��� � �K� � � �S�)�'�$�-�-�8�8��D� F� F�g�m�m�o�o� F� F� F� F� F�G�G� � � �� *� *� *� *� *� � � � � � � � � � � � � �*� � � � � � r )�__name__� __module__� __qualname__�schemer rF � __classcell__)r s @r r r sV �� � � � � � �o� .�F� G� G� G� G� G�" � " � " � " � " � " � " r r N)�__doc__� __future__r �raven.utils.compatr �raven.transport.baser �raven.transport.httpr �twisted.web.clientr r r r r �twisted.web.http_headersr r r r r! r r �<module>rS s ��� � '� &� &� &� &� &� '� &� &� &� &� &� /� /� /� /� /� /� .� .� .� .� .� .��� � � � � � � � � � � � � � 1�0�0�0�0�0��K�K��� � � ��K�K�K�����1 � 1 � 1 � 1 � 1 �>�=� 1 � 1 � 1 � 1 � 1 s �3 �=�=