← Back
Editing: http_channel.cpython-312.pyc
� 2�i� � � � d dl Zd dlZd dlZd dlZddlmZmZ ddlm Z m Z m Z m Z m Z mZ ej e� Z G d� de� Zy)� N� )� AsyncChannel� ChannelError)� JsonObject�get_dict�get_int� get_object�get_str� typecheckedc �h � e Zd ZdZedej j dede fd�� Z ede dej j fd�� Z edej j d d dd fd �� Z edej j d ededddedej j f d�� Zde dd fd�Zy )� HttpChannelz http-stream2�response�binary�returnc � � ddh}|s|j ddh� | j � D ��ci c] \ }}||vs� ||�� c}}S c c}}w )N� ConnectionzTransfer-EncodingzContent-Length�Range)�update� getheaders)r r �remove�key�values �B/usr/lib/python3.12/site-packages/cockpit/channels/http_channel.py� get_headerszHttpChannel.get_headers sW � � � 3�4��� �M�M�+�W�5� 6�-5�-@�-@�-B�X�-B�z�s�E�c�QW�FW��U� �-B�X�X��Xs � A�A�optionsc � � t | dd� }t | dd � }t | dd � }t | dd � }|�|� t dd�� �|�|� t dd �� �|�|� t dd �� �|��t |d d � }|�Gt |d d � }|�t j |� � }n5t j t |d� �� }nt j � }d|v r+|d s&d|_ t j j |_ t j j |||�� S t j j ||�� S )N�address� localhost�tls�unix�port�protocol-errorz#TLS on Unix socket is not supported��messagez&no "port" or "unix" option for channelz-cannot specify both "port" and "unix" options� authority�data)�cadata�file)�cafile�validateF)r! �context)r! )r r r r �ssl�create_default_context�check_hostname� VerifyMode� CERT_NONE� verify_mode�http�client�HTTPSConnection�HTTPConnection)r � opt_address�opt_tls�opt_unix�opt_portr% r& r+ s r � create_clientzHttpChannel.create_client sN � � �g�y�+�>� ��7�E�4�0���7�F�D�1���7�F�D�1�� � �8�#7� � /�9^�_� _� � �� 0� � /�9a�b� b� � �H�$8� � /�9h�i� i� � � ��+�t�<�I��$� �y�&�$�7���#� !� 8� 8�� E�G� !� 8� 8�� �SY�@Z� [�G� �4�4�6���W�$�W�Z�-@�).��&�&)�n�n�&>�&>��#��;�;�.�.�{��SZ�.�[� [� �;�;�-�-�k��-�I� I� � connectionr8 z str | NoneNc � � |rDt j t j � | _ | j j |� y | j � y �N)�socket�AF_UNIX�sock�connect)r< r8 s r rB zHttpChannel.connectA s; � � � $�m�m�F�N�N� ;�J�O� �O�O� #� #�H� -� � � � r; �method�path�headerszdict[str, str]�bodyc �T � | j |||xs i |�� | j � S )N)rE rF )�request� getresponse)r< rC rD rE rF s r rH zHttpChannel.requestL s. � � ���6�4�� �B�T��J��%�%�'�'r; c � � K � t j d|� t |d� }t |d� }t |dd� d � }d|v r t dd� � �| j |� }| j � d } | j � � d { ��� }|�n||z }�! | j | j |t |d d � � � d { ��� | j | j ||||xs i |� � d { ��� } | j' d| j( | j* | j- | | j. �� �� | j | j0 | j2 � � d { ��� } | sn| j5 | � � d { ��� �Kt j d� | j � } | d k( sJ �| j |j6 � � d { ��� | j9 � y 7 ��]7 ��&# t j $ r }t d t |� � � |�d }~wt t f$ r }t d t |� � � |�d }~ww xY w7 ��W# t j" j$ t f$ r }t dt |� � � |�d }~ww xY w7 ��(7 ��7 ��# t j" j$ t f$ r }t dt |� � � |�d }~ww xY w�w)Nzopen %srC rD rE c �r � | j � D ��ci c] \ }}|t |t � �� c}}S c c}}w r> )�itemsr �str)�d�k�vs r �<lambda>z!HttpChannel.run.<locals>.<lambda>Y s5 � �_`�_f�_f�_h�;i�_h�W[�WX�Z[�A�{�1�c�?R�<R�_h�;i��;is �3r< r" z4connection sharing is not implemented on this bridger# r; r zunknown-hostkeyz not-found� terminatedr )r )�command�status�reasonrE zreading response done) �logger�debugr r r r: �ready�read� in_threadrB r, �SSLCertVerificationErrorrM �OSError�IOErrorrH r2 r3 � HTTPException� send_controlrT rU r � is_binary�read1� BLOCK_SIZE�write�close�done) �selfr rC rD rE r< rF r& �excr �blocks r �runzHttpChannel.runT s� � �� �� � �Y��(���(�+���w��'�� �W�i�1i�ko�p�� �7� "� � /�9o�p� p��'�'��0� � � � � ���� ����$�D��|�� �D�L�D� � G��.�.�� � �z�7�7�F�TX�;Y�Z� Z� Z� H� !�^�^�D�L�L�*�f�d�T[�Ta�_a�cg� h�h�H� ���*�!)� � �!)� � �"&�"2�"2�8�D�N�N�"2�"S� � U� H�� "�n�n�X�^�^�T�_�_� M�M�� ���j�j��'�'�'� � �L�L�0� 1� �M�M�O�E��C�<� �<��.�.��!1�!1�2� 2� 2� � � � �U %�� [���+�+� M� � 0�#�c�(�C�� L����!� G� �{�C��H�=�3� F�� G�� i��� � �)�)�7�3� H� �|�S��X�>�C� G�� H�� N�� (�� 3��� � �)�)�7�3� H� �|�S��X�>�C� G�� H�s� �BK�G%� K�+G+ �G(�G+ �'I �/I�0I �4AK�9*J �#J �$J �?J� AJ �J�J �K�(G+ �+I�>H�I�'H>�>I�K�I � #J�,J�J�K� J �J �J �#K�6K � K�K)�__name__� __module__� __qualname__�payload� staticmethodr2 r3 � HTTPResponse�boolr r r5 r: rB rM �bytesrH ri � r; r r r s � � �G��Y�d�k�k� 6� 6� Y�4� Y�J� Y� �Y� � J�z� J�d�k�k�.H�.H� J� � J�B �!�D�K�K� 6� 6� !�,� !�SW� !� �!� �(��K�K�.�.�(�8;�(�CF�(�Qa�(�in�(� ��� !� !�(� �(�:�� :�� :r; r )� http.clientr2 �loggingr? r, �channelr r �jsonutilr r r r r r � getLoggerrj rV r rr r; r �<module>rx s< �� � � � � 0� V� V� �� � �8� $��}�,� }r;
Save File
Cancel