|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /lib/python2.7/site-packages/redhat_support_lib/web/ |
Upload File : |
�
f�Tc @ s� d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m
Z
m Z d d l m
Z
d d l m Z d d l m Z d d l m Z e j d � Z d e f d � � YZ d S(
i����N( t HTTPConnectiont
BadStatusLine( t SSL( t HTTPSConnection( t RSLProxyHTTPSConnection( t RequestErrors! redhat_support_lib.web.connectiont
Connectionc B s� e Z d Z d d d d d d d e e d d �
Z d � Z d � Z d � Z e j
i � i d � Z d d d � Z d d d � Z
d � Z d � Z d d d
� Z d � Z d � Z d
� Z d � Z d � Z d � Z e e d d d � Z RS( s)
The strata api connection proxy
c C s' | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ |
| _ | | _ | | _
|
| _ | | _ | j
| � } | d | _ | d | _ | d | _ d | _ | r� | j
| � } | d | _ | d | _ n | j � | _ | j j t | � � | | _ t | � | _ d S( Ni i i t ( t urlt usernamet passwordt key_filet cert_filet strictt timeoutt proxy_urlt
proxy_usert
proxy_passt debugt noverifyt ssl_cat _Connection__parse_urlt
url_schemat url_hostt url_portt
handlerprefixt
proxy_hostt
proxy_portt _Connection__createConnectiont _Connection__connectiont set_debuglevelt intt _Connection__managert idt _Connection__id( t selfR R R
t managerR R R
R R R R R R R t ut purl( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt __init__( s4
c C s | j S( N( R" ( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt get_idW s c C s | j S( N( R ( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt
getConnectionZ s c C s
| j j � S( N( t _Connection__headerst copy( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt getDefaultHeaders] s c C s� d } x� t r� y: | j j | | j | | | j | � � | j j � SWq t k
r� | d k r� | j � | d 7} t j t
d � � q� � q Xq Wd S( Ni i s' Connection socket closed, reconnecting.( t TrueR t requestR t
getHeaderst getresponseR t resetConnectiont loggingR t _( R# t methodR t bodyt headerst attempts( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt doRequest` s
c C s� d } x~ t r� y' | j | | | | � | j j � SWq t k
r� | d k r| | j � | d 7} t j t d � � q� � q Xq Wd S( s2 Wrapper for _doUpload to handle connection retriesi i s' Connection socket closed, reconnecting.N( R- t _doUploadR R0 R R1 R2 R R3 ( R# R t fileNamet fileChunkt descriptionR7 ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt doUploadu s
c
C s� d t j � } d } zdySt | d � } t j j | � } x+t rjg } | r� | j d | � | j d � | j d � | j t | � � n | j d | � | r� d t j j | � | d f } | d j | � | }
n t j j | � }
| j d d
|
f � | j d t
j | � d p,d
� | j d � | j d � d j | � } g } | j d � | j d | d � | j d � d j | � }
t
| � t
|
� } | r�| | d 7} n
| | 7} | j j d d d | d d d d � | j i t | � d 6d | d 6d d 6� } x- | j � D] \ } } | j j | | � q5W| j j � | j j | � | r@| j j | j | d � � | j j |
� | j � | k r�Pno | j j � } | j � | j d k r-t j d | j | j | j � f � t | j | j | j � � � n | d c d 7<q@ | j j | j � � | j j |
� Pq@ WWn
� n XWd | r�| j � n Xd S( sY
Do an upload of a single file to the given URL.
Keyword arguments:
url -- The URL to upload to.
fileName -- An open file handle whose content needs to be sent.
fileChunk -- Dict describing the chunk of fileName to be sent.
description -- Optional description of the file.
s ----------%xt rbs --s2 Content-Disposition: form-data; name="description"R s %s.%03dt numt namess8 Content-Disposition: form-data; name="%s"; filename="%s"t files Content-Type: %si s application/octet-streams
t sizeR4 t POSTR t skip_hostt skip_accept_encodingi s Content-Lengths multipart/form-data; boundary=%ss Content-Types
text/plaint Accepti� s1 HTTP status(%s) HTTP reason(%s) HTTP response(%s)N( t timet Nonet opent ost patht getsizeR- t appendt strt basenamet mimetypest
guess_typet joint lenR t
putrequestR/ t itemst putheadert
endheaderst sendt readt tellR0 t statust loggerR t reasonR t close( R# R R: R; R< t boundaryt fht fileSizet headFormAryt chunkNamet header_filenamet headFormt tailFormAryt tailFormt totalLengtht hdrDictt keyt valuet response( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyR9 � s�
c C sd | j � } xQ | j � D]C } | | d k rN | j | � rN | j | � q | | | | <q W| S( N( R, t keysRH t has_keyt pop( R# R6 t extended_headerst k( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyR/ � s c C s | j j | � d S( N( R R ( R# t level( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt
setDebugLevel� s c C s | j j | | | � d S( N( R t
set_tunnel( R# t hostt portR6 ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt setTunnel� s c C s3 | j j � | j d k r/ | j j | � n d S( N( R R^ R RH t
_freeResource( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyR^ � s
c C s
| j j S( N( R t _Connection__state( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt state� s c C s� | j d � s d | } n t j | � } | d j d � } | d g } t | � d k r� | j | d � y | j t | d � � Wq� t k
r� | j d � q� Xn | j | d � | j d � | S( Nt https https://i t :i i ( t
startswitht urlparset rsplitRS RM R t
ValueErrorRH ( R# R t parset hostportt ret( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt __parse_url� s
c sp � f d � } � f d � } d } i } � j d k rK | � \ } } n | � \ } } � j | � � _ | S( Nc sB i } d } t j � } � j r7 | j t j d � n | j t j d � t j d t j � ro | j
d � n � j r� t j � j t j � r� | j
� j � n � j rt
� j � j � j � j � j d | �} � j d k rd � j � j f � _ q8d � j � _ n! t � j � j � j d | �} | | f S( Ni s /etc/pki/tls/certs/ca-bundle.crtt ssl_contexts
https://%s:%ss
https://%s( RH R t ContextR t
set_verifyt verify_nonet verify_peerRJ t accesst R_OKt load_verify_locationsR R R R R R
R R R R R R ( t hdrt connt context( R# ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt makeHTTPSConnection s0
! c s� i } d } � j r� t � j � j � j � } � j d k r[ d � j � j f � _ n d � j � _ | d d !t r� t
r� t j d � j
� j f � j � } d | | d <q� n t � j � j � j � } | | f S( Ns
https://%s:%ss
https://%ss Proxy-Connections
Keep-Alives %s:%ss Basic %ss Proxy-authorization( RH R R R R R
R R R t proxyusert proxypasst base64t encodestringR R t strip( R� R� t auth( R# ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt makeHTTPConnection6 s" R{ ( RH R t _Connection__createHeadersR* ( R# R� R� R� R� ( ( R# sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt __createConnection s %c C s_ t j d | j | j f � j � } i d d 6d d 6| j d 6d | d 6} | j | � | S( Ns %s:%ss application/xmlRF s Content-Typet Hosts Basic %st
Authorization( R� R� R R
R� R t update( R# t defaultheadersR� t hdrs( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt __createHeadersY s
c C s! | j � | j | j � k d S( N( R^ R R ( R# ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyR1 c s
N( t __name__t
__module__t __doc__RH t FalseR' R( R) R, t urllibt urlencodeR8 R= R9 R/ Rs Rw R^ Rz R R R� R1 t propertyR! ( ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyR $ s6 _
J
( t sysR� RP RJ t socketRG R� R~ R2 t httplibR R t M2CryptoR t M2Crypto.httpslibR t+ redhat_support_lib.web.proxyhttpsconnectionR t( redhat_support_lib.infrastructure.errorsR t getLoggerR\ t objectR ( ( ( sE /usr/lib/python2.7/site-packages/redhat_support_lib/web/connection.pyt <module> s