q&fw&ddlZddlZddlZddlZddlZddlZddlZddlZddlZ ddl m Z ddl m Z mZmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZ ddl!m"Z"m#Z#m$Z$m%Z%da&ejNZ'ejPZ(ejRZ)ejTZ*dZ+dZ,Gd d ejZZ.d Z/d Z0d Z1dZ2ddddZ3dZ4ddZ5dZ6GddZ7Gdde7Z8Gdde7Z9Gdde7Z:e8e9e:dZ;y)N)_)binhexshort)cmdutilencodingerrorexchange logcmdutilmatchmergepathutilphasespycompatscmutil subrepoutilutilvfs)dateutilhashutilprocutilurlutilctjtj|}tj|}|j s2tj tj|j}|S)zU get a path or url and if it is a path expand it and return an absolute path ) r urllocalpathr expandpathurlschemenormpathabspathpath)r! expandedpathus 3/usr/lib/python3/dist-packages/mercurial/subrepo.py_expandedabspathr%7sR''(=>L L!A 88}}T\\!&&12 Kcrttjt|j ddS)zEget a unique filename for the store hash cache of a remote repositoryr )rrsha1r%digest) remotepaths r$_getstorehashcachenamer,Bs, x}}-j9:AAC DQr JJr&ceZdZdZdZy) SubrepoAbortzEException class used to avoid handling a subrepo error more than oncec|jdd|_|jdd|_tjj |g|i|y)Nsubrepocause)popr0r1r Abort__init__)selfargskws r$r4zSubrepoAbort.__init__JsBvvi. VVGT*  T/D/B/r&N)__name__ __module__ __qualname____doc__r4r&r$r.r.Gs O0r&r.cfd}|S)Nc |g|i|}|S#t$r}|d}~wtj$rY}t|}|jdzt d|zz}t||j |tjd}~wwxYw)N s(in subrepository "%s"))hintr0r1) r.r r3 subrelpathmessagerr@sysexc_info)r5r6kargsresexr0errormsgfuncs r$decoratedmethodz-annotatesubrepoerror..decoratedmethodQs t,d,e,C  H{{  &G T!A&@$AG$KK rwws||~   s  B B ABB r<)rIrJs` r$annotatesubrepoerrorrKPs" r&c|rtdt|||fz}ntdt|||fz}|j|dS)Ns subrepository sources for %s differ you can use (l)ocal source (%s) or (r)emote source (%s). what do you want to do?$$ &Local $$ &Remotes subrepository sources for %s differ (in checked out version) you can use (l)ocal source (%s) or (r)emote source (%s). what do you want to do?$$ &Local $$ &Remoter)rrA promptchoice)uisubdirtylocalremotemsgs r$ _updatepromptrTesb  $ _eV , - $ _eV , - ??3 ""r&c|jD]\}}}t|D]\}}|j|k(s||=n|j|jdk7rU|D]c}|jdk(s|j t d|j |z|j|j||ey)Ns.hghgrcs5warning: removing potentially hostile 'hgrc' in '%s' ) walk enumeratelowerbasenamewarnrjoinunlinkreljoin) rNrignoredirnamedirsnamesidfs r$ _sanitizerfxs # 4udO DAqwwyF"G  << & & (F 2  4AwwyG#%hhw' ( 3;;w23 44r&cb|jdsd|vstj||k7r!tjt d|zt j|j||jj|r!tjt d|zy)N~$+subrepo path contains illegal component: %ss$subrepo '%s' traverses symbolic link) startswithrrr r3rr pathauditorrootwvfsislink)repor!s r$_auditsubrepopathrqs t 0E0Mkk < = D  $H#D) yykk!CDtKLLr&TF)hggitsvnc~|jddds)tjtdtdtj |d}|jdd|z|s,tjtd |ztd|t vr!tjtd |zy) NsubrepossallowedTssubrepos not enableds)see 'hg help config.subrepos' for detailsr@Fs %s:alloweds%s subrepos not allowedsunknown subrepo type %s) configboolr r3rSUBREPO_ALLOWED_DEFAULTSgettypes)rNkinddefaults r$ _checktyper~s ==j$ 7kk % &?@  '**47G ==md&:G Dkk ( )D 0?@   5kk!67$>??r&cddlm}|a|j}t|||j|}t |j |d|r|d|j||df}t|d|||dd|S)z>return instance of the right subrepo class for subrepo in pathrhgrN) rrprqsubstater~rNsubrevr{)ctxr! allowwdir allowcreatehrpstates r$r0r0s B 88:DdD! LL Etwwa!q3::d+U1X6 q?3eBQi ==r&cddlm}|a|j}t|||j|}t |j |dd}|ddk(rd}t|d|||d|fdS) z=return an empty subrepo in pctx for the extant subrepo in ctxrrrr&rrs(0000000000000000000000000000000000000000rT)rrrprqrr~rNr{)rr!pctxrrprrs r$ nullsubreporsy B 88:DdD! LL Etwwa! F Qx5 q?4a&'94 @@r&ceZdZdZdZdZd&dZd&dZd'dZdZ d Z d Z d Z d Z d(d ZdZdZdZdZdZdZdZdZdZdZdZdZd)dZdZd*dZdZdZdZ d Z!d!Z"d"Z#d(d#Z$e%d$Z&e%d%Z'y)+abstractsubrepoc^|jj|_||_||_y)zInitialize abstractsubrepo part ``ctx`` is the context referring this subrepository in the parent repository. ``path`` is the path to this subrepository as seen from innermost repository. N)rprN_ctx_path)r5rr!s r$r4zabstractsubrepo.__init__s#((*--  r&cy)zAdd the hgwebdir entries for this subrepo, and any of its subrepos. ``serverpath`` is the path component of the URL for this repo. ``webconf`` is the dictionary of hgwebdir entries. Nr<r5 serverpathwebconfs r$ addwebdirpathzabstractsubrepo.addwebdirpaths r&cy)z returns true if the repository has not changed since it was last cloned from or pushed to a given repository. Fr<r5r!s r$ storecleanzabstractsubrepo.storecleans r&ct)a returns true if the dirstate of the subrepo is dirty or does not match current stored state. If ignoreupdate is true, only check whether the subrepo has uncommitted changes in its dirstate. If missing is true, check for deleted files. NotImplementedErrorr5 ignoreupdatemissings r$rPzabstractsubrepo.dirtys "!r&cX|j||rtdt|zSy)zreturn reason string if it is ``dirty()`` Returned string should have enough information for the message of exception. This returns None, otherwise. rrs)uncommitted changes in subrepository "%s"N)rPrrArs r$ dirtyreasonzabstractsubrepo.dirtyreasons8 ::<: AABZF  Br&Nc\|j|d}|rtj||y)z+raise Abort if subrepository is ``dirty()``TrrwN)rr r3)r5rr@rs r$ bailifchangedzabstractsubrepo.bailifchangeds0&&L$&O ++k5 5 r&ct)zpcurrent working directory base state, disregarding .hgsubstate state and working directory modificationsrr5s r$ basestatezabstractsubrepo.basestates "!r&cy)z7check if path is a subrepository within this repositoryFr<rs r$ checknestedzabstractsubrepo.checknestedsr&ct)zcommit the current changes to the subrepo with the given log message. Use given user and date if possible. Return the new state of the subrepo. r)r5textuserdates r$commitzabstractsubrepo.commit! "!r&c"tjS)z6returns phase of specified state in the subrepository.)rpublicr5rs r$phasezabstractsubrepo.phase(s }}r&ct)zTremove the subrepo (should verify the dirstate is not dirty first) rrs r$removezabstractsubrepo.remove,rr&ct)zTrun whatever commands are needed to put the subrepo into this state r)r5r overwrites r$rzzabstractsubrepo.get3s "!r&ct)z/merge currently-saved state with the new state.rrs r$rzabstractsubrepo.merge9!!r&ct)zhperform whatever action is analogous to 'hg push' This may be a no-op on some systems. rr5optss r$pushzabstractsubrepo.push=rr&c gSNr<r5rNr prefixuipathfn explicitonlyrs r$addzabstractsubrepo.addDs r&cV|jjd|tdfzy)Ns%s: %ssaddremove is not supportedrrNr[r)r5matcherrrrs r$ addremovezabstractsubrepo.addremoveGs%  Y&!,I*J!KKLr&c yNrr<)r5r fm fntemplaterrs r$catzabstractsubrepo.catKr&c 8tjgggggggSr)rstatus)r5rev2rs r$rzabstractsubrepo.statusNs~~b"b"b"b99r&c yrr<)r5rNdiffoptsnode2r rrs r$diffzabstractsubrepo.diffQs r&cyrr<)r5rNdestrs r$outgoingzabstractsubrepo.outgoingTrr&cyrr<)r5rNsourcers r$incomingzabstractsubrepo.incomingWrr&ct)zreturn filename iteratorrrs r$fileszabstractsubrepo.filesZrr&ct)z9return file data, optionally passed through repo decodersrr5namedecodes r$filedatazabstractsubrepo.filedata^rr&cy)zreturn file flagsr&r<)r5rs r$ fileflagszabstractsubrepo.fileflagsbsr&c.tj|S)z,Resolve the fileset expression for this repobadfn)matchmodnever)r5cwdexprrs r$ matchfilesetzabstractsubrepo.matchfilesetfs~~E**r&cy)z)handle the files command for this subreporr<)r5rNmrrfmtsubreposs r$ printfileszabstractsubrepo.printfilesjsr&c |'|jDcgc] }||s |}}n|j}t|}t|}|jj t d|zt d|} | j d|D]Z} |j| } d| vxrdxsd} d| v} |j|| z| | |j| || j\| j|Scc}w) Narchiving (%s)files)unittotalrxiil) rlenrArN makeprogressrupdateraddfiler incrementcomplete)r5archiverrr rrerrrelpathprogressrflagsmodesymlinks r$archivezabstractsubrepo.archivens   $ 91aQ9E9JJLEE T"77''  7 *8E(   !DNN4(E5=*U3eDemG    tWdmmD&.I      !  %:s DDcy)zv walk recursively through the directory tree, finding all files matched by the match function Nr<)r5r s r$rWzabstractsubrepo.walkr&c ggfSrr<r5r rrdryrun interactives r$forgetzabstractsubrepo.forgets Bxr&c R|jtd|jzy)zremove the matched files from the subrepository and the filesystem, possibly by force and/or after the file has been removed from the filesystem. Return 0 on success, 1 on any warning. s)warning: removefiles not implemented (%s)r)appendrr r5rrrafterforcerr warningss r$ removefileszabstractsubrepo.removefiless'  : ;djj H r&cd|jjtd|d|dfzgS)Ns)%s: reverting %s subrepos is unsupported rrrr5rpatsrs r$revertzabstractsubrepo.reverts7  ; <{HQK( )  r&c|Srr<r5revids r$shortidzabstractsubrepo.shortids r&cy)zH convert this repository from shared to normal storage. Nr<rs r$unsharezabstractsubrepo.unsharerr&cy)a1verify the revision of this repository that is held in `_state` is present and not hidden. Return 0 on success or warning, 1 on any error. In the case of ``onpush``, warnings or errors will raise an exception if the result of pushing would be a broken remote repository. rr<)r5onpushs r$verifyzabstractsubrepo.verifys r&ctj|jjjj |j S)z@return vfs to access the working directory of this subrepository)vfsmodrrrprnr\rrs r$rnzabstractsubrepo.wvfss3zz$))..*//44TZZ@AAr&c|jjt|jj |j SzCreturn path to this subrepository as seen from outermost repository)rnr^ reporelpathrrprrs r$_relpathzabstractsubrepo._relpaths/yy  TYY^^-=!> KKr&FF)FNFrNT)(r8r9r:r4rrrPrrrrrrrrzrrrrrrrrrrrrrrrrWr rrrrr! propertycachernr'r<r&r$rrs  " 6 " """ "": ""+, ( BBLLr&rc2eZdZfdZedZdZdZdZe dZ dZ dZ d Z ed Zed Zed Zed ZedZedZed,dZed-dZdZdZedZedZedZdZed.dZedZedZedZedZ edZ!dZ"dZ#ed Z$ed/d!Z%d"Z&ed#Z'ed$Z(ed%Z)d&Z*d'Z+ed(Z,d.d)Z-e d*Z.e d+Z/xZ0S)0 hgsubrepoctt| ||||_|j }|j t j|}|xr|jjd|z }tjj|}tjjtjjt j|} | |k7r!tj t#d|zt$j'|j(|||_tjj|j*j,tjj|k7r.tj.d||j*j,fz||j1ur|j*j1|_|j*j2|_dD]B\} } |j2j5| | } | s%|j2j7| | | dD|j2j7ddd d|j9||d |y) Ns%s/.hgrjcreates9failed to reject unsafe subrepo path: %s (expanded to %s)))uiscommitsubrepossubrepor1s_usedassubreposTruer)superr-r4_staterpwjoinr localpathrnexistsosr!normcaserealpathrr r3rr repositorybaseui_repormProgrammingError unfilteredrNconfig setconfig _initrepo)r5rr!rrrrmr0 norm_root real_rootskv __class__s r$r4zhgsubrepo.__init__s i'T2 HHJwwt~~d+,DQVV]]9t3C%D!DGG$$T* GG$$RWW%5%5dood6K%LM  !++@ADH ]]188T&]A 77  DJJOO ,0@0@0F F((-04djjoo/FG    ..0DJ**--0 7DAq Aq!A!!!Q:6 7 %!2GZH q%(F+r&cXtj|jt||yr)rrr=rArs r$rzhgsubrepo.addwebdirpathsdjj*T*:GDr&c|jj5|j|cdddS#1swYyxYwr)r=lock _storecleanrs r$rzhgsubrepo.storecleans3 ZZ__  *##D) * * *s6?cd}|j|}|j|D]}|t|dk7sd}n|rt|ddu}|S)NTF)_calcstorehash_readstorehashcachenext)r5r!clean itercachefilehashs r$rMzhgsubrepo._storecleanse''- 006 H4 400  D)T1E r&c#Kd}dt|z|jj}|D]F}tt j |j |j}d||fzHyw)zcalculate a unique "store hash" This method is used to to detect when there are changes that may require a push to a given remote path.)s bookmarkssstore/phaserootssstore/00changelog.is# %s %s = %s N)r%r=rrrr)tryreadr*)r5r+filelistrrelnamerTs r$rOzhgsubrepo._calcstorehashsp O*:666jjnn 5G8==W)=>EEGHH'8!44 4 5sA5A7crtj|jjjdS)Nscache/storehash)r#rr=r\rs r$_cachestorehashvfszhgsubrepo._cachestorehashvfss%zz$**..--.@ABBr&cPt|}|jj|dS)z7read the store hash cache for a given remote repositoryr)r,r[ tryreadlines)r5r+ cachefiles r$rPzhgsubrepo._readstorehashcache s%*:6 &&33ItDDr&ct|}|jj5t|j |}|j }|j ||dddddy#1swYyxYw)zcache the current store hash Each remote repo requires its own store hash cache, because a subrepo store may be "clean" versus a given remote repo, but not versus another swbT)r notindexedN)r,r=rLlistrOr[ writelines)r5r+r_ storehashrs r$_cachestorehashzhgsubrepo._cachestorehashsi +:6 ZZ__  NT00<=I))C NN9ieN M N N Ns .addpathconfig-s8LLe !<=GG%%hUJGr&F)abortTsdefaults default-pushrVr&) r= _subparent _subsource _abssourcerwriter tonativeeolr\)r5 parentreporr0rndefpath defpushpathrms` @r$rBzhgsubrepo._initrepo%s *  &  !NE H !59G$TZZUCK *g .+%o{; JJNN $*:*:388E?*K L r&c H|jj5|jjj|j5t j ||j||||fi|cdddcdddS#1swYnxYwdddy#1swYyxYwr)r=wlockdirstatechanging_filesrrrs r$rz hgsubrepo.add:s ZZ    !4!4!C!CDJJ!O ;;         s#0B %B0 BB BB!c xtj|}d|d<|jj5|jjj |j5t j |j||||cdddcdddS#1swYnxYwdddy#1swYyxYw)NTrv)copyr=ryrzr{rr)r5rrrrs r$rzhgsubrepo.addremoveKs yy [ ZZ    !4!4!C!CDJJ!O $$         s#0B0%#B B0B$ B00B9c |jd}|j|}tj|j|j|||||fi|Sr)r4r=rrrN)r5r rrrrrgrs r$rz hgsubrepo.cat_sLkk!njjo{{ GGTZZeRV GK  r&c t |jd}|j|}|j|}|jj||fi|S#tj$rW}|j j td|t|fztjgggggggcYd}~Sd}~wwxYw)Nr*warning: error "%s" in subrepository "%s" ) r4r=rr RepoLookupErrorrNr[rrAr)r5rrrev1ctx1ctx2insts r$rzhgsubrepo.statusgs >;;q>D::d#D::d#D$4::$$T4848 8$$ > GGLL@AD)*+ >>"b"b"b"= =  >sA A B7 A B2,B72B7c x t|jd}| t|}tj||j||j||j||f|dd|y#t j $r<}|jjtd|t|fzYd}~yd}~wwxYw)NrT)r listsubreposr) rr4r diffordiffstatr=r rrNr[rrA) r5rNrrr rrnode1rs r$rzhgsubrepo.diffus  A'E E   % %  5! 5! !  $$  GGLL@AD)*+   sA'A**B9=2B44B9cP|j|jdz|j}|r|Dcgc] }||s |}}|jd}|j|}t j |j|j t j|j|fgtj||||} |jD]D} t|| d} tj| |} || zdz} | | j|| | |z } F| Scc}w)N)rrrT/)_getr4rr=r prefetchfilesrg matchfilesrrrr0r subdirmatcher)r5rrr rrrergrrsubpathrFsubmatch subprefixs r$rzhgsubrepo.archives $++()   %21qQ2E2kk!njjo JJ#'')W%7%7 E%JKL  ''hF|| FGWd+A--gu=H(4/I QYYxHfE EE  F  3s D#D#c|jd}|dk(r|sy|jd}||jjk7r|sy|j |S)Nrr&T)r)r4r=p1rrP)r5rrrCws r$rPzhgsubrepo.dirtysS KKN 8L JJt   \wwww''r&c<|jdjSN.)r=rrs r$rzhgsubrepo.basestateszz$##%%r&cj|jj|jj|Sr)r= _checknestedr5rs r$rzhgsubrepo.checknesteds&zz&&tzz'7'7'=>>r&c:|jds|jdjS|jj dt |z|jj |||}|s|jdjSt|S)NTrscommitting subrepo %s )rPr=rrNdebugrAr)r5rrrns r$rzhgsubrepo.commitszz$::d#'') )  0:d3CCD JJ  dD$ /::d#'') )1v r&cD|j|xsdjSr)r=rrs r$rzhgsubrepo.phaseszz%-4(..00r&c|jjtdt|ztj |j |j jdy)Nremoving subrepo %s F)rNnoterrArrRr=nullidrs r$rzhgsubrepo.removesB  Q/0:d3CCD TZZ..6r&c|\}}}jj}|jjvr)tjdk7s|j sy|j_t jfd}tjdk(rCjjj|j rtjrjjtdtfz|} tjjjj |jj"dd}|j%|j'_n'|j rSjj)dd} | rt+j,| } | jj)dd d } ni} jjtd tt/j0fz|} tj3jjj i|jj"d| \} } |j%| j'_j5||d j7yjjtdtt/j0fzj9} |} t;j<j||j%| rj7y#|j%wxYw#|j%wxYw#|j%wxYw)NrTcFtjjiSr)rpeerr=)r5srcurlsr$z hgsubrepo._get..s"''$**b&9r&ssharing subrepo %s from %s F)r bookmarksssharepools poolnaming)rsmodecloning subrepo %s from %s )r shareoptsr/pulling subrepo %s from %s )r=rpr?rsharedrqrrrrmtreerislocalrNrrrAsharer<rmcloserQr@rrr hidepasswordclonerBrerr pull)r5rrrevisionr|rugetpeerrrpoolrotherclonedcleansubrs` @r$rzhgsubrepo._gets!&$ZZ** tzz,,. .4::!#:+<+<+> & DJJ': tzz?a  JJNN ! ! #  "rzz&'956!$'01y !XX --44 $"' &FJJL#\\^ $$&77>>(G