^c dZ dZdZdZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z gdZded<d Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)d Z*d!Z+dZ,dZ-dZ.dZ/dZ0d"Z1d#Z2d$Z3d%Z4d&Z5d'Z6d(Z7d)Z8d*Z9d+Z:d,Z;dZd Z?e%d/e&d0e'd1e(d2e)d3e*d4iZ@ie-d5e.d6e/d7e0d8e1d9e2d:e3d;e4d<e5d=e6d>e7d?e8d@e9dAe:dBe;dCedFe?d4iZAdGZBGdHdIeCZDGdJdKeCZEGdLdMeCZFGdNdOeCZGGdPdQeCZHGdRdSeCZIGdTdUeIZJGdVdWZKGdXdYeKZLGdZd[eKZMGd\d]eMZNGd^d_eMZOGd`daeMZPGdbdceMZQGdddeeMZRGdfdgZSGdhdiZTGdjdkZUGdldme jVZWGdndoZXGdpdqe jVZYGdrdse jVZZGdtduZ[GdvdwZ\e]dxkr0e^dyee\Z_e^dzd{d|d}d~Z`e[ddejadddde`Zbe^de_cebe^de^de^dede_edde^de^de^dede_edde^de^de_febe^de_gdSdS)a Multicast DNS Service Discovery for Python, v0.12 Copyright (C) 2003, Paul Scott-Murphy This module provides a framework for the use of DNS Service Discovery using IP multicast. It has been tested against the JRendezvous implementation from StrangeBerry, and against the mDNSResponder from Mac OS X 10.3.8. This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, see . sPaul Scott-Murphys!paul at scott dash murphy dot coms0.12N)pycompat)sZeroconfs ServiceInfosServiceBrowser _GLOBAL_DONE}iz 224.0.0.251i5iii #iii@ i !sinscsschshssnonesanyasnssmdsmfscnamessoasmbsmgsmrsnullswkssptrshinfosminfosmxstxtsquadassrvc.tjdzS)z#Current system time in milliseconds)time9/usr/lib/python3/dist-packages/hgext/zeroconf/Zeroconf.pycurrentTimeMillisr(s 9;; r&ceZdZdS)NonLocalNameExceptionN__name__ __module__ __qualname__r%r&r'r*r*Dr&r*ceZdZdS)NonUniqueNameExceptionNr+r%r&r'r1r1r/r&r1ceZdZdS)NamePartTooLongExceptionNr+r%r&r'r3r3r/r&r3ceZdZdS)AbstractMethodExceptionNr+r%r&r'r5r5r/r&r5ceZdZdS)BadTypeInNameExceptionNr+r%r&r'r7r7r/r&r7ceZdZdZdS) BadDomainNamecBt|d|zdS)Nsat position %s) Exception__init__)selfposs r'r<zBadDomainName.__init__s$4!2S!899999r&N)r,r-r.r<r%r&r'r9r9s#:::::r&r9ceZdZdS)BadDomainNameCircularNr+r%r&r'r@r@r/r&r@c6eZdZdZdZdZdZdZdZdZ dS) DNSEntryz A DNS entryc||_||_||_|tz|_|t zdk|_dS)Nr)lowerkeynametype _CLASS_MASKclazz _CLASS_UNIQUEuniquer=rFrGrIs r'r<zDNSEntry.__init__s@::<<  [( },2 r&ct|tr0|j|jko|j|jko|j|jkSdS)z&Equality test on name, type, and classr) isinstancerBrFrGrIr=others r'__eq__zDNSEntry.__eq__sN eX & &  UZ'.I+.J%+-  qr&c.|| SzNon-equality testrQrOs r'__ne__zDNSEntry.__ne__;;u%%%%r&cH t|S#t$rd|zcYSwxYw)zClass accessor?(%s))_CLASSESKeyError)r=rIs r'getClazzzDNSEntry.getClazzs= $E? " $ $ $e# # # # $ !!cH t|S#t$rd|zcYSwxYw) Type accessorrX)_TYPESrZ)r=rGs r'getTypezDNSEntry.getType s< #$<  # # #d? " " " #r\cd|||j||jfz}|jr|dz }n|dz }||jz }| |d|zz }n|dz }|S)1String representation with additional informations%s[%s,%ss-unique,,Ns,%s]])r`rGr[rIrKrF)r=hdrrPresults r'toStringzDNSEntry.toStrings  LL # # MM$* % %   ;  k !FF dNF$)   go %FF dNF r&N) r,r-r.__doc__r<rQrUr[r`rgr%r&r'rBrBst333&&&$$$###r&rBc$eZdZdZdZdZdZdS) DNSQuestionzA DNS question entryct|tr|d}|dst |t ||||dS)Nasciis.local.)rNstrencodeendswithr*rBr<rLs r'r<zDNSQuestion.__init__&sg dC  (;;w''D}}Z(( .'-- -$dE22222r&c|j|jko/|j|jkp|jtko|j|jkS)z6Returns true if the question is answered by the record)rIrG _TYPE_ANYrF)r=recs r' answeredByzDNSQuestion.answeredBy-sC J#) # &ch&@$)y*@ & SX% r&c:t|ddS)String representationsquestionN)rBrgr=s r'__repr__zDNSQuestion.__repr__5s  {D999r&N)r,r-r.rhr<rsrwr%r&r'rjrj#sG333   :::::r&rjcTeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd S) DNSRecordz.A DNS record - like a DNS entry, but has a TTLctt||||||_t|_dSN)rBr<ttlr(created)r=rFrGrIr|s r'r<zDNSRecord.__init__=s4$dE222(** r&cft|trt||SdS)zTests equality as per DNSRecordr)rNryrBrQrOs r'rQzDNSRecord.__eq__Bs- eY ' ' 0??4// /qr&cJ|jD]}||rdSdS)zdReturns true if any answer in a message can suffice for the information held in this record.rr)answerssuppressedByAnswer)r=msgrecords r' suppressedByzDNSRecord.suppressedByHs<k  F&&v.. qq qr&c<||kr|j|jdz krdSdS)zwReturns true if another record has same name, type and class, and if its TTL is at least half of this record's.rrr)r|rOs r'rzDNSRecord.suppressedByAnswerPs) 5==UY$(Q,771qr&c,|j||jzdzzS)zXReturns the time at which this record will have expired by a certain percentage.rr}r|)r=percents r'getExpirationTimezDNSRecord.getExpirationTimeWs|w1B677r&cTtd|d|z dz S)z%Returns the remaining TTL in seconds.rdr#)maxrr=nows r'getRemainingTTLzDNSRecord.getRemainingTTL\s*1t--c22S8D@AAAr&c4|d|kS)z(Returns true if this record has expired.rrrs r' isExpiredzDNSRecord.isExpired`s%%c**c11r&c4|d|kS)z9Returns true if this record is at least half way expired.2rrs r'isStalezDNSRecord.isStaleds%%b))S00r&c6|j|_|j|_dS)zJSets this record's TTL and created time to that of another record.NrrOs r'resetTTLzDNSRecord.resetTTLhs} 9r&ct)zAbstract method)r5r=outs r'writezDNSRecord.writens%%r&cd|j|t|fz}t|d|S)rbs%s/%s,%ssrecord)r|rr(rBrg)r=rPargs r'rgzDNSRecord.toStringrsK H  !2!4!4 5 5      y#666r&N)r,r-r.rhr<rQrrrrrrrrrgr%r&r'ryry:s88+++  888 BBB222111 &&&77777r&ryc*eZdZdZdZdZdZdZdS) DNSAddresszA DNS address recordcPt|||||||_dSr{)ryr<address)r=rFrGrIr|rs r'r<zDNSAddress.__init__s)4tUC888 r&c`||jt|jdSz'Used in constructing an outgoing packetN) writeStringrlenrs r'rzDNSAddress.writes(  c$,&7&788888r&cPt|tr|j|jkSdS)zTests equality on addressr)rNrrrOs r'rQzDNSAddress.__eq__s( eZ ( ( 1<5=0 0qr&cd tj|jS#t$r |jcYSwxYwru)socket inet_ntoarr;rvs r'rwzDNSAddress.__repr__sC #DL11 1   <    s //Nr,r-r.rhr<rrQrwr%r&r'rr|sV999      r&rc*eZdZdZdZdZdZdZdS)DNSHinfozA DNS host information recordc^t|||||||_||_dSr{)ryr<cpuos)r=rFrGrIr|rrs r'r<zDNSHinfo.__init__s04tUC888r&c||jt|j||jt|jdSr)rrrrrs r'rzDNSHinfo.writesD #dh--000 TW.....r&cpt|tr |j|jko|j|jkSdS)zTests equality on cpu and osr)rNrrrrOs r'rQzDNSHinfo.__eq__s7 eX & & A8uy(@TW-@ @qr&c&|jdz|jzS)ru )rrrvs r'rwzDNSHinfo.__repr__sx$((r&Nrr%r&r'rrsV'' ///  )))))r&rc*eZdZdZdZdZdZdZdS) DNSPointerzA DNS pointer recordcPt|||||||_dSr{)ryr<alias)r=rFrGrIr|rs r'r<zDNSPointer.__init__s)4tUC888 r&c:||jdSr) writeNamerrs r'rzDNSPointer.writes dj!!!!!r&cPt|tr|j|jkSdS)zTests equality on aliasr)rNrrrOs r'rQzDNSPointer.__eq__s( eZ ( ( -:, ,qr&c6||jSr)rgrrvs r'rwzDNSPointer.__repr__s}}TZ(((r&Nrr%r&r'rrsV""" )))))r&rc*eZdZdZdZdZdZdZdS)DNSTextzA DNS text recordcPt|||||||_dSr{)ryr<text)r=rFrGrIr|rs r'r<zDNSText.__init__s)4tUC888 r&c`||jt|jdSr)rrrrs r'rz DNSText.writes&  3ty>>22222r&cPt|tr|j|jkSdS)zTests equality on textr)rNrrrOs r'rQzDNSText.__eq__s( eW % % +9 * *qr&ct|jdkr%||jdddzS||jS)rurNr...)rrrgrvs r'rwzDNSText.__repr__sJ ty>>B  ==2A2!788 8==++ +r&Nrr%r&r'rrsV333 ,,,,,r&rc*eZdZdZdZdZdZdZdS) DNSServicezA DNS service recordc zt|||||||_||_||_||_dSr{)ryr<priorityweightportserver) r=rFrGrIr|rrrrs r'r<zDNSService.__init__s>4tUC888     r&c||j||j||j||jdSr) writeShortrrrrrrs r'rzDNSService.writesX t}%%% t{### ty!!! dk"""""r&ct|tr@|j|jko/|j|jko|j|jko|j|jkSdS)z3Tests equality on priority, weight, port and serverr)rNrrrrrrOs r'rQzDNSService.__eq__sa eZ ( (  /0K5</0I+0K5</   qr&cJ|d|j|jfzS)rus%s:%s)rgrrrvs r'rwzDNSService.__repr__s"}}Xdi(@@AAAr&Nrr%r&r'rrs[###   BBBBBr&rcZeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdS) DNSIncomingz/Object representation of an incoming DNS packetcd|_||_g|_g|_d|_d|_d|_d|_|| | dS)z/Constructor from string holding bytes of packetrN) offsetdata questionsr numquestions numanswersnumauthoritiesnumadditionals readHeader readQuestions readOthers)r=rs r'r<zDNSIncoming.__init__su      r&cLd}tj|}tj||j|j|j|z}|xj|z c_|d|_|d|_|d|_|d|_|d|_ |d|_ dS) zReads header portion of packets!HHHHHHrrrrrrN) structcalcsizeunpackrridflagsrrrrr=formatlengthinfos r'rzDNSIncoming.readHeaders((} DIdkDK&,@@A   v q'!W  Gq'"1g"1gr&cd}tj|}td|jD]}|}tj||j|j|j|z}|xj|z c_ t||d|d}|j |#t$rYwxYwdS)z!Reads questions section of packets!HHrrN) rrrangerreadNamerrrrjrappendr*)r=rrirFrquestions r'rzDNSIncoming.readQuestionss((q$+,,  A==??D= $+ f0D"DED KK6 !KK &tT!Wd1g>>%%h////(      s7B:: CCcd}tj|}tj||j|j|j|z}|xj|z c_|dS)z Reads an integer from the packet!Irrrrrrrs r'readIntzDNSIncoming.readInt0\((} DIdkDK&,@@A   v Awr&ct|j|j}|xjdz c_||S)z(Reads a character string from the packetr)ordrr readString)r=rs r'readCharacterStringzDNSIncoming.readCharacterString:s:TYt{+,, q v&&&r&cd|z}tj|}tj||j|j|j|z}|xj|z c_|dS)z0Reads a string of a given length from the packets!%dsrr)r=rrrrs r'rzDNSIncoming.readString@s`3((} DIdkDK&,@@A   v Awr&cd}tj|}tj||j|j|j|z}|xj|z c_|dS)z'Reads an unsigned short from the packet!Hrrrs r'readUnsignedShortzDNSIncoming.readUnsignedShortJrr&c d}tj|}|j|jz|jz}t d|D]}|}tj||j|j |j |z}|xj |z c_ d}|dtkr:t||d|d|d| d}n|dtks|dtkr9t||d|d|d|}n|dt kr@t#||d|d|d| |d}n>|dt$krqt'||d|d|d||||}n|dt*krKt-||d|d|d||}n`|dt0kr9t||d|d|d| d}n|xj |dz c_ ||j|dS) z@Reads answers, authorities and additionals section of the packets!HHiHrNrrrrr )rrrrrrrrrr_TYPE_Arr _TYPE_CNAME _TYPE_PTRr _TYPE_TXTr _TYPE_SRVrr _TYPE_HINFOrr _TYPE_AAAArr)r=rrnrdomainrrrs r'rzDNSIncoming.readOthersTs(( Od1 1D4G Gq!8 )8 )A]]__F= $+ f0D"DED KK6 !KKCAw'!! DGT!Wd1gtq7I7IaK''47i+?+? DGT!Wd1gt}}aI%%DGT!Wd1gttAw7O7OaI%% GGG**,,**,,**,,MMOO  aK''GGG,,..,,.. aJ&& DGT!Wd1gtr7J7J tAw&  ##C(((q8 )8 )r&c2|jtztkS)zReturns true if this is a query)r_FLAGS_QR_MASK_FLAGS_QR_QUERYrvs r'isQueryzDNSIncoming.isQuerys ^+??r&c2|jtztkS)z"Returns true if this is a response)rr_FLAGS_QR_RESPONSErvs r' isResponsezDNSIncoming.isResponses ^+0BBBr&cL|j|||zdS)z6Reads a UTF-8 string of a given length from the packetutf-8)rdecode)r=rrs r'readUTFzDNSIncoming.readUTFs&y&3,./66w???r&cd}|j}d}|} t|j||dz}|dz }|dkrn|dz}|dkr4d||||dzf}||z }n`|dkrK|dkr|dz}|dzd zt|j||dzz}||krt ||}nt ||dkr||_n||_|S) z#Reads a domain name from the packetTrr.?r)rrrjoinrr@r9)r=rfoffnextfirstrts r'rzDNSIncoming.readNames*k )dicAg .//C 1HCaxxd ADyy&$,,sC*@*@3*F!GHHs d!887Dd q(C #a-0H,I,II%<</444#C(((# )& 199DKKDK r&N)r,r-r.rhr<rrrrrrrrr rrr%r&r'rrs99   &&& "''' =)=)=)~@@@CCC@@@r&rcteZdZdZddZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdS) DNSOutgoingz+Object representation of an outgoing packetrcd|_d|_||_||_i|_g|_d|_g|_g|_g|_ g|_ dS)Nrr) finishedr multicastrnamesrsizerr authorities additionals)r=rrs r'r<zDNSOutgoing.__init__sW "     r&c:|j|dS)zAdds a questionN)rrr=rs r' addQuestionzDNSOutgoing.addQuestions f%%%%%r&c`||s||ddSdS)zAdds an answerrN)raddAnswerAtTime)r=inprs r' addAnswerzDNSOutgoing.addAnswers>""3'' ,   + + + + + , ,r&c|9|dks||s |j||fdSdSdS)z6Adds an answer if if does not expire by a certain timeNr)rrr)r=rrs r'r'zDNSOutgoing.addAnswerAtTimesP  axxv//44x ##VSM22222  xr&c:|j|dS)zAdds an authoritative answerN)r!rr$s r'addAuthoritativeAnswerz"DNSOutgoing.addAuthoritativeAnswer '''''r&c:|j|dS)zAdds an additional answerN)r"rr$s r'addAdditionalAnswerzDNSOutgoing.addAdditionalAnswerr-r&cd}|jtj|t ||xjdz c_dS)z"Writes a single byte to the packet!crN)rrrpackchrr r=valuers r' writeBytezDNSOutgoing.writeByteB VSZZ88999 Q r&cd}|j|tj|||xjdz c_dS)z=Inserts an unsigned short in a certain position in the packetrrN)rinsertrr2r )r=indexr5rs r' insertShortzDNSOutgoing.insertShorts>  FE : :;;; Q r&cd}|jtj|||xjdz c_dS)z&Writes an unsigned short to the packetrrN)rrrr2r r4s r'rzDNSOutgoing.writeShorts< VU33444 Q r&cd}|jtj|t ||xjdz c_dS)z(Writes an unsigned integer to the packetrrN)rrrr2intr r4s r'writeIntzDNSOutgoing.writeIntr7r&cdt|zdz}|jtj|||xj|z c_dS)zWrites a string to the packet!sN)rmrrrr2r )r=r5rrs r'rzDNSOutgoing.writeStringsMs6{{"S( VU33444 V r&c|d}t|}|dkrt|||||dS)z5Writes a UTF-8 string of a given length to the packetr r N)rnrr3r6r)r=rButfstrrs r'writeUTFzDNSOutgoing.writeUTFs['""V B;;* * v (((((r&cx |j|}nz#t$rm|j|j|<|d}|ddkr |dd}|D]}|||dYdSwxYw||dz dz||dS)z"Writes a domain name to the packet.rr&Nrrr)rrZr splitrEr6)r=rFr:partsparts r'rzDNSOutgoing.writeNames Jt$EE    $yDJt JJt$$ERyCcrc  $ $ d#### NN1    FF   d*+++ us A3BBc||j||j||jdS)zWrites a question to the packetN)rrFrrGrI)r=rs r' writeQuestionzDNSOutgoing.writeQuestion*sD x}%%%  &&& '''''r&c||j||j|jr*|jr#||jtzn||j|dkr||j n(|| |t|j }|xj dz c_ |||xj dzc_ td|j |d}|||dS)zPWrites a record (answer, authoritative answer, additional) to the packetrrr&N)rrFrrGrKrrIrJr?r|rrrr rrr;)r=rrr:rs r' writeRecordzDNSOutgoing.writeRecord0s. v{###  $$$ = *T^ * OOFL=8 9 9 9 9 OOFL ) ) ) !88 MM&* % % % % MM&0055 6 6 6DI Q  T Q SXXdi/0011 '''''r&c@|js}d|_|jD]}|||jD]\}}||||jD]}||d|jD]}||d|dt|j|dt|j|dt|j|dt|j|d|j |j r|ddn|d|j d |j S)zReturns a string containing the packet's bytes No further parts should be added to the packet once this is done.rrr&)rrrLrrNr!r"r;rrrrrr)r=ranswertime_ authority additionals r'packetzDNSOutgoing.packetGs } -DM N - -""8,,,,!% 0 0   ////!- / /   A....". 0 0   Q////   QD$4 5 5 6 6 6   QD$4 5 5 6 6 6   QDL 1 1 2 2 2   QDN 3 3 4 4 4   Q + + +~ -  A&&&&  DG,,,xx """r&N)r)r,r-r.rhr<r%r)r'r,r/r6r;rr?rrErrLrNrTr%r&r'rrs55    &&&,,, 333 ((((((     )))4((( (((.#####r&rc<eZdZdZdZdZdZdZdZdZ dZ d S) DNSCachezA cache of DNS entriesci|_dSr{)cachervs r'r<zDNSCache.__init__fs  r&c |j|j}n!#t$rgx}|j|j<YnwxYw||dS)z Adds an entryN)rXrErZrr=entrylists r'addz DNSCache.addisc .:ei(DD . . .+- -D4:ei((( . Es 33cx |j|j}||dS#t$rYdSwxYw)zRemoves an entryN)rXrEremoverZrZs r'r_zDNSCache.removeqsO :ei(D KK         DD s '+ 99c |j|j}|||S#ttf$rYdSwxYw)zNGets an entry by key. Will return None if there is no matching entry.N)rXrEr:rZ ValueErrorrZs r'getz DNSCache.getysS :ei(D 5))* **%   44 s,/AAcNt|||}||S)zRGets an entry by details. Will return None if there is no matching entry.)rBrb)r=rFrGrIr[s r' getByDetailszDNSCache.getByDetailss%tU++xxr&cB |j|S#t$rgcYSwxYw)z5Returns a list of entries whose key matches the name.)rXrZ)r=rFs r'entriesWithNamezDNSCache.entriesWithNames8 :d# #   III s  c ttj|jS#t $rgcYSwxYw)zReturns a list of all entries)r\ itertoolschain from_iterablerXvaluesr;rvs r'entrieszDNSCache.entriessW  55dj6G6G6I6IJJKK K   III sAA AAN) r,r-r.rhr<r]r_rbrdrfrlr%r&r'rVrVcs   r&rVc6eZdZdZdZdZdZdZdZdZ dS) EngineacAn engine wraps read access to sockets, allowing objects that need to receive data from sockets to be called back when the sockets are ready. A reader needs a handle_read() method, which is called when the socket it is interested in is ready for reading. Writers are not implemented here, because we only send short packets. ctj|||_i|_d|_tj|_|dS)Nr) threadingThreadr<zeroconfreaderstimeout Condition conditionstartr=rrs r'r<zEngine.__init__sO!!$'''    ",.. r&cltds|}t|dkrR|j|j|j|jn tj|gg|j\}}}|D]Y} |j | ##t$r*tdstj YVwxYwn#t$rYnwxYwtddSdS)Nrr)globals getReadersrrvacquirewaitrtreleaseselectrs handle_readr; traceback print_exc)r=rsrrwrersocks r'runz Engine.runsS))O, ""B2ww!||&&(((##DL111&&(((( !'r2r4>    r&cvjtkr!jjkr|} jj}|s|nAjj=fd}j |dSnS#t$rF|sAjj<fd}j |YnwxYw d}|j kr |_ dSdSdSdS)zCallback invoked by Zeroconf when new information arrives. Updates information required by browser in the Zeroconf cache.cPj|jjSr{)r removeServicerGrxrr=s r'z-ServiceBrowser.updateRecord..:s$)D)D49fl**r&NcPj|jjSr{)r addServicerGrrs r'rz-ServiceBrowser.updateRecord..Bs$)A)A49fl**r&K) rGrrFrrrrDrr\rr;rr)r=rrrrexpired oldrecordcallbackexpiress` ` r'rzServiceBrowser.updateRecord.s~ ;) # # ty(@(@&&s++G / M&,*<*<*>*>? &&v.... fl&8&8&:&:;     HI$$X...F/ / / //:@DM&,"4"4"6"67     HI$$X...  /..r22G&& ' / $ #(@(@,'&sA;B99A D D cFd|_|jdS)Nr)rrr notifyAllrvs r'cancelzServiceBrowser.cancelKs#  !!!!!r&cN d}t}t|jdkr-|j|kr"|j|j|z t ds|jrdSt}|j|krtt}| t|j tt|jD]-}||s|||.|j|||jz|_t+d|jdz|_t|jdkr|jd}|||j)NTrri Nr)r(rr\rrrr}rzrrrr%rjrGrrrrkrr'sendrminpop)r=eventrrrs r'rzServiceBrowser.runOs %E#%%C49~~""t}s':': ""4=3#6777yy) TY #%%C}##!/22 DIy) L LMMM"m224499F!++C009++FC888 ""3''' #dj 0  DJN;; 49~~!! a(( dm$$$/ %r&N)r,r-r.rhr<rrrr%r&r'rrsZ77 $(((:"""%%%%%r&rceZdZdZ ddZdZdZdZdZd Z d Z d Z d Z d Z dZdZdZdZdZdZdZdS) ServiceInfozService informationNrc ||st||_||_||_||_||_||_|r||_n||_| |dS)aCreate a service description. type: fully qualified service type name name: fully qualified service name address: IP address as unsigned short, network byte order port: port that the service runs on weight: weight of the service priority: priority of the service properties: dictionary of properties (or a string holding the bytes for the text field) server: fully qualified name for service host (defaults to name)N) ror7rGrFrrrrr setProperties) r=rGrFrrrr propertiesrs r'r<zServiceInfo.__init__msz.}}T"" )( (         DKKDK :&&&&&r&c t|tr||_g}d}|D]p}||}|d}n7t|tr|}nt|tr|rd}nd}nd}|d||fq|D]L}d|tjdtj t||f}M||_ dS||_ dS)z7Sets properties and text of this info from a dictionaryr&Ntruefalse=r1) rNdictrrmr>rrrr2rbytechrrr)r=rr\rfrEr5suffixitems r'rzServiceInfo.setPropertiess j$ ' ' #(DODF! 6 6"3= FFs++!"FFs++!*!(!) F DIIsFm445555   E8+;CII+F+FGGDIII"DIIIr&c||_ i}t|}d}g}||krEt||}|dz }|||||z||z }||kE|D]h}|d}|dkr|} d} n*|d|} ||dzd} | dkrd} n | dks| sd} | r|| | || <i||_dS#t$rtj d|_YdSwxYw)z+Sets properties and text given a text fieldrrrrNrr) rrrrfindrbrr;rr) r=rrfendr:strsrrBeindexrEr5s r'setTextzServiceInfo.setTexts^  #Fd))CED#++T%[))  D!78999 #++  ( (R<<CEEGVG*CfqjllOE'' !(**%* !(6::c??2"'F3K$DOOO # # #   ! ! !"DOOOO #sCC$DDc|jS)r^)rGrvs r'r`zServiceInfo.getType yr&c|j[|jd|jzr9|jdt|jt|jz dz S|jS)z Name accessorNrGr)rGrFrorrvs r'getNamezServiceInfo.getNames[ 9 TY%7%7ty8H%I%I 9Bs49~~DI>BBC Cyr&c|jS)zAddress accessor)rrvs r' getAddresszServiceInfo.getAddresss |r&c|jS)z Port accessor)rrvs r'getPortzServiceInfo.getPortrr&c|jS)zPriority accessor)rrvs r' getPriorityzServiceInfo.getPrioritys }r&c|jS)zWeight accessor)rrvs r' getWeightzServiceInfo.getWeight {r&c|jS)zProperties accessor)rrvs r' getPropertieszServiceInfo.getPropertiess r&c|jS)z Text accessor)rrvs r'getTextzServiceInfo.getTextrr&c|jS)zServer accessor)rrvs r' getServerzServiceInfo.getServerrr&c D|||s|jtkr |j|jkr|j|_dSdS|jt kr|j|jkrr|j|_|j|_|j|_|j |_ | |||j |jttdSdS|jtkr0|j|jkr"||jdSdSdSdSdS)z-Updates service information from a DNS recordN)rrGrrFrrrrrrrrXrdrrrr)r=rrrrs r'rzServiceInfo.updateRecords.  f&6&6s&;&; {g%%;$+--#)>DLLL.- ));$)++"(-DK & DI"(-DK$*ODM%%  33 K) ,+ ));$)++LL-----+    &*)++r&c@t}t}||z}||z} ||t|jt t |j|j|j ||kr | |dS||krtt}| t|jtt ||j|jtt || t|jt$t ||j|jt$t ||jr| t|jt&t ||j|jt&t |||||z}|dz}|t-|||z t}|j|j|j d}| |n#| |wxYw|S)zReturns true if the service could be discovered on the network, and updates this object with details discovered. Nrrr)r(_LISTENER_TIMErrjrFrqrrrrremoveListenerrrr%rr'rXrdrrrr}r) r=rrrtrrrlastrrfs r'requestzServiceInfo.requests !!U{W}/ *  k$)Y BB    #t|';ty?P3;;N  # #D ) ) ) ) )M3;;%o66COO#DIy)DD'' 33 Iy)  OO#DIy)DD'' 33 Iy)  {.' WiHH++$N77 $ Wi  MM#&&&;D!AIE c$oo3444'))O #t|';ty?PPF  # #D ) ) ) )H # #D ) ) ) ) sAJ G%JJcPt|tr|j|jkSdS)zTests equality of service namer)rNrrFrOs r'rQzServiceInfo.__eq__Qs( e[ ) ) +:* *qr&c.|| SrSrTrOs r'rUzServiceInfo.__ne__WrVr&cd|jtj||jfz}|j|dz }n8t |jdkr ||jz }n||jdddzz }|dz }|S)russervice[%s,%s:%s,NsNonerrd)rFrrrrrrrs r'rwzServiceInfo.__repr__[s% I  T__.. / / I)   9  g FF49~~""$)#$)CRC.611$ r&)NNrrNN)r,r-r.rhr<rrr`rrrrrrrrrrrQrUrwr%r&r'rrjs6  #'#'#'#'J###@######J ...2999v &&&r&rceZdZdZddZdZdZdZdZdd Z d Z d Z e fd Z d ZdZdZdZdZdZdZdZeefdZdZdS)ZeroconfzImplementation of Zeroconf Multicast DNS Service Discovery Supports registration, unregistration, queries and browsing. Ncdtd<|+tjtj|_n||_dt f|_tjtjtj|_ |j tj tj d|j tj tj dn#t$rYnwxYw|j tjtjd|j tjtjd |j|jn#t$rYnwxYw|j tjtjtjt(tjdzg|_g|_i|_i|_t3|_t7j|_t=||_tA||_!tE||_#dS) zxCreates an instance of the Zeroconf class, establishing multicast communications, listening and reaping threads.rrNr&r0.0.0.0)$rzr gethostbyname gethostnameintfrgroupAF_INET SOCK_DGRAM setsockopt SOL_SOCKET SO_REUSEADDR SO_REUSEPORTr;SOL_IPIP_MULTICAST_TTLIP_MULTICAST_LOOPbindIP_ADD_MEMBERSHIP inet_atonr listenersbrowsersr servicetypesrVrXrprurvrnrrrrreaper)r= bindaddresss r'r<zZeroconf.__init__ss&' /"  ,V-?-A-ABBDII#DI:& mFNF4EFF   K " "6#4f6I1 M M M K " "6#4f6I1 M M M M    D  v}f.EwOOO v}f.FPPP  K  TZ ( ( ( (    D   M  $  Z ( (6+;I+F+F F     ZZ ",..Tll   Tll s%A C$$ C10C1E55 FFc6|jdS)N 127.0.0.1r startswithrvs r' isLoopbackzZeroconf.isLoopbacksy##L111r&c6|jdS)Ns169.254.rrvs r' isLinklocalzZeroconf.isLinklocalsy##K000r&c|j|j|dz |jdS)zRCalling thread waits for a given number of milliseconds or until notified.r#N)rvr|r}r~)r=rts r'r}z Zeroconf.waitsL     GdN+++      r&c|j|j|jdS)zNotifies all waiting threadsN)rvr| notify_allr~rvs r'rzZeroconf.notifyAllsD     !!###      r& cVt||}|||r|SdS)zReturns network's service information for a particular name and type, or None if no service matches by the timeout, which defaults to 3 seconds.N)rr)r=rGrFrtrs r'getServiceInfozZeroconf.getServiceInfos34&& <<g & & Ktr&c|||jt|||dS)zAdds a listener for a particular service type. This object will then have its updateRecord method called when information arrives for that type.N)removeServiceListenerrrr)r=rGrs r'addServiceListenerzZeroconf.addServiceListeners@ ""8,,, ^D$AABBBBBr&cZ|jD]"}|j|kr|~#dS)z>IIhn---+--C!"4y"@AA M0022D''" Iy)Q   ''" I%% M K I K     '' 9iDINN|++& $ WiDL   #Q,,Oa%%%% " !%r&c t}|}d}|dkr|j|jD]}|jtkr||so|j|jkr_|jddkr:d|j|j |j |jfz|_| |dSt||kr'| ||z t}ttt z}||_|t'|jtt(|t-|jtt(t.|j|||dz }|t2z }|dkdSdS)znChecks the network for a unique service name, modifying the ServiceInfo passed in if it is not unique.rrrGs %s.[%s:%d].%sNr)r(rXrfrGrrrrFrrrr)r1r}rrr*debugr%rjrr,r_DNS_TTLr _CHECK_TIME)r=rrrrrrs r'r)zZeroconf.checkServicebs !! !ee*44TY?? 1 1K9,,",,S11-  11y~~d++a//$4 I L I I 8% ))$///00X~~ (S.)))'))o 9::CDJ OOK 9iHH I I I  & &49iHdiPP    IIcNNN FA  #H;!eeeeeer&cHt}|j||c|j|jD]C}||r,||s||||D| dS)zAdds a listener for a given question. The listener will have its updateRecord method called when information is available to answer the question.N) r(rrrXrfrFrsrrr)r=rrrrs r'rzZeroconf.addListeners !! h'''  *44X]CC = =&&v..=v7G7G7L7L=))$V<<< r&c |j||dS#t$rYdSwxYw)zRemoves a listener.N)rr_rr;)r=rs r'rzZeroconf.removeListenersU  N ! !( + + + NN         DD s.2 AAcp|jD]}|||||dS)zNUsed to notify listeners of new information that has updated a record.N)rrr)r=rrrrs r'rzZeroconf.updateRecordsF 2 2H  ! !$S 1 1 1 1 r&ct}|jD]}||}||jvrQ|r|j|nN|j|}||||}n|j|| ||dS)zlDeal with incoming response packets. All answers are held in the cache, and listeners are notified.N) r(rrrXrlr_rbrr]r)r=rrrrr[s r'rzZeroconf.handleResponses !!k + +F&&s++G++----'J%%f---- JNN622E(v...!& v&&&   c6 * * * * + +r&cd}|tkrrcs0IO J;.# @4C " 0     : : : /                                  u u u u    T  e  e  e      v   e  e  e  v v    e  v! "# $v v'  2     I        Y        y        i        Y   :::::I:::      M   66666666r:::::(:::.?7?7?7?7?7?7?7?7D        2)))))y)))0)))))))),,,,,,i,,,2BBBBBBBBBAAAAAAAAH_#_#_#_#_#_#_#_#D11111111h?!?!?!?!?!Y ?!?!?!D$.$.$.$.$.$.$.$.N77777Y 777*R%R%R%R%R%Y%R%R%R%j@@@@@@@@FK K K K K K K K b z E @+NNN A E 4555}