3q,N ddlmZmZmZmZmZmZmZmZm Z ddl m Z dZ dZ e jddd d Zd Zy ) ) bundle2errorexchange extensionshg narrowspecwireprototypeswireprotov1peerwireprotov1server) narrowbundle2c6ttj_y)N)peernarrowwidenr wirepeer narrow_widen?usr/lib/python3.12/site-packages/hgext/narrow/narrowwirepeer.pyuisetuprs,;O)rcNfd}tjj|y)Nc>fd}tj|d|y)Nc|dk(r7j\}}dj||d<dj||d<||g|i|S)Nsunbundle, includepats excludepats) narrowpatsjoin)origcmdargskwargsincludeexcluderepos rwrappedz1reposetup..wirereposetup..wrappedsVk!$(?? (, '(:}%(, '(:}%-d-f- -rs_calltwowaystream)r wrapfunction)uipeerr%r$s r wirereposetupz reposetup..wirereposetups . &:GDr)rwirepeersetupfuncsappend)r$r)s` r reposetupr,s E  /r narrow_widensToldincludes oldexcludes newincludes newexcludes commonheads cgversion known ellipsesspull) permissionc d} d} | |}| |}| |}| |}|jjtjrtj|d|it j t|t j t|t j t|t j t|tj|} tj|}| dk(rd} n t| } |}tj|j} t j|j||}t j|j||}| stj| |||| ||| nt!j"| ||||| || j3}tj4|| S#t$j&$r}tj|j} d|j(fg}g}|j*|j-d|j*f| j/tj0d ||d } Yd}~d}~wwxYw) awireprotocol command to send data when a narrow clone is widen. We will be sending a changegroup here. The current set of arguments which are required: oldincludes: the old includes of the narrow copy oldexcludes: the old excludes of the narrow copy newincludes: the new includes of the narrow copy newexcludes: the new excludes of the narrow copy commonheads: list of heads which are common between the server and client cgversion(maybe): the changegroup version to produce known: list of nodes which are known on the client (used in ellipses cases) ellipses: whether to send ellipses data or not Fc,|r|jdSgS)Nr)split)datas r splitpathsz narrow_widen..splitpathsQs'+4::d# 3 3rr0)r"r#smessageNshints error:abortT)genprefer_uncompressed)r' has_sectionr_NARROWACL_SECTIONapplynarrowaclrvalidatepatternssetr decodelistboolrbundle20matchroot widen_bundler &generate_ellipses_bundle2_for_wideningrAbortmessagehintr+addpart bundlepart getchunks streamres)r$proto oldincludes oldexcludes newincludes newexcludes commonheads cgversionknownellipsespreferuncompressedr3commonbundlernewmatcholdmatchexcmanargsadvargschunkss rrr,s=D@" 4!-  -  -  -  77  x:: ;  # #D=+*F G ##C $45##C $45##C $45##C $45**;7))%0 t HH~H ""477+## II{K ## II{K      @ @ $   F  # # (:  ;;"""477+ ,- 88  NNGSXX. /**>7GLM!"sF8G##J6BI<<Jc dD]}tj||||<dD]}dj||||<dt|dz|d<|jdi|}t j |j|S)N)rOrQ)rKrMrLrNrs%irR)r-)r encodelistrr=_callcompressabler getunbundlerr')remoter!chfs rrrs&#..vbz:r 'KYYvbz*r KfZ&8!99F:   ;F;A    1 --rN) mercurialrrrrrrr r r r rr,wireprotocommandrrrrrrfsZ   < 0 $## ``F .r