q&fNdZddlZddlZddlZddlmZddlmZmZm Z m Z m Z m Z m ZddlmZdZdadadZd Zd ZGd d Zd ZdZdZdZdZdZe j<edee j<ejdee j<ejdee j<ejdee j<e dee j<edey)adiscover and advertise repositories on the local network The zeroconf extension will advertise :hg:`serve` instances over DNS-SD so that they can be discovered using the :hg:`paths` command without knowing the server's IP address. To allow other people to discover your repository using run :hg:`serve` in your repository:: $ cd test $ hg serve You can discover Zeroconf-enabled repositories by running :hg:`paths`:: $ hg paths zc-test = http://example.com:8000/test N)Zeroconf)dispatchencoding extensionshgpycompatrcutilui)serversships-with-hg-corec tjtjtj}|jd|j d}|S#tj $rYnwxYw tj tjdd}d|vrd}|jds|Sn+#tjtjf$rd}YnwxYw tjtjtj}|jd|j d}|S#tj $rY|SwxYw)N)1.0.0.1rr:z 127.0.0.1127.)rr) socketAF_INET SOCK_DGRAMconnect getsocknameerror gethostbyaddr gethostname startswithgaierrorherror)sipdumbips 9/usr/lib/python3/dist-packages/hgext/zeroconf/__init__.pygetipr!6s  MM&..&*;*; < .! ]]_Q  <<   %%f&8&8&:;A>qA &= F  (M) OOV]] + MM&..&*;*; < .! ]]_Q  <<  M s8AAA0/A04AB;;%C#"C#'AD??EEc HtsFt}|jdrytj|at j |atjjdd}|dz}|d|}t jdtj|dz|||d|zd t dd }tj|t jd tj|d z|||d|zd t dd }tj|y) Nr.rz.local-s_http._tcp.local.z._http._tcp.local./) descriptionspath)r port propertiesaddressweightpriority_hg._tcp.local.z._hg._tcp.local.) r r!rr inet_atonlocaliprrsplit ServiceInfor bytestrregisterService)namedescpathr'rhostnamehostsvcs r publishr9Vs  W == ""2&""2&!!#))#.q1H h D %D    445 $(4$;? C 3    223 $(4$;? C 3c|||}|j} |j}|jjdddj ddz}|D]\}}|jj } t jr0| jtjj|ddtjj|} ||zj d}| jdd} | s| } t| | |||S#t$r|j5}|j xs)tjj|j"} |jjdddj d}|jjdd} | s| } dddn #1swYnxYwt  |Y|SwxYw)Nswebsprefixr:r%s.hgshgrcr&)r'reposr configstripcopyr use_repo_hgrc readconfigosr5joinbasenamer9AttributeError _obtainreporeponameroot) create_serverr apphttpdr'r<prefixrepor5ur3r4s r zc_create_serverrOs "c "E ::D, vy#6<277#3#3DII#>D77>>&)S9??ED77>>&.9D     dD$' L-(s* DG,BF90 G9G >GGceZdZdZdZdZy)listenerci|_yN)found)selfs r __init__zlistener.__init__s  r:c`t||jvr|jt|=yyrS)reprrTrUr typer3s r removeServicezlistener.removeServices' : # 4:& $r:cT|j|||jt|<yrS)getServiceInforTrXrYs r addServicezlistener.addServices!!'!6!6tT!B 4:r:N)__name__ __module__ __qualname__rVr[r^r:r rQrQs'Cr:rQc #VKt}|jdrytj|}t}tj|d|t j d|j|jjD]}|jd|jjd}dtj|jd|j|j j#dd}d |zt%j&|fyw) Nrr,r.zhttp://rr5/zc-)r!rrrQServiceBrowsertimesleepcloserTvaluesr3indexr inet_ntoar)r'r(getr r1)rr lvaluer3urls r getzcpathsrrs B }}V   r "F A F$6:JJqM LLN!3zz2EJJ,,T23   U]] + JJ     -  tmX--c2223sD'D)c|dk(r,|jdrtD]\}}||k(s |cS||||g|i|SNpathsrfrrr)origrUsectionkeyargskwargsr3r5s r r=r=sQ(s~~f5$, JD$s{   gs 4T 4V 44r:cD|||g|i|}|dk(r |tz }|S)Nru)rr)rwrUrxrzr{r<s r configitemsr}s1 w 0 0 0E(  Lr:c||||g|i|\}}|dk(r.|jdrtD]\}} ||k(s | |fcS||fSrtrv) rwrUrxr3rzr{optsubzcnamezcurls r configsuboptionsrsdD'49$9&9HC(tv6(\ "MFE~cz! " 8Or:ctD]+\}}||k(s |jtjcS||SrS)rrencoder)rwsourcer3r5s r defaultdestrs? l2 d 6>;;x001 12 <r:c |||||trtjSS#trtjwwxYwrS)r rj)rwr optionscmdcmdfuncs r cleanupafterdispatchrs:Bg.  LLN 6 LLN s (A _runcommandr=r}rrrI)__doc__rBrrhr mercurialrrrrr r r uimodmercurial.hgwebr servermod testedwithr.r!r9rOrQrrr=r}rrr wrapfunctionrbr:r rs& 0 #   @& RD C C3&5 -1EF (F3 -= "46FG M;7  ?4DEr: