c C s| t j |¡}|| jkrxt j |¡sx| j |¡ t j |¡\}}| |¡ t d| ¡ | j
sft |¡ | j rx| j
|¡ d S )Nz Creating %s)rZ r[ rÈ rÀ rÇ rÅ rv rÎ rÐ rÑ r¿ Úmkdirr rÄ )r r[ rw rá r, r, r- rÎ A s
zFileOperator.ensure_dirc C s˜ t || ƒ}t d||¡ | jsŠ|s0| ||¡rX|s:d }n | |¡sHt‚|t|ƒd … }i }|rvtt dƒrvt j
j |d< t j |||df|Ž |
|¡ |S )NzByte-compiling %s to %sÚPycInvalidationModeÚinvalidation_modeT)r rÐ rÑ r¿ rÍ rN r] r^ ri Ú
py_compilerò Ú CHECKED_HASHÚcompilerÆ ) r r[ ÚoptimizeÚforcerf Zhashed_invalidationZdpathZdiagpathZcompile_kwargsr, r, r- Ú byte_compileM s
zFileOperator.byte_compilec C s² t j |¡r®t j |¡r^t j |¡s^t d|¡ | js@t |¡ | j
r®|| j kr®| j |¡ nPt j |¡rpd}nd}t d||¡ | js’t |¡ | j
r®|| j
kr®| j
|¡ d S )Nz Removing directory tree at %sÚlinkÚfilezRemoving %s %s)rZ r[ rÇ rÝ rÒ rÐ Údebugr¿ r r£ r rÄ rº rà )r r[ r+ r, r, r- Úensure_removed^ s"
zFileOperator.ensure_removedc C sH d}x>|sBt j |¡r&t |t j¡}P t j |¡}||kr)rJ rf rd r )r r, r, r- Ú__repr__µ s
zExportEntry.__repr__c C sD t |tƒsd}n0| j|jko>| j|jko>| j|jko>| j|jk}|S )NF)rn r rJ rf rd 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| ks"d| krÜtd| ƒ‚n¬| ¡ }|d }|d }| d¡}|dkrf|d }}n"|dkrztd| ƒ‚| d¡\}}|d } | d krºd| ks¨d| kr´td| ƒ‚g } nd
d „ | d ¡D ƒ} t|||| ƒ}|S )
Nr> r? zInvalid specification '%s'rJ Úcallableú:r r r c S s g | ] }| ¡ ‘qS r, )rM )rH rá r, r, r- rI å s z$get_export_entry..r@ )ÚENTRY_REÚsearchr Ú groupdictÚcountrv r )
Z
specificationr' r( rw rJ r[ Zcolonsrf rd r r, r, r- rŠ Ë s2
rŠ c C sÈ | dkr d} t jdkr.dt jkr.t j d¡}n t j d¡}t j |¡rft |t j¡}|s¢t
d|¡ n| dd¡\}} d|kr.|}n| dd¡\}}|rJt|ƒ}|rVt|ƒ}||| fS )NrA r r )Úrsplitrv r )rR ÚusernameÚpasswordrf r, r, r- Úparse_credentials* s r. c C s t d¡} t | ¡ | S )Né )rZ Úumask)r( r, r, r- Úget_process_umask9 s
r1 c C s> d}d }x$t | ƒD ]\}}t|tƒsd}P qW |d k s:t‚|S )NTF)Ú enumeratern r r] )Úseqr( rU r+ r, r, r- Úis_string_sequence> s
r4 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| ¡ … } |r˜t| ƒt|ƒd kr˜t t |¡d | ¡}|r˜|
¡ }| d|… | |d d… |f}|dkrÄt | ¡}|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” Ústartr^ Úrer Úescaper ÚPROJECT_NAME_AND_VERSION)ÚfilenameZ project_namer( Zpyverr' Únr, r, r- Úsplit_filenameM s"
r> 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'rJ Zver)ÚNAME_VERSION_REr r r rM rp )rs r' rw r, r, r- Úparse_name_and_versioni s
r@ c C s¾ t ƒ }t | pg ƒ} t |pg ƒ}d| kr8| d¡ ||O }x€| D ]x}|dkrV| |¡ q>| d¡r–|dd … }||kr‚t d| ¡ ||kr¶| |¡ q>||kr¬t d| ¡ | |¡ q>W |S )NÚ*r6 r zundeclared extra: %s)rž rº rÅ rN rÐ r# )Z requestedZ availabler( ÚrZunwantedr, r, r- Ú
get_extrasx s&
rC c
C sˆ i }yNt | ƒ}| ¡ }| d¡}| d¡s8t d|¡ nt d¡|ƒ}t |¡}W n0 t
k
r‚ } zt d| |¡ W d d }~X Y nX |S )Nz Content-Typezapplication/jsonz(Unexpected response for JSON request: %szutf-8z&Failed to get external data for %s: %s) r rÑ ÚgetrN rÐ rü r„ r… r‡ rˆ r‹ Ú exception)rL r( ZrespÚheadersÚctÚreaderÚer, r, r- Ú_get_external_data‘ s
rJ 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_urlrJ )rJ rL r( r, r, r- Úget_project_data§ s
rM c C s( d| d ¡ | |f }tt|ƒ}t|ƒS )Nz%s/%s/package-%s.jsonr )rK r
rL rJ )rJ ÚversionrL r, r, r- Úget_package_data s
rO 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@ dkr6t d|¡ t j t j |¡¡| _
dS )zu
Initialise an instance.
:param base: The base directory where the cache should be located.
é? r z Directory '%s' is not privateN) rZ r[ rÝ r$ rÉ rè rÐ r# rÈ Únormpathrc )r rc r, r, r- r® º s
zCache.__init__c C s t |ƒS )zN
Converts a resource prefix to a directory name in the cache.
)r( )r rf r, r, r- Ú
prefix_to_dirÈ s zCache.prefix_to_dirc C sŒ g }x‚t | j¡D ]r}t j | j|¡}y>t j |¡s@t j |¡rLt |¡ nt j |¡rbt
|¡ W q t k
r‚ | |¡ Y qX qW |S )z"
Clear the cache.
)
rZ r rc r[ r$ rÒ rÓ rº rÝ r r£ r‹ r" )r Z not_removedÚfnr, r, r- ÚclearÎ s z Cache.clearN)r± rµ r¶ Ú__doc__r® rS rU r, r, r, r- rP ³ s rP c @ s: e Zd ZdZdd„ Zddd„Zdd„ Zd d
„ Zd d „ Zd
S )Ú
EventMixinz1
A very simple publish/subscribe system.
c C s
i | _ d S )N)Ú _subscribers)r r, r, r- r® ã s zEventMixin.__init__Tc C sD | j }||kr 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)rX r r" Ú
appendleft)r ÚeventÚ
subscriberr" ÚsubsÚsqr, r, r- rÅ æ s
zEventMixin.addc C s, | j }||krtd| ƒ‚|| |¡ 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)rX r¸ rº )r rZ r[ r\ r, r, r- rº ú s zEventMixin.removec C s t | j |d¡ƒS )z
Return an iterator for the subscribers for an event.
:param event: The event to return subscribers for.
r, )ÚiterrX rD )r rZ r, r, r- Úget_subscribers s zEventMixin.get_subscribersc O sp g }xT| |¡D ]F}y||f|ž|Ž}W n" tk
rJ t d¡ d}Y nX | |¡ qW t d||||¡ |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)r_ r‹ rÐ rE r" rü )r rZ ÚargsÚkwargsr( r[ r˜ r, r, r- Úpublish
s
zEventMixin.publishN)T) r± rµ r¶ rV r® rÅ rº r_ rb r, r, r, r- rW ß s
rW c @ s^ e Zd Zdd„ Zdd„ Zddd„Zdd „ Zd
d „ Zd d
„ Zdd„ Z e
dd„ ƒZ e
dd„ ƒZ dS )Ú Sequencerc C s i | _ i | _tƒ | _d S )N)Ú_predsÚ_succsrž Ú_nodes)r r, r, r- r® ( s zSequencer.__init__c C s | j |¡ d S )N)rf rÅ )r Únoder, r, r- Úadd_node- s zSequencer.add_nodeFc C s¾ || j kr| j |¡ |rºx&t| j |d¡ƒD ]}| ||¡ q.W x&t| j |d¡ƒD ]}| ||¡ qVW x&t| j ¡ ƒD ]\}}|sz| j|= qzW x&t| j ¡ ƒD ]\}}|s¢| j|= q¢W d S )Nr, )rf rº rž rd rD re r r‰ )r rg Zedgesrs r+ r– rE r, r, r- Ú remove_node0 s
zSequencer.remove_nodec C s< ||ks t ‚| j |tƒ ¡ |¡ | j |tƒ ¡ |¡ d S )N)r] rd Ú
setdefaultrž rÅ re )r ÚpredÚsuccr, r, r- rÅ @ s z
Sequencer.addc C sˆ ||ks t ‚y| j| }| j| }W n tk
rD td| ƒ‚Y nX y| |¡ | |¡ W n$ tk
r‚ td||f ƒ‚Y nX d S )Nz %r not a successor of anythingz%r not a successor of %r)r] rd re ÚKeyErrorr¸ rº )r rk rl ÚpredsZsuccsr, r, r- rº E s
zSequencer.removec C s || j kp || jkp || jkS )N)rd re rf )r Ústepr, r, r- Úis_stepR s zSequencer.is_stepc C sœ | |¡std| ƒ‚g }g }tƒ }| |¡ xd|r’| d¡}||krd||kr| |¡ | |¡ q0| |¡ | |¡ | j |d¡}| |¡ q0W t
|ƒS )Nz Unknown: %rr r, ) rp r¸ rž r" ra rº rÅ rd rD ÚextendÚreversed)r Úfinalr( ZtodoÚseenro rn r, r, r- Ú get_stepsV s"
zSequencer.get_stepsc sV dg‰g ‰i ‰i ‰g ‰| j ‰ ‡ ‡‡‡‡‡‡fdd„‰x ˆ D ]}|ˆkr:ˆ|ƒ q:W ˆS )Nr c sø ˆd ˆ| < ˆd ˆ| < ˆd d7 < ˆ | ¡ y ˆ | }W n tk
rV g }Y nX xR|D ]J}|ˆkrŠˆ|ƒ tˆ| ˆ| ƒˆ| < q^|ˆkr^tˆ| ˆ| ƒˆ| < q^W ˆ| ˆ| krôg }x ˆ ¡ }| |¡ || krÂP qÂW t|ƒ}ˆ |¡ d S )Nr r )r" r‹ Úminra Útuple)rg Z
successorsZ successorZconnected_componentZ component)ÚgraphÚindexÚ
index_counterÚlowlinksr( ÚstackÚ
strongconnectr, r- r} z s.
z3Sequencer.strong_connections..strongconnect)re )r rg r, )rx ry rz r{ r( r| r} r- Ústrong_connectionso s "
z Sequencer.strong_connectionsc C sr dg}x8| j D ].}| j | }x |D ]}| d||f ¡ q"W qW x | jD ]}| d| ¡ qHW | d¡ d |¡S )Nz digraph G {z %s -> %s;z %s;Ú}Ú
)rd r" rf r$ )r r( rl rn rk rg r, r, r- Údot¢ s
z
Sequencer.dotN)F)
r± rµ r¶ r® rh ri rÅ rº rp ru Úpropertyr~ r r, r, r, r- rc ' s
3rc )z.tar.gzz.tar.bz2z.tarz.zipz.tgzz.tbzz.whlTc
sX ‡ ‡fdd„}t j ˆ ¡‰ tˆ ƒ‰d }|d kr†| d¡r>d}nH| d¡rRd}d}n4| d¡rfd }d
}n | d ¡rzd }d
}n td| ƒ‚z¼|dkr¾t| d
ƒ}|rì| ¡ }xD|D ] }||ƒ q¬W n.t | |¡}|rì|
¡ }x|D ] }||ƒ qÜW |dkr6t j d dk r6x.|
¡ D ]"} t| jtƒs| j d¡| _qW | ˆ ¡ W d |rR| ¡ X d S )Nc sR t | tƒs| d¡} tj tj ˆ | ¡¡}| ˆ ¡rB|ˆ tjkrNt d| ƒ‚d S )Nzutf-8z path outside destination: %r)
rn r ÚdecoderZ r[ rÈ r$ rN r\ r¸ )r[ rs )Údest_dirÚplenr, r- Ú
check_path· s
z unarchive..check_path)z.zipz.whlÚzip)z.tar.gzz.tgzZtgzzr:gz)z.tar.bz2z.tbzZtbzzr:bz2z.tarÚtarrB zUnknown format for %rr r{ zutf-8)rZ r[ rÈ r^ r) r¸ r ÚnamelistÚtarfilerÞ Zgetnamesrj rƒ Z
getmembersrn rJ r rƒ Ú
extractallr )
Zarchive_filenamer„ Úformatr× r† Úarchiverí ÚnamesrJ Útarinfor, )r„ r… r- Ú unarchiveµ sH
r c C s† t ¡ }t| ƒ}t|dƒb}xZt | ¡D ]L\}}}x@|D ]8}tj ||¡}||d… } tj | |¡}
| ||
¡ q8W q(W W dQ R X |S )z*zip a directory tree into a BytesIO objectrÛ N) ÚioÚBytesIOr^ r rZ Úwalkr[ r$ rŸ ) Ú directoryr( ZdlenÚzfr_ r rì rJ ZfullZrelre r, r, r- Úzip_dirë s
r– )r ÚKÚMÚGÚTÚPc @ sr e Zd ZdZddd„Zdd„ Zdd „ Zd
d „ Zd d
„ Ze dd„ ƒZ
e dd„ ƒZ dd„ Z e dd„ ƒZ
e dd„ ƒZdS )ÚProgressÚUNKNOWNr éd c C s< |d ks||kst ‚| | _| _|| _d | _d| _d| _d S )Nr F)r] rv ÚcurÚmaxÚstartedÚelapsedÚdone)r ZminvalZmaxvalr, r, r- r® s zProgress.__init__c C sV | j |kst‚| jd ks&|| jks&t‚|| _t ¡ }| jd krF|| _n || j | _d S )N)rv r] r rŸ Útimer¡ r¢ )r ZcurvalZnowr, r, r- Úupdate
s
zProgress.updatec C s |dks t ‚| | j| ¡ d S )Nr )r] r¥ rŸ )r Zincrr, r, r- Ú increment s zProgress.incrementc C s | | j¡ | S )N)r¥ rv )r r, r, r- r8 s zProgress.startc C s | j d k r| | j ¡ d| _d S )NT)r r¥ r£ )r r, r, r- Ústop s
z
Progress.stopc C s | j d kr| jS | j S )N)r Úunknown)r r, r, r- Úmaximum! s zProgress.maximumc C sD | j r d}n4| jd kr d}n$d| j| j | j| j }d| }|S )Nz100 %z ?? %g Y@z%3d %%)r£ r rŸ rv )r r( rE r, r, r- Ú
percentage% s
zProgress.percentagec C s: |dkr| j d ks | j| jkr$d}nt dt |¡¡}|S )Nr z??:??:??z%H:%M:%S)r rŸ rv r¤ ÚstrftimeÚgmtime)r Zdurationr( r, r, r- Úformat_duration0 s zProgress.format_durationc C s‚ | j rd}| j}n^d}| jd kr&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Ÿ rv Úfloatr )r rf rV r, r, r- ÚETA9 s
z Progress.ETAc C sN | j dkrd}n| j| j | j }x tD ]}|dk r6P |d }q(W d||f S )Nr g iè g @@z%d %sB/s)r¢ rŸ rv ÚUNITS)r r( Zunitr, r, r- ÚspeedL s
zProgress.speedN)r rž )r± rµ r¶ r¨ r® r¥ r¦ r8 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 a s
r c c s t | d¡}t|ƒdkrpt|ƒdks,t|ƒ‚|\}}}xâ| d¡D ](}x"td |||f¡ƒD ]
}|V q\W qBW nªd| kr’x t| ƒD ]
}|V q‚W nˆ| dd¡\}}|dkr®d}|dkr¼d}n| d¡}| d ¡}xHt |¡D ]:\}}} tj
|¡}x"ttj
||¡ƒD ] }
|
V qW qÜW d S )
Nr r{ r@ r z**r rA rY ú\) Ú RICH_GLOBrv r^ r] r´ r$ Ú std_iglobr% rZ r“ r[ rR ) rµ Zrich_path_globrf rž rd Úitemr[ ZradicalÚdirrì rT r, r, r- r´ l s*
r´ )Ú HTTPSHandlerÚmatch_hostnameÚCertificateErrorc @ s e Zd ZdZdZdd„ ZdS )ÚHTTPSConnectionNTc C s t | j| jf| j¡}t| ddƒr0|| _| ¡ t tj
¡}t tdƒrV| j tj
O _ | jrl| | j| j¡ i }| jr¢tj|_|j| jd ttddƒr¢| j|d< |j|f|Ž| _| jr| jry$t| j ¡ | jƒ t d| j¡ W n0 tk
r | j t j ¡ | j ¡ ‚ Y nX d S )NZ _tunnel_hostFÚ OP_NO_SSLv2)ZcafileZHAS_SNIZserver_hostnamezHost verified: %s) r© Zcreate_connectionÚhostZportÚtimeoutrk ÚsockZ_tunnelÚsslZ
SSLContextZPROTOCOL_SSLv23ri Úoptionsr¿ Z cert_fileZload_cert_chainZkey_fileÚca_certsZ
CERT_REQUIREDZ verify_modeZload_verify_locationsZ wrap_socketÚ check_domainr¼ Z getpeercertrÐ rü r½ ÚshutdownZ SHUT_RDWRr )r r Úcontextra r, r, r- Úconnect• s0
zHTTPSConnection.connect)r± rµ r¶ rÅ rÆ rÉ r, r, r, r- r¾ s r¾ c @ s& e Zd Zd dd„Zdd„ Zdd„ ZdS )
r» Tc C s t | ¡ || _|| _d S )N)ÚBaseHTTPSHandlerr® rÅ rÆ )r rÅ rÆ r, r, r- r® ² s
zHTTPSHandler.__init__c O s$ t ||Ž}| 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 r` ra r( r, r, r- Ú _conn_maker· s
zHTTPSHandler._conn_makerc
C sV y| | j|¡S tk
rP } z$dt|jƒkr>td|j ƒ‚n‚ W d d }~X Y nX d S )Nzcertificate verify failedz*Unable to verify server certificate for %s)Zdo_openrË r ÚstrÚreasonr½ rÀ )r rS rI 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 rS r, r, r- Ú http_openÛ s zHTTPSOnlyHandler.http_openN)r± rµ r¶ rÐ r, r, r, r- rÏ Ú s rÏ c @ s e Zd Zddd„Zdd„ ZdS )Ú Transportr c C s || _ tj | |¡ d S )N)rÁ r rÑ r® )r rÁ Ú use_datetimer, r, r- r® ã s zTransport.__init__c C sD | |¡\}}}| jr$|| jd kr:|| _|t |¡f| _| jd S )Nr r )Ú
get_host_infoÚ _connectionÚ_extra_headersr ZHTTPConnection)r rÀ ÚhÚehZx509r, 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 Zddd„Zdd„ ZdS )Ú
SafeTransportr c C s || _ tj | |¡ d S )N)rÁ r rÙ r® )r rÁ rÒ r, r, r- r® ð s zSafeTransport.__init__c C s\ | |¡\}}}|si }| j|d< | jr6|| jd krR|| _|tj|d f|Žf| _| jd S )NrÁ r r )rÓ rÁ rÔ rÕ r r¾ )r rÀ rÖ r× ra r, r, r- rØ ô s
z SafeTransport.make_connectionN)r )r± rµ r¶ r® rØ r, r, r, r- rÙ ï s
rÙ c @ s e Zd Zdd„ ZdS )Ú ServerProxyc K st | dd ¡ | _}|d k r^t|ƒd }| dd¡}|dkr@t}nt}|||d |d< }|| _tjj | |f|Ž d S )NrÁ r rÒ Zhttps)rÒ Ú transport)
ra rÁ r rD rÙ rÑ rÛ r rÚ r® )r rT ra rÁ rQ rÒ ZtclsrV r, r, r- r® s zServerProxy.__init__N)r± rµ r¶ r® r, r, r, r- rÚ s rÚ c K s6 t jd dk r|d7 }nd|d< d|d< t| |f|ŽS )Nr r{ Úbr Únewlinezutf-8rÜ )rj rƒ rÞ )rT rí ra r, r, r- Ú _csv_open s
rÞ c @ s4 e Zd ZedƒedƒedƒdœZdd„ Zdd„ Zd S )
ÚCSVBaser@ ú"r€ )Ú delimiterZ quotecharZlineterminatorc C s | S )Nr, )r r, r, r- Ú __enter__( s zCSVBase.__enter__c G s | j ¡ d S )N)r r )r r r, r, r- Ú__exit__+ s zCSVBase.__exit__N)r± rµ r¶ rÌ Údefaultsrâ rã r, r, r, r- rß ! s
rß c @ s( e Zd Zdd„ Zdd„ Zdd„ ZeZdS )Ú CSVReaderc K s\ d|kr4|d }t jd dkr,t d¡|ƒ}|| _nt|d dƒ| _tj| jf| jŽ| _d S )Nr r r{ zutf-8r[ rB ) rj rƒ r„ r… r rÞ ÚcsvrH rä )r ra r r, r, r- r® 0 s zCSVReader.__init__c C s | S )Nr, )r r, r, r- Ú__iter__; s zCSVReader.__iter__c C sJ t | jƒ}tjd dk rFx,t|ƒD ] \}}t|tƒs"| d¡||< q"W |S )Nr r{ zutf-8)ÚnextrH rj rƒ r2 rn r rƒ )r r( rU r¹ r, r, r- rè > s
zCSVReader.nextN)r± rµ r¶ r® rç rè Ú__next__r, r, r, r- rå / s rå c @ s e Zd Zdd„ Zdd„ ZdS )Ú CSVWriterc K s$ t |dƒ| _tj| jf| jŽ| _d S )NrÛ )rÞ r ræ Úwriterrä )r rT ra r, r, r- r® I s zCSVWriter.__init__c C sR t jd dk rBg }x*|D ]"}t|tƒr0| d¡}| |¡ qW |}| j |¡ d S )Nr r{ zutf-8)rj rƒ rn r rã r" rë Úwriterow)r ÚrowrB r¹ r, r, r- rì M s
zCSVWriter.writerowN)r± rµ r¶ r® rì r, r, r, r- rê H s rê c sH e Zd ZeejƒZded< d ‡ fdd„ Zdd„ Zdd „ Zd
d „ Z ‡ Z
S )
Ú ConfiguratorÚ inc_convertZincNc s" t t| ƒ |¡ |pt ¡ | _d S )N)Úsuperrî r® rZ r¥ rc )r Úconfigrc )Ú __class__r, r- r® ` s zConfigurator.__init__c
s° ‡‡fdd„‰ˆ d¡}t|ƒs*ˆ |¡}ˆ dd ¡}ˆ dd¡}|r\t‡fdd„|D ƒƒ}‡ ‡fd d„ˆ D ƒ}t|ƒ}|||Ž}|r¬x$| ¡ D ]\}} t||ˆ| ƒƒ qW |S )
Nc sz t | ttfƒr*t| ƒ‡ fdd„| D ƒƒ}nLt | tƒrld| krHˆ | ¡}qvi }x(| D ]}ˆ | | ƒ||< qRW n
ˆ | ¡}|S )Nc s g | ] }ˆ |ƒ‘qS r, r, )rH rU )Úconvertr, r- rI g s zBConfigurator.configure_custom..convert..z())rn r rw ÚtypeÚdictÚconfigure_customró )Úor( r– )ró r r, r- ró e s
z.Configurator.configure_custom..convertz()r z[]r, c s g | ] }ˆ |ƒ‘qS r, r, )rH r÷ )ró r, r- rI z s z1Configurator.configure_custom..c s$ g | ] }t |ƒr|ˆˆ | ƒf‘qS r, )r )rH r– )rñ ró r, r- rI { s )ra r r rw rõ r‰ Úsetattr)
r rñ rt Úpropsr` r‰ ra r( r= rE r, )rñ ró r r- rö d s
z Configurator.configure_customc C s4 | j | }t|tƒr0d|kr0| |¡ | j |< }|S )Nz())rñ rn rõ rö )r ry r( r, r, r- Ú __getitem__ƒ s
zConfigurator.__getitem__c C sF t j |¡s t j | j|¡}tj|ddd}t |¡}W dQ R X |S )z*Default converter for the inc:// protocol.rB zutf-8)rÜ N) rZ r[ Úisabsr$ rc 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
dd„Zdd„ Zdd „ ZdS ) ÚSubprocessMixinzC
Mixin for running subprocesses and capturing their output
FNc C s || _ || _d S )N)ÚverboseÚprogress)r rþ rÿ r, r, r- r® – s zSubprocessMixin.__init__c C sn | j }| j}xT| ¡ }|s P |dk r0|||ƒ q|sBtj d¡ ntj | d¡¡ tj ¡ qW | ¡ 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 zutf-8) rÿ rþ Úreadlinerj ÚstderrrŸ rƒ Úflushr )r r rÈ rÿ rþ r+ r, r, r- rH š s zSubprocessMixin.readerc K sž t j|ft jt jdœ|—Ž}tj| j|jdfd}| ¡ tj| j|jdfd}| ¡ | ¡ |
¡ |
¡ | j d k rˆ| dd¡ n| j ršt
j d¡ |S )N)Ústdoutr r )rÌ r` r zdone.Úmainzdone.
)Ú
subprocessÚPopenÚPIPEÚ threadingÚThreadrH r r8 r Úwaitr$ rÿ rþ rj rŸ )r Úcmdra rs Zt1Zt2r, r, r- Ú run_command¯ s
zSubprocessMixin.run_command)FN)r± rµ r¶ rV r® rH r r, r, r, r- rý ’ s
rý c C s t dd| ¡ ¡ S )z,Normalize a python package name a la PEP 503z[-_.]+r6 )r9 Úsubrp )rJ r, r, r- Únormalize_nameÀ s r c @ s. e Zd ZdZdZd
dd„Zdd„ Zdd „ ZdS ) Ú
PyPIRCFilez https://upload.pypi.org/legacy/ÚpypiNc C s. |d kr t j t j d¡d¡}|| _|| _d S )Nr z.pypirc)rZ r[ r$ r" r< rL )r rT rL r, r, r- r® Ô s zPyPIRCFile.__init__c
C sˆ i }t j | j¡r„| jp | j}t ¡ }| | j¡ | ¡ }d|kr2|
dd¡}dd„ | d¡D ƒ}|g kr~d|kr|dg}n²x°|D ]¨}d|i}|
|d¡|d< xHd | jfd
| j fd fD ].\}} |
||¡rÞ|
||¡||< q¸| ||< q¸W |dkr|| jdfkr| j|d < q„|d |kr„|d |kr„i }q„W nRd |kr„d }|
|d ¡r\|
|d ¡}n| j}|
|d¡|
|d
¡||| j dœ}|S )NÚ distutilsz
index-serversc S s g | ]}| ¡ d kr| ¡ ‘qS )r )rM )rH Úserverr, r, r- rI æ s z#PyPIRCFile.read..r€ r r r, Ú
repositoryÚrealm)r- Nz server-loginr- )r, r- r r r )rZ r[ rÇ r< rL ÚDEFAULT_REPOSITORYr ÚRawConfigParserr† r’ rD rv Ú
DEFAULT_REALMÚ
has_option)
r r( r rñ r’ Ú
index_serversÚ_serversr ry rr r, r, r- r† Ú sN
zPyPIRCFile.readc C sl t ¡ }| j}| |¡ | d¡s,| d¡ | dd|¡ | dd|¡ t|dƒ}| |¡ W d Q R X d S )Nr r, r- rÛ ) r r r< r† Ú has_sectionr› rž rÞ rŸ )r r, r- rñ rT rá r, r, r- r¥ s
zPyPIRCFile.update)NN)r± rµ r¶ r r r® r† r¥ r, r, r, r- r Ï s
:r c C s t | jd ¡ S )zG
Read the PyPI access configuration as supported by distutils.
)rL )r rL r† )ry r, r, r- Ú _load_pypirc s r c C s t ƒ | j| j¡ d S )N)r r¥ r, r- )ry r, r, r- Ú
_store_pypirc& s r c C sÖ t jdkrFdtj ¡ kr dS dtj ¡ kr.dS dtj ¡ kr@dS tjS dt jkrZt jd S t jd ksntt d
ƒsttjS t ¡ \} }}}}| ¡ d d ¡} | d
d¡ d d¡}| dd… dkrÆd| |f S | dd… dkr(|d dkrÈd} dt
|d ƒd |dd… f }dd d œ}|d |tj 7 }n | dd… d krLdd l m
} |ƒ S | dd!… d"krŠd"} t d#tj¡}| |¡}|rÈ| ¡ }n>| dd!… d$krÈddl} 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 Úamd64z win-amd64z(arm)z win-arm32z(arm64)z win-arm64Ú_PYTHON_HOST_PLATFORMrå ÚunamerY r r5 rW r6 Né Úlinuxz%s-%sÚsunosr Ú5Úsolarisz%d.%sr{ é Ú32bitÚ64bit)iÿÿÿl ÿÿÿÿ z.%sÚaix)Ú aix_platformé Úcygwinz[\d.]+Údarwinz%s-%s-%s)rZ rJ rj rN rp Úplatformr ri r r! ÚintÚmaxsizeZ _aix_supportr* r9 rö ÚASCIIr r” Ú _osx_supportÚdistutils.sysconfigÚget_platform_osxÚ sysconfigÚget_config_vars) ÚosnamerÀ ÚreleaserN ÚmachineÚbitnessr* Úrel_rer' r2 r r, r, r- Úget_host_platform. sL
r< Úwin32z win-amd64z win-arm32)Zx86Zx64Zarmc C s2 t jdkrtƒ S t j d¡} | tkr*tƒ S t| S )Nr ZVSCMD_ARG_TGT_ARCH)rZ rJ r< r rD Ú_TARGET_TO_PLAT)Zcross_compilation_targetr, r, r- Ú get_platform† s
r? )NN)r¨ )N)N)NT)†r„ Ú collectionsr Ú
contextlibræ Zglobr r¸ r‘ r‡ ÚloggingrZ rô r9 r© rÃ Ú ImportErrorr rj 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 Ú getLoggerr± rÐ rö r rC rB r4 r; r8 rP r# r< rX rg rl ro ru rz r™ r Úcontextmanagerr¤ r¦ rª r¯ r« r½ r¾ r r ÚVERBOSEr rŠ r& r( r* r. r1 r4 ÚIr; r7 r> r? r@ rC rJ rL rM rO rP rW rc 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 r< r> r? r, r, r, r- Ú sâ
\
Y}
/
8
)
,H
6]
!) 7.QR