q&f/cTddlZddlZddlZddlmZddlmZddlmZm Z m Z ddl m Z m Z mZmZmZmZmZmZmZmZmZddlmZej6ZddlmZej<Zej>Zej@d Z!Gd d ejDZ#Gd d ejHZ%y)N)_)open)binhexsha1nodeconstants) bookmarkscontexterrorexchangehglock logcmdutilmerge mergestatephasesutil)dateutil)commons\b[0-9a-f]{12,40}\bcfeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZy)mercurial_sinkcltjj|||||jdd|_|jdd|_|j dd|_d|_tjj|ryttj|dkDrX tj|j ||_|j"j%st't)d|zn |j3t)d|ztj|j |d |_|j"j%st't)d|z|j4j7|d|_d|_d |_i|_y#t*j,$r-}|j/t'|j0dd}~wwxYw#t*j,$r(|j/t't)d |zwxYw) Nconvertshg.usebranchnamesshg.clonebranchess hg.tagsbranchr&%s is not a local Mercurial repositorys'initializing destination %s repository Tcreates)could not create hg repository %s as sinkF) rconverter_sink__init__ configbool branchnames clonebranchesconfig tagsbranch lastbranchospathisdirlenlistdirr repositoryuirepolocalNoReporr RepoError tracebackargsstatuscreatedappendr wlock filemapmode subrevmaps)selfr+repotyper&errs 2/usr/lib/python3/dist-packages/hgext/convert/hg.pyrzmercurial_sink.__init__9s&&tR4@==5IJ]]:7JK))J0@A 77== 3rzz$'7#81#< *MM$''48 yy( CDtK)  !GH4OPMM$''4E yy( CDtK ##D)    )?? * SXXa[)) *??  BCdJ s&0AF5BG85G5(G00G58;H3c|jjd|jj|_|jj |_y)Ns"run hg sink pre-conversion action )r+debugr,r5r r8s r;beforezmercurial_sink.before\s7  <=YY__& IINN$ c|jjd|jr|jj|jr|jjyy)Ns#run hg sink post-conversion action )r+r=r releaser5r>s r;afterzmercurial_sink.afterasF  => 99 II    :: JJ    r@cL|jjjdS)Nshamapr,vfsjoinr>s r; revmapfilezmercurial_sink.revmapfilehsyy}}!!),,r@cL|jjjdS)Ns authormaprFr>s r; authorfilezmercurial_sink.authorfileksyy}}!!,//r@c |jsy||jk7}||_|sd}|Dcgc]}|d|dxr|dxsdf}}tjj |j|}|rF|j  t j|j||_ |ji}|D]!} |jj|d#|r|j t|j!D]\}}tjj |j|} t j"|ji| } |jj%t'd||fzt)j*|j| |D cgc]} | j| c} |jyycc}w#t$r+t j|j|d|_ YhwxYw#t$r+|j|dgj|dYwxYwcc} w)NsdefaultrrTrspulling from %s into %s )heads)r!r$r%r&rHrCr r*r+r, Exceptionr?lookup setdefaultr4sorteditemspeernoterr pull) r8branch pbranches setbranchb branchpathmissingspbranchrM pbranchpathprepohs r;rXzmercurial_sink.setbranchns!! doo-  FBKLQadAaDMQqT7Z8L LWW\\$))V4  JJL LMM$'':>  KKM ;A ;   1& ;  JJL"()9":  ggll499g> [9 23w6GG IIue,LU\\!_,L   KKM )M LMM$'':dK  L ;##AaD"-44QqT: ;-Ms/G%G!H(I!0HH0I  I cDt}|jD]}|jdd}t|dk7r<|jj t d|z|jd|z_|j|j|d}|sX|dtjk(r|d}n<|jj t d|z|jd|z|jd||dfz|jS) N rsinvalid tag entry: "%s" s%s rsmissing tag entry: "%s" %s %s ) stringio splitlinessplitr(r+warnrwriteget lookuprevrnullhexgetvalue)r8sourcerevmapdatafplinesrevids r; _rewritetagszmercurial_sink._rewritetagss ZOO% 1D 4#A1v{ Q;$-!HF06DOOG, OPC6{a'"iinn44WfE99>>005 GGLLw7 5)6{Q CD$g./ "E HHZ5'"22 3I$ 4L{{}r@c #vK|j|g}tj|j|||dddd}|j D]i\}\}}} |j |r|t jvr$tjtd|||fz|t jk(rf|kyw)aRCalculates the files from p2 that we need to pull in when merging p1 and p2, given that the merge is coming from the given source. This prevents us from losing files that only exist in the target p2 and that don't come from the source repo (like if you're merging multiple repositories together). TF) branchmergeforce acceptremote followcopiesseunable to convert merge commit since target parents do not merge cleanly (file %s, parents %s and %s)N) ancestormergemodcalculateupdatesr,filemaptargetfilebelongstosourcerCONVERT_MERGE_ACTIONSr Abortr ACTION_KEEP) r8rmp1ctxp2ctxancmresultfileactioninfor|s r;_calculatemergedfilesz$mercurial_sink._calculatemergedfiless~~e$%++ II     *1):  %D%64//5999kk2 UE* +:111 - sB7B9c j $%t$%fd} g} |D]} | | vs| j| | }t|} jrD| dk(r?|d} t | }j j j|j}t|dkr%|jj jt|dkr%|jj j|jd}|j}tjt|}|D]E}j|}j!|}|(|j#||dt|}G|j$j'}j j(j+dd}|r||d<dD]O}|j!|}||d k(r t-|}j!|}|;|d k(r t |}|||<Qj.r|j0r|j0|d <|j2r|j4r|j2|d <|r`|}|jd}j |}d$|j jk7rj |$t7}|r<|j9j ||j9j |$rEt7|%j;|$D]$}%j=||j=|&t?j@j ||f||| |jB|jD|}j j(jGd d tHjJ|jLdj jOd5}j j(j+ddr |jP} nd} t-j jS|| }|j2|k7roj |}|jMtHjTkr?tIjVj |tHjT|j3gdddd}}|r`jr| dk(rɉj jXj[d}!j j j]t |d}"d|j$v}#|#sc|!j_|!ja|"sBj(jctedj jgd S|S#1swYxYw)Nc r,| vr(|vr$ jjd|z |S |} j ||\}}|y|dk(r j |}|dk(r j |}tj j|||d|vd|vj|S#tj$rYywxYw#t$rYywxYw)Nsreusing %s from p2 .hgtagss .hgsubstatelx) r+r=r ManifestLookupErrorKeyErrorgetfilertrr memfilectxr,ri) r,memctxfvromodecopiesfilesrp2filesrnr8rms r; getfilectxz,mercurial_sink.putcommit..getfilectxsg!6/ 59:  8O  !H 1-JD$|J((>N",,VT:%%    1  00     s"B5C5C  C  CCrrrbrs hg.sourcenamesconvert_source)ssourcetransplant_sources rebase_sourcesintermediate-sourcerbranchsconvert_revisionsphasess new-commitshg.preserve-hash)origctxs(octopus merge fixup) r@sclosesfiltering out empty revision T)r)4dictr4r(r6rr, changelogchangelogrevisionmanifestnullidpopdescrefindallsha1rerjrireplaceextracopyr+r"rr rVrevsaverevsetupdateraddr rauthordate setconfigr phasenamesphase transactionctx commitctxdraft registernew manifestlog getstoragereadcmprevisionr2rrollback)&r8rrparentscommitrmrnfullcleanp2rplpnparentsparentp1_nodem1nodep2textsha1ssha1oldrevnewrevr sourcenamelabelnodep1rfilesetrrtrrmanmnodeclosedrrs&``` `` @@r; putcommitzmercurial_sink.putcommitsU   < A{ !  w<   A QZF&kGYY((::7CLLF w  ?  !!#YY\\((5EF '1E# $  &E 99U#D|,,4yZZ%F!00 [F%e ) &,    %}}E)  ::&..)/E% &BQBIIbMEETYY%%% " %jGtyy}-tyy}-g, 66vueL&DKK%KK%&.. R   C IILL " "!!&,,/  &&z2 b99<<&&z3FG$jjG"G499..sG.DE ::%))D/Cyy{V\\1** IIr6<<#'') ".DBqt   A ))''2237CII'',,SW5a8E-F#''&#,,u2E"Fq!BCD """.  9  s #CV))V2c f|jj|jd}|xs|jj}t }|jj j D]e\}}|D][}d|j|vs|jt |j|djjd]gtt|}t|Dcgc] }d|||fzc}}||k(ryt } t } |D]E} | jjdd} t| dk7r2| j| dG|D][} | jjdd} t| dk7r2| d| vs:| j| dj]| syd j!|fd } |j"j%t'd d t)t+j,t+j.z}d |ji}t1j2|j|dfddg| d||}|jj5|}t7|t7|fScc}w)NT) ignoremissingrrcNNrarrbr@c :tj|||dddS)NF)r r)r,rrros r;rz*mercurial_sink.puttags..getfilectxs %%dFAtUE4P Pr@supdating tags s%d 0rs update tagss convert-repo)r, branchtipr#rr branchmaprRrrorerQliststriprfr(rrHr+r2rinttimemktimegmtimer rrr)r8tags tagparentoldlinesrVrMr_tagnewlinesoldtagsnewtagsrqrrrrrrrros @r;puttagszmercurial_sink.puttagsseII''t'L 1!1!1 5!YY00288: MFE 1-OODIIaL499;FFtLM   $x.)dKsJ$s)S)99KL x %% D ""4+A1v{ KK!     *D ""4+A1v{t7" AaDJJL)  *xx! Q q+,-T[[788DOO,nn II    L      yy""3'4y#i.((SLs:J.c||_yN)r6)r8actives r;setfilemapmodezmercurial_sink.setfilemapmodes !r@c@t|sydx}x}} |jj}|jj}|jj d}|j j td|jj}|Dcgc]}|t||f}}|j|j|||jtj|||ycc}w#tj|||wxYw)Nsbookmarksupdating bookmarks )r(r,r5r rr+r2r _bookmarksr applychangescloselockmodrB)r8updatedbookmarkr5r r destmarksbookmarkchangess r; putbookmarkszmercurial_sink.putbookmarkss?#    r -IIOO%E99>>#D&&{3B GGNN145 6 ,,I!03x89:G  " "499b' : HHJ OOD% , OOD% ,sB D!C?8/D?DDc:||jvxs |jSr)r,r!r8rs r;hascommitfrommapzmercurial_sink.hascommitfrommapsdii54#5#55r@c||jvr-|jr!tjt d|z||jvS)Nserevision %s not found in destination repository (lookups with clonebranches=true are not implemented))r,r!r rrrs r;hascommitforsplicemapz$mercurial_sink.hascommitforsplicemapsO dii D$6$6++,   diir@N)__name__ __module__ __qualname__rr?rCrIrKrXrtrrrrrrr r r@r;rr8sT!F% !-0'R((T,\`D6)p"-&6  r@rceZdZddZdZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZddZy)mercurial_sourceNctjj||||||jdd|_t |_|jdd|_ tj|j||_ |jjstj d|_d|_d|_d|_|j-dd}|j-dd}|| |jj/|}|jj2j5|}|d i}|jj2j7|gD]*} d ||jj2j9| <,|j:|_nt>j@|_|r/|D cgc]} |jj/| c} |_!y|jjE|_!y|s|tj0t#d t } t } tGjH|j|gD]V} |j| } | jK| j9| jMd | jODX| j:|_| | z |_!y#tj$r(|jt!t#d|zwxYw#tj$r"tj0t#d|zwxYwcc} w) Nrshg.ignoreerrorss hg.saverevrrs hg.startrevshg.revss %s is not a valid start revisionrs4hg.revs cannot be combined with hg.startrev or --revc3<K|]}|jywr)r).0rs r; z,mercurial_source.__init__..:s?Aqvvx?s)(rconverter_sourcerr ignoreerrorsrignoredrr r*r+r,r-r r/r0r.rlastrevlastctx _changescache convertfpr"rOrrr descendantsr __contains__keepralways_headsrMrrevrangerrr) r8r+r9r&revs startnodehgrevsstartrevchildrenrnodesrrs r;rzmercurial_source.__init__s((r8T4HMM*6HIu }}Z?  N dggt4DI99??$oo%%   'IIj.9 :z2 >$ $ 0 0 ;I  99..229=%q>,,88(D>A<=HTYY0055a89>$11  KK <@Aqtyy//2A "iioo/ y,kk0 EEeG((VH= @iil #((*%??? @**DI'/DKY N LLNDELM M N++=>JBs"AK8L<"M ;L5Mcn|j|k7r|j||_||_|jSr)rr,rrs r; _changectxzmercurial_source._changectx>s. <<3 99S>DLDL||r@c|jDcgc]'}|s|j|js&|)c}Scc}wr)rrr)r8rrs r;_parentszmercurial_source._parentsDs/;;=FaA$))AFFH2EFFFsAAAcv|jDcgc]}|j|st|!c}Scc}wr)r!rr)r8r_s r;getheadszmercurial_source.getheadsGs( $ <1tyy|A<<*FAGGI #5=KKN #&+Dat||.CAs8DD ''Es D?"D?ci}|D]Z}||jvr |j|j|jvrAtfd|DsV||<\|S#t$rYjt j $rY}|js|jj||jjtd|zYd}~d}~wwxYw)Nc3&K|]}|v ywrr)rr copysources r;rz.mercurial_source._getcopies..sOaeegP P}}88:!!#((*.GH"!::<))+GGILL))+  .PsDDDDc,t|jSr)r(r,r>s r; numcommitszmercurial_source.numcommitss499~r@c |jjDcgc]%}|jj|ddk(r|'}}|Dcic]#\}}|j|s|t |%c}}Scc}wcc}}w)Nrsglobal)r,tagslisttagtyperr)r8trr3rs r;gettagszmercurial_source.gettagss}YY'') yy  1&)3   37JJD$$))D/c$iJJ  Ks*A:A?(A?c x|j|}|j|}|s%|#d}|jjg}}n|xsd}|j |||\}}||fDcgc]!}|Dcgc]}||j vs|c}#c}}\}}|dk(r |||ff|_||zScc}wcc}}w)Nr)r+r-rkeysrArr) r8rirrr9r(lrs r;getchangedfilesz mercurial_source.getchangedfilessooc"--$19ALLN'')2BQA&&wqz37EBCEq'JQQ8!4<<"7!8JA 6"%AwD Av 9Js/ B68B1 B1 B61B6c|j4t|jjj dd|_|jj t jd||fz|jjy)NrEsabrc) rrr,rGrHrhr tonativeeolflush)r8rdestrevs r; convertedzmercurial_source.convertedsc >> !!$))--"4"4Y"?GDN T--jGS>.IJK r@c:|jjdy)Ns$run hg source pre-conversion action r+r=r>s r;r?zmercurial_source.befores  >?r@c:|jjdy)Ns%run hg source post-conversion action rjr>s r;rCzmercurial_source.afters  ?@r@cyNTrr>s r;hasnativeorderzmercurial_source.hasnativeorderr@cyrmrr>s r;hasnativeclosezmercurial_source.hasnativecloseror@c t|jj|S#tjtj f$rYywxYwr)rr,rOr r/r2rs r;rjzmercurial_source.lookuprevsB tyy'',- -!2!23  s#&#A  A c@tj|jSr)r listbookmarksr,r>s r; getbookmarkszmercurial_source.getbookmarkss&&tyy11r@c(|j||y)z+Mercurial, revision string is a 40 byte hexN)checkhexformat)r8revstrmapnames r;checkrevformatzmercurial_source.checkrevformats FG,r@r)s splicemap)r r rrr+r-r/rrArHrDrWrYr^rcrhr?rCrnrqrjrurzrr@r;rrsk7*r G= (:, ,K  @A 2-r@r)&r%rrmercurial.i18nrmercurial.pycompatrmercurial.noderrr mercurialrr r r r r rrrrrrrmercurial.utilsrrdrrvr.compilerrrrrrr@r;rs( #    % == ..  + ,I V**I X[-v..[-r@