8jJdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddl mZmZddlZddlmZddlmZmZmZmZejGd d ejZe eezeeeeefefzezZejGd d ejZejGd dejZ dIdZ!dJdZ"dKdZ#dLdZ$dMdZ%dNdZ&dOd!Z'dPd%Z(dQd(Z)e j*fdRd-Z+dSd1Z,dSd2Z-dTd3Z.ee j*d4fdUd:Z/dVd>Z0 dWdXd@Z1ej2d4e j*d4fdYdBZ3dZdEZ4d[dGZ5d\dHZ6dS)]aMulticast 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)Anycast)log) _IPPROTO_IPV6 _MDNS_ADDR _MDNS_ADDR6 _MDNS_PORTceZdZdZdZdS)InterfaceChoicerN)__name__ __module__ __qualname__DefaultAllI/home/user/adhan/venv/lib/python3.11/site-packages/zeroconf/_utils/net.pyrr)sG CCCrrceZdZdZdZdZdS)ServiceStateChangerrN)rrrAddedRemovedUpdatedrrrrr2s EGGGGrrceZdZdZdZdZdS) IPVersionrrrN)rrrV4OnlyV6Onlyrrrrr r 9s F F CCCrr addrbytesreturnboolc(t|dkS)N)len)r#s r_is_v6_addressr*Cs t99?raddressstrchd|v}|r tjn tj}tj||S)N:)socketAF_INET6AF_INET inet_pton)r+is_ipv6address_familys r_encode_addressr5Gs0WnG(/CV__V^N  NG 4 44radaptersIterable[ifaddr.Adapter] list[str]c4td|DS)Nc>h|]}|jD]}|j |jSr)ipsis_IPv4ip.0ifacer#s r z)get_all_addresses_ipv4..Ns0UUUU59UU4 UUUUUrlistr6s rget_all_addresses_ipv4rEMs UUhUUU V VVr&list[tuple[tuple[str, int, int], int]]c4td|DS)NcLh|]!}|jD]}|j |j|jf"Sr)r;is_IPv6r=indexr>s rrAz)get_all_addresses_ipv6..Us7\\\E%)\\$t|\$'5; \\\\rrBrDs rget_all_addresses_ipv6rKQs' \\X\\\  rcztjdtdtt jS)Nzget_all_addresses is deprecated, and will be removed in a future version. Use ifaddrdirectly instead to get a list of adapters.r stacklevel)warningswarnDeprecationWarningrEifaddr get_adaptersrrrget_all_addressesrTY? M 6  "&"5"7"7 8 88rcztjdtdtt jS)Nzget_all_addresses_v6 is deprecated, and will be removed in a future version. Use ifaddrdirectly instead to get a list of adapters.rrM)rOrPrQrKrRrSrrrget_all_addresses_v6rWcrUrr= tuple[tuple[str, int, int], int]cZd|vr|d|d}tj|}|D]b}|jD]X}|jOt |jt r5tj|jd|kr|j|jfccSYctd|)N%rz No adapter found for IP address )rJ ipaddress ip_addressr; isinstancer=tuple RuntimeError)r6r=ipaddradapter adapter_ips rip6_to_address_and_indexrcms byy "((3--   !" % %F66!+ 6 6J )z}e44*(q)9::fDD" w}555555 6 >">> ? ??rrJinttuple[str, int, int]c|D]<}|j|kr/|jD]'}t|jtr |jccS(=t d|)NzNo adapter found for index )rJr;r]r=r^r_)r6rJrarbs rinterface_index_to_ip6_addressrg~sv)) =E ! !%k ) ) jmU33)%=((((() z.normalize_interface_choice..sAcccz!S'9'9ci>RST>U>U>]ab>b>b!>b>b>brz.choice must be a list or InterfaceChoice, got )rrr r!r errorrOrPrQrlr"rrRrSextendrKrEr_r]rCro TypeError)rprrrnmessager6s rnormalize_interface_choicers<>F ((( ) ) ) U  Ig    M'#5! D D D D MM+ , , , ) ) ) MM) $ $ $ ?& & &&(( ) ) ) MM0:: ; ; ; ) ) ) MM0:: ; ; ; eYcee   FD ! !UccVccc*6222SSSTTT Mrs socket.socketNonec |ttjddS#t$rt jdwxYw)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 r{)rs rdisable_ipv6_only_or_raisersU ]F$6>>>>>  cddd s &* A cttdsdS |tjtjddS#t $r!}|jt jkrYd}~dSd}~wwxYw)z*Set SO_REUSEADDR on a socket if available. SO_REUSEPORTNr)hasattrr/r SOL_SOCKETrrerrno ENOPROTOOPT)rerrs rset_so_reuseport_if_availablers 6> * * V&(;Q?????  9) ) )  * ) ) ) ) )s+A A1A,,A1c|tjkrtjdd}tjdd}|t jt j||t jt j|dS|tj krN|tt j d|tt j ddStd)z.Set ttl/hops and loop for mDNS respond socket.BrTz)Dual-stack responder socket not supportedN)r r!structpackrr/ IPPROTO_IPIP_MULTICAST_TTLIP_MULTICAST_LOOPr"r IPV6_MULTICAST_HOPSIPV6_MULTICAST_LOOPr_)rrrttlloops r$set_respond_socket_multicast_optionsrs Y%%%k$$${4## V&(?EEE V&(@$GGGGG y' ' ' ]F$>DDD ]F$>EEEEEFGGGrF bind_addr!tuple[str] | tuple[str, int, int]port apple_p2psocket.socket | Nonectjd|||||tjkr tjn tj}t j|tj}|tjkrt|| tj tj dt||r!| tj dd|d|g|ddR} ||n#t$r}|jt jkrtjd|Yd}~dS|jt jkrit(jdst(jdrtjd|ntjd |d}~wwxYwtjd ||S) 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/r1r0 SOCK_DGRAMrrrr SO_REUSEADDRrbindrr EADDRNOTAVAILwarning EADDRINUSEsysplatform startswithr{)rrrrr socket_familyrbind_tupexs r new_socketrs IX  '1I4D&D&DFNN&/M mV%677AY]"""1%%%LL"F$7;;;!!$$$3 V&222! d3Yqrr]33H x  8u* * * Kd   44444 8u' ' '|&&x00 CL4K4KI4V4V  2   2  56I!1%%% Hs2D G*GA?GG listen_socket interface&str | tuple[tuple[str, int, int], int]ct|t}tjh}tjdkr#|t ttjhz}tj d||  |r tj tjt}n&#t $rtjd|YdSwxYwt%jdt t(|d}||z}|t,tj|nltjt2tjt t4|z}|tjtj|nR#t $rD}t;|}|tjkrtjd|Yd}~dS|tjkrR|s5tj drtj!d |ntj!d |Yd}~dS|tj"krtjd |Yd}~dS||vrtjd |Yd}~dS|tj#krtjd |Yd}~dS|r+|tj$krtjd|Yd}~dSd}~wwxYwdS)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\]]]  Kd3 ! &=&=>> !!-1I9UUUU!!    "  T#y11 2 2   )U9h9I9IXaXhiii r0tuple[socket.socket | None, list[socket.socket]]c2|rd}ntd||}t||}|s|tjur|tjkrr|D]*}t ttj||+tttj|||ttj|gfSg}|D]V}|s)t ttj||s-t|||}|| |W||fS)N))rrrr)rr) rrrrr rrrr/rrrl) rhrrrrrnormalized_interfacesrrespond_socketsrs rcreate_socketsrs= ` "UzU^___ 6z:NN Cz_%<<<y}A\A\. P PI fm]!C!CY O O O O,T&--O-OQ[\\\tFM=AABBBO*33  3D 4V4VXabb  +IT[\\\  %  " "> 2 2 2 / ))rrrcBtt|jdS)Nr)rrdargs)rs rrrs QVAY  r ipv6_socketc|rd|vnd|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)rr+s r can_send_tors ) @3'>>c.@@rct|trPtd|D}td|D}|r|r tjS|r tjStjS)z3Auto detect the IP version when it is not provided.c3K|]K}t|tp1t|totj|jdkVLdS)rkN)r]rdr,r[r\rmrxs r z(autodetect_ip_version..sh   q#   _:a#5#5#^):Nq:Q:Q:Y]^:^      rc3zK|]6}t|totj|jdkV7dS)rvNrwrxs rrz(autodetect_ip_version..sEeeUVZ3''PI,@,C,C,Kq,Peeeeeer)r]rCanyr rr"r!)rhhas_v6has_v4s rautodetect_ip_versionrs*d## $       eeZdeeeee  !f !=  $# #  r)r#r$r%r&)r+r,r%r$)r6r7r%r8)r6r7r%rF)r%r8)r%rF)r6r7r=r,r%rX)r6r7rJrdr%re)rhrir%rF)rprqrrr r%rs)rrr%r)rrrrr r%r) rrrrdrrr rr&r%r)rrrrr%r&)FF)rrrr&rr&r%r) rhrqrr&rrr rr&r%r)rrr%rd)rr&r+r,r%r&)rhrqr%r )7__doc__ __future__renumrr[r/rrrOcollections.abcrrtypingrrrR_loggerr constr r r r uniqueEnumrr,rdr^rqrr r*r5rErKrTrWrcrgror!rrrrrrrrrrrrrrrrs,#"""""  ........ FFFFFFFFFFFF     di    #)eE#sC-,@#,E&FFG/Y            5555 WWWW99999999@@@@">>>>.5>4D*****Z&HHHH>%, ; ; ; ; ; |NNNNf#####N"1!4%, "*"*"*"*"*J    AAAA      r