^V@sddlZddlmZddlZddlZddlmZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZyddlZWnek rddlZYnXddlZddlmZddlmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1e j2e3Z4dZ5e j6e5Z7dZ8d e8d Z9e8d Z:d Z;d e;de:de5d e;de:dZ<dZ=de<de=de<dZ>e9d e5e9dZ?de?dZ@de8de@de>dZAe j6eAZBde;de:d ZCe j6eCZDdd ZEd!d"ZFd#d$ZGd%d&ZHddd'd(ZId)d*ZJd+d,ZKd-d.ZLejMd/d0ZNejMd1d2ZOejMd3d4d5ZPGd6d7d7eQZRd8d9ZSGd:d;d;eQZTd<d=ZUGd>d?d?eQZVe j6d@e jWZXdAdBZYddCdDZZdEdFZ[dGdHZ\dIdJZ]dKdLZ^dMdNZ_e j6dOe j`Zae j6dPZbddQdRZce j6dSZddTdUZedVdWZfdXdYZgdZZhd[d\Zid]d^ZjGd_d`d`eQZkGdadbdbeQZlGdcddddeQZmdZnddldmdnZododpZpdZqGdwdxdxeQZre j6dyZse j6dzZte j6d{Zud|d}Zd~dZvGddde$jwZwGddde)Z(Gddde(e'ZxejyddZzezdkr&Gddde$j{Z{Gddde$j|Z|nGddde%j}Z}Gddde%j~Z~Gddde%jZddZGdddeQZGdddeZGdddeZGddde*ZGdddeQZdS)N)deque)iglob)DistlibException) string_types text_typeshutil raw_inputStringIOcache_from_sourceurlopenurljoinhttplib xmlrpclib splittype HTTPHandler HTTPSHandlerBaseConfigurator valid_ident Container configparserURLErrormatch_hostnameCertificateErrorZipFilez\s*,\s*z (\w|[.-])+z(\*|:(\*|\w+):|)z\*?z([<>=!~]=)|[<>](z)?\s*(z)(z)\s*(z))*z(from\s+(?P.*))z \(\s*(?P|z)\s*\)|(?Pz\s*)z)*z \[\s*(?Pz)?\s*\]z(?Pz \s*)?(\s*z)?$z(?Pz )\s*(?Pc s^ddd}tj|}|rZ|j}|d}|dpN|d}|dsdd}nd}|dj}|sd}d}|d}nk|dd krd |}ntj|} fd d | D}d |djdd |Df}|dsd} ntj|d} t d|d|d| d|d|d|}n|S)NcSs|j}|d|dfS)Nopvn) groupdict)mdr#7/tmp/pip-build-9m6vxulb/pip/pip/_vendor/distlib/util.pyget_constraintVs z)parse_requirement..get_constraintdnc1c2direfrz<>!=z~=csg|]}|qSr#r#).0r!)r%r#r$ ns z%parse_requirement..z%s (%s)z, cSsg|]}d|qS)z%s %sr#)r+conr#r#r$r,os exname constraintsextras requirementsourceurl) REQUIREMENT_REmatchr stripRELOP_IDENT_REfinditerjoinCOMMA_REsplitr) sresultr!r"r/consr4constrrsiteratorr1r#)r%r$parse_requirementTs4       &  rCcCsdd}i}x|D]\}}}tjj||}xt|D]}tjj||} xt| D]v} ||| } |dkr|j| dqr||| } |jtjjdjd} | d| || .get_rel_pathNrD)rFrGr:rpoprErHrstrip)resources_rootrulesrN destinationsrMsuffixdestprefixabs_baseabs_globabs_path resource_filerel_pathrel_destr#r#r$get_resources_destsys  !r]cCs:ttdrd}ntjttdtjk}|S)N real_prefixT base_prefix)hasattrsysrVgetattr)r>r#r#r$in_venvs rccCstjjtjS)N)rFrGnormcasera executabler#r#r#r$get_executables rfcCs~|}xqt|}|}| r1|r1|}n|r |dj}||krWPn|rvd|||f}qvq q W|S)Nrz %c: %s %s)r lower)prompt allowed_chars error_promptdefaultpr=cr#r#r$proceeds    rncCsVt|tr|j}ni}x+|D]#}||kr+||||keyr#r#r$extract_by_keys  rrcCstjddkr+tjd|}n|j}t|}ytj|}|ddd}xo|jD]a\}}xR|jD]D\}}d||f}t |} | dk st | ||.read_stream)ra version_infocodecs getreaderreadr jsonloaditemsget_export_entryrJ Exceptionseekr ConfigParserMissingSectionHeaderErrorclosetextwrapdedentsections)rydatajdatar>groupentrieskvr=entryrzrxrqr/valuer#r#r$ read_exportssD         rcCstjddkr+tjd|}ntj}x|jD]\}}|j|x|jD]u}|j dkr|j }nd|j |j f}|j rd|dj |j f}n|j ||j|qjWqDW|j|dS)Nrrszutf-8z%s:%sz%s [%s]z, )rar{r| getwriterrrr add_sectionvaluesrTrVflagsr:setr/write)ruryrxrrrr=r#r#r$ write_exportss    rc cs*tj}z |VWdtj|XdS)N)tempfilemkdtemprrmtree)tdr#r#r$tempdirs  rc cs7tj}ztj|dVWdtj|XdS)N)rFgetcwdchdir)r"cwdr#r#r$rs    rc cs7tj}ztj|dVWdtj|XdS)N)socketgetdefaulttimeoutsetdefaulttimeout)secondsctor#r#r$socket_timeouts    rc@s+eZdZddZdddZdS)cached_propertycCs ||_dS)N)func)selfrr#r#r$__init__#szcached_property.__init__NcCs<|dkr|S|j|}tj||jj||S)N)robject __setattr____name__)robjclsrr#r#r$__get__(s  zcached_property.__get__)r __module__ __qualname__rrr#r#r#r$r"s  rcCstjdkr|S|s|S|ddkr@td|n|ddkrctd|n|jd}x#tj|kr|jtjquW|stjStjj|S)aReturn 'pathname' as a name that will work on the native filesystem. The path is split on '/' and put back together again using the current directory separator. Needed because filenames in the setup script are always supplied in Unix style, and have to be converted to the local convention before we can actually use them in the filesystem. Raises ValueError on non-Unix-ish systems if 'pathname' either starts or ends with a slash. rDrzpath '%s' cannot be absoluterzpath '%s' cannot end with '/')rFrH ValueErrorr<curdirremoverGr:)pathnamepathsr#r#r$ convert_path0s rc@seZdZdddZddZddZdd Zd d d Zd ddZddZ ddZ ddZ ddZ ddZ ddd ddZddZddZd d!Zd"d#Zd S)$ FileOperatorFcCs#||_t|_|jdS)N)dry_runrensured _init_record)rrr#r#r$rLs  zFileOperator.__init__cCs%d|_t|_t|_dS)NF)recordr files_written dirs_created)rr#r#r$rQs  zFileOperator._init_recordcCs |jr|jj|ndS)N)rradd)rrGr#r#r$record_as_writtenVs zFileOperator.record_as_writtencCsitjj|s1tdtjj|ntjj|sGdStj|jtj|jkS)aTell if the target is newer than the source. Returns true if 'source' exists and is more recently modified than 'target', or if 'source' exists and 'target' doesn't. Returns false if both exist and 'target' is the same age or younger than 'source'. Raise PackagingFileError if 'source' does not exist. Note that this test is not very accurate: files created in the same second will have the same "age". zfile '%r' does not existT)rFrGexistsrabspathstatst_mtime)rr3targetr#r#r$newerZs zFileOperator.newerTcCs|jtjj|tjd|||jsd}|rtjj|r`d|}qtjj|rtjj | rd|}qn|rt |dnt j ||n|j |dS)z8Copy a file respecting dry-run and force flags. zCopying %s to %sNz%s is a symlinkz%s is a non-regular filez which would be overwritten) ensure_dirrFrGdirnameloggerinforislinkrisfilerrcopyfiler)rinfileoutfilecheckmsgr#r#r$ copy_filens  %zFileOperator.copy_fileNc Cstjj| st|jtjj|tjd|||js|dkrlt |d}nt j |dd|}zt j ||Wd|j Xn|j|dS)NzCopying stream %s to %swbwencoding)rFrGisdirrJrrrrropenr|r copyfileobjrr)rinstreamrr outstreamr#r#r$ copy_streams  zFileOperator.copy_streamc Cs[|jtjj||jsJt|d}|j|WdQXn|j|dS)Nr)rrFrGrrrrr)rrGrfr#r#r$write_binary_files  zFileOperator.write_binary_filec Csd|jtjj||jsSt|d}|j|j|WdQXn|j|dS)Nr) rrFrGrrrrencoder)rrGrrrr#r#r$write_text_files  zFileOperator.write_text_filecCstjdks-tjdkrtjdkrxj|D]_}|jrVtjd|q4tj|j|B|@}tjd||tj||q4WndS)Nposixjavazchanging mode of %szchanging mode of %s to %o) rFr/_namerrrrst_modechmod)rbitsmaskfilesrmoder#r#r$set_modes-  zFileOperator.set_modecCs|jdd|S)Nimi)r)r=rr#r#r$szFileOperator.cCstjj|}||jkrtjj| r|jj|tjj|\}}|j|tj d||j stj |n|j r|j j|qndS)Nz Creating %s)rFrGrrrrr<rrrrmkdirrr)rrGr"rr#r#r$rs"   zFileOperator.ensure_dircCst|| }tjd|||js|sD|j||r|sSd}q|j|sht|t|d}ntj |||dn|j ||S)NzByte-compiling %s to %sT) r rrrrrIrJrK py_compilecompiler)rrGoptimizeforcerVdpathdiagpathr#r#r$ byte_compiles   zFileOperator.byte_compilecCstjj|rtjj|rtjj| rtjd||js`tj |n|j r ||j kr|j j |qq qtjj|rd}nd}tjd|||jstj |n|j r||j kr |j j |q qndS)NzRemoving directory tree at %slinkfilezRemoving %s %s)rFrGrrrrdebugrrrrrrr)rrGr=r#r#r$ensure_removeds"%     zFileOperator.ensure_removedcCsjd}x]|setjj|r:tj|tj}Pntjj|}||kr\Pn|}q W|S)NF)rFrGraccessW_OKr)rrGr>parentr#r#r$ is_writables   zFileOperator.is_writablecCs/|jst|j|jf}|j|S)zV Commit recorded changes, turn off recording, return changes. )rrJrrr)rr>r#r#r$commits zFileOperator.commitcCs|jsx9t|jD](}tjj|rtj|qqWt|jdd}xq|D]f}tj |}|r|dgkst tjj ||d}tj |ntj |qaWn|j dS)NreverseT __pycache__r)rlistrrFrGrrsortedrlistdirrJr:rmdirr)rrdirsr"flistsdr#r#r$rollbacks  zFileOperator.rollback)rrrrrrrrrrrrset_executable_moderrrrrr r#r#r#r$rKs          rcCs|tjkrtj|}n t|}|dkr@|}nG|jd}t||jd}x|D]}t||}qnW|S)N.r)ramodules __import__r<rbrO) module_name dotted_pathmodr>partsrlr#r#r$resolves    rc@sOeZdZddZeddZddZddZej Z d S) ExportEntrycCs(||_||_||_||_dS)N)r/rVrTr)rr/rVrTrr#r#r$rs   zExportEntry.__init__cCst|j|jS)N)rrVrT)rr#r#r$rszExportEntry.valuecCs d|j|j|j|jfS)Nz)r/rVrTr)rr#r#r$__repr__szExportEntry.__repr__cCsdt|tsd}nH|j|jko]|j|jko]|j|jko]|j|jk}|S)NF)rorr/rVrTr)rotherr>r#r#r$__eq__s zExportEntry.__eq__N) rrrrrrrrr__hash__r#r#r#r$rs    rz(?P(\w|[-.])+) \s*=\s*(?P(\w+)([:\.]\w+)*) \s*(\[\s*(?P\w+(=\w+)?(,\s*\w+(=\w+)?)*)\s*\])? c CsGtj|}|sId}d|ks3d|krCtd|qCn|j}|d}|d}|jd}|dkr|d}}n4|dkrtd|n|jd\}}|d } | dkrd|ksd|kr td|ng} nd d | jd D} t|||| }|S) N[]zInvalid specification %rr/callable:rrrcSsg|]}|jqSr#)r7)r+rr#r#r$r,Ls z$get_export_entry..,)ENTRY_REsearchrr countr<r) specificationr!r>r"r/rGcolonsrVrTrr#r#r$r2s2          rc Cs|dkrd}ntjdkrHdtjkrHtjjd}ntjjd}tjj|rtj|tj}|st j d|qnHytj |d}Wn.t k rt j d |d dd }YnX|s t j}t j d |ntjj||S) a Return the default base location for distlib caches. If the directory does not exist, it is created. Use the suffix provided for the base directory, and default to '.distlib' if it isn't provided. On Windows, if LOCALAPPDATA is defined in the environment, then it is assumed to be a directory, and will be the parent directory of the result. On POSIX, and on Windows if LOCALAPPDATA is not defined, the user's home directory - using os.expanduser('~') - will be the parent directory of the result. The result is just the directory '.distlib' in the parent directory as determined above, or with the name specified with ``suffix``. Nz.distlibnt LOCALAPPDATAz $localappdata~z(Directory exists but is not writable: %sTzUnable to create %sexc_infoFz#Default location unusable, using %s)rFr/environrG expandvars expanduserrrrrwarningmakedirsOSErrorrrr:)rTr>usabler#r#r$get_cache_baseQs&       r.cCs`tjjtjj|\}}|r?|jdd}n|jtjd}||dS)a Convert an absolute path to a directory name for use in a cache. The algorithm used is: #. On Windows, any ``':'`` in the drive is replaced with ``'---'``. #. Any occurrence of ``os.sep`` is replaced with ``'--'``. #. ``'.cache'`` is appended. rz---z--z.cache)rFrG splitdriverrErH)rGr"rlr#r#r$path_to_cache_dirzs $r0cCs|jds|dS|S)NrD)endswith)r=r#r#r$ ensure_slashsr2cCskd}}d|kr^|jdd\}}d|krC|}q^|jdd\}}n|||fS)N@rr)r<)netlocusernamepasswordrVr#r#r$parse_credentialss    r7cCs tjd}tj||S)N)rFumask)r>r#r#r$get_process_umasks r:cCsXd}d}x3t|D]%\}}t|tsd}PqqW|dk sTt|S)NTF) enumeraterorrJ)seqr>ir=r#r#r$is_string_sequencesr>z3([a-z0-9_]+([.-][a-z_][a-z0-9_]*)*)-([a-z0-9_.+-]+)z -py(\d\.?\d?)cCsd}d}tj|}|rI|jd}|d|j}n|rt|t|dkrtjtj|d|}|r|j}|d|||dd|f}qn|dkrt j|}|r|jd|jd|f}qn|S)zw Extract name, version, python version from a filename (no extension) Return name, version, pyver or None Nrz\brs) PYTHON_VERSIONrrstartrKrer6escapeendPROJECT_NAME_AND_VERSION)filename project_namer>pyverr!nr#r#r$split_filenames " - 'rIz-(?P[\w .-]+)\s*\(\s*(?P[^\s)]+)\)$cCsRtj|}|s(td|n|j}|djj|dfS)z A utility method used to get name and version from a string. From e.g. a Provides-Dist value. :param p: A value in a form 'foo (1.0)' :return: The name and version as a tuple. z$Ill-formed name/version string: '%s'r/ver)NAME_VERSION_REr6rr r7rg)rlr!r"r#r#r$parse_name_and_versions  rLcCst}t|pg}t|p'g}d|krS|jd||O}nx|D]}|dkr||j|qZ|jdr|dd}||krtjd|n||kr|j|qqZ||krtjd|n|j|qZW|S)N*-rzundeclared extra: %s)rrrrIrr*) requested availabler>runwantedr#r#r$ get_extrass&         rScCsi}yet|}|j}|jddkrFtjdn$tjd|}tj|}Wn8t k r}ztj d||WYdd}~XnX|S)Nz Content-Typezapplication/jsonz$Unexpected response for JSON requestzutf-8z&Failed to get external data for %s: %s) r rgetrrr|r}rrr exception)r4r>respheadersreaderer#r#r$_get_external_datas  &rZz'https://www.red-dove.com/pypi/projects/cCs9d|dj|f}tt|}t|}|S)Nz%s/%s/project.jsonr)upperr _external_data_base_urlrZ)r/r4r>r#r#r$get_project_datas r]cCs6d|dj||f}tt|}t|S)Nz%s/%s/package-%s.jsonr)r[r r\rZ)r/versionr4r#r#r$get_package_datasr_c@s:eZdZdZddZddZddZdS) Cachez A class implementing a cache for resources that need to live in the file system e.g. shared libraries. This class was moved from resources to here because it could be used by other modules, e.g. the wheel module. cCsvtjj|s"tj|ntj|jd@dkrQtjd|ntjjtjj ||_ dS)zu Initialise an instance. :param base: The base directory where the cache should be located. ?rzDirectory '%s' is not privateN) rFrGrr+rrrr*rnormpathrM)rrMr#r#r$rs zCache.__init__cCs t|S)zN Converts a resource prefix to a directory name in the cache. )r0)rrVr#r#r$ prefix_to_dir)szCache.prefix_to_dirc Csg}xtj|jD]}tjj|j|}yZtjj|s^tjj|rntj|n"tjj|rt j |nWqt k r|j |YqXqW|S)z" Clear the cache. ) rFrrMrGr:rrrrrrrappend)r not_removedfnr#r#r$clear/s$ z Cache.clearN)rrr__doc__rrcrgr#r#r#r$r`s   r`c@sUeZdZdZddZdddZddZd d Zd d Zd S) EventMixinz1 A very simple publish/subscribe system. cCs i|_dS)N) _subscribers)rr#r#r$rDszEventMixin.__init__TcCs\|j}||kr+t|g||rmrr#r#r$publishns     zEventMixin.publishN) rrrrhrrrrqrtr#r#r#r$ri@s   ric@seZdZddZddZdddZdd Zd d Zd d ZddZ e ddZ e ddZ dS) SequencercCs"i|_i|_t|_dS)N)_preds_succsr_nodes)rr#r#r$rs  zSequencer.__init__cCs|jj|dS)N)rxr)rnoder#r#r$add_nodeszSequencer.add_nodeFcCs ||jkr"|jj|n|r x3t|jj|fD]}|j||qDWx3t|jj|fD]}|j||qzWx6t|jjD]\}}|s|j|=qqWx9t|jjD]\}}|s|j|=qqWndS)N)rxrrrvrTrwrr)rryedgesrlr=rrr#r#r$ remove_nodes""""zSequencer.remove_nodecCsT||kst|jj|tj||jj|tj|dS)N)rJrv setdefaultrrrw)rpredsuccr#r#r$rsz Sequencer.addcCs||ksty|j|}|j|}Wn"tk rTtd|YnXy|j||j|Wn(tk rtd||fYnXdS)Nz%r not a successor of anythingz%r not a successor of %r)rJrvrwKeyErrorrr)rr~rpredssuccsr#r#r$rs    zSequencer.removecCs+||jkp*||jkp*||jkS)N)rvrwrx)rstepr#r#r$is_stepszSequencer.is_stepcCs|j|s"td|ng}g}t}|j|x|r|jd}||kr||kr|j||j|qqG|j||j||jj|f}|j |qGWt |S)Nz Unknown: %rr) rrrrdrOrrrvrTextendreversed)rfinalr>todoseenrrr#r#r$ get_stepss"        zSequencer.get_stepscs|dggiig|jfddx'D]}|krU|qUqUWS)Nrc s9d|<d|<dd7<j|y|}Wntk r_g}YnXxl|D]d}|kr|t|||stack strongconnectr#r$rs.       "    z3Sequencer.strong_connections..strongconnect)rw)rryr#)rrrrr>rrr$strong_connectionss  $"  zSequencer.strong_connectionscCsdg}xF|jD];}|j|}x%|D]}|jd||fq-WqWx"|jD]}|jd|q\W|jddj|S)Nz digraph G {z %s -> %s;z %s;} )rvrdrxr:)rr>rrr~ryr#r#r$dots    z Sequencer.dotN) rrrrrzr|rrrrpropertyrrr#r#r#r$rus      3ru.tar.gz.tar.bz2.tar.zip.tgz.tbz.whlTc sfdd}tjjtd}|dkr|jdr]d}q|jdr{d}d }q|jdrd }d }q|jdrd}d}qtd|nz|dkrt|d}|r]|j}x|D]}||qWq]nBtj ||}|r]|j }x|D]}||qFWn|dkrt j ddkrxA|j D]0} t| jts| jjd| _qqWn|jWd|r|jnXdS)Ncs|t|ts!|jd}ntjjtjj|}|j se|tjkrxt d|ndS)Nzutf-8zpath outside destination: %r) rordecoderFrGrr:rIrHr)rGrl)dest_dirplenr#r$ check_paths !#zunarchive..check_path.zip.whlzip.tar.gz.tgztgzzr:gz.tar.bz2.tbztbzzr:bz2z.tartarrQzUnknown format for %rrrszutf-8)rr)rr)rr)rFrGrrKr1rrnamelisttarfilergetnamesrar{ getmembersror/rr extractallr) archive_filenamerformatrrarchivernamesr/tarinfor#)rrr$ unarchivesH           rc Cstj}t|}t|d}x{tj|D]j\}}}xX|D]P}tjj||}||d} tjj| |} |j|| qPWq:WWdQX|S)z*zip a directory tree into a BytesIO objectrN) ioBytesIOrKrrFwalkrGr:r) directoryr>dlenzfrootrrr/fullrelrUr#r#r$zip_dirLs   rr*KMGTPc@seZdZdZddddZddZdd Zd d Zd d Ze ddZ e ddZ ddZ e ddZ e ddZdS)ProgressUNKNOWNrdcCsV|dks||kst||_|_||_d|_d|_d|_dS)NrF)rJrcurmaxstartedelapseddone)rminvalmaxvalr#r#r$rcs    zProgress.__init__cCs}|j|kst|jdks9||jks9t||_tj}|jdkri||_n||j|_dS)N)rrJrrtimerr)rcurvalnowr#r#r$updateks$   zProgress.updatecCs*|dkst|j|j|dS)Nr)rJrr)rincrr#r#r$ incrementuszProgress.incrementcCs|j|j|S)N)rr)rr#r#r$r@yszProgress.startcCs/|jdk r"|j|jnd|_dS)NT)rrr)rr#r#r$stop}sz Progress.stopcCs|jdkr|jS|jS)N)runknown)rr#r#r$maximumszProgress.maximumcCsZ|jrd}nD|jdkr*d}n,d|j|j|j|j}d|}|S)Nz100 %z ?? %gY@z%3d %%)rrrr)rr>rr#r#r$ percentages   " zProgress.percentagecCsU|dkr|jdks-|j|jkr6d}ntjdtj|}|S)Nrz??:??:??z%H:%M:%S)rrrrstrftimegmtime)rdurationr>r#r#r$format_durations- zProgress.format_durationcCs|jrd}|j}nd}|jdkr9d}ne|jdksZ|j|jkrcd}n;t|j|j}||j|j}|d|j}d||j|fS)NDonezETA rrz%s: %sr)rrrrrfloatr)rrVtr#r#r$ETAs   ! z Progress.ETAcCsh|jdkrd}n|j|j|j}x(tD] }|dkrLPn|d}q6Wd||fS)Nrgig@@z%d %sB/s)rrrUNITS)rr>unitr#r#r$speeds   zProgress.speedN)rrrrrrrr@rrrrrrrr#r#r#r$r`s     rz \{([^}]*)\}z[^/\\,{]\*\*|\*\*[^/\\,}]z^[^{]*\}|\{[^}]*$cCsZtj|r(d}t||ntj|rPd}t||nt|S)zAExtended globbing function that supports ** and {opt1,opt2,opt3}.z7invalid glob %r: recursive glob "**" must be used alonez2invalid glob %r: mismatching set marker '{' or '}')_CHECK_RECURSIVE_GLOBrr_CHECK_MISMATCH_SET_iglob) path_globrr#r#r$rsrc cstj|d}t|dkrt|dksBt||\}}}x3|jdD]4}x+tdj|||fD] }|VqWqaWnd|krxt|D] }|VqWn|jdd\}}|dkrd}n|dkr d}n|jd}|jd }x]tj |D]L\}}} tj j |}x(ttj j||D] } | VqtWq7WdS) Nrrsrr*z**r rMrD\) RICH_GLOBr<rKrJrr: std_iglobrLrFrrGrb) rrich_path_globrVrrTitemrGradicaldirrrfr#r#r$rs*%      "rc@s(eZdZdZdZddZdS)HTTPSConnectionNTc Cstj|j|jf|j}t|ddrI||_|jntt ds|j rmt j }n t j }t j ||j|jd|dt jd|j |_nt jt j}|jt jO_|jr|j|j|jni}|j rHt j |_|jd|j tt ddrH|j|d !           zHTTPSConnection.connect)rrrrrrr#r#r#r$rs rc@s7eZdZdddZddZddZdS) rTcCs#tj|||_||_dS)N)BaseHTTPSHandlerrrr)rrrr#r#r$rs  zHTTPSHandler.__init__cOs7t||}|jr3|j|_|j|_n|S)a This is called to create a connection instance. Normally you'd pass a connection class to do_open, but it doesn't actually check for a class, and just expects a callable. As long as we behave just as a constructor would have, we should be OK. If it ever changes so that we *must* pass a class, we'll create an UnsafeHTTPSConnection class which just sets check_domain to False in the class definition, and choose which one to pass to do_open. )rrr)rrrrsr>r#r#r$ _conn_makers   zHTTPSHandler._conn_makercCsqy|j|j|SWnStk rl}z3dt|jkrWtd|jnWYdd}~XnXdS)Nzcertificate verify failedz*Unable to verify server certificate for %s)do_openrrstrreasonrr)rreqrYr#r#r$ https_open.szHTTPSHandler.https_openN)rrrrrrr#r#r#r$rs  rc@seZdZddZdS)HTTPSOnlyHandlercCstd|dS)NzAUnexpected HTTP request on what should be a secure connection: %s)r)rrr#r#r$ http_openBszHTTPSOnlyHandler.http_openN)rrrrr#r#r#r$rAs rc@s"eZdZddddZdS)HTTPr*NcKs5|dkrd}n|j|j|||dS)Nr)_setup_connection_class)rrrrsr#r#r$rNs  z HTTP.__init__)rrrrr#r#r#r$r!Ms r!c@s"eZdZddddZdS)HTTPSr*NcKs5|dkrd}n|j|j|||dS)Nr)r"r#)rrrrsr#r#r$rUs  zHTTPS.__init__)rrrrr#r#r#r$r$Ts r$c@s+eZdZdddZddZdS) TransportrcCs ||_tjj||dS)N)rrr%r)rr use_datetimer#r#r$r\s zTransport.__init__cCs|j|\}}}tdkr<t|d|j}nN|j sY||jdkr}||_|tj|f|_n|jd}|S)Nrr rrr)rr ) get_host_info _ver_infor!r _connection_extra_headersrHTTPConnection)rrhehx509r>r#r#r$make_connection`s   zTransport.make_connectionN)rrrrr/r#r#r#r$r%[s r%c@s+eZdZdddZddZdS) SafeTransportrcCs ||_tjj||dS)N)rrr0r)rrr&r#r#r$rls zSafeTransport.__init__cCs|j|\}}}|s'i}n|j|dr#r#r$r/ps     zSafeTransport.make_connectionN)rrrrr/r#r#r#r$r0ks r0c@seZdZddZdS) ServerProxyc Ks|jdd|_}|dk rt|\}}|jdd}|dkr^t}nt}||d||d<}||_ntjj |||dS)Nrr&rhttps transport) rOrrrTr0r%r3rr1r) rurirsrscheme_r&tclsrr#r#r$rs    zServerProxy.__init__N)rrrrr#r#r#r$r1s r1cKs:tjddkr |d7}n d|dr=rr#r#r$rFs zCSVReader.nextN)rrrrrErF__next__r#r#r#r$rCs   rCc@s(eZdZddZddZdS) CSVWritercKs1t|d|_tj|j|j|_dS)Nr)r:ryrDwriterrB)rrfrsr#r#r$rszCSVWriter.__init__cCsutjddkrag}x<|D]4}t|trG|jd}n|j|q W|}n|jj|dS)Nrrszutf-8)rar{rorrrdrIwriterow)rrowrQrr#r#r$rJs  zCSVWriter.writerowN)rrrrrJr#r#r#r$rHs  rHcsbeZdZeejZded.convert..z())rorrtypedictconfigure_customrR)or>r)rRrr#r$rRs(  z.Configurator.configure_custom..convertz()r z[]csg|]}|qSr#r#)r+rV)rRr#r$r,s z1Configurator.configure_custom..cs2g|](}t|r||fqSr#)r)r+r)rPrRr#r$r,s )rOrrrrTrsetattr) rrPrmpropsrrrrsr>rHrr#)rPrRrr$rUs " zConfigurator.configure_customcCsI|j|}t|trEd|krE|j||j|<}n|S)Nz())rProrTrU)rrqr>r#r#r$ __getitem__s zConfigurator.__getitem__c Csatjj|s-tjj|j|}ntj|ddd}tj|}WdQX|S)z*Default converter for the inc:// protocol.rQrzutf-8N) rFrGisabsr:rMr|rrr)rrrr>r#r#r$rMs zConfigurator.inc_convert) rrrrTrvalue_convertersrrUrYrMr#r#)rQr$rLs    rLc@s:eZdZddddZddZddZdS) SubprocessMixinFNcCs||_||_dS)N)verboseprogress)rr]r^r#r#r$rs zSubprocessMixin.__init__cCs|j}|j}xu|j}|s+Pn|dk rG|||q|s`tjjdntjj|jdtjjqW|jdS)z Read lines from a subprocess' output stream and either pass to a progress callable (if specified) or write progress information to sys.stderr. Nr zutf-8) r^r]readlinerastderrrrflushr)rryrr^r]r=r#r#r$rXs    zSubprocessMixin.readercKstj|dtjdtj|}tjd|jd|jdf}|jtjd|jd|jdf}|j|j |j |j |j dk r|j ddn|j rt jjdn|S)Nstdoutr`rrrzdone.mainzdone. ) subprocessPopenPIPE threadingThreadrXrbr@r`waitr:r^r]rar)rcmdrsrlt1t2r#r#r$ run_command+s$ $     zSubprocessMixin.run_command)rrrrrXrmr#r#r#r$r\s  r\)rrrrrrr)r*rrrrr)rr )r| collectionsr contextlibrDglobrrrrloggingrFrrArrrrdrarrrrg ImportErrordummy_threadingrr*rcompatrrr r r r r rrrrrrrrrrrrrr getLoggerrrCOMMArr;IDENT EXTRA_IDENTVERSPECRELOPBARE_CONSTRAINTS DIRECT_REF CONSTRAINTS EXTRA_LISTEXTRAS REQUIREMENTr5 RELOP_IDENTr8rCr]rcrfrnrrrrcontextmanagerrrrrrrrrrVERBOSErrr.r0r2r7r:r>IrDr?rIrKrLrSrZr\r]r_r`riruARCHIVE_EXTENSIONSrrrrrrrrrrr{r(r!r$r%r0r1r:r;rCrHrLr\r#r#r#r$s                     . %   /      )          ,H6 ] !*)   :