آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 غ`ً%م@s&ddlZddlZddlZddlmZddlmZddlmZddlm Z y(ddl Z ddl mZmZm Z ddlZWn<ek r¬ddljZ ddlmZmZm Z ddljZYnXGdd„de jƒZGd d „d e jƒZGdd„deƒZGd d„deƒZGdd„deƒZGdd„deƒZdd„Zdd„ZdS)éN)عpython_version)عSSL)عnonblocking)عi18n)ع_CS_REQ_SENTع_CS_IDLEعResponseNotReadyc@seZdZdd„ZdS)عHTTPResponsecCs4t|jtjƒstj|jƒ|_|jj|||||ƒdS)N)ع isinstanceعfprZNonBlockingFileعset_callback)عselfعrsعwsعexع user_dataعcallback©rْ!/usr/lib/python3.6/connections.pyr szHTTPResponse.set_callbackN)ع__name__ع __module__ع__qualname__rrrrrr sr c@s@eZdZeZdejfdd„Zdd„Zdd„Z dd „Z d d„ZdS)عHTTPConnectionNcCs^tƒdkr tjj||||dچntjj|||ƒg|_g|_g|_d|_d|_d|_ ||_ dS)Nz2.6.1)عtimeoutz#rhn.connections $Revision$ (python))rعhttplibrع__init__ع_cb_rsع_cb_wsع_cb_exع _cb_user_dataع_cb_callbackع_user_agentr)r عhostعportrrrrr(s zHTTPConnection.__init__cCs"||_||_||_||_||_dS)N)rrrrr )r rrrrrrrrr5s zHTTPConnection.set_callbackcCs ||_dS)N)r!)r Z user_agentrrrعset_user_agent=szHTTPConnection.set_user_agentcCs‍|jr|jjƒrd|_|jtks&|jr,tƒ‚|jdkrH|j|j|jƒ}n|j|jƒ}|jrv|j |j |j|j|j |jƒ|jƒt|_|jr”|jƒn||_|S)z!Get the response from the server.Nr)Z_HTTPConnection__responseZisclosedZ_HTTPConnection__staterrZ debuglevelعresponse_classعsockr rrrrrعbeginrع will_closeعclose)r عresponserrrعgetresponseBs zHTTPConnection.getresponsecCstjj|ƒ|jj|jƒdS)N)rrعconnectr&ع settimeoutr)r rrrr,sszHTTPConnection.connect)rrrr r%rعDEFAULT_TIMEOUTrrr$r+r,rrrrr%s 1rc@sBeZdZdddejfdd„Zdd„Zd dd„Zd d „Zdd„Z dS)عHTTPProxyConnectionNcCsPtj|||dچ|j|j|_|_|j||ƒ|j|j|_|_||_ ||_ dS)N)r)rrr"r#ع_HTTPProxyConnection__proxyع _HTTPProxyConnection__proxy_portع _set_hostportع_hostع_portع_HTTPProxyConnection__usernameع_HTTPProxyConnection__password)r عproxyr"r#عusernameعpasswordrrrrryszHTTPProxyConnection.__init__cCs.|j|j|jƒtj|ƒ|j|j|jƒdS)N)r2r0r1rr,r3r4)r rrrr,‡s zHTTPProxyConnection.connectrcCsN|j}|j|jkr$|dt|jƒ}d||f}tj||||dچ|jƒdS)Nْ:zhttp://%s%s)ع skip_host)r3r4عdefault_portعstrrع putrequestع_add_proxy_headers)r عmethodعurlr;عhostnameZnewurlrrrr>ژszHTTPProxyConnection.putrequestcCsX|js dSd|j|jf}tjtj|ƒƒjtjdƒtjdƒƒ}|jddtj|ƒƒdS)Nz%s:%sع عzProxy-AuthorizationzBasic %s) r5r6عbase64Zencodestringrعbstrعreplaceع putheaderZsstr)r ZuserpassZenc_userpassrrrr?™s $z&HTTPProxyConnection._add_proxy_headerscCs|j||ƒ\|_|_dS)N)Z _get_hostportr"r#)r r"r#rrrr2،sz!HTTPProxyConnection._set_hostport)r) rrrrr.rr,r>r?r2rrrrr/xs r/c@s2eZdZeZejjZddej fdd„Z dd„ZdS)عHTTPSConnectionNcCs$tj||||dچ|pg}||_dS)N)r)rrع trusted_certs)r r"r#rJrrrrr¨szHTTPSConnection.__init__c Csقtj|j|jtjtjƒ}x”|D]Œ}|\}}}}}ytj|||ƒ}Wntjk r^d}wYnXy"|j|j|jfƒ|j|j ƒWn$tjk r¦|j ƒd}wYnXPqW|dkrہtjdƒ‚tj||j ƒ|_|jjƒdS)z'Connect to a host on a given (SSL) portNz0Unable to connect to the host and port specified)عsocketZgetaddrinfor"r#Z AF_UNSPECZSOCK_STREAMعerrorr,r-rr)rع SSLSocketrJr&عinit_ssl) r عresultsعrZafZsocktypeعprotoZ canonnameZsar&rrrr,®s* zHTTPSConnection.connect)rrrr r%rrIr<rr.rr,rrrrrI¤s rIc@seZdZdd„ZdS)عHTTPSProxyResponsecCstj|ƒd|_dS)Nr)r r'r()r rrrr'ثs zHTTPSProxyResponse.beginN)rrrr'rrrrrRتsrRc@sBeZdZejZddddejfdd„Zdd„Zddd„Z d d „Z dS)عHTTPSProxyConnectionNc Cs*tj|||||||dچ|pg}||_dS)N)r)r/rrJ)r r7r"r#r8r9rJrrrrrزs zHTTPSProxyConnection.__init__cCs¦tj|ƒd|j|jf}tj|d|ƒ|jƒtj|ƒ|j}t |_tj |ƒ}||_|jƒ|jdkr†|jƒt j||j|j|jƒ‚tj|j|jƒ|_|jjƒdS)Nz%s:%sZCONNECTéب)r/r,r3r4rr>r?Z endheadersr%rRr+r)Zstatusع xmlrpclibZ ProtocolErrorعreasonعmsgrrMr&rJrN)r r"r%r*rrrr,ظs zHTTPSProxyConnection.connectrcCstj||||dچS)N)r;)rr>)r r@rAr;rrrr>ُszHTTPSProxyConnection.putrequestcCstj|ƒ|jd|jƒdS)Nz User-Agent)r/r?rHr!)r rrrr?ّs z'HTTPSProxyConnection._add_proxy_headers)r)rrrrIr<rr.rr,r>r?rrrrrSدs rScCs$|dkrdStj|ƒ}|jdƒSdS)zJ Convert Internationalized domain name from Punycode (RFC3492) to Unicode Nعidna)rrFعdecode)rBrrrعidn_puny_to_unicode‎s rZcCs*|dkrdStj|ƒ}tj|jdƒƒSdS)zZ Convert domain name to Punycode (RFC3492). Hostname can be instance of string or Unicode NrX)rZustrعencode)rBrrrعidn_ascii_to_punys r\)rEZencodings.idnaZ encodingsrKعplatformrZrhnrrrrrrrrUعImportErrorZhttp.clientZclientZ xmlrpc.clientr rr/rIrRrSrZr\rrrrع s, S,&.