|; iJ dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZmZmZddlZddlmZddlmZmZmZmZej2Gd d ej4Zee eeeeeeeefeffefZej2Gd d ej4Z ej2Gd dej4Z!d$dZ"d%dZ#d&dZ$d'dZ%d(dZ&d)dZ'd*dZ(d+dZ) d,dZ*e!jVf d-dZ,d.dZ-d.dZ. d/dZ/ee!jVdf d0dZ0 d1dZ1 d2 d3dZ2ejfde!jVdf d4d Z4d5d!Z5d6d"Z6d7d#Z7y)8aMulticast DNS Service Discovery for Python, v0.14-wmcbrine Copyright 2003 Paul Scott-Murphy, 2014 William McBrine This module provides a framework for the use of DNS Service Discovery using IP multicast. 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, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA ) annotationsN)IterableSequence)AnyUnioncast)log) _IPPROTO_IPV6 _MDNS_ADDR _MDNS_ADDR6 _MDNS_PORTceZdZdZdZy)InterfaceChoicer N)__name__ __module__ __qualname__DefaultAllF/home/ubuntu/myenv/lib/python3.12/site-packages/zeroconf/_utils/net.pyrr)s G CrrceZdZdZdZdZy)ServiceStateChangerr N)rrrAddedRemovedUpdatedrrrrr2s EGGrrceZdZdZdZdZy) IPVersionrr rN)rrrV4OnlyV6Onlyrrrrr!r!9s F F Crr!ct|dk(S)N)len)addrs r_is_v6_addressr(Cs t9?rczd|v}|rtjntj}tj||S)N:)socketAF_INET6AF_INET inet_pton)addressis_ipv6address_familys r_encode_addressr2Gs/WnG(/V__V^^N   NG 44rct|Dchc],}|jD]}|js|j.c}}Scc}}wN)listipsis_IPv4ipadaptersifacer's rget_all_addresses_ipv4r<Ms5 hUU599U4 UU VVUs A A c t|Dchc]8}|jD]'}|js|j|jf):c}}Scc}}wr4)r5r6is_IPv6r8indexr9s rget_all_addresses_ipv6r@QsF -5\E%))\$t||$''5;; \ \ \s A A cttjdtdtt j S)Nzget_all_addresses is deprecated, and will be removed in a future version. Use ifaddrdirectly instead to get a list of adapters.r  stacklevel)warningswarnDeprecationWarningr<ifaddr get_adaptersrrrget_all_addressesrIY/ MM 6  "&"5"5"7 88rcttjdtdtt j S)Nzget_all_addresses_v6 is deprecated, and will be removed in a future version. Use ifaddrdirectly instead to get a list of adapters.r rB)rDrErFr@rGrHrrrget_all_addresses_v6rLcrJrczd|vr|d|jd}tj|}|D]|}|jD]k}|jt |j t s+tj|j d|k(sQ|j |jfccS~td|)N%rz No adapter found for IP address )r? ipaddress ip_addressr6 isinstancer8tuple RuntimeError)r:r8ipaddradapter adapter_ips rip6_to_address_and_indexrWms by "((3-   ! !" %F6!++ 6J )z}}e4((q)9:fD" w}}55 66 9"> ??rc|D]M}|j|k(s|jD],}t|jts|jccSOt d|)NzNo adapter found for index )r?r6rQr8rRrS)r:r?rUrVs rinterface_index_to_ip6_addressrY~s]) ==E !%kk ) jmmU3%==( )) 4UG< ==rc:g}tj}|D]}t|tr|j t |||f1t|t sBtj|jdk(se|j t|||S)zConvert IPv6 interface addresses to interface indexes. IPv4 addresses are ignored. :param interfaces: List of IP addresses and indexes. :returns: List of indexes. ) rGrHrQintappendrYstrrOrPversionrW) interfacesresultr:r;s rip6_addresses_to_indexesrbsF""$HE eS ! MM9(EJER S s # (<(F ((( )) ) U  IIg  MM'#5! D MM+ , )) ) MM) $$ M# ?&& &&&( )) ) MM0: ; )) ) MM0: ;XYcXde  M FD !#cz!S'9i>R>RST>U>]>]ab>b!cc*622 MH STT ds8F"F1Fc |jttjdy#t$rt j dwxYw)z?Make V6 sockets work for both V4 and V6 (required for Windows).FzOSupport for dual V4-V6 sockets is not present, use IPVersion.V4 or IPVersion.V6N) setsockoptr r+ IPV6_V6ONLYOSErrorr re)ss rdisable_ipv6_only_or_raiserrs< ]F$6$6>  cd s %( Acttdsy |jtjtjdy#t $r(}|j t jk7rYd}~yd}~wwxYw)z*Set SO_REUSEADDR on a socket if available. SO_REUSEPORTNr)hasattrr+rn SOL_SOCKETrtrperrno ENOPROTOOPT)rqerrs rset_so_reuseport_if_availablerzs\ 6> * V&&(;(;Q?  99)) )  *s/A A4 A//A4c|tjk(rtjdd}tjdd}|j t j t j||j t j t j|y|tjk(rK|j tt jd|j tt jdytd)z.Set ttl/hops and loop for mDNS respond socket.BrTz)Dual-stack responder socket not supportedN)r!r"structpackrnr+ IPPROTO_IPIP_MULTICAST_TTLIP_MULTICAST_LOOPr#r IPV6_MULTICAST_HOPSIPV6_MULTICAST_LOOPrS)rqrittlloops r$set_respond_socket_multicast_optionsrs Y%%%kk$${{4# V&&(?(?E V&&(@(@$G y'' ' ]F$>$>D ]F$>$>EFGGrFctjd|||||tjk(rtj ntj }t j|tj}|tjk(r t||jtjtjdt||r!|jtjdd|d|g|dd} |j|tjd ||S#t$r}|j t j"k(rtj$d|Yd}~y|j t j&k(rkt(j*j-dst(j*j-drtj.d|tj.d |d}~wwxYw) NzNCreating new socket with port %s, ip_version %s, apple_p2p %s and bind_addr %rrirzRAddress not available when binding to %s, it is expected to happen on some systemsdarwinfreebsdzAddress in use when binding to %s; On BSD based systems sharing the same port with another stack may require processes to run with the same UID; When using avahi, make sure disallow-other-stacks is set to no in avahi-daemon.confzvAddress in use when binding to %s; When using avahi, make sure disallow-other-stacks is set to no in avahi-daemon.confzCreated socket %s)r debugr!r"r+r-r, SOCK_DGRAMrrrrnrv SO_REUSEADDRrzbindrprw EADDRNOTAVAILwarning EADDRINUSEsysplatform startswithre) bind_addrportri apple_p2p socket_familyrqbind_tupexs r new_socketrs IIX  '1I4D4D&DFNN&//M mV%6%67AY]]""1%LL""F$7$7;!!$ V&&2! d3Yqr]3H x8II!1% H9  88u** * KKd  88u'' '||&&x0CLL4K4KI4V 2  "  2  5s:D## G2,3G-$B G--G2ct|t}tjh}tj dk(r"|t ttjhz}tjd||j |r{ tjtjt}t%j&dt t(|d}||z}|j+t,tj.|ytj0t2tj0t t4|z}|j+tj6tj8| y#t $rtj"d|YywxYw#t $rP}t;|}|tj<k(rtj"d|Yd}~y|tj>k(rS|s6tj jAdrtjBd |ntjBd |Yd}~y|tjDk(rtj"d |Yd}~y||vrtj"d |Yd}~y|tjFk(rtj"d |Yd}~y|r.|tjHk(rtj"d|Yd}~yd}~wwxYw)Nwin32z(Adding %r (socket %d) to multicast groupzuUnable to translate IPv6 address when adding %s to multicast group, this can happen if IPv6 is disabled on the systemF@IrzZAddress in use when adding %s to multicast group, it is expected to happen on some systemslinuxzNo buffer space available when adding %s to multicast group, try increasing `net.ipv4.igmp_max_memberships` to `1024` in sysctl.confzS\] KKd3 ! &=> !!-1I1I9U!!     " "   T#y1 2 )U9I9Ii YbXhXhi rc|rd}ntd||}t||}|s|tjur|tj k7rl|D]&}t ttj||(tttj|||ttj|gfSg}|D]K}|s%t ttj||s*t|||}|;|j|M||fS)N))rrir)rr) rrlrrr!rrrr+rrr]) r`rrirrnormalized_interfacesrrespond_socketsrs rcreate_socketsrs  "UzU^_ 6z:N z_%<%<<y}}A\. PI fmm]!CY O P -T&---OQ[\tFMM=ABBBO*3 3D 4VXab +IT[\  %  " "> 23 / ))rc<tt|jdS)Nr)rr\args)rs rrrs QVVAY rc|rd|vSd|vS)zCheck if the address type matches the socket type. This function does not validate if the address is a valid ipv6 or ipv4 address. r*r) ipv6_socketr/s r can_send_tors )3'>@c.@@rct|trJtd|D}td|D}|r|rtjS|rtj Stj S)z3Auto detect the IP version when it is not provided.c3K|]J}t|txs4t|txr"tj|j dk(Lyw)r[N)rQr\r^rOrPr_.0rks r z(autodetect_ip_version..sJ  q#  _:a#5#^):N:Nq:Q:Y:Y]^:^ _ sAAc3K|]8}t|txr"tj|jdk(:yw)rdN)rQr^rOrPr_rs rrz(autodetect_ip_version..s6eUVZ3'PI,@,@,C,K,Kq,PPes>A)rQr5anyr!rr#r")r`has_v6has_v4s rautodetect_ip_versionrs`*d#   eZdee f== ## #   r)r'bytesreturnbool)r/r^rr)r:Iterable[ifaddr.Adapter]r list[str])r:rr&list[tuple[tuple[str, int, int], int]])rr)rr)r:rr8r^rz tuple[tuple[str, int, int], int])r:rr?r\rztuple[str, int, int])r`z6Sequence[str | int | tuple[tuple[str, int, int], int]]rr)rhInterfacesTyperir!rz,list[str | tuple[tuple[str, int, int], int]])rq socket.socketrNone)rqrrir!rr) rz!tuple[str] | tuple[str, int, int]rr\rir!rrrsocket.socket | None)rrr&str | tuple[tuple[str, int, int], int]rr)FF)rrrrrrrr) r`rrrrir!rrrz0tuple[socket.socket | None, list[socket.socket]])rrprr\)rrr/r^rr)r`rrr!)8__doc__ __future__renumrwrOr+r~rrDcollections.abcrrtypingrrrrG_loggerr constr r r runiqueEnumrr^r\rRrrr!r(r2r<r@rIrLrWrYrbr"rlrrrzrrrrrrrrrrrrrsh,#  .## FF dii   xc3eCcM6JC6O0P&P QRTccd       5 W99@">F+.5>4D4D* *(1*1*Z&HHH H>%,, ; 0; ; ;  ;  ; |N N5N Nf#5### #N"1!4!4%,, "*"* "*"* "* 6 "*J A r