a
lj @ s d dl Z d dlmZ d dlZd dlZd dlmZ d dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZz d dlZW n ey dZY n0 d dlZd dlZd dlZd dlZd dlZz d dlZW n ey d dlZY n0 d dlZddlmZ ddlm 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*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 e
1e2Z3e
4dZ5e
4dZ6e
4d Z7e
4d
Z8e
4d Z9e
4d Z:e
4d
Z;e
4dZdd Z?dd Z@dd ZAdddZBdd ZCd d ZDd d ZEejFd!d" ZGejFd#d$ ZHejFdd&d'ZIG d(d) d)eJZKd*d+ ZLG d,d- d-eJZMd.d/ ZNG d0d1 d1eJZOe
4d2e
jPZQd3d4 ZRdd5d6ZSd7d8 ZTd9d: ZUd;d< ZVd=d> ZWd?d@ ZXe
4dAe
jYZZe
4dBZ[ddCdDZ\e
4dEZ]dFdG Z^dHdI Z_dJdK Z`dLZadMdN ZbdOdP ZcG dQdR dReJZdG dSdT dTeJZeG dUdV dVeJZfdWZgddYdZZhd[d\ Zid]ZjG d^d_ d_eJZke
4d`Zle
4daZme
4dbZndcdd Zdedf ZoerddglmpZqmrZrmsZs G dhdi die$jtZtG djdk dkeqZpG dldm dmepe'Zuejvddn ZwewdokrG dpdq dqe$jxZxerG drds dse$jyZyG dtdu due%jzZzer>G dvdw dwe%j{Z{G dxdy dye%j|Z|dzd{ Z}G d|d} d}eJZ~G d~d de~ZG dd de~ZG dd de(ZG dd deJZdd ZG dd deJZdd Zdd Zdd ZddddZdd ZdS ) N)deque)iglob )DistlibException) string_types text_typeshutil raw_inputStringIOcache_from_sourceurlopenurljoinhttplib xmlrpclib splittype HTTPHandlerBaseConfigurator valid_ident Container configparserURLErrorZipFilefsdecodeunquoteurlparsez^([\w\.-]+)\s*z^([\w\.*+-]+)\s*z^(<=?|>=?|={2,3}|[~!]=)\s*z*^((<=?)|(>=?)|={2,3}|[~!]=|in|not\s+in)\s*z^or\b\s*z ^and\b\s*z(\S+)\s*z(([\s\w\.{}()*+#:;,/?!~`@$%^&=|<>\[\]-]+)c s6 dd fddfddfdd | S ) ae
Parse a marker string and return a dictionary containing a marker expression.
The dictionary will contain keys "op", "lhs" and "rhs" for non-terminals in
the expression grammar, or strings. A string contained in quotes is to be
interpreted as a literal string, and a string not contained in quotes is a
variable (such as os_name).
c S s. t | }|r,| d }| | d } n| s:tdn| d }|dvrVtd| d|d}| dd } |g}| r| d |krqqt| d |kr|| | dd } qtt| }|std| || d | | d } qtd|}td| || d|}| dd } || fS ) Nr zunexpected end of inputz'"zinvalid expression: %s r zerror in string literal: %szunterminated string: %s)
IDENTIFIERmatchgroupsend SyntaxErrorreplaceappend STRING_CHUNKjoinlstrip) remainingmresultqZoqpartss r, .marker_varc s | rR| d dkrR | dd \}} | d dkr@td| | dd } nZ| \}} | rt| }|srq| d }| | d } | \}} |||d}q^|}|| fS )Nr (r ) unterminated parenthesis: %soplhsrhs)r% r MARKER_OPr r r )r& r( r4 r' r3 r5 )markerr. r, r- marker_expre s
z!parse_marker..marker_exprc sR | \}} | rJt | }|s qJ| | d } | \}} d||d}q || fS )Nandr2 )ANDr r r& r4 r' r5 )r8 r, r-
marker_andx s
z parse_marker..marker_andc sR | \}} | rJt | }|s qJ| | d } | \}} d||d}q || fS )Norr2 )ORr r r; )r< r, r- r7 s
z parse_marker..markerr, )Z
marker_stringr, )r7 r< r8 r. r- parse_marker8 s
$ r? c C s0 | }|r|drdS t|}|s4td| | d }|| d }d } } }}|r:|d dkr:|dd}|dk rtd| |d| } ||d d }g }| r0t| }|std | | | d | | d } | sq0| d d
kr td | | dd } q|s:d}|r|d d kr|dd }t
|}|sztd
| | d }t |}
|
j r|
j
std| || d }ndd } |d dkr| |\}}n|dd}|dk rtd| |d| } ||d d }t| r@| | \}} nXt| }|s\td| | d }
| | d } | rtd| d|
fg}|r|d dkrtd| |dd }t|\}}|r|d dkrtd| |s |}n d|ddd |D f }t||||||d S ) z
Parse a requirement passed in as a string. Return a Container
whose attributes contain the various parts of the requirement.
#Nzname expected: %sr []r zunterminated extra: %szmalformed extra: %s,z comma expected in extras: %s@zinvalid URI: %szInvalid URL: %sc S s t | }d}|rg }| d }| | d } t| }|sLtd| | d }|||f | | d } | r| d dkrq| dd } | sqt | }|std| q|sd}|| fS )z|
Return a list of operator, version tuples if any are
specified, else None.
Nr zinvalid version: %srC r invalid constraint: %s)
COMPARE_OPr r r VERSION_IDENTIFIERr r" r% )Z
ver_remainingr' versionsr3 vr, r, r- get_versions s.
z'parse_requirement..get_versionsr/ r0 r1 rE z~=;zinvalid requirement: %sz unexpected trailing data: %s%s %s, c S s g | ] }d | qS )rL r, ).0Zconr, r, r-
z%parse_requirement..)nameextras constraintsr7 urlZ requirement)strip
startswithr r r r r findr% r" NON_SPACEr schemenetlocrF rG r? r$ r )reqr& r' ZdistnamerR Z mark_exprrH uriir+ trJ _rI Zrsr, r, r- parse_requirement s
r` c C s dd }i }|D ]\}}}t j| |}t|D ]p}t j||} t| D ]T}
|| |
} |du rn|| d qJ|||
} |t jjdd}
|
d | || < qJq0q|S )z%Find destinations for resources filesc S sD | tjjd} | tjjd}|| s.J |t| d dS N/)r! ospathseprV lenr% )rootrd r, r, r- get_rel_path s z)get_resources_dests..get_rel_pathNrb )rc rd r$ r popr! re rstrip)Zresources_rootZrulesrh Z destinationsbasesuffixdestprefixZabs_baseZabs_globZabs_pathZ
resource_fileZrel_pathZrel_destr, r, r- get_resources_dests s
ro c C s( t tdrd} ntjttdtjk} | S )NZ real_prefixT base_prefix)hasattrsysrn getattrr( r, r, r- in_venv( s
ru c C s t j} t| tst| } | S N)rr
executable
isinstancer r rt r, r, r- get_executable2 s
ry c C sN | }t |}| }|s |r |}|r|d }||v r6qJ|rd||| f }q|S )Nr z %c: %s
%s)r lower)promptZ
allowed_charsZ error_promptdefaultpr+ cr, r, r- proceedD s r c C s8 t |tr| }i }|D ]}|| v r| | ||< q|S rv )rx r split)dkeysr( keyr, r, r- extract_by_keyT s
r c C sv t jd dkr td| } | }t|} zlt| }|d d d }| D ]B\}}| D ]0\}}d||f }t |} | d usJ | ||< q`qP|W S t
y | dd Y n0 dd }
t
} z|
| | W n: t jy | t|}t|} |
| | Y n0 i }| D ]R} i || < }| | D ]4\}
}d|
|f }t |} | d usbJ | ||
< q8q |S )
Nr utf-8
extensionszpython.exportsexportsz%s = %sc S s$ t | dr| | n
| | d S )N read_file)rq r Zreadfp)cpstreamr, r, r- read_streamq s
z!read_exports..read_stream)rr version_infocodecs getreaderreadr
jsonloaditemsget_export_entry Exceptionseekr ConfigParserZMissingSectionHeaderErrorclosetextwrapdedentsections)r dataZjdatar( groupentrieskrI r+ entryr r r rQ valuer, r, r- read_exports] sD
r c C s t jd dkr td|}t }| D ]l\}}|| | D ]P}|j d u r\|j
}nd|j
|j f }|j rd|d |j f }|
||j| qFq,|| d S )Nr r r z%s:%sz%s [%s]rM )rr r r getwriterr r r add_sectionvaluesrl rn flagsr$ setrQ write)r r r r rI r r+ r, r, r-
write_exports s
r c c s. t } z| V W t| n t| 0 d S rv )tempfilemkdtempr rmtree)Ztdr, r, r- tempdir s r c c s8 t }z t | d V W t | n t | 0 d S rv )rc getcwdchdir)r cwdr, r, r- r s
r c c s8 t }z t | d V W t | n t | 0 d S rv )socketZgetdefaulttimeoutZsetdefaulttimeout)ZsecondsZctor, r, r- socket_timeout s
r c @ s e Zd Zdd ZdddZdS )cached_propertyc C s
|| _ d S rv )func)selfr r, r, r- __init__ s zcached_property.__init__Nc C s, |d u r | S | |}t|| j j| |S rv )r object __setattr____name__)r objclsr r, r, r- __get__ s
zcached_property.__get__)N)r
__module__ __qualname__r r r, r, r, r- r s r c C s~ t jdkr| S | s| S | d dkr.td| | d dkrFtd| | d}t j|v rh|t j qP|srt jS t jj| S )a Return '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.
rb r z path '%s' cannot be absolutez path '%s' cannot end with '/')rc re
ValueErrorr curdirremoverd r$ )pathnamepathsr, r, r- convert_path s
r c @ s e Zd Zd$ddZdd Zdd Zdd Zd%d d Zd&ddZdd Z dd Z
dd Z dd Z dd Z
d'ddZd d Zd d Zd d! Zd"d# Zd
S )( FileOperatorFc C s || _ t | _| d S rv )dry_runr ensured _init_record)r r r, r, r- r s zFileOperator.__init__c C s d| _ t | _t | _d S NF)recordr
files_written dirs_createdr r, r, r- r s zFileOperator._init_recordc C s | j r| j| d S rv )r r add)r rd r, r, r- record_as_written s z FileOperator.record_as_writtenc C sH t j|s tdt j| t j|s0dS t |jt |jkS )a Tell 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)rc rd existsr abspathstatst_mtime)r sourcetargetr, r, r- newer s
zFileOperator.newerTc C s | tj| td|| | jsd}|rdtj|rDd| }n tj|rdtj |sdd| }|rtt
|d t || |
| 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_dirrc rd dirnameloggerinfor islinkr isfiler r copyfiler )r Zinfileoutfilecheckmsgr, r, r- copy_file s
zFileOperator.copy_fileNc C s t j|rJ | t j| td|| | js~|d u rJt|d}nt j|d|d}zt
|| W | n
| 0 |
| d S )NzCopying stream %s to %swbwencoding)rc rd isdirr r r r r openr r copyfileobjr r )r Zinstreamr r Z outstreamr, r, r- copy_stream s zFileOperator.copy_streamc C sp | tj| | jsbtj|r.t| t|d}|| W d n1 sX0 Y | | d S )Nr )
r rc rd r r r r r r r )r rd r fr, r, r- write_binary_file' s
(z FileOperator.write_binary_filec C s | ||| d S rv )r encode)r rd r r r, r, r- write_text_file0 s z FileOperator.write_text_filec C sn t jdks t jdkrjt jdkrj|D ]F}| jr:td| q"t |j|B |@ }td|| t || q"d S )Nposixjavazchanging mode of %szchanging mode of %s to %o) rc rQ _namer r r r st_modechmod)r bitsmaskfilesr moder, r, r- set_mode3 s zFileOperator.set_modec C s | dd|S )Nim i )r )r+ r r, r, r- ? rP zFileOperator.c C s| t j|}|| jvrxt j|sx| j| t j|\}}| | t d| | j
sft | | j rx| j
| d S )Nz Creating %s)rc rd r r r r r r r r r mkdirr r )r rd r r r, r, r- r A s
zFileOperator.ensure_dirc C s t || }td|| | js|s0| ||rX|s:d }n ||sHJ |t|d }i }|rvttdrvtj j
|d< tj |||dfi | | | |S )NzByte-compiling %s to %sPycInvalidationModeinvalidation_modeT)
r r r r r rV rf rq
py_compiler CHECKED_HASHcompiler ) r rd optimizeforcern Zhashed_invalidationZdpathZdiagpathZcompile_kwargsr, r, r- byte_compileM s
zFileOperator.byte_compilec C s t j|rt j|r^t j|s^td| | js@t | | j
r|| j v r| j | nPt j|rpd}nd}td|| | jst | | j
r|| j
v r| j
| d S )Nz Removing directory tree at %slinkfilezRemoving %s %s)rc rd r r r r debugr r r r r r r )r rd r+ r, r, r- ensure_removed^ s"
zFileOperator.ensure_removedc C sD d}|s@t j|r$t |t j}q@t j|}||kr:q@|}q|S r )rc rd r accessW_OKr )r rd r( parentr, r, r- is_writables s zFileOperator.is_writablec C s" | j s
J | j| jf}| |S )zV
Commit recorded changes, turn off recording, return
changes.
)r r r r )r r( r, r, r- commit s
zFileOperator.commitc C s | j st| jD ]}tj|rt| qt| jdd}|D ]F}t |}|rz|dgks^J tj
||d }t | t | q>| d S )NT)reverse __pycache__r )
r listr rc rd r r sortedr listdirr$ rmdirr )r r dirsr flistsdr, r, r- rollback s
zFileOperator.rollback)F)T)N)FFNF)r r r r r r r r r r r r Zset_executable_moder r r r r r r, r, r, r- r s
r c C s^ | t jv rt j| }nt| }|d u r,|}n.|d}t||d}|D ]}t||}qJ|S )N.r )rr modules
__import__r rs ri )Z module_nameZ dotted_pathmodr( r* r} r, r, r- resolve s
r c @ s6 e Zd Zdd Zedd Zdd Zdd Zej Z d S )
ExportEntryc C s || _ || _|| _|| _d S rv rQ rn rl r )r rQ rn rl r r, r, r- r s zExportEntry.__init__c C s t | j| jS rv )r rn rl r r, r, r- r s zExportEntry.valuec C s d| j | j| j| jf S )Nzr r r, r, r- __repr__ s
zExportEntry.__repr__c C sD t |tsd}n0| j|jko>| j|jko>| j|jko>| j|jk}|S r )rx r rQ rn rl r )r otherr( r, r, r- __eq__ s
zExportEntry.__eq__N)
r r r r r r r r r __hash__r, r, r, r- r s
r z(?P(\w|[-.+])+)
\s*=\s*(?P(\w+)([:\.]\w+)*)
\s*(\[\s*(?P[\w-]+(=\w+)?(,\s*\w+(=\w+)?)*)\s*\])?
c
C s t | }|s0d }d| v s"d| v rtd| n| }|d }|d }|d}|dkrf|d }}n"|dkrztd| |d\}}|d } | d u rd| v sd| v rtd| g } nd
d | d D } t|||| }|S )
NrA rB zInvalid specification '%s'rQ callable:r r r c S s g | ] }| qS r, rU )rN r r, r, r- rO rP z$get_export_entry..rC )ENTRY_REsearchr groupdictcountr r )
Z
specificationr' r( r rQ rd Zcolonsrn rl r r, r, r- r s8
r c C s | du r d} t jdkr.dt jv r.t jd}n t jd}t j|rft |t j}|st
d| n:zt | d}W n& t y t j
d |dd
d }Y n0 |st
}t
d | t j|| 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.distlibntZ LOCALAPPDATAz
$localappdata~z(Directory exists but is not writable: %sTzUnable to create %s)exc_infoFz#Default location unusable, using %s)rc rQ environrd
expandvars
expanduserr r r r warningmakedirsOSErrorr r r$ )rl r( Zusabler, r, r- get_cache_base s&
r2 c C sB t jt j| \}}|r(|dd}|t jd}|| d S )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.
r# z---z--z.cache)rc rd
splitdriver r! re )rd r r} r, r, r- path_to_cache_dir s
r4 c C s | ds| d S | S ra )endswith)r+ r, r, r- ensure_slash$ s
r6 c C s` d }}d| v r>| dd\}} d|vr.|}n|dd\}}|rJt|}|rVt|}||| fS )NrD r r# )rsplitr r )rZ usernamepasswordrn r, r, r- parse_credentials* s r: c C s t d} t | | S )N )rc umaskrt r, r, r- get_process_umask9 s
r= c C s< d}d }t | D ]\}}t|tsd} q,q|d us8J |S )NTF) enumeraterx r )seqr( r] r+ r, r, r- is_string_sequence> s
r@ z3([a-z0-9_]+([.-][a-z_][a-z0-9_]*)*)-([a-z0-9_.+-]+)z
-py(\d\.?\d?)c C s d}d}t | dd} t| }|r@|d}| d| } |rt| t|d krtt |d | }|r|
}| d| | |d d |f}|du rt | }|r|d|d|f}|S )zw
Extract name, version, python version from a filename (no extension)
Return name, version, pyver or None
N -r z\br ) r r! PYTHON_VERSIONr& r startrf rer escaper PROJECT_NAME_AND_VERSION)filenameZ project_namer( Zpyverr' nr, r, r- split_filenameM s"
rJ z-(?P[\w .-]+)\s*\(\s*(?P[^\s)]+)\)$c C s: t | }|std| | }|d |d fS )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'rQ Zver)NAME_VERSION_REr r r' rU rz )r} r' r r, r, r- parse_name_and_versioni s
rL c C s t }t | pg } t |pg }d| v r8| d ||O }| D ]x}|dkrT|| q<|dr|dd }||vrtd| ||v r|| q<||vrtd| || q<|S )N*rB r zundeclared extra: %s)r r r rV r r/ )Z requestedZ availabler( rZunwantedr, r, r-
get_extrasx s&
rO c
C s i }zNt | }| }|d}|ds8td| ntd|}t |}W n2 t
y } zt d| | W Y d }~n
d }~0 0 |S )Nz Content-Typezapplication/jsonz(Unexpected response for JSON request: %sr z&Failed to get external data for %s: %s) r r getrV r r r r r r r exception)rT r( ZrespZheadersZctreaderer, r, r- _get_external_data s
$rT z'https://www.red-dove.com/pypi/projects/c C s* d| d | f }tt|}t|}|S )Nz%s/%s/project.jsonr upperr
_external_data_base_urlrT )rQ rT r( r, r, r- get_project_data s
rX c C s( d| d | |f }tt|}t|S )Nz%s/%s/package-%s.jsonr rU )rQ versionrT r, r, r- get_package_data s
rZ c @ s( e Zd ZdZdd Zdd Zdd ZdS ) 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.
c C sP t j|st | t |jd@ dkr6td| t jt j || _
dS )zu
Initialise an instance.
:param base: The base directory where the cache should be located.
? r z Directory '%s' is not privateN) rc rd r r0 r r r r/ r normpathrk )r rk r, r, r- r s
zCache.__init__c C s t |S )zN
Converts a resource prefix to a directory name in the cache.
)r4 )r rn r, r, r-
prefix_to_dir s zCache.prefix_to_dirc C s g }t | jD ]p}t j| j|}z>t j|s>t j|rJt | nt j|r`t
| W q t y~ | | Y q0 q|S )z"
Clear the cache.
)
rc r rk rd r$ r r r r r r r r" )r Z not_removedfnr, r, r- clear s z Cache.clearN)r r r __doc__r r^ r` r, r, r, r- r[ s r[ c @ s: e Zd ZdZdd ZdddZdd Zd d
Zd d Zd
S )
EventMixinz1
A very simple publish/subscribe system.
c C s
i | _ d S rv ) _subscribersr r, r, r- r s zEventMixin.__init__Tc C sD | j }||vr t|g||< n"|| }|r6|| n
|| dS )a`
Add a subscriber for an event.
:param event: The name of an event.
:param subscriber: The subscriber to be added (and called when the
event is published).
:param append: Whether to append or prepend the subscriber to an
existing subscriber list for the event.
N)rc r r"
appendleft)r event
subscriberr" subssqr, r, r- r s
zEventMixin.addc C s, | j }||vrtd| || | dS )z
Remove a subscriber for an event.
:param event: The name of an event.
:param subscriber: The subscriber to be removed.
zNo subscribers: %rN)rc r r )r re rf rg r, r, r- r s zEventMixin.removec C s t | j|dS )z
Return an iterator for the subscribers for an event.
:param event: The event to return subscribers for.
r, )iterrc rP )r re r, r, r- get_subscribers s zEventMixin.get_subscribersc O sp g }| |D ]J}z||g|R i |}W n tyL td d}Y n0 || qtd|||| |S )a^
Publish a event and return a list of values returned by its
subscribers.
:param event: The event to publish.
:param args: The positional arguments to pass to the event's
subscribers.
:param kwargs: The keyword arguments to pass to the event's
subscribers.
z"Exception during event publicationNz/publish %s: args = %s, kwargs = %s, result = %s)rj r r rQ r" r )r re argskwargsr( rf r r, r, r- publish
s
zEventMixin.publishN)T) r r r ra r r r rj rm r, r, r, r- rb s
rb c @ s^ e Zd Zdd Zdd ZdddZdd Zd
d Zd d
Zdd Z e
dd Z e
dd Z dS ) Sequencerc C s i | _ i | _t | _d S rv )_preds_succsr _nodesr r, r, r- r ( s zSequencer.__init__c C s | j | d S rv )rq r r noder, r, r- add_node- s zSequencer.add_nodeFc C s || j v r| j | |rt| j|dD ]}| || q,t| j|dD ]}| || qPt| j D ]\}}|sp| j|= qpt| j D ]\}}|s| j|= qd S )Nr, )rq r r ro rP rp r r )r rs Zedgesr} r+ r rI r, r, r- remove_node0 s
zSequencer.remove_nodec C s< ||ks J | j |t | | j|t | d S rv )ro
setdefaultr r rp )r predsuccr, r, r- r @ s z
Sequencer.addc C s ||ks J z| j | }| j| }W n tyB td| Y n0 z|| || W n" ty~ td||f Y n0 d S )Nz %r not a successor of anythingz%r not a successor of %r)ro rp KeyErrorr r )r rw rx predsZsuccsr, r, r- r E s
zSequencer.removec C s || j v p || jv p || jv S rv )ro rp rq )r stepr, r, r- is_stepR s zSequencer.is_stepc C s | |std| g }g }t }|| |r|d}||v rb||kr|| || q.|| || | j|d}| | q.t
|S )Nz Unknown: %rr r, ) r| r r r" ri r r ro rP extendreversed)r finalr( Ztodoseenr{ rz r, r, r- get_stepsV s"
zSequencer.get_stepsc sR dgg i i g | j fdd D ]}|vr8| q8S )Nr c s d | < d | < d d7 < | z | }W n tyT g }Y n0 |D ]J}|vr| t| | | < qZ|v rZt| | | < qZ| | krg } }| | || krqqt|} | d S )Nr r )r" r minri tuple)rs Z
successors successorZconnected_componentZ componentZgraphindexZ
index_counterZlowlinksr( stack
strongconnectr, r- r z s*
z3Sequencer.strong_connections..strongconnect)rp rr r, r r- strong_connectionso s "
z Sequencer.strong_connectionsc C sf dg}| j D ]*}| j | }|D ]}|d||f q q | jD ]}|d| q>|d d|S )Nz digraph G {z %s -> %s;z %s;}
)ro r" rq r$ )r r( rx rz rw rs r, r, r- dot s
z
Sequencer.dotN)F)
r r r r rt ru r r r| r propertyr r r, r, r, r- rn ' s
2rn ).tar.gz.tar.bz2.tar.zip.tgz.tbz.whlTc sh fdd}t j t d }|d u r| dr>d}nH| drRd}d}n4| drfd }d
}n | d rzd }d
}n td| z|dkrt| d
}|r| }|D ] }|| qn*t | |}|r|
}|D ] }|| q|dkr*t j d dk r*|
D ]"} t| jts| jd| _qdd }
|
|_| W |rd| n|rb| 0 d S )Nc sR t | ts| d} tjtj | }| rB| tjkrNt d| d S )Nr z path outside destination: %r)
rx r decoderc rd r r$ rV re r )rd r} dest_dirplenr, r-
check_path s
z unarchive..check_path)r r zip)r r Ztgzzr:gz)r r Ztbzzr:bz2r tarrN zUnknown format for %rr r r c
S sF zt | |W S t jy@ } ztt|W Y d}~n
d}~0 0 dS )z:Run tarfile.tar_fillter, but raise the expected ValueErrorN)tarfileZ
tar_filterZ FilterErrorr str)memberrd excr, r, r- extraction_filter s z$unarchive..extraction_filter)rc rd r rf r5 r r Znamelistr r Zgetnamesrr r Z
getmembersrx rQ r r r
extractallr ) Zarchive_filenamer formatr r archiver namesrQ tarinfor r, r r- unarchive sP
r c C s t }t| }t|dd}t| D ]H\}}}|D ]8}tj||}||d } tj| |}
|||
q4q&W d n1 s0 Y |S )z*zip a directory tree into a BytesIO objectr N) ioBytesIOrf r rc walkrd r$ r ) Z directoryr( Zdlenzfrg r r rQ Zfullrelrm r, r, r- zip_dir s .r )r KMGTPc @ sr e Zd ZdZdddZdd Zdd Zd
d Zd d
Ze dd Z
e dd Z dd Z e dd Z
e dd ZdS )ProgressZUNKNOWNr d c C s< |d u s||ksJ | | _ | _|| _d | _d| _d| _d S )Nr F)r curmaxstartedelapseddone)r ZminvalZmaxvalr, r, r- r s zProgress.__init__c C sV | j |ksJ | jd u s&|| jks&J || _t }| jd u rF|| _n || j | _d S rv )r r r timer r )r ZcurvalZnowr, r, r- update s
zProgress.updatec C s |dks J | | j| d S Nr )r r )r Zincrr, r, r- increment! s zProgress.incrementc C s | | j | S rv )r r r r, r, r- rD % s zProgress.startc C s | j d ur| | j d| _d S )NT)r r r r r, r, r- stop) s
z
Progress.stopc C s | j d u r| jS | j S rv )r unknownr r, r, r- maximum. s zProgress.maximumc C sD | j r d}n4| jd u r d}n$d| j| j | j| j }d| }|S )Nz100 %z ?? %g Y@z%3d %%)r r r r )r r( rI r, r, r-
percentage2 s
zProgress.percentagec C s: |dkr| j d u s | j| jkr$d}ntdt|}|S )Nr z??:??:??z%H:%M:%S)r r r r strftimegmtime)r Zdurationr( r, r, r- format_duration= s zProgress.format_durationc C s | j rd}| j}n^d}| jd u r&d}nJ| jdks<| j| jkrBd}n.t| j| j }|| j| j }|d | j }d|| |f S )NZDonezETA r r r z%s: %s)r r r r r floatr )r rn r^ r, r, r- ETAF s
z Progress.ETAc C sL | j dkrd}n| j| j | j }tD ]}|dk r6 q@|d }q&d||f S )Nr g i g @@z%d %sB/s)r r r UNITS)r r( Zunitr, r, r- speedY s
zProgress.speedN)r r )r r r r r r r rD r r r r r r r r, r, r, r- r s
r z \{([^}]*)\}z[^/\\,{]\*\*|\*\*[^/\\,}]z^[^{]*\}|\{[^}]*$c C s< t | rd}t|| t| r4d}t|| t| 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_GLOBr& r _CHECK_MISMATCH_SET_iglob) path_globr r, r, r- r n s
r c c s t | d}t|dkrht|dks,J ||\}}}|dD ]$}td|||fD ]
}|V qXq@nd| vrt| D ]
}|V qxn~| dd\}}|dkrd}|dkrd}n|d}|d }t|D ]4\}}} tj
|}ttj ||D ]
}
|
V qqd S )
Nr r rC r z**r rM rb \) RICH_GLOBr rf r r$ std_iglobr% rc r rd r] ) r Zrich_path_globrn r rl itemrd Zradicaldirr r_ r, r, r- r y s*
r ) HTTPSHandlermatch_hostnameCertificateErrorc @ s e Zd ZdZdZdd ZdS )HTTPSConnectionNTc C s^ t | j| jf| j}t| ddr0|| _| tt dsp| j
rHt j }nt j }t j
|| j| j|t j| j
d| _nt t j}tt dr| jt jO _| jr|| j| j i }| j
rt j |_|j| j
d tt ddr| j|d< |j
|fi || _| j
rZ| jrZz$t| j | j td | j W n. t yX | j t j | j Y n0 d S )
NZ _tunnel_hostF
SSLContext) cert_reqsZ ssl_versionca_certs OP_NO_SSLv2)ZcafileZHAS_SNIZserver_hostnamezHost verified: %s) r Zcreate_connectionhostporttimeoutrs sockZ_tunnelrq sslr Z
CERT_REQUIREDZ CERT_NONEZ wrap_socketZkey_fileZ cert_fileZPROTOCOL_SSLv23r optionsr Zload_cert_chainZ verify_modeZload_verify_locations check_domainr Z getpeercertr r r ZshutdownZ SHUT_RDWRr )r r r contextrl r, r, r- connect sB
zHTTPSConnection.connect)r r r r r r r, r, r, r- r s r c @ s& e Zd Zd ddZdd Zdd ZdS )
r Tc C s t | || _|| _d S rv )BaseHTTPSHandlerr r r )r r r r, r, r- r s
zHTTPSHandler.__init__c O s( t |i |}| jr$| j|_| j|_|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.
)r r r )r rk rl r( r, r, r- _conn_maker s
zHTTPSHandler._conn_makerc
C sZ z| | j|W S tyT } z,dt|jv r>td|j n W Y d }~n
d }~0 0 d S )Nzcertificate verify failedz*Unable to verify server certificate for %s)Zdo_openr r r reasonr r )r r[ rS r, r, r-
https_open s zHTTPSHandler.https_openN)T)r r r r r r r, r, r, r- r s
r c @ s e Zd Zdd ZdS )HTTPSOnlyHandlerc C s t d| d S )NzAUnexpected HTTP request on what should be a secure connection: %s)r )r r[ r, r, r- http_open s zHTTPSOnlyHandler.http_openN)r r r r r, r, r, r- r s r r c @ s e Zd ZdddZdS )HTTPr Nc K s* |dkr d }| | j||fi | d S r _setupZ_connection_classr r r rl r, r, r- r s z
HTTP.__init__)r Nr r r r r, r, r, r- r s r c @ s e Zd ZdddZdS )HTTPSr Nc K s* |dkr d }| | j||fi | d S r r r r, r, r- r s zHTTPS.__init__)r Nr r, r, r, r- r s r c @ s e Zd ZdddZdd ZdS ) Transportr c C s || _ tj| | d S rv )r r r r r r use_datetimer, r, r- r
s zTransport.__init__c C s` | |\}}}tdkr(t|| jd}n4| jr<|| jd krR|| _|t|f| _| jd }|S )Nr )r r r )
get_host_info _ver_infor r _connection_extra_headersr ZHTTPConnection)r r hehZx509r( r, r, r- make_connection s
zTransport.make_connectionN)r r r r r r r, r, r, r- r s
r c @ s e Zd ZdddZdd ZdS )
SafeTransportr c C s || _ tj| | d S rv )r r r r r r, r, r- r s zSafeTransport.__init__c C s | |\}}}|si }| j|d< tdkr>t|d fi |}n>| jrR|| jd krr|| _|tj|d fi |f| _| jd }|S )Nr r r r )r r r r r r r r )r r r r rl r( r, r, r- r " s
z SafeTransport.make_connectionN)r r r, r, r, r- r s
r c @ s e Zd Zdd ZdS ) ServerProxyc K sx | dd | _}|d ur^t|d }|dd}|dkr@t}nt}|||d |d< }|| _tjj | |fi | d S )Nr r r https)r transport)
ri r r rP r r r r r r )r r\ rl r rY r Ztclsr^ r, r, r- r 3 s zServerProxy.__init__Nr r, r, r, r- r 2 s r c K s: t jd dk r|d7 }nd|d< d|d< t| |fi |S )Nr r br newliner r )rr r r )r_ r rl r, r, r- _csv_openH s
r c @ s4 e Zd ZedededdZdd Zdd Zd S )
CSVBaserC "r )Z delimiterZ quotecharZlineterminatorc C s | S rv r, r r, r, r- __enter__Z s zCSVBase.__enter__c G s | j d S rv )r r )r r+ r, r, r- __exit__] s zCSVBase.__exit__N)r r r r defaultsr r r, r, r, r- r S s r c @ s( e Zd Zdd Zdd Zdd ZeZdS ) CSVReaderc K s` d|v r4|d }t jd dkr,td|}|| _nt|d d| _tj| jfi | j| _d S )Nr r r r rd rN ) rr r r r r r csvrR r )r rl r r, r, r- r b s zCSVReader.__init__c C s | S rv r, r r, r, r- __iter__m s zCSVReader.__iter__c C sF t | j}tjd dk rBt|D ] \}}t|ts |d||< q |S Nr r r )nextrR rr r r> rx r r )r r( r] r r, r, r- r p s
zCSVReader.nextN)r r r r r
r __next__r, r, r, r- r a s r c @ s e Zd Zdd Zdd ZdS ) CSVWriterc K s( t |d| _tj| jfi | j| _d S )Nr )r r r writerr )r r_ rl r, r, r- r { s zCSVWriter.__init__c C sN t jd dk r>g }|D ]"}t|tr.|d}|| q|}| j| d S r )rr r rx r r r" r writerow)r rowrN r r, r, r- r s
zCSVWriter.writerowN)r r r r r r, r, r, r- r z s r c sH e Zd ZeejZded< d fdd Zdd Zdd Zd
d Z Z
S )
Configurator inc_convertZincNc s" t t| | |pt | _d S rv )superr r rc r rk )r configrk __class__r, r- r s zConfigurator.__init__c
s fdd d}t|s*|} dd } dd}|r\tfdd|D } fd d D }t|}||i |}|r| D ]\}} t||| q|S )
Nc sv t | ttfr*t| fdd| D }nHt | trhd| v rH| }qri }| D ]} | | ||< qPn
| }|S )Nc s g | ] } |qS r, r, )rN r] convertr, r- rO rP zBConfigurator.configure_custom..convert..())rx r r typedictconfigure_customr )or( r )r r r, r- r s
z.Configurator.configure_custom..convertr r z[]r, c s g | ] } |qS r, r, )rN r r r, r- rO rP z1Configurator.configure_custom..c s$ g | ] }t |r| | fqS r, )r )rN r )r r r, r- rO rP )ri r" r r r r setattr)
r r r~ Zpropsrk r rl r( rI rI r, )r r r r- r s
z Configurator.configure_customc C s4 | j | }t|tr0d|v r0| | | j |< }|S )Nr )r rx r r )r r r( r, r, r- __getitem__ s
zConfigurator.__getitem__c C sZ t j|s t j| j|}tj|ddd}t|}W d n1 sL0 Y |S )z*Default converter for the inc:// protocol.rN r r N) rc rd isabsr$ rk r r r r )r r r r( r, r, r- r s
(zConfigurator.inc_convert)N) r r r r r Zvalue_convertersr r r r
__classcell__r, r, r r- r s
r c @ s* e Zd ZdZd
ddZdd Zdd ZdS ) SubprocessMixinzC
Mixin for running subprocesses and capturing their output
FNc C s || _ || _d S rv )verboseprogress)r r$ r% r, r, r- r s zSubprocessMixin.__init__c C sj | j }| j}| }|sq^|dur.||| q |s@tjd ntj|d tj q | dS )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 r ) r% r$ readlinerr stderrr r flushr )r r r r% r$ r+ r, r, r- rR s zSubprocessMixin.readerc K s t j|ft jt jd|}tj| j|jdfd}| tj| j|jdfd}| | |
|
| j d ur| dd n| j rt
jd |S )N)stdoutr' r) )r rk r' zdone.mainzdone.
)
subprocessPopenPIPE threadingThreadrR r) rD r' waitr$ r% r$ rr r )r cmdrl r} t1t2r, r, r- run_command s"
zSubprocessMixin.run_command)FN)r r r ra r rR r4 r, r, r, r- r# s
r# c C s t dd| S )z,Normalize a python package name a la PEP 503z[-_.]+rB )rE subrz )rQ r, r, r- normalize_name s r6 c @ s. e Zd ZdZdZd
ddZdd Zdd ZdS )
PyPIRCFilez https://upload.pypi.org/legacy/pypiNc C s. |d u r t jt jdd}|| _|| _d S )Nr* z.pypirc)rc rd r$ r. rH rT )r r_ rT r, r, r- r s zPyPIRCFile.__init__c
C s i }t j| jr|| jp | j}t }|| j | }d|v r*|
dd}dd | dD }|g kr~d|v r|dg}n|D ]}d|i}|
|d|d< d | jfd
| j fd fD ].\}} |
||r|
||||< q| ||< q|dkr
|| jdfv r
| j|d < q|d |kr|d |kri }qnRd |v r|d }|
|d rT|
|d }n| j}|
|d|
|d
||| j d}|S )N distutilsz
index-serversc S s g | ]}| d kr| qS )r r$ )rN serverr, r, r- rO s z#PyPIRCFile.read..r r8 r: r8
repositoryrealm)r9 Nz server-loginr9 )r8 r9 r; r: r< )rc rd r rH rT DEFAULT_REPOSITORYr RawConfigParserr r rP r
DEFAULT_REALMZ
has_option)
r r( r; r r Z
index_serversZ_serversr: r r| r, r, r- r sX
zPyPIRCFile.readc C s t }| j}|| |ds,|d |dd| |dd| t|d}|| W d n1 sr0 Y d S )Nr8 r8 r9 r ) r r> rH r Z has_sectionr r r r )r r8 r9 r r_ r r, r, r- r F s
zPyPIRCFile.update)NN)r r r r= r? r r r r, r, r, r- r7 s
:r7 c C s t | jd S )zG
Read the PyPI access configuration as supported by distutils.
)rT )r7 rT r r r, r, r- _load_pypircR s rA c C s t | j| j d S rv )r7 r r8 r9 r@ r, r, r-
_store_pypircX s rB c C s t jdkrFdtj v r dS dtj v r.dS dtj v r@dS tjS dt jv rZt jd S t jd ksntt d
sttjS t \} }}}}| d d } | d
d d d}| dd dkrd| |f S | dd dkr(|d dkrd} dt
|d d |dd f }dd d }|d |tj 7 }n| dd d krLdd l m
} | S | dd! d"krd"} td#tj}||}|r| }n>| dd! d$krddl} ddl}
| |
j | ||\} }}d%| ||f S )&a Return a string that identifies the current platform. This is used mainly to
distinguish platform-specific build directories and platform-specific built
distributions. Typically includes the OS name and version and the
architecture (as supplied by 'os.uname()'), although the exact information
included depends on the OS; eg. on Linux, the kernel version isn't
particularly important.
Examples of returned values:
linux-i586
linux-alpha (?)
solaris-2.6-sun4u
Windows will return one of:
win-amd64 (64bit Windows on AMD64 (aka x86_64, Intel64, EM64T, etc)
win32 (all others - specifically, sys.platform is returned)
For other non-POSIX platforms, currently just returns 'sys.platform'.
r) Zamd64 win-amd64z(arm) win-arm32z(arm64)z win-arm64Z_PYTHON_HOST_PLATFORMr unamerb r rA r_ rB N Zlinuxz%s-%sZsunosr 5Zsolarisz%d.%sr r Z32bitZ64bit)il z.%sZaix) aix_platformr cygwinz[\d.]+darwinz%s-%s-%s)rc rQ rr rY rz platformr, rq rE r! intmaxsizeZ _aix_supportrH rE r ASCIIr r _osx_supportZdistutils.sysconfigZget_platform_osxZ sysconfigZget_config_vars) Zosnamer releaserY machineZbitnessrH Zrel_rer' rO r9 r, r, r- get_host_platform` sN
rR win32rC rD )Zx86Zx64Zarmc C s2 t jdkrt S t jd} | tvr*t S t| S )Nr) ZVSCMD_ARG_TGT_ARCH)rc rQ rR r, rP _TARGET_TO_PLAT)Zcross_compilation_targetr, r, r- get_platform s
rU )NN)r )N)N)NT)r collectionsr
contextlibr globr r r r Zloggingrc r rE r r ImportErrorr+ rr r r r r. Zdummy_threadingr r r compatr r r r r
r r r
r r r r r r r r r r r r r Z getLoggerr r r r rG rF r6 r> r: rX r# r? r` ro ru ry r r r r contextmanagerr r r r r r r r r VERBOSEr% r r2 r4 r6 r: r= r@ IrG rC rJ rK rL rO rT rW rX rZ r[ rb rn ZARCHIVE_EXTENSIONSr r r r r r r r r r r r r r r r r r r r r r r r r r r# r6 r7 rA rB rR rT rU r, r, r, r- s
\
Y}
/
8
)
,H
C]
+)
7.QR