q&fddlmZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZdZdZe j$dd d d Zd Zy))_) stringutil) bundle2errorexchange extensionshg narrowspecwireprototypeswireprotov1peerwireprotov1server) narrowbundle2c6ttj_y)N)peernarrowwidenr wirepeer narrow_widen=/usr/lib/python3/dist-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..wrapped"sVk!$(?? (, '(:}%(, '(:}%-d-f- -r_calltwowaystream)r wrapfunction)uipeerr'r&s r wirereposetupz reposetup..wirereposetup!s . &97Cr)r wirepeersetupfuncsappend)r&r,s` r reposetupr/ s D  /r narrow_widensToldincludes oldexcludes newincludes newexcludes commonheads cgversion known ellipsesspull) permissionc @d} d} t| |}t| |}t| |}t| |}|jjtjrtj |||d} | d}| d|z } | r|j}|j |jjdxs|j}tjtd|tjt| fz| d}t!j"|t!j"|t!j"|t!j"|t%j&|}t%j&|}| dk(rd} n t)| } |}t+j,|j}t!j.|j0|| }t!j.|j0|| }| st+j2|||||||| nt5j6||||||||jC}t%jD|| S#tj$r}t+j,|j}d |j8fg}g}|j:|j=d |j:f|j?t+j@d ||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..splitpathsUs'+4::d# 3 3r)rrrrs REMOTE_USERs3The following excludes cannot be removed for %s: %s0)r$r%smessageNshints error:abortT)genprefer_uncompressed)#setr* has_sectionr_NARROWACL_SECTIONapplynarrowacl shortuserenvirongetusernamerAbortrrpprintlistr validatepatternsr decodelistboolrbundle20matchroot widen_bundler&generate_ellipses_bundle2_for_wideningmessagehintr.addpart bundlepart getchunks streamres)r&proto oldincludes oldexcludes newincludes newexcludes commonheads cgversionknownellipsespreferuncompressedr6r#requiredexcludesr*rAcommonbundlernewmatcholdmatchexcmanargsadvargschunkss rrr0sDR" 4*[12 *[12 *[12 *[12  77  x:: ;,,k+NF!/K%m4{B  WW<<JJNN>2CbkkmkkLM!2!248H3I!JKL!/K ##K0##K0##K0##K0**;7))%0 t HH~H ""477+## II{K ## II{K      @ @ $   F  # # (:  ;;"""477+ ,- 88  NNGSXX. /**>7GLM!"sII??LBLLc dD]}tj||||<dD]}dj||||<dt|dz|d<|jdi|}t j |j|S)N)rXrZ)rTrVrUrWrs%ir[)r0)r encodelistrrG_callcompressabler getunbundlerr*)remoter#chfs rrrs&;#..vbz:r ;K+YYvbz*r +fZ&8!99F:   ;F;A    1 --rN)mercurial.i18nrmercurial.utilsr mercurialrrrrr r r r r rrr/wireprotocommandrrrrrrrsb&   < 0 $## rrj .r