^c8ddlmZddlmZddlmZmZmZmZm Z m Z ddl m Z e j Z dZdZdZd ZGd d Zd S) )_)hex)bundle2 changegrouperror extensions revsetlangutil)commonsb2x:infinitepushc6|js!tjtdtt j|vr)tjtdtzt|tj d|j|tj |}| dt|}t||jtj|||d}i}||d<|r-||d<d|d <|j} || vrt#| ||d <t%|sd |d <g} | t jt|| | S) Nsno commits to pushsno server support for %rs%lns01spushs cgversionsbookmarks bookprevnode1spushbackbookmarks)advisoryparamsdata)missingrAbortrscratchbranchparttyper bundle2caps_validaterevsetr formatspecrsupportedoutgoingversionsdiscardmin _handlelfs makestream _bookmarksrisremotebooksenabledappend bundlepartupperitems) repopeeroutgoinguibookmarksupportedversions cgversioncgparams bookmarkspartss @/usr/lib/python3/dist-packages/hgext/infinitepush/bundleparts.pygetscratchbranchpartsr/s  4k!122333G$7$=$===k ) * *-B B    j#FH,<==x$=dCCe$$$%&&ItX%&&&  h 7 C CB F$F<?&{"%O y &))H*=&>&>F? #  # #,'+#$ E LL ! ' ' ) )!<<>>    Lrc||s!tjtd|rJ|d|}t |dkr#tjtddSdS)zAAbort if the revs to be pushed aren't valid for a scratch branch.snothing to pushs heads(%r)r s2cannot push more than one head to a scratch branchN)revsrrrlen)r#revsetr'headss r.rrMs 99V  1k!.//000 ,// u::>>+GHH   >rc tjd}|j||dS#t$rYdSwxYw)zSpecial case if lfs is enabled If lfs is enabled then we need to call prepush hook to make sure large files are uploaded to lfs slfsN)rfindwrapperuploadblobsfromrevsKeyError)r#rlfsmods r.rrZsV ((**499999 s/3 AAc&eZdZdZdZdZddZdS) copiedpartz9a copy of unbundlepart content that can be consumed laterc|j|_|j|_|j|_|j|_|j|_|j|_|j|_tj| |_ dSN) typeid mandatorymandatoryparamsrr+ mandatorykeysr stringioread_io)selfparts r.__init__zcopiedpart.__init__ksdI '#3"1k !/=--rcdSr>)rGs r.consumezcopiedpart.consumewsrNcl||jS|j|Sr>)rFrE)rGsizes r.rEzcopiedpart.readzs+ <8==?? "8==&& &rr>)__name__ __module__ __qualname____doc__rIrLrErKrr.r<r<hsLCC . . .''''''rr<N)mercurial.i18nrmercurial.noder mercurialrrrrr r r rrr/rrr<rKrr.rWs2+000f      ''''''''''r