6hq\SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r SSKJrJrJrJrJrJrJrJrJr SSKJrJr SS KJr \R@"S 5r!"S S \R05r""S S\"5r#"SS\RH5r%"SS5r&Sr'"SS\RPRR5r*"SS5r+"SS5r,"SS5r-"SS5r.\+\+\,\-\.S.r/Sr0S r1S&S!jr2"S"S#\Rf5r4"S$S%\Rj5r6g)') annotationsN)Optional)_)hex) encodingerrorhttpconnectionpathutilpycompaturlutilvfsworker) stringutilurlutil)lfutils\A[a-f0-9]{64}\Zc6^\rSrSrSU4SjjrSSjrSrU=r$)lfsvfs/c>[RU5(d[R"SU-5e[TU]"USSUSS/UQ76$)z9split the path at first two characters, like: XX/XXXXX...sunexpected lfs path: %srrN)_lfsrematchrProgrammingErrorsuperjoin)selfpathinsidef __class__s 5/usr/lib/python3/dist-packages/hgext/lfs/blobstore.pyr lfsvfs.join0sK||D!!(()Cd)JK Kw|D1ItABx:'::c ## [RRUR5n[ [ R "U55n/n[R"URURU=(d S5US9H]upgnXdSn[ U5S:XdMURUV s/sH%n [RXi-5(dM!Xi-PM' sn 5 M_ S/U4v gs sn f7f)zxYield (dirpath, [], oids) tuple for blobs under path Oids only exist in the root of this vfs, so dirpath is always ''. r#)onerrorNr) osrnormpathbaselenr normasprefixwalkreljoinextendrr) rrr%root prefixlenoidsdirpathdirsfilesfs r!r+ lfsvfs.walk6s ww *--d34 $&GG LLDKC 0'% G5j)G7|q  */M%Q6<< 3L[W[%M% BoNsBC3 C3/ C. C. C3)rOptional[bytes]rbytesreturnr8NN)__name__ __module__ __qualname____firstlineno__rr+__static_attributes__ __classcell__r s@r!rr/s; r#rcB\rSrSrSrS S SjjrSrS SjrS SjrSr g) nullvfsOcgNr6rs r!__init__nullvfs.__init__P r#Ncg)NFr6)rrs r!existsnullvfs.existsSsr#cd[[R[R"SU-55e)Ns%s: No such file or directory)OSErrorerrnoENOENTr sysstrroids r!read nullvfs.readVs*  LL OOrHrLrUr+r\r?r6r#r!rCrCOs  r#rCc2^\rSrSrSrU4SjrSrSrU=r$) lfsuploadfilegz+a file-like object that supports keepalive.c\>[TU]XS5 URRUlgNsrb)rrH_datarU)ruifilenamer s r!rHlfsuploadfile.__init__js! u-JJOO r#cgrFr6rGs r! _makeprogresslfsuploadfile._makeprogressnsr#)rU) r;r<r=r>__doc__rHrjr?r@rAs@r!rarags5$r#rac^\rSrSrSrSrSrSrSrSr Sr S r SS jr S r S rS rSrg)localrzLocal blobstore for large file contents. This blobstore is used both as a cache and as a staging area for large blobs to be uploaded to the remote blobstore. c@URRS5n[U5UlURR SS5(a[ 5UlO1[R"URS5n[U5UlURUlg)Ns lfs/objects experimentalslfs.disableusercachelfs) svfsrrrrf configboolrCcachevfsr _usercachedir)rrepofullpath usercaches r!rHlocal.__init__ysn99>>.1(# 77  o/F G G#IDM,,TWWf=I"9-DM''r#c8[URU5S5$)z_Open a read-only file descriptor to the named blob, in either the usercache or the local store.rb)openrrSs r!r} local.opensDIIcND))r#cURRU5(aURRU5$URRU5$)aKBuild the path for the given blob ``oid``. If the blob exists locally, the path may point to either the usercache or the local store. If it doesn't, it will point to the local store. This is meant for situations where existing code that isn't LFS aware needs to open a blob. Generally, prefer the ``open`` method on this class. )rurLrrrSs r!r local.pathsA ==   $ $==%%c* *xx}}S!!r#c[R"5nSnURUSSS9n[R"USS9H3nUR U5 UR U5 U[U5- nM5 Ub4[U5U:wa%Sn[[U5U[U5U4-5e[UR55n X:wa[[S 5U-5eSSS5 URU5 g!,(df  N =f) zfRead the blob from the remote source in chunks, verify the content, and write to this local blobstore.rwbT atomictempsizeNsEResponse length (%d) does not match Content-Length header (%d) for %sscorrupt remote lfs object: %s)hashlibsha256rr filechunkiterr\updater)r_LfsRemoteErrorrrdigestLfsCorruptionError_linktousercache) rrTsrccontent_lengthrrfpchunkmsgrealoids r!downloadlocal.downloads! XXc5TX 2b++Cg> e$E "?)c..AT.I*%QsVtS5H#.N%NOO&--/*G~(67#=/38 c"93 2s B9C== D cURUSSS9nURU5 SSS5 URU5 g!,(df  N =f)zWrite blob to local blobstore. This should only be called from the filelog during a commit or similar. As such, there is no need to verify the data. Imports from a remote store must use ``download()`` instead.rTrN)rr\r)rrTdatars r!r\ local.writesA XXc5TX 2b HHTN3 c"3 2s > A cf[UR[5(dURR U5(dqUR R [S5U-5 [R"URRU5URRU55 ggg)a_Link blobs found in the user cache into this store. The server module needs to do this when it lets the client know not to upload the blob, to ensure it is always available in this store. Normally this is done implicitly when the client reads or writes the blob, but that doesn't happen when the server tells the client that it already has the blob. lfs: found %s in the usercache N) isinstancerurCrrLrfnoterrlinkrrSs r!linkfromusercachelocal.linkfromusercachesu$--11$((//#:N:N GGLL>?#E F KK **3/s1C D;O1r#cfURRU5(d[UR[5(dqURR [ S5U-5 [R"URRU5URRU55 ggg)Ns lfs: adding %s to the usercache ) rurLrrCrfrrrrrrrSs r!rlocal._linktousercaches}}}##C(( MM72 2  GGLL?@3F G KK c*DMM,>,>s,C D 2 (r#cXURRU5(dURURX5nU(d1[ [ R "U5R55U:XapURR[S5U-5 [R"URRU5URRU55 U$URR[S5U-5 URURX5nU$)zRead blob from local blobstore.rs%lfs: found %s in the local lfs store )rrL_readrurrrrrfrrrrr)rrTverifyblobs r!rU local.readsxxs##::dmmS9DW^^D188:;sB QBCcIJ DMM..s3TXX]]35GH  GGLLDEK L::dhh4D r#cLURU5nU(a [X$5 U$)z0Read blob (after verifying) from the given store)rU_verify)rrrTrrs r!r local._readsxx}  C  r#c[R"5nURU5n[R"USS9HnUR U5 M SSS5 U[ UR55:H$!,(df  N*=f)zIIndicate whether or not the hash of the underlying file matches its name.rrN)rrr}r rrrr)rrTrrrs r!r local.verifyse! YYs^r++BW= e$>c&--/*** ^s .A99 Bc|URRU5=(d URRU5$)zQReturns True if the local blobstore contains the requested blob, False otherwise.)rurLrrSs r!has local.hass+}}##C(@DHHOOC,@@r#)rurfrN)T)r;r<r=r>rlrHr}rrr\rrrUrrrr?r6r#r!rnrnrsB * "("#H # EE$ +Ar#rncUn[UR[5(a URn[US5(aGURRSn[U[5(a[R"U5nU$[USS5(a [R"UR5$[R"U5$![ [ 4a URnNf=f)zZCreate a friendly message for the given URLError to be used in an LfsRemoteError message. reasonstrerrorN)rr ExceptionhasattrrZAttributeError IndexErrorstrr unitolocalgetattr strtolocalrr forcebytestr)urlerrorinstrs r!_urlerrorreasonr s D(//9--tX ![[%%a(F fc " "((0F z4 ( (""4==11&&x00 + ![[F !sCC-,C-c\rSrSrSrSrSrg)lfsauthhandleri%ic$URSS5nU(awUR5SnUR5S:waP[S5n[R R UR5U[R"U5UU5eg)zpEnforces that any authentication performed is HTTP Basic Authentication. No authentication is also acceptable. zwww-authenticateNrbasics,the server must support Basic Authentication) getsplitlowerrr urlerr httperror get_full_urlr strfromlocal)rreqrcoderheadersauthreqschemes r!http_error_401lfsauthhandler.http_error_401(s++0$7 ]]_Q'F||~(GHkk++$$&))#. r#r6N)r;r<r=r> handler_orderrr?r6r#r!rr%s Mr#rcJ\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _gitlfsremotei<cURnX0lUR5upEURS5UlURR SS5nU(dS[ R "5-n[R"X5U5Ul URR[55 URSS5Ul g)N/rqslfs.user-agentsgit-lfs/2.3.4 (Mercurial %s)rrsretry)rfauthinforstripbaseurlconfigr versionurlmodopener urlopener add_handlerr configintretry)rrwr rfrr useragents r!rH_gitlfsremote.__init__=s WWLLN~~d+ GGNN?4EF 7$,,.HIrY? "">#34\\&(3 r#c<UR[U5US5 g)z,Batch upload from local to remote blobstore.uploadN_batch _deduplicaterpointers fromstores r! writebatch_gitlfsremote.writebatchIs L*IyAr#c<UR[U5US5 g)z-Batch download from remote to local blostore.downloadNrrrtostores r! readbatch_gitlfsremote.readbatchMs L*G[Ar#c UVs/sH8n[R"UR55UR5S.PM: nn[R"[ R "U[R"U5S.55nSUR-n[RR[R"U5US9nURSS5 URSS5 [R"URRU55nUR!5n SSS5 [R6"W 5n UR<R>(aUR<RASWRB-5 [RD"URG55RI5nUR<RASSRK[MURO555-5 SU ;a[MU SSS9U S'UR<RAS[R"[ R "U SSSS95-5 Sn[RP"X5$s snf!,(df  GN[=f![R"R$an ['S 5URU4-['S 5UR-S .n U R)U R*['S 5Xb4-5n [-['S 5[.R0"U 5-U S9eSn A f[R"R2a<n ['S 5UR-n [-['S5[5U 5-U S9eSn A ff=f![8a' [-['S5W R;S5-5ef=f)zGet metadata about objects pointed by pointers for given action Return decoded JSON object like {'objects': [{'oid': '', 'size': 1}]} See https://github.com/git-lfs/git-lfs/blob/master/docs/api/batch.md )rTr)objects operations%s/objects/batch)rAcceptzapplication/vnd.git-lfs+json Content-TypeNs=check that lfs serving is enabled on %s and "%s" is supporteds/the "lfs.url" config may be used to override %s)isapi=%s, action=%ssLFS HTTP error: %shint LFS error: %ss#LFS server returns invalid JSON: %sutf-8 Status: %d %s  rc US$)NrTr6)ps r!-_gitlfsremote._batchrequest..sqxr#keyr)z: T)indent separators sort_keyscR[U[5(aURS5$U$)Nr)rrencode)xs r! encodestr._gitlfsremote._batchrequest..encodestrs#!S!!xx((Hr#))r strurlrTrbytesurljsondumpsrr urlreqrequest add_header contextlibclosingrr}rUrrrrrrrrrr json_loads ValueErrorr rf debugflagdebugstatusbytestrinfostriprsorted splitlinesrapply)rractionrr requestdatar batchreqrsprawjsonexhintsrresponserrs r! _batchrequest_gitlfsremote._batchrequestQs6 OOAEEG,affh ?  '' JJ&!)!8  "DLL0;;&&xs';+&NH&DEN,JK ##DNN$7$7$ABc((*C2 **73H 77   GGMM/CJJ6 7&&sxxz288:G GGMM'EJJvg6H6H6J/K$LL MH$&,Y'-?'# GGMM##JJ  #-"&    y33[ "CB{{$$ !<<( ) IJ,, E99RWWa(<&= &MND '(:+B+B2+FF {{## DE,, !"#ob&99     89..)*  sT?I<-/JJ-J6N J JJN1BL77!N7NN1OcUHnSU;a US:XaX4RS/5;aSnO#M)URS5RSS5nUVs0sHofR5U_M nnURUSS5nU(aA[US S 5nS S S SS.n U RUSU-5n [[ S5X4-5e[[ S5US-5e gs snf)zMScans errors from objects Raises LfsRemoteError if any objects have an errorserrorractionsrscodeoidNrgsunknownsThe object does not exists#The object was removed by the ownersValidation errorsInternal server error)riir1sstatus code %dsLFS server error for "%s": %ss1LFS server error. Unsolicited response for oid %s)rrTrrr) rr responsesr%r,rrptrmaprgerrorsrs r!_checkforservererror"_gitlfsremote._checkforservererrors"H x'[(V<<<.D ||H-11'3?*23(Qeegqj(F3 8F+T2A"1j*=5?,1  jj'84'?@$678/I%JKv&'A""4sC'cURS/5nURX$U5 UVs/sHoSURS/5;dMUPM nnU$s snf)zextract objects from response of the batch API response: parsed JSON object returned by batch API return response['objects'] filtered by action raise if any object has an error sobjectsr0)rr6)rr,rr%rofilteredobjectss r!_extractobjects_gitlfsremote._extractobjectss_,,z2. !!(V<  !AEE*b,A"AAw    s AAc USnUSURS5nUSURS05R5n[RR [ R "U55nUS:Xa@URU5(d*[R"[S5U-[S5S9eUH?upUR[ R "U5[ R "U 55 MA US:Xaj[URURU55UlS UlURS S 5 URS URR"5 [$R&"UR(R+U55n U R-5RS 5n URn URR.(aU R1SU R2-5 [ R4"U R-55R75nU R1SSR9[;UR=555-5 US:XaUR?XJU 5 O\/n U RAS5nU(dOU RCU5 M,SR9U 5nU(aU R1SX/4-5 SSS5 UR(aURRY5 gg!,(df  N;=f![RDRFa{nURR.(a.URR1SUURA54-5 [I[S5[JRL"U5XB4-5eSnAf[RDRNacn[S5[ RP"[RRRUU55-n[I[S5[WU5-US9eSnAff=f!UR(aURRY5 ff=f)aDownload or upload a single object using basic transfer protocol obj: dict, an object description returned by batch API action: string, one of ['upload', 'download'] localstore: blobstore.local See https://github.com/git-lfs/git-lfs/blob/master/docs/api/ basic-transfers.md r2r0shrefsheaderrdetected corrupt lfs object: %s run hg verifyrcg)NPUTr6r6r#r!r._gitlfsremote._basictransfer..sUr#rzapplication/octet-streamzContent-Lengthscontent-lengthrrrrrr#slfs %s response: %sNs%s: %s s&LFS HTTP error: %s (oid=%s, action=%s)sattempted connection to %sr)-ritemsr rrr rrrAbortrrrarfrr get_methodlengthrrrr}r rrrrr!rr"r#rrUappendrrrrrrr urllibcompat getfullurlrclose)robjr% localstorerThrefrrkvres contentlengthrfblocksrr,r*rs r!_basictransfer_gitlfsremote._basictransfers&k:v&**73j/&)--i<BBD++%%hood&;< Y $$S))kk89C?+, DA   xq18??13E F2 %",TWWjooc6JK %2""">3MN""#3W\\5H5HI##DNN$7$7$@AS # /@ A WW77$$HH_szz9:'..sxxz:@@BGHHWuzz&9K9K9M2N'OOP[(''-@F"xx0#! d+  #xx/H!76:L!LM1BT|| ""$UBA2{{$$ ww   3 "22!;<**2.<= {{## 23h6G6G!!,,W57D!"#ob&99   || ""$sXBL-!EL'L- L*&L-)Q*L--Q A6O!Q"AQQQ.Q6c ,^^^TS;a[R"ST-5eTRUT5nTRXAT5n[ SU55n0nUH&nUR SS5XxR S5'M( [ S5[ S5S.Tn [U5S :aFTRR[ S 5[U5[R"U54-5 UUU4S jn TRRS S 5(a3U4Sjn [R"TRSU S[USS9U S9n OU "[USS95n TRRU [ S5US9n U R!S5 SnSnU HJunnXU- nUS - nU R!U5 TRR[ S5U-5 ML SSS5 WS:aTS:Xa>TRR#[ S5U[R"W54-5 gTS:Xa>TRR#[ S5U[R"W54-5 ggg!,(df  N=f)N)rrsinvalid Git-LFS action: %sc3D# UHoRSS5v M g7f)sizerNr).0rs r! '_gitlfsremote._batch..6s7w!EE'1%%ws rWrr2s lfs uploadingslfs downloadingrs&lfs: need to transfer %d objects (%s) c3t># UHnURSS5nTRR(afTS:Xa [S5nOTS:Xa [S5nTRR WURS5[ R "U54-5 TRnTRUTT5 SURS54v M g![aTnUS:aHTRR [S 5[R"U5U4-5 US-nSnAMeSnAff=f7f) NrWrrslfs: downloading %s (%s) rslfs: uploading %s (%s) r2rs%lfs: failed: %r (remaining retry %d) ) rrfverboserrr bytecountrrSrOrr) rrKobjsizerrr*r%rLrs r!transfer&_gitlfsremote._batch..transferDs'''1-77??, =>9, ;<GGLLswwvw0GHH  ++CD00 # 19 GGLL !"K L#-#:#:2#>"F!G"QJE$s7B&D8*(CD8 D5!AD0)D8/D00D55D8rqslfs.worker-enablecf>TRRHn[USS5"5 M g)N close_allcgrFr6r6r#r!r7_gitlfsremote._batch..prefork..nsDr#)rhandlersr)hrs r!prefork%_gitlfsremote._batch..preforkls&00AA{L9;1r#g?r6c$URS5$Nr2rXr9s r!r&_gitlfsremote._batch..us aeeFmr#r)rhc$URS5$rkrXrls r!rrmys !%%-r#sbytes)unittotalslfs: processed: %s rslfs: uploaded %d files (%s) rslfs: downloaded %d files (%s) )rrr-r;sumrrr)rfrr r^rtrr" makeprogressrr)rrrLr%r,rrpsizesrKtopicr`rhr0progress processedblobs_onerTs` `` r!r_gitlfsremote._batch0se 1 1(()F)OP P%%h7&&x6B7w77C%(WWWa%8E''&/ ")*-.   w "   19"67dnnY789;&89dnnY789'   s A&J Jc[USS5nU(a7URH&nUR5 [USS5"5 M( gg)NrrccgrFr6r6r#r!r'_gitlfsremote.__del__..sr#)rrfrJ)rrrgs r!__del___gitlfsremote.__del__s@D+t4 '' ; 57( r#)rrrfrN)r;r<r=r>rHrrr-r6r;rSrr}r?r6r#r!rr<s8 4BBS4j'R&L%\aF8r#rc*\rSrSrSrSrSrSrSrg) _dummyremoteiz,Dummy store storing blobs to temp directory.cpURRSUR5n[U5Ulg)Nrr)rrrr)rrwr rxs r!rH_dummyremote.__init__s&88==2(#r#c[U5HZnURUR5SS9nURUR5SSS9nUR U5 SSS5 M\ g!,(df  Mn=f)NT)rrr)rrUrTrr\)rrrrcontentrs r!r_dummyremote.writebatchs^h'AnnQUUWTn:G!%%'5T:b!;:(::s A++ A: c[U5HMnURUR5S5nURUR5US5 SSS5 MO g!,(df  Ma=frd)rrrTr)rrrrrs r!r_dummyremote.readbatchsNh'A!%%'5)R  "d3*)())s "A A- )rN r;r<r=r>rlrHrrr?r6r#r!rrs6$" 4r#rc*\rSrSrSrSrSrSrSrg) _nullremoteiz&Null store storing blobs to /dev/null.cgrFr6rrwr s r!rH_nullremote.__init__rJr#cgrFr6rs r!r_nullremote.writebatchrJr#cgrFr6rs r!r_nullremote.readbatchrJr#r6Nrr6r#r!rrs0   r#rc8\rSrSrSrSrS SjrS SjrSrSr g) _promptremoteiz)Prompt user to set lfs.url when accessed.cgrFr6rs r!rH_promptremote.__init__rJr#Nc$UR5 grF_prompt)rrrrfs r!r_promptremote.writebatch  r#c$UR5 grFr)rrrrfs r!r_promptremote.readbatchrr#c@[R"[S55e)Nslfs.url needs to be configured)rrDrrGs r!r_promptremote._promptskk!=>??r#r6rF) r;r<r=r>rlrHrrrr?r6r#r!rrs3 @r#r)httpshttpsfilesnullNc[R"5nUHnX!UR5'M UR5$)z0Remove any duplicate oids that exist in the list)r sortdictrTvalues)rreducedrs r!rrs2mmoG  >> r#c[[R"U5R55nX :wa[ [ S5U-[ S5S9eg)Nr>r?r)rrrrrr)rTrrs r!rrsL'..)0023G~ 0 1C 7#$  r#c,URRSS5n[R"U=(d S5nUGcU(aUnOC[ US5(a UR nO%URRSS5=(d Sn[R"U5nUR S;aUR(a(URSS S :waU=RS - slUR=(d SS -Ul[R"[U55nURR[S 5U-5 UR nU[;a"[R"[S 5U-5e[U"X5$)aremotestore factory. return a store in _storemap depending on config If ``lfs.url`` is specified, use that remote endpoint. Otherwise, try to infer the endpoint, based on the remote repository using the same path adjustments as git. As an extension, 'http' is supported as well so that ``hg serve`` works out of the box. https://github.com/git-lfs/git-lfs/blob/master/docs/api/server-discovery.md rrsurlr#N _subtoppathspathssdefault)rrrs .git/info/lfsslfs: assuming remote store: %s slfs: unknown url scheme: %s)rfrrr rrrrr8rr _storemaprrD)rwremotelfsurlr r defaulturlrs r!rrs1WW^^FF +F ++fm $C ~ D T= ) )##D77>>(J7>3D[[&     3 3:??3B#74#?4')5#9IIJO++eJ/0C GGLL>?#E F ZZF Ykk!:;fDEE V T ''r#c\rSrSrSrg)rir6N)r;r<r=r>r?r6r#r!rrsr#rc\rSrSrSrSrg)rizzRaised when a corrupt blob is detected, aborting an operation It exists to allow specialized handling on the server side.r6N)r;r<r=r>rlr?r6r#r!rrsCr#rrF)7 __future__rrrPrrr&retypingrmercurial.i18nrmercurial.noder mercurialrrr httpconnectionmodr r r rr rvfsmodrmercurial.utilsrr largefilesrcompilerrrC httpsendfilerarnrr basehandlerrrrrrrrrr StorageErrorrrDrr6r#r!rs&#        ( )VZZ@f0%22WAWAt12T[[,,.]8]8@ 44&    @ @"        ((V U'' CCr#