File: //usr/libexec/kcare/python/kcarectl/__pycache__/http_utils.cpython-312.pyc
�
p��g: � � � d dl Z d dlZd dlZd dlmZ d dlZddlmZmZ ddlmZ ddlm Z ddlm
Z
ddl m Z m
Z
mZmZmZ d � Zdd
�Zd � Zd � Zdd
�Zd� Zd� Z e� Zy)� N)�SSLError� )�config� constants)� log_utils)�utils)�errors)�Request� std_urlopen� HTTPError�URLError�httplibc � � t | d� r| j � }n
| }t | � } |j di � }|j t
j t
j d�� |j � D ] \ }}| j ||� � t j dj ||� � t
j sd|vrt j |d< t j sUt# t$ dd � rDt% j& � }d|_ t$ j* |_ ||d< t/ | g|��i |��S t/ | g|��i |��S # t0 $ r`}|j2 d k( rKt5 j6 |j8 |j2 |j: |j< |j> � �� d }~wt@ $ r�}|jB ret |jB d
d � rL|jB d
jD tD jF k( r"t5 j6 | d tI |� d d � �d j ||� |_% ||_ � d }~ww xY w)
N� get_full_url�headers)z
KC-VersionzKC-Patch-Versionz#Requesting url: `{0}`. Headers: {1}�timeout�HAS_SNIF�contexti� r �errnoz Request for `{0}` failed: {1})&�hasattrr r
�pop�updater �VERSION�KC_PATCH_VERSION�items�
add_headerr �logdebug�format�PY2_6r � HTTP_TIMEOUT�CHECK_SSL_CERTS�getattr�ssl�create_default_context�check_hostname� CERT_NONE� verify_moder r �coder �NotFound�url�msg�hdrs�fpr
�argsr �ENOENT�str�reason) r* r. �kwargs� request_urlr �header�value�ctx�exs �0/usr/libexec/kcare/python/kcarectl/http_utils.py� urlopen_baser9 s� � ��s�N�#��&�&�(� �� ��c�l���j�j��B�'�G� �N�N�#�+�+� )� :� :�
�� !� � � � &�
��� ���v�u�%�&� ���<�C�C�K�QX�Y�Z�����9�F�#:� &� 3� 3�F�9� ��%�%�'�#�y�$�*G��,�,�.�C�!&�C� � !�m�m�C�O� #�F�9� � �s�4�T�4�V�4� 4��3�0��0��0�0�� � �
�7�7�c�>��/�/�"�&�&�"�'�'�2�6�6�2�7�7�B�E�E�J� J�
�� �
� �7�7�w�r�w�w�q�z�7�3�����
�8H�8H�E�L�L�8X��/�/�#�s�C��G�T�4�@� @� 4�:�:�;��K�� � ���
��
�s- �=B E � E � I �!AF<�< I �BI�I c � � � � fd�}|S )Nc �D �� t | t � r�xr | j dk\ S t | t t j
t t j f� ryt | d� r;t | j � dk( r"| j d t j k( ryy y y )Ni� Tr. � r )�
isinstancer r( r
r �
HTTPExceptionr �socketr r �lenr. r �
ECONNRESET)�e�state� retry_on_500s �r8 �check_functionz3check_urlopen_retry_factory.<locals>.check_functionD s} �� � �a�� #� �1�A�F�F�c�M� 1�
��H�g�&;�&;�X�v�~�~�V�
W��
�Q��
�C����K�1�$4������e�FV�FV�9V�� :W�$4�
� � )rD rE s ` r8 �check_urlopen_retry_factoryrH C s �� �� �rF c �\ � t | d� r| j � } | j d� S )Nr zfile:)r r �
startswith)r* s r8 � is_local_urlrK P s) � ��s�N�#�� � � �� �>�>�'� "�"rF c � � |j dd� }t | � rt | g|��i |��S t j t |�� � t � | g|��i |��S )NrD T)rD )r rK r9 r �retryrH )r* r. r2 rD s r8 �urlopenrN V s` � ��:�:�n�d�3�L��C���C�1�$�1�&�1�1� \� N�5�;�;�2� �M� N�|� \�]`� r�cg� r�kq� r�rrF c �� � t | |�� }t j s#|r!|j ddj |� � t j s"|r |j t
j |� |S )N)�method�
Authorizationz Basic {0})r
r �UPDATE_FROM_LOCALr r r �AUTH_TOKEN_HEADER)r* � auth_string�
auth_tokenrP �requests r8 � http_requestrW ] sZ � ��c�&�)�G� � #� #� ����?�K�,>�,>�{�,K�L� � #� #�
����9�6�6�
�C� �NrF c �� � | dk( r,t j d� xs t j d� S | dk( r,t j d� xs t j d� S y )N�http�
http_proxy�
HTTP_PROXY�https� https_proxy� HTTPS_PROXY)�os�getenv)�schemes r8 �get_proxy_from_envrb h sQ � �
����y�y� �&�A�"�)�)�L�*A�A� �7� ��y�y� �'�C�2�9�9�]�+C�C�
rF c �V � t t d� � xs t t d� � S )NrY r\ )�boolrb rG rF r8 �
proxy_is_usedre o s# � � �"�6�*� +� P�t�4F�w�4O�/P�PrF )T)NN)r r_ r# r r? � r r r r r �py23r
r r r
r r9 rH rK rN rW rb re �check_urlopen_retryrG rF r8 �<module>ri sZ ��
� �
� �
� � � � � D� D�.�b
�#� s��D�Q� 2�3� rF