HEX
Server: Apache
System: Linux pdx1-shared-a1-38 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64
User: mmickelson (3396398)
PHP: 8.1.31
Disabled: NONE
$ pwd: /usr/lib/python3/dist-packages/hgext/__pycache__/
Upload Files
File: //usr/lib/python3/dist-packages/hgext/__pycache__/phabricator.cpython-310.pyc
o

�]Lb�B�@s4dZddlmZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlm
Z
mZddlmZddlmZddlmZddlmZmZmZmZmZmZmZmZmZm 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/m0Z0dd	l1m2Z2m3Z3m4Z4d
dl5m6Z6dZ7e��Z8e8j9Z9e8j:Z:e8j;Z;e8j<Z<e8j=Z>e8j?d
ddd�e8j?d
ddd�e8j?d
ddd�e8j?d
ddd�e8j?d
ddd�e8j?d
ddd�e8j?d
dd
d�e8j?d
ddd�e8j?dddd�e8j?dddd�e8j?dddd�dddd d!d"dd#d$d$d%�
Z@d&d'd&ed(�fgZAe8�Bed)�d*d+��ZCd�d,d-�ZDd.d/�ZEd0d1�ZFd2d3�ZGd4d5�ZHeDd6ged7�d8d9�d:d;��ZId<d=�ZJe
�Kd>�ZLe
�Kd?e
jM�ZNd@dA�ZOdBdC�ZPdDdE�ZQGdFdG�dGeR�ZSGdHdI�dIeR�ZTejUGdJdK�dKeV��ZWejUGdLdM�dMeR��ZXejUGdNdO�dOeR��ZYdPdQ�ZZdRdS�Z[dTdU�Z\dVdW�Z]dXdY�Z^dZd[d\d]�Z_d^d_�Z`d`da�Zadbdc�Zbddde�Zcdfdg�Zddhdi�Ze							d�djdk�Zfdldm�Zgdndo�Zhdpdq�ZieDddrdsgedt�edu�fd&dvd8edw�fd&dxgedy�fd&dzged{�fd|d}d&ed~�fd&dded�fd&d�ded��fged��e:jjd��d�d���Zke0�lgd���Zmd�d��Znhd��Zod�d��Zpd�d�d�d�d�d�d�d�d��Zqd�d��Zrd�d��Zsd�d��Ztd�d��Zud�d��Zvd�d��Zwd�d��Zxd�d��Zyd�d��Zzd�d��Z{d�d��Z|eDd�d&d�ded��fged��e:jjd8d��d�d���Z}eDdd&d�ded��fged��e:jjd��d�d���Z~eDd�d&d�ded��fd&d�ded��fd&d�ded��fd&d�ded��fd&d�ded��fd&d�ded��fd&d�dedƒfd&d�dedăfd&d�dedƃfd&d�dedȃfd|d}d&edɃfdrdsd&edʃedu�fged˃e:jjd8d��d�d̈́�Ze8j<d�d�hdЍd�d҄�Z�e8j<d�hdԣdЍd�dք�Z�e6j�d�d�d؍d�dڄ�Z�dS)�asimple Phabricator integration (EXPERIMENTAL)

This extension provides a ``phabsend`` command which sends a stack of
changesets to Phabricator, and a ``phabread`` command which prints a stack of
revisions in a format suitable for :hg:`import`, and a ``phabupdate`` command
to update statuses in batch.

A "phabstatus" view for :hg:`show` is also provided; it displays status
information of Phabricator differentials associated with unfinished
changesets.

By default, Phabricator requires ``Test Plan`` which might prevent some
changeset from being sent. The requirement could be disabled by changing
``differential.require-test-plan-field`` config server side.

Config::

    [phabricator]
    # Phabricator URL
    url = https://phab.example.com/

    # Repo callsign. If a repo has a URL https://$HOST/diffusion/FOO, then its
    # callsign is "FOO".
    callsign = FOO

    # curl command to use. If not set (default), use builtin HTTP library to
    # communicate. If set, use the specified curl command. This could be useful
    # if you need to specify advanced options that is not easily supported by
    # the internal library.
    curlcmd = curl --connect-timeout 2 --retry 3 --silent

    # retry failed command N time (default 0). Useful when using the extension
    # over flakly connection.
    #
    # We wait `retry.interval` between each retry, in seconds.
    # (default 1 second).
    retry = 3
    retry.interval = 10

    # the retry option can combine well with the http.timeout one.
    #
    # For example to give up on http request after 20 seconds:
    [http]
    timeout=20

    [auth]
    example.schemes = https
    example.prefix = phab.example.com

    # API token. Get it from https://$HOST/conduit/login/
    example.phabtoken = cli-xxxxxxxxxxxxxxxxxxxxxxxxxxxx
�)�absolute_importN)�bin�short)�_)�getattr)�attr)�cmdutil�context�copies�encoding�error�	exthelper�graphmod�httpconnection�	localrepo�
logcmdutil�match�mdiff�obsutil�parser�patch�phases�pycompat�rewriteutil�scmutil�smartset�tags�templatefilters�templateutil�url�util)�procutil�
stringutil�urlutil�)�showsships-with-hg-core�phabricator�	batchsize���default�callsign�curlcmd�debugF�repophid�retry�retry.interval�url�phabsend�confirm�
phabimport�secret�obsoletesgreensmagentasboldsmagenta dims
green boldsyellowsred)
sphabricator.action.createdsphabricator.action.skippedsphabricator.action.updated�phabricator.drevsphabricator.status.abandonedsphabricator.status.acceptedsphabricator.status.closedsphabricator.status.needsreviews phabricator.status.needsrevisions!phabricator.status.changesplanned�stest-vcrs�Path to a vcr file. If nonexistent, will record a new vcr transcript, otherwise will mock all http requests using the specified vcr file. (ADVANCED)�loadhgrcc	Os�d}i}zt�|�d��}	t�dd�t�|	��}d}Wnty0|�td�|�	d��Yn	t
y8Ynwt��}
d|vrG|d|
d<d	|vrQ|d	|
d
<|
r]|j
|
|�	d�d�|||||g|�Ri|��pl|S)zBLoad ``.arcconfig`` content into a ui instance on repository open.Fs
.arcconfigcS�t|tj�rt�|�S|S�N��
isinstancer�unicoder�
unitolocal��x�rB�3/usr/lib/python3/dist-packages/hgext/phabricator.py�<lambda>��
�z_loadhgrc.<locals>.<lambda>Tsinvalid JSON in %s
srepository.callsign)r&r+sphabricator.uri�r&r1)�source)r�unifromlocal�readr�rapply�
json_loads�
ValueError�warnr�join�IOErrorr �sortdict�applyconfig)�orig�ui�wdirvfs�hgvfs�requirements�args�opts�result�	arcconfig�	rawparams�cfgrBrBrC�	_loadhgrc�s.���r]cs>|t�dd��dd��dd����������fdd�}|S)	NcSs�|j|jks|j|jkrdStj�|j�}tj�|j�}|D]:}||vr'dS||d}|�d�rM|�d�rMt�	|�}t�	||d�}||krLdSq||d|krXdSqdS)NFr�{�}T)
�uri�methodr �urlreq�parseqs�body�
startswith�endswithrrK)�r1�r2�r1params�r2params�key�value�r1json�r2jsonrBrBrC�	hgmatcher�s$
��zvcrcommand.<locals>.hgmatchercSst�dd|j�|_|S)Ns
cli-[a-z0-9]+scli-hahayouwish)�re�subrd)�requestrBrBrC�sanitiserequests�z#vcrcommand.<locals>.sanitiserequestcSsd|dvr|dd=|S)Nz
set-cookie�headersrB)�responserBrBrC�sanitiseresponses
z$vcrcommand.<locals>.sanitiseresponsecsF����fdd�}tj|dd�}�j|_�j|_t�����d�|�S)Nc	s�|�d�}|rmt�|�}ddl}|���Qddl}ddlm}|jd��t	d|j
ft	d|jfgd�}|�d��|j
|dgd���|i|��Wd�Wd�S1sYwYWd�n1shwY�|i|��S)	N�test_vcrr�jsonr�httpsconnection)�
serializer�before_record_request�before_record_response�custom_patchesro)�match_on)�popr�fsdecode�hgdemandimport�deactivated�vcr�	vcr.stubs�stubs�VCR�urlmod�VCRHTTPConnection�VCRHTTPSConnection�register_matcher�use_cassette)rW�kwargsr��cassetter��vcrmodr�)�fnrorsrvrBrC�inners:


�������z+vcrcommand.<locals>.decorate.<locals>.inner�)�depth��helpcategory�optionalrepo)r �checksignature�__name__�__doc__�command)r�r��cmd��	fullflagsr�ro�namer�rsrv�spec)r�rC�decorates ��zvcrcommand.<locals>.decorate)�
_VCR_FLAGS)r��flagsr�r�r�r�rBr�rC�
vcrcommand�s-r�cOsB|�dd�r|j}zd|_|j|i|��W||_dS||_wdS)z�write debug output for Phabricator if ``phabricator.debug`` is set

    Specifically, this avoids dumping Conduit and HTTP auth chatter that is
    printed with the --debug argument.
    r&r-TN)�
configbool�	debugflag�write)rS�msgrX�flagrBrBrC�_debugKs�r�cs,t�����fdd���d|�tj���S)alike urlencode, but works with nested parameters.

    For example, if params is {'a': ['b', 'c'], 'd': {'e': 'f'}}, it will be
    flattened to {'a[0]': 'b', 'a[1]': 'c', 'd[e]': 'f'} and then passed to
    urlencode. Note: the encoding is consistent with PHP's http_build_query.
    cs�t|t�rddd�|}dd�}t|tdd�i�t|��}|dur'|�|<dS||�D]\}}|r;�d||f|�q+�||�q+dS)Nstruesfalse)TFcSsdd�t|�D�S)NcSsg|]
\}}d||f�qS)�%drB)�.0�k�vrBrBrC�
<listcomp>f�zFurlencodenested.<locals>.process.<locals>.<lambda>.<locals>.<listcomp>)�	enumerate)�lrBrBrCrDfsz2urlencodenested.<locals>.process.<locals>.<lambda>cSs|��Sr;)�itemsr@rBrBrCrDg�s%s[%s])r=�bool�list�dict�get�type)�prefix�obj�listerr�r�r���
flatparams�processrBrCr�cs
�z urlencodenested.<locals>.processr8)r rPr#rb�	urlencode)�paramsrBr�rC�urlencodenestedZs
r�cCs�|�dd�}|st�td�d��t�||t�|�j�}d}|r0|\}}|�	d|�|�
d�}|s<t�td�|f��||fS)	z�return conduit url, token and make sure they exist

    Currently read from [auth] config section. In the future, it might
    make sense to read from .arcconfig and .arcrc as well.
    r&r1sconfig %s.%s is requiredrFNs#using auth.%s.* for authentication
s	phabtokens)Can't find conduit token associated to %s)�configr�Abortr�httpconnectionmod�readauthforurir#r�user�debugr�)rSr�res�token�group�authrBrBrC�readurltokenus 
�
�r�cCst|�\}}t�d�|d|g����\}}|�d|t�|�f�|��}d|i|d<t	�
|�ddd�}t|�}|�d	d
�}	|	r\t
�d|	t
�|�f�\}
}|
�|�|
��|��}nzt�||�}
tjjt�|�|d�}|�d	d
�d}|�tdd�}t|�D]U}z!t�|
j||d���}|��}Wd�n1s�wYWn2tj j!y�}z$||dkr��|�d|d||f�|�d	d�}t"�#|�WYd}~q�d}~ww|�d|�t�$dd�t�%t&�'|���}|�(d��rt)d�|d|df}t*�+|��|dS)zEcall Conduit API, params is a dict. return json.loads result, or None�/sapisConduit Call: %s %s
stoken�__conduit__sjsonr$)sparamssoutputr�r&r,s%s -d @- %s)�datar/shttpstimeout)�timeoutNs'Conduit Request failed (try %d/%d): %r
r0sConduit Response: %s
cSr:r;r<r@rBrBrCrD�rEzcallconduit.<locals>.<lambda>s
error_codesConduit Error (%s): %ss
error_infosresult),r�r#rrN�authinfor�r�byterepr�copyrrxr�r�r!�popen2�
shellquoter��closerIr��openerr rbrr�strurl�	configint�
configwith�float�range�
contextlib�closing�open�urlerr�urlerror�time�sleeprJrKrrHr�rrr�)rSr�r��hostr�rr��rawdatar��curlcmd�sin�soutrd�	urlopenerrr�max_tryr��	try_count�rsp�err�retry_interval�parsedr�rBrBrC�callconduit�sp���

�
�����
��
r�sdebugcallconduitsMETHODT)r�cCsht�|j���}t�dd�t�|��}t�dd�t|||��}tj	|dddd�}|�
dt�|��d	S)
z�call Conduit API

    Call parameters are read from stdin as a JSON blob. Result will be written
    to stdout as a JSON blob.
    cSr:r;r<r@rBrBrCrD�rEz"debugcallconduit.<locals>.<lambda>cSst|t�r
t�|�S|Sr;)r=�bytesrrHr@rBrBrCrD��Tr�)�,z: )�	sort_keys�indent�
separatorss%s
N)rrH�finrIrrJrKr�rx�dumpsr�r?)rS�repor�r[r�rY�srBrBrC�debugcallconduit�s�
�r�cCs||j�dd�}|r|S|j�dd�}|sdSt|jddd|gii�}t|d�d	kr,dS|dd	d
}|j�dd|�|S)z.given callsign, return repository PHID or Noner&r.r+Nsdiffusion.repository.search�constraintss	callsigns�datar�phid)rSr�r��len�	setconfig)r��repophid�callsign�queryrBrBrC�getrepophid�s �rs\AD([1-9][0-9]*)\Zs>^Differential Revision:\s*(?P<url>(?:.*)D(?P<id>[1-9][0-9]*))$c
s|��}|jjj}i}t��}|D]R}||}tt�|j	|g��}|D](}	||	�rK|�
|	�D]}
t�|
�}|rGdt
|�t|�d��f||<nq.q#nq#t�|���}|rcdt
|�t|�d��f||<q|r�dd�|��D�}t|jdd|i�}
dd	��|��D]~\}\}���fd
d�|
��D�}��fdd�|D�}|s�|s�d
�}tj|||jddddd�|j�td���q�d}}|r�t|dd�d�}�|��}t|jdt|�t� dd�t!|�D��f�t"|�dkr�|d}|r�||�s�d}||�f||<q�|S)a�find previous nodes that has been sent to Phabricator

    return {node: (oldnode, Differential diff, Differential Revision ID)}
    for node in nodelist with known previous sent versions, or associated
    Differential Revision IDs. ``oldnode`` and ``Differential diff`` could
    be ``None``.

    Examines commit messages like "Differential Revision:" to get the
    association information.

    If such commit message line is not found, examines all precursors and their
    tags. Tags with format like "D1234" are considered a match and the node
    with that tag, and the number after "D" (ex. 1234) will be returned.

    The ``old node``, if not None, is guaranteed to be the last diff of
    corresponding Differential Revision, and exist in the repo.
    rr$�idcSsg|]\}}}|�qSrBrB)r��force�precs�drevrBrBrCr�4�z%getoldnodedrevmap.<locals>.<listcomp>�differential.querydiffssrevisionIDscs�fdd�t|�D�S)Ncsg|]}|�vr|�qSrBrB�r��n��precsetrBrCr�<r�z7getoldnodedrevmap.<locals>.getnodes.<locals>.<listcomp>)�getlocalcommits)�dr
rBrrC�getnodes9sz#getoldnodedrevmap.<locals>.getnodesc� g|]}t|d��kr|�qS)s
revisionID��int�r�r�rrBrCr�?scs h|]}�|��D]}|�q	qSrBrB)r�rr)rr
rBrC�	<setcomp>D� z$getoldnodedrevmap.<locals>.<setcomp>�D%dNT��messager��date�locals=D%d: local tag removed - does not match Differential history
cSst|d�S)N�idr)rrBrBrCrD`sz#getoldnodedrevmap.<locals>.<lambda>)rks%s mapped to old nodes %s
cS�g|]}t|��qSrB�rr
rBrBrCr�h�)#�
unfiltered�	changelog�index�has_noder rPr�r�allpredecessors�obsstore�nodetags�_differentialrevisiontagrer�setrr��_differentialrevisiondescre�search�description�valuesr�rSr�r�tag�nullidrMr�maxr�rr"�pprint�sortedr�)r��nodelist�unfir$rY�	toconfirm�node�ctx�	precnodesrr.�m�drevs�alldiffs�newnoder�diffs�	phprecset�tagname�oldnode�lastdiff�oldnodesrB)rrr
rC�getoldnodedrevmaps�

����
��	���
���rCcCs�i}|D]9}d||<||}t�|���}|r!t|�d��||<q|�|���D]}t�|�}|r<t|�d��||<nq(q|S)z\Return a dict mapping each rev in `revs` to their Differential Revision
    ID or None.
    Nrr$)	r*r+r,rr�r'r6r(r)r��revsrY�revr7r9r.rBrBrC�
getdrevmap�s 
��rFcCsHt��}tj|��|����|��d|d�D]	\}}|�|�q|��S)z:plain-text diff without header (user, commit message, etc)N�rX)	r �stringior�diffuir��p1r6r��getvalue)�basectxr7�diffopts�output�chunk�_labelrBrBrC�getdiff�s�rQc@s,eZdZdZdZdZdZdZdZdZ	dZ
d	S)
�DiffChangeTyper$r�������N)r��
__module__�__qualname__�ADD�CHANGE�DELETE�	MOVE_AWAY�	COPY_AWAY�	MOVE_HERE�	COPY_HERE�	MULTICOPYrBrBrBrCrR�srRc@seZdZdZdZdZdS)�DiffFileTyper$r�rSN)r�rYrZ�TEXT�IMAGE�BINARYrBrBrBrCrc�srcc@sdeZdZdZejdd�Zejdd�Zejdd�Zejdd�Z	ejdd�Z
ejdd�Zejdd�ZdS)�phabhunkzGRepresents a Differential hunk, which is owned by a Differential changerr)�N)
r�rYrZr�r�ib�	oldOffset�	oldLength�	newOffset�	newLength�corpus�addLines�delLinesrBrBrBrCrg�srgc@s�eZdZdZejdd�Zejdd�Zeje�e	�d�Z
eje�e�d�Zeje�e�d�Z
eje�e�d�Zejejd�Zejejd�Zejdd�Zejdd�Zejdd�Zeje�e	�d�Zdd�Zdd�Zd	d
�Zdd�ZdS)
�
phabchangez�Represents a Differential change, owns Differential hunks and owned by a
    Differential diff.  Each one represents one file in a diff.
    Nr)rcCs4t|j���D]}|�dd�}|j||j|<qdS)Nsnew:sold:)r��metadata�keys�replace)�selfrk�newkeyrBrBrC�copynewmetadatatoold�s�zphabchange.copynewmetadatatooldcC�||jd<dS�Ns
unix:filemode)�
oldProperties�rurlrBrBrC�
addoldmode��zphabchange.addoldmodecCrxry)�
newPropertiesr{rBrBrC�
addnewmode�r}zphabchange.addnewmodecCsPt|t�s
t�d��|j�t�t�	|���|j
|j
7_
|j|j7_dS)Ns'phabchange.addhunk only takes phabhunks)r=rgrr��hunks�appendr�byteskwargsr�asdictrorp)ru�hunkrBrBrC�addhunk�s


zphabchange.addhunk)r�rYrZr�rri�currentPath�oldPath�Factoryr��	awayPathsr�rrrzr~rRr\r�rcrd�fileType�
commitHashrorpr�rwr|rr�rBrBrBrCrq�s$rqc@s�eZdZdZejdd�Zejdd�Zejdd�Zejdd�Z	ejdd�Z
ejdd�Zejdd�Zejd	d�Z
ejd
d�Zejd
d�Zeje�e�d�Zejdd�Zdd�ZdS)
�phabdiffz]Represents a Differential diff, owns Differential changes.  Corresponds
    to a commit.
    r8r)r�s(0000000000000000000000000000000000000000shgsdefaultNr2snonecCs0t|t�s
t�d��t�t�|��|j|j	<dS)Ns)phabdiff.addchange only takes phabchanges)
r=rqrr�rr�rr��changesr�)ru�changerBrBrC�	addchanges


�zphabdiff.addchange)r�rYrZr�rri�
sourceMachine�
sourcePath�sourceControlBaseRevision�sourceControlPath�sourceControlSystem�branch�bookmark�creationMethod�
lintStatus�
unitStatusr�r�r��repositoryPHIDr�rBrBrBrCr��sr�cCs�|��}t�|g�}tjddd�}ttj||��|||d��\}}}	}
|
D]9}|\\}}
}}}d�	|dd��}t
|	�}|�|�t�t�
t�|���\}}}}}|�t||
|||||��q%dS)z'populate the phabchange for a text fileT���gitr	rGr8r$N)r�r�exactrrM�nextr�	diffhunksrJrNr��extend�diffstatsum�diffstatdatar �	iterlinesr�rg)�pchangerLr7�fnamer��fmatcherrM�_pfctx�_fctx�header�fhunks�fhunkrjrkrlrm�linesrn�shunk�_mf�_mtrorp�_hbrBrBrC�maketext	s4�
����r�cCs�|��j}t|dd|i�}|jtd�td�t|�d��7}|D]+}|��|dr)qt|d�}t|d�}t|d	||t�	|�
�||��d
d��qWd�dS1sUwYdS)
ztupload large binary files as separate chunks.
    Phab requests chunking over 8MiB, and splits into 4MiB chunks
    sfile.querychunks�filePHIDsuploading file chunksschunks)�unit�totalscomplete�	byteStartsbyteEndsfile.uploadchunksbase64)r�r�r�sdataEncodingN)r�rSr��makeprogressrr��	incrementr�base64�	b64encoder�)�fctx�fphidrS�chunks�progressrO�bstart�bendrBrBrC�uploadchunks's.
����"�r�c
Cs�|��}|j}|��}|��}t�t�|����	��}|||d�}t
|d|�}|d}|drS|�td�t
|��|sM|t�|���d�}	t
|d|	�}nt||�n	|�dt
|��|sgt�d	t
|���|S)
z"upload binary files to Phabricator)�names
contentLengthscontentHashs
file.allocater�suploads
uploading %s
)r�sdata_base64sfile.uploadsserver already has %s
sUpload of %s failed.)r�rS�path�sizer�bytestr�hashlib�sha256r��	hexdigestr�r�rr�r�r�r�r�rr�)
r�r�rSr�r��fhash�allocateparams�	fileallocr��uploadparamsrBrBrC�
uploadfileBs.��r�cCsr|r|�|�r/|��|jd<t�t�|����\}}|r$t�	|�|jd<t
|�}||jd<dStj|_
|��dS)z�add the metadata for the previous version of a binary file to the
    phabchange for the new version

    ``oldfctx`` is the previous version of the file; ``fctx`` is the new
    version of the file, or None if the file is being removed.
    s
old:file:sizesold:file:mime-typesold:binary-phidN)�cmpr�rr�	mimetypes�
guess_typerrHr�rr�r�rcrdr�rw)r��oldfctxr��	mimeguess�_encr�rBrBrC�addoldbinarygs�
�r�cCsvtj|_t|�}||jd<|��|jd<t�t�	|�
���\}}|r7t�|�}||jd<|�
d�r9tj|_dSdSdS)z)populate the phabchange for a binary filesnew:binary-phids
new:file:sizesnew:file:mime-typesimage/N)rcrfr�r�rrr�r�r�rrHr�rr�rere)r�r�r�r�r�rBrBrC�
makebinary�s



�r�s120000s100755s100644)�l�xr8cCsFz
|���d�WdSty"|��j�td�|���YdSw)z[detect non-UTF-8 text files since Phabricator requires them to be marked
    as binary
    zutf-8Fs0file %s detected as non-UTF-8, marked as binary
T)r��decode�UnicodeDecodeErrorr�rSr�rr�)r�rBrBrC�notutf8�s
���r�cCsd|D]-}t||tjd�}|��|}|�t|���|��s*t|�s*t	||||�|�
|�qdS)z:add removed files to the phabdiff. Shouldn't include moves)r�r�r�N)rqrRr]rJr|�gitmoder��isbinaryr�r�r�)�pdiffrLr7�removedr�r�r�rBrBrC�
addremoved�s��r�c
Cs�|D]T}||}|��|}t||d�}t|��}t|��}	||	kr.|�|	�|�|�|��s>t|�s>|��s>t|�rJt||�t	|||�nt
||||�|�|�qdS)z"add modified files to the phabdiff)r�r�N)rJrqr�r�r|rr�r�r�r�r�r�)
r�rLr7�modifiedr�r�r�r��filemode�originalmoderBrBrC�addmodified�s,

����
�r�cCsi}i}i}||krt�|��|�}|D]�}||}	d}
t|d�}t|	��}|r0|�||�}
n|}
|	��r<|	��d}
||
k}|r�|��|
}
t|
��}|
|_|
|vrmt|
|
t	j
|gd�}|||
<|�|
�t	j|_
n5|
|vr�t	j||
_
||
j�|�t	j|_
n|
|vr�t|
t	jd�}|||
<n||
}|j�|�t	j|_
||kr�|�|�|�|�n
|�t|	���t	j|_
|	��s�t|	�s�|
r�|
��s�t|
�r�t||	�|r�t||
|	�nt||||�|�|�q|��D]	\}}|�|�q�|��D]	\}}|�|�q�dS)z>add file adds to the phabdiff, both new files and copies/movesN)r�r)r�r�r�r�)r�r�)r
�
pathcopiesrJrqr�r�r��renamedr�rRr^�remover`r�rbr�r�rar_r|rr[r�r�r�r�r�r�r�)r�rLr7�addedr��
copiedchanges�movedchangesr�r�r�r�r�r��
originalfnamer�r��origpchange�_path�copiedchange�movedchangerBrBrC�addadded�s�
�


�


������
��r�cCs�|��}t|�}td|����d|��d�}|���|�\}}}}}	}
}t|||||�t||||�t	||||�|rA||_
t|jdt
�t�|���}|sh||kr]td�||f}
ntd�|}
t�|
��|S)zcreate a Differential Diffs%s)r�r�sdifferential.creatediffscannot create diff for %s::%sscannot create diff for %s)r�rr�rJ�hexr��statusr�r�r�r�r�rSrr�rr�rrr�)rLr7r�rr�r�r�r��_d�_u�_i�_c�diffr�rBrBrC�
creatediffs.
��
r�c
Cs�|�d|�d��}|d}|d}|dt�|��d|��|��|��|����d��d�}t|�	�j
d	|�i}|D](}t�|���t�
|���t|��d�|��|����g|��d
�||��<q;|dt�|�d�}t|�	�j
d	|�dS)
z�write metadata to diff so patches could be applied losslessly

    ``ctxs`` is the list of commits that created the diff, in ascending order.
    The list is generally a single commit, but may be several when using
    ``phabsend --fold``.
    sdiffidrr����hg:metas%d %d)�user�date�branch�node�parent)sdiff_idr�r�sdifferential.setdiffproperty)�author�authorEmail�time�commit�parentsr��
local:commitsN)r�rrxr�rr�r�rJr�r�rSr"�person�emailr)�ctxsr��diffidrL�tipctxr��commitsr7rBrBrC�writediffproperties;s:

���
�	�rc	Cs�|d}|d}	|��}
|r.tjddd�}|
��}||}
||}t|	||�t||
|�k}nd}g}|rNt|	|�}|�d|dd��|rM|�d	|d��n|sRJ�|}t||�|rd|�d
|gd��|rj||7}t�	�}t
|�D]B\}}|��}t|
j
dd|i�}d
D].}|d�|�}|s�q�|dkr�|��||<q�|dkr�d}d�td|�|�|��g��||<q�qr|��D]\}}|�||d��q�d|i}|dur�||d<t|
j
d|�}|s�t|�dkr�td�|}ntd�|	|f}t�|��||fS)a�create or update a Differential Revision

    If revid is None, create a new Differential Revision, otherwise update
    revid. If parentrevphid is not None, set it as a dependency.

    If there is a single commit for the new Differential Revision, ``ctxs`` will
    be a list of that single context.  Otherwise, it is a list that covers the
    range of changes for the differential, where ``ctxs[0]`` is the first change
    to include and ``ctxs[-1]`` is the last.

    If oldnode is not None, check if the patch content (without commit message
    and metadata) has changed before creating another diff.  For a Revision with
    a single commit, ``oldbasenode`` and ``oldnode`` have the same value.  For a
    Revision covering multiple commits, ``oldbasenode`` corresponds to
    ``ctxs[0]`` the previous time this Revision was posted, and ``oldnode``
    corresponds to ``ctxs[-1]``.

    If actions is not None, they will be appended to the transaction.
    r�rTr�r�supdater��stypesvalue�commentsparents.setsdifferential.parsecommitmessagescorpus)�title�summary�testPlan�fieldsrr�

N�transactions�objectIdentifier�differential.revision.editr$scannot create revision for %ss!cannot create revision for %s::%s)r�rrMr!rQr�r�rr rPr�r,r�rSr��rstriprN�filterr�r�rrr�)r�revid�
parentrevphid�oldbasenoder@�olddiff�actions�commentr7rLr�rMr4�oldctx�
oldbasectx�neednewdiff�transactionsr��fields�i�_ctx�desc�infor�r�r��revisionr�rBrBrC�createdifferentialrevisionhsr�
�

�	�$�
r(cCsvdd�|D�}dd|ii}t|d|�}|d}dd�|D�}t|�|}|r4t�td	�d
�t|����dd�|D�S)zconvert user names to PHIDscSsg|]}|���qSrB��lower)r�r�rBrBrCr��r zuserphids.<locals>.<listcomp>r�s	usernamessuser.searchr�cSsh|]
}|dd���qS)rsusernamer)�r��entryrBrBrCr�r�zuserphids.<locals>.<setcomp>sunknown username: %s� cSsg|]}|d�qS)r�rBr+rBrBrCr��r )r�r)rr�rrNr2)rS�namesrrYr��resolved�
unresolvedrBrBrC�	userphids�s�r1cCsb|�td�td�td�d�|d|�}|�d|d�}t�||d�}|�td	�|||f�d
S)z�print the ``action`` that occurred when posting ``ctx`` for review

    This is a utility function for the sending phase of ``phabsend``, which
    makes it easier to show a status for all local commits with `--fold``.
    �created�skipped�updated)r2r3r4sphabricator.action.%srr7r2s
%s - %s - %s
N)�labelrr�format_changeset_summaryr�)rSr7�newrevid�action�
actiondesc�drevdesc�summaryrBrBrC�_print_phabsend_action�s���r<csht�jdt�dd�|D���zt�fdd�|D�|�WdStjjy3�j�d|�YdSw)z�update the local commit list for the ``diff`` associated with ``drevid``

    This is a utility function for the amend phase of ``phabsend``, which
    converts failures to warning messages.
    snew commits: %s
cSrrBrr
rBrBrCr�r z*_amend_diff_properties.<locals>.<listcomp>c�g|]}�|�qSrBrB)r�r<�r4rBrCr�r s"Failed to update metadata for D%d
N)	r�rSr"r1rr r�r��
warnnoi18n)r4�drevid�newnodesr�rBr>rC�_amend_diff_propertiess��rB�r�revsrevisions to sendsREV�amendsupdate commit messages�reviewersspecify reviewers�blockersspecify blocking reviewers�mr
s1add a comment to Revisions with new/updated Diffss#ask for confirmation before sending�folds%combine the revisions into one reviews
REV [OPTIONS])r�c1
s$t�|�}t|�|�dg�}t��|�}|��|s"t�t	d���|�d�r,t
����fdd�|D�}tdd�|D��rEt�t	d����fd	d
�}��
d|�}t|�dkr\||d
���
d|�}t|�dkrm||d�|�d�}|r�t|�dkr�t�t	d���|�d�s�t�t	d���dd�|D�}	tdd�|	D��dkr�t�t	d���t��fdd�|D��}
|�dd�}|t|�d��O}|r�t�||
�}|s�t�t	d���g}
|�dg�}|�dg�}g}|r�|�t�j|��|r�|�tdd�t�j|���|�r|
�d|d ��g}i}d!}|D]�}|�r%|�d"|��|d#��f�n	|�d$|���|
�|��d%�\}}}|||}}}|�rQ|
�|d#��d%�\}}}||��k�s^|�d��r�t|�rd|n|g||||||
|�d&��\}}|�r�|D]	}|||��<�qyn|||��<t|d'd(�}|d'd)}|�r�d*}nd+}|�s�t�|���} | �r�t| � d,��|k�r�d-|}!t!j"�|!|��d!d!d!d.d/�nt#�jd0|�d1d)}|}d2}|�|�|}|�r|D]}"|
�|"��d%�d3�r�d*}nd+}t$||"||��q�n	t$||||��q|�d��r��%�}#t&|d4d5|i�}$��'������(������)d����d6d���*d7||�D�}%|#d8��}&i}'g}(|d1�t+|�D]�\})}*|#|*}+|�s^||)��fd9d�|$D�d1},t,|,|+|�}-|+��|-k�s�|+�-���|'v�s�|+�.���|'v�r|+�/�t0j1k�r�|�2t	d:�t3�4|+���qO|'�|+�-���|+�-�f�d1|'�|+�.���|+�.�f�d1g}.t5�6�|-|'�}-t7j8�|+|.|-|+�9�|+�:�|+�;�d;�}/|/�<�}0|0g|'|+��<|�r�|(�|0��qOt=|#�|0g||+���d-�}!|!��!�v�rt!j"�|!�j>d!d!d!d.d/��qO|�r|(�|+����qO|�rK|(�rK||+��}|�r4t*|(�t?|�k�rCt@|d<��t=|#�|(|�nt@|d=��n|�rSt@|d>�|%D]h}+|'�|+�-���|+�-�f�d1|'�|+�.���|+�.�f�d1g}.t7j8�|+|.t5�6�|+��|'�|+�9�|+�:�|+�;�d;�}/|/�<�}0|0|+��k�r�|0g|'|+��<t@|d?tA|+���tA|0�f��qUt@|d@tA|+�����qUt3jB�|'dd.dA�|&|'v�r�|#�C|'|&d1�Wd!�n	1�s�wYWd!�n1�s�wYWd!�d!SWd!�d!S1�s	wYd!Sd!S)Ba�upload changesets to Phabricator

    If there are multiple revisions specified, they will be send as a stack
    with a linear dependencies relationship using the order specified by the
    revset.

    For the first time uploading changesets, local tags will be created to
    maintain the association. After the first time, phabsend will check
    obsstore and tags information so it can figure out whether to update an
    existing Differential Revision, or create a new one.

    If --amend is set, update commit messages so they have the
    ``Differential Revision`` URL, remove related tags. This is similar to what
    arcanist will do, and is more desired in author-push workflows. Otherwise,
    use local tags to record the ``Differential Revision`` association.

    The --confirm option lets you confirm changesets before sending them. You
    can also add following to your configuration file to make it default
    behaviour::

        [phabsend]
        confirm = true

    By default, a separate review will be created for each commit that is
    selected, and will have the same parent/child relationship in Phabricator.
    If ``--fold`` is set, multiple commits are rolled up into a single review
    as if diffed from the parent of the first revision to the last.  The commit
    messages are concatenated in the summary field on Phabricator.

    phabsend will check obsstore and the above association to decide whether to
    update an existing Differential Revision, or create a new one.
    rDs(phabsend requires at least one changesetrEcr=rBrB)r�rE�r�rBrCr�Ur zphabsend.<locals>.<listcomp>css�|]	}|��r|VqdSr;)�obsolete�r��crBrBrC�	<genexpr>Ws�zphabsend.<locals>.<genexpr>s,obsolete commits cannot be posted for reviewcs8�fdd�|D�}tjtd�|t��|�ftd�d��)Nc�g|]}�|���qSrB�r6�r��rrJrBrCr�_r�z:phabsend.<locals>._fail_nonlinear_revs.<locals>.<listcomp>s)cannot phabsend multiple %s revisions: %ss&the revisions must form a linear chain)�hint)rr�rr�
nodesummaries)rD�revtype�badnodesrJrBrC�_fail_nonlinear_revs^s��z&phabsend.<locals>._fail_nonlinear_revss
heads(%ld)r$sheads
roots(%ld)srootrIscannot fold a single revisionscannot fold with --no-amendcSsg|]	}t�|����qSrB)r*r+r,)r�r7rBrBrCr��s��cSsh|]	}|r|�d��qS)r)r�)r�r9rBrBrCr�szphabsend.<locals>.<setcomp>s0cannot fold revisions with different DREV valuescrOrBrPrQrJrBrCr��r�r2r3sphabsend cancelledrFrGcSsd|S)Nsblocking(%s)rB)�phidrBrBrCrD�r�zphabsend.<locals>.<lambda>s
reviewers.addrNssending rev %d::%d
r�ssending rev %d
�NNNr
sobjectrr�r4r2rrTrr�rr3r��differential.query�idscSsg|]}|�qSrBrBrLrBrBrCr�s��s4(%ld::) - (%ld) - unstable() - obsolete() - public()�.cr)rrr)r@rBrCr�rs'warning: not updating public commit %s
)�parents�textr�r�extras#updating local commit list for D%d
s0local commit list for D%d is already up-to-date
sno newnodes to update
srestabilizing %s as %s
snot restabilizing unchanged %s
)�fixphase)Drr�r�r�r�revrange�sortrr�rr�checkunfinished�anyrDr�rCr�r��_confirmbeforesendr�r1rS�mapr�r�rEr6r(rr*r+r,r�rr.�	querydrevr<r!r��wlock�lock�transactionr)r��get_amended_descrJ�p2�phaser�publicrMr�formatchangeidr�update_hash_refsr	�metadataonlyctxr�rr_�commitrBr/rr�r�cleanupnodes�
setparents)1rSr�rDrXrrW�heads�roots�fold�drevmatchers�oldmap�confirm�	confirmedr�	reviewers�blockers�phids�drevids�diffmap�lastrevphidr7r@rrr�oldbasediff�oldbaserevidr'r�r7�
newrevphidr8r9r?rMr4r:�restack�wnode�mappingrAr#rE�oldr�newdescr]�newr<rB)r@r�rC�phabsends�
4





��
�� 
�����
&�������

���	���
�
�����
����T�r�))r�sUser)r�sDate)r�sBranch)r�sNode ID)r�sParent c
Cs�t|j�\}}|j}|D]4}||}|�|��d�\}}	}
|
r(|�d|
d�}n|�td�d�}|�td�|t�||d�f�q|�	td�|�rLdSd	S)
NrYrr7sNEWs%s - %s
r2s1Send the above changes to %s (Y/n)?$$ &Yes $$ &NoFT)
r�rSr�r6r5rr�rr6�promptchoice)r�rDryrr�rSrEr7r@rr@r:rBrBrCre�s(���
�re>�closed�accepted�	abandoned�needsreview�
needsrevision�changesplannedcCs|d�dd���S)z7get normalized status name from a Differential Revision�
statusNamer-r8)rtr*rrBrBrC�_getstatusname�sr�)r(N)�groupr$�)NN)rXN)�	ancestorsrXNN)rUNN)�and_rUN)rTNN)�addrTN)rTNN)�subrTN)rNNNN)r�symbolNNN)�(�:�&�+�-r�r��endc
#s��t|�}d�d}t|�}||krRd�t��fdd�t�||d����}|r4d||fV|t|�7}n|||d�dkrJ|||d�d|fV|d7}||ksd	d|fVdS)
Ns():+-& rr8cs|�vSr;rB)�ch��specialrBrCrD�r�z_tokenize.<locals>.<lambda>r�r$r-r�)�
memoryviewr�rN�	itertools�	takewhiler�iterbytestr)r^�view�pos�length�symbolrBr�rC�	_tokenize�s&����
r�cCs4t�t��t|��\}}|t|�krt�d|��|S)Ns
invalid token)r�	_elements�parser�r�r�
ParseError)r^�treer�rBrBrC�_parse�sr�cCs>|�d�r|dd���rt|dd��S|��rt|�SdS)z<str -> int or None, ex. 'D45' -> 45; '12' -> 12; 'x' -> None�Dr$N)re�isdigitr)r�rBrBrC�
_parsedrev�s
�r�cCs�t�}t�}|d}|dkrt|d�}|r|�|�||fS|dkr>t|d�\}}|�|�|�|�|�|�||fS|dd�D]}t|�\}}|�|�|�|�qD||fS)z9return ({single-drev-id}, {ancestor-drev-id}) to prefetchrr�r$r�N)r)r��add�_prefetchdrevs�update)r�r:�
ancestordrevs�oprR�a�trBrBrCr�s&
�


�
r�cs���fdd���fdd��i�t|�}t|�\}}��dd�}t|�}|D]}|�ttd||�|d��q%|rA�dt|�i�tt�t|���t|�B������fd	d
���fdd��|�D�S)
a�return a list of "Differential Revision" dicts

    spec is a string using a simple query language, see docstring in phabread
    for details.

    A "Differential Revision dict" looks like:

        {
            "activeDiffPHID": "PHID-DIFF-xoqnjkobbm6k4dk6hi72",
            "authorPHID": "PHID-USER-tv3ohwc4v4jeu34otlye",
            "auxiliary": {
              "phabricator:depends-on": [
                "PHID-DREV-gbapp366kutjebt7agcd"
              ]
              "phabricator:projects": [],
            },
            "branch": "default",
            "ccs": [],
            "commits": [],
            "dateCreated": "1499181406",
            "dateModified": "1499182103",
            "diffs": [
              "3",
              "4",
            ],
            "hashes": [],
            "id": "2",
            "lineCount": "2",
            "phid": "PHID-DREV-672qvysjcczopag46qty",
            "properties": {},
            "repositoryPHID": "PHID-REPO-hub2hx62ieuqeheznasv",
            "reviewers": [],
            "sourcePath": null
            "status": "0",
            "statusName": "Needs Review",
            "summary": "",
            "testPlan": "",
            "title": "example",
            "uri": "https://phab.example.com/D2",
        }
    cs�|�d�p|�d�pdgd}|�vr�|St�d|�}|D]}|�|d<|�t|d�<q|�vr=t�td�|���|S)	zparams -> single drev or Noner[�phidsNrrZr�rs#cannot get Differential Revision %r)r�r�rrr�r)r�rkr:r)�
prefetchedrSrBrC�fetchDs
�zquerydrev.<locals>.fetchc	s�t�}g}dd�|D�}|rH|��}�|�}|d|vrq|�|d�|�t|d��|�di�}|�dg�}|D]
}|�d|gi�q;|s|��t�|�S)z6given a top, get a stack from the bottom, [id] -> [id]cSsg|]}d|gi�qS)r[rB)r�r#rBrBrCr�Xrz/querydrev.<locals>.getstack.<locals>.<listcomp>rs	auxiliarysphabricator:depends-onr�)	r)rr�r�rr��reverser�baseset)	�
topdrevids�visitedrY�queuer�r�	auxiliary�dependsrX)r�rBrC�getstackTs"�
zquerydrev.<locals>.getstackr&r'r$r[cs��d}|dkr6t�d�}|rt�|g�S�dtvr+��fdd��D�}t�|�St�td��d��|dvrRt��dksBJ�tt	|���d���d	��S|d
kr\��d�S|dkrh���d��St�
d���)
Nrr�r$cs$g|]}t�|��dkr|�qS)r$)r�rQ)r�r�rBrCr��s
�z+querydrev.<locals>.walk.<locals>.<listcomp>sunknown symbol: %s>r�r�r�rSr�r�r�sillegal tree: %r)r�rr��_knownstatusnamesrr�rr�r�operator�ProgrammingError)r�r�rr:)r�r��validids�walk)r�rCr�ys&�
 zquerydrev.<locals>.walkcr=rBrBrQ)r�rBrCr��r zquerydrev.<locals>.<listcomp>)	r�r�r�r)r�r�r0r�r2)rSr�r�r:r��	batchsize�tofetchrRrB)r�r�r�rSr�r�rCrgs. rgcCsP|d}|d��}|d��}|rd|}d|d}d�td||||g��S)	z�get description (commit message) from "Differential Revision"

    This is similar to differential.getcommitmessage API. But we only care
    about limited fields: title, summary, test plan, and URL.
    rrrs
Test Plan:
%s�Differential Revision: %s�urirN)rrNr)r�titler;�testplanr`rBrBrC�getdescfromdrev�sr�cCsL|st|�Sd|d}t�|���}|sd�|��|g�St�||���S)a1similar to ``getdescfromdrev``, but supports a folded series of commits

    This is used when determining if an individual commit needs to have its
    message amended after posting it for review.  The determination is made for
    each individual commit, even when they were folded into one review.
    r�r�r)r�r*r+r,rNrq)rr7�foldedr`r9rBrBrCrk�s
rkcCsT|�d�pi}|�d�p
i}t|�dkrdd�|��D�Stt|��dd��p(dhS)	zkget the set of local commits from a diff object

    See ``getdiffmeta()`` for an example diff object.
    �
propertiesrr$cSsh|]}t|��qSrB)rrLrBrBrCr�r z"getlocalcommits.<locals>.<setcomp>r�r8N)r�r�rsr�getdiffmeta)r��propsr
rBrBrCr�s
rcCs>|�d�pi}|�d�}|so|�d�rmt|d���d}i}d|vr3d|vr3d|d|df|d<d	|vrAd
t|d	�|d<d|vrK|d|d<|�d
|�d��}|rZ||d<t|�dd��dkrl|dd|d<ni}d|vrd|vrd|d|d<d|vr�|�d�r�|d|d<d|vr�|�d�r�|d|d<|S)a�get commit metadata (date, node, user, p1) from a diff object

    The metadata could be "hg:meta", sent by phabsend, like:

        "properties": {
          "hg:meta": {
            "branch": "default",
            "date": "1499571514 25200",
            "node": "98c08acae292b2faf60a279b4189beb6cff1414d",
            "user": "Foo Bar <foo@example.com>",
            "parent": "6d0abad76b30e4724a37ab8721d630394070fe16"
          }
        }

    Or converted from "local:commits", sent by "arc", like:

        "properties": {
          "local:commits": {
            "98c08acae292b2faf60a279b4189beb6cff1414d": {
              "author": "Foo Bar",
              "authorEmail": "foo@example.com"
              "branch": "default",
              "commit": "98c08acae292b2faf60a279b4189beb6cff1414d",
              "local": "1000",
              "message": "...",
              "parents": ["6d0abad76b30e4724a37ab8721d630394070fe16"],
              "rev": "98c08acae292b2faf60a279b4189beb6cff1414d",
              "summary": "...",
              "tag": "",
              "time": 1499546314,
            }
          }
        }

    Note: metadata extracted from "local:commits" will lose time zone
    information.
    r�r�rrr�rs%s <%s>r�rs%d 0r�r�rrDr�rrBr$r�sdateCreateds%s 0ssourceControlBaseRevision)r�r2r-rr�)r�r��metarrr6rBrBrCr��s:&


��r�csJt|�dkr�fdd�}d�t�||��}t||�}|r|St�td���)z�convert user supplied DREVSPECs into "Differential Revision" dicts

    See ``hg help phabread`` for how to specify each DREVSPEC.
    rcs�rd|}d|S)Ns:(%s)s(%s)rB)r���stackrBrC�_formatspecsz_getdrevs.<locals>._formatspecr�sempty DREVSPEC set)r�rNr�maplistrgrr�r)rSr��specsr�r�r:rBr�rC�	_getdrevss
r�cCs�tdd�|D��}t|dd|i�}g}|D]U}|�td�|d�tdd�|d	D��}t|d
d|i�}t|�}	d}
t|d
|�}t��D]}||vrY|
dt|||f7}
qGd|
|	|f}
|�	|d|
f�q||�dS)a/generate plain-text patch readable by 'hg import'

    write takes a list of (DREV, bytes), where DREV is the differential number
    (as bytes, without the "D" prefix) and the bytes are the text of a patch
    to be imported. drevs is what "querydrev" returns, results of
    "differential.query".
    cSs"h|]
}tdd�|dD���qS)cs��|]}t|�VqdSr;r�r�r�rBrBrCrN1��z&readpatch.<locals>.<setcomp>.<genexpr>�diffs)r0)r�rrBrBrCr1�"zreadpatch.<locals>.<setcomp>r	r[sreading D%s
rcsr�r;rr�rBrBrCrN:r�zreadpatch.<locals>.<genexpr>r�sdifferential.getrawdiffsdiffIDs# HG changeset patch
r�s# %s %s
s%s%s
%sN)
r2r��noterr0r�r��_metanamemaprsr�)rSr:r��diffidsr=�patchesrrrdr%r�r�r��contentrBrBrC�	readpatch(s"	�r�sphabread�stacksread dependenciessDREVSPEC... [OPTIONS]r�cs8t�|�}t�|�d�|�}�fdd�}t�||�dS)aprint patches from Phabricator suitable for importing

    DREVSPEC could be a Differential Revision identity, like ``D123``, or just
    the number ``123``. It could also have common operators like ``+``, ``-``,
    ``&``, ``(``, ``)`` for complex queries. Prefix ``:`` could be used to
    select a stack.  If multiple DREVSPEC values are given, the result is the
    union of each individually evaluated value.  No attempt is currently made
    to reorder the values to run from parent to child.

    ``abandoned``, ``accepted``, ``closed``, ``needsreview``, ``needsrevision``
    could be used to filter patches by status. For performance reason, they
    only represent a subset of non-status selections and cannot be used alone.

    For example, ``:D6+8-(2+D4)`` selects a stack up to D6, plus D8 and exclude
    D2 and D4. ``:D9 & needsreview`` selects "Needs Review" revisions in a
    stack up to D9.

    If --stack is given, follow dependencies information and read all patches.
    It is equivalent to the ``:`` operator.
    r�cs|D]	\}}��|�qdSr;)r�)r�rr��rSrBrC�_writems�zphabread.<locals>._writeN)rr�r�r�r�)rSr�r�rXr:r�rBr�rC�phabreadNs
r�simport dependencies as wellcs�t����d�d<d�d<d�d<d�d<��d	d
�rd�d
<��d	d�r)d�d<���fdd�}t���d
�|�}t�j||�dS)z�import patches from Phabricator for the specified Differential Revisions

    The patches are read and applied starting at the parent of the working
    directory.

    See ``hg help phabread`` for how to specify DREVSPEC.
    Tsbypassr$sstripr8sprefixFr6r4r5cs8�d��}���������k��d��V|D]K\}}��td�|�t��t�	|���-}t
���||�gd�\}}}|sHt�
td�|����|d��|g}Wd�n1s^wYqWd�n1snwYWd�n1s}wYWd�dSWd�dS1s�wYdS)Nr4sapplying patch from D%s
sD%s: no diffs found�
)r]rhrirjr�rr�extractr�bytesior�tryimportonerr�r�)r�r]r�contents�	patchdatar�r6�rej�rXr�rSrBrCr��s0 
�
�����Pzphabimport.<locals>._writer�N)rr�r�r�r�r�rS)rSr�r�rXr�r:rBr�rC�
phabimportts
r�s
phabupdate�acceptsaccept revisions�rejectsreject revisions�request-reviewsrequest review on revisions�abandonsabandon revisions�reclaimsreclaim revisions�closesclose revisions�reopensreopen revisions�plan-changessplan changes for revisions�resigns#resign as a reviewer from revisions�
commandeerscommandeer revisionsscomment on the last revisionslocal revision to updates"[DREVSPEC...| -r REV...] [OPTIONS]cs�t����gd�}�fdd�|D�}t|�dkr$t�td�d�|���g}|D]
}|�|dd��q(��d	�}|r�|sCt�	td
���|rLt�	td���t
|t�||g��}	g}g}
t�
|	�D]\}}|duro|
�||�q_|�d
|�q_|
r�t�	td�t�||
���t|��d�|�}
t|
�D]*\}}|dt|
�kr���d�r�|�d�dd��|r�|d|d�}t|d|�q�dS)zrupdate Differential Revision in batch

    DREVSPEC selects revisions. See :hg:`help phabread` for its usage.
    )
r�r�r�rr�r�r�r�r�r�cs"g|]
}��|�dd��r|�qS)r��_)r�rtr
rGrBrCr��r�zphabupdate.<locals>.<listcomp>r$s%s cannot be used togethers, TrrDs--rev requires a repositorys&cannot specify both DREVSPEC and --revNrs-selected revisions without a Differential: %sr�r
r�)rrr)rr�r�rr�rrNr�r��
InputErrorrFrra�	iteritemsrrTr�r�r�)rSr�r�rXr!r�r�frD�drevmap�unknownrRrr:r#rr�rBrGrC�
phabupdate�sL


�����rs
phabreview�ctx)�requirescCs�|�|d�}t�|���}|rt�|�d�d|�d�d��S|���|�	��}|D]'}t
�|�rQ|��j�
dd�}|�d�sC|d7}||7}t�||d��Sq*d	S)
ze:phabreview: Object describing the review for this changeset.
    Has attributes `url` and `id`.
    rrsD%sr)r1rr&r1r�N)�resourcer*r+r,r�
hybriddictr�r�r'r6r(rrSr�rf)r	r�r7r9rr�rrBrBrC�template_review	s,��

���rs
phabstatus>�uir�repoc	Cs�|�|d�}|�|d�}|�|d�}|��}z
t||g�|}Wn
ty*YdSwt|dd|gi�}|D]}t|d�|krNt�|d|d	d
��Sq6dS)z8:phabstatus: String. Status of Phabricator differential.rrr
NrZr[rr�r�)r1sstatus)r
rErF�KeyErrorr�rrr)	r	r�r7r�rSrEr@r:rrBrBrC�template_status!	s&����rswork)�	csettopiccs|�d�}t||�}gt�i}}}t�|�D]\}}	|	dur0|�|	�|�|	t���|�q|�|�qt�ddt	|�i�}
i�|
D]}|t
|d�D]}|�|<qNqD��fdd�}|t�|�8}t
�||�}
��dd	d
�||_t�||�}tj�||
|t
jd|id�dS)
z Phabricator differiential statuszsort(_underway(), topo)NrZr[rcs>�|��}��d|dt|��}��d|d|f�dS)Ns%(statusName)ssphabricator.status.%ss
%s %s
r�)rEr5r�r�)r7rr���
drevsbyrevrSrBrC�
phabstatusL	s
�z&phabstatusshowview.<locals>.phabstatussexperimentalsgraphshortenTsnodelen)r�)rDrFr)rrr��
setdefaultr�r�r�rrr�r�	dagwalkerr��_exthookr%�longestshortestr�displaygraph�
asciiedges)rSr��	displayerrDr�unknownrevsr�revsbydrevidrEr@r:rr�revdag�nodelenrBrrC�phabstatusshowview9	s8



�
�r )NF)NNNNNNN)�r��
__future__rr�r�r�r�rxr�r�rpr��mercurial.noderr�mercurial.i18nr�mercurial.pycompatr�mercurial.thirdpartyr�	mercurialrr	r
rrr
rrr�rrrrrrrrrrrrrrrrr�r �mercurial.utilsr!r"r#rhr%�
testedwith�eh�cmdtabler��configtable�templatekeyword�finaluisetup�uisetup�
configitem�
colortabler��wrapfunctionr]r�r�r�r�r�r�r�compiler(�Mr*rCrFrQ�objectrRrcr�r�rgrqr�r�r�r�r�r�r�r�r�r�r�r�rr(r1r<rB�CATEGORY_IMPORT_EXPORTr�rPr�rer�r�r�r�r�r�r�rgr�rkrr�r�r�r�r�rrr�showviewr rBrBrBrC�<module>s�5l���������������


&Q>

�

(%S/
�x���
o�

�
E&�
�
7��
<


@ Telegram